coreshoppro/CoreCms.Net.Web.WebApi/Controllers/WeChatTransactionComponentController.cs

using Microsoft.AspNetCore.Mvc;
using System.Threading.Tasks;
using CoreCms.Net.Caching.AccressToken;
using CoreCms.Net.Model.FromBody;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.WeChat.Service.HttpClients;
using Microsoft.AspNetCore.Authorization;
using SKIT.FlurlHttpClient.Wechat.Api;
using SKIT.FlurlHttpClient.Wechat.Api.Models;

namespace CoreCms.Net.Web.WebApi.Controllers
{
    /// <summary>
    /// 微信小程序自定义交易组件
    /// </summary>
    [Route("api/[controller]/[action]")]
    [ApiController]
    public class WeChatTransactionComponentController : ControllerBase
    {
        private readonly WeChat.Service.HttpClients.IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="weChatApiHttpClientFactory"></param>
        public WeChatTransactionComponentController(IWeChatApiHttpClientFactory weChatApiHttpClientFactory)
        {
            _weChatApiHttpClientFactory = weChatApiHttpClientFactory;
        }


        #region 获取用户是否订阅
        /// <summary>
        /// 获取用户是否订阅
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [Authorize]
        public async Task<WebApiCallBack> CheckScene(FMIntId entity)
        {
            var jm = new WebApiCallBack();


            //获取小程序认证
            var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
            var client = _weChatApiHttpClientFactory.CreateWxOpenClient();

            var sceneRequest = new ShopSceneCheckRequest();
            sceneRequest.AccessToken = accessToken;
            sceneRequest.Scene = entity.id;

            var sceneResponse = await client.ExecuteShopSceneCheckAsync(sceneRequest);

            jm.status = true;
            jm.data = sceneResponse;


            return jm;
        }
        #endregion



    }
}