tangjiang 10 months ago
parent
commit
ebc7702fea

+ 2 - 0
src/DataSharing.YiBin/Enterprise/EnterprisePusherProviderService.cs

@@ -157,6 +157,8 @@ namespace DataSharing.YiBin.Enterprise
 
                     if (dto.SendTimes >= 7)
                         dto.State = EWaitSendTaskState.PushFail;
+                    else
+                        dto.State = EWaitSendTaskState.WaitPush;
 
                     await _waitSendTaskOtherPlatformsRepository.UpdateAsync(dto, cancellationToken);
                 }

+ 2 - 0
src/DataSharing.YiBin/ZzptPlatformsYB/ZzptPusherProviderService.cs

@@ -101,6 +101,8 @@ namespace DataSharing.YiBin.ZzptPlatformsYB
 
                         if (dto.SendTimes >= 7)
                             dto.State = EWaitSendTaskState.PushFail;
+                        else
+                            dto.State = EWaitSendTaskState.WaitPush;
 
                         await _waitSendTaskOtherPlatformsRepository.UpdateAsync(dto, cancellationToken);
                     }

+ 2 - 0
src/DataSharing/CityStateDataExchange/CityStateDataExchangePusherProviderService.cs

@@ -100,6 +100,8 @@ namespace DataSharing.CityStateDataExchange
 
                     if (dto.SendTimes >= 7)
                         dto.State = EWaitSendTaskState.PushFail;
+                    else
+                        dto.State = EWaitSendTaskState.WaitPush;
 
                     await _dsSendTaskRepository.UpdateAsync(dto, cancellationToken);
                 }

+ 2 - 0
src/DataSharing/Province/SendTask/TaskProvinceOtherJob.cs

@@ -146,6 +146,8 @@ namespace DataSharing.Province.SendTask
 
                                 if (sendTask.SendTimes >= 7)
                                     sendTask.State = EWaitSendTaskState.PushFail;
+                                else
+                                    sendTask.State = EWaitSendTaskState.WaitPush;
 
                                 await _waitSendTaskProvinceOtherRepository.UpdateAsync(sendTask, context.CancellationToken);
                             }

+ 2 - 0
src/DataSharing/Province/SendTask/TaskSubmitCaseInfoJob.cs

@@ -146,6 +146,8 @@ namespace DataSharing.Province.SendTask
 
                                 if (item.SendTimes >= 7)
                                     item.State = EWaitSendTaskState.PushFail;
+                                else
+                                    item.State = EWaitSendTaskState.WaitPush;
 
                                 //修改待推送表
                                 await _waitSendTaskSubmitCaseInfoRepository.UpdateAsync(item, context.CancellationToken);

+ 2 - 0
src/DataSharing/Province/SendTask/TaskSubmitCaseProcessJob.cs

@@ -136,6 +136,8 @@ namespace DataSharing.Province.SendTask
 
                                 if (item.SendTimes >= 7)
                                     item.State = EWaitSendTaskState.PushFail;
+                                else
+                                    item.State = EWaitSendTaskState.WaitPush;
 
                                 //修改待推送表
                                 await _waitSendTaskSubmitCaseProcessRepository.UpdateAsync(item, context.CancellationToken);

+ 2 - 0
src/DataSharing/Province/SendTask/TaskSubmitCaseRecordJob.cs

@@ -143,6 +143,8 @@ namespace DataSharing.Province.SendTask
 
                                 if (item.SendTimes >= 7)
                                     item.State = EWaitSendTaskState.PushFail;
+                                else
+                                    item.State = EWaitSendTaskState.WaitPush;
 
                                 //修改待推送表
                                 await _waitSendTaskSubmitCaseRecordRepository.UpdateAsync(item, context.CancellationToken);

+ 2 - 0
src/DataSharing/Province/SendTask/TaskSubmitCaseResultJob.cs

@@ -136,6 +136,8 @@ namespace DataSharing.Province.SendTask
 
                                 if (item.SendTimes >= 7)
                                     item.State = EWaitSendTaskState.PushFail;
+                                else
+                                    item.State = EWaitSendTaskState.WaitPush;
 
                                 //修改待推送表
                                 await _waitSendTaskSubmitCaseResultRepository.UpdateAsync(item, context.CancellationToken);