From 557c2711a3e103ebc3d0492344eca9730d5e92b2 Mon Sep 17 00:00:00 2001
From: 移动系统liao <liaoxujun@qq.com>
Date: 星期一, 17 二月 2025 10:47:47 +0800
Subject: [PATCH] 增加司机配送单超时处理任务，防止一直不停手机定位信息，
---
CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs b/CoreCms.Net.RedisMQ/OrderFinishCommandSubscribe.cs
index 6961144..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>
@@ -63,6 +67,8 @@
await _agentOrderServices.FinishOrder(msg);
//閭�璇疯姹傛ā寮忎笅杩涜鍒嗕剑锛屼細妫�娴嬫槸鍚﹀紑鍚簡涓夌骇鍒嗛攢鍜屼唬鐞嗘ā寮忋��
await _userServices.InviteCommission(msg);
+ //澶勭悊缁忛攢鍟嗗彂璐ф敹鐩婂垎閰嶈褰曞埌浣欓鍐�
+ await _distributorDeliveryServices.FinishOrder(msg);
NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "璁㈠崟瀹岀粨缁撲剑", "璁㈠崟缂栧彿鑾峰彇姝ｅ父锛�" + msg);
}
--
Gitblit v1.9.1