src/DataSharing.Host/Controllers/TestController.cs

@@ -102,10 +102,27 @@ namespace DataSharing.Host.Controllers
         /// <returns></returns>
         [HttpGet("gettesttokeninfo")]
         [AllowAnonymous]
-        public async Task GetToken([FromQuery]  string  TEXT)
+        public async Task GetToken([FromQuery] string TEXT)
         {
+            //DsWaitSendTaskSubmitCaseRecord data = new();
+            //var list = await _waitSendTaskSubmitCaseRecordRepository.Queryable().ToListAsync();
+            //for (int i = 0; i < list.Count; i++)
+            //{
+            //    list[i].TaskType=i.ToString();
+            //    await _waitSendTaskSubmitCaseRecordRepository.UpdateAsync(list[i]);
+            //    data = list[i];
+            //}
+
+            //for (int i =40; i < 200; i++)
+            //{
+            //    data.Id = Guid.NewGuid().ToString();
+            //    data.TaskType= i.ToString();
+            //    await _waitSendTaskSubmitCaseRecordRepository.AddAsync(data);
+            //}
+
+
 
-            List<ProvinceBathErrorObjsResponse> ErrorObjs=new List<ProvinceBathErrorObjsResponse>();
+            List<ProvinceBathErrorObjsResponse> ErrorObjs = new List<ProvinceBathErrorObjsResponse>();
 
             var t = ErrorObjs.Exists(p => p.CaseSerial == "123456");
 
@@ -132,7 +149,7 @@ namespace DataSharing.Host.Controllers
                 catch (Exception ex)
                 {
 
-                    ss=ex.Message;
+                    ss = ex.Message;
                 }
 
 

src/DataSharing.Host/StartupHelper.cs

@@ -200,7 +200,7 @@ namespace DataSharing.Host
                     .WithIdentity("task-submit-case-info-trigger")
                     .ForJob(taskSubmitCaseInfoJobKey)
                     .StartNow()
-                     .WithCronSchedule("0/30 * * * * ? ")
+                    .WithCronSchedule("0/30 * * * * ? ")
                 );
 
                 //服务工单处理过程
@@ -210,7 +210,7 @@ namespace DataSharing.Host
                     .WithIdentity("task-submit-case-process-trigger")
                     .ForJob(taskSubmitCaseProcessKey)
                     .StartNow()
-                     .WithCronSchedule("0/30 * * * * ? ")
+                  .WithCronSchedule("0/30 * * * * ? ")
                 );
 
                 //服务工单处理结果
@@ -220,7 +220,7 @@ namespace DataSharing.Host
                     .WithIdentity("task-submit-case-result-trigger")
                     .ForJob(taskSubmitCaseResultKey)
                     .StartNow()
-                     .WithCronSchedule("0/30 * * * * ? ")
+                    .WithCronSchedule("0/30 * * * * ? ")
                 );
 
                 //电话记录
@@ -230,7 +230,7 @@ namespace DataSharing.Host
                     .WithIdentity("task-submit-case-record-trigger")
                     .ForJob(taskSubmitCaseRecordKey)
                     .StartNow()
-                     .WithCronSchedule("0/30 * * * * ? ")
+                    .WithCronSchedule("0/30 * * * * ? ")
                 );
 
                 //省推送其他服务
@@ -240,7 +240,7 @@ namespace DataSharing.Host
                     .WithIdentity("task-province-other-trigger")
                     .ForJob(taskProvinceOtherKey)
                     .StartNow()
-                     .WithCronSchedule("0/30 * * * * ? ")
+                   .WithCronSchedule("0/30 * * * * ? ")
                 );
 
                 //其它平台服务
@@ -250,7 +250,7 @@ namespace DataSharing.Host
                     .WithIdentity("task-other-platforms-trigger")
                     .ForJob(taskOtherPlatformsKey)
                     .StartNow()
-                     .WithCronSchedule("0/30 * * * * ? ")
+                    .WithCronSchedule("0/30 * * * * ? ")
                 );
 
                 ////execute send task

src/DataSharing/Province/SendTask/TaskProvinceOtherJob.cs

@@ -71,7 +71,7 @@ namespace DataSharing.Province.SendTask
             var tasks = await _waitSendTaskProvinceOtherRepository.Queryable()
            .Where(d => d.State == EWaitSendTaskState.WaitPush && d.SendTimes <= 6)
            .OrderBy(d => d.CreationTime)
-           .Take(100)
+           .Take(50)
            .ToListAsync(context.CancellationToken);
 
             if (tasks.Count != 0)

src/DataSharing/Province/SendTask/TaskSubmitCaseInfoJob.cs

@@ -67,7 +67,7 @@ namespace DataSharing.Province.SendTask
             var tasks = await _waitSendTaskSubmitCaseInfoRepository.Queryable()
            .Where(d => d.State == EWaitSendTaskState.WaitPush && d.SendTimes <= 6)
            .OrderBy(d => d.CreationTime)
-           .Take(100)
+           .Take(50)
            .ToListAsync(context.CancellationToken);
 
             _logger.LogWarning("业务汇聚-服务工单受理读取数据条数--------------------------------------" + tasks.Count);

src/DataSharing/Province/SendTask/TaskSubmitCaseProcessJob.cs

@@ -61,7 +61,7 @@ namespace DataSharing.Province.SendTask
             var tasks = await _waitSendTaskSubmitCaseProcessRepository.Queryable()
            .Where(d => d.State == EWaitSendTaskState.WaitPush && d.SendTimes <= 6)
            .OrderBy(d => d.CreationTime)
-           .Take(100)
+           .Take(50)
            .ToListAsync(context.CancellationToken);
             _logger.LogWarning("业务汇聚-服务工单处理过程读取数据条数--------------------------------------" + tasks.Count);
             if (tasks.Count != 0)

src/DataSharing/Province/SendTask/TaskSubmitCaseRecordJob.cs

@@ -66,7 +66,7 @@ namespace DataSharing.Province.SendTask
             var tasks = await _waitSendTaskSubmitCaseRecordRepository.Queryable()
            .Where(d => d.State == EWaitSendTaskState.WaitPush && d.SendTimes <= 6)
            .OrderBy(d => d.CreationTime)
-           .Take(100)
+           .Take(50)
            .ToListAsync(context.CancellationToken);
             _logger.LogWarning("业务汇聚-电话记录读取数据条数--------------------------------------" + tasks.Count);
             if (tasks.Count != 0)

src/DataSharing/Province/SendTask/TaskSubmitCaseResultJob.cs

@@ -61,7 +61,7 @@ namespace DataSharing.Province.SendTask
             var tasks = await _waitSendTaskSubmitCaseResultRepository.Queryable()
            .Where(d => d.State == EWaitSendTaskState.WaitPush && d.SendTimes <= 6)
            .OrderBy(d => d.CreationTime)
-           .Take(100)
+           .Take(50)
            .ToListAsync(context.CancellationToken);
             _logger.LogWarning("业务汇聚-服务工单处理结果读取数据条数--------------------------------------" + tasks.Count);
             if (tasks.Count != 0)