常量和枚举的优化

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

@@ -94,6 +94,10 @@ public class MyConstants {
     public static final int DAILY_RECORDS_TOTAL = 30;
     public static final int DAILY_REPORT_COUNT_RECORD = 7;
     public static final String JIAN_BAO_END = "简报";
+    public static final String LIANXUJIANCE = "连续检测";
+    public static final String YVCE = "预测";
+    public static final String ZAIXIANYIBIAO = "在线仪表";
+    public static final String CHUSHUI = "出水";
 
     //简报的prompt
     public static final String JIAN_BAO_PROMPT = "作为一个工艺分析师，请生成一份#{0}分析报告，根据我提供的详细数据，输出一份详细的分析报告。报告需数据准确、分析深入，建议具体可行，以便为水务管理和决策提供支持。报告分为三部分： 1、水质数据指标超标情况分析，不用列出数值，只写是否有超标情况，并分析 2、对于超标的数据推送解决方案，没有超标情况的话，对比前一日数据，计算数据环比的增减具体比值，并分析每项指标的具体情况 3、提出针对性的改善建议，包括优化处理工艺点，每项调整点不要太概括，一定要给出具体调整数据 4、所有小数均保留两位小数。 以下是需要分析的数据：\n" +

slibra-common/src/main/java/com/slibra/common/enums/BusinessEnum.java

@@ -183,4 +183,39 @@ public class BusinessEnum {
             return msg;
         }
     }
+
+
+    /**
+     *
+     * 区分来源的报警类型枚举
+     *
+     */
+    public enum BigModelWarningTypeRemarkEnum
+    {
+        ZERO_SZ_WARNING("0", "水质报警"),
+        ONE_SH_WARNING("1", "生化报警"),
+        TWO_YC_WARNING("2", "预测预警"),
+        THREE_HYS_WARNING("3", "化验室报警"),
+
+        ;
+
+        private final String code;
+        private final String msg;
+
+        BigModelWarningTypeRemarkEnum(String code, String msg)
+        {
+            this.code = code;
+            this.msg = msg;
+        }
+
+        public String getCode()
+        {
+            return code;
+        }
+
+        public String getMsg()
+        {
+            return msg;
+        }
+    }
 }

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

@@ -35,6 +35,7 @@ import java.math.RoundingMode;
 import java.util.*;
 
 import static com.slibra.common.constant.MyConstants.*;
+import static com.slibra.common.enums.BusinessEnum.BigModelWarningTypeRemarkEnum.*;
 import static com.slibra.common.enums.BusinessEnum.WarningCategoryEnum.*;
 
 @Component
@@ -984,7 +985,7 @@ public class AsyncTask {
         tXinyiWarningRecord.setControlVal(sjscgkz);
         tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
         tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
-        tXinyiWarningRecord.setRemark("1");
+        tXinyiWarningRecord.setRemark(ONE_SH_WARNING.getCode());
 
         //2024年6月27日17:36:25 有一个判断是反正的
         if(normal){
@@ -1448,15 +1449,15 @@ public class AsyncTask {
         int count = DateUtils.differentHoursByMillisecond(warningTime, DateUtils.getNowDate()) + 1;
         ShowValueSHBasic showValueSHBasic = new ShowValueSHBasic();
         /*if("0".equals(remark)){//水质报警
-            showValueSHBasic.setH("在线仪表");
+            showValueSHBasic.setH(ZAIXIANYIBIAO);
             showValueSHBasic.setF(tXinyiWarningRecord.getLevel());
         }else if("1".equals(remark)){//生化报警
-            showValueSHBasic.setH("在线仪表");
+            showValueSHBasic.setH(ZAIXIANYIBIAO);
         }else if("2".equals(remark)){//预测报警
-            showValueSHBasic.setH("预测");
+            showValueSHBasic.setH(YVCE);
 //                showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
         }else {//机器人化验室报警（特殊的 水质报警）
-            showValueSHBasic.setH("连续检测");
+            showValueSHBasic.setH(LIANXUJIANCE);
             showValueSHBasic.setF(tXinyiWarningRecord.getLevel());
         }*/
         //生化报警固定了
@@ -1505,21 +1506,21 @@ public class AsyncTask {
         basic.put("告警级别", tXinyiWarningRecord.getLevel());*/
         //2024年6月25日16:00:18 进出水展示的不一样
         //2024年7月15日10:57:31 因为新增了化验室的3个指标，也是出水数据
-        if(category.contains("出水")
+        if(category.contains(CHUSHUI)
             || ROBOT_ECCZLSY.getCode().equalsIgnoreCase(category)
                 || ROBOT_XSY_2.getCode().equalsIgnoreCase(category)
                     || ROBOT_XSY_1.getCode().equalsIgnoreCase(category)){//出水的展示
             ShowValueCSBasic showValueCSBasic = new ShowValueCSBasic();
-            if("0".equals(remark)){//水质报警
-                showValueCSBasic.setH("在线仪表");
+            if(ZERO_SZ_WARNING.getCode().equals(remark)){//水质报警
+                showValueCSBasic.setH(ZAIXIANYIBIAO);
                 showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
-            }else if("1".equals(remark)){//生化报警
-                showValueCSBasic.setH("在线仪表");
-            }else if("2".equals(remark)){//预测报警
-                showValueCSBasic.setH("预测");
+            }else if(ONE_SH_WARNING.getCode().equals(remark)){//生化报警
+                showValueCSBasic.setH(ZAIXIANYIBIAO);
+            }else if(BusinessEnum.BigModelWarningTypeRemarkEnum.TWO_YC_WARNING.getCode().equals(remark)){//预测报警
+                showValueCSBasic.setH(YVCE);
 //                showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
             }else {//机器人化验室报警（特殊的水质报警）
-                showValueCSBasic.setH("连续检测");
+                showValueCSBasic.setH(LIANXUJIANCE);
                 showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
             }
             //通用的
@@ -1537,16 +1538,16 @@ public class AsyncTask {
             result.put("basic", showValueCSBasic);
         }else{//进水的展示
             ShowValueJSBasic showValueJSBasic = new ShowValueJSBasic();
-            if("0".equals(remark)){//水质报警
-                showValueJSBasic.setH("在线仪表");
+            if(ZERO_SZ_WARNING.getCode().equals(remark)){//水质报警
+                showValueJSBasic.setH(ZAIXIANYIBIAO);
                 showValueJSBasic.setF(tXinyiWarningRecord.getLevel());
-            }else if("1".equals(remark)){//生化报警
-                showValueJSBasic.setH("在线仪表");
-            }else if("2".equals(remark)){//预测报警
-                showValueJSBasic.setH("预测");
+            }else if(ONE_SH_WARNING.getCode().equals(remark)){//生化报警
+                showValueJSBasic.setH(ZAIXIANYIBIAO);
+            }else if(BusinessEnum.BigModelWarningTypeRemarkEnum.TWO_YC_WARNING.getCode().equals(remark)){//预测报警
+                showValueJSBasic.setH(YVCE);
 //                showValueCSBasic.setF(tXinyiWarningRecord.getLevel());
             }else {//机器人化验室报警（特殊的 水质报警）
-                showValueJSBasic.setH("连续检测");
+                showValueJSBasic.setH(LIANXUJIANCE);
                 showValueJSBasic.setF(tXinyiWarningRecord.getLevel());
             }
             //通用的
@@ -1664,7 +1665,7 @@ public class AsyncTask {
         tXinyiWarningRecord.setControlVal(csGkz);
         tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
         tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
-        tXinyiWarningRecord.setRemark("0");
+        tXinyiWarningRecord.setRemark(ZERO_SZ_WARNING.getCode());
 
         //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
         if(Objects.isNull(currentVal) || currentVal.compareTo(BigDecimal.ZERO) == 0){
@@ -1761,7 +1762,7 @@ public class AsyncTask {
 //        tXinyiWarningRecord.setControlVal(csGkz);
         tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
         tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
-        tXinyiWarningRecord.setRemark("0");
+        tXinyiWarningRecord.setRemark(ZERO_SZ_WARNING.getCode());
 
         //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
         if(Objects.isNull(currentVal) || currentVal.compareTo(BigDecimal.ZERO) == 0){
@@ -1954,7 +1955,7 @@ public class AsyncTask {
         tXinyiWarningRecord.setControlVal(csGkz);
         tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
         tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
-        tXinyiWarningRecord.setRemark("3");//化验室
+        tXinyiWarningRecord.setRemark(THREE_HYS_WARNING.getCode());//化验室
 
         //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
         if(Objects.isNull(currentVal)){

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

@@ -47,6 +47,7 @@ import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 import static com.slibra.common.constant.MyConstants.*;
+import static com.slibra.common.enums.BusinessEnum.BigModelWarningTypeRemarkEnum.TWO_YC_WARNING;
 
 /**
  * 定时任务调度测试
@@ -427,13 +428,13 @@ public class RyTask
         int count = DateUtils.differentHoursByMillisecond(warningTime, DateUtils.getNowDate()) + 1;*/
         ShowValueChartBasic showValueChartBasic = new ShowValueChartBasic();
         /*if("0".equals(remark)){//水质报警
-            showValueChartBasic.setH("在线仪表");
+            showValueChartBasic.setH(ZAIXIANYIBIAO);
         }else if("1".equals(remark)){//生化报警
-            showValueChartBasic.setH("在线仪表");
+            showValueChartBasic.setH(ZAIXIANYIBIAO);
         }else if("2".equals(remark)){//预测报错
-            showValueChartBasic.setH("预测");
+            showValueChartBasic.setH(YVCE);
         }else {//机器人化验室报警
-            showValueChartBasic.setH("连续检测");
+            showValueChartBasic.setH(LIANXUJIANCE);
         }*/
         //通用的
         //        showValueBasic.setA(tXinyiWarningRecord.getReason());
@@ -1197,7 +1198,7 @@ public class RyTask
             tXinyiWarningRecord.setControlVal(csGkz);
             tXinyiWarningRecord.setCreateBy(WARNING_DEFAULT_CREATE);
             tXinyiWarningRecord.setCreateTime(DateUtils.getNowDate());
-            tXinyiWarningRecord.setRemark("2");
+            tXinyiWarningRecord.setRemark(TWO_YC_WARNING.getCode());
 
             //2024年5月25日17:52:33  如果工业库获取不到数据，也触发报警，但是不调用决策接口
             if (Objects.isNull(forecastVal)) {