SyncTool/hb_syncdata
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码提交

Browse Source
This commit is contained in:
wr
2023-06-09 16:21:30 +08:00
parent 8ebeaa056c
commit 14cae10422
8 changed files with 446 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/com/njcn/syncdata/controller/DataImportController.java
View File

@@ -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<PWOPTransformerPSR> data = JSONArray.parseArray(JSONArray.toJSONString(map.get("result")), PWOPTransformerPSR.class);
return data;
}
@GetMapping("/insertData")
public String getResourceData(){
Map map = service.insertData();
return "data";
}
}

3
src/main/java/com/njcn/syncdata/mapper/DictDataMapper.java
View File

@@ -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<DictData> {
List<DictData> selectList(@Param("code") String code);
DictData selectByCode(@Param("code") String code);
List<Dept> selectUserList();
}

4
src/main/java/com/njcn/syncdata/mapper/PowerDistributionareaMapper.java
View File

@@ -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<PowerDistributionarea> {
public interface PowerDistributionareaMapper extends BatchBaseMapper<PowerDistributionarea> {
}

14
src/main/java/com/njcn/syncdata/mapper/mapping/DictDataMapper.xml
View File

@@ -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
</select>
<select id="selectUserList" resultType="com.njcn.syncdata.pojo.po.Dept">
select * from sys_dept where state = 1 order by sort
</select>
<select id="selectByCode" resultType="com.njcn.syncdata.pojo.po.DictData">
SELECT sys_dict_data.*
FROM sys_dict_data sys_dict_data
WHERE
sys_dict_data.code = #{code}
and sys_dict_data.state = 1
</select>
</mapper>

75
src/main/java/com/njcn/syncdata/pojo/po/Dept.java Normal file
View File

@@ -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;
}

5
src/main/java/com/njcn/syncdata/pojo/po/PowerDistributionarea.java
View File

@@ -152,5 +152,8 @@ public class PowerDistributionarea extends BaseEntity {
private Integer status;
/**
* 数据状态：0-手动录入；1-gw台账录入
*/
private Integer inputStatus;
}

6
src/main/java/com/njcn/syncdata/service/IPowerDistributionareaService.java
View File

@@ -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<PowerDistributionarea> {
public interface IPowerDistributionareaService extends IReplenishMybatisService<PowerDistributionarea> {
/**
* 登录获取token
@@ -35,7 +35,7 @@ public interface IPowerDistributionareaService extends IService<PowerDistributio
* @param fieldValue 数据id集合
* @return
*/
Map staticMethod(String token,String psrType, String fieldName,String fieldValue);
Map getResourceData(String token,String psrType,Integer num, String fieldName,String fieldValue);
Map insertData();
}

366
src/main/java/com/njcn/syncdata/service/impl/PowerDistributionareaServiceImpl.java
View File

@@ -1,12 +1,12 @@
package com.njcn.syncdata.service.impl;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.collection.ListUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.cloud.apigateway.sdk.utils.Client;
import com.cloud.apigateway.sdk.utils.Request;
import com.njcn.db.service.impl.ReplenishMybatisServiceImpl;
import com.njcn.syncdata.mapper.DictDataMapper;
import com.njcn.syncdata.mapper.PowerDistributionareaMapper;
import com.njcn.syncdata.pojo.po.*;
@@ -43,7 +43,7 @@ import java.util.stream.Collectors;
*/
@Service
@RequiredArgsConstructor
public class PowerDistributionareaServiceImpl extends ServiceImpl<PowerDistributionareaMapper, PowerDistributionarea> implements IPowerDistributionareaService {
public class PowerDistributionareaServiceImpl extends ReplenishMybatisServiceImpl<PowerDistributionareaMapper, PowerDistributionarea> implements IPowerDistributionareaService {
private static Logger logger = LoggerFactory.getLogger(PowerDistributionareaServiceImpl.class);
private final DictDataMapper dictDataMapper;
@@ -149,8 +149,8 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl<PowerDistribut
}
@Override
public Map staticMethod(String token, String psrType, String fieldName, String fieldValue) {
public Map getResourceData(String token, String psrType,Integer num, String fieldName, String fieldValue) {
Map body=new HashMap();
String userUrl = "http://dwzyywzt.com/baseCenter/oauth2/accessToken";
Map<String, String> mapHeader = new HashMap<>();
@@ -163,7 +163,7 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl<PowerDistribut
map1.put("psrType", psrType);
map1.put("distribution", 1);
Map<String, Object> mapSubset = new HashMap<>();
mapSubset.put("perPage", 100);
mapSubset.put("perPage", num);
//sql查询
List<Map<String, Object>> info = new ArrayList<>();
Map<String, Object> mapSubsets = new HashMap<>();
@@ -174,23 +174,51 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl<PowerDistribut
mapSubset.put("filters", info);
map1.put("params", mapSubset);
ResponseEntity<Map> 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<DictData> devVoltage = dictDataMapper.selectList("Dev_Voltage");
/*
//初始化集合
List<PowerDistributionarea> info = new ArrayList<>();
String token= LoginToken();
//1.获取数据台账信息
/*
String s1 = adsList();
JSONObject jsonObject = JSON.parseObject(s1);
JSONArray data = jsonObject.getJSONArray("result");
List<AdsAstXbjcptGetFctgDi> 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<AdsAstXbjcptGetFctgDi> aas = JSONArray.parseArray(s, AdsAstXbjcptGetFctgDi.class);
//进行数据拆分查询
Set<AdsAstXbjcptGetFctgDi> aa = new HashSet<>(aas);
List<AdsAstXbjcptGetFctgDi> dome = new ArrayList<>(aa);
//设置需要进行的分片数据
//2.1.1获取电压字典
List<DictData> devVoltage = dictDataMapper.selectList("Dev_Voltage");
//2.1.2运行状态
List<DictData> state = dictDataMapper.selectList("Line_State");
//2.1.3获取分布式光伏字典
DictData photovoltaics = dictDataMapper.selectByCode("Distributed_Photovoltaics");
//2.1.4获取部门字典
List<Dept> depts = dictDataMapper.selectUserList();
//3.设置需要进行的分片数据
Integer num = 1000;
int totalCount = dome.size();
List<List<AdsAstXbjcptGetFctgDi>> pageList = ListUtil.split(dome, num);
@@ -199,9 +227,31 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl<PowerDistribut
for (Integer i = 0; i < forNum; i++) {
List<AdsAstXbjcptGetFctgDi> temList = pageList.get(i);
List<String> trans_pms_id = temList.stream().map(AdsAstXbjcptGetFctgDi::getTrans_pms_id).distinct().collect(Collectors.toList());
// List<PWOPTransformerPSR> transformer =OssTest.staticMethod(1,PWOPTransformerPSR.class);
// List<PWFeederLinePSR> line =OssTest.staticMethod(2,PWFeederLinePSR.class);
// List<Substation> substation =OssTest.staticMethod(3,Substation.class);
/*
//1.需要查询的户外变id
String transPmsIds = String.join(",", trans_pms_id);
List<PWOPTransformerPSR> transformer = resourceMethod(1, token, num, transPmsIds, PWOPTransformerPSR.class);
List<String> 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<PWFeederLinePSR> line = resourceMethod(2, token, num, rootIds, PWFeederLinePSR.class);
List<String> 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> substation = resourceMethod(3, token, num, substationIds, Substation.class);
if(CollUtil.isEmpty(substation)){
continue;
}
*/
List<PWOPTransformerPSR> transformer =this.staticMethod(1,PWOPTransformerPSR.class);
List<PWFeederLinePSR> line =this.staticMethod(2,PWFeederLinePSR.class);
List<Substation> substation =this.staticMethod(3,Substation.class);
Map<String, PWOPTransformerPSR> transformerMap = transformer.stream().collect(Collectors.toMap(PWOPTransformerPSR::getACCOUNT_ID, Function.identity(), (key1, kye2) -> key1));
Map<String, PWFeederLinePSR> lineMap = line.stream().collect(Collectors.toMap(PWFeederLinePSR::getID, Function.identity(), (key1, kye2) -> key1));
@@ -221,32 +271,32 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl<PowerDistribut
if (substationMap.containsKey(pwFeederLinePSR.getStart_station_id())) {
Substation sub = substationMap.get(pwFeederLinePSR.getStart_station_id());
//名称暂时不知道
area.setOrgName(deptMap.get(pwFeederLinePSR.getDEPART()));
area.setOrgName(getDeptName(pwFeederLinePSR.getDEPART(),depts));
area.setOrgId(pwFeederLinePSR.getDEPART());
area.setOperationName(deptMap.get(pwFeederLinePSR.getMAINTENANCE_TEAM()));
area.setOperationName(getDeptName(pwFeederLinePSR.getMAINTENANCE_TEAM(),depts));
area.setOperationId(pwFeederLinePSR.getMAINTENANCE_TEAM());
area.setPowerrName(sub.getNAME());
area.setPowerStationId(sub.getID());
area.setLineName(pwFeederLinePSR.getName());
area.setLineId(pwFeederLinePSR.getID());
//todo 要做处理
area.setVoltageLevel(getVoltageLevel(pwopTransformerPSR.getVOLTAGELEVEL_ID(),devVoltage));
//todo 要做处理(处理)
area.setVoltageLevel(getAlgoDescribe(pwopTransformerPSR.getVOLTAGELEVEL_ID(),devVoltage));
area.setPCapacity(fctgDi.getTg_cap().floatValue());
//todo 要做处理
//todo 要做处理(未处理)
area.setRegionalism(fctgDi.getArea_type());
area.setIfRuralPowerGrid(pwopTransformerPSR.getIS_RURAL_GRID());
//todo 要做处理
//todo 要做处理(未处理)
area.setNatureOfUse(pwopTransformerPSR.getUse_nature());
area.setPowerSupplyRadius(pwFeederLinePSR.getSUPPLY_RADIUS().floatValue());
area.setLineLength(pwFeederLinePSR.getLENGTH().floatValue());
//todo 要做处理
area.setState(pwopTransformerPSR.getRUN_STATUS());
//todo 要做处理(处理)
area.setState(getAlgoDescribe(pwopTransformerPSR.getRUN_STATUS(),state));
area.setDistributedPhotovoltaicNum(fctgDi.getFc_num());
area.setPhotovoltaicCapacity(fctgDi.getFc_sum_cap().floatValue());
area.setIfBevAp(0);
area.setApLoadType(data.getId());
area.setApLoadType(photovoltaics.getId());
area.setIsUpToGrid(1);
area.setStatus(1);
area.setCreateBy(null);
@@ -261,17 +311,275 @@ public class PowerDistributionareaServiceImpl extends ServiceImpl<PowerDistribut
continue;
}
}
}
*/
if(CollUtil.isNotEmpty(info)){
LambdaQueryWrapper<PowerDistributionarea> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(PowerDistributionarea::getInputStatus,1);
this.remove(lambdaQueryWrapper);
this.insertBatchBySlice(info,1000);
}
return null;
}
public String getVoltageLevel(String name,List<DictData> VoltageLevel){
Map<Integer, String> 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 <T> List<T> staticMethod(Integer a,Class<T> t){
List<T> 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 <T> List<T> resourceMethod(Integer a,String token,Integer num,String ids,Class<T> t){
List<T> 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<DictData> voltageLevel){
Map<Integer, String> 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<Dept> depts){
Map<String, String> deptMap = depts.stream().collect(Collectors.toMap(Dept::getCode, Dept::getName, (key1, key2) -> key1));
if(deptMap.containsKey(name)){
return deptMap.get(name);
}
return "";
}
}