同步用户定时任务加锁

src/main/java/com/cmeeting/job/CmeetingJob.java

@@ -66,6 +66,9 @@ public class CmeetingJob {
      */
     @Scheduled(cron = "0 30 6 * * ?")
     public void weComUserSync() {
+        if (redisUtils.setnx("weComUserSync", "weComUserSync", 20 * 60 * 60)){
+            return;
+        }
         try {
             log.info("-------企微人员定时同步任务开始-------");
             log.info("当前时间: " + LocalDate.now().format(DateTimeFormatter.ISO_LOCAL_DATE));
@@ -74,6 +77,8 @@ public class CmeetingJob {
             log.info("-------企微人员定时同步任务结束--------");
         } catch (Exception e) {
             e.printStackTrace();
+        } finally {
+            redisUtils.del("weComUserSync");
         }
     }
 
@@ -83,6 +88,9 @@ public class CmeetingJob {
     @Scheduled(cron = "0 0 7 * * ?")
 //    @Scheduled(fixedRate = 5 * 60 * 1000)
     public void TencentUserSync() {
+        if (redisUtils.setnx("TencentUserSync", "TencentUserSync", 20 * 60 * 60)){
+            return;
+        }
         try {
             log.info("-------腾讯会议人员定时同步任务开始-------");
             log.info("当前时间: " + LocalDate.now().format(DateTimeFormatter.ISO_LOCAL_DATE));
@@ -91,6 +99,8 @@ public class CmeetingJob {
             log.info("-------腾讯会议人员定时同步任务结束--------");
         } catch (Exception e) {
             e.printStackTrace();
+        } finally {
+            redisUtils.del("TencentUserSync");
         }
     }
 
@@ -99,10 +109,19 @@ public class CmeetingJob {
      */
     @Scheduled(cron = "0 20 7 * * ?")
     public void userBind() {
-        log.info("-------关联企微腾会人员定时任务开始-------");
-        log.info("当前时间: " + LocalDate.now().format(DateTimeFormatter.ISO_LOCAL_DATE));
-        weComService.userBind();
-        log.info("-------关联企微腾会人员定时任务结束--------");
+        if (redisUtils.setnx("userBind", "userBind", 20 * 60 * 60)){
+            return;
+        }
+        try {
+            log.info("-------关联企微腾会人员定时任务开始-------");
+            log.info("当前时间: " + LocalDate.now().format(DateTimeFormatter.ISO_LOCAL_DATE));
+            weComService.userBind();
+            log.info("-------关联企微腾会人员定时任务结束--------");
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            redisUtils.del("userBind");
+        }
     }
 
     @Scheduled(fixedRate = 20 * 60 * 1000,initialDelay = 2 * 60 * 1000)