YOHOBUY / yohobuy-union · Commits

Go to a project

Authored by mingdan.ge
Commit f62871b5e893997ba9cf24dc73b43b5f9626c0df 1 parent 5c5e3a22

测试

Inline Side-by-side
Showing 2 changed files with 4 additions and 3 deletions
@@ -30,8 +30,8 @@ public class CpsOrdersSumMessageTask { @@ -30,8 +30,8 @@ public class CpsOrdersSumMessageTask {
30 30
31 private static String TASK_KEY = "yh:union:share:CpsOrdersSumMessageTask:"; 31 private static String TASK_KEY = "yh:union:share:CpsOrdersSumMessageTask:";
32 32
33 -// @Scheduled(cron = "0 0/5 * * * ?")  
34 - @Scheduled(cron = "0 0 10 * * ?") 33 + @Scheduled(cron = "0 0/5 * * * ?")
  34 +// @Scheduled(cron = "0 0 10 * * ?")
35 public void run() { 35 public void run() {
36 //绑定已处理状态 36 //绑定已处理状态
37 CpsMessageTaskBo bo = new CpsMessageTaskBo(); 37 CpsMessageTaskBo bo = new CpsMessageTaskBo();
@@ -30,7 +30,8 @@ public class CpsSettlementMessageTask { @@ -30,7 +30,8 @@ public class CpsSettlementMessageTask {
30 private static String SETTLEMENT_TASK_KEY = "yh:union:share:CpsSettlementMessageTask:"; 30 private static String SETTLEMENT_TASK_KEY = "yh:union:share:CpsSettlementMessageTask:";
31 31
32 32
33 - @Scheduled(cron = "0 0 10 20,28 * ?") 33 + @Scheduled(cron = "0 2/5 * * * ?")
  34 +// @Scheduled(cron = "0 0 10 20,28 * ?")
34 public void run(){ 35 public void run(){
35 //竞争任务处理者 36 //竞争任务处理者
36 CpsMessageTaskBo bo = new CpsMessageTaskBo(); 37 CpsMessageTaskBo bo = new CpsMessageTaskBo();