src/DataSharing/Province/SendTask/TaskSubmitCaseInfoJob.cs

@@ -70,6 +70,8 @@ namespace DataSharing.Province.SendTask
            .Take(100)
            .ToListAsync(context.CancellationToken);
 
+            _logger.LogWarning("业务汇聚-服务工单受理读取数据条数--------------------------------------" + tasks.Count);
+
             if (tasks.Count != 0)
             {
                 #region 处理请求参数
@@ -88,18 +90,17 @@ namespace DataSharing.Province.SendTask
                     if (await _waitSendTaskSubmitCaseInfoRepository.Updateable(sendTask).ExecuteCommandWithOptLockAsync() > 0)
                     {
                         //组装这一条数据
-                        if (sendTask.RequestData != null)
-                        {
-                            listOrder.Add(sendTask.RequestData);
-                            taskData.Add(sendTask);
-                        }
+                        listOrder.Add(sendTask.RequestData);
+                        taskData.Add(sendTask);
                     }
                 }
+                _logger.LogWarning("业务汇聚-服务工单受理锁定条数--------------------------------------" + taskData.Count);
 
                 if (listOrder != null && listOrder.Count > 0)
                 {
                     request.SetData(listOrder);
                     var jsonData = request.ToString();
+                    _logger.LogWarning("业务汇聚-服务工单受理请求参数--------------------------------------" + jsonData);
                     ProvinceResponse result = new();
                     string error = "";
                     //执行推送任务
@@ -111,7 +112,7 @@ namespace DataSharing.Province.SendTask
                     {
                         error = ex.Message;
                     }
-
+                    _logger.LogWarning("业务汇聚-服务工单受理返回参数--------------------------------------" + JsonSerializer.Serialize(result));
                     if (result != null)
                     {
                         //处理数据

src/DataSharing/Province/SendTask/TaskSubmitCaseProcessJob.cs

@@ -63,7 +63,7 @@ namespace DataSharing.Province.SendTask
            .OrderBy(d => d.CreationTime)
            .Take(100)
            .ToListAsync(context.CancellationToken);
-
+            _logger.LogWarning("业务汇聚-服务工单处理过程读取数据条数--------------------------------------" + tasks.Count);
             if (tasks.Count != 0)
             {
                 #region 处理请求参数
@@ -82,18 +82,16 @@ namespace DataSharing.Province.SendTask
                     if (await _waitSendTaskSubmitCaseProcessRepository.Updateable(sendTask).ExecuteCommandWithOptLockAsync() > 0)
                     {
                         //组装这一条数据
-                        if (sendTask.RequestData != null)
-                        {
-                            listOrder.Add(sendTask.RequestData);
-                            taskData.Add(sendTask);
-                        }
+                        listOrder.Add(sendTask.RequestData);
+                        taskData.Add(sendTask);
                     }
                 }
-
+                _logger.LogWarning("业务汇聚-服务工单处理过程锁定条数--------------------------------------" + taskData.Count);
                 if (listOrder != null && listOrder.Count > 0)
                 {
                     request.SetData(listOrder);
                     var jsonData = request.ToString();
+                    _logger.LogWarning("业务汇聚-服务工单处理过程请求参数--------------------------------------" + jsonData);
                     ProvinceResponse result = new();
                     string error = "";
                     //执行推送任务
@@ -105,6 +103,7 @@ namespace DataSharing.Province.SendTask
                     {
                         error = ex.Message;
                     }
+                    _logger.LogWarning("业务汇聚-服务工单处理过程返回数据-------------------------------------" + JsonSerializer.Serialize(result));
                     if (result != null)
                     {
                         //处理数据

src/DataSharing/Province/SendTask/TaskSubmitCaseRecordJob.cs

@@ -68,7 +68,7 @@ namespace DataSharing.Province.SendTask
            .OrderBy(d => d.CreationTime)
            .Take(100)
            .ToListAsync(context.CancellationToken);
-
+            _logger.LogWarning("业务汇聚-电话记录读取数据条数--------------------------------------" + tasks.Count);
             if (tasks.Count != 0)
             {
                 #region 处理请求参数
@@ -87,18 +87,17 @@ namespace DataSharing.Province.SendTask
                     if (await _waitSendTaskSubmitCaseRecordRepository.Updateable(sendTask).ExecuteCommandWithOptLockAsync() > 0)
                     {
                         //组装这一条数据
-                        if (sendTask.RequestData != null)
-                        {
-                            listOrder.Add(sendTask.RequestData);
-                            taskData.Add(sendTask);
-                        }
+                        listOrder.Add(sendTask.RequestData);
+                        taskData.Add(sendTask);
                     }
                 }
+                _logger.LogWarning("业务汇聚-电话记录锁定条数--------------------------------------" + taskData.Count);
 
                 if (listOrder != null && listOrder.Count > 0)
                 {
                     request.SetData(listOrder);
                     var jsonData = request.ToString();
+                    _logger.LogWarning("业务汇聚-电话记录请求参数--------------------------------------" + jsonData);
                     ProvinceResponse result = new();
                     string error = "";
                     //执行推送任务
@@ -110,6 +109,7 @@ namespace DataSharing.Province.SendTask
                     {
                         error = ex.Message;
                     }
+                    _logger.LogWarning("业务汇聚-电话记录返回参数--------------------------------------" + JsonSerializer.Serialize(result));
                     if (result != null)
                     {
                         //处理数据

src/DataSharing/Province/SendTask/TaskSubmitCaseResultJob.cs

@@ -63,7 +63,7 @@ namespace DataSharing.Province.SendTask
            .OrderBy(d => d.CreationTime)
            .Take(100)
            .ToListAsync(context.CancellationToken);
-
+            _logger.LogWarning("业务汇聚-服务工单处理结果读取数据条数--------------------------------------" + tasks.Count);
             if (tasks.Count != 0)
             {
                 #region 处理请求参数
@@ -82,18 +82,16 @@ namespace DataSharing.Province.SendTask
                     if (await _waitSendTaskSubmitCaseResultRepository.Updateable(sendTask).ExecuteCommandWithOptLockAsync() > 0)
                     {
                         //组装这一条数据
-                        if (sendTask.RequestData != null)
-                        {
-                            listOrder.Add(sendTask.RequestData);
-                            taskData.Add(sendTask);
-                        }
+                        listOrder.Add(sendTask.RequestData);
+                        taskData.Add(sendTask);
                     }
                 }
-
+                _logger.LogWarning("业务汇聚-服务工单处理结果锁定条数--------------------------------------" + taskData.Count);
                 if (listOrder != null && listOrder.Count > 0)
                 {
                     request.SetData(listOrder);
                     var jsonData = request.ToString();
+                    _logger.LogWarning("业务汇聚-服务工单处理结果请求参数--------------------------------------" + jsonData);
                     ProvinceResponse result = new();
                     string error = "";
                     //执行推送任务
@@ -105,7 +103,7 @@ namespace DataSharing.Province.SendTask
                     {
                         error = ex.Message;
                     }
-
+                    _logger.LogWarning("业务汇聚-服务工单处理结果返回参数--------------------------------------" + JsonSerializer.Serialize(result));
                     if (result != null)
                     {
                         //处理数据