定时任务执行控制 1java 2php

src/main/java/com/sqx/modules/job/task/OrderTask.java

@@ -4,6 +4,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.thread.ThreadUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.sqx.modules.common.service.CommonInfoService;
 import com.sqx.modules.discSpinning.entity.DiscSpinningRecord;
 import com.sqx.modules.orders.dao.OrdersDao;
 import com.sqx.modules.orders.entity.Orders;
@@ -36,9 +37,15 @@ public class OrderTask {
     private OrdersService ordersService;
     @Resource
     private PayDetailsDao payDetailsDao;
+    @Resource
+    private CommonInfoService commonRepository;
 
     @Scheduled(cron = "0 7/5 * * * ? ")
     public void record() {
+        String value = commonRepository.findOne(939).getValue();
+        if(!"1".equals(value)){
+            return;
+        }
         record1();
     }
 

src/main/java/com/sqx/modules/job/task/SpinningTask3.java

@@ -3,6 +3,7 @@ package com.sqx.modules.job.task;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.thread.ThreadUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.sqx.modules.common.service.CommonInfoService;
 import com.sqx.modules.discSpinning.entity.DiscSpinningRecord;
 import com.sqx.modules.discSpinning.service.DiscSpinningRecordService;
 import com.sqx.modules.discSpinning.service.DiscSpinningService;
@@ -28,12 +29,18 @@ public class SpinningTask3 {
     private DiscSpinningService spinningController;
     @Resource
     private DiscSpinningRecordService recordService;
+    @Resource
+    private CommonInfoService commonRepository;
 
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
     @Scheduled(cron = "0 0/5 * * * ? ")
     public void record() {
+        String value = commonRepository.findOne(939).getValue();
+        if(!"1".equals(value)){
+            return;
+        }
         record("1");
     }
 

src/main/java/com/sqx/modules/job/task/TempCashOutTask.java

@@ -10,6 +10,7 @@ import com.sqx.modules.app.entity.UserMoney;
 import com.sqx.modules.app.entity.UserMoneyDetails;
 import com.sqx.modules.app.service.UserMoneyDetailsService;
 import com.sqx.modules.app.service.UserMoneyService;
+import com.sqx.modules.common.service.CommonInfoService;
 import com.sqx.modules.pay.dao.CashOutDao;
 import com.sqx.modules.pay.entity.CashOut;
 import com.sqx.modules.pay.service.WuyouCallbackService;
@@ -43,12 +44,18 @@ public class TempCashOutTask {
     private WuyouPay wuyouPay;
     @Resource
     private WuyouCallbackService wuyouCallbackService;
+    @Resource
+    private CommonInfoService commonRepository;
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
 
     @Scheduled(cron = "0 4/5 * * * ? ")
     public void run() {
+        String value = commonRepository.findOne(939).getValue();
+        if(!"1".equals(value)){
+            return;
+        }
         List<CashOut> cashOuts = cashOutDao.selectTemp(DateUtil.offsetMinute(DateUtil.date(), 15));
         logger.info("定时查询提现订单 待处理订单: {}", cashOuts.size());
 

src/main/java/com/sqx/modules/job/task/TempOrdersTask.java

@@ -105,6 +105,10 @@ public class TempOrdersTask {
 //        if (!"pay".equals(profiles)) {
 //            return;
 //        }
+        String value = commonRepository.findOne(939).getValue();
+        if(!"1".equals(value)){
+            return;
+        }
         logger.info("订单表数据处理开始");
 //        List<Orders> orders = ordersDao.selectList(Wrappers.<Orders>lambdaQuery()
 //                .eq(Orders::getStatus, 0)