修改定时拉取数据

src/DataSharing.Host/StartupHelper.cs

@@ -274,65 +274,65 @@ 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");
-                //d.AddJob<TaskRepublishFiledOrdersJob>(taskRepublishFiledOrdersJobKey);
-                //d.AddTrigger(t => t
-                //    .WithIdentity("task-republish-filed-orders-job-trigger")
-                //    .ForJob(taskRepublishFiledOrdersJobKey)
-                //   .StartNow()
-                //   .WithCronSchedule("0 0 23 * * ?")//0 0 1 * * ?
-                //);
+                //每天晚上23点处理每天办理完成未及时推送办理结果的数据
+                var taskRepublishFiledOrdersJobKey = new JobKey("task-republish-filed-orders-job", "task republish filed orders job");
+                d.AddJob<TaskRepublishFiledOrdersJob>(taskRepublishFiledOrdersJobKey);
+                d.AddTrigger(t => t
+                    .WithIdentity("task-republish-filed-orders-job-trigger")
+                    .ForJob(taskRepublishFiledOrdersJobKey)
+                   .StartNow()
+                   .WithCronSchedule("0 0 23 * * ?")//0 0 1 * * ?
+                );
 
-                ////每天晚上23点处理未关联工单的通话记录
-                //var taskAssociateCallRecordsJobKey = new JobKey("task-associate-call-records-job", "task associate call records job");
-                //d.AddJob<TaskAssociateCallRecordsJob>(taskAssociateCallRecordsJobKey);
-                //d.AddTrigger(t => t
-                //    .WithIdentity("task-associate-call-records-job-trigger")
-                //    .ForJob(taskAssociateCallRecordsJobKey)
-                //   .StartNow()
-                //   .WithCronSchedule("0 0 23 * * ?")//0 0 1 * * ?
-                //);
+                //每天晚上23点处理未关联工单的通话记录
+                var taskAssociateCallRecordsJobKey = new JobKey("task-associate-call-records-job", "task associate call records job");
+                d.AddJob<TaskAssociateCallRecordsJob>(taskAssociateCallRecordsJobKey);
+                d.AddTrigger(t => t
+                    .WithIdentity("task-associate-call-records-job-trigger")
+                    .ForJob(taskAssociateCallRecordsJobKey)
+                   .StartNow()
+                   .WithCronSchedule("0 0 23 * * ?")//0 0 1 * * ?
+                );
 
-                ////每天晚上23点50处理未查询到通话记录的工单，修改为其他来源
-                //var TaskGetOrderMatchingCallListJobKey = new JobKey("task-get-order-matching-call-list-job-job", "task get order matching call list job");
-                //d.AddJob<TaskGetOrderMatchingCallListJob>(TaskGetOrderMatchingCallListJobKey);
-                //d.AddTrigger(t => t
-                //    .WithIdentity("task-get-order-matching-call-list-job-trigger")
-                //    .ForJob(TaskGetOrderMatchingCallListJobKey)
-                //   .StartNow()
-                //   .WithCronSchedule("0 50 23 * * ?")//0 0 1 * * ?
-                //);
+                //每天晚上23点50处理未查询到通话记录的工单，修改为其他来源
+                var TaskGetOrderMatchingCallListJobKey = new JobKey("task-get-order-matching-call-list-job-job", "task get order matching call list job");
+                d.AddJob<TaskGetOrderMatchingCallListJob>(TaskGetOrderMatchingCallListJobKey);
+                d.AddTrigger(t => t
+                    .WithIdentity("task-get-order-matching-call-list-job-trigger")
+                    .ForJob(TaskGetOrderMatchingCallListJobKey)
+                   .StartNow()
+                   .WithCronSchedule("0 50 23 * * ?")//0 0 1 * * ?
+                );
 
             });