Commit 6008d4f6 authored by 郝彦辉's avatar 郝彦辉

提交测试

parent 2b88ae79
Pipeline #563 failed with stages
...@@ -46,7 +46,7 @@ public class QuantGroupZhuDaiReportToBaiHang { ...@@ -46,7 +46,7 @@ public class QuantGroupZhuDaiReportToBaiHang {
private DingTalk dingTalk; private DingTalk dingTalk;
@Async @Async
@Scheduled(cron = "0 0 05 * * ?") //@Scheduled(cron = "0 0 05 * * ?")
public void startZhuDaiReport(){ public void startZhuDaiReport(){
if(increment()){ if(increment()){
redisTemplate.expire(Constant.QG_ZHU_DAI_REPORT_LOCK_KEY, 10, TimeUnit.SECONDS); redisTemplate.expire(Constant.QG_ZHU_DAI_REPORT_LOCK_KEY, 10, TimeUnit.SECONDS);
......
...@@ -68,7 +68,7 @@ public class RoutineWorkTask { ...@@ -68,7 +68,7 @@ public class RoutineWorkTask {
public String BACKLOG_DELAY_DAY; public String BACKLOG_DELAY_DAY;
@Async @Async
@Scheduled(cron = "0 0 18 * * ?") //@Scheduled(cron = "0 0 18 * * ?")
public void downloadLog() { public void downloadLog() {
//if (increment(ROUTINE_WORK_BH_LOCK_KEY_1)) { //if (increment(ROUTINE_WORK_BH_LOCK_KEY_1)) {
// redisTemplate.expire(ROUTINE_WORK_BH_LOCK_KEY_1, 10, TimeUnit.SECONDS); // redisTemplate.expire(ROUTINE_WORK_BH_LOCK_KEY_1, 10, TimeUnit.SECONDS);
...@@ -160,7 +160,7 @@ public class RoutineWorkTask { ...@@ -160,7 +160,7 @@ public class RoutineWorkTask {
@Async @Async
@Scheduled(cron = "0 10 18 * * ?") //@Scheduled(cron = "0 10 18 * * ?")
public void sendBaoSong() { public void sendBaoSong() {
//if (increment(ROUTINE_WORK_BH_LOCK_KEY_2)) { //if (increment(ROUTINE_WORK_BH_LOCK_KEY_2)) {
// redisTemplate.expire(ROUTINE_WORK_BH_LOCK_KEY_2, 10, TimeUnit.SECONDS); // redisTemplate.expire(ROUTINE_WORK_BH_LOCK_KEY_2, 10, TimeUnit.SECONDS);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment