参数阈值报警

huimv-ql-farm/huimv-ql-production/src/main/java/com/huimv/production/task/WarningParameterTask.java

@@ -39,7 +39,7 @@ public class WarningParameterTask {
     @Autowired
     private WarningParameterEntityRepo warningParameterEntityRepo;
 
-    @Scheduled(cron = "0 46 14 * * ?")
+    @Scheduled(cron = "0 0 0/12 * * ?")
     public void warningTask() {
         List<ConfigEntity> all = configEntityRepo.findAll();
         ConfigEntity configEntity = all.get(0);
@@ -54,7 +54,8 @@ public class WarningParameterTask {
                             .anyMatch(w -> w.getParameterName().equals(localEntity.getName())))
                     .collect(Collectors.toList());
 
-            List<IndexParameter2Entity> collect1 = collect.stream().filter(s -> warningParameterList.stream().anyMatch(warningParameter -> warningParameter.getParameterName().equals(s.getName()) && warningParameter.getThresholdValue() < Double.parseDouble(s.getData())))
+            List<IndexParameter2Entity> collect1 = collect.stream().filter(s -> warningParameterList.stream()
+                    .anyMatch(warningParameter -> warningParameter.getParameterName().equals(s.getName()) && warningParameter.getThresholdValue() >= Double.parseDouble(s.getData())))
                     .collect(Collectors.toList());
 
             for (IndexParameter2Entity indexParameter2Entity : collect1) {
@@ -72,7 +73,8 @@ public class WarningParameterTask {
                             .anyMatch(w -> w.getParameterName().equals(localEntity.getName())))
                     .collect(Collectors.toList());
 
-            List<IndexParameterEntity> collect1 = collect.stream().filter(s -> warningParameterList.stream().anyMatch(warningParameter -> warningParameter.getParameterName().equals(s.getName()) && warningParameter.getThresholdValue() >= Double.parseDouble(s.getData())))
+            List<IndexParameterEntity> collect1 = collect.stream().filter(s -> warningParameterList.stream()
+                    .anyMatch(warningParameter -> warningParameter.getParameterName().equals(s.getName()) && warningParameter.getThresholdValue() >= Double.parseDouble(s.getData())))
                     .collect(Collectors.toList());
 
             for (IndexParameterEntity indexParameter2Entity : collect1) {