发帖
翼度科技»论坛 › 编程开发 › .net › 查看内容

微信支付--JSAPI支付(微信小程序和微信公众号支付都可以采用该方式)

張魁

4

主题

4

帖子

12

积分

新手上路

Rank: 1

积分
12
显示全部楼层
本实例使用了工具包SKIT.FlurlHttpClient.Wechat.TenpayV3（github:https://github.com/fudiwei/DotNetCore.SKIT.FlurlHttpClient.Wechat）
示例中的_repositoryWrapper的相关使用是我们业务中的业务代码，使用者可以根据自己的业务自行删除。
1、生成预支付订单(供前端调用，返回的信息供小程序端或公众号端调起微信支付).
  1. public async Task<PayTransactionDto> GeneratePrePaidOrder(PrePaidOrderRequestDto orderBasic)
  2.         {
  3.             string orderStatus = await _repositoryWrapper.OrderRepository.QueryOrderStatusAsync(orderBasic.OrderId);
  4.             //订单已取消||订单已支付
  5.             if (orderStatus == OrderStatus.Cancel.ToString("D")
  6.                 || orderStatus == OrderStatus.PaySuccess.ToString("D"))
  7.             {
  8.                 PayTransactionDto payTransaction = new()
  9.                 {
  10.                     OrderStatus = orderStatus,
  11.                 };
  12.                 return payTransaction;
  13.             }
  14.             //string serialNumber = RSAUtility.ExportSerialNumber(@"D:\1630126864_20220905_cert\apiclient_cert.pem");
  15.             var manager = new InMemoryCertificateManager();
  16.             var options = new WechatTenpayClientOptions()
  17.             {
  19.                 MerchantId = _config["MerchantId"],//商户号
  20.                 MerchantV3Secret = _config["MerchantV3Secret"],//商户API v3密钥
  21.                 MerchantCertificateSerialNumber = _config["MerchantCertificateSerialNumber"],//商户API证书序列号
  22.                 MerchantCertificatePrivateKey = FileContentHelper.ReadFileContent("apiclient_key.pem", Path.Combine(AppContext.BaseDirectory, "apiclient_key.pem")),//商户API证书私钥
  23.                 PlatformCertificateManager = manager // 证书管理器的具体用法请参阅下文的高级技巧与加密、验签有关的章节
  24.             };
  25.             var client = new WechatTenpayClient(options);
  27.             /* 以 JSAPI 统一下单接口为例 */
  28.             //var userLogin = await _userService.UserLogin(orderBasic.JSCode);
  29.             Log.Information("OpenId is " + orderBasic.OpenId);
  30.             Log.Information("OrderId is " + orderBasic.OrderId);
  31.             IEnumerable<OrderDetailEntity> orderList = await _repositoryWrapper.OrderRepository.GetOrderPriceAndQty(orderBasic.OrderId);
  32.             int total = 0;
  33.             foreach (OrderDetailEntity orderDetail in orderList)
  34.             {
  35.                 total += orderDetail.TicketTypePrice * 100 * orderDetail.Qty;
  36.             }
  37.             total = (int)(total - orderBasic.UseWalletAmount * 100);
  38.             long orderNumber = await _repositoryWrapper.OrderRepository.QueryOrderNumberByOrderIdAsync(orderBasic.OrderId);
  40.             var request = new CreatePayTransactionJsapiRequest()
  41.             {
  42.                 OutTradeNumber = orderNumber.ToString(),
  43.                 AppId = _config["EmscnplAppId"],//微信 AppId
  44.                 Description = $"订单号为{orderNumber}",
  45.                 ExpireTime = DateTimeOffset.Now.AddSeconds(200),
  46.                 NotifyUrl = _config["wechatPayNotifyUrl"],//回调地址
  47.                 Amount = new()
  48.                 {
  49.                     Total = total
  50.                     //Total = 1
  51.                 },
  52.                 Payer = new()
  53.                 {
  54.                     OpenId = orderBasic.OpenId
  55.                     //OpenId = "oLS5G5C9C2KZuYo-Y9HhyyP-RiFs"
  56.                 },
  57.                 Attachment = orderBasic.UseWalletAmount.ToString(),
  58.             };
  59.             //var response = await client.ExecuteCreatePayTransactionH5Async(request);
  60.             var response = await client.ExecuteCreatePayTransactionJsapiAsync(request);
  61.             Log.Information("response ExecuteCreatePayTransactionJsapiAsync {@response}", response);
  62.             if (response.IsSuccessful())
  63.             {
  64.                 //Console.WriteLine("PrepayId：" + response.PrepayId);
  65.                 //var collection = ExtractQueryParams(response.H5Url);
  66.                 //var prepayId = collection["prepay_id"];
  67.                 //var package= collection["package"];
  68.                 var paramMap = client.GenerateParametersForJsapiPayRequest(request.AppId, response.PrepayId);
  69.                 Log.Information("response paramMap {@paramMap}", paramMap);
  70.                 PayTransactionDto payTransaction = new()
  71.                 {
  72.                     WechatpayNonce = paramMap["nonceStr"],
  73.                     WechatpaySignature = paramMap["paySign"],
  74.                     WeChatPrepayId = response.PrepayId,
  75.                     TimeStamp = paramMap["timeStamp"],
  76.                     SignType = paramMap["signType"],
  77.                     Package = paramMap["package"],
  78.                     OrderStatus = orderStatus,
  79.                 };
  80.                 Log.Information("payTransaction information {@payTransaction}", payTransaction);
  81.                 await _repositoryWrapper.OrderRepository.UpdateOrderStatusAsync(new Contract.OrderStatusDto
  82.                 {
  83.                     OrderId = orderBasic.OrderId,
  84.                     OrderStatus = OrderStatus.PrePay.ToString("D")
  85.                 });
  86.                 await _repositoryWrapper.RedPackageRepository.BatchUpdateRedPackeStatus(orderBasic.VoucherId, orderBasic.WeChatId, orderBasic.OrderId, RedpackageUseEnum.Lock);
  87.                 await _repositoryWrapper.OrderRepository.BindWechatId(orderBasic.OrderId, orderBasic.WeChatId);
  88.                 return payTransaction;
  89.             }
  90.             else
  91.             {
  92.                 throw new Exception("ExecuteCreatePayTransactionJsapiAsync call return fail");
  93.             }
  94.         }
复制代码
2、支付完成后的回调方法处理
   Controller方法：
  1. /// <summary>
  2.         /// 支付成功后的回调函数
  3.         /// </summary>
  4.         /// <param name="timestamp"></param>
  5.         /// <param name="nonce"></param>
  6.         /// <param name="signature"></param>
  7.         /// <param name="serialNumber"></param>
  8.         /// <returns></returns>
  9.         [HttpPost("WeChatPayNotifyUrl", Name = "WeChatPayNotifyUrl")]
  10.         public async Task WeChatPayNotifyUrl(
  11.             [FromHeader(Name = "Wechatpay-Timestamp")] string timestamp,
  12.             [FromHeader(Name = "Wechatpay-Nonce")] string nonce,
  13.             [FromHeader(Name = "Wechatpay-Signature")] string signature,
  14.             [FromHeader(Name = "Wechatpay-Serial")] string serialNumber)
  15.         {
  16.             // 接收服务器推送
  17.             // 文档：https://pay.weixin.qq.com/wiki/doc/apiv3/wechatpay/wechatpay4_2.shtml
  19.             using var reader = new StreamReader(Request.Body, Encoding.UTF8);
  20.             string content = await reader.ReadToEndAsync();
  21.             Log.Information("Wechatpay-Timestamp data is {@content}", content);
  22.             Log.Information("Wechatpay-Nonce {@nonce}", nonce);
  23.             Log.Information("Wechatpay-Signature {@signature}", signature);
  24.             Log.Information("Wechatpay-Serial {@serialNumber}", serialNumber);
  25.             _weChatAppService.ParseNotifyData(timestamp, nonce, content, signature, serialNumber);
  26.            
  27.         }
复制代码
Service方法：
  1. public async void ParseNotifyData(string timeStamp, string nonce, string content, string signature, string serialNumber)
  2.         {
  3.             var manager = new InMemoryCertificateManager();
  4.             var options = new WechatTenpayClientOptions()
  5.             {
  6.                 MerchantId = _config["MerchantId"],//商户号
  7.                 MerchantV3Secret = _config["MerchantV3Secret"],//商户API v3密钥
  8.                 MerchantCertificateSerialNumber = _config["MerchantCertificateSerialNumber"],//商户API证书序列号
  9.                 MerchantCertificatePrivateKey = FileContentHelper.ReadFileContent("apiclient_key.pem", Path.Combine(AppContext.BaseDirectory, "apiclient_key.pem")),//商户API证书私钥
  10.                 PlatformCertificateManager = manager // 证书管理器的具体用法请参阅下文的高级技巧与加密、验签有关的章节
  11.             };
  12.             var client = new WechatTenpayClient(options);
  13.             var request = new QueryCertificatesRequest();
  14.             var response = await client.ExecuteQueryCertificatesAsync(request);
  15.             if (response.IsSuccessful())
  16.             {
  17.                 response = client.DecryptResponseSensitiveProperty(response);
  18.                 foreach (var certificateModel in response.CertificateList)
  19.                 {
  20.                     manager.AddEntry(new CertificateEntry(certificateModel));
  21.                 }
  22.                 Log.Information("查询微信商户平台证书成功。");
  23.             }
  24.             bool valid = client.VerifyEventSignature(timeStamp, nonce, content, signature, serialNumber, out Exception? error);
  25.             if (valid)
  26.             {
  27.                 /* 将 JSON 反序列化得到通知对象 */
  28.                 /* 你也可以将 WechatTenpayEvent 类型直接绑定到 MVC 模型上，这样就不再需要手动反序列化 */
  29.                 var callbackModel = client.DeserializeEvent(content);
  30.                 if ("TRANSACTION.SUCCESS".Equals(callbackModel.EventType))
  31.                 {
  32.                     /* 根据事件类型，解密得到支付通知敏感数据 */
  33.                     var callbackResource = client.DecryptEventResource<TransactionResource>(callbackModel);
  34.                     string outTradeNumber = callbackResource.OutTradeNumber;
  35.                     string transactionId = callbackResource.TransactionId;
  36.                     Log.Information("回调返回的解密数据为{@callbackResource}", callbackResource);
  37.                     Console.WriteLine("订单 {0} 已完成支付，交易单号为 {1}", outTradeNumber, transactionId);
  38.                     Log.Information("outTradeNumber is " + outTradeNumber);
  39.                     Log.Information("outTradeNumber is " + transactionId);
  41.                     #region[存取支付结果]
  43.                     string boxCode = await GetBoxCodeByOrderNumber(Convert.ToInt64(outTradeNumber));
  44.                     //解绑机器;
  45.                     await _repositoryWrapper.UserBoxRepository.UnBindBox(boxCode);
  46.                     var orderId = await _repositoryWrapper.OrderRepository.QueryOrderIdByOrderNumberAsync(Convert.ToInt64(outTradeNumber));
  47.                     Log.Information("Update order pay result");
  48.                     await _repositoryWrapper.OrderRepository.SavePayResult(new OrderEntity()
  49.                     {
  50.                         OrderId = orderId,
  51.                         OutTradeNo = Int64.Parse(outTradeNumber),
  52.                         TradeState = callbackResource.TradeState,
  53.                         TradeStateDesc = callbackResource.TradeStateDescription,
  54.                         BankType = callbackResource.BankType,
  55.                         Total = callbackResource.Amount.Total,
  56.                         OpenId = callbackResource.Payer.OpenId,
  57.                         PayTotal = callbackResource.Amount.PayerTotal,
  58.                         TransactionId = callbackResource.TransactionId,
  59.                         SuccessTime = callbackResource.SuccessTime.ToString()
  61.                     });
  62.                     #endregion
  63.                     Log.Information("Update order pay status");
  64.                     if (!String.IsNullOrWhiteSpace(callbackResource.Attachment))
  65.                     {
  66.                         decimal walletAmount = 0m;
  67.                         if (Decimal.TryParse(callbackResource.Attachment, out walletAmount) && walletAmount > 0)
  68.                         {
  69.                             string weChatId = await _repositoryWrapper.OrderRepository.QueryWeChatIdByOrderId(orderId);
  70.                             await _repositoryWrapper.WalletRepository.PayUseWallet(new List<long>(), orderId, weChatId, walletAmount, false, true);
  71.                         }
  72.                     }
  73.                     await _repositoryWrapper.OrderRepository.UpdateOrderStatusByOrderNumberAsync(Convert.ToInt64(outTradeNumber), OrderStatus.PaySuccess.ToString("D"), (decimal)callbackResource.Amount.PayerTotal / 100);
  74.                     await _repositoryWrapper.RedPackageRepository.BatchUpdateRedPackeStatus(orderId, RedpackageUseEnum.Used);
  76.                 }
  77.                 else
  78.                 {
  79.                     /* 根据事件类型，解密得到支付通知敏感数据 */
  80.                     var callbackResource = client.DecryptEventResource<TransactionResource>(callbackModel);
  81.                     string outTradeNumber = callbackResource.OutTradeNumber;
  83.                     JObject obj = new();
  84.                     obj.Add("action", "payFail");
  85.                     var payFailStr = JsonConvert.SerializeObject(obj);
  86.                     await _repositoryWrapper.OrderRepository.UpdateOrderStatusByOrderNumberAsync(Convert.ToInt64(outTradeNumber), OrderStatus.PayFail.ToString("D"), (decimal)callbackResource.Amount.PayerTotal / 100);
  87.                 }
  88.             }
  89.             else
  90.             {
  91.                 Log.Error("Verify fail");
  92.                 Log.Error("Verify fail is {@error}", error);
  93.             }
  94.         }
复制代码
3、查询支付结果
  1. _orderService是我们业务中使用的service,使用方可自行根据自身业务删除。
复制代码
  1. public async Task<PayResultDto> QueryOrderPayStatus(OrderBaseDto orderBasic)
  2.         {
  3.             PayResultDto payResultDto = new PayResultDto();
  4.             string orderStatus = await _repositoryWrapper.OrderRepository.QueryOrderStatusAsync(orderBasic.OrderId);
  5.             if (orderStatus != null)
  6.             {
  7.                 OrderStatus orderEnumStatus = OrderStatus.UnDefine;
  8.                 if (System.Enum.TryParse(orderStatus, out orderEnumStatus) && orderEnumStatus == OrderStatus.PaySuccess)
  9.                 {
  10.                     payResultDto.PaySuccess = true;
  11.                     payResultDto.ContributionAmount = await _orderService.GetOrderContributionAsync(orderBasic.OrderId); ;
  12.                     return payResultDto;
  13.                 }
  15.             }
  16.             //string serialNumber = RSAUtility.ExportSerialNumber(@"D:\1630126864_20220905_cert\apiclient_cert.pem");
  17.             var manager = new InMemoryCertificateManager();
  18.             var options = new WechatTenpayClientOptions()
  19.             {
  21.                 MerchantId = _config["MerchantId"],//商户号
  22.                 MerchantV3Secret = _config["MerchantV3Secret"],//商户API v3密钥
  23.                 MerchantCertificateSerialNumber = _config["MerchantCertificateSerialNumber"],//商户API证书序列号
  24.                 MerchantCertificatePrivateKey = FileContentHelper.ReadFileContent("apiclient_key.pem", Path.Combine(AppContext.BaseDirectory, "apiclient_key.pem")),//商户API证书私钥
  25.                 PlatformCertificateManager = manager // 证书管理器的具体用法请参阅下文的高级技巧与加密、验签有关的章节
  26.             };
  27.             var client = new WechatTenpayClient(options);
  29.             /* 以 JSAPI 统一下单接口为例 */
  30.             //var userLogin = await _userService.UserLogin(orderBasic.JSCode);
  31.             Log.Information("OrderId is " + orderBasic.OrderId);
  32.             long orderNumber = await _repositoryWrapper.OrderRepository.QueryOrderNumberByOrderIdAsync(orderBasic.OrderId);
  33.             var request = new GetPayTransactionByOutTradeNumberRequest()
  34.             {
  35.                 OutTradeNumber = orderNumber.ToString(),
  36.                 MerchantId = _config["MerchantId"],//商户号
  37.                 WechatpayCertificateSerialNumber = _config["MerchantCertificateSerialNumber"]//商户API证书序列号
  38.             };
  39.             var response = await client.ExecuteGetPayTransactionByOutTradeNumberAsync(request);
  40.             Log.Information("response {@response}", response);
  41.             if (response.IsSuccessful() && response.TradeState == "SUCCESS")
  42.             {
  43.                 int payTotal = response.Amount.Total;
  44.                 Console.WriteLine("pay amount：" + payTotal);
  45.                 Log.Information($"QueryOrder order {orderNumber} payTotal is {payTotal}");
  46.                 if (payTotal > 0)
  47.                 {
  48.                     await _repositoryWrapper.OrderRepository.UpdateOrderStatusAsync(new OrderStatusDto()
  49.                     {
  50.                         OrderId = orderBasic.OrderId,
  51.                         OrderStatus = OrderStatus.PaySuccess.ToString("D"),
  52.                     });
  53.                     payResultDto.PaySuccess = true;
  54.                     payResultDto.ContributionAmount = await _orderService.GetOrderContributionAsync(orderBasic.OrderId);
  55.                     //payResultDto.Amount = payTotal/100m;
  56.                 }
  57.             }
  58.             else
  59.             {
  60.                 Log.Information($"response.RawStatus is {response.RawStatus}");
  61.                 Log.Information($"response.ErrorCode is {response.ErrorCode},response.ErrorMessage is {response.ErrorMessage}");
  62.                 //throw new Exception($"QueryOrder call return fail,orderNumber is {orderNumber}");
  63.             }
  64.             return payResultDto;
  65.         }
复制代码
 
出处：https://www.cnblogs.com/cby-love本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须在文章页面给出原文连接,否则保留追究法律责任的权利.如果您觉得文章对您有帮助,可以点击文章右下角"推荐".您的鼓励是作者坚持原创和持续写作的最大动力!
来源:https://www.cnblogs.com/cby-love/archive/2023/01/05/17026424.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！

上一篇: pve虚拟机Vmware安装教程

下一篇: 那些年我们用过的组件-结构化日志组件 Serilog

发表于 2023-1-5 06:48:46

举报 回复 使用道具

返回列表 发新帖

Archiver|手机版|小黑屋|翼度科技

Copyright © 2001-2020, Tencent Cloud.　Powered by Discuz! X3.4