Ver código fonte

预测正磷酸盐prompt优化 修复更新报警的时,没有报警报警原因字段

wangmiaomiao 8 meses atrás
pai
commit
1bb635a9a7

+ 8 - 0
slibra-quartz/src/main/java/com/slibra/quartz/task/AsyncTask.java

@@ -1076,6 +1076,8 @@ public class AsyncTask {
                         xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                         //2024年7月15日11:07:33 报警的级别也要重新计算并更新
                         xinyiWarningRecord.setLevel(tXinyiWarningRecord.getLevel());
+                        //2024年7月31日09:20:47 报警的原因(超标还是超管控也需要更新)
+                        xinyiWarningRecord.setReason(tXinyiWarningRecord.getReason());
                         //更新数据库
                         this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                         //继续调用决策(普通问答)
@@ -1752,6 +1754,8 @@ public class AsyncTask {
                         xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                         //2024年7月15日11:07:33 报警的级别也要重新计算并更新
                         xinyiWarningRecord.setLevel(tXinyiWarningRecord.getLevel());
+                        //2024年7月31日09:20:47 报警的原因(超标还是超管控也需要更新)
+                        xinyiWarningRecord.setReason(tXinyiWarningRecord.getReason());
                         //更新数据库
                         this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                         //继续调用决策
@@ -1862,6 +1866,8 @@ public class AsyncTask {
                         xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                         //2024年7月15日11:07:33 报警的级别也要重新计算并更新
                         xinyiWarningRecord.setLevel(tXinyiWarningRecord.getLevel());
+                        //2024年7月31日09:20:47 报警的原因(超标还是超管控也需要更新)
+                        xinyiWarningRecord.setReason(tXinyiWarningRecord.getReason());
                         //更新数据库
                         this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                         //继续调用决策
@@ -2185,6 +2191,8 @@ public class AsyncTask {
                         xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                         //2024年7月15日11:07:33 报警的级别也要重新计算并更新
                         xinyiWarningRecord.setLevel(tXinyiWarningRecord.getLevel());
+                        //2024年7月31日09:20:47 报警的原因(超标还是超管控也需要更新)
+                        xinyiWarningRecord.setReason(tXinyiWarningRecord.getReason());
                         //更新数据库
                         this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                         //继续调用决策

+ 12 - 4
slibra-quartz/src/main/java/com/slibra/quartz/task/RyTask.java

@@ -1439,6 +1439,8 @@ public class RyTask
                         xinyiWarningRecord.setUpdateBy(WARNING_DEFAULT_CREATE);
                         //2024年7月15日11:07:33 报警的级别也要重新计算并更新
                         xinyiWarningRecord.setLevel(tXinyiWarningRecord.getLevel());
+                        //2024年7月31日09:20:47 报警的原因(超标还是超管控也需要更新)
+                        xinyiWarningRecord.setReason(tXinyiWarningRecord.getReason());
                         //更新数据库
                         this.xinyiWarningRecordMapper.updateTXinyiWarningRecord(xinyiWarningRecord);
                         //继续调用决策
@@ -1480,8 +1482,11 @@ public class RyTask
             //查询最近7天的二沉池正磷酸盐数据
             List<HashMap<String, Object>> list = this.xinyiRobotMapper.selectAvg7Datas();
             if(!CollectionUtils.isEmpty(list)){
-                for (HashMap<String, Object> map : list) {
-                    prompt.append(map.get("DATE")).append(map.get("VAL")).append(",");
+                for (int i = 0; i < list.size(); i++) {
+                    HashMap<String, Object> map = list.get(i);
+                    prompt.append(map.get("DATE")).append(":").append(DecimalUtils.getAbsAndScale(new BigDecimal(map.get("VAL").toString()), INT_2));
+                    if(i < list.size() -1)//不是最后一条
+                        prompt.append(",");
                 }
             }
             prompt.append(";");
@@ -1489,8 +1494,11 @@ public class RyTask
             //查询最近7天的进水总磷数据
             List<TXinyiDaily> tXinyiDailies = this.xinyiDailyMapper.selectNRecords(7);
             if(!CollectionUtils.isEmpty(tXinyiDailies)){
-                for (TXinyiDaily tXinyiDaily : tXinyiDailies) {
-                    prompt.append(tXinyiDaily.getTestDate()).append(tXinyiDaily.getJsTp()).append(",");
+                for (int i = 0; i < tXinyiDailies.size(); i++) {
+                    TXinyiDaily tXinyiDaily = tXinyiDailies.get(i);
+                    prompt.append(tXinyiDaily.getTestDate()).append(":").append(DecimalUtils.getAbsAndScale(tXinyiDaily.getJsTp(), INT_2));
+                    if(i < tXinyiDailies.size() -1)//不是最后一条
+                        prompt.append(",");
                 }
             }
             prompt.append(";");