优化sql语句

nb-service/web-service/src/main/java/com/nb/web/service/bus/hospital/config/HospitalFunctionExtraConfigHandler.java

@@ -1,5 +1,6 @@
 package com.nb.web.service.bus.hospital.config;
 
+import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.extra.spring.SpringUtil;
 import com.nb.web.api.enums.FlowStatusEnum;
 import com.nb.web.service.bus.hospital.config.bean.FunctionExtraConfig;
@@ -109,7 +110,11 @@ public class HospitalFunctionExtraConfigHandler  extends  AbstractHospitalConfig
         //仅智能泵存在
         if(DeviceTypeEnum.intelligent.equals(source.getType())){
             DeviceOperator operator = deviceRegistry.getOperator(source.getDeviceId());
-            if (source.getFlowDownLimit()!=null&&source.getContinueDose().compareTo(source.getFlowDownLimit())<1) {
+            if(source.getFlowUpLimit()!=null&&ObjectUtil.compare(source.getContinueDose(),source.getFlowUpLimit())>=0){
+                source.setWarnFlow(FlowStatusEnum.MaxFlow);
+            }
+            if (source.getFlowDownLimit()!=null
+                    &&source.getContinueDose().compareTo(source.getFlowDownLimit())<1) {
                 if(log.isDebugEnabled()) {
                     log.debug("消息【{}】,设备【{}】，持续量【{}】，下限【{}】，触发【低输注】判定", source.getMsgId(),source.getDeviceId(), source.getContinueDose(), source.getFlowDownLimit());
                 }

nb-service/web-service/src/main/java/com/nb/web/service/bus/service/LocalBusDeviceAlarmService.java

@@ -173,9 +173,6 @@ public class LocalBusDeviceAlarmService extends BaseService<BusDeviceAlarmMapper
             alarmMap.put(deviceAlarmResult.getTenantId(),map);
         }
 
-
-
-
         // 获取告警信息
         List<DeviceWarnCountResult> warnResults = this.baseMapper.selectWarnCount(query);
         //处理告警信息
@@ -198,8 +195,7 @@ public class LocalBusDeviceAlarmService extends BaseService<BusDeviceAlarmMapper
         }
 
         // 遍历医院
-        for (BusHospitalEntity hospital:hospitalEntities
-             ) {
+        for (BusHospitalEntity hospital:hospitalEntities) {
             DeviceUse deviceUse = new DeviceUse();
             deviceUse.setTenantId(hospital.getId());
             deviceUse.setAddress(hospital.getAddress());