Przeglądaj źródła

工单延时关联通话记录

qinchaoyue 5 miesięcy temu
rodzic
commit
5c1c0f6252

+ 1 - 1
src/Hotline.Application/CallCenter/DefaultCallApplication.cs

@@ -483,7 +483,7 @@ public abstract class DefaultCallApplication : ICallApplication
     {
         // 延迟一段时间后去通话记录中查询有通话音频记录文件的那通电话记录关联回工单.
         var second = _systemSettingCacheManager.VisitCallDelaySecond;
-        await _capPublisher.PublishDelayAsync(TimeSpan.FromSeconds(second), EventNames.OrderRelateCall, orderId);
+        await _capPublisher.PublishDelayAsync(TimeSpan.FromSeconds(second), EventNames.OrderRelateCall, orderId, cancellationToken: cancellationToken);
     }
 
     /// <summary>

+ 4 - 6
src/Hotline.Application/Handlers/Order/OrderRelateCallHandler.cs

@@ -16,14 +16,11 @@ namespace Hotline.Application.Handlers.Order
 {
     public class OrderRelateCallHandler : ICapSubscribe, ITransientDependency
     {
-        private readonly IOrderRepository _orderRepository;
-        private readonly IRepository<TrCallRecord> _trCallRecordRepository;
-
+        private readonly ICallApplication _callApplication;
 
-        public OrderRelateCallHandler(IOrderRepository orderRepository, IRepository<TrCallRecord> trCallRecordRepository)
+        public OrderRelateCallHandler(ICallApplication callApplication)
         {
-            _orderRepository = orderRepository;
-            _trCallRecordRepository = trCallRecordRepository;
+            _callApplication = callApplication;
         }
 
         /// <summary>
@@ -35,6 +32,7 @@ namespace Hotline.Application.Handlers.Order
         [CapSubscribe(EventNames.OrderRelateCall)]
         public async Task OrderRelateCallAsync(string orderId, CancellationToken cancellationToken)
         {
+            await _callApplication.OrderRelateCallHandlerAsync(orderId, cancellationToken);
         }
     }