From d7d4cd2576474b2a97ca6576ff33fd89ebae5404 Mon Sep 17 00:00:00 2001 From: JianWeie Date: Sat, 8 Oct 2022 16:56:34 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90=E4=BC=98=E5=8C=96=E3=80=91=E4=BC=98?= =?UTF-8?q?=E5=8C=96=E5=AE=8C=E6=88=90=E8=AE=A2=E5=8D=95=E4=B8=9A=E5=8A=A1?= =?UTF-8?q?=E5=91=98=EF=BC=8C=E3=80=90=E4=BD=A3=E9=87=91=E8=AE=A1=E7=AE=97?= =?UTF-8?q?=E3=80=91=E4=BD=BF=E7=94=A8=E5=BB=B6=E8=BF=9F=E9=98=9F=E5=88=97?= =?UTF-8?q?=E5=AF=BC=E8=87=B4=E6=97=B6=E6=95=88=E6=80=A7=E4=B8=8D=E9=AB=98?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs | 5 ++--- CoreCms.Net.Services/Order/CoreCmsOrderServices.cs | 6 +++--- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs b/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs index 7163dcd2..39652881 100644 --- a/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs +++ b/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs @@ -40,11 +40,10 @@ namespace CoreCms.Net.RedisMQ } /// - /// 订单完成时，结算该订单|延迟队列 + /// 订单完成时，结算该订单 /// /// /// - //[SubscribeDelay(RedisMessageQueueKey.OrderFinishCommand)] [Subscribe(RedisMessageQueueKey.OrderFinishCommand)] private async Task OrderFinishCommand(string msg) @@ -62,7 +61,7 @@ namespace CoreCms.Net.RedisMQ await _agentOrderServices.FinishOrder(msg); NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "订单完结结佣", "订单编号获取正常：" + msg); } - + } catch (Exception ex) { diff --git a/CoreCms.Net.Services/Order/CoreCmsOrderServices.cs b/CoreCms.Net.Services/Order/CoreCmsOrderServices.cs index 2e4f666b..d271f39e 100644 --- a/CoreCms.Net.Services/Order/CoreCmsOrderServices.cs +++ b/CoreCms.Net.Services/Order/CoreCmsOrderServices.cs @@ -2147,9 +2147,9 @@ namespace CoreCms.Net.Services 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)); @@ -2272,7 +2272,7 @@ namespace CoreCms.Net.Services return jm; } #endregion - + #region 重写根据条件列表数据 /// /// 重写根据条件列表数据