wgh/coreshoppro
1
0
Fork 0
mirror of http://git.coreshop.cn/jianweie/coreshoppro.git synced 2026-03-22 14:17:21 +08:00
Code Issues Packages Projects Releases Wiki Activity

【优化】优化完成订单业务员，【佣金计算】使用延迟队列导致时效性不高的问题。

Browse Source
This commit is contained in:
JianWeie
2022-10-08 16:56:34 +08:00
parent 1606569f06
commit d7d4cd2576
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs
View File

@@ -40,11 +40,10 @@ namespace CoreCms.Net.RedisMQ
} }
/// <summary> /// <summary>
/// 订单完成时，结算该订单|延迟队列 /// 订单完成时，结算该订单
/// </summary> /// </summary>
/// <param name="msg"></param> /// <param name="msg"></param>
/// <returns></returns> /// <returns></returns>
//[SubscribeDelay(RedisMessageQueueKey.OrderFinishCommand)]
[Subscribe(RedisMessageQueueKey.OrderFinishCommand)] [Subscribe(RedisMessageQueueKey.OrderFinishCommand)]
private async Task OrderFinishCommand(string msg) private async Task OrderFinishCommand(string msg)
@@ -62,7 +61,7 @@ namespace CoreCms.Net.RedisMQ
await _agentOrderServices.FinishOrder(msg); await _agentOrderServices.FinishOrder(msg);
NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "订单完结结佣", "订单编号获取正常：" + msg); NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "订单完结结佣", "订单编号获取正常：" + msg);
} }
} }
catch (Exception ex) catch (Exception ex)
{ {

6
CoreCms.Net.Services/Order/CoreCmsOrderServices.cs
View File

@@ -2147,9 +2147,9 @@ namespace CoreCms.Net.Services
await _orderLogServices.InsertAsync(orderLog); await _orderLogServices.InsertAsync(orderLog);
//订单完成结算订单 //订单完成结算订单
await _redisOperationRepository.SortedSetAddAsync(RedisMessageQueueKey.OrderFinishCommand, orderInfo.orderId, score); await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.OrderFinishCommand, orderInfo.orderId);
if (source== "system") if (source == "system")
{ {
// 微信自定义交易组件-订单确认收货 // 微信自定义交易组件-订单确认收货
await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.TransactionComponentOrderDeliveryRecieveSync, JsonConvert.SerializeObject(orderInfo)); await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.TransactionComponentOrderDeliveryRecieveSync, JsonConvert.SerializeObject(orderInfo));
@@ -2272,7 +2272,7 @@ namespace CoreCms.Net.Services
return jm; return jm;
} }
#endregion #endregion
#region 重写根据条件列表数据 #region 重写根据条件列表数据
/// <summary> /// <summary>
/// 重写根据条件列表数据 /// 重写根据条件列表数据