mirror of
http://git.coreshop.cn/jianweie/coreshoppro.git
synced 2025-12-06 19:53:27 +08:00
05df55d7ec
### 1.3.5 开源社区版（会员专业版同步修改）： 无 ### 0.1.5 会员专业版： 【升级】nuget升级常用组件到最新版本。 【修复】服务商品列表图片组件从image调整为u--image组件。#I4RUC6 【优化】规范coreshop-goods.vue组件for循环未定义key的问题。 【修复】修复因升级uview版本导致【商品选项卡goodTabBar组件】切换失效的问题。 【新增】微信自定义交易组件增加【商品审核结果回调】，【类目审核结果回调】微信服务器消息推送处理。 【优化】调整自定义交易组件sku价格为decimal(18, 2)类型，方便小数处理。 【优化】微信自定义交易组件增加图片同步至微信侧功能。 【优化】重命名一些方法名称大小写。 【新增】首页设计轮播图增加高度设置功能。#I4SWEA 【修复】优化在苹果6/7/8plus及安卓一些机型出现分享海报弹窗文字被遮挡的问题。#I4SWCA
102 lines
4.0 KiB
C#
102 lines
4.0 KiB
C#
/***********************************************************************
|
|
* Project: CoreCms
|
|
* ProjectName: 核心内容管理系统
|
|
* Web: https://www.corecms.net
|
|
* Author: 大灰灰
|
|
* Email: jianweie@163.com
|
|
* CreateTime: 2021/7/10 22:41:46
|
|
* Description: 暂无
|
|
***********************************************************************/
|
|
|
|
|
|
using System;
|
|
using System.Threading.Tasks;
|
|
using CoreCms.Net.Caching.AccressToken;
|
|
using CoreCms.Net.Configuration;
|
|
using CoreCms.Net.IServices;
|
|
using CoreCms.Net.Loging;
|
|
using CoreCms.Net.Model.Entities;
|
|
using CoreCms.Net.WeChat.Service.HttpClients;
|
|
using InitQ.Abstractions;
|
|
using InitQ.Attributes;
|
|
using Newtonsoft.Json;
|
|
using SKIT.FlurlHttpClient.Wechat.Api;
|
|
using SKIT.FlurlHttpClient.Wechat.Api.Models;
|
|
|
|
namespace CoreCms.Net.RedisMQ.Subscribe
|
|
{
|
|
/// <summary>
|
|
/// 自定义交易组件-同步订单状态
|
|
/// </summary>
|
|
public class TCPayOrderSyncSubscribe : IRedisSubscribe
|
|
{
|
|
private readonly ICoreCmsUserWeChatInfoServices _userWeChatInfoServices;
|
|
private readonly WeChat.Service.HttpClients.IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;
|
|
|
|
|
|
|
|
|
|
public TCPayOrderSyncSubscribe(ICoreCmsUserWeChatInfoServices userWeChatInfoServices, IWeChatApiHttpClientFactory weChatApiHttpClientFactory)
|
|
{
|
|
_userWeChatInfoServices = userWeChatInfoServices;
|
|
_weChatApiHttpClientFactory = weChatApiHttpClientFactory;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 自定义交易组件-同步订单状态
|
|
/// </summary>
|
|
/// <param name="msg"></param>
|
|
/// <returns></returns>
|
|
[Subscribe(RedisMessageQueueKey.TransactionComponentPayOrderSync)]
|
|
private async Task TransactionComponentPayOrderSync(string msg)
|
|
{
|
|
try
|
|
{
|
|
var orderModel = JsonConvert.DeserializeObject<CoreCmsOrder>(msg);
|
|
if (orderModel is { scene: > 0 })
|
|
{
|
|
//获取小程序认证
|
|
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
|
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
|
|
|
var userInfo = await _userWeChatInfoServices.QueryByClauseAsync(p => p.userId == orderModel.userId);
|
|
if (userInfo != null)
|
|
{
|
|
var payment = orderModel.paymentItem[0];
|
|
|
|
//获取同步地址接口地址
|
|
var request = new ShopOrderPayRequest();
|
|
request.AccessToken = accessToken;
|
|
request.OutOrderId = orderModel.orderId;
|
|
request.OpenId = userInfo.openid;
|
|
request.ActionType = 1;
|
|
request.TransactionId = payment.tradeNo;
|
|
request.PayTime = payment.createTime;
|
|
|
|
var response = await client.ExecuteShopOrderPayAsync(request);
|
|
NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "自定义交易组件-同步订单状态", JsonConvert.SerializeObject(response));
|
|
}
|
|
else
|
|
{
|
|
NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "自定义交易组件-同步订单状态", "微信用户数据获取失败");
|
|
}
|
|
}
|
|
else
|
|
{
|
|
NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "自定义交易组件-同步订单状态", "商品获取失败");
|
|
}
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "自定义交易组件-同步订单状态", msg, ex);
|
|
throw;
|
|
}
|
|
await Task.CompletedTask;
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|