报警矩阵提交

runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/monitor/MatrixController.java

@@ -3,10 +3,15 @@ package com.gyee.runeconomy.controller.monitor;/*
 @date   2023/3/28-8:43
 */
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.gyee.common.model.StringUtils;
 import com.gyee.runeconomy.dto.AjaxResult;
 import com.gyee.runeconomy.dto.R;
 import com.gyee.runeconomy.dto.ResultMsg;
+import com.gyee.runeconomy.model.auto.ProEconAlarmType;
+import com.gyee.runeconomy.model.vo.PoliceVo;
+import com.gyee.runeconomy.service.auto.IProEconAlarmTypeService;
+import com.gyee.runeconomy.service.monitor.AlarmService;
 import com.gyee.runeconomy.service.monitor.MatrixService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -18,6 +23,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
 
 import javax.annotation.Resource;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 @Controller
@@ -27,7 +33,11 @@ public class MatrixController {
     @Resource
     private MatrixService matrixService;
 
+    @Resource
+    private IProEconAlarmTypeService proEconAlarmTypeService;
 
+    @Resource
+    private AlarmService alarmService;
     /**
      * 基础矩阵
      *
@@ -67,6 +77,42 @@ public class MatrixController {
         }
     }
 
+    /**
+     * 明细矩阵弹窗-报警分类
+     *
+     * @return
+     */
+    @GetMapping("/alarmtype")
+    @ResponseBody
+    @ApiOperation(value = "报警分类", notes = "报警分类")
+    public R alarmtype(@RequestParam(value = "wtid", required = true) String wtid) throws Exception {
+        List<ProEconAlarmType> bylist = proEconAlarmTypeService.bylist(wtid);
+        if (StringUtils.isNotNull(bylist)) {
+            return R.data(ResultMsg.ok(bylist));
+        } else {
+            return R.error(ResultMsg.error());
+        }
+    }
+
+
+    /**
+     *  明细矩阵弹窗-报警信息
+     *
+     * @return
+     */
+    @GetMapping("/alarm")
+    @ResponseBody
+    @ApiOperation(value = "报警信息", notes = "报警信息")
+    public R alarm(@RequestParam(value = "type", required = true) String type,
+                      @RequestParam(value = "wtid", required = true) String wtid) throws Exception {
+
+        List<PoliceVo.AlarmDetails> resultMap = alarmService.Alarm(type,wtid);
+        if (StringUtils.isNotNull(resultMap)) {
+            return R.data(ResultMsg.ok(resultMap));
+        } else {
+            return R.error(ResultMsg.error());
+        }
+    }
 
     /**
      * 单场矩阵

runeconomy-xk/src/main/java/com/gyee/runeconomy/model/vo/PoliceVo.java

@@ -0,0 +1,415 @@
+package com.gyee.runeconomy.model.vo;
+
+import java.util.List;
+
+public class PoliceVo {
+
+    // 内部类 Data，用于表示 JSON 中的 data 部分
+    public static class Data {
+        private Integer total;  // total 字段
+        private List<AlarmDetails> ls;  // ls 字段，表示报警详细信息的列表
+
+        // Getter 和 Setter 方法
+        public Integer getTotal() {
+            return total;
+        }
+
+        public void setTotal(Integer total) {
+            this.total = total;
+        }
+
+        public List<AlarmDetails> getLs() {
+            return ls;
+        }
+
+        public void setLs(List<AlarmDetails> ls) {
+            this.ls = ls;
+        }
+    }
+
+    // 内部类 AlarmDetails，用于表示报警的详细信息
+    public static class AlarmDetails {
+        private String tbName;
+        private String alarmId;
+        private String alarmType;
+        private String characteristic;
+        private String components;
+        private Boolean confirmed;
+        private String description;
+        private String deviceId;
+        private String devicename;
+        private String deviceType;
+        private Boolean enabled;
+        private String lineid;
+        private String linename;
+        private String modelId;
+        private String projectid;
+        private String projectname;
+        private Integer rank;
+        private Boolean resettable;
+        private String stationid;
+        private String stationname;
+        private String subcomponents;
+        private String suffix;
+        private String tagid;
+        private Integer triggertype;
+        private String uniformcode;
+        private String superTableName;
+        private Long ts;
+        private Integer val;
+        private String oval;
+        private Long endts;
+        private Integer timelong;
+        private String name;
+        private String nemCode;
+        private String faultCause;
+        private String resolvent;
+        private String wpName;
+        private String code;
+        private String wpId;
+        private String faultType;
+        private String id;
+
+        // Getter 和 Setter 方法
+        public String getTbName() {
+            return tbName;
+        }
+
+        public void setTbName(String tbName) {
+            this.tbName = tbName;
+        }
+
+        public String getAlarmId() {
+            return alarmId;
+        }
+
+        public void setAlarmId(String alarmId) {
+            this.alarmId = alarmId;
+        }
+
+        public String getAlarmType() {
+            return alarmType;
+        }
+
+        public void setAlarmType(String alarmType) {
+            this.alarmType = alarmType;
+        }
+
+        public String getCharacteristic() {
+            return characteristic;
+        }
+
+        public void setCharacteristic(String characteristic) {
+            this.characteristic = characteristic;
+        }
+
+        public String getComponents() {
+            return components;
+        }
+
+        public void setComponents(String components) {
+            this.components = components;
+        }
+
+        public Boolean getConfirmed() {
+            return confirmed;
+        }
+
+        public void setConfirmed(Boolean confirmed) {
+            this.confirmed = confirmed;
+        }
+
+        public String getDescription() {
+            return description;
+        }
+
+        public void setDescription(String description) {
+            this.description = description;
+        }
+
+        public String getDeviceId() {
+            return deviceId;
+        }
+
+        public void setDeviceId(String deviceId) {
+            this.deviceId = deviceId;
+        }
+
+        public String getDevicename() {
+            return devicename;
+        }
+
+        public void setDevicename(String devicename) {
+            this.devicename = devicename;
+        }
+
+        public String getDeviceType() {
+            return deviceType;
+        }
+
+        public void setDeviceType(String deviceType) {
+            this.deviceType = deviceType;
+        }
+
+        public Boolean getEnabled() {
+            return enabled;
+        }
+
+        public void setEnabled(Boolean enabled) {
+            this.enabled = enabled;
+        }
+
+        public String getLineid() {
+            return lineid;
+        }
+
+        public void setLineid(String lineid) {
+            this.lineid = lineid;
+        }
+
+        public String getLinename() {
+            return linename;
+        }
+
+        public void setLinename(String linename) {
+            this.linename = linename;
+        }
+
+        public String getModelId() {
+            return modelId;
+        }
+
+        public void setModelId(String modelId) {
+            this.modelId = modelId;
+        }
+
+        public String getProjectid() {
+            return projectid;
+        }
+
+        public void setProjectid(String projectid) {
+            this.projectid = projectid;
+        }
+
+        public String getProjectname() {
+            return projectname;
+        }
+
+        public void setProjectname(String projectname) {
+            this.projectname = projectname;
+        }
+
+        public Integer getRank() {
+            return rank;
+        }
+
+        public void setRank(Integer rank) {
+            this.rank = rank;
+        }
+
+        public Boolean getResettable() {
+            return resettable;
+        }
+
+        public void setResettable(Boolean resettable) {
+            this.resettable = resettable;
+        }
+
+        public String getStationid() {
+            return stationid;
+        }
+
+        public void setStationid(String stationid) {
+            this.stationid = stationid;
+        }
+
+        public String getStationname() {
+            return stationname;
+        }
+
+        public void setStationname(String stationname) {
+            this.stationname = stationname;
+        }
+
+        public String getSubcomponents() {
+            return subcomponents;
+        }
+
+        public void setSubcomponents(String subcomponents) {
+            this.subcomponents = subcomponents;
+        }
+
+        public String getSuffix() {
+            return suffix;
+        }
+
+        public void setSuffix(String suffix) {
+            this.suffix = suffix;
+        }
+
+        public String getTagid() {
+            return tagid;
+        }
+
+        public void setTagid(String tagid) {
+            this.tagid = tagid;
+        }
+
+        public Integer getTriggertype() {
+            return triggertype;
+        }
+
+        public void setTriggertype(Integer triggertype) {
+            this.triggertype = triggertype;
+        }
+
+        public String getUniformcode() {
+            return uniformcode;
+        }
+
+        public void setUniformcode(String uniformcode) {
+            this.uniformcode = uniformcode;
+        }
+
+        public String getSuperTableName() {
+            return superTableName;
+        }
+
+        public void setSuperTableName(String superTableName) {
+            this.superTableName = superTableName;
+        }
+
+        public Long getTs() {
+            return ts;
+        }
+
+        public void setTs(Long ts) {
+            this.ts = ts;
+        }
+
+        public Integer getVal() {
+            return val;
+        }
+
+        public void setVal(Integer val) {
+            this.val = val;
+        }
+
+        public String getOval() {
+            return oval;
+        }
+
+        public void setOval(String oval) {
+            this.oval = oval;
+        }
+
+        public Long getEndts() {
+            return endts;
+        }
+
+        public void setEndts(Long endts) {
+            this.endts = endts;
+        }
+
+        public Integer getTimelong() {
+            return timelong;
+        }
+
+        public void setTimelong(Integer timelong) {
+            this.timelong = timelong;
+        }
+
+        public String getName() {
+            return name;
+        }
+
+        public void setName(String name) {
+            this.name = name;
+        }
+
+        public String getNemCode() {
+            return nemCode;
+        }
+
+        public void setNemCode(String nemCode) {
+            this.nemCode = nemCode;
+        }
+
+        public String getFaultCause() {
+            return faultCause;
+        }
+
+        public void setFaultCause(String faultCause) {
+            this.faultCause = faultCause;
+        }
+
+        public String getResolvent() {
+            return resolvent;
+        }
+
+        public void setResolvent(String resolvent) {
+            this.resolvent = resolvent;
+        }
+
+        public String getWpName() {
+            return wpName;
+        }
+
+        public void setWpName(String wpName) {
+            this.wpName = wpName;
+        }
+
+        public String getCode() {
+            return code;
+        }
+
+        public void setCode(String code) {
+            this.code = code;
+        }
+
+        public String getWpId() {
+            return wpId;
+        }
+
+        public void setWpId(String wpId) {
+            this.wpId = wpId;
+        }
+
+        public String getFaultType() {
+            return faultType;
+        }
+
+        public void setFaultType(String faultType) {
+            this.faultType = faultType;
+        }
+
+        public String getId() {
+            return id;
+        }
+
+        public void setId(String id) {
+            this.id = id;
+        }
+    }
+
+    // PoliceVo 的字段
+    private Integer code;  // code 字段
+    private Data data;     // data 字段，类型是 Data
+
+    // Getter 和 Setter 方法
+    public Integer getCode() {
+        return code;
+    }
+
+    public void setCode(Integer code) {
+        this.code = code;
+    }
+
+    public Data getData() {
+        return data;
+    }
+
+    public void setData(Data data) {
+        this.data = data;
+    }
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/service/EarlyWarning/ApiClient.java

@@ -43,7 +43,7 @@ public class ApiClient {
                                String deviceType,String components, String alarmId, String isclose, String pageNum,String pageSize) {
         try {
             // 构建 URL
-            String baseUrl = "http://172.16.12.101:6015/alarm/history/findAlarmlist";
+            String baseUrl = "http://10.220.1.11:6015/alarm/history/findAlarmlist";
             String charset = StandardCharsets.UTF_8.name();  // 获取字符集名称
             String url = String.format("%s?begin=%s&end=%s&alarmType=%s&stationid=%s&deviceid=%s&description=%s&modelId=%s&deviceType=%s&components=%s&alarmId=%s&isclose=%s&pageNum=%s&pageSize=%s",
                     baseUrl,

runeconomy-xk/src/main/java/com/gyee/runeconomy/service/auto/IProEconAlarmTypeService.java

@@ -3,6 +3,8 @@ package com.gyee.runeconomy.service.auto;
 import com.gyee.runeconomy.model.auto.ProEconAlarmType;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import java.util.List;
+
 /**
  * <p>
  * 自定义类型 服务类
@@ -13,4 +15,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface IProEconAlarmTypeService extends IService<ProEconAlarmType> {
 
+    List<ProEconAlarmType> bylist (String wtid);
 }

runeconomy-xk/src/main/java/com/gyee/runeconomy/service/auto/impl/ProEconAlarmTypeServiceImpl.java

@@ -1,11 +1,17 @@
 package com.gyee.runeconomy.service.auto.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.gyee.runeconomy.init.CacheContext;
+import com.gyee.runeconomy.model.auto.ProBasicEquipment;
 import com.gyee.runeconomy.model.auto.ProEconAlarmType;
 import com.gyee.runeconomy.mapper.auto.ProEconAlarmTypeMapper;
 import com.gyee.runeconomy.service.auto.IProEconAlarmTypeService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+import java.util.stream.Collectors;
+
 /**
  * <p>
  * 自定义类型 服务实现类
@@ -17,4 +23,16 @@ import org.springframework.stereotype.Service;
 @Service
 public class ProEconAlarmTypeServiceImpl extends ServiceImpl<ProEconAlarmTypeMapper, ProEconAlarmType> implements IProEconAlarmTypeService {
 
+    @Override
+    public List<ProEconAlarmType> bylist(String wtid) {
+        List<ProBasicEquipment> collect = CacheContext.wtls.stream().filter(wt -> wtid.equals(wt.getId())).collect(Collectors.toList());
+        String model = "WT2000D121H85";
+        if (collect != null || collect.size() > 0) {
+            model = collect.get(0).getModelId();
+        }
+        QueryWrapper<ProEconAlarmType> queryWrapper = new QueryWrapper<>();
+        queryWrapper.lambda().eq(ProEconAlarmType::getCategory,model);
+        List<ProEconAlarmType> proEconAlarmTypes = baseMapper.selectList(queryWrapper);
+        return proEconAlarmTypes;
+    }
 }

runeconomy-xk/src/main/java/com/gyee/runeconomy/service/monitor/AlarmService.java

@@ -0,0 +1,102 @@
+package com.gyee.runeconomy.service.monitor;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.gyee.runeconomy.dto.AlarmDataParser;
+import com.gyee.runeconomy.init.CacheContext;
+import com.gyee.runeconomy.model.auto.ProBasicEquipment;
+import com.gyee.runeconomy.model.vo.PoliceVo;
+import com.gyee.runeconomy.service.EarlyWarning.ApiClient;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Service
+public class AlarmService {
+
+    ApiClient client = new ApiClient();
+
+    public List<PoliceVo.AlarmDetails> Alarm(String type,String wtid) throws Exception {
+        // 获取当天零点时间
+        Calendar calendar = Calendar.getInstance();
+        calendar.set(Calendar.HOUR_OF_DAY, 0);
+        calendar.set(Calendar.MINUTE, 0);
+        calendar.set(Calendar.SECOND, 0);
+        calendar.set(Calendar.MILLISECOND, 0);
+        Date startDate = calendar.getTime();
+
+        // 获取当前时间
+        Date endDate = new Date();
+
+        // 格式化时间为字符串
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        String startTime = sdf.format(startDate);
+        String endTime = sdf.format(endDate);
+
+        List<PoliceVo.AlarmDetails> list = new ArrayList<>();
+
+        List<ProBasicEquipment> equipments = CacheContext.wtls.stream()
+                .filter(a -> wtid.equals(a.getId())).collect(Collectors.toList());
+
+        String modelId = "WT2000D121H85";
+        String station = "NX_FGS_HA_FDC_STA";
+        if (equipments.size() > 0) {
+            modelId = equipments.get(0).getModelId();
+            station = equipments.get(0).getWindpowerstationId();
+        }
+
+
+//        startTime = "2024-12-12 00:00:00";
+        String result = client.getgzFromApi(
+                startTime,
+                endTime,
+                "windturbine",
+                station,
+                wtid,
+                "",
+                modelId,
+                "windturbine",
+                type,
+                "",
+                "",
+                "1",
+                "20"
+        );
+
+
+        // 解析预警数据
+        try {
+            // 调用parseJson方法解析JSON
+            PoliceVo policeVo = parseJson(result);
+
+            if (policeVo != null) {
+
+                // 输出解析后的对象，检查内容
+                List<PoliceVo.AlarmDetails> alarmList1 = policeVo.getData().getLs();
+                for (PoliceVo.AlarmDetails alarm1 : alarmList1) {
+                    list.add(alarm1);
+                }
+            }
+        } catch (IOException e){
+            e.printStackTrace();
+        }
+
+        return list;
+    }
+
+
+    public static PoliceVo parseJson(String json) throws IOException {
+        // 创建ObjectMapper实例
+        ObjectMapper objectMapper = new ObjectMapper();
+
+        // 设置ObjectMapper来忽略未知的属性
+        objectMapper.configure(com.fasterxml.jackson.databind.DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+
+        // 解析JSON并转换为PoliceVo对象
+        PoliceVo policeVo = objectMapper.readValue(json, PoliceVo.class);
+
+        return policeVo;
+    }
+}