TANG JIANG 1 year ago
parent
commit
658728378e
1 changed files with 6 additions and 1 deletions
  1. 6 1
      src/DataSharing/Province/PusherProviderService.cs

+ 6 - 1
src/DataSharing/Province/PusherProviderService.cs

@@ -87,11 +87,16 @@ namespace DataSharing.Province
             if (dto is null)
                 return;
 
+            var configProvince = _channelConfigurationManager.GetConfigurationProvince();
+            if (configProvince.SendTaskStartTime > dto.GenerationTime)
+            {
+                dto.IsSuccess = true;
+                await _dsSendTaskRepository.UpdateAsync(dto, cancellationToken);
+            }
             var name = GetName(dto.Path);
 
             _logger.LogWarning("省请求参数:" + "--------------" + dto.Request);
             ProvinceResponse result = new();
-            var configProvince = _channelConfigurationManager.GetConfigurationProvince();
             if (dto.PathType == EPathType.HuiJu) //汇聚推送
                 result = await _huiJuClient.RequestAsync<ProvinceResponse>(configProvince.HuiJu + dto.Path, dto.HttpMethod, dto.Request, cancellationToken);