设置挡板, 非PRD环境不执行定时任务

jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java

@@ -8,6 +8,7 @@ import com.jsowell.common.core.redis.RedisCache;
 import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum;
 import com.jsowell.common.util.DateUtils;
 import com.jsowell.common.util.StringUtils;
+import com.jsowell.common.util.spring.SpringUtils;
 import com.jsowell.pile.domain.OrderBasicInfo;
 import com.jsowell.pile.domain.PileMerchantInfo;
 import com.jsowell.pile.domain.PileStationInfo;
@@ -67,11 +68,23 @@ public class JsowellTask {
     @Autowired
     private ThirdPartyStationRelationService thirdPartyStationRelationService;
 
+    /**
+     * 设置挡板, PRE环境不执行
+     */
+    public void setBarrier() {
+        String env = SpringUtils.getActiveProfile();
+        if (!StringUtils.equalsIgnoreCase(env, "prd")) {
+            log.info("非PRD环境不执行");
+            return;
+        }
+    }
+
     /**
      * 关闭15分钟未支付的订单
      * close15MinutesOfUnpaidOrders
      */
     public void close15MinutesOfUnpaidOrders() {
+        setBarrier();
         // log.info("关闭15分钟未支付的订单");
         orderBasicInfoService.close15MinutesOfUnpaidOrders();
     }
@@ -81,6 +94,7 @@ public class JsowellTask {
      * 订单支付成功，在15分钟内未启动，
      */
     public void closeStartFailedOrder() {
+        setBarrier();
         // 查询出最近2天支付成功，并且订单状态为未启动的订单
         String startTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, DateUtils.addDays(new Date(), -2));
         String endTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, new Date());
@@ -91,6 +105,7 @@ public class JsowellTask {
      * 查询预约充电的订单并启动
      */
     public void appointmentOrderStart() {
+        setBarrier();
         // 查询出 已支付 设置预约充电 未启动 的订单
         LocalDateTime now = LocalDateTime.now();
         List<OrderBasicInfo> list = orderBasicInfoService.getReservedOrder(now);
@@ -135,6 +150,7 @@ public class JsowellTask {
      * jsowellTask.calculateTheSiteOrdersReport()
      */
     public void calculateTheSiteOrdersReport() {
+        setBarrier();
         // 查询出所有站点
         PileStationInfo pileStationInfo = new PileStationInfo();
         pileStationInfo.setDelFlag(Constants.ZERO);
@@ -159,6 +175,7 @@ public class JsowellTask {
      * jsowellTask.pushToAMap()
      */
     public void pushToAMap() {
+        setBarrier();
         Set<String> stationIds = redisCache.getCacheSet(CacheConstants.PUSH_STATION_CONNECTOR);
         if (CollectionUtils.isEmpty(stationIds)) {
             return;
@@ -179,6 +196,7 @@ public class JsowellTask {
      * 贵州省平台推送充电站实时功率
      */
     public void pushStationRealTimePowerInfo() {
+        setBarrier();
         // 查询出要推送的站点（贵州、）
         String thirdPartyType = ThirdPlatformTypeEnum.GUI_ZHOU_PLATFORM.getTypeCode();
         List<StationInfoVO> stationInfoVOS = thirdPartyStationRelationService.selectStationList(thirdPartyType);
@@ -196,6 +214,7 @@ public class JsowellTask {
      * jsowellTask.processOrderSplitting()
      */
     public void processOrderSplitting() {
+        setBarrier();
         // 查询运营商列表
         List<PileMerchantInfo> pileMerchantInfos = pileMerchantInfoService.selectPileMerchantInfoList(null);
         if (CollectionUtils.isEmpty(pileMerchantInfos)) {
@@ -230,6 +249,7 @@ public class JsowellTask {
      *
      */
     public void generateMerchantBill() {
+        setBarrier();
         // 查询运营商列表
         List<PileMerchantInfo> pileMerchantInfos = pileMerchantInfoService.selectPileMerchantInfoList(null);
         if (CollectionUtils.isEmpty(pileMerchantInfos)) {
@@ -254,6 +274,7 @@ public class JsowellTask {
      * jsowellTask.automaticPayouts()
      */
     public void automaticPayouts() {
+        setBarrier();
         // TODO 查询开启自动提现运营商列表
         // List<PileMerchantInfo> pileMerchantInfos = pileMerchantInfoService.selectPileMerchantInfoList(null);
         List<PileMerchantInfo> pileMerchantInfos = pileMerchantInfoService.selectAutoWithdrawalMerchantInfoList();