按照今日会议 做的相关调整

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

@@ -29,25 +29,15 @@ public class MyConstants {
     public static final String JIAN_BAO_END = "简报";
 
     //简报的prompt
-    public static final String JIAN_BAO_PROMPT = "作为一个工艺分析师，请生成一份#{0}日分析报告，根据我提供的详细数据，输出一份详细的分析报告。报告需数据准确、分析深入，所有小数均保留两位小数，建议具体可行，以便为水务管理和决策提供支持。整体文字在500字内，报告分为三部分：\n" +
-            "\n" +
-            "\n" +
-            "\n" +
-            "     1、水质数据指标超标情况分析\n" +
-            "\n" +
-            "     2、对于超标的数据推送解决方案，没有超标情况的话，对比前一日数据，计算数据同比和可能出现异常的情况\n" +
-            "\n" +
-            "     3、提出针对性的改善建议，包括但不限于优化处理工艺、加强水质监测、改善水源保护等。\n" +
-            "\n" +
-            "   \n" +
-            "\n" +
-            "     #{0}日进出水质数据：\n" +
+    public static final String JIAN_BAO_PROMPT = "作为一个工艺分析师，请生成一份#{0}分析报告，根据我提供的详细数据，输出一份详细的分析报告。报告需数据准确、分析深入，建议具体可行，以便为水务管理和决策提供支持。报告分为三部分： 1、水质数据指标超标情况分析，不用列出数值，只写是否有超标情况，并分析 2、对于超标的数据推送解决方案，没有超标情况的话，对比前一日数据，计算数据环比的增减具体比值，并分析每项指标的具体情况 3、提出针对性的改善建议，包括优化处理工艺点，每项调整点不要太概括，一定要给出具体调整数据\n" +
+            "4、所有小数均保留两位小数" +
+            "     #{0}进出水质数据：\n" +
             "\n" +
             "进水  -  COD：#{2}mg/L  、 TN：#{3}mg/L 、TP：#{4}mg/L、NH3-N：#{5}mg/L、SS：#{6}mg/L、进水水量：#{7}m³/d\n" +
             "\n" +
             "出水  -  COD：#{8}mg/L  、 TN：#{9}mg/L 、TP：#{10}mg/L、NH3-N：#{11}mg/L、SS：#{12}mg/L、出水水量：#{13}m³/d\n" +
             "\n" +
-            "     #{1}日进出水质数据：\n" +
+            "     #{1}进出水质数据：\n" +
             "\n" +
             "\n" +
             "\n" +

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

@@ -79,10 +79,11 @@ public class AsyncTask {
     }
 
     private void handleSHWarning(TXinyiIndustry tXinyiIndustry, TXinyiNormConfig normConfig) {
+        //todo 2024年5月31日13:53:36 生化报警目前只要do的 并且要超标
         //判断对应指标是否报警  然后调研大模型获取决策信息
         BigDecimal jsSlq = tXinyiIndustry.getJsSlq();
         //内回流比报警
-        BigDecimal nhlbSjz = normConfig.getNhlbSjz();//400
+        /*BigDecimal nhlbSjz = normConfig.getNhlbSjz();//400
         BigDecimal nhlbnkSxz = normConfig.getNhlbnkSxz();//360
         BigDecimal nhlbqdsl = normConfig.getNHLBQDSL();
         BigDecimal nhlbdsjll = normConfig.getNHLBDSJLL();
@@ -106,7 +107,7 @@ public class AsyncTask {
             if(!Objects.isNull(whlbSjz)){
                 handleXinYiWarningsSH(whlbSjz, divide, whlbnkXxz, BusinessEnum.WarningCategoryEnum.WHLB.getCode(), tXinyiIndustry, normConfig);
             }
-        }
+        }*/
 
 
         //最新的一条日报数据
@@ -123,7 +124,7 @@ public class AsyncTask {
 
         //碳氮比(需要从日报获取数据)
         //进水碳氮比=[b]=[BOD_in]/[TN_in]
-        BigDecimal jsTn = tXinyiIndustry.getJsTn();
+        /*BigDecimal jsTn = tXinyiIndustry.getJsTn();
         if(!Objects.isNull(jsBod5) && !Objects.isNull(jsTn)){
             BigDecimal divide = jsBod5.divide(jsTn, 4, RoundingMode.HALF_UP);
             BigDecimal jstdbnkzSxz = normConfig.getJstdbnkzSxz();
@@ -158,30 +159,31 @@ public class AsyncTask {
                 handleXinYiWarningsSH(gkz, divide, jsbodycodbzSzj, BusinessEnum.WarningCategoryEnum.BODCODB.getCode(), tXinyiIndustry, normConfig);
             }
 
-        }
+        }*/
 
-        //好氧区DO（一池）
-        BigDecimal shcHyOneDo = tXinyiIndustry.getOneHymdDo();
+        //好氧区DO（一池） 2024年5月31日14:04:37 加数据，让他一直报警
+//        BigDecimal shcHyOneDo = tXinyiIndustry.getOneHymdDo();
+        BigDecimal shcHyOneDo = new BigDecimal("5");
         BigDecimal hycrjysjzSxz = normConfig.getHycrjysjzSxz();
         BigDecimal hycrjyNkz = normConfig.getHycrjyNkz();
         if(!Objects.isNull(shcHyOneDo) && !Objects.isNull(hycrjysjzSxz)){
             handleXinYiWarningsSH(hycrjysjzSxz, shcHyOneDo, hycrjyNkz, BusinessEnum.WarningCategoryEnum.HYQDO_ONE.getCode(), tXinyiIndustry, normConfig);
         }
-        //好氧区DO（二池）
-        BigDecimal shcHyTwoDo = tXinyiIndustry.getTwoHymdDo();
+        //好氧区DO（二池） 2024年5月31日14:09:36 溶解氧从日报获取  工业的不准
+        BigDecimal shcHyTwoDo = tXinyiDaily.getShcHyTwoDo();
         if(!Objects.isNull(shcHyTwoDo) && !Objects.isNull(hycrjysjzSxz)){
             handleXinYiWarningsSH(hycrjysjzSxz, shcHyTwoDo, hycrjyNkz, BusinessEnum.WarningCategoryEnum.HYQDO_TWO.getCode(), tXinyiIndustry, normConfig);
         }
 
         //气水比(需要从日报获取数据)
-        BigDecimal gfjgzts = normConfig.getGFJGZTS();
+        /*BigDecimal gfjgzts = normConfig.getGFJGZTS();
         BigDecimal gfjckll = normConfig.getGFJCKLL();
         BigDecimal shcqbSjz = normConfig.getShcqbSjz();
         if(!Objects.isNull(gfjgzts) && !Objects.isNull(gfjckll) && !Objects.isNull(shcqbSjz) && !Objects.isNull(jsSlq)){
             BigDecimal qsb = gfjgzts.multiply(gfjckll).divide(jsSlq, 4, RoundingMode.HALF_UP);
             BigDecimal shcqbNkz = normConfig.getShcqbNkz();
             handleXinYiWarningsSH(shcqbSjz, qsb, shcqbNkz, BusinessEnum.WarningCategoryEnum.WHLB.getCode(), tXinyiIndustry, normConfig);
-        }
+        }*/
     }
 
 

slibra-system/src/main/java/com/slibra/business/service/impl/FrontServiceImpl.java

@@ -261,6 +261,13 @@ public class FrontServiceImpl implements IFrontService {
         req.put("recordNumbers", 100000);
         String body = HttpRequest.post(url).header("Authorization", "c2E6c2E=").header("clientName", "hongshan").body(JSON.toJSONString(req)).execute().body();
 //            System.out.println("body = " + body);
+        log.info("实时数据返回的结果是{}", body);
+        //2024年5月31日13:43:24  新增解析内容，判断是否正常返回
+        String errorCode = (String) JSON.parseObject(body).get("errorCode");
+        if("-1".equals(errorCode)){
+            log.info("工业库数据返回错误");
+            return new XinyiIndustrySimple();
+        }
         List<HashMap<String, String>> list = new ArrayList<>();
 
         //行转列数据处理