Quellcode durchsuchen

开始定时拉取12315的数据

tangjiang vor 6 Monaten
Ursprung
Commit
22f9b1c9ee
1 geänderte Dateien mit 27 neuen und 27 gelöschten Zeilen
  1. 27 27
      src/DataSharing.Host/StartupHelper.cs

+ 27 - 27
src/DataSharing.Host/StartupHelper.cs

@@ -274,35 +274,35 @@ namespace DataSharing.Host
                 //    .WithCronSchedule("0/1 * * * * ? ")
                 //);
 
-                ////2小时定时拉取12315的办理过程
-                //var taskCaseDistrecordJobKey = new JobKey("task-case-distrecord-job", "task case distrecord job");
-                //d.AddJob<TaskCaseDistrecordJob>(taskCaseDistrecordJobKey);
-                //d.AddTrigger(t => t
-                //    .WithIdentity("task-case-distrecord-job-trigger")
-                //    .ForJob(taskCaseDistrecordJobKey)
-                //    .StartNow()
-                //    .WithCronSchedule("0 0 */2 * * ?")
-                //);
+                //2小时定时拉取12315的办理过程
+                var taskCaseDistrecordJobKey = new JobKey("task-case-distrecord-job", "task case distrecord job");
+                d.AddJob<TaskCaseDistrecordJob>(taskCaseDistrecordJobKey);
+                d.AddTrigger(t => t
+                    .WithIdentity("task-case-distrecord-job-trigger")
+                    .ForJob(taskCaseDistrecordJobKey)
+                    .StartNow()
+                    .WithCronSchedule("0 0 */2 * * ?")
+                );
 
-                ////2小时上传实时服务上报
-                //var taskSendRealTimeStatusJobKey = new JobKey("task-send-realtime-status-job", "task send realtime status job");
-                //d.AddJob<TaskSendRealTimeStatusJob>(taskSendRealTimeStatusJobKey);
-                //d.AddTrigger(t => t
-                //    .WithIdentity("task-send-realtime-status-trigger")
-                //    .ForJob(taskSendRealTimeStatusJobKey)
-                //    .StartNow()
-                //    .WithCronSchedule("0 0 */2 * * ?")
-                //);
+                //2小时上传实时服务上报
+                var taskSendRealTimeStatusJobKey = new JobKey("task-send-realtime-status-job", "task send realtime status job");
+                d.AddJob<TaskSendRealTimeStatusJob>(taskSendRealTimeStatusJobKey);
+                d.AddTrigger(t => t
+                    .WithIdentity("task-send-realtime-status-trigger")
+                    .ForJob(taskSendRealTimeStatusJobKey)
+                    .StartNow()
+                    .WithCronSchedule("0 0 */2 * * ?")
+                );
 
-                ////每天凌晨1点推送业务汇聚-统计数据
-                //var taskSubmitCaseTotalJobKey = new JobKey("task-submit-case-total-job", "task submit case total job");
-                //d.AddJob<TaskSubmitCaseTotalJob>(taskSubmitCaseTotalJobKey);
-                //d.AddTrigger(t => t
-                //    .WithIdentity("task-submit-case-total-job-trigger")
-                //    .ForJob(taskSubmitCaseTotalJobKey)
-                //   .StartNow()
-                //    .WithCronSchedule("0 0 1 * * ?")//0 0 1 * * ?
-                //);
+                //每天凌晨1点推送业务汇聚-统计数据
+                var taskSubmitCaseTotalJobKey = new JobKey("task-submit-case-total-job", "task submit case total job");
+                d.AddJob<TaskSubmitCaseTotalJob>(taskSubmitCaseTotalJobKey);
+                d.AddTrigger(t => t
+                    .WithIdentity("task-submit-case-total-job-trigger")
+                    .ForJob(taskSubmitCaseTotalJobKey)
+                   .StartNow()
+                    .WithCronSchedule("0 0 1 * * ?")//0 0 1 * * ?
+                );
 
                 //每天晚上23点处理每天办理完成未及时推送办理结果的数据
                 var taskRepublishFiledOrdersJobKey = new JobKey("task-republish-filed-orders-job", "task republish filed orders job");