tangjiang 10 月之前
父節點
當前提交
4e08b85ffe

+ 11 - 8
src/DataSharing/Province/SendTask/TaskSubmitCaseInfoJob.cs

@@ -188,15 +188,18 @@ namespace DataSharing.Province.SendTask
                             await _sendTaskDetailInfoRepository.AddAsync(dsSendTaskDetailInfo, context.CancellationToken);
                             #endregion
 
-                            #region 处理工单的上传时间,用于统计
-                            var order = await _orderSendRepository.GetAsync(p => p.ProvinceNo == item.ProvinceNo, context.CancellationToken);
-                            if (order != null)
+                            #region 上传成功后,处理工单的上传时间,用于统计
+                            if (!isError)
                             {
-                                if (order.FirstSendProvinceTime is null)
-                                    order.FirstSendProvinceTime = DateTime.Now;
-
-                                order.LastSendProvinceTime = DateTime.Now;
-                                await _orderSendRepository.UpdateAsync(order, context.CancellationToken);
+                                var order = await _orderSendRepository.GetAsync(p => p.ProvinceNo == item.ProvinceNo, context.CancellationToken);
+                                if (order != null)
+                                {
+                                    if (order.FirstSendProvinceTime is null)
+                                        order.FirstSendProvinceTime = DateTime.Now;
+
+                                    order.LastSendProvinceTime = DateTime.Now;
+                                    await _orderSendRepository.UpdateAsync(order, context.CancellationToken);
+                                }
                             }
                             #endregion
                         }

+ 12 - 9
src/DataSharing/Province/SendTask/TaskSubmitCaseRecordJob.cs

@@ -185,16 +185,19 @@ namespace DataSharing.Province.SendTask
                             await _sendTaskDetailInfoRepository.AddAsync(dsSendTaskDetailInfo, context.CancellationToken);
                             #endregion
 
-                            #region 处理通话记录的上传时间,用于统计
-                            //处理通话记录的上传时间,用于统计
-                            var telCall = await _dsTelCallRepository.GetAsync(p => p.TaskId == item.Id, context.CancellationToken);
-                            if (telCall != null)
+                            #region 上传成功后,处理通话记录的上传时间,用于统计
+                            if (!isError)
                             {
-                                if (telCall.FirstSendProvinceTime is null)
-                                    telCall.FirstSendProvinceTime = DateTime.Now;
-
-                                telCall.LastSendProvinceTime = DateTime.Now;
-                                await _dsTelCallRepository.UpdateAsync(telCall, context.CancellationToken);
+                                //处理通话记录的上传时间,用于统计
+                                var telCall = await _dsTelCallRepository.GetAsync(p => p.TaskId == item.Id, context.CancellationToken);
+                                if (telCall != null)
+                                {
+                                    if (telCall.FirstSendProvinceTime is null)
+                                        telCall.FirstSendProvinceTime = DateTime.Now;
+
+                                    telCall.LastSendProvinceTime = DateTime.Now;
+                                    await _dsTelCallRepository.UpdateAsync(telCall, context.CancellationToken);
+                                }
                             }
                             #endregion
                         }