From 119637bc8819507f5559184843d1c8839a2d2d09 Mon Sep 17 00:00:00 2001
From: wr <1754607820@qq.com>
Date: Wed, 11 Oct 2023 16:07:50 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=8F=B0=E8=B4=A6=E7=BC=96=E5=8F=B7=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0160=E5=89=8D=E7=BC=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/DisPhotovoltaicController.java | 10 ++++++
 .../jbsyncdata/mapper/DictDataMapper.java     |  2 ++
 .../mapper/mapping/DictDataMapper.xml         | 36 +++++++++++++++++++
 .../service/DisPhotovoltaicService.java       |  8 +++++
 .../impl/DisPhotovoltaicServiceImpl.java      | 13 +++++--
 5 files changed, 67 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/njcn/jbsyncdata/controller/DisPhotovoltaicController.java b/src/main/java/com/njcn/jbsyncdata/controller/DisPhotovoltaicController.java
index 98be201..f6b011a 100644
--- a/src/main/java/com/njcn/jbsyncdata/controller/DisPhotovoltaicController.java
+++ b/src/main/java/com/njcn/jbsyncdata/controller/DisPhotovoltaicController.java
@@ -103,4 +103,14 @@ public class DisPhotovoltaicController {
         System.out.println();
 
     }
+
+//    @ApiOperation(value = "将用户数据导入到配网表中")
+//    @PostMapping("/insertDistributionMonitor")
+//    public String import380KV() throws Exception {
+//        Boolean aBoolean = disPhotovoltaicService.savePmsDistributionMonitor();
+//        if(aBoolean){
+//            return "数据导入成功";
+//        }
+//        return "数据导入失败";
+//    }
 }
diff --git a/src/main/java/com/njcn/jbsyncdata/mapper/DictDataMapper.java b/src/main/java/com/njcn/jbsyncdata/mapper/DictDataMapper.java
index 66ba3a5..0a9a6f4 100644
--- a/src/main/java/com/njcn/jbsyncdata/mapper/DictDataMapper.java
+++ b/src/main/java/com/njcn/jbsyncdata/mapper/DictDataMapper.java
@@ -20,5 +20,7 @@ public interface DictDataMapper extends BaseMapper<DictData> {
     List<DictData> selectList(@Param("code") String code);
     DictData selectByCode(@Param("dataCode") String dataCode,@Param("typeCode") String typeCode);
     List<Dept> selectUserList();
+    Boolean deletePmsDistributionMonitor(@Param("date") String date);
+    Boolean insertPmsDistributionMonitor();
 
 }
diff --git a/src/main/java/com/njcn/jbsyncdata/mapper/mapping/DictDataMapper.xml b/src/main/java/com/njcn/jbsyncdata/mapper/mapping/DictDataMapper.xml
index e52b198..10e4a67 100644
--- a/src/main/java/com/njcn/jbsyncdata/mapper/mapping/DictDataMapper.xml
+++ b/src/main/java/com/njcn/jbsyncdata/mapper/mapping/DictDataMapper.xml
@@ -2,6 +2,42 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.njcn.jbsyncdata.mapper.DictDataMapper">
 
+    <insert id="insertPmsDistributionMonitor">
+        INSERT INTO pms_distribution_monitor (
+            Monitor_Sort,
+            Monitor_Id,
+            Org_Id,
+            Voltage_Level,
+            If_Power_User,
+            Monitor_State,
+            Created_Date,
+            Status,
+            Create_Time,
+            Update_Time
+        )
+        select
+                (select id from sys_dict_data where code="Three_Line") as Monitor_Sort,
+                id as Monitor_Id,
+                Org_Id as Org_Id ,
+                Voltage_Level as Voltage_Level,
+                1 as If_Power_User,
+                (select sd.id from sys_dict_data sd INNER JOIN sys_dict_type st on st.id=sd.Type_Id where sd.`Code`="Run" and st.`Code`="Line_State") as Monitor_State,
+                now() as Created_Date,
+                1 as Status,
+                now() as Create_Time,
+                now() as Update_Time
+        from
+            pms_power_generation_user
+        where Status=1
+    </insert>
+    <delete id="deletePmsDistributionMonitor">
+        delete FROM pms_distribution_monitor
+        <where>
+            <if test="date != null and  date !=''">
+                DATE_FORMAT(Create_Time, '%Y-%m-%d') = DATE_FORMAT(#{date}, '%Y-%m-%d')
+            </if>
+        </where>
+    </delete>
 
     <select id="selectList" resultType="com.njcn.jbsyncdata.pojo.DictData">
         SELECT sys_dict_data.*
diff --git a/src/main/java/com/njcn/jbsyncdata/service/DisPhotovoltaicService.java b/src/main/java/com/njcn/jbsyncdata/service/DisPhotovoltaicService.java
index 6db4fba..9965495 100644
--- a/src/main/java/com/njcn/jbsyncdata/service/DisPhotovoltaicService.java
+++ b/src/main/java/com/njcn/jbsyncdata/service/DisPhotovoltaicService.java
@@ -31,4 +31,12 @@ public interface DisPhotovoltaicService {
      */
     void SavaPmsPowerGenerationUser380KV(List<DisPhotovoltaic380Excel> list, HttpServletResponse response);
 
+    /**
+     * @Description: 配网表数据新增
+     * @param
+     * @return: java.lang.Boolean
+     * @Author: wr
+     * @Date: 2023/10/11 14:31
+     */
+    Boolean savePmsDistributionMonitor();
 }
diff --git a/src/main/java/com/njcn/jbsyncdata/service/impl/DisPhotovoltaicServiceImpl.java b/src/main/java/com/njcn/jbsyncdata/service/impl/DisPhotovoltaicServiceImpl.java
index 961beeb..184c277 100644
--- a/src/main/java/com/njcn/jbsyncdata/service/impl/DisPhotovoltaicServiceImpl.java
+++ b/src/main/java/com/njcn/jbsyncdata/service/impl/DisPhotovoltaicServiceImpl.java
@@ -88,7 +88,7 @@ public class DisPhotovoltaicServiceImpl implements DisPhotovoltaicService {
             }
 
             user = new PmsPowerGenerationUser();
-            user.setId(excel.getGenerationUserID());
+            user.setId("160"+excel.getGenerationUserID());
             user.setName(excel.getGenerationUserName());
             //todo 部门信息
             user.setOrgName("国网" + excel.getOrgName());
@@ -188,7 +188,7 @@ public class DisPhotovoltaicServiceImpl implements DisPhotovoltaicService {
             }
 
             user = new PmsPowerGenerationUser();
-            user.setId(excel.getGenerationUserID());
+            user.setId("160"+excel.getGenerationUserID());
             user.setName(excel.getGenerationUserName());
             //todo 部门信息
             user.setOrgName(replace);
@@ -239,6 +239,15 @@ public class DisPhotovoltaicServiceImpl implements DisPhotovoltaicService {
         }
     }
 
+    @Override
+    public Boolean savePmsDistributionMonitor() {
+        Boolean aBoolean = dictDataMapper.deletePmsDistributionMonitor(null);
+        if(aBoolean){
+           return dictDataMapper.insertPmsDistributionMonitor();
+        }
+        return false;
+    }
+
     public String getAlgoDescribe(String name, List<DictData> dictData) {
         List<DictData> dictDataList = dictData.stream().filter(x -> x.getName().indexOf(name) != -1).collect(Collectors.toList());
         if (CollUtil.isNotEmpty(dictDataList)) {