diff --git a/src/main/java/com/sqx/modules/job/task/OrderTask.java b/src/main/java/com/sqx/modules/job/task/OrderTask.java index de1c3ec3..22d078b4 100644 --- a/src/main/java/com/sqx/modules/job/task/OrderTask.java +++ b/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(); } diff --git a/src/main/java/com/sqx/modules/job/task/SpinningTask3.java b/src/main/java/com/sqx/modules/job/task/SpinningTask3.java index ec94dbda..f0cb9953 100644 --- a/src/main/java/com/sqx/modules/job/task/SpinningTask3.java +++ b/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"); } diff --git a/src/main/java/com/sqx/modules/job/task/TempCashOutTask.java b/src/main/java/com/sqx/modules/job/task/TempCashOutTask.java index f815b2a3..d2dc7072 100644 --- a/src/main/java/com/sqx/modules/job/task/TempCashOutTask.java +++ b/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 cashOuts = cashOutDao.selectTemp(DateUtil.offsetMinute(DateUtil.date(), 15)); logger.info("定时查询提现订单 待处理订单: {}", cashOuts.size()); diff --git a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java index d2a9fc42..09e3275f 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/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 = ordersDao.selectList(Wrappers.lambdaQuery() // .eq(Orders::getStatus, 0)