状态监控接口

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

@@ -234,5 +234,19 @@ public class MonitorFanIdxController extends BaseController {
         return ResponseHelper.buildResponse(detailsWindSpeed);
     }
 
+    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "状态监控")
+    @GetMapping("/statusMonitoring")
+    public ResponseModel<IPage<Map<String, Object>>> getStatusMonitoring(@RequestParam(value = "stationId", required = true)String stationId,String equipNum,String systemType) {
+        StationBasic stationBasic = stationBasicMapper.selectById(stationId);
+        String gatewayId = stationBasic.getFanGatewayId();
+        List<Map<String, Object>> statusMonitoring = monitorFanIndicator.getStatusMonitoring(gatewayId, equipNum, systemType);
+        IPage<Map<String,Object>> result = new Page<>();
+        result.setRecords(statusMonitoring);
+        result.setCurrent(1);
+        result.setTotal(statusMonitoring.size());
+        return ResponseHelper.buildResponse(result);
+    }
+
 
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/dto/SystemEnumDto.java

+package com.yeejoin.amos.boot.module.jxiop.biz.dto;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+public class SystemEnumDto {
+    private Long sequenceNumber;
+    private String type;
+    private String syetemName;
+    private String code;
+    private String enumDesc;
+    private String eunmValue;
+    private String gatewayId;
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/SystemEnum.java

+package com.yeejoin.amos.boot.module.jxiop.biz.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+@TableName("system_enum")
+public class SystemEnum {
+    @TableField("sequence_nbr")
+    private Long sequenceNumber;
+    @TableField("type")
+    private String type;
+    @TableField("system_name")
+    private String syetemName;
+    @TableField("code")
+    private String code;
+    @TableField("enum_desc")
+    private String enumDesc;
+    @TableField("eunm_value")
+    private String eunmValue;
+    @TableField("gatewayId")
+    private String gatewayId;
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/SystemEnumMapper.java

+package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.dto.SystemEnumDto;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.SystemEnum;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.TemporaryData;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.List;
+import java.util.Map;
+
+public interface SystemEnumMapper extends BaseMapper<SystemEnum> {
+
+
+    List<SystemEnumDto> getStatusMonitoring(String type,String systemName);
+
+
+}

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

@@ -16,13 +16,11 @@ import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
 import com.yeejoin.amos.boot.module.jxiop.api.mapper.MonitorFanIndicatorMapper;
 import com.yeejoin.amos.boot.module.jxiop.api.mapper.RegionMapper;
 import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
-import com.yeejoin.amos.boot.module.jxiop.biz.dto.ColModel;
-import com.yeejoin.amos.boot.module.jxiop.biz.dto.DataGridMock;
-import com.yeejoin.amos.boot.module.jxiop.biz.dto.IndicatorsDto;
-import com.yeejoin.amos.boot.module.jxiop.biz.dto.ResultsData;
+import com.yeejoin.amos.boot.module.jxiop.biz.dto.*;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.SjglZsjZsbtz;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.TemporaryData;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.TpriDmpDatabook;
+import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.SystemEnumMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.TemporaryDataMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.utils.InfluxDButils;
 import com.yeejoin.amos.boot.module.jxiop.biz.service.IMonitorFanIndicator;
@@ -58,6 +56,9 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
     @Autowired
     InfluxDButils influxDButils;
 
+    @Autowired
+    SystemEnumMapper systemEnumMapper;
+
 
     @Autowired
     TemporaryDataMapper temporaryDataMapper;
@@ -475,4 +476,28 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
     }
 
 
+    public List<Map<String,Object>>  getStatusMonitoring(String gatewayId,String equipNum,String systemName){
+        String sql =   "SELECT * FROM indicators_"+gatewayId+" WHERE equipmentNumber = '"+equipNum+"' and equipmentIndexName =~/实时故障/";
+        List<IndicatorsDto> listData = influxDButils.getListData(sql, IndicatorsDto.class);
+        String type = listData.get(0).getEquipmentSpecificName().substring(0,5);
+        List<SystemEnumDto> statusMonitoring = systemEnumMapper.getStatusMonitoring(type, systemName);
+        List<Map<String,Object>> statusMaps = new ArrayList<>();
+        for (SystemEnumDto systemEnumDto : statusMonitoring) {
+            Map<String, Object> statusMap = new HashMap<>();
+            statusMap.put("title1",systemEnumDto.getEnumDesc());
+            for (IndicatorsDto listDatum : listData) {
+                if (listDatum.getEquipmentSpecificName().contains(systemEnumDto.getCode()) &&
+                        systemEnumDto.getEunmValue().equals(listDatum.getValue())){
+                    statusMap.put("state","1");
+                }else {
+                    statusMap.put("state","0");
+                }
+            }
+            statusMaps.add(statusMap);
+        }
+        return  statusMaps;
+    }
+
+
+
 }
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/resources/mapper/cluster/SystemEnumMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.mapper2.SystemEnumMapper">
+
+
+
+    <select id="getStatusMonitoring" resultType="com.yeejoin.amos.boot.module.jxiop.biz.dto.SystemEnumDto">
+        SELECT * FROM `system_enum` WHERE type = #{type} and system_name = #{systemName}
+    </select>
+</mapper>