From 18a8fab394f764e5b30c48c8e0d6887ef7d44cbf Mon Sep 17 00:00:00 2001
From: username@email.com <yzy2002yzy@163.com>
Date: 星期二, 29 十月 2024 14:22:49 +0800
Subject: [PATCH] 取消拆单
---
CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs b/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs
index 22deb48..d73b545 100644
--- a/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs
+++ b/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs
@@ -2,6 +2,7 @@
using System.Threading.Tasks;
using CoreCms.Net.Configuration;
using CoreCms.Net.IServices;
+using CoreCms.Net.IServices.baifenbingfa;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Utility.Extensions;
@@ -27,9 +28,11 @@
private readonly ICoreCmsSettingServices _settingServices;
private readonly ICoreCmsUserServices _userServices;
private readonly ICoreCmsAgentOrderServices _agentOrderServices;
+ private readonly IDistributorDeliveryServices _distributorDeliveryServices;
- public OrderFinishCommandSubscribe(ICoreCmsBillPaymentsServices billPaymentsServices, ICoreCmsDistributionOrderServices distributionOrderServices, ICoreCmsDistributionServices distributionServices, ICoreCmsSettingServices settingServices, ICoreCmsUserServices userServices, ICoreCmsAgentOrderServices agentOrderServices)
+ public OrderFinishCommandSubscribe(ICoreCmsBillPaymentsServices billPaymentsServices, ICoreCmsDistributionOrderServices distributionOrderServices, ICoreCmsDistributionServices distributionServices, ICoreCmsSettingServices settingServices, ICoreCmsUserServices userServices, ICoreCmsAgentOrderServices agentOrderServices,
+ IDistributorDeliveryServices distributorDeliveryServices)
{
_billPaymentsServices = billPaymentsServices;
_distributionOrderServices = distributionOrderServices;
@@ -37,6 +40,7 @@
_settingServices = settingServices;
_userServices = userServices;
_agentOrderServices = agentOrderServices;
+ _distributorDeliveryServices= distributorDeliveryServices;
}
/// <summary>
@@ -57,12 +61,14 @@
}
else
{
- //瀵瑰凡缁忚鍏ュ垎閿�浣ｉ噾璁㈠崟琛ㄩ噷闈㈢殑鏁版嵁杩涜鍌ㄥ�煎埌鍒嗛攢鍟嗕綑棰濆唴銆�
+ //瀵瑰凡缁忚鍏ュ垎閿�浣ｉ噾璁㈠崟琛ㄩ噷闈㈢殑鏁版嵁杩涜鍌ㄥ�煎埌缁忛攢鍟嗕綑棰濆唴銆�
await _distributionOrderServices.FinishOrder(msg);
//瀵瑰凡缁忚鍏ヤ唬鐞嗗晢浣ｉ噾璁㈠崟琛ㄩ噷闈㈢殑鏁版嵁杩涜鍌ㄥ�煎埌浠ｇ悊鍟嗕綑棰濆唴銆�
await _agentOrderServices.FinishOrder(msg);
//閭�璇疯姹傛ā寮忎笅杩涜鍒嗕剑锛屼細妫�娴嬫槸鍚﹀紑鍚簡涓夌骇鍒嗛攢鍜屼唬鐞嗘ā寮忋��
await _userServices.InviteCommission(msg);
+ //澶勭悊缁忛攢鍟嗗彂璐ф敹鐩婂垎閰嶈褰曞埌浣欓鍐�
+ await _distributorDeliveryServices.FinishOrder(msg);
NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "璁㈠崟瀹岀粨缁撲剑", "璁㈠崟缂栧彿鑾峰彇姝ｅ父锛�" + msg);
}
--
Gitblit v1.9.1