报警预警接口

runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/NewDataFittingController.java

@@ -2,6 +2,9 @@ package com.gyee.runeconomy.controller;
 
 
 import com.alibaba.fastjson.JSONObject;
+import com.gyee.runeconomy.dto.fitting.Alarm;
+import com.gyee.runeconomy.dto.fitting.AlarmDataVo;
+import com.gyee.runeconomy.dto.fitting.AlarmRequest;
 import com.gyee.runeconomy.dto.result.JsonResult;
 import com.gyee.runeconomy.dto.result.PowerPointData;
 import com.gyee.runeconomy.dto.result.ResultCode;
@@ -90,5 +93,17 @@ public class NewDataFittingController {
         Map<String, Object> result = newDataFittingService.dataFittingShow(id);
         return JsonResult.successData(ResultCode.SUCCESS, result);
     }
-
+    /**
+     * 获取故障或预警数据
+     //     * @param table
+     //     * @param only
+     * @return
+     */
+    @PostMapping("alarms")
+    public JSONObject getDataAlarms(@RequestBody AlarmRequest request) {
+        String table = request.getTable();
+        List<Alarm> alarmList = request.getAlarmList();
+        List<AlarmDataVo> list = newDataFittingService.getDataAlarms(table, alarmList);
+        return JsonResult.successData(ResultCode.SUCCESS, list);
+    }
 }

runeconomy-xk/src/main/java/com/gyee/runeconomy/dto/fitting/Alarm.java

@@ -0,0 +1,23 @@
+package com.gyee.runeconomy.dto.fitting;
+
+public class Alarm {
+    private String wtId;
+    private String time;
+
+    // Getters and Setters
+    public String getWtId() {
+        return wtId;
+    }
+
+    public void setWtId(String wtId) {
+        this.wtId = wtId;
+    }
+
+    public String getTime() {
+        return time;
+    }
+
+    public void setTime(String time) {
+        this.time = time;
+    }
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/dto/fitting/AlarmDataVo.java

@@ -0,0 +1,49 @@
+package com.gyee.runeconomy.dto.fitting;
+
+public class AlarmDataVo {
+    private String wtid;
+    private String time;
+    private String tx;
+    private String bj;
+    private String alarmname;
+
+    public String getWtid() {
+        return wtid;
+    }
+
+    public void setWtid(String wtid) {
+        this.wtid = wtid;
+    }
+
+    public String getTime() {
+        return time;
+    }
+
+    public void setTime(String time) {
+        this.time = time;
+    }
+
+    public String getTx() {
+        return tx;
+    }
+
+    public void setTx(String tx) {
+        this.tx = tx;
+    }
+
+    public String getBj() {
+        return bj;
+    }
+
+    public void setBj(String bj) {
+        this.bj = bj;
+    }
+
+    public String getAlarmname() {
+        return alarmname;
+    }
+
+    public void setAlarmname(String alarmname) {
+        this.alarmname = alarmname;
+    }
+}

runeconomy-xk/src/main/java/com/gyee/runeconomy/dto/fitting/AlarmRequest.java

@@ -0,0 +1,26 @@
+package com.gyee.runeconomy.dto.fitting;
+
+import java.util.List;
+
+public class AlarmRequest {
+    private String table;
+    private List<Alarm> alarmList;
+
+    // Getters and Setters
+    public String getTable() {
+        return table;
+    }
+
+    public void setTable(String table) {
+        this.table = table;
+    }
+
+    public List<Alarm> getAlarmList() {
+        return alarmList;
+    }
+
+    public void setAlarmList(List<Alarm> alarmList) {
+        this.alarmList = alarmList;
+    }
+
+}

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

@@ -0,0 +1,29 @@
+package com.gyee.runeconomy.model.vo;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+import java.util.List;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class DataResult {
+    private List<ResultItem> result;
+    private int total;
+
+    public List<ResultItem> getResult() {
+        return result;
+    }
+
+    public void setResult(List<ResultItem> result) {
+        this.result = result;
+    }
+
+    public int getTotal() {
+        return total;
+    }
+
+    public void setTotal(int total) {
+        this.total = total;
+    }
+
+    // getters/setters
+}

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

@@ -0,0 +1,151 @@
+package com.gyee.runeconomy.model.vo;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class ResultItem {
+    private String id;
+    private String winpowerstationId;
+    private String windturbineId;
+    private String stopTime;
+    private String startTime;
+    private double stopHours;
+    private double lossPower;
+    private String stopTypeId;
+    private Object isHandle;  // 根据实际情况可改为具体类型
+    private String warningId;
+    private String projectId;
+    private Object handleWay;
+    private String faultView;
+    private int statusCode;
+    private String code;
+    private String windturbineName;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getWinpowerstationId() {
+        return winpowerstationId;
+    }
+
+    public void setWinpowerstationId(String winpowerstationId) {
+        this.winpowerstationId = winpowerstationId;
+    }
+
+    public String getWindturbineId() {
+        return windturbineId;
+    }
+
+    public void setWindturbineId(String windturbineId) {
+        this.windturbineId = windturbineId;
+    }
+
+    public String getStopTime() {
+        return stopTime;
+    }
+
+    public void setStopTime(String stopTime) {
+        this.stopTime = stopTime;
+    }
+
+    public String getStartTime() {
+        return startTime;
+    }
+
+    public void setStartTime(String startTime) {
+        this.startTime = startTime;
+    }
+
+    public double getStopHours() {
+        return stopHours;
+    }
+
+    public void setStopHours(double stopHours) {
+        this.stopHours = stopHours;
+    }
+
+    public double getLossPower() {
+        return lossPower;
+    }
+
+    public void setLossPower(double lossPower) {
+        this.lossPower = lossPower;
+    }
+
+    public String getStopTypeId() {
+        return stopTypeId;
+    }
+
+    public void setStopTypeId(String stopTypeId) {
+        this.stopTypeId = stopTypeId;
+    }
+
+    public Object getIsHandle() {
+        return isHandle;
+    }
+
+    public void setIsHandle(Object isHandle) {
+        this.isHandle = isHandle;
+    }
+
+    public String getWarningId() {
+        return warningId;
+    }
+
+    public void setWarningId(String warningId) {
+        this.warningId = warningId;
+    }
+
+    public String getProjectId() {
+        return projectId;
+    }
+
+    public void setProjectId(String projectId) {
+        this.projectId = projectId;
+    }
+
+    public Object getHandleWay() {
+        return handleWay;
+    }
+
+    public void setHandleWay(Object handleWay) {
+        this.handleWay = handleWay;
+    }
+
+    public String getFaultView() {
+        return faultView;
+    }
+
+    public void setFaultView(String faultView) {
+        this.faultView = faultView;
+    }
+
+    public int getStatusCode() {
+        return statusCode;
+    }
+
+    public void setStatusCode(int statusCode) {
+        this.statusCode = statusCode;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getWindturbineName() {
+        return windturbineName;
+    }
+
+    public void setWindturbineName(String windturbineName) {
+        this.windturbineName = windturbineName;
+    }
+}

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

@@ -0,0 +1,28 @@
+package com.gyee.runeconomy.model.vo;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class alarmWtVo {
+
+    private int code;
+    private DataResult data;
+
+    public int getCode() {
+        return code;
+    }
+
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    public DataResult getData() {
+        return data;
+    }
+
+    public void setData(DataResult data) {
+        this.data = data;
+    }
+}
+

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

@@ -1,8 +1,12 @@
 package com.gyee.runeconomy.service.EarlyWarning;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.gyee.runeconomy.model.vo.PoliceVo;
+import com.gyee.runeconomy.model.vo.alarmWtVo;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.client.RestTemplate;
 
+import java.io.IOException;
 import java.net.URI;
 import java.net.URLEncoder;
 import java.nio.charset.StandardCharsets;
@@ -75,4 +79,75 @@ public class ApiClient {
             return null;
         }
     }
+
+    /**
+     * 功率曲线故障
+     * @author gyee
+     * @param wpId
+     * @param wtId
+     * @param modelId
+     * @param description
+     * @param begin
+     * @param end
+     * @param pageNum
+     * @param pageSize
+     * @param type
+     * @return
+     */
+    public String getglqxgzFromApi(String wpId,String wtId, String modelId,String description ,String begin, String end, String pageNum,String pageSize,String type) {
+        try {
+            // 构建 URL
+            String baseUrl = "http://10.220.1.5:6015//shutdownevent2/queryshutdowneventlist";
+            String charset = StandardCharsets.UTF_8.name();  // 获取字符集名称
+            String url = String.format("%s?wpId=%s&wtId=%s&modelId=%s&description=%s&begin=%s&end=%s&pageNum=%s&pageSize=%s&type=%s",
+                    baseUrl,
+                    URLEncoder.encode(wpId, charset),
+                    URLEncoder.encode(wtId, charset),
+                    URLEncoder.encode(modelId, charset),
+                    URLEncoder.encode(description, charset),
+                    URLEncoder.encode(begin, charset),
+                    URLEncoder.encode(end, charset),
+                    URLEncoder.encode(pageNum, charset),
+                    URLEncoder.encode(pageSize, charset),
+                    URLEncoder.encode(type, charset)
+                    );
+
+            // 发送 GET 请求
+            URI uri = new URI(url);
+            ResponseEntity<String> response = restTemplate.getForEntity(uri, String.class);
+
+            // 返回响应内容
+            return response.getBody();
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    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;
+    }
+
+    public static alarmWtVo wtparseJson(String json) throws IOException {
+        // 创建ObjectMapper实例
+        ObjectMapper objectMapper = new ObjectMapper();
+
+        // 设置ObjectMapper来忽略未知的属性
+        objectMapper.configure(com.fasterxml.jackson.databind.DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+
+        // 解析JSON并转换为PoliceVo对象
+        alarmWtVo alarmWtVo = objectMapper.readValue(json, alarmWtVo.class);
+
+        return alarmWtVo;
+    }
 }

runeconomy-xk/src/main/java/com/gyee/runeconomy/service/WindDirection/WindALG.java

@@ -300,11 +300,11 @@ public class WindALG {
         for (int i = 0; i < list.size(); i++){
             PowerPointData item = list.get(i);
             double dfwc = 0;
-            if (equipments.size()>0) {
-                dfwc = Math.abs(item.getDfwc()) * 57.2958;//对风误差进行弧度转角度
-            } else {
+//            if (equipments.size()>0) {
+//                dfwc = Math.abs(item.getDfwc()) * 57.2958;//对风误差进行弧度转角度
+//            } else {
                 dfwc = Math.abs(item.getDfwc());
-            }
+//            }
             int ele = (int)Math.round((item.getFx() + dfwc));
             int index = ele - 180;
             if (index >= -50 && index <= 50 && item.getSpeed() > 0) {
@@ -391,13 +391,13 @@ public class WindALG {
         for (int i = 0; i < list.size(); i++){
             PowerPointData item = list.get(i);
             double dfwc = 0;
-            if (equipments.size()>0) {
-                dfwc = Math.abs(item.getDfwc()) * 57.2958;
-                dfwcls.add(dfwc);
-            } else {
+//            if (equipments.size()>0) {
+//                dfwc = Math.abs(item.getDfwc()) * 57.2958;
+//                dfwcls.add(dfwc);
+//            } else {
                 dfwc = Math.abs(item.getDfwc());
                 dfwcls.add(dfwc);
-            }
+//            }
             fxls.add(item.getFx());
             int ele = (int) (Math.abs(item.getFx()) + dfwc);
             int index = ele - 180;

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

@@ -2,10 +2,14 @@ package com.gyee.runeconomy.service.auto.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.gyee.runeconomy.config.GyeeConfig;
+import com.gyee.runeconomy.dto.AlarmDataParser;
 import com.gyee.runeconomy.dto.FiveLoss.AnnotationTool;
 import com.gyee.runeconomy.dto.FiveLoss.FixedVo;
 import com.gyee.runeconomy.dto.FiveLoss.TableTitle;
+import com.gyee.runeconomy.dto.fitting.Alarm;
+import com.gyee.runeconomy.dto.fitting.AlarmDataVo;
 import com.gyee.runeconomy.dto.result.PowerPointData;
 import com.gyee.runeconomy.dto.speed.WindDirectionALG;
 import com.gyee.runeconomy.init.CacheContext;
@@ -13,16 +17,22 @@ import com.gyee.runeconomy.model.LineCurveFitting;
 import com.gyee.runeconomy.model.PowerFittingALG;
 import com.gyee.runeconomy.model.PowerFittingData;
 import com.gyee.runeconomy.model.PowerProcessALG;
+import com.gyee.runeconomy.model.auto.ProBasicEquipment;
 import com.gyee.runeconomy.model.auto.ProBasicEquipmentPoint;
 import com.gyee.runeconomy.model.auto.ProBasicModelPower;
 import com.gyee.runeconomy.model.auto.ProEconPowerFittingAnalySis;
 import com.gyee.runeconomy.model.vo.PointVo;
+import com.gyee.runeconomy.model.vo.PoliceVo;
+import com.gyee.runeconomy.model.vo.ResultItem;
+import com.gyee.runeconomy.model.vo.alarmWtVo;
 import com.gyee.runeconomy.service.DBSCANPointALG;
 import com.gyee.runeconomy.service.DataScanService;
+import com.gyee.runeconomy.service.EarlyWarning.ApiClient;
 import com.gyee.runeconomy.service.WindDirection.Point;
 import com.gyee.runeconomy.util.FileUtil;
 import com.gyee.runeconomy.util.realtimesource.feign.RemoteServiceBuilder;
 import com.gyee.runeconomy.util.realtimesource.feign.TsDoubleData;
+import io.swagger.annotations.ApiResponse;
 import lombok.extern.slf4j.Slf4j;
 import lombok.val;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -30,8 +40,11 @@ import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.io.File;
+import java.io.IOException;
 import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
@@ -661,22 +674,167 @@ public class NewDataFittingService {
     }
 
 
-    //
-    //    private boolean deleteDir(String path){
-    //         boolean  b  =false;
-    //        File directory = new File(path);
-    //        for (File file: Objects.requireNonNull(directory.listFiles())) {
-    //            if (!file.isDirectory()) {
-    //                b = file.delete();
-    //                if(!b){
-    //                    return b;
-    //                }
-    //            }
-    //        }
-    //        return b;
-    //
-    //    }
+    /**
+     * @param table //     * @param only
+     * @return
+     */
+    public List<AlarmDataVo> getDataAlarms(String table, List<Alarm> alarmList) {
+
+        ApiClient client = new ApiClient();
+
+        List<AlarmDataVo> list1 = new ArrayList<>();
+        if (table.equals("alarmWt")) {
+            for (Alarm alarm : alarmList) {
+
+                List<ProBasicEquipment> equipments = CacheContext.wtls.stream()
+                        .filter(a -> alarm.getWtId().equals(a.getAname())).collect(Collectors.toList());
+
+                String modelId = equipments.get(0).getModelId();
+                String wtid = equipments.get(0).getId();
+                String station = equipments.get(0).getWindpowerstationId();
+                String begin = alarm.getTime();
+
+                // 定义日期时间格式
+                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+                // 将时间字符串转换为 LocalDateTime
+                LocalDateTime parsedTime = LocalDateTime.parse(begin, formatter);
+
+                // 增加一分钟
+//                LocalDateTime endTime = parsedTime.plusMinutes(1);
+                LocalDateTime endTime = parsedTime.plusDays(1);
+
+                // 将新的时间转换回字符串
+                String end = endTime.format(formatter);
+
+                String result = client.getglqxgzFromApi(
+                        station,
+                        wtid,
+                        modelId,
+                        "",
+                        begin,
+                        end,
+                        "1",
+                        "20",
+                        "gz"
+                );
+
+
+                String json = result;
+
+                ObjectMapper mapper = new ObjectMapper();
+                try {
+                    alarmWtVo response = mapper.readValue(json, alarmWtVo.class);
+
+                    // 使用解析后的数据
+                    for (ResultItem item : response.getData().getResult()) {
+                        // 读取所需数据
+                        AlarmDataVo vo = new AlarmDataVo();
+                        vo.setWtid(equipments.get(0).getAname());
+                        vo.setTime(begin);
+                        vo.setBj("故障");
+                        vo.setTx("自定义");
+                        vo.setAlarmname(item.getFaultView());
+                        list1.add(vo);
+                    }
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+
+            }
 
+            return list1;
+
+        } else if (table.equals("alarmCt")) {
+
+            for (Alarm alarm : alarmList) {
+
+                List<ProBasicEquipment> equipments = CacheContext.wtls.stream()
+                        .filter(a -> alarm.getWtId().equals(a.getAname())).collect(Collectors.toList());
+
+                String modelId = equipments.get(0).getModelId();
+                String wtid = equipments.get(0).getId();
+                String begin = alarm.getTime();
+
+                // 定义日期时间格式
+                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+                // 将时间字符串转换为 LocalDateTime
+                LocalDateTime parsedTime = LocalDateTime.parse(begin, formatter);
+
+                // 增加一分钟
+                LocalDateTime endTime = parsedTime.plusMinutes(1);
+
+                // 将新的时间转换回字符串
+                String end = endTime.format(formatter);
+
+                String result = client.getDataFromApi(
+                        begin,
+                        end,
+                        wtid,
+                        modelId,
+                        "windturbine",
+                        "",  // 如果没有 alarmIds，可以传空字符串
+                        "s"
+                );
+
+//                String result = "[\n" +
+//                        "    {\n" +
+//                        "        \"GJNY_SXGS_LJSF01_LN\":[\n" +
+//                        "            {\n" +
+//                        "                \"snapId\":1302951473243889700,\n" +
+//                        "                \"stationId\":\"GJNY_SXGS_LJSF01_LN\",\n" +
+//                        "                \"windturbineId\":null,\n" +
+//                        "                \"alertText\":\"变桨电容电压小于57v\",\n" +
+//                        "                \"count\":1,\n" +
+//                        "                \"alarmid\":\"0000425\",\n" +
+//                        "                \"time\":0,\n" +
+//                        "                \"relateParts\":\"BJXT\",\n" +
+//                        "                \"relatePartsText\":\"变桨系统\",\n" +
+//                        "                \"code\":null,\n" +
+//                        "                \"windturbineCode\":null,\n" +
+//                        "                \"lineId\":null\n" +
+//                        "            },\n" +
+//                        "            {\n" +
+//                        "                \"snapId\":1302951473243889700,\n" +
+//                        "                \"stationId\":\"GJNY_SXGS_LJSF01_LN\",\n" +
+//                        "                \"windturbineId\":null,\n" +
+//                        "                \"alertText\":\"如果风机轴a 和 轴b 温度差 大于20度，则报警\",\n" +
+//                        "                \"count\":3,\n" +
+//                        "                \"alarmid\":\"0000454\",\n" +
+//                        "                \"time\":4270,\n" +
+//                        "                \"relateParts\":\"ZZ\",\n" +
+//                        "                \"relatePartsText\":null,\n" +
+//                        "                \"code\":null,\n" +
+//                        "                \"windturbineCode\":null,\n" +
+//                        "                \"lineId\":null\n" +
+//                        "            }\n" +
+//                        "        ]\n" +
+//                        "    }\n" +
+//                        "]";
+                List response = AlarmDataParser.parseResponse(result);
+
+                if (response != null) {
+                    for (Object resc : response) {
+                        AlarmDataParser.AlarmData alarmData = (AlarmDataParser.AlarmData) resc;
+                        // 读取所需数据
+                        String alertText = alarmData.getAlertText(); // 预警内容
+                        String relateType = alarmData.getRelatePartsText(); // 部件名称
+                        AlarmDataVo vo = new AlarmDataVo();
+                        vo.setWtid(equipments.get(0).getAname());
+                        vo.setTime(begin);
+                        vo.setBj(relateType);
+                        vo.setTx("自定义");
+                        vo.setAlarmname(alertText);
+                        list1.add(vo);
+                    }
+                }
+            }
+            return list1;
+        }
+
+        return list1;
+    }
 
 }
 

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

@@ -79,7 +79,7 @@ public class AlarmService {
         // 解析预警数据
         try {
             // 调用parseJson方法解析JSON
-            PoliceVo policeVo = parseJson(result);
+            PoliceVo policeVo = ApiClient.parseJson(result);
 
             if (policeVo != null) {
 
@@ -147,7 +147,7 @@ public class AlarmService {
             // 解析所有类别预警数据
             try {
                 // 调用parseJson方法解析JSON
-                PoliceVo policeVo = parseJson(zsresult);
+                PoliceVo policeVo = ApiClient.parseJson(zsresult);
 
                 if (policeVo != null) {
 
@@ -199,17 +199,4 @@ public class AlarmService {
         return map;
     }
 
-
-    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;
-    }
 }