Fedex / iClear-Connect-Pre-Clearance

Go to a project
Toggle navigation Toggle navigation pinning
zelong.shao
aabe1b24 1 parent 48d33d25

task|定时任务配置调整

Inline Side-by-side
Showing 3 changed files with 10 additions and 4 deletions
...@@ -29,5 +29,9 @@ public interface ParamConfigConstants { ...@@ -29,5 +29,9 @@ public interface ParamConfigConstants {
29 String NOTIFICATION_SENDER_NUMBER = "notification_sender_number"; 29 String NOTIFICATION_SENDER_NUMBER = "notification_sender_number";
30 //通知发件人邮件定时任务处理数量 30 //通知发件人邮件定时任务处理数量
31 String NOTIFICATION_SENDER_EMAIL_NUMBER = "notification_sender_email_number"; 31 String NOTIFICATION_SENDER_EMAIL_NUMBER = "notification_sender_email_number";
32 + //邮件发送进口文件时间间隔key
33 + String PUSH_CON_EMAIL_INTERVAL = "push_con_email_interval";
34 + //通知发件人时间间隔
35 + String NOTIFICATION_SENDER_EMAIL_INTERVAL = "notification_sender_email_interval";
32 } 36 }
33 } 37 }
......
1 package com.fedex.connect.task.job; 1 package com.fedex.connect.task.job;
2 2
3 +import com.fedex.connect.common.dependencies.contants.ParamConfigConstants;
3 import com.fedex.connect.task.annotation.ProcessingInterval; 4 import com.fedex.connect.task.annotation.ProcessingInterval;
4 import com.fedex.connect.task.service.biz.IDuplicateConsignmentEmailService; 5 import com.fedex.connect.task.service.biz.IDuplicateConsignmentEmailService;
5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.beans.factory.annotation.Autowired;
...@@ -17,8 +18,8 @@ public class DuplicateConsignmentEmailJob { ...@@ -17,8 +18,8 @@ public class DuplicateConsignmentEmailJob {
17 @Autowired 18 @Autowired
18 private IDuplicateConsignmentEmailService duplicateConsignmentEmailService; 19 private IDuplicateConsignmentEmailService duplicateConsignmentEmailService;
19 20
20 - @ProcessingInterval 21 + @ProcessingInterval(paramCode = ParamConfigConstants.TASK_PARAM_KEYS.NOTIFICATION_SENDER_EMAIL_INTERVAL)
21 - @Scheduled(cron = "${export.task.allocation.pushConFile}") 22 + @Scheduled(cron = "${export.task.allocation.sendOb}")
22 public void pushConsignmentFileTask() { 23 public void pushConsignmentFileTask() {
23 duplicateConsignmentEmailService.duplicateConsignmentEmail(); 24 duplicateConsignmentEmailService.duplicateConsignmentEmail();
24 } 25 }
......
1 package com.fedex.connect.task.job; 1 package com.fedex.connect.task.job;
2 2
3 +import com.fedex.connect.common.dependencies.contants.ParamConfigConstants;
3 import com.fedex.connect.task.annotation.ProcessingInterval; 4 import com.fedex.connect.task.annotation.ProcessingInterval;
4 import com.fedex.connect.task.service.biz.IPushConsignmentFileService; 5 import com.fedex.connect.task.service.biz.IPushConsignmentFileService;
5 import org.springframework.beans.factory.annotation.Autowired; 6 import org.springframework.beans.factory.annotation.Autowired;
...@@ -17,8 +18,8 @@ public class PushConsignmentFileEmailJob { ...@@ -17,8 +18,8 @@ public class PushConsignmentFileEmailJob {
17 @Autowired 18 @Autowired
18 private IPushConsignmentFileService pushConsignmentFileService; 19 private IPushConsignmentFileService pushConsignmentFileService;
19 20
20 - @ProcessingInterval 21 + @ProcessingInterval(paramCode = ParamConfigConstants.TASK_PARAM_KEYS.PUSH_CON_EMAIL_INTERVAL)
21 - @Scheduled(cron = "${export.task.allocation.pushConFile}") 22 + @Scheduled(cron = "${export.task.allocation.sendOb}")
22 public void pushConsignmentFileTask() { 23 public void pushConsignmentFileTask() {
23 pushConsignmentFileService.pushConsignmentFileTask(); 24 pushConsignmentFileService.pushConsignmentFileTask();
24 } 25 }
......