tede/gx_api/GxPress/Api/GxPress.Api/WebControllers/WxpayController.cs

using GxPress.Common.WechatPay;
using GxPress.Service.Interface.Order;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using System.IO;
using System.Threading.Tasks;

namespace GxPress.Api.WebControllers
{
    [Route("api/web/wxpay")]
    [ApiController]
    [Authorize]
    public class WxpayController : Controller
    {
        private IHttpContextAccessor _contextAccessor;
        private HttpContext _context { get { return _contextAccessor.HttpContext; } }
        private IOrderService orderService;
        public WxpayController(IHttpContextAccessor contextAccessor, IOrderService orderService)
        {
            _contextAccessor = contextAccessor;
            this.orderService = orderService;
        }
        [HttpGet()]
        [AllowAnonymous]
        public string GetNativePayUrl()
        {
            var nativePay = new NativePay();
            return nativePay.GetPayUrl("637263608658642540", "汪峰讲故事", 7);
        }
        /// <summary>
        /// 回调地址
        /// </summary>
        [HttpPost("notify")]
        [AllowAnonymous]
        public async Task<string> Callback()
        {
            var contentType = Request.ContentType;
            var notifyData = await GetNotifyData();
            //检查支付结果中transaction_id是否存在
            if (!notifyData.IsSet("transaction_id"))
            {
                //若transaction_id不存在，则立即返回结果给微信支付后台
                notifyData = new WxPayData();
                notifyData.SetValue("return_code", "FAIL");
                notifyData.SetValue("return_msg", "支付结果中微信订单号不存在");
                return (notifyData.ToXml());
            }
            string transaction_id = notifyData.GetValue("transaction_id").ToString();
            //查询订单，判断订单真实性
            if (!Common.WechatPay.WxPayApi.QueryOrder(transaction_id))
            {
                //若订单查询失败，则立即返回结果给微信支付后台
                notifyData = new WxPayData();
                notifyData.SetValue("return_code", "FAIL");
                notifyData.SetValue("return_msg", "订单查询失败");
                return (notifyData.ToXml());
            }
            //查询订单成功
            else
            {
                notifyData = new WxPayData();
                //创建订单
                if (await orderService.InsertWxOrderAsync(notifyData))
                {
                    notifyData.SetValue("return_code", "SUCCESS");
                    notifyData.SetValue("return_msg", "OK");
                    return (notifyData.ToXml());
                }
            }
            notifyData = new WxPayData();
            notifyData.SetValue("return_code", "FAIL");
            notifyData.SetValue("return_msg", "支付结果中微信订单号不存在");
            return (notifyData.ToXml());
        }

        private async Task<WxPayData> GetNotifyData()
        {
            var body = string.Empty;
            //接收从微信后台POST过来的数据
            using (var reader = new StreamReader(Request.Body))
            {
                body = await reader.ReadToEndAsync();
            }
            //转换数据格式并验证签名
            WxPayData data = new WxPayData();
            if (string.IsNullOrEmpty(body))
            {
                data.SetValue("return_code", "FAIL");
                return data;
            }
            try
            {
                data.FromXml(body);
            }
            catch (WxPayException ex)
            {
                //若签名错误，则立即返回结果给微信支付后台
                WxPayData res = new WxPayData();
                res.SetValue("return_code", "FAIL");
                res.SetValue("return_msg", ex.Message);
                // Log.Error(this.GetType().ToString(), "Sign check error : " + res.ToXml());
                // page.Response.Write(res.ToXml());
                // page.Response.End();
            }
            // Log.Info(this.GetType().ToString(), "Check sign success");
            return data;
        }
    }
}