试一试k8s

backend/src/main/java/com/reyun/saas/mob/user/task/SyncChannelTask.java

@@ -11,7 +11,6 @@ import com.reyun.saas.report.realtimecommon.dao.ChannelInfoMapper;
 import com.reyun.saas.report.realtimecommon.domain.ChannelInfo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
-import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 import tk.mybatis.mapper.entity.Example;
@@ -54,7 +53,7 @@ public class SyncChannelTask {
      * 从实时数据库中渠道数据 同步数据到web的数据库中
      */
     @Async
-    @Scheduled(cron = "0 0/30 * * * ?")
+//    @Scheduled(cron = "0 0/30 * * * ?")
 //    @Scheduled(cron = "0 * * * * ?")
     public void syncChannel() {
         //分布式锁

backend/src/main/java/com/reyun/saas/mob/user/task/UniversalPwdTask.java

@@ -9,7 +9,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Async;
-import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
@@ -31,7 +30,7 @@ public class UniversalPwdTask {
     private RedisUtils redisUtils;
 
     @Async
-    @Scheduled(cron = "0 0 8 * * ? ")
+//    @Scheduled(cron = "0 0 8 * * ? ")
     public void genUniversalPwd(){
         if(!"pro".equals(env)){//线上生效
             return;

backend/src/main/java/com/reyun/saas/mob/user/task/WarningConfigTask.java

@@ -9,7 +9,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.scheduling.annotation.Async;
-import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 import tk.mybatis.mapper.entity.Example;
@@ -36,7 +35,7 @@ public class WarningConfigTask {
     private WarningConfigMapper warningConfigMapper;
 
     @Async
-    @Scheduled(cron = "0 0 * * * ? ")//整点
+//    @Scheduled(cron = "0 0 * * * ? ")//整点
     public void checkWarningReport(){
         Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("checkWarningReport", "lock", 10, TimeUnit.SECONDS);
         if (!lock) {

backend/src/main/java/com/reyun/saas/mob/user/task/WorkOrderTask.java

@@ -7,7 +7,6 @@ import com.reyun.saas.mob.user.domain.WorkOrderExport;
 import com.reyun.saas.mob.user.thread.workorder.WorkOrderThread;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
-import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import tk.mybatis.mapper.entity.Example;
 
@@ -42,7 +41,7 @@ public class WorkOrderTask {
 
     @Async
 //    @Scheduled(cron = "0 0/5 * * * ?")
-    @Scheduled(cron = "0 * * * * ?")
+//    @Scheduled(cron = "0 * * * * ?")
     public void scanWorkOrderExport() {
         //分布式锁
         if (!redisUtils.tryLock("scanWorkOrderExport",10)) {
@@ -90,7 +89,7 @@ public class WorkOrderTask {
      * 将工期的工单删除
      */
     @Async
-    @Scheduled(cron = "0 0 * * * ?")
+//    @Scheduled(cron = "0 0 * * * ?")
     public void expireWorkOrderDispose() {
 
         //分布式锁