From 0ecb8e158595c1c899e0a0308ada388d6ab47d2c Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Thu, 1 Aug 2024 15:52:52 +0800
Subject: [PATCH] =?UTF-8?q?1.=E6=95=B0=E6=8D=AE=E5=AE=8C=E6=95=B4=E6=80=A7?=
 =?UTF-8?q?=E5=88=97=E8=A1=A8=E7=AD=9B=E9=80=89=E6=9D=A1=E4=BB=B6=E8=B0=83?=
 =?UTF-8?q?=E6=95=B4=202.=E7=AE=A1=E7=90=86=E5=91=98=E6=96=B0=E5=A2=9E?=
 =?UTF-8?q?=E8=A3=85=E7=BD=AE=E8=87=AA=E5=8A=A8=E7=94=9F=E6=88=90=E8=A3=85?=
 =?UTF-8?q?=E7=BD=AE=E5=90=8D=E7=A7=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/configuration/DeviceMapper.java    |  2 ++
 .../njcn/mapper/configuration/LineMapper.java |  2 ++
 .../configuration/DeviceServiceImpl.java      | 26 +++++++++++++++++-
 .../mappers/configuration/LineMapper.xml      | 18 +++++++++++++
 .../controller/business/DeviceController.java | 14 ++++++++++
 .../configuration/ManaDeviceService.java      |  2 ++
 .../configuration/ManaDeviceServiceImpl.java  | 27 +++++++++++++++++++
 .../mappers/configuration/DeviceMapper.xml    |  4 +++
 .../WEB-INF/views/business/device/addDev.jsp  | 14 ++++++++++
 9 files changed, 108 insertions(+), 1 deletion(-)

diff --git a/comService/src/main/java/com/njcn/mapper/configuration/DeviceMapper.java b/comService/src/main/java/com/njcn/mapper/configuration/DeviceMapper.java
index 1cd5b8f..4fbf83c 100644
--- a/comService/src/main/java/com/njcn/mapper/configuration/DeviceMapper.java
+++ b/comService/src/main/java/com/njcn/mapper/configuration/DeviceMapper.java
@@ -70,4 +70,6 @@ public interface DeviceMapper extends Mapper<Device>{
 	List<Integer> getDevIndex(@Param("list") List<Integer> dataType);
 
 	DeviceDetail getDevAndParent(@Param("devIndex")String devIndex);
+
+	String findMaxDeviceName(@Param("gdIndex")Long gdIndex);
 }
diff --git a/comService/src/main/java/com/njcn/mapper/configuration/LineMapper.java b/comService/src/main/java/com/njcn/mapper/configuration/LineMapper.java
index dddae4a..795307a 100644
--- a/comService/src/main/java/com/njcn/mapper/configuration/LineMapper.java
+++ b/comService/src/main/java/com/njcn/mapper/configuration/LineMapper.java
@@ -53,6 +53,8 @@ public interface LineMapper extends Mapper<Line> {
     //根据现有的监测点筛选出国网监测点
     List<Integer> getGWLines(@Param("list") List<Integer> subList);
 
+    List<Integer> getAllGWLines(@Param("list") List<Integer> subList);
+
     String selectLineName(String name);
 
     //获取该表所有数据，提供excel导出
diff --git a/comService/src/main/java/com/njcn/serviceimpl/configuration/DeviceServiceImpl.java b/comService/src/main/java/com/njcn/serviceimpl/configuration/DeviceServiceImpl.java
index 1a4ee4f..b3183a7 100644
--- a/comService/src/main/java/com/njcn/serviceimpl/configuration/DeviceServiceImpl.java
+++ b/comService/src/main/java/com/njcn/serviceimpl/configuration/DeviceServiceImpl.java
@@ -340,7 +340,7 @@ public class DeviceServiceImpl implements DeviceService {
         }
         intergralityData.setAllNets(list1);
         //国网监测点
-        List<Integer> countryLineIndexs = getGwLine(lineIndexs);
+        List<Integer> countryLineIndexs = getAllGwLine(lineIndexs);
         if (!CollectionUtils.isEmpty(countryLineIndexs)) {
             List<IntergralityTable> list2 = getGWIntegralityTable(startTime, endTime, countryLineIndexs);
             if (CollUtil.isNotEmpty(list2)){
@@ -1085,6 +1085,30 @@ public class DeviceServiceImpl implements DeviceService {
         return tempLine;
     }
 
+    private List<Integer> getAllGwLine(List<Integer> lines) {
+        if (CollectionUtils.isEmpty(lines)) {
+            return new ArrayList<>();
+        }
+        List<Integer> lineTemp = new ArrayList<>(lines);
+        List<Integer> tempLine = new ArrayList<>();
+        if (lineTemp.size() > 1000) {
+            int times = lineTemp.size() / 1000 + 1;
+            for (int i = 0; i < times; i++) {
+                if (lineTemp.size() > 1000) {
+                    List<Integer> subList = lineTemp.subList(0, 1000);
+                    List<Integer> temp = lineMapper.getAllGWLines(subList);
+                    subList.clear();
+                    tempLine.addAll(temp);
+                } else {
+                    tempLine.addAll(lineMapper.getAllGWLines(lineTemp));
+                }
+            }
+        } else {
+            tempLine.addAll(lineMapper.getAllGWLines(lineTemp));
+        }
+        return tempLine;
+    }
+
     /**
      * 根据监测点索引获取当前的数据完整性
      *
diff --git a/pqs9000/src/main/resources/mybatis/mappers/configuration/LineMapper.xml b/pqs9000/src/main/resources/mybatis/mappers/configuration/LineMapper.xml
index a00edc0..0c8fdb9 100644
--- a/pqs9000/src/main/resources/mybatis/mappers/configuration/LineMapper.xml
+++ b/pqs9000/src/main/resources/mybatis/mappers/configuration/LineMapper.xml
@@ -181,6 +181,24 @@
         AND T2.MONITOR_ID IS NOT NULL
     </select>
 
+    <select id="getAllGWLines" resultType="Integer">
+        SELECT
+        T2.LINE_INDEX
+        FROM
+        PQ_LINE t1,
+        PQ_LINEDETAIL t2,
+        PQ_DEVICE t3
+        WHERE
+        T1.LINE_INDEX = T2.LINE_INDEX
+        AND T1.DEV_INDEX=T3.DEV_INDEX
+        AND T1.LINE_INDEX IN
+        <foreach collection="list" item="item" open="(" close=")"
+                 separator=",">
+            #{item}
+        </foreach>
+        AND T2.MONITOR_ID IS NOT NULL
+    </select>
+
     <select id="getLineByEventDetailIndex" resultType="line">
         select t1.*
         from PQ_LINE t1,
diff --git a/pqs9900/src/main/java/com/pqs9900/controller/business/DeviceController.java b/pqs9900/src/main/java/com/pqs9900/controller/business/DeviceController.java
index 061703d..3bbb2d4 100644
--- a/pqs9900/src/main/java/com/pqs9900/controller/business/DeviceController.java
+++ b/pqs9900/src/main/java/com/pqs9900/controller/business/DeviceController.java
@@ -798,6 +798,20 @@ public class DeviceController {
         return result;
     }
 
+    @RequestMapping(value = "findMaxDeviceName", method = RequestMethod.POST)
+    @ResponseBody
+    public String findMaxDeviceName(HttpServletRequest request, Long gdIndex) {
+        String result;
+        try {
+            result = manaDevice.findMaxDeviceName(gdIndex);
+            userLog.getLog("查询当前供电公司下面最大的设备名称", "成功", result, LogTypeEnum.SYSTEM.toString(), 0);
+        } catch (Exception e) {
+            result = null;
+            userLog.getLog("查询当前供电公司下面最大的设备名称", "失败", result, LogTypeEnum.SYSTEM.toString(), 0);
+        }
+        return result;
+    }
+
     @RequestMapping(value = "addDevice", method = RequestMethod.POST)
     @ResponseBody
     public HttpResult addDevice(HttpServletRequest request, HttpSession session, String devName, Long gdIndex,
diff --git a/pqs9900/src/main/java/com/pqs9900/service/configuration/ManaDeviceService.java b/pqs9900/src/main/java/com/pqs9900/service/configuration/ManaDeviceService.java
index 3955d8a..e76ca14 100644
--- a/pqs9900/src/main/java/com/pqs9900/service/configuration/ManaDeviceService.java
+++ b/pqs9900/src/main/java/com/pqs9900/service/configuration/ManaDeviceService.java
@@ -123,4 +123,6 @@ public interface ManaDeviceService {
      */
     int addMonitor(String monitorId);
 
+    String findMaxDeviceName(Long gdIndex);
+
 }
diff --git a/pqs9900/src/main/java/com/pqs9900/serviceImpl/configuration/ManaDeviceServiceImpl.java b/pqs9900/src/main/java/com/pqs9900/serviceImpl/configuration/ManaDeviceServiceImpl.java
index f8d6d28..90342fe 100644
--- a/pqs9900/src/main/java/com/pqs9900/serviceImpl/configuration/ManaDeviceServiceImpl.java
+++ b/pqs9900/src/main/java/com/pqs9900/serviceImpl/configuration/ManaDeviceServiceImpl.java
@@ -2488,4 +2488,31 @@ public class ManaDeviceServiceImpl implements ManaDeviceService {
             return 0;
         }
     }
+
+    @Override
+    public String findMaxDeviceName(Long gdIndex) {
+        String name = deviceMapper.findMaxDeviceName(gdIndex);
+        return incrementString(name);
+    }
+
+    public String incrementString(String str) {
+        // 查找最后一个非数字字符的位置
+        int lastIndex = str.length() - 1;
+        while (lastIndex >= 0 && Character.isDigit(str.charAt(lastIndex))) {
+            lastIndex--;
+        }
+        // 如果没有找到非数字字符，说明整个字符串都是数字
+        if (lastIndex == -1) {
+            // 直接将字符串转换为整数，递增，再转回字符串
+            return String.valueOf(Long.parseLong(str) + 1);
+        }
+        // 提取出数字部分
+        String numberPart = str.substring(lastIndex + 1);
+        // 将数字部分转换为整数，递增，再转回字符串
+        long number = Long.parseLong(numberPart) + 1;
+        String incrementedNumberPart = String.format("%0" + numberPart.length() + "d", number);
+        // 将递增后的数字部分拼接到原字符串的非数字部分
+        return str.substring(0, lastIndex + 1) + incrementedNumberPart;
+    }
+
 }
diff --git a/pqs9900/src/main/resources/mybatis/mappers/configuration/DeviceMapper.xml b/pqs9900/src/main/resources/mybatis/mappers/configuration/DeviceMapper.xml
index ac69240..640de6d 100644
--- a/pqs9900/src/main/resources/mybatis/mappers/configuration/DeviceMapper.xml
+++ b/pqs9900/src/main/resources/mybatis/mappers/configuration/DeviceMapper.xml
@@ -171,4 +171,8 @@ FROM
 WHERE
 	a.dev_index = #{devIndex}
 	</select>
+
+    <select id="findMaxDeviceName" resultType="String">
+        SELECT MAX(NAME) FROM PQ_DEVICE WHERE GD_INDEX = #{gdIndex}
+    </select>
 </mapper>
diff --git a/pqs9900/src/main/webapp/WEB-INF/views/business/device/addDev.jsp b/pqs9900/src/main/webapp/WEB-INF/views/business/device/addDev.jsp
index 656368a..9cadd19 100644
--- a/pqs9900/src/main/webapp/WEB-INF/views/business/device/addDev.jsp
+++ b/pqs9900/src/main/webapp/WEB-INF/views/business/device/addDev.jsp
@@ -49,6 +49,20 @@
 <script type="text/javascript">
     $(document).ready(function () {
         $("html").css("height", "100px");
+
+        //获取默认装置名称
+        var gdIndex = $("#gdIndex").val();
+        $.ajax({
+            url: '/pqs9900/device/findMaxDeviceName',
+            type: 'POST',
+            dataType: "text",
+            data: {
+                gdIndex: gdIndex
+            },
+            success: function (data) {
+                $('#devName').val(data);
+            }
+        });
     });
 
     var index = parent.layer.getFrameIndex(window.name); //获取窗口索引