From aa92d49d17ed7cfebdd2db7fe632e1f235d57f1f Mon Sep 17 00:00:00 2001
From: Guoqs <123@jsowell.com>
Date: Tue, 25 Mar 2025 14:33:58 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E7=BD=AE=E6=8C=A1=E6=9D=BF,=20?=
 =?UTF-8?q?=E9=9D=9EPRD=E7=8E=AF=E5=A2=83=E4=B8=8D=E6=89=A7=E8=A1=8C?=
 =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/jsowell/quartz/task/JsowellTask.java  | 21 +++++++++++++++++++
 1 file changed, 21 insertions(+)

diff --git a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
index c51b97e42..fd6792167 100644
--- a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
+++ b/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();