瀏覽代碼

fix: 接收省平台工单处理结果重复处理业务数据,交由订阅流程事件处理

xf 11 月之前
父節點
當前提交
fdf07faed1
共有 1 個文件被更改,包括 30 次插入30 次删除
  1. 30 30
      src/Hotline.Application/Subscribers/DatasharingSubscriber.cs

+ 30 - 30
src/Hotline.Application/Subscribers/DatasharingSubscriber.cs

@@ -132,21 +132,21 @@ namespace Hotline.Application.Subscribers
 
                 if (dto.Result is 1)
                 {
-                    var now = DateTime.Now;
-                    var handleDuration = order.StartTime.HasValue
-                        ? _timeLimitDomainService.CalcWorkTime(order.StartTime.Value,
-                            now, order.ProcessType is EProcessType.Zhiban)
-                        : 0;
-                    var fileDuration = order.CenterToOrgTime.HasValue
-                        ? _timeLimitDomainService.CalcWorkTime(order.CenterToOrgTime.Value,
-                            now, order.ProcessType is EProcessType.Zhiban)
-                        : 0;
-                    var allDuration = order.StartTime.HasValue
-                        ? _timeLimitDomainService.CalcWorkTime(order.StartTime.Value, now,
-                            order.ProcessType is EProcessType.Zhiban)
-                        : 0;
-                    order.File(now, handleDuration, fileDuration, allDuration);
-                    await _orderRepository.UpdateAsync(order, cancellationToken);
+                    //var now = DateTime.Now;
+                    //var handleDuration = order.StartTime.HasValue
+                    //    ? _timeLimitDomainService.CalcWorkTime(order.StartTime.Value,
+                    //        now, order.ProcessType is EProcessType.Zhiban)
+                    //    : 0;
+                    //var fileDuration = order.CenterToOrgTime.HasValue
+                    //    ? _timeLimitDomainService.CalcWorkTime(order.CenterToOrgTime.Value,
+                    //        now, order.ProcessType is EProcessType.Zhiban)
+                    //    : 0;
+                    //var allDuration = order.StartTime.HasValue
+                    //    ? _timeLimitDomainService.CalcWorkTime(order.StartTime.Value, now,
+                    //        order.ProcessType is EProcessType.Zhiban)
+                    //    : 0;
+                    //order.File(now, handleDuration, fileDuration, allDuration);
+                    //await _orderRepository.UpdateAsync(order, cancellationToken);
 
                     var current = SessionContextCreator.CreateSessionContext(dto.Source);
                     if (string.IsNullOrEmpty(order.WorkflowId))
@@ -526,21 +526,21 @@ namespace Hotline.Application.Subscribers
                     break;
             }
 
-            var now = DateTime.Now;
-            var handleDuration = order.StartTime.HasValue
-                ? _timeLimitDomainService.CalcWorkTime(order.StartTime.Value,
-                    now, order.ProcessType is EProcessType.Zhiban)
-                : 0;
-            var fileDuration = order.CenterToOrgTime.HasValue
-                ? _timeLimitDomainService.CalcWorkTime(order.CenterToOrgTime.Value,
-                    now, order.ProcessType is EProcessType.Zhiban)
-                : 0;
-            var allDuration = order.StartTime.HasValue
-                ? _timeLimitDomainService.CalcWorkTime(order.StartTime.Value, now,
-                    order.ProcessType is EProcessType.Zhiban)
-                : 0;
-            order.File(now, handleDuration, fileDuration, allDuration);
-            await _orderRepository.UpdateAsync(order, cancellationToken);
+            //var now = DateTime.Now;
+            //var handleDuration = order.StartTime.HasValue
+            //    ? _timeLimitDomainService.CalcWorkTime(order.StartTime.Value,
+            //        now, order.ProcessType is EProcessType.Zhiban)
+            //    : 0;
+            //var fileDuration = order.CenterToOrgTime.HasValue
+            //    ? _timeLimitDomainService.CalcWorkTime(order.CenterToOrgTime.Value,
+            //        now, order.ProcessType is EProcessType.Zhiban)
+            //    : 0;
+            //var allDuration = order.StartTime.HasValue
+            //    ? _timeLimitDomainService.CalcWorkTime(order.StartTime.Value, now,
+            //        order.ProcessType is EProcessType.Zhiban)
+            //    : 0;
+            //order.File(now, handleDuration, fileDuration, allDuration);
+            //await _orderRepository.UpdateAsync(order, cancellationToken);
         }
 
         /// <summary>