报警矩阵提交

runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/WindDirection/WindDirectionController.java

@@ -56,6 +56,18 @@ public class WindDirectionController {
     }
 
     /**
+     * 气象单机偏差分析
+
+     * @return
+     */
+    @GetMapping("/weatherMachine")
+    public JSONObject weathermachine(String wpid) throws Exception {
+
+        Object o = windMachineService.weathermachine(wpid);
+        return JsonResult.successData(ResultCode.SUCCESS, o);
+    }
+
+    /**
      * 单机偏差分析计算
 
      * @return

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

@@ -3,11 +3,14 @@ package com.gyee.runeconomy.controller.monitor;/*
 @date   2023/3/28-8:43
 */
 
+import com.alibaba.fastjson.JSONObject;
 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.dto.result.JsonResult;
+import com.gyee.runeconomy.dto.result.ResultCode;
 import com.gyee.runeconomy.model.auto.ProEconAlarmType;
 import com.gyee.runeconomy.model.vo.PoliceVo;
 import com.gyee.runeconomy.service.auto.IProEconAlarmTypeService;
@@ -66,14 +69,14 @@ public class MatrixController {
     @GetMapping("/detailed")
     @ResponseBody
     @ApiOperation(value = "明细矩阵", notes = "明细矩阵")
-    public R detailed(@RequestParam(value = "type", required = true) String type,
+    public JSONObject detailed(@RequestParam(value = "type", required = true) String type,
                       @RequestParam(value = "company", required = true) String company) throws Exception {
 
         Map<String, Object> resultMap = matrixService.matrixMX(company, type);
         if (StringUtils.isNotNull(resultMap)) {
-            return R.data(ResultMsg.ok(resultMap));
+            return JsonResult.successData(ResultCode.SUCCESS, resultMap);
         } else {
-            return R.error(ResultMsg.error());
+            return JsonResult.error();
         }
     }
 
@@ -85,12 +88,13 @@ public class MatrixController {
     @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));
+    public JSONObject alarmtype(@RequestParam(value = "wtid", required = true) String wtid) throws Exception {
+        Map<String, Object> resultMap = alarmService.flAlarm(wtid);
+
+        if (StringUtils.isNotNull(resultMap)) {
+            return JsonResult.successData(ResultCode.SUCCESS, resultMap);
         } else {
-            return R.error(ResultMsg.error());
+            return JsonResult.error();
         }
     }
 
@@ -103,14 +107,14 @@ public class MatrixController {
     @GetMapping("/alarm")
     @ResponseBody
     @ApiOperation(value = "报警信息", notes = "报警信息")
-    public R alarm(@RequestParam(value = "type", required = true) String type,
+    public JSONObject 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));
+            return JsonResult.successData(ResultCode.SUCCESS, resultMap);
         } else {
-            return R.error(ResultMsg.error());
+            return JsonResult.error();
         }
     }
 

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

@@ -161,4 +161,147 @@ public class WindMachineService {
 
         return monthlyData;
     }
+
+    /**
+     * 气象单机偏差分析
+     * @param wpid
+     * @return
+     * @throws Exception
+     */
+    public Object weathermachine(String wpid) throws Exception {
+        // 获取当前日期
+        int currentYear = LocalDate.now().getYear();
+
+        List<ProBasicEquipment> collect = CacheContext.wtls.stream()
+                .filter(wt -> wpid.equals(wt.getWindpowerstationId()))
+                .collect(Collectors.toList());
+
+        Map<String, List> monthlyData = new LinkedHashMap<>();
+
+
+        // 风机循环：每台风机每个月一个 WindData 对象
+        for (ProBasicEquipment eq : collect) {
+
+            // 获取当前年份的开始日期（1月1日）
+            LocalDate startOfYear = LocalDate.of(currentYear, 1, 1);
+
+            // 获取当前年份的结束日期（12月31日）
+            LocalDate endOfYear = LocalDate.of(currentYear, 12, 31);
+
+            // 使用 DateTimeFormatter 格式化日期为字符串
+            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+
+            // 转换为字符串
+            String startOfYearStr = startOfYear.format(formatter);
+            String endOfYearStr = endOfYear.format(formatter);
+
+            List<TurbineInfoDay> turbineList = turbineInfoDayService.getTurbineList(eq.getId(), startOfYearStr, endOfYearStr);
+            List<StationInfoDay> infoDays = stationInfoDayService.getTurbineList(wpid, startOfYearStr, endOfYearStr);
+            List<String> zb = new ArrayList<>();
+            zb.add("fsavg");
+            zb.add("cftfsavg");
+            zb.add("fspc");
+            zb.add("fxavg");
+            zb.add("cftfxavg");
+            zb.add("fxpc");
+
+            for (String z : zb) {
+                // 循环从1月到12月
+                List<Double> result = new ArrayList<>();
+                String zbwz = "";
+                for (int month = 1; month <= 12; month++) {
+                    // 过滤 turbineList 中的记录，筛选出对应月份的数据
+                    int finalMonth = month;
+                    List<TurbineInfoDay> filteredList = turbineList.stream()
+                            .filter(turbine -> {
+                                // 获取 turbineInfoDay 的 recordDate（类型为 LocalDate）
+                                Date dateFromTurbine = turbine.getRecordDate();
+
+                                // 将 Date 转换为 LocalDate
+                                ZonedDateTime zonedDateTime = dateFromTurbine.toInstant().atZone(ZoneId.systemDefault());
+                                LocalDate recordDate = zonedDateTime.toLocalDate();
+
+                                // 获取记录的月份（注意，月份从 1 开始，1 表示1月）
+                                int recordMonth = recordDate.getMonthValue();
+
+                                // 判断记录的月份是否等于给定的 time
+                                return recordMonth == finalMonth;  // 比较 int 类型的月份和 time 变量
+                            })
+                            .collect(Collectors.toList());
+
+                    List<StationInfoDay> dayfilteredList = infoDays.stream()
+                            .filter(turbine -> {
+                                // 获取 turbineInfoDay 的 recordDate（类型为 LocalDate）
+                                LocalDate dateFromTurbine = turbine.getRecordDate();
+
+                                // 获取记录的月份（注意，月份从 1 开始，1 表示1月）
+                                int recordMonth = dateFromTurbine.getMonthValue();
+
+                                // 判断记录的月份是否等于给定的 time
+                                return recordMonth == finalMonth;  // 比较 int 类型的月份和 time 变量
+                            })
+                            .collect(Collectors.toList());
+
+                    // 风速
+                    double fsaverage = filteredList.stream()
+                            .mapToDouble(turbineInfoDay -> Optional.ofNullable(turbineInfoDay.getPjfs()).map(Number::doubleValue).orElse(0.0))
+                            .average()
+                            .orElse(0.0);  // 默认值0.0
+
+                    // 风向
+                    double fxaverage = filteredList.stream()
+                            .mapToDouble(turbineInfoDay -> Optional.ofNullable(turbineInfoDay.getFx()).map(Number::doubleValue).orElse(0.0))
+                            .average()
+                            .orElse(0.0);  // 默认值0.0
+
+                    // 测风塔风速
+                    double cftfsaverage = dayfilteredList.stream()
+                            .mapToDouble(turbineInfoDay -> Optional.ofNullable(turbineInfoDay.getCftfs()).map(Number::doubleValue).orElse(0.0))
+                            .average()
+                            .orElse(0.0); // 默认值0.0
+
+                    // 测风塔风向
+                    double cftfxaverage = dayfilteredList.stream()
+                            .mapToDouble(turbineInfoDay -> Optional.ofNullable(turbineInfoDay.getCftfx()).map(Number::doubleValue).orElse(0.0))
+                            .average()
+                            .orElse(0.0);  // 默认值0.0
+
+
+                    double zbsj = 0.0;
+
+                    if (z.toString().equals("fsavg")) {
+                        // 保留两位小数并转换回 double
+                        zbsj = Double.parseDouble(String.format("%.2f", fsaverage));
+                        zbwz = "风速";
+                    } else if (z.toString().equals("fxavg")) {
+                        zbsj = Double.parseDouble(String.format("%.2f", fxaverage));
+                        zbwz = "风向";
+                    } else if (z.toString().equals("cftfsavg")) {
+                        zbsj = Double.parseDouble(String.format("%.2f", cftfsaverage));
+                        zbwz = "测风塔风速";
+                    } else if (z.toString().equals("cftfxavg")) {
+                        zbsj = Double.parseDouble(String.format("%.2f", cftfxaverage));
+                        zbwz = "测风塔风向";
+                    } else if (z.toString().equals("fspc")) {
+                        zbsj = Deviation.calculateSpeedDeviation(
+                                fsaverage,
+                                cftfsaverage
+                        );
+                        zbwz = "风速偏差";
+                    } else if (z.toString().equals("fxpc")) {
+                        zbsj = Deviation.calculateDirectionDeviation(
+                                fxaverage,
+                                cftfxaverage
+                        );
+                        zbwz = "风向偏差";
+                    }
+                    result.add(zbsj);
+                }
+                monthlyData.put(eq.getAname() + zbwz, result);
+            }
+
+        }
+
+        return monthlyData;
+    }
 }

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

@@ -16,4 +16,5 @@ import java.util.List;
 public interface IProEconAlarmTypeService extends IService<ProEconAlarmType> {
 
     List<ProEconAlarmType> bylist (String wtid);
+    List<ProEconAlarmType> bylists ();
 }

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

@@ -9,6 +9,7 @@ import com.gyee.runeconomy.service.auto.IProEconAlarmTypeService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 
+import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -30,9 +31,16 @@ public class ProEconAlarmTypeServiceImpl extends ServiceImpl<ProEconAlarmTypeMap
         if (collect != null || collect.size() > 0) {
             model = collect.get(0).getModelId();
         }
+        model="alertrule_category";
         QueryWrapper<ProEconAlarmType> queryWrapper = new QueryWrapper<>();
         queryWrapper.lambda().eq(ProEconAlarmType::getCategory,model);
         List<ProEconAlarmType> proEconAlarmTypes = baseMapper.selectList(queryWrapper);
         return proEconAlarmTypes;
     }
+
+    @Override
+    public List<ProEconAlarmType> bylists() {
+        List<ProEconAlarmType> proEconAlarmTypes = baseMapper.selectList(null);
+        return proEconAlarmTypes;
+    }
 }

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

@@ -1,13 +1,17 @@
 package com.gyee.runeconomy.service.monitor;
 
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 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.auto.ProEconAlarmType;
 import com.gyee.runeconomy.model.vo.PoliceVo;
 import com.gyee.runeconomy.service.EarlyWarning.ApiClient;
+import com.gyee.runeconomy.service.auto.IProEconAlarmTypeService;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
 import java.io.IOException;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -16,9 +20,14 @@ import java.util.stream.Collectors;
 @Service
 public class AlarmService {
 
+    @Resource
+    private IProEconAlarmTypeService proEconAlarmTypeService;
+
     ApiClient client = new ApiClient();
 
-    public List<PoliceVo.AlarmDetails> Alarm(String type,String wtid) throws Exception {
+    public  List<PoliceVo.AlarmDetails> Alarm(String type,String wtid) throws Exception {
+
+        Map<String, Object> map = new HashMap<>();
         // 获取当天零点时间
         Calendar calendar = Calendar.getInstance();
         calendar.set(Calendar.HOUR_OF_DAY, 0);
@@ -62,7 +71,7 @@ public class AlarmService {
                 "",
                 "",
                 "1",
-                "20"
+                "1000"
         );
 
 
@@ -82,10 +91,109 @@ public class AlarmService {
         } catch (IOException e){
             e.printStackTrace();
         }
-
         return list;
     }
 
+    public Map<String, Object> flAlarm(String wtid) throws Exception {
+        List<ProEconAlarmType> bylist = proEconAlarmTypeService.bylist(wtid);
+        Map<String, Object> map = new HashMap<>();
+        // 获取当天零点时间
+        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> zslist = 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();
+        }
+
+        String zsresult = client.getgzFromApi(
+                startTime,
+                endTime,
+                "windturbine",
+                station,
+                wtid,
+                "",
+                modelId,
+                "windturbine",
+                "",
+                "",
+                "",
+                "1",
+                "1000"
+        );
+        // 解析所有类别预警数据
+        try {
+            // 调用parseJson方法解析JSON
+            PoliceVo policeVo = parseJson(zsresult);
+
+            if (policeVo != null) {
+
+                // 输出解析后的对象，检查内容
+                List<PoliceVo.AlarmDetails> alarmList1 = policeVo.getData().getLs();
+                for (PoliceVo.AlarmDetails alarm1 : alarmList1) {
+                    zslist.add(alarm1);
+                }
+            }
+        } catch (IOException e){
+            e.printStackTrace();
+        }
+
+        List<ProEconAlarmType> bylists = proEconAlarmTypeService.bylists();
+
+        Map<String, Long> componentCountMap = zslist.stream()
+                .collect(Collectors.groupingBy(
+                        PoliceVo.AlarmDetails::getComponents, // 分组条件：按照 components 字段
+                        Collectors.counting()                // 统计数量
+                ));
+
+        // 创建一个 name 到 nemcode 的映射
+        Map<String, String> nameToNemcodeMap = bylists.stream()
+                .collect(Collectors.toMap(
+                        ProEconAlarmType::getName,    // key: name 字段
+                        ProEconAlarmType::getNemCode // value: nemcode 字段
+                ));
+
+        // 创建一个新的 Map 存储替换后的结果
+        Map<String, Long> updatedComponentCountMap = new HashMap<>();
+
+
+        // 遍历 componentCountMap
+        componentCountMap.forEach((key, value) -> {
+            // 检查是否能匹配到 nemcode
+            if (nameToNemcodeMap.containsKey(key)) {
+                // 如果匹配，使用 nemcode 替换 key
+                updatedComponentCountMap.put(nameToNemcodeMap.get(key), value);
+            } else {
+                // 如果未匹配，保留原来的 key
+                updatedComponentCountMap.put(key, value);
+            }
+        });
+        Long zscount = (long) zslist.size();
+        updatedComponentCountMap.put("zs",zscount);
+        map.put("data",bylist);
+        map.put("count",updatedComponentCountMap);
+        return map;
+    }
+
 
     public static PoliceVo parseJson(String json) throws IOException {
         // 创建ObjectMapper实例