风机三维告警接口提交

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/MonitorFanIdxController.java

@@ -765,5 +765,11 @@ public class MonitorFanIdxController extends BaseController {
         return ResponseHelper.buildResponse(result);
     }
 
-
+    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "风机-三维告警")
+    @GetMapping("/partofWaring3D")
+    public ResponseModel<Map<String, Object>> partofWaring3D(@RequestParam(value = "stationId")String stationId,@RequestParam(value = "equipNum") String equipNum) {
+        Map<String, Object> result = monitorFanIndicator.partofWaring3D(stationId,equipNum);
+        return ResponseHelper.buildResponse(result);
+    }
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/IMonitorFanIndicator.java

@@ -5,6 +5,7 @@ import com.yeejoin.amos.boot.module.jxiop.biz.dto.ResultsData;
 import org.springframework.web.bind.annotation.RequestParam;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * @description:
@@ -17,4 +18,6 @@ public interface IMonitorFanIndicator {
 
     ResultsData getNationWideInfo( int current, int size,  String stationBasicId, String equipmentNumber);
     ResultsData getLsNationWideInfo( int current, int size,  String stationBasicId, String equipmentNumber);
+
+    Map<String, Object> partofWaring3D(String stationId, String equipNum);
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/MonitorFanIndicatorImpl.java

@@ -31,6 +31,7 @@ import com.yeejoin.amos.component.robot.BadRequest;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.velocity.runtime.directive.Break;
 import org.eclipse.paho.client.mqttv3.MqttException;
 import org.elasticsearch.common.recycler.Recycler;
 import org.springframework.beans.BeanUtils;
@@ -186,6 +187,8 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
         return resultsData;
     }
 
+
+
     public IPage<IndexDto> getFanIdxInfoByPage(String equipNum, String stationId, String frontModule, int current, int size, String systemType) {
         StationBasic stationBasic = getOneByStationNumber(stationId);
         Page<IndexDto> page = new Page<>(current, size);
@@ -1649,5 +1652,30 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
         map.put("axisData",timeMap.keySet());
         return map;
     }
+
+    @Override
+    public Map<String, Object> partofWaring3D(String stationId, String equipNum) {
+        Map<String,Object> resultMap=new HashMap<>();
+        StationBasic stationBasic = stationBasicMapper.selectById(stationId);
+        String querySql = "SELECT * FROM indicators_"+stationBasic.getFanGatewayId()+" WHERE equipmentNumber = '"+equipNum+"' and equipmentIndexName =~/实时故障/";
+        List<IndicatorsDto> indicatorsDtoList  = influxDButils.getListData(querySql,IndicatorsDto.class);
+        //获取风机型号
+        String type = indicatorsDtoList.get(0).getEquipmentSpecificName().substring(0,5);
+        List<String> sytemNames =Arrays.asList("发电机系统","机舱与塔筒系统","变流与主控系统","偏航与液压系统","叶轮系统");
+        List<SystemEnum> systemEnumListAll = systemEnumMapper.selectList(new QueryWrapper<SystemEnum>().isNotNull("system_name"));
+        sytemNames.forEach(name->{
+            resultMap.put(name,false);
+            List<SystemEnum> systemEnumList = systemEnumListAll.stream().filter(systemEnum -> systemEnum.getSyetemName().equals(name)).collect(Collectors.toList());
+            outer:for(SystemEnum systemEnum:systemEnumList) {
+                for (IndicatorsDto indicatorsDto : indicatorsDtoList) {
+                    if (indicatorsDto.getEquipmentSpecificName().contains(systemEnum.getCode()) && indicatorsDto.getValue().equals(systemEnum.getEunmValue())) {
+                        resultMap.put(name, true);
+                        break outer;
+                    }
+                }
+            }
+        });
+        return resultMap;
+    }
 }