一个设备的一组发数只判断一次是否触发报警

src/main/java/com/persagy/service/impl/AlarmHandleServiceImpl.java

@@ -149,14 +149,22 @@ public class AlarmHandleServiceImpl implements AlarmHandleService {
             }
         }
 
-        // 将一组数据拆分为单条处理
-        for (String funcId : funcIdArray) {
-            if (alarmInfoCache.hasKey(meterId, funcId)) {
-                handleSingleIotData(dataTime, meterId, funcId);
-            } else {
-                log.info("未获取到对应的报警定义, meterId:{}, funcId:{}", meterId, funcId);
-            }
+//        // 将一组数据拆分为单条处理
+//        for (String funcId : funcIdArray) {
+//            if (alarmInfoCache.hasKey(meterId, funcId)) {
+//                handleSingleIotData(dataTime, meterId, funcId);
+//            } else {
+//                log.info("未获取到对应的报警定义, meterId:{}, funcId:{}", meterId, funcId);
+//            }
+//        }
+        // 因为所有功能点的数据都被缓存了，所以这里只处理一个功能点即可
+        String funcId = funcIdArray[0];
+        if (alarmInfoCache.hasKey(meterId, funcId)) {
+            handleSingleIotData(dataTime, meterId, funcId);
+        } else {
+            log.info("未获取到对应的报警定义, meterId:{}, funcId:{}", meterId, funcId);
         }
+
     }
 
     /**
@@ -202,7 +210,6 @@ public class AlarmHandleServiceImpl implements AlarmHandleService {
                 }
 
                 // 执行报警条件公式，得到触发和恢复结果
-
                 Boolean triggerResult = null;
                 Boolean endResult = null;
                 try {
@@ -216,6 +223,7 @@ public class AlarmHandleServiceImpl implements AlarmHandleService {
                     log.error(end);
                     log.error("参数：");
                     log.error(paramMap.toString());
+                    return;
                 }
                 log.info("triggerResult:[{}],endResult:[{}]", triggerResult, endResult);
                 if (triggerResult && endResult) {

src/main/resources/application.yml

@@ -1,5 +1,5 @@
-corePoolSize: 30
-maxPoolSize: 50
+corePoolSize: 10
+maxPoolSize: 10
 server:
   port: 8101
 spring: