bug修改

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

@@ -597,6 +597,7 @@ public class RyTask
         BigDecimal multiply = csBzz.multiply(new BigDecimal(MyConstants.SCALE_VALUE));
         TXinyiWarningRecord tXinyiWarningRecord = new TXinyiWarningRecord();
         /*String category = BusinessEnum.WarningCategoryEnum.CS_AD.getCode();*/
+        tXinyiWarningRecord.setStatus(0);
         tXinyiWarningRecord.setType(0);
         tXinyiWarningRecord.setCategory(category);
         tXinyiWarningRecord.setTime(DateUtils.getNowDate());
@@ -639,7 +640,11 @@ public class RyTask
                 //继续调用决策
                 this.handleDecision(tXinyiWarningRecord, tXinyiIndustry, normConfig);
             }else{
-                log.info("{}:之前已经有过告警记录了，且还是继续报警，无需重复处理", category);
+                log.info("{}:之前已经有过告警记录了，且还是继续报警，无需重复添加报警，但是决策仍然要调用", category);
+                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {//理论上只有一个的
+                    //继续调用决策
+                    this.handleDecision(tXinyiWarningRecord, tXinyiIndustry, normConfig);
+                }
             }
         }
 
@@ -660,6 +665,7 @@ public class RyTask
         BigDecimal multiply = jsBzz.multiply(new BigDecimal(MyConstants.SCALE_VALUE));
         TXinyiWarningRecord tXinyiWarningRecord = new TXinyiWarningRecord();
         /*String category = BusinessEnum.WarningCategoryEnum.CS_AD.getCode();*/
+        tXinyiWarningRecord.setStatus(0);
         tXinyiWarningRecord.setType(0);
         tXinyiWarningRecord.setCategory(category);
         tXinyiWarningRecord.setTime(DateUtils.getNowDate());
@@ -703,7 +709,11 @@ public class RyTask
                 //继续调用决策
                 this.handleDecision(tXinyiWarningRecord, tXinyiIndustry, normConfig);
             }else{
-                log.info("{}:之前已经有过告警记录了，且还是继续报警，无需重复处理", category);
+                log.info("{}:之前已经有过告警记录了，且还是继续报警，无需重复添加报警，但是决策仍然要调用", category);
+                for (TXinyiWarningRecord xinyiWarningRecord : tXinyiWarningRecords) {//理论上只有一个的
+                    //继续调用决策
+                    this.handleDecision(tXinyiWarningRecord, tXinyiIndustry, normConfig);
+                }
             }
         }
     }