定时任务报警和预计相关 只有生产环境才会运行

slibra-common/src/main/java/com/slibra/common/constant/MyConstants.java

@@ -13,6 +13,7 @@ public class MyConstants {
     public static final String SPACE_STR = " ";//空格
     public static final String SESSION_ID = "session_id";
     public static final String STOP_GEN_STREAM = "stop_gen_stream";
+    public static final String PROD_ENVIRONMENT = "prod";
 
 
 

slibra-quartz/src/main/java/com/slibra/quartz/task/AsyncTask.java

@@ -29,6 +29,7 @@ import io.grpc.ManagedChannel;
 import io.grpc.ManagedChannelBuilder;
 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.stereotype.Component;
 import org.springframework.util.CollectionUtils;
@@ -80,6 +81,10 @@ public class AsyncTask {
     @Autowired
     private JsCsFormatData jsCsFormatData;
 
+    /** 使用的是哪个环境 */
+    @Value("${spring.profiles.active}")
+    private String environment;
+
 
     /**
      *
@@ -105,11 +110,14 @@ public class AsyncTask {
         TXinyiCalculate xinyiCalculate = this.addCalculateByIndustry(tXinyiIndustry, normConfig);
         this.xinyiCalculateMapper.insertTXinyiCalculate(xinyiCalculate);
 
-        //水质报警
-        this.handleSZWarning(tXinyiIndustry, normConfig);
+        //2024年08月09日14:26:29  为了节省费用，测试环境关闭报警并增加手动触发报警操作
+        if(PROD_ENVIRONMENT.equalsIgnoreCase(environment)){
+            //水质报警
+            this.handleSZWarning(tXinyiIndustry, normConfig);
 
-        //2024年5月28日14:14:26  下面是新增的 生化报警处理
-        this.handleSHWarning(tXinyiIndustry, normConfig, xinyiCalculate);
+            //2024年5月28日14:14:26  下面是新增的 生化报警处理
+            this.handleSHWarning(tXinyiIndustry, normConfig, xinyiCalculate);
+        }
 
         //2024年7月3日18:01:13 额外处理大表数据
         this.addBigTable(tXinyiIndustry, xinyiCalculate);

slibra-quartz/src/main/java/com/slibra/quartz/task/RyTask.java

@@ -35,6 +35,7 @@ import io.grpc.ManagedChannel;
 import io.grpc.ManagedChannelBuilder;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import com.slibra.common.utils.StringUtils;
 import org.springframework.util.CollectionUtils;
@@ -117,6 +118,10 @@ public class RyTask
     @Autowired
     private JsCsFormatData jsCsFormatData;
 
+    /** 使用的是哪个环境 */
+    @Value("${spring.profiles.active}")
+    private String environment;
+
 
 //    public final static StopWatch watch = new StopWatch("task");
     public static final String[] queryTags = {"信义污水厂JS_COD_Value","信义污水厂JS_PH_Value","信义污水厂JS_SS_Value","信义污水厂JS_ZL_Value","信义污水厂JS_ZA_Value","信义污水厂JS_AD_Value","信义污水厂JS_T_Value","信义污水厂进水泵房液位","信义污水厂出水瞬时流量","信义污水厂升级出水COD","信义污水厂升级出水PH","信义污水厂升级出水SS","信义污水厂升级出水TN","信义污水厂升级出水TP","信义污水厂升级出水氨氮","信义污水厂AIT202_Value","信义污水厂AIT203_Value","信义污水厂AIT207_Value","信义污水厂AIT206_Value","信义污水厂AIT209_Value","信义污水厂AIT210_Value","信义污水厂进水TDS","信义污水厂FT101_Value","信义污水厂SWCHHYHLB1_R_Value","信义污水厂SWCHHYHLB2_R_Value","信义污水厂SWCHHYHLB3_R_Value","信义污水厂SWCHHYHLB4_R_Value","信义污水厂SWCHHYHLB5_R_Value","信义污水厂SWCHHYHLB6_R_Value","信义污水厂SWCWNHLB1_R_Value","信义污水厂SWCWNHLB2_R_Value","信义污水厂SWCWNHLB3_R_Value","信义污水厂SWCWNHLB4_R_Value","信义污水厂SWCWNHLB5_R_Value","信义污水厂GFJ1_R_Value","信义污水厂GFJ2_R_Value","信义污水厂GFJ3_R_Value","信义污水厂GFJ4_R_Value","信义污水厂GFJ5_R_Value","信义污水厂GFJ6_R_Value","信义污水厂GFJ1_KQLL_Value","信义污水厂GFJ2_KQLL_Value","信义污水厂GFJ3_KQLL_Value","信义污水厂GFJ4_KQLL_Value","信义污水厂GFJ5_KQLL_Value","信义污水厂GFJ6_KQLL_Value","信义污水厂实际碳源加药量","信义污水厂除磷加药瞬时流量", "信义污水厂_除磷P04预测值_"};
@@ -633,23 +638,27 @@ public class RyTask
                             Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(TXinyiRobot::getTestHour))),
                             ArrayList::new
                     ));
-        if(!CollectionUtils.isEmpty(uniqueList))
-            for (TXinyiRobot tXinyiRobot : uniqueList) {
-                //判断是否添加过了(小时)
-                String testHour = tXinyiRobot.getTestHour();
-                List<TXinyiRobot> tXinyiRobotList = this.xinyiRobotMapper.selectTXinyiRobotList(TXinyiRobot.builder().testHour(testHour).build());
-                if(CollectionUtils.isEmpty(tXinyiRobotList)){
-                    this.xinyiRobotMapper.insertTXinyiRobot(tXinyiRobot);
-                    //2024年6月18日10:45:20 额外计算一下预测的准确度
-                    asyncTask.updateForecastComparisonByRobot(tXinyiRobot);
-
-                    //2024年7月6日10:32:36  大宽表的数据处理
-                    asyncTask.updateBigTableHourByRobot(tXinyiRobot);
+            if(!CollectionUtils.isEmpty(uniqueList)){
+                for (TXinyiRobot tXinyiRobot : uniqueList) {
+                    //判断是否添加过了(小时)
+                    String testHour = tXinyiRobot.getTestHour();
+                    List<TXinyiRobot> tXinyiRobotList = this.xinyiRobotMapper.selectTXinyiRobotList(TXinyiRobot.builder().testHour(testHour).build());
+                    if(CollectionUtils.isEmpty(tXinyiRobotList)){
+                        this.xinyiRobotMapper.insertTXinyiRobot(tXinyiRobot);
+                        //2024年6月18日10:45:20 额外计算一下预测的准确度
+                        asyncTask.updateForecastComparisonByRobot(tXinyiRobot);
+
+                        //2024年7月6日10:32:36  大宽表的数据处理
+                        asyncTask.updateBigTableHourByRobot(tXinyiRobot);
+                    }
+                    else
+                        log.info("{}已经吧保存过了，无需重复保存***&&&···", testHour);
+                }
+                //2024年08月09日14:26:29  为了节省费用，测试环境关闭报警并增加手动触发报警操作
+                if(PROD_ENVIRONMENT.equalsIgnoreCase(environment)){
+                    asyncTask.handleRobotWarning(uniqueList);
                 }
-                else
-                    log.info("{}已经吧保存过了，无需重复保存***&&&···", testHour);
             }
-        asyncTask.handleRobotWarning(uniqueList);
         }
 
     }
@@ -732,8 +741,10 @@ public class RyTask
 //                    handleXinYiWarningsYC(cscodBzz, split, cscodGkz, BusinessEnum.WarningCategoryEnum.CS_COD_YC.getCode(), hour, normConfig);
                     continue;
                 }
-                //解析数据 处理报警 调研prompt 保存等
-                this.handlePredictorWarning(split, hour, task, tXinyiIndustries6, tXinyiRobots6, date);
+                if(PROD_ENVIRONMENT.equalsIgnoreCase(environment)){
+                    //解析数据 处理报警 调研prompt 保存等
+                    this.handlePredictorWarning(split, hour, task, tXinyiIndustries6, tXinyiRobots6, date);
+                }
             }else {
                 log.error("预测数据返回结果为{},无法正常解析", result);
             }