zbj//1.稳态指标超标占比(区域)

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/LargeScreenService.java

@@ -0,0 +1,17 @@
+package com.njcn.harmonic.service.majornetwork;
+
+import com.njcn.device.pq.pojo.param.LargeScreenParam;
+import com.njcn.device.pq.pojo.vo.*;
+
+import java.util.List;
+
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/03/31
+ */
+public interface LargeScreenService {
+
+    List<HomeostasisAreaVO> getHomeostasisArea(LargeScreenParam largeScreenParam);
+}

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/LargeScreenServiceImpl.java

@@ -0,0 +1,82 @@
+package com.njcn.harmonic.service.majornetwork.impl;
+
+import com.njcn.common.pojo.dto.SimpleDTO;
+import com.njcn.device.pq.api.GeneralDeviceInfoClient;
+import com.njcn.device.pq.pojo.dto.GeneralDeviceDTO;
+import com.njcn.device.pq.pojo.param.DeviceInfoParam;
+import com.njcn.device.pq.pojo.param.LargeScreenParam;
+import com.njcn.device.pq.pojo.param.MonitoringPointScaleParam;
+import com.njcn.device.pq.pojo.vo.*;
+import com.njcn.harmonic.mapper.majornetwork.LargeScreenMapper;
+import com.njcn.harmonic.service.majornetwork.LargeScreenService;
+import com.njcn.system.pojo.enums.StatisticsEnum;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.map.HashedMap;
+import org.springframework.stereotype.Service;
+
+import java.math.RoundingMode;
+import java.text.NumberFormat;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * @version 1.0.0
+ * @author: zbj
+ * @date: 2023/03/31
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class LargeScreenServiceImpl implements LargeScreenService {
+
+    private final GeneralDeviceInfoClient generalDeviceInfoClient;
+
+    private final LargeScreenMapper largeScreenMapper;
+
+    /**
+     * 稳态指标超标占比(区域)
+     */
+    @Override
+    public List<HomeostasisAreaVO> getHomeostasisArea(LargeScreenParam largeScreenParam) {
+        //创建返回VO
+        List<HomeostasisAreaVO> result = new ArrayList<>();
+
+        DeviceInfoParam.BusinessParam deviceInfoParam = new DeviceInfoParam.BusinessParam();
+        //部门索引
+        deviceInfoParam.setDeptIndex(largeScreenParam.getDeptIndex());
+        //统计类型
+        SimpleDTO simpleDTO = new SimpleDTO();
+        simpleDTO.setCode(String.valueOf(StatisticsEnum.POWER_NETWORK));
+        deviceInfoParam.setStatisticalType(simpleDTO);
+        //添加时间
+        deviceInfoParam.setSearchBeginTime(largeScreenParam.getSearchBeginTime());
+        deviceInfoParam.setSearchEndTime(largeScreenParam.getSearchEndTime());
+
+        // 获取所有数据
+        List<GeneralDeviceDTO> generalDeviceDTOList = generalDeviceInfoClient.getPracticalAllDeviceInfo(deviceInfoParam).getData();
+        //部门id集合
+        List<String> indexIds = generalDeviceDTOList.stream().map(GeneralDeviceDTO::getIndex).collect(Collectors.toList());
+
+        List<Map<String, Object>> homeostasisArea = largeScreenMapper.getHomeostasisArea(indexIds, largeScreenParam.getSearchBeginTime(), largeScreenParam.getSearchEndTime());
+
+        for (GeneralDeviceDTO generalDeviceDTO : generalDeviceDTOList) {
+            for (Map<String, Object> map : homeostasisArea) {
+                if (Objects.equals(generalDeviceDTO.getIndex(), map.get("id"))) {
+                    HomeostasisAreaVO homeostasisAreaVO = new HomeostasisAreaVO();
+                    homeostasisAreaVO.setName(generalDeviceDTO.getName());
+                    homeostasisAreaVO.setAvg(map.get("avg").toString());
+                    result.add(homeostasisAreaVO);
+                    } else {
+                    HomeostasisAreaVO homeostasisAreaVO = new HomeostasisAreaVO();
+                    homeostasisAreaVO.setName(generalDeviceDTO.getName());
+                    homeostasisAreaVO.setAvg("0");
+                    result.add(homeostasisAreaVO);
+                    }
+                }
+            }
+        return result;
+    }
+}