|
@@ -76,23 +76,18 @@ public class CacheContext implements CommandLineRunner {
|
|
|
@Resource
|
|
|
private IProBasicOrganizeTreeService proBasicOrganizeTreeService;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private IProEconPowerstationInfoDay7Service proEconPowerstationInfoDay7Service;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private IProEconPowerstationInfoDay1Service proEconPowerstationInfoDay1Service;
|
|
|
|
|
|
public static List<ProBasicBranch> bnls = new ArrayList<>();
|
|
|
-// public static List<ProBasicEquipment> wtls = new ArrayList<>();
|
|
|
-// public static List<ProBasicProject> pjls = new ArrayList<>();
|
|
|
-// public static List<ProBasicLine> lnls = new ArrayList<>();
|
|
|
-// public static List<ProBasicSubStation> subwpls = new ArrayList<>();
|
|
|
+
|
|
|
public static List<ProBasicWeatherStation> weawpls = new ArrayList<>();
|
|
|
-// public static List<ProBasicSquare> sqls = new ArrayList<>();
|
|
|
-// public static List<ProBasicPowerstation> wpls = new ArrayList<>();
|
|
|
-// public static List<ProBasicPowerstation> wplsf = new ArrayList<>();
|
|
|
-// public static List<ProBasicPowerstation> wplsG = new ArrayList<>(); //光电集合
|
|
|
- public static List<ProBasicPowerstation> zwpls = new ArrayList<>();
|
|
|
-// public static List<ProBasicCompany> cpls = new ArrayList<>();
|
|
|
public static List<ProBasicCompany> cpls1 = new ArrayList<>();
|
|
|
-// public static List<ProBasicRegion> rgls = new ArrayList<>();
|
|
|
-// public static List<ProBasicEnergyGroup> gpls = new ArrayList<>();
|
|
|
|
|
|
+ public static List<ProBasicOrganizeTree> treels = new ArrayList<>();
|
|
|
public static List<ProBasicOrganizeTree> sqls = new ArrayList<>(); //阵区
|
|
|
public static List<ProBasicOrganizeTree> cpls = new ArrayList<>();//公司
|
|
|
public static List<ProBasicOrganizeTree> rgls = new ArrayList<>();//区域
|
|
@@ -104,15 +99,12 @@ public class CacheContext implements CommandLineRunner {
|
|
|
public static List<ProBasicOrganizeTree> subwpls = new ArrayList<>(); //变电所
|
|
|
public static List<ProBasicOrganizeTree> wplsf = new ArrayList<>();
|
|
|
public static List<ProBasicOrganizeTree> wplsG = new ArrayList<>(); //光电集合
|
|
|
-
|
|
|
-
|
|
|
-// public static Map<String,ProBasicProject> pjmap = new HashMap<>();
|
|
|
-// public static Map<String,ProBasicLine> lnmap = new HashMap<>();
|
|
|
-// public static Map<String,ProBasicRegion> rgmap = new HashMap<>();
|
|
|
-// public static Map<String,ProBasicCompany> cpmap = new HashMap<>();
|
|
|
-// public static Map<String,ProBasicEnergyGroup> gpmap = new HashMap<>();
|
|
|
+ public static List<ProEconPowerstationInfoDay7> station7ls = new ArrayList<>();
|
|
|
+ public static List<ProEconPowerstationInfoDay1> station1ls = new ArrayList<>();
|
|
|
|
|
|
public static Map<String,ProBasicOrganizeTree> sqmap = new HashMap<>();
|
|
|
+ public static Map<String,ProEconPowerstationInfoDay7> station7map = new HashMap<>();
|
|
|
+ public static Map<String,ProEconPowerstationInfoDay1> station1map = new HashMap<>();
|
|
|
public static Map<String,ProBasicOrganizeTree> cpmap = new HashMap<>();
|
|
|
public static Map<String,ProBasicOrganizeTree> rgmap = new HashMap<>();
|
|
|
public static Map<String,ProBasicOrganizeTree> gpmap = new HashMap<>();
|
|
@@ -130,32 +122,14 @@ public class CacheContext implements CommandLineRunner {
|
|
|
public static Map<Object,List<ProBasicOrganizeTree>> rgwtlsmap = new HashMap<>();
|
|
|
public static Map<Object,List<ProBasicOrganizeTree>> sqwtmap = new HashMap<>();
|
|
|
public static Map<Object,List<ProBasicOrganizeTree>> prolinemap = new HashMap<>();
|
|
|
-// public static Map<Object,List<ProBasicOrganizeTree>> cpwpmap = new HashMap<>();
|
|
|
public static Map<String,List<ProBasicOrganizeTree>> wpmapls = new HashMap<>();
|
|
|
public static Map<Object,Map<String,ProBasicOrganizeTree>> cmwtmap = new HashMap<>();
|
|
|
public static Map<Object,List<ProBasicOrganizeTree>> wppromap = new HashMap<>();
|
|
|
public static Map<String,String> wtstandardmap = new HashMap<>();//标杆
|
|
|
|
|
|
-
|
|
|
-// public static Map<String,List<ProBasicPowerstation>> cpwpmap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicPowerstation>> wpmapls = new HashMap<>();
|
|
|
- public static Map<String,List<ProBasicPowerstation>> stationls = new HashMap<>();
|
|
|
public static Map<String,List<ProBasicBranch>> wtbnmap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicCompany>> rgcpmap = new HashMap<>();
|
|
|
-// public static Map<String,ProBasicSquare> sqmap = new HashMap<>();
|
|
|
-// public static Map<String, ProBasicPowerstation> wpmap = new HashMap<>();
|
|
|
public static List<ProBasicMeterPoint> meterpoints = new ArrayList<>();
|
|
|
public static Map<String,ProBasicMeterPoint> meterpointMap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicProject>> wppromap = new HashMap<>();
|
|
|
- public static Map<String,List<ProBasicProject>> projmap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicLine>> prolinemap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicEquipment>> wpwtmap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicEquipment>> pjwtmap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicEquipment>> lnwtmap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicEquipment>> cmwtlsmap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicEquipment>> rgwtlsmap = new HashMap<>();
|
|
|
-// public static Map<String,Map<String,ProBasicEquipment>> cmwtmap = new HashMap<>();
|
|
|
-// public static Map<String,List<ProBasicEquipment>> sqwtmap = new HashMap<>();
|
|
|
public static Map<String, Map<String, ProBasicEquipmentPoint>> bnAimap = new HashMap<>();
|
|
|
public static Map<String, Map<String, ProBasicEquipmentPoint>> wtpAimap = new HashMap<>();// 风电机测点AI表
|
|
|
public static Map<String,Map<String, ProBasicPowerstationPoint>> linepointmap =new HashMap<>();
|
|
@@ -167,21 +141,15 @@ public class CacheContext implements CommandLineRunner {
|
|
|
public static Map<String,Map<String, ProBasicPowerstationPoint>> regionpointmap =new HashMap<>();
|
|
|
public static Map<String,Map<String, ProBasicPowerstationPoint>> grouppointmap =new HashMap<>();
|
|
|
|
|
|
- public static Map<String,Map<Double,Double>> zbzglMap = new HashMap<>();
|
|
|
public static Map<String,ProEconEquipmentmodel> modelMap = new HashMap<>();
|
|
|
- public static Map<String,Map<Double,Double>> zzsglMap = new HashMap<>();
|
|
|
public static Map<String,Double> modelpower = new HashMap<>();
|
|
|
|
|
|
-// public static Map<String,String> wtstandardmap = new HashMap<>();
|
|
|
-// public static Map<String, ProBasicEquipment> wtmap = new HashMap<>();
|
|
|
-
|
|
|
public static Map<String,Map<Double,ProBasicModelPower>> modelpowermap = new TreeMap<>();
|
|
|
|
|
|
public static List<ProBasicModelPower> mpls=new ArrayList<>();
|
|
|
|
|
|
public static List<ProEconEquipmentmodel> equipmentmodels=new ArrayList<>();
|
|
|
|
|
|
- public static Map<String,List<ProBasicEquipment>> subWtsMap = new HashMap<>();
|
|
|
public static List<ProBasicModelPowerRd> theoreticalPowerList=new ArrayList<>();
|
|
|
public static Map<String, Map<Double,ProBasicModelPowerRd>> theoreticalPowerMap = new HashMap<>(); //理论,保证功率
|
|
|
public static Map<String, Map<Double,ProEconWtPowerCurveFitting>> curveFittingPowerMap = new HashMap<>(); //自算,最优功率
|
|
@@ -232,15 +200,7 @@ public class CacheContext implements CommandLineRunner {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-// sqls=proBasicSquareService.list().stream().filter(i->i.getIsAble()==1).collect(Collectors.toList());
|
|
|
-// if (!sqls.isEmpty())
|
|
|
-// {
|
|
|
-// for(ProBasicSquare sq:sqls)
|
|
|
-// {
|
|
|
-// sqmap.put(sq.getId(),sq);
|
|
|
-// }
|
|
|
-// }
|
|
|
+ treels = proBasicOrganizeTreeService.list().stream().filter(i->i.getIsAble()==1).collect(Collectors.toList());
|
|
|
|
|
|
//树形方阵
|
|
|
sqls = proBasicOrganizeTreeService.list().stream().filter(i->i.getOrgType().contains("AG") && i.getIsAble()==1).collect(Collectors.toList());
|
|
@@ -252,42 +212,29 @@ public class CacheContext implements CommandLineRunner {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-// cpls=proBasicCompanyService.list().stream().filter(i->i.getIsAble().equals(1)).collect(Collectors.toList());
|
|
|
-//
|
|
|
-// cpls1=proBasicCompanyService.list().stream().filter(i->i.getSpare2().equals("1")).collect(Collectors.toList());
|
|
|
-// if (!cpls.isEmpty())
|
|
|
-// {
|
|
|
-// for(ProBasicCompany sq:cpls)
|
|
|
-// {
|
|
|
-// cpmap.put(sq.getId(),sq);
|
|
|
-//
|
|
|
-// if (redisService.hasKey(sq.getId()+"0")){
|
|
|
-// String cp0String = redisService.get(sq.getId()+"0");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp0String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// companypointmap.put(sq.getId()+"0",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-// if (redisService.hasKey(sq.getId()+"-1")){
|
|
|
-// String cp1String = redisService.get(sq.getId()+"-1");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp1String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// companypointmap.put(sq.getId()+"-1",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-// if (redisService.hasKey(sq.getId()+"-2")){
|
|
|
-// String cp2String = redisService.get(sq.getId()+"-2");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp2String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// companypointmap.put(sq.getId()+"-2",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-//
|
|
|
-//
|
|
|
-//
|
|
|
-//
|
|
|
-// }
|
|
|
-//
|
|
|
-// }
|
|
|
-
|
|
|
- //三级公司树形
|
|
|
+
|
|
|
+
|
|
|
+ station7ls = proEconPowerstationInfoDay7Service.list().stream().filter(i->i.getId()!=null).collect(Collectors.toList());
|
|
|
+ if (!station7ls.isEmpty())
|
|
|
+ {
|
|
|
+ for (ProEconPowerstationInfoDay7 sq : station7ls)
|
|
|
+ {
|
|
|
+ station7map.put(sq.getForeignKeyId(),sq);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ station1ls = proEconPowerstationInfoDay1Service.list().stream().filter(i->i.getId()!=null).collect(Collectors.toList());
|
|
|
+ if (!station1ls.isEmpty())
|
|
|
+ {
|
|
|
+ for (ProEconPowerstationInfoDay1 sq : station1ls)
|
|
|
+ {
|
|
|
+ station1map.put(sq.getForeignKeyId(),sq);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ //三级公司
|
|
|
cpls=proBasicOrganizeTreeService.list().stream().filter(i->i.getIsAble().equals(1) && i.getOrgType().contains("ZGS")).collect(Collectors.toList());
|
|
|
if (!cpls.isEmpty())
|
|
|
{
|
|
@@ -316,35 +263,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-// rgls=proBasicRegionService.list().stream().filter(i->i.getIsAble()==1).collect(Collectors.toList());
|
|
|
-//
|
|
|
-//
|
|
|
-// if (!rgls.isEmpty())
|
|
|
-// {
|
|
|
-// for(ProBasicRegion sq:rgls)
|
|
|
-// {
|
|
|
-// rgmap.put(sq.getId(),sq);
|
|
|
-//
|
|
|
-// if (redisService.hasKey(sq.getId()+"0")){
|
|
|
-// String cp0String = redisService.get(sq.getId()+"0");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp0String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// regionpointmap.put(sq.getId()+"0",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-// if (redisService.hasKey(sq.getId()+"-1")){
|
|
|
-// String cp1String = redisService.get(sq.getId()+"-1");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp1String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// regionpointmap.put(sq.getId()+"-1",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-// if (redisService.hasKey(sq.getId()+"-2")){
|
|
|
-// String cp2String = redisService.get(sq.getId()+"-2");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp2String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// regionpointmap.put(sq.getId()+"-2",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
|
|
|
|
|
|
//区域树形
|
|
@@ -375,36 +293,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
-//
|
|
|
-// List<ProBasicEnergyGroup> energyGroups = proBasicEnergyGroupService.list();
|
|
|
-// gpls = energyGroups.stream().filter(e->e.getIsAble()==1 && e.getId().endsWith("FGS")).collect(Collectors.toList());
|
|
|
-//
|
|
|
-// if (!gpls.isEmpty())
|
|
|
-// {
|
|
|
-// for(ProBasicEnergyGroup gp:gpls)
|
|
|
-// {
|
|
|
-// gpmap.put(gp.getId(),gp);
|
|
|
-//
|
|
|
-// if (redisService.hasKey(gp.getId()+"0")){
|
|
|
-// String cp0String = redisService.get(gp.getId()+"0");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp0String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// grouppointmap.put(gp.getId()+"0",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-// if (redisService.hasKey(gp.getId()+"-1")){
|
|
|
-// String cp1String = redisService.get(gp.getId()+"-1");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp1String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// grouppointmap.put(gp.getId()+"-1",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-// if (redisService.hasKey(gp.getId()+"-2")){
|
|
|
-// String cp2String = redisService.get(gp.getId()+"-2");
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(cp2String, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// grouppointmap.put(gp.getId()+"-2",stringWindpowerstationpointnewMap);
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
|
|
|
|
|
|
|
|
@@ -440,19 +328,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
-// for(ProBasicCompany cp:cpls)
|
|
|
-// {
|
|
|
-// if (rgcpmap.containsKey(cp.getRegionId())){
|
|
|
-// rgcpmap.get(cp.getRegionId()).add(cp);
|
|
|
-// }else {
|
|
|
-// List<ProBasicCompany> wps = new ArrayList<>();
|
|
|
-// wps.add(cp);
|
|
|
-// rgcpmap.put(cp.getRegionId(),wps);
|
|
|
-// }
|
|
|
-// }
|
|
|
-
|
|
|
-
|
|
|
//区域子公司树形
|
|
|
for(ProBasicOrganizeTree cp:cpls)
|
|
|
{
|
|
@@ -465,16 +340,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-// for(ProBasicPowerstation wp:wpls)
|
|
|
-// {
|
|
|
-// if (cpwpmap.containsKey(wp.getCompanyId())){
|
|
|
-// cpwpmap.get(wp.getCompanyId()).add(wp);
|
|
|
-// }else {
|
|
|
-// List<ProBasicPowerstation> wps = new ArrayList<>();
|
|
|
-// wps.add(wp);
|
|
|
-// cpwpmap.put(wp.getCompanyId(),wps);
|
|
|
-// }
|
|
|
-// }
|
|
|
wpls = proBasicOrganizeTreeService.list().stream().filter(i->i.getIsAble()==1 && i.getOrgType().contains("STA")).collect(Collectors.toList());
|
|
|
for(ProBasicOrganizeTree wp:wpls)
|
|
|
{
|
|
@@ -488,79 +353,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
}
|
|
|
|
|
|
|
|
|
-// wtls = proBasicEquipmentService.list().stream().filter(i->i.getIsable()==1).collect(Collectors.toList());
|
|
|
-// logger.info(wtls.size()+"");
|
|
|
-// wtls.forEach(wt->{
|
|
|
-// if(modelMap.containsKey(wt.getModelId()))
|
|
|
-// {
|
|
|
-// ProEconEquipmentmodel equipmentmodel = modelMap.get(wt.getModelId());
|
|
|
-// modelpower.put(wt.getId(),equipmentmodel.getPowerProduction().doubleValue());
|
|
|
-// }
|
|
|
-//
|
|
|
-//
|
|
|
-// wtmap.put(wt.getId(),wt);
|
|
|
-// //标杆风机初始化
|
|
|
-// wtstandardmap.put(wt.getId(),wt.getId());
|
|
|
-// String wtString = redisService.get(wt.getId());
|
|
|
-// Map<String, ProBasicEquipmentPoint> stringWindturbinetestingpointnewMap = JSONObject.parseObject(wtString, new TypeReference<Map<String, ProBasicEquipmentPoint>>() {
|
|
|
-// });
|
|
|
-// wtpAimap.put(wt.getId(),stringWindturbinetestingpointnewMap);
|
|
|
-//
|
|
|
-//
|
|
|
-// if (wpwtmap.containsKey(wt.getWindpowerstationId())){
|
|
|
-// wpwtmap.get(wt.getWindpowerstationId()).add(wt);
|
|
|
-// }else {
|
|
|
-// List<ProBasicEquipment> wps = new ArrayList<>();
|
|
|
-// wps.add(wt);
|
|
|
-// wpwtmap.put(wt.getWindpowerstationId(),wps);
|
|
|
-// }
|
|
|
-//
|
|
|
-// if (pjwtmap.containsKey(wt.getProjectId())){
|
|
|
-// pjwtmap.get(wt.getProjectId()).add(wt);
|
|
|
-// }else {
|
|
|
-// List<ProBasicEquipment> pjs = new ArrayList<>();
|
|
|
-// pjs.add(wt);
|
|
|
-// pjwtmap.put(wt.getProjectId(),pjs);
|
|
|
-// }
|
|
|
-// if (lnwtmap.containsKey(wt.getLineId())){
|
|
|
-// lnwtmap.get(wt.getLineId()).add(wt);
|
|
|
-// }else {
|
|
|
-// List<ProBasicEquipment> lnls = new ArrayList<>();
|
|
|
-// lnls.add(wt);
|
|
|
-// lnwtmap.put(wt.getLineId(),lnls);
|
|
|
-// }
|
|
|
-// if (cmwtlsmap.containsKey(wt.getCompanyId())){
|
|
|
-// cmwtlsmap.get(wt.getCompanyId()).add(wt);
|
|
|
-// }else {
|
|
|
-// List<ProBasicEquipment> cmls = new ArrayList<>();
|
|
|
-// cmls.add(wt);
|
|
|
-// cmwtlsmap.put(wt.getCompanyId(),cmls);
|
|
|
-// }
|
|
|
-// if (rgwtlsmap.containsKey(wt.getRegionId())){
|
|
|
-// rgwtlsmap.get(wt.getRegionId()).add(wt);
|
|
|
-// }else {
|
|
|
-// List<ProBasicEquipment> rgls = new ArrayList<>();
|
|
|
-// rgls.add(wt);
|
|
|
-// rgwtlsmap.put(wt.getRegionId(),rgls);
|
|
|
-// }
|
|
|
-//
|
|
|
-// if (sqwtmap.containsKey(wt.getSquareId())){
|
|
|
-// sqwtmap.get(wt.getSquareId()).add(wt);
|
|
|
-// }else {
|
|
|
-// List<ProBasicEquipment> lnls = new ArrayList<>();
|
|
|
-// lnls.add(wt);
|
|
|
-// sqwtmap.put(wt.getSquareId(),lnls);
|
|
|
-// }
|
|
|
-//
|
|
|
-// if (cmwtmap.containsKey(wt.getCompanyId())){
|
|
|
-// cmwtmap.get(wt.getCompanyId()).put(wt.getId(),wt);
|
|
|
-// }else {
|
|
|
-// Map<String,ProBasicEquipment> map=new HashMap<>();
|
|
|
-// map.put(wt.getId(),wt);
|
|
|
-// cmwtmap.put(wt.getCompanyId(),map);
|
|
|
-// }
|
|
|
-// });
|
|
|
-
|
|
|
|
|
|
|
|
|
//树形设备
|
|
@@ -639,48 +431,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
});
|
|
|
|
|
|
|
|
|
-//
|
|
|
-// //初始化标杆风机
|
|
|
-// for(ProBasicEquipment wt:wtls)
|
|
|
-// {
|
|
|
-// if(wpwtmap.containsKey(wt.getLineId()))
|
|
|
-// {
|
|
|
-// List<ProBasicEquipment> wts=wpwtmap.get(wt.getLineId());
|
|
|
-// for(ProBasicEquipment w:wts)
|
|
|
-// {
|
|
|
-// if(StringUtils.notEmp(w.getIsStandard()) && w.getIsStandard()!=0)
|
|
|
-// {
|
|
|
-// wtstandardmap.put(wt.getId(),w.getId());
|
|
|
-// break;
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
-// if(pjwtmap.containsKey(wt.getLineId()))
|
|
|
-// {
|
|
|
-// List<ProBasicEquipment> wts=pjwtmap.get(wt.getLineId());
|
|
|
-// for(ProBasicEquipment w:wts)
|
|
|
-// {
|
|
|
-// if(StringUtils.notEmp(w.getIsStandard()) && w.getIsStandard()!=0)
|
|
|
-// {
|
|
|
-// wtstandardmap.put(wt.getId(),w.getId());
|
|
|
-// break;
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
-// if(lnwtmap.containsKey(wt.getLineId()))
|
|
|
-// {
|
|
|
-// List<ProBasicEquipment> wts=lnwtmap.get(wt.getLineId());
|
|
|
-// for(ProBasicEquipment w:wts)
|
|
|
-// {
|
|
|
-// if(StringUtils.notEmp(w.getIsStandard()) && w.getIsStandard()!=0)
|
|
|
-// {
|
|
|
-// wtstandardmap.put(wt.getId(),w.getId());
|
|
|
-// break;
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
-
|
|
|
|
|
|
//树形初始化标杆风机
|
|
|
for(ProBasicOrganizeTree wt : wtls)
|
|
@@ -725,25 +475,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
|
|
|
|
|
|
|
|
|
-
|
|
|
-// pjls = proBasicProjectService.list().stream().filter(i-> i.getIsAble()==1).collect(Collectors.toList());
|
|
|
-// pjls.stream().forEach(p->{
|
|
|
-// pjmap.put(p.getId(),p);
|
|
|
-// if (wppromap.containsKey(p.getWindpowerstationId())){
|
|
|
-// wppromap.get(p.getWindpowerstationId()).add(p);
|
|
|
-// }else {
|
|
|
-// List<ProBasicProject> prolist = new ArrayList<>();
|
|
|
-// prolist.add(p);
|
|
|
-// wppromap.put(p.getWindpowerstationId(),prolist);
|
|
|
-// }
|
|
|
-// String pjString = redisService.get(p.getId());
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(pjString, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// propointmap.put(p.getId(),stringWindpowerstationpointnewMap);
|
|
|
-//
|
|
|
-// });
|
|
|
-
|
|
|
-
|
|
|
//期次场站树形
|
|
|
pjls = proBasicOrganizeTreeService.list().stream().filter(i-> i.getIsAble()==1 && i.getOrgType().contains("EG")).collect(Collectors.toList());
|
|
|
pjls.stream().forEach(p->{
|
|
@@ -764,20 +495,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
|
|
|
|
|
|
|
|
|
-// projmap = pjls.stream().collect(Collectors.groupingBy(ProBasicProject::getWindpowerstationId));
|
|
|
-
|
|
|
-// subwpls = proBasicSubStationService.list().stream().filter(i-> i.getIsAble()==1).collect(Collectors.toList());
|
|
|
-// subwpls.stream().forEach(sub->{
|
|
|
-//
|
|
|
-// String subString = redisService.get(sub.getId());
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(subString, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// subwppointmap.put(sub.getId(),stringWindpowerstationpointnewMap);
|
|
|
-//
|
|
|
-// });
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
subwpls = proBasicOrganizeTreeService.list().stream().filter(i-> i.getIsAble()==1 && i.getOrgType().contains("SBS")).collect(Collectors.toList());
|
|
|
subwpls.stream().forEach(sub->{
|
|
|
|
|
@@ -800,23 +517,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
|
|
|
});
|
|
|
|
|
|
-//
|
|
|
-// //线路
|
|
|
-// lnls = proBasicLineService.list().stream().filter(i-> StringUtils.isNotNull(pjmap.get(i.getProjectId())) && i.getIsAble()==1).collect(Collectors.toList());
|
|
|
-// lnls.stream().forEach(l->{
|
|
|
-// lnmap.put(l.getId(),l);
|
|
|
-// if (prolinemap.containsKey(l.getProjectId())){
|
|
|
-// prolinemap.get(l.getProjectId()).add(l);
|
|
|
-// }else {
|
|
|
-// List<ProBasicLine> lineList = new ArrayList<>();
|
|
|
-// lineList.add(l);
|
|
|
-// prolinemap.put(l.getProjectId(),lineList);
|
|
|
-// }
|
|
|
-// String lnString = redisService.get(l.getId());
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringWindpowerstationpointnewMap = JSONObject.parseObject(lnString, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// linepointmap.put(l.getId(),stringWindpowerstationpointnewMap);
|
|
|
-// });
|
|
|
|
|
|
|
|
|
//树形线路
|
|
@@ -836,24 +536,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
linepointmap.put(l.getId(),stringWindpowerstationpointnewMap);
|
|
|
});
|
|
|
|
|
|
-//
|
|
|
-// zwpls = proBasicWindpowerstationService.list().stream().filter(i->i.getIsAble()==1).collect(Collectors.toList());
|
|
|
-// wpls = proBasicWindpowerstationService.list().stream().filter(i->i.getIsAble()==1).collect(Collectors.toList());
|
|
|
-// for(ProBasicPowerstation wp:wpls)
|
|
|
-// {
|
|
|
-// if (cpwpmap.containsKey(wp.getCompanyId())){
|
|
|
-// cpwpmap.get(wp.getCompanyId()).add(wp);
|
|
|
-// }else {
|
|
|
-// List<ProBasicPowerstation> wps = new ArrayList<>();
|
|
|
-// wps.add(wp);
|
|
|
-// cpwpmap.put(wp.getCompanyId(),wps);
|
|
|
-// }
|
|
|
-// }
|
|
|
-// meterpoints = proBasicMeterPointService.list().stream().filter(i->i.getIsAble()==1).collect(Collectors.toList());
|
|
|
-// meterpoints.stream().forEach(meterpoint -> {
|
|
|
-// meterpointMap.put(meterpoint.getId(),meterpoint);
|
|
|
-// });
|
|
|
-
|
|
|
|
|
|
for(ProBasicOrganizeTree wp:wpls)
|
|
|
{
|
|
@@ -870,15 +552,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
meterpointMap.put(meterpoint.getId(),meterpoint);
|
|
|
});
|
|
|
|
|
|
-// wpls.stream().forEach(wp->{
|
|
|
-//
|
|
|
-// wpmap.put(wp.getId(),wp);
|
|
|
-// String wpString = redisService.get(wp.getId());
|
|
|
-// Map<String, ProBasicPowerstationPoint> stringMapMap = JSONObject.parseObject(wpString, new TypeReference<Map<String, ProBasicPowerstationPoint>>() {
|
|
|
-// });
|
|
|
-// wppointmap.put(wp.getId(),stringMapMap);
|
|
|
-// });
|
|
|
-
|
|
|
wpls.stream().forEach(wp->{
|
|
|
|
|
|
wpmap.put(wp.getId(),wp);
|
|
@@ -890,30 +563,6 @@ public class CacheContext implements CommandLineRunner {
|
|
|
|
|
|
|
|
|
|
|
|
-// if (!wpls.isEmpty()) {
|
|
|
-// for (ProBasicPowerstation wp : wpls) {
|
|
|
-// if (wp.getId().endsWith("FDC_STA")) {
|
|
|
-// wplsf.add(wp);
|
|
|
-// }
|
|
|
-// if (wp.getId().endsWith("GDC_STA")) {
|
|
|
-// wplsG.add(wp);
|
|
|
-// }
|
|
|
-//
|
|
|
-// if(wpmapls.containsKey(wp.getId()))
|
|
|
-// {
|
|
|
-// List<ProBasicPowerstation> ls=wpmapls.get(wp.getId());
|
|
|
-// ls.add(wp);
|
|
|
-// wpmapls.put(wp.getId(),ls);
|
|
|
-// }else {
|
|
|
-// List<ProBasicPowerstation> ls=new ArrayList<>();
|
|
|
-// ls.add(wp);
|
|
|
-// wpmapls.put(wp.getId(),ls);
|
|
|
-// }
|
|
|
-//
|
|
|
-// wpmap.put(wp.getId(),wp);
|
|
|
-// }
|
|
|
-// }
|
|
|
-
|
|
|
if (!wpls.isEmpty()) {
|
|
|
for (ProBasicOrganizeTree wp : wpls) {
|
|
|
if (wp.getEleType().contains("F")) {
|