diff --git a/src/main/java/com/njcn/syncdata/controller/DataImportController.java b/src/main/java/com/njcn/syncdata/controller/DataImportController.java index 50914d7..e5cd8b8 100644 --- a/src/main/java/com/njcn/syncdata/controller/DataImportController.java +++ b/src/main/java/com/njcn/syncdata/controller/DataImportController.java @@ -1,5 +1,7 @@ package com.njcn.syncdata.controller; +import com.alibaba.fastjson.JSONArray; +import com.njcn.syncdata.pojo.po.PWOPTransformerPSR; import com.njcn.syncdata.service.IPowerDistributionareaService; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.GetMapping; @@ -44,7 +46,7 @@ public class DataImportController { */ @GetMapping("/getResource") public Map getResource(String token,String psrType, String fieldName,String fieldValue){ - return service.staticMethod(token,psrType,fieldName,fieldValue); + return service.getResourceData(token,psrType,100,fieldName,fieldValue); } /** @@ -57,8 +59,13 @@ public class DataImportController { */ @GetMapping("/getResourceData") public List getResourceData(String token,String psrType, String fieldName,String fieldValue){ - Map map = service.staticMethod(token, psrType, fieldName, fieldValue); - List data = (List) map.get("data"); + Map map = service.getResourceData(token, psrType,100, fieldName, fieldValue); + List data = JSONArray.parseArray(JSONArray.toJSONString(map.get("result")), PWOPTransformerPSR.class); return data; } + @GetMapping("/insertData") + public String getResourceData(){ + Map map = service.insertData(); + return "data"; + } } \ No newline at end of file diff --git a/src/main/java/com/njcn/syncdata/mapper/DictDataMapper.java b/src/main/java/com/njcn/syncdata/mapper/DictDataMapper.java index f2b80fb..20b959a 100644 --- a/src/main/java/com/njcn/syncdata/mapper/DictDataMapper.java +++ b/src/main/java/com/njcn/syncdata/mapper/DictDataMapper.java @@ -1,6 +1,7 @@ package com.njcn.syncdata.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.syncdata.pojo.po.Dept; import com.njcn.syncdata.pojo.po.DictData; import org.apache.ibatis.annotations.Param; @@ -17,5 +18,7 @@ import java.util.List; public interface DictDataMapper extends BaseMapper { List selectList(@Param("code") String code); + DictData selectByCode(@Param("code") String code); + List selectUserList(); } diff --git a/src/main/java/com/njcn/syncdata/mapper/PowerDistributionareaMapper.java b/src/main/java/com/njcn/syncdata/mapper/PowerDistributionareaMapper.java index e748bbd..129aa78 100644 --- a/src/main/java/com/njcn/syncdata/mapper/PowerDistributionareaMapper.java +++ b/src/main/java/com/njcn/syncdata/mapper/PowerDistributionareaMapper.java @@ -1,7 +1,7 @@ package com.njcn.syncdata.mapper; -import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.db.mapper.BatchBaseMapper; import com.njcn.syncdata.pojo.po.PowerDistributionarea; @@ -13,7 +13,7 @@ import com.njcn.syncdata.pojo.po.PowerDistributionarea; * @author hongawen * @since 2022-10-14 */ -public interface PowerDistributionareaMapper extends BaseMapper { +public interface PowerDistributionareaMapper extends BatchBaseMapper { } diff --git a/src/main/java/com/njcn/syncdata/mapper/mapping/DictDataMapper.xml b/src/main/java/com/njcn/syncdata/mapper/mapping/DictDataMapper.xml index e622fc0..2ad11a8 100644 --- a/src/main/java/com/njcn/syncdata/mapper/mapping/DictDataMapper.xml +++ b/src/main/java/com/njcn/syncdata/mapper/mapping/DictDataMapper.xml @@ -8,8 +8,18 @@ FROM sys_dict_data sys_dict_data, sys_dict_type sys_dict_type WHERE sys_dict_data.type_id = sys_dict_type.id --- AND sys_dict_type.code = #{code} - and sys_dict_data.state = 1 + AND sys_dict_type.code = #{code} + order by sort + + diff --git a/src/main/java/com/njcn/syncdata/pojo/po/Dept.java b/src/main/java/com/njcn/syncdata/pojo/po/Dept.java new file mode 100644 index 0000000..eaab350 --- /dev/null +++ b/src/main/java/com/njcn/syncdata/pojo/po/Dept.java @@ -0,0 +1,75 @@ +package com.njcn.syncdata.pojo.po; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.njcn.db.bo.BaseEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + * + * @author hongawen + * @since 2021-12-13 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@TableName("sys_dept") +public class Dept extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** + * 部门表Id + */ + private String id; + + /** + * 父节点Id(0为根节点) + */ + private String pid; + + /** + * 上层所有节点Id + */ + private String pids; + + /** + * 部门名称 + */ + private String name; + + /** + * 部门编号 + */ + private String code; + + /** + * 专项分析类型区分 + */ + private Integer specialType; + + /** + * （sys_Area）行政区域Id，自定义部门无需填写部门 + */ + private String area; + + /** + * 部门类型 0-非自定义；1-web自定义；2-App自定义；3-web测试 + */ + private Integer type; + + /** + * 排序 + */ + private Integer sort; + + /** + * 部门描述 + */ + private String remark; + + /** + * 部门状态 0-删除；1-正常；默认正常 + */ + private Integer state; + +} diff --git a/src/main/java/com/njcn/syncdata/pojo/po/PowerDistributionarea.java b/src/main/java/com/njcn/syncdata/pojo/po/PowerDistributionarea.java index 6e93a9c..af2bd27 100644 --- a/src/main/java/com/njcn/syncdata/pojo/po/PowerDistributionarea.java +++ b/src/main/java/com/njcn/syncdata/pojo/po/PowerDistributionarea.java @@ -152,5 +152,8 @@ public class PowerDistributionarea extends BaseEntity { private Integer status; - + /** + * 数据状态：0-手动录入；1-gw台账录入 + */ + private Integer inputStatus; } diff --git a/src/main/java/com/njcn/syncdata/service/IPowerDistributionareaService.java b/src/main/java/com/njcn/syncdata/service/IPowerDistributionareaService.java index 868ee80..96682a6 100644 --- a/src/main/java/com/njcn/syncdata/service/IPowerDistributionareaService.java +++ b/src/main/java/com/njcn/syncdata/service/IPowerDistributionareaService.java @@ -1,6 +1,6 @@ package com.njcn.syncdata.service; -import com.baomidou.mybatisplus.extension.service.IService; +import com.njcn.db.service.IReplenishMybatisService; import com.njcn.syncdata.pojo.po.PowerDistributionarea; import java.util.Map; @@ -13,7 +13,7 @@ import java.util.Map; * @author hongawen * @since 2022-10-14 */ -public interface IPowerDistributionareaService extends IService { +public interface IPowerDistributionareaService extends IReplenishMybatisService { /** * 登录获取token @@ -35,7 +35,7 @@ public interface IPowerDistributionareaService extends IService implements IPowerDistributionareaService { +public class PowerDistributionareaServiceImpl extends ReplenishMybatisServiceImpl implements IPowerDistributionareaService { private static Logger logger = LoggerFactory.getLogger(PowerDistributionareaServiceImpl.class); private final DictDataMapper dictDataMapper; @@ -149,8 +149,8 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl mapHeader = new HashMap<>(); @@ -163,7 +163,7 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl mapSubset = new HashMap<>(); - mapSubset.put("perPage", 100); + mapSubset.put("perPage", num); //sql查询 List> info = new ArrayList<>(); Map mapSubsets = new HashMap<>(); @@ -174,23 +174,51 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl userEntity = RestTemplateUtil.post(userUrl, mapHeader, map1, Map.class, new ArrayList<>()); - return userEntity.getBody(); + + if (userEntity.getStatusCodeValue() == 200) { + logger.debug(Thread.currentThread().getName() + "数据：" + userEntity.getBody() + "结束----！"); + //获取返回体 + body = userEntity.getBody(); + + } + return body; } @Override public Map insertData() { - List devVoltage = dictDataMapper.selectList("Dev_Voltage"); -/* + //初始化集合 List info = new ArrayList<>(); + + String token= LoginToken(); + //1.获取数据台账信息 + /* + String s1 = adsList(); + JSONObject jsonObject = JSON.parseObject(s1); + JSONArray data = jsonObject.getJSONArray("result"); + List aas = JSONArray.parseArray(String.valueOf(data), AdsAstXbjcptGetFctgDi.class); + */ + String s = "[{\"tg_id\":\"824843\",\"trans_pms_id\":\"73a32eea908afa989256723aa9015673a323181105\",\"id\":\"1415129064\",\"tg_name\":\"【混全】10kV722协神线东安香村南1号160公用配变\",\"tg_no\":\"0010034073\",\"pub_priv_flag\":\"01\",\"org_no\":\"134011910\",\"org_name\":\"行唐县安香供电所\",\"org_type\":\"06\",\"p_org_no\":\"1340119\",\"run_status_code\":\"01\",\"tg_cap\":160.0,\"fc_num\":2,\"fc_sum_cap\":44.8},\n" + " {\"tg_id\":\"825000\",\"trans_pms_id\":\"bc82f8391f8afa9890505facdb0150bc820b995f08\",\"id\":\"1411391450\",\"tg_name\":\"【混全】10kV722协神线东安香社厂100公用配变\",\"tg_no\":\"0010034337\",\"pub_priv_flag\":\"01\",\"org_no\":\"134011910\",\"org_name\":\"行唐县安香供电所\",\"org_type\":\"06\",\"p_org_no\":\"1340119\",\"run_status_code\":\"01\",\"tg_cap\":100.0,\"fc_num\":2,\"fc_sum_cap\":52.0}," + "{\"tg_id\":\"825000\",\"trans_pms_id\":\"bc82f8391f8afa9890505facdb0150bc820b995f08\",\"id\":\"1411391450\",\"tg_name\":\"【混全】10kV722协神线东安香社厂100公用配变\",\"tg_no\":\"0010034337\",\"pub_priv_flag\":\"01\",\"org_no\":\"134011910\",\"org_name\":\"行唐县安香供电所\",\"org_type\":\"06\",\"p_org_no\":\"1340119\",\"run_status_code\":\"01\",\"tg_cap\":100.0,\"fc_num\":2,\"fc_sum_cap\":52.0}," + "{\"tg_id\":\"825001\",\"trans_pms_id\":\"c06e78c12c8afa98904fb5b289014fc06e636c1f90\",\"id\":\"1411391450\",\"tg_name\":\"【混全】10kV722协神线东安香社厂100公用配变\",\"tg_no\":\"0010034337\",\"pub_priv_flag\":\"01\",\"org_no\":\"134011910\",\"org_name\":\"行唐县安香供电所\",\"org_type\":\"06\",\"p_org_no\":\"1340119\",\"run_status_code\":\"01\",\"tg_cap\":100.0,\"fc_num\":2,\"fc_sum_cap\":52.0}]"; List aas = JSONArray.parseArray(s, AdsAstXbjcptGetFctgDi.class); + + //进行数据拆分查询 Set aa = new HashSet<>(aas); List dome = new ArrayList<>(aa); - //设置需要进行的分片数据 + + //2.1.1获取电压字典 + List devVoltage = dictDataMapper.selectList("Dev_Voltage"); + //2.1.2运行状态 + List state = dictDataMapper.selectList("Line_State"); + //2.1.3获取分布式光伏字典 + DictData photovoltaics = dictDataMapper.selectByCode("Distributed_Photovoltaics"); + //2.1.4获取部门字典 + List depts = dictDataMapper.selectUserList(); + + //3.设置需要进行的分片数据 Integer num = 1000; int totalCount = dome.size(); List> pageList = ListUtil.split(dome, num); @@ -199,9 +227,31 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl temList = pageList.get(i); List trans_pms_id = temList.stream().map(AdsAstXbjcptGetFctgDi::getTrans_pms_id).distinct().collect(Collectors.toList()); -// List transformer =OssTest.staticMethod(1,PWOPTransformerPSR.class); -// List line =OssTest.staticMethod(2,PWFeederLinePSR.class); -// List substation =OssTest.staticMethod(3,Substation.class); + /* + //1.需要查询的户外变id + String transPmsIds = String.join(",", trans_pms_id); + List transformer = resourceMethod(1, token, num, transPmsIds, PWOPTransformerPSR.class); + List root_id = transformer.stream().map(PWOPTransformerPSR::getROOT_ID).distinct().collect(Collectors.toList()); + if(CollUtil.isEmpty(root_id)){ + continue; + } + //2.查询配网馈线id + String rootIds = String.join(",", root_id); + List line = resourceMethod(2, token, num, rootIds, PWFeederLinePSR.class); + List start_station_id = line.stream().map(PWFeederLinePSR::getStart_station_id).distinct().collect(Collectors.toList()); + if(CollUtil.isEmpty(start_station_id)){ + continue; + } + //3.查询变电站id + String substationIds = String.join(",", start_station_id); + List substation = resourceMethod(3, token, num, substationIds, Substation.class); + if(CollUtil.isEmpty(substation)){ + continue; + } + */ + List transformer =this.staticMethod(1,PWOPTransformerPSR.class); + List line =this.staticMethod(2,PWFeederLinePSR.class); + List substation =this.staticMethod(3,Substation.class); Map transformerMap = transformer.stream().collect(Collectors.toMap(PWOPTransformerPSR::getACCOUNT_ID, Function.identity(), (key1, kye2) -> key1)); Map lineMap = line.stream().collect(Collectors.toMap(PWFeederLinePSR::getID, Function.identity(), (key1, kye2) -> key1)); @@ -221,32 +271,32 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(PowerDistributionarea::getInputStatus,1); + this.remove(lambdaQueryWrapper); + this.insertBatchBySlice(info,1000); + } return null; } - public String getVoltageLevel(String name,List VoltageLevel){ - Map voltageMap = VoltageLevel.stream().filter(x -> x.getAlgoDescribe() != null).collect(Collectors.toMap(DictData::getAlgoDescribe, DictData::getId)); - if(voltageMap.containsKey(name)){ - return voltageMap.get(name); + public static List staticMethod(Integer a,Class t){ + List aas=new ArrayList<>(); + String s=null; + switch (a){ + case 1: + s="[{\n" + + " \"RUN_DATE\":\"2014-10-19 00:00:00\",\n" + + " \"ACCOUNT_ID\":\"c06e78c12c8afa98904fb5b289014fc06e636c1f90\",\n" + + " \"BELONG_TYPE\":\"1\",\n" + + " \"YX_TG_ID\":\"1569713\",\n" + + " \"CUSTOMER_TRANSFORMER_NAME\":\"电网_杨户解家寨内\",\n" + + " \"DEPART\":\"13B9B47F20603324E05338297A0A0595\",\n" + + " \"IS_WHOLESET_EQUIP\":null,\n" + + " \"SIGNIFICANCE\":\"1\",\n" + + " \"DISPATCH_OP_RIGHT\":null,\n" + + " \"POLE_ID\":\"10200001-3367889\",\n" + + " \"TRUSTEE\":null,\n" + + " \"DISPATCH_RIGHT\":null,\n" + + " \"MARKETING_UNIT\":null,\n" + + " \"ROOT_ID\":\"10000100-173425\",\n" + + " \"ALIAS_NAME\":null,\n" + + " \"CREATE_TIME\":\"2022-07-24 04:41:09\",\n" + + " \"ID\":\"11000000-579533\",\n" + + " \"DISPATCH_PERMISSION\":null,\n" + + " \"MEMO\":null,\n" + + " \"RETIRED_DATE\":null,\n" + + " \"LAST_RUN_DATE\":null,\n" + + " \"CAPACITY\":200,\n" + + " \"ROOT_CLASS_NAME\":\"PWFeederLinePSR\",\n" + + " \"MRID\":\"04M72000000363062\",\n" + + " \"PLAN_FEATURE\":\"05\",\n" + + " \"IS_COALTOELECTRICITY\":null,\n" + + " \"CHARGE_PILE_NUMBER\":0,\n" + + " \"SERVICE_POINT_ID\":null,\n" + + " \"DISPATCH_MONITOR_RIGHT\":null,\n" + + " \"PARENT_ID\":\"10000200-3235697\",\n" + + " \"NAME\":\"杨户解家寨内\",\n" + + " \"PATH_NAME\":\"\\\\赵县\\\\解家宅线426\\\\解家宅线426干线\\\\解家宅线426解家寨村内分支\",\n" + + " \"IS_STATION5G_POWER\":null,\n" + + " \"ADDRESS\":null,\n" + + " \"CUSTOMER_TRANSFORMER_ID\":\"1968493\",\n" + + " \"IS_AGENT\":\"0\",\n" + + " \"MODIFY_TIME\":\"2023-01-12 16:58:36\",\n" + + " \"MAINTENANCE_TEAM\":\"13B9B47F20783324E05338297A0A0595\",\n" + + " \"VOLTAGELEVEL_ID\":\"22\",\n" + + " \"DEV_MASTER\":\"130000000146834\",\n" + + " \"IS_CHARGEPILE_POWER\":null,\n" + + " \"CLASS_NAME\":\"PWOPTransformerPSR\",\n" + + " \"SUBGEOREGION\":\"\",\n" + + " \"AFFILIATRD_BRANCH\":null,\n" + + " \"DISTRICT\":\"13B9B47F1F223324E05338297A0A0595\",\n" + + " \"RUN_NO\":\"10038\",\n" + + " \"PARENT_CLASS_NAME\":\"PWSubLinePSR\",\n" + + " \"REGION_TYPE\":\"05\",\n" + + " \"ELECHTG_METHOD\":null,\n" + + " \"PATH_ID\":\"\\\\1f0b1e58-cfbd-11e9-b474-fa163ec04b01\\\\10000100-173505\\\\10000201-3235601\\\\10000200-3235697\",\n" + + " \"RUN_STATUS\":\"20\",\n" + + " \"IS_RURAL_GRID\":\"1\",\n" + + " \"CUSTOMER_NO\":null,\n" + + " \"GEOREGION\":\"1f0b1e58-cfbd-11e9-b474-fa163ec04b01\",\n" + + " \"USE_NATURE\":\"03\",\n" + + " \"SECTION\":\"13B9B47F20773324E05338297A0A0595\"\n" + + " }]"; + aas = JSONArray.parseArray(s, t); + break; + case 2: + s="[\n" + + " {\n" + + " \"DISPATCH_DEPART\": null,\n" + + " \"RUN_DATE\": \"2017-07-18 00:00:00\",\n" + + " \"START_STATION_ID\": \"30000000-180377\",\n" + + " \"BELONG_TYPE\": \"1\",\n" + + " \"ACCOUNT_ID\": \"04DKX-173425\",\n" + + " \"TRANSFORMER_CAPACITY\": 13440,\n" + + " \"TRANSFORMER_CAPACITY_PRIV\": 3065,\n" + + " \"DEPART\": \"13B9B47F20603324E05338297A0A0595\",\n" + + " \"SIGNIFICANCE\": null,\n" + + " \"START_STATION_CLASS_NAME\": \"Substation\",\n" + + " \"TRANSFORMER_CAPACITY_AMOR\": 1800,\n" + + " \"ROOT_ID\": \"10000100-173425\",\n" + + " \"ALIAS_NAME\": \"北龙化线454\",\n" + + " \"IS_CROSSCOUNTY_CONTACT\": null,\n" + + " \"START_BAY_CLASS_NAME\": \"BayPSR\",\n" + + " \"CREATE_TIME\": \"2022-07-24 03:45:33\",\n" + + " \"ID\": \"10000100-173425\",\n" + + " \"IS_DISTRIBUTEDELECHTG\": null,\n" + + " \"SECTION_COUNT\": 0,\n" + + " \"CONDUCTOR_LENGTH\": 16.721,\n" + + " \"RETIRED_DATE\": null,\n" + + " \"MEMO\": \"【煤改电】\",\n" + + " \"AGENT_LINE_LENGTH\": 0.012,\n" + + " \"LAST_RUN_DATE\": \"2005-09-06 00:00:00\",\n" + + " \"CURRENT_LIMIT\": 0,\n" + + " \"ROOT_CLASS_NAME\": \"PWFeederLinePSR\",\n" + + " \"MRID\": \"04M72000035746393\",\n" + + " \"PRECOMSTATION_COUNT\": 0,\n" + + " \"SWITCHSTATION_COUNT\": 0,\n" + + " \"PLAN_FEATURE\": \"04\",\n" + + " \"IS_COALTOELECTRICITY\": \"1\",\n" + + " \"POWERCABLE_COUNT\": 0,\n" + + " \"TRANSFORMER_COUNT_PRIV\": 17,\n" + + " \"START_SWITCH_ID\": \"30500000-191318\",\n" + + " \"PARENT_ID\": \"10000100-173425\",\n" + + " \"NAME\": \"北龙化线454\",\n" + + " \"PATH_NAME\": \"\\\\赵县\",\n" + + " \"LOOP_UNIT_COUNT\": 0,\n" + + " \"IS_AGENT\": \"0\",\n" + + " \"MODIFY_TIME\": \"2023-05-17 07:51:45\",\n" + + " \"IS_NSUBO\": null,\n" + + " \"INTERCONNECYION_LINE\": null,\n" + + " \"POLE_COUNT\": 342,\n" + + " \"MAINTENANCE_TEAM\": \"13B9B47F206E3324E05338297A0A0595\",\n" + + " \"DEV_MASTER\": \"130000000146417\",\n" + + " \"VOLTAGELEVEL_ID\": \"22\",\n" + + " \"LENGTH\": 16.751,\n" + + " \"TRANSFORMER_COUNT_PUBL\": 56,\n" + + " \"PRECOMSTATION_CAPACITY\": 0,\n" + + " \"TRANSFORMER_COUNT_AMOR\": 5,\n" + + " \"CLASS_NAME\": \"PWFeederLinePSR\",\n" + + " \"SUBGEOREGION\": \"\",\n" + + " \"AFFILIATRD_BRANCH\": null,\n" + + " \"DISTRICT\": \"13B9B47F1F223324E05338297A0A0595\",\n" + + " \"DISPATCH_LEVEL\": null,\n" + + " \"RUN_NO\": \"454\",\n" + + " \"PARENT_CLASS_NAME\": \"PWFeederLinePSR\",\n" + + " \"CABLE_LENGTH\": 0.03,\n" + + " \"FUSE_COUNT\": 57,\n" + + " \"REGION_TYPE\": \"01\",\n" + + " \"LAYOUT_MODE\": \"2\",\n" + + " \"START_SWITCH_CLASS_NAME\": \"BreakerPSR\",\n" + + " \"PATH_ID\": \"\\\\1f0b1e58-cfbd-11e9-b474-fa163ec04b01\",\n" + + " \"TRANSFORMER_CAPACITY_PUBL\": 10375,\n" + + " \"INSULATEDWIRE_LENGTH\": 16.721,\n" + + " \"RUN_STATUS\": \"20\",\n" + + " \"SUPPLY_RADIUS\": 4.351,\n" + + " \"IS_RURAL_GRID\": \"1\",\n" + + " \"GEOREGION\": \"1f0b1e58-cfbd-11e9-b474-fa163ec04b01\",\n" + + " \"USE_NATURE\": \"03\",\n" + + " \"TRANSFORMER_COUNT\": 73,\n" + + " \"START_BAY_ID\": \"38000000-131567\",\n" + + " \"BASEWIRE_LENGTH\": 0,\n" + + " \"SWITCH_COUNT\": 69,\n" + + " \"SECTION\": \"13B9B47F206D3324E05338297A0A0595\",\n" + + " \"IS_CENTRALIZEDELECHTG\": \"0\"\n" + + " }\n" + + " ]"; + aas = JSONArray.parseArray(s, t); + break; + case 3: + s="[\n" + + " {\n" + + " \"RUN_DATE\": \"2004-11-30 00:00:00\",\n" + + " \"BELONG_TYPE\": \"1\",\n" + + " \"ACCOUNT_ID\": \"5B039E90-F1DF-4611-859B-D87562B86CFF-61535\",\n" + + " \"TELEPHONE_NUMBER\": null,\n" + + " \"DEPART\": \"13B9B47F20603324E05338297A0A0595\",\n" + + " \"SIGNIFICANCE\": \"4\",\n" + + " \"DISPATCH_RIGHT\": null,\n" + + " \"ROOT_ID\": \"30000000-180377\",\n" + + " \"FIRE_PREVENT_CERTIFICATION\": \"01\",\n" + + " \"ALIAS_NAME\": null,\n" + + " \"ID\": \"30000000-180377\",\n" + + " \"CREATE_TIME\": \"2022-07-11 07:29:41\",\n" + + " \"SCALE\": null,\n" + + " \"FIRE_PREVENT_TYPE\": \"01\",\n" + + " \"TYPE\": null,\n" + + " \"RETIRED_DATE\": null,\n" + + " \"MEMO\": \"【煤改电】11\",\n" + + " \"LAST_RUN_DATE\": null,\n" + + " \"CAPACITY\": 0,\n" + + " \"ROOT_CLASS_NAME\": \"Substation\",\n" + + " \"MRID\": \"04M00000012958387\",\n" + + " \"PLAN_FEATURE\": \"05\",\n" + + " \"SUPERVISOR\": null,\n" + + " \"IS_LOOPED_NETWORK\": \"0\",\n" + + " \"NAME\": \"35kV圪塔头站(农网)\",\n" + + " \"PARENT_ID\": \"30000000-180377\",\n" + + " \"REGION\": null,\n" + + " \"PATH_NAME\": \"\\\\赵县\",\n" + + " \"ADDRESS\": \"石家庄赵县033省道黄市村村西304乡道各南村东\",\n" + + " \"IS_AVC_JOINED\": \"1\",\n" + + " \"IS_GIS_SUBSTATION\": \"0\",\n" + + " \"IS_AGENT\": \"0\",\n" + + " \"POLLUTION_GRADE\": \"04\",\n" + + " \"MODIFY_TIME\": \"2022-11-17 09:52:59\",\n" + + " \"IMPORTANT_LEVEL\": \"4\",\n" + + " \"IS_FUSION_SUBSTATION\": \"0\",\n" + + " \"IS_NSUBO\": \"1\",\n" + + " \"MAINTENANCE_TEAM\": \"13B9B47F20643324E05338297A0A0595\",\n" + + " \"DEV_MASTER\": \"130000000010186\",\n" + + " \"VOLTAGELEVEL_ID\": \"25\",\n" + + " \"IS_LOWLYING\": \"0\",\n" + + " \"WATCH_KEEPER_MODE\": \"2\",\n" + + " \"IS_PIVOT\": \"0\",\n" + + " \"DESIGNER\": \"河北华艺建筑设计有限公司\",\n" + + " \"CLASS_NAME\": \"Substation\",\n" + + " \"IS_FIRT_JOINED\": \"1\",\n" + + " \"IS_UNDERGROUND\": null,\n" + + " \"CONSTRUCTOR_UNIT\": null,\n" + + " \"SUBGEOREGION\": \"\",\n" + + " \"DISTRICT\": \"13B9B47F1F223324E05338297A0A0595\",\n" + + " \"RUN_NO\": \"35kV圪塔头站(农网)\",\n" + + " \"PARENT_CLASS_NAME\": \"Substation\",\n" + + " \"IS_LOADER_STATION\": null,\n" + + " \"ARRENTMENT_FORM\": \"01\",\n" + + " \"MARKET_ACCOUNT\": \"\",\n" + + " \"FUSION_PROJECT\": null,\n" + + " \"ANTI_MISOPERATION_MODE\": null,\n" + + " \"PATH_ID\": \"\\\\1f0b1e58-cfbd-11e9-b474-fa163ec04b01\",\n" + + " \"RUN_STATUS\": \"20\",\n" + + " \"IS_CENTRAL_SUPERVISORY\": \"1\",\n" + + " \"HAVE_FLOOD_PREVENTION_WALL\": \"0\",\n" + + " \"IS_RURAL_GRID\": \"1\",\n" + + " \"GEOREGION\": \"1f0b1e58-cfbd-11e9-b474-fa163ec04b01\",\n" + + " \"USE_NATURE\": \"03\",\n" + + " \"IDLE_CAPACITY\": 0,\n" + + " \"IS_SMART\": \"0\",\n" + + " \"SECTION\": \"13B9B47F20633324E05338297A0A0595\"\n" + + " }\n" + + " ]"; + aas = JSONArray.parseArray(s, t); + break; + } + return aas; + } + public List resourceMethod(Integer a,String token,Integer num,String ids,Class t){ + List aas=new ArrayList<>(); + switch (a){ + case 1: + //查询户外变 + Map transformerData = getResourceData(token, "PWOPTransformerPSR", num, "ACCOUNT_ID", ids); + aas = JSONArray.parseArray(JSONArray.toJSONString(transformerData.get("result")), t); + break; + case 2: + //查询配网馈线 + Map feederLineData = getResourceData(token, "PWFeederLinePSR", num, "ID", ids); + aas = JSONArray.parseArray(JSONArray.toJSONString(feederLineData.get("result")), t); + break; + case 3: + //查询变电站 + Map substationData = getResourceData(token, "Substation", num, "ID", ids); + aas = JSONArray.parseArray(JSONArray.toJSONString(substationData.get("result")), t); + break; + } + return aas; + } + public String getAlgoDescribe(String name,List voltageLevel){ + Map voltageMap = voltageLevel.stream().filter(x -> x.getAlgoDescribe() != null).collect(Collectors.toMap(DictData::getAlgoDescribe, DictData::getId,(key1, key2) -> key1)); + if(voltageMap.containsKey(Integer.valueOf(name))){ + return voltageMap.get(Integer.valueOf(name)); } return ""; } + public String getDeptName(String name,List depts){ + Map deptMap = depts.stream().collect(Collectors.toMap(Dept::getCode, Dept::getName, (key1, key2) -> key1)); + if(deptMap.containsKey(name)){ + return deptMap.get(name); + } + return ""; + } + }