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 { List selectList(@Param("code") String code); DictData selectByCode(@Param("dataCode") String dataCode,@Param("typeCode") String typeCode); List 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 @@ + + 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 + + + delete FROM pms_distribution_monitor + + + DATE_FORMAT(Create_Time, '%Y-%m-%d') = DATE_FORMAT(#{date}, '%Y-%m-%d') + + +