Bläddra i källkod

修改12315定时拉取数据

tangjiang 6 månader sedan
förälder
incheckning
10866275e1
1 ändrade filer med 14 tillägg och 0 borttagningar
  1. 14 0
      src/DataSharing/Province/SendTask/TaskCaseDistrecordJob.cs

+ 14 - 0
src/DataSharing/Province/SendTask/TaskCaseDistrecordJob.cs

@@ -106,11 +106,19 @@ namespace DataSharing.Province.SendTask
 
                     var response = await _xieTongClient.RequestAsync<ProvinceDistrecordResponse>(url, "Post", jsonData, context.CancellationToken);
 
+                    _logger.LogError($"工单:{itemData.CaseSerial},请求的结果:-------------" + System.Text.Json.JsonSerializer.Serialize(response));
+
                     if (response is null || response.status is null || response.custom is null)
                         continue;
 
+                    //如果没有成功,修改为待读取
                     if (response.status.code != "1")
+                    {
+                        itemData.State = "0";
+                        await _sendCaseInfoRepository.UpdateAsync(itemData, cancellationToken: context.CancellationToken);
                         continue;
+                    }
+
 
                     //这里处理业务
                     if (response.custom.STEP_List != null && response.custom.STEP_List.Count > 0)
@@ -218,6 +226,12 @@ namespace DataSharing.Province.SendTask
                         #endregion
                     }
 
+                    if (itemData.IsEnd == false)
+                    {
+                        itemData.State = "0";
+                        await _sendCaseInfoRepository.UpdateAsync(itemData, cancellationToken: context.CancellationToken);
+                    }
+
                     Thread.Sleep(2000);
                 }
             }