From 0676b467ca62214dfe55aaf902ff4a1f29a629b0 Mon Sep 17 00:00:00 2001
From: wr <1754607820@qq.com>
Date: Mon, 6 May 2024 17:44:58 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=86=80=E5=8C=97=E7=94=B5=E7=BD=91=E4=B8=80?=
 =?UTF-8?q?=E5=BC=A0=E5=9B=BE,=E5=8C=BA=E5=9F=9F=E7=BB=88=E7=AB=AF?=
 =?UTF-8?q?=E7=BB=9F=E8=AE=A1=EF=BC=8C=E7=9B=91=E6=B5=8B=E7=82=B9=E5=88=86?=
 =?UTF-8?q?=E5=B8=83=E7=BB=9F=E8=AE=A1=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/device/pq/pojo/vo/GridDiagramVO.java | 22 +++++++
 .../pq/controller/GridDiagramController.java  |  9 +++
 .../mapper/mapping/RStatIntegrityDMapper.xml  |  2 +-
 .../mapper/mapping/RStatOnlinerateDMapper.xml |  2 +-
 .../device/pq/service/GridDiagramService.java | 12 ++++
 .../service/impl/GridDiagramServiceImpl.java  | 42 ++++++++++++++
 .../impl/RStatLimitServiceImpl.java           | 58 +++++++++++--------
 7 files changed, 122 insertions(+), 25 deletions(-)

diff --git a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/GridDiagramVO.java b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/GridDiagramVO.java
index 617704146..571736d69 100644
--- a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/GridDiagramVO.java
+++ b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/GridDiagramVO.java
@@ -105,4 +105,26 @@ public class GridDiagramVO {
         private Float outOfStandardRate;
 
     }
+
+    @Data
+    public static class DevData {
+
+        @ApiModelProperty(name = "orgId", value = "单位id")
+        private String orgId;
+
+        @ApiModelProperty(name = "orgName", value = "单位名称")
+        private String orgName;
+
+        @ApiModelProperty(name = "onLineRate", value = "运行个数")
+        private Long runNum;
+
+        @ApiModelProperty(name = "integrityRate", value = "检修个数")
+        private Long overhaulNum;
+
+        @ApiModelProperty(name = "outOfStandardRate", value = "退役个数")
+        private Long refundNum;
+
+        @ApiModelProperty(name = "onLineRate", value = "数据在线率")
+        private Float onLineRate;
+    }
 }
diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/GridDiagramController.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/GridDiagramController.java
index 2a56a18e3..9b0ab0618 100644
--- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/GridDiagramController.java
+++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/GridDiagramController.java
@@ -75,6 +75,15 @@ public class GridDiagramController extends BaseController {
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, gridDiagramDevData, methodDescribe);
     }
 
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/getGridDiagramDevDataList")
+    @ApiOperation("区域终端统计")
+    public HttpResult<List<GridDiagramVO.DevData>> getGridDiagramDevDataList(@RequestBody GridDiagramParam param){
+        String methodDescribe = getMethodDescribe("getGridDiagramDevDataList");
+        List<GridDiagramVO.DevData> gridDiagramDevDataList = gridDiagramService.getGridDiagramDevDataList(param);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, gridDiagramDevDataList, methodDescribe);
+    }
+
     @OperateInfo(info = LogEnum.BUSINESS_COMMON)
     @PostMapping("/getGridDiagramLineTendency")
     @ApiOperation("监测点趋势分析")
diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/RStatIntegrityDMapper.xml b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/RStatIntegrityDMapper.xml
index a28b06563..5d7b05f2b 100644
--- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/RStatIntegrityDMapper.xml
+++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/RStatIntegrityDMapper.xml
@@ -65,7 +65,7 @@
     </select>
     <select id="selectTotalIntegrityByLineIds" resultType="java.lang.Float">
         select
-        ROUND( sum(real_time)/sum(due_time)*100,2) as integrityRate
+            IFNULL(ROUND( sum(real_time)/sum(due_time)*100,2),0) as integrityRate
         from
             r_stat_integrity_d
         <where>
diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/RStatOnlinerateDMapper.xml b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/RStatOnlinerateDMapper.xml
index b17767bd4..88ae5fce5 100644
--- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/RStatOnlinerateDMapper.xml
+++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/RStatOnlinerateDMapper.xml
@@ -26,7 +26,7 @@
     </select>
     <select id="getTotalOnlineRates" resultType="java.lang.Float">
         select
-        ROUND( sum(online_min)/(sum(online_min) + sum(offline_min))*100,2) as online_rate
+        IFNULL(ROUND( sum(online_min)/(sum(online_min) + sum(offline_min))*100,2),0) as online_rate
         from r_stat_onlinerate_d
         <where>
             <if test="param!=null and param.ids != null and param.ids.size > 0">
diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/GridDiagramService.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/GridDiagramService.java
index d11dfff19..94bcb2ec9 100644
--- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/GridDiagramService.java
+++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/GridDiagramService.java
@@ -49,6 +49,18 @@ public interface GridDiagramService {
      */
 
     List<GridDiagramVO.DeviceData> getGridDiagramDevData(GridDiagramParam param);
+
+
+    /**
+     * @Description: 终端统计详细列表
+     * @param
+     * @Author: wr
+     */
+
+    List<GridDiagramVO.DevData> getGridDiagramDevDataList(GridDiagramParam param);
+
+
+
     //---------------------------------------------------市级---------------------------------------
 
     /**
diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/GridDiagramServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/GridDiagramServiceImpl.java
index e270dfd8a..f2cbc414c 100644
--- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/GridDiagramServiceImpl.java
+++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/GridDiagramServiceImpl.java
@@ -361,6 +361,48 @@ public class GridDiagramServiceImpl implements GridDiagramService {
         return info;
     }
 
+    @Override
+    public List<GridDiagramVO.DevData> getGridDiagramDevDataList(GridDiagramParam param) {
+        List<GridDiagramVO.DevData> info=new ArrayList<>();
+        List<GeneralDeviceDTO> generalDeviceDTOList = generalDeviceService.getDeviceInfoAsDept(param.getDeviceInfoParam(), null, Stream.of(1).collect(Collectors.toList()));
+        List<String> devIds = generalDeviceDTOList.stream().flatMap(x -> x.getDeviceIndexes().stream()).collect(Collectors.toList());
+        //终端信息
+        List<Device> devList =new ArrayList<>();
+        if(CollUtil.isNotEmpty(devIds)){
+            devList = deviceService.list(new LambdaQueryWrapper<Device>().in(CollUtil.isNotEmpty(devIds), Device::getId, devIds));
+        }
+        GridDiagramVO.DevData data;
+        OnlineRateParam onlineRateParam = new OnlineRateParam();
+        onlineRateParam.setStartTime(param.getSearchBeginTime());
+        onlineRateParam.setEndTime(param.getSearchEndTime());
+        for (GeneralDeviceDTO dto : generalDeviceDTOList) {
+            List<String> list = new ArrayList<>();
+            for (int i = 0; i < 3; i++) {
+                int finalI = i;
+                List<String> devices = devList.stream()
+                        .filter(x->dto.getDeviceIndexes().contains(x.getId()))
+                        .filter(x -> finalI == x.getRunFlag())
+                        .map(Device::getId).distinct().collect(Collectors.toList());
+                list.add(String.valueOf(devices.size()));
+                if (i == 0) {
+                    onlineRateParam.setIds(devices);
+                    list.add(String.valueOf(onLineRateDMapper.getTotalOnlineRates(onlineRateParam)));
+                } else {
+                    list.add(String.valueOf(3.14159));
+                }
+            }
+            data=new GridDiagramVO.DevData();
+            data.setOrgId(dto.getIndex());
+            data.setOrgName(dto.getName());
+            data.setRunNum(Long.valueOf(list.get(0)));
+            data.setOverhaulNum(Long.valueOf(list.get(2)));
+            data.setRefundNum(Long.valueOf(list.get(4)));
+            data.setOnLineRate(Float.valueOf(list.get(1)));
+            info.add(data);
+        }
+        return info;
+    }
+
     @Override
     public List<String> getGridDiagramCityDev(GridDiagramParam param) {
         List<GeneralDeviceDTO> generalDeviceDTOList = generalDeviceService.getDeviceInfoAsDept(param.getDeviceInfoParam(), null, Stream.of(1).collect(Collectors.toList()));
diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/RStatLimitServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/RStatLimitServiceImpl.java
index 8d8eb7d0f..88943f7bf 100644
--- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/RStatLimitServiceImpl.java
+++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/majornetwork/impl/RStatLimitServiceImpl.java
@@ -3,8 +3,10 @@ package com.njcn.harmonic.service.majornetwork.impl;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.NumberUtil;
+import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.njcn.common.pojo.dto.SimpleDTO;
 import com.njcn.device.pq.api.GeneralDeviceInfoClient;
 import com.njcn.device.pq.api.LineIntegrityClient;
 import com.njcn.device.pq.pojo.dto.GeneralDeviceDTO;
@@ -21,6 +23,7 @@ import com.njcn.harmonic.mapper.RStatLimitTargetMapper;
 import com.njcn.harmonic.pojo.po.day.RStatLimitRateDPO;
 import com.njcn.harmonic.pojo.po.day.RStatLimitTargetDPO;
 import com.njcn.harmonic.service.majornetwork.RStatLimitService;
+import com.njcn.system.pojo.enums.StatisticsEnum;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -60,7 +63,6 @@ public class RStatLimitServiceImpl implements RStatLimitService {
     @Override
     public List<GridDiagramVO.LineData> getGridDiagramLineData(DeviceInfoParam.BusinessParam deviceInfoParam) {
         List<GridDiagramVO.LineData> info=new ArrayList<>();
-
         List<GeneralDeviceDTO> data = generalDeviceInfoClient.getPracticalRunDeviceInfo(deviceInfoParam).getData();
         List<GeneralDeviceDTO> list = data.stream().sorted(Comparator.comparing(x -> x.getLineIndexes().size(),Comparator.reverseOrder())).collect(Collectors.toList());
         //终端总数量
@@ -89,39 +91,49 @@ public class RStatLimitServiceImpl implements RStatLimitService {
         }
         List<GeneralDeviceDTO> topList=new ArrayList<>();
         List<GeneralDeviceDTO> otherList=new ArrayList<>();
-        if(list.size()>4){
-            topList.addAll(list.subList(0, 4));
-            otherList.addAll(list.subList(4, list.size()));
-        }else{
-            if(list.size()>3){
-                topList.addAll(list.subList(0, 3));
-                otherList.addAll(list.subList(3, list.size()));
-            }else{
-                if(list.size()>2){
-                    topList.addAll(list.subList(0, 2));
-                    otherList.addAll(list.subList(2, list.size()));
+        if(ObjectUtil.isNotNull(deviceInfoParam.getStatisticalType())){
+            SimpleDTO statisticalType = deviceInfoParam.getStatisticalType();
+            if(!StatisticsEnum.POWER_NETWORK.getCode().equals(statisticalType.getCode())){
+                if(list.size()>4){
+                    topList.addAll(list.subList(0, 4));
+                    otherList.addAll(list.subList(4, list.size()));
                 }else{
-                    topList.addAll(list.subList(0, 1));
-                    otherList.addAll(list.subList(1, list.size()));
+                    if(list.size()>3){
+                        topList.addAll(list.subList(0, 3));
+                        otherList.addAll(list.subList(3, list.size()));
+                    }else{
+                        if(list.size()>2){
+                            topList.addAll(list.subList(0, 2));
+                            otherList.addAll(list.subList(2, list.size()));
+                        }else{
+                            topList.addAll(list.subList(0, 1));
+                            otherList.addAll(list.subList(1, list.size()));
+                        }
+                    }
                 }
+            }else{
+                topList.addAll(list);
             }
+        }else{
+            topList.addAll(list);
         }
         GridDiagramVO.LineData lineData;
         for (GeneralDeviceDTO dto : topList) {
             lineData=new GridDiagramVO.LineData();
             lineData.setOrgId(dto.getIndex());
-            lineData.setOrgName(dto.getName()+"("+dto.getLineIndexes().size()+")");
+            lineData.setOrgName(dto.getName()+"\n("+dto.getLineIndexes().size()+")");
             onLineAndIntegrity(dto.getLineIndexes(), integrityList, dto.getDeviceIndexes(), onlineRateList,limitTargetList, lineData);
             info.add(lineData);
         }
-        List<String> otherDevIds = otherList.stream().flatMap(x -> x.getDeviceIndexes().stream()).distinct().collect(Collectors.toList());
-        List<String> otherLineIds = otherList.stream().flatMap(x -> x.getLineIndexes().stream()).distinct().collect(Collectors.toList());
-        lineData=new GridDiagramVO.LineData();
-        lineData.setOrgId("123456");
-        lineData.setOrgName("其他("+otherLineIds.size()+")");
-        onLineAndIntegrity(otherLineIds, integrityList, otherDevIds, onlineRateList,limitTargetList, lineData);
-        info.add(lineData);
-
+        if(CollUtil.isNotEmpty(otherList)){
+            List<String> otherDevIds = otherList.stream().flatMap(x -> x.getDeviceIndexes().stream()).distinct().collect(Collectors.toList());
+            List<String> otherLineIds = otherList.stream().flatMap(x -> x.getLineIndexes().stream()).distinct().collect(Collectors.toList());
+            lineData=new GridDiagramVO.LineData();
+            lineData.setOrgId("123456");
+            lineData.setOrgName("其他\n("+otherLineIds.size()+")");
+            onLineAndIntegrity(otherLineIds, integrityList, otherDevIds, onlineRateList,limitTargetList, lineData);
+            info.add(lineData);
+        }
         return info;
     }