|
@@ -180,7 +180,7 @@ public class MonitorService {
|
|
|
double fd_jclyxnum = 0;
|
|
|
|
|
|
double fd_xdjclnum = 0;
|
|
|
-
|
|
|
+
|
|
|
double fd_tjnum = 0;
|
|
|
|
|
|
double fd_gztjnum = 0;
|
|
@@ -235,73 +235,79 @@ public class MonitorService {
|
|
|
List<String> fjztls = new ArrayList<>();
|
|
|
List<String> gfztls = new ArrayList<>();
|
|
|
|
|
|
- if (wp.getId().endsWith("FDC_STA") && CacheContext.wpwtmap.containsKey(wp.getId())) {
|
|
|
- List<ProBasicEquipment> wtls = CacheContext.wpwtmap.get(wp.getId());
|
|
|
- for (ProBasicEquipment wt : wtls) {
|
|
|
- fjztls.add(proBasicEquipmentPointService.getEquipmentPoint(wt.getId(), ContantXk.MXZT).getNemCode());
|
|
|
+ if (wp.getId().endsWith("FDC_STA") && CacheContext.wpmapls.containsKey(wp.getId())) {
|
|
|
+ List<ProBasicPowerstation> wpls = CacheContext.wpmapls.get(wp.getId());
|
|
|
+ for (ProBasicPowerstation wt : wpls) {
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.GZTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.CNSLGZTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.JXTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.CNSLJXTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.DJTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.QXJCLTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.SDTJTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.XNTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.XDTJTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.XDJCLTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.CWSLDWTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.CWSLTQTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.LXTSMX).getNemCode());
|
|
|
+ fjztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.TXZDTSMX).getNemCode());
|
|
|
+
|
|
|
+ List<PointData> fjztlist = edosUtil.getRealData(fjztls);
|
|
|
+
|
|
|
+ fd_gztjnum += fjztlist.get(0).getPointValueInDouble();
|
|
|
+ fd_gzcnslnum += fjztlist.get(1).getPointValueInDouble();
|
|
|
+ fd_jxtjnum += fjztlist.get(2).getPointValueInDouble();
|
|
|
+ fd_jxclslnum += fjztlist.get(3).getPointValueInDouble();
|
|
|
+ fd_dfnum += fjztlist.get(4).getPointValueInDouble();
|
|
|
+ fd_jclyxnum += fjztlist.get(5).getPointValueInDouble();
|
|
|
+ fd_sdtjnum += fjztlist.get(6).getPointValueInDouble();
|
|
|
+ fd_zcfdnum += fjztlist.get(7).getPointValueInDouble();
|
|
|
+ fd_tjnum += fjztlist.get(8).getPointValueInDouble();
|
|
|
+ fd_xdjclnum += fjztlist.get(9).getPointValueInDouble();
|
|
|
+ fd_sldwnum += fjztlist.get(10).getPointValueInDouble();
|
|
|
+ fd_slhjnum += fjztlist.get(11).getPointValueInDouble();
|
|
|
+ fd_lxnum += fjztlist.get(12).getPointValueInDouble();
|
|
|
+ fd_wznum += fjztlist.get(13).getPointValueInDouble();
|
|
|
}
|
|
|
|
|
|
- } else if (wp.getId().endsWith("GDC_STA") && CacheContext.wpwtmap.containsKey(wp.getId())) {
|
|
|
- List<ProBasicEquipment> wtls = CacheContext.wpwtmap.get(wp.getId());
|
|
|
- for (ProBasicEquipment wt : wtls) {
|
|
|
- gfztls.add(proBasicEquipmentPointService.getEquipmentPoint(wt.getId(), ContantXk.MXZT).getNemCode());
|
|
|
+ } else if (wp.getId().endsWith("GDC_STA") && CacheContext.wpmapls.containsKey(wp.getId())) {
|
|
|
+ List<ProBasicPowerstation> wtls = CacheContext.wpmapls.get(wp.getId());
|
|
|
+ for (ProBasicPowerstation wt : wtls) {
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.GZTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.CNSLGZTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.JXTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.CNSLJXTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.DJTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.QXJCLTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.SDTJTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.XNTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.XDTJTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.XDJCLTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.CWSLDWTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.CWSLTQTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.LXTSMX).getNemCode());
|
|
|
+ gfztls.add(proBasicPowerstationPointService.getPowerstationPoint(wt.getId(),ContantXk.TXZDTSMX).getNemCode());
|
|
|
+
|
|
|
+ List<PointData> gfztlist = edosUtil.getRealData(gfztls);
|
|
|
+
|
|
|
+ gf_gztjnum += gfztlist.get(0).getPointValueInDouble();
|
|
|
+ gf_gzcnslnum += gfztlist.get(1).getPointValueInDouble();
|
|
|
+ gf_jxtjnum += gfztlist.get(2).getPointValueInDouble();
|
|
|
+ gf_jxclslnum += gfztlist.get(3).getPointValueInDouble();
|
|
|
+ gf_dfnum += gfztlist.get(4).getPointValueInDouble();
|
|
|
+ gf_jclyxnum += gfztlist.get(5).getPointValueInDouble();
|
|
|
+ gf_sdtjnum += gfztlist.get(6).getPointValueInDouble();
|
|
|
+ gf_zcfdnum += gfztlist.get(7).getPointValueInDouble();
|
|
|
+ gf_tjnum += gfztlist.get(8).getPointValueInDouble();
|
|
|
+ gf_xdjclnum += gfztlist.get(9).getPointValueInDouble();
|
|
|
+ gf_sldwnum += gfztlist.get(10).getPointValueInDouble();
|
|
|
+ gf_slhjnum += gfztlist.get(11).getPointValueInDouble();
|
|
|
+ gf_lxnum += gfztlist.get(12).getPointValueInDouble();
|
|
|
+ gf_wznum += gfztlist.get(13).getPointValueInDouble();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- List<PointData> fjztlist = edosUtil.getRealData(fjztls);
|
|
|
- List<PointData> gfztlist = edosUtil.getRealData(gfztls);
|
|
|
-
|
|
|
- if (!fjztlist.isEmpty() && fjztlist.size() == fjztls.size()) {
|
|
|
- for (int i = 0; i < fjztlist.size(); i++) {
|
|
|
- double fjzt = MathUtil.twoBit(MathUtil.twoBit(fjztlist.get(i).getPointValueInDouble()));
|
|
|
- switch (Double.valueOf(fjzt).intValue()) {
|
|
|
- case 0:
|
|
|
- fd_dfnum++;
|
|
|
- break;
|
|
|
- case 1:
|
|
|
- fd_sdtjnum++;
|
|
|
- break;
|
|
|
- case 2:
|
|
|
- fd_zcfdnum++;
|
|
|
- break;
|
|
|
- case 3:
|
|
|
- fd_jclyxnum++;
|
|
|
- break;
|
|
|
- case 4:
|
|
|
- fd_gztjnum++;
|
|
|
- break;
|
|
|
- case 5:
|
|
|
- fd_gzcnslnum++;
|
|
|
- break;
|
|
|
- case 6:
|
|
|
- fd_jxtjnum++;
|
|
|
- break;
|
|
|
- case 7:
|
|
|
- fd_jxclslnum++;
|
|
|
- break;
|
|
|
- case 8:
|
|
|
- fd_xdjclnum++;
|
|
|
- break;
|
|
|
- case 9:
|
|
|
- fd_tjnum++;
|
|
|
- break;
|
|
|
- case 10:
|
|
|
- fd_sldwnum++;
|
|
|
- break;
|
|
|
- case 11:
|
|
|
- fd_slhjnum++;
|
|
|
- break;
|
|
|
- case 12:
|
|
|
- fd_wznum++;
|
|
|
- break;
|
|
|
- case 13:
|
|
|
- fd_lxnum++;
|
|
|
- break;
|
|
|
- default:
|
|
|
- break;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
mxztmap.put("fd_dfnum", fd_dfnum);
|
|
|
mxztmap.put("fd_sdtjnum", fd_sdtjnum);
|
|
|
mxztmap.put("fd_zcfdnum", fd_zcfdnum);
|
|
@@ -325,59 +331,6 @@ public class MonitorService {
|
|
|
mxztmap.put("fd_slnum", fd_slhjnum + fd_sldwnum);
|
|
|
mxztmap.put("fd_lxyznum", fd_wznum + fd_lxnum);
|
|
|
|
|
|
- }
|
|
|
-
|
|
|
- if (!gfztlist.isEmpty() && gfztlist.size() == gfztls.size()) {
|
|
|
- for (int i = 0; i < gfztlist.size(); i++) {
|
|
|
- double gfzt = MathUtil.twoBit(MathUtil.twoBit(gfztlist.get(i).getPointValueInDouble()));
|
|
|
- switch (Double.valueOf(gfzt).intValue()) {
|
|
|
- case 0:
|
|
|
- gf_dfnum++;
|
|
|
- break;
|
|
|
- case 1:
|
|
|
- gf_sdtjnum++;
|
|
|
- break;
|
|
|
- case 2:
|
|
|
- gf_zcfdnum++;
|
|
|
- break;
|
|
|
- case 3:
|
|
|
- gf_jclyxnum++;
|
|
|
- break;
|
|
|
- case 4:
|
|
|
- gf_gztjnum++;
|
|
|
- break;
|
|
|
- case 5:
|
|
|
- gf_gzcnslnum++;
|
|
|
- break;
|
|
|
- case 6:
|
|
|
- gf_jxtjnum++;
|
|
|
- break;
|
|
|
- case 7:
|
|
|
- gf_jxclslnum++;
|
|
|
- break;
|
|
|
- case 8:
|
|
|
- gf_xdjclnum++;
|
|
|
- break;
|
|
|
- case 9:
|
|
|
- gf_tjnum++;
|
|
|
- break;
|
|
|
- case 10:
|
|
|
- gf_sldwnum++;
|
|
|
- break;
|
|
|
- case 11:
|
|
|
- gf_slhjnum++;
|
|
|
- break;
|
|
|
- case 12:
|
|
|
- gf_wznum++;
|
|
|
- break;
|
|
|
- case 13:
|
|
|
- gf_lxnum++;
|
|
|
- break;
|
|
|
- default:
|
|
|
- break;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
mxztmap.put("gf_dfnum", gf_dfnum);
|
|
|
mxztmap.put("gf_sdtjnum", gf_sdtjnum);
|
|
|
mxztmap.put("gf_zcfdnum", gf_zcfdnum);
|
|
@@ -400,7 +353,157 @@ public class MonitorService {
|
|
|
mxztmap.put("gf_xdnum", gf_xdjclnum + gf_tjnum);
|
|
|
mxztmap.put("gf_slnum", gf_slhjnum + gf_sldwnum);
|
|
|
mxztmap.put("gf_lxyznum", gf_wznum + gf_lxnum);
|
|
|
- }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
}
|
|
|
map.put("mxztmap", mxztmap);
|
|
@@ -1498,8 +1601,21 @@ public class MonitorService {
|
|
|
zjrlmap.put("zjrl", zjrl);
|
|
|
|
|
|
|
|
|
- Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap = CacheContext.pointwpmap;
|
|
|
- Map<String, ProBasicPowerstationPoint> wtpointmap = pointwpmap.get(wpId);
|
|
|
+ Map<String, ProBasicPowerstationPoint> wtpointmap = null;
|
|
|
+ Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap = CacheContext.wppointmap;
|
|
|
+ Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap1 = CacheContext.companypointmap;
|
|
|
+ Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap2 = CacheContext.regionpointmap;
|
|
|
+ Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap3 = CacheContext.grouppointmap;
|
|
|
+
|
|
|
+ if (pointwpmap.containsKey(wpId)){
|
|
|
+ wtpointmap = pointwpmap.get(wpId);
|
|
|
+ }else if (pointwpmap1.containsKey(wpId)) {
|
|
|
+ wtpointmap = pointwpmap1.get(wpId);
|
|
|
+ }else if (pointwpmap2.containsKey(wpId)){
|
|
|
+ wtpointmap = pointwpmap2.get(wpId);
|
|
|
+ }else if (pointwpmap3.containsKey(wpId)){
|
|
|
+ wtpointmap = pointwpmap3.get(wpId);
|
|
|
+ }
|
|
|
|
|
|
List<String> year = new ArrayList<>();
|
|
|
year.add(wtpointmap.get(ContantXk.NFDL).getNemCode());
|
|
@@ -1599,8 +1715,23 @@ public class MonitorService {
|
|
|
wplist.add(wp);
|
|
|
}
|
|
|
}
|
|
|
- Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap = CacheContext.pointwpmap;
|
|
|
- Map<String, ProBasicPowerstationPoint> wtpointmap = pointwpmap.get(wpId);
|
|
|
+
|
|
|
+ Map<String, ProBasicPowerstationPoint> wtpointmap = null;
|
|
|
+ Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap = CacheContext.wppointmap;
|
|
|
+ Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap1 = CacheContext.companypointmap;
|
|
|
+ Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap2 = CacheContext.regionpointmap;
|
|
|
+ Map<String, Map<String, ProBasicPowerstationPoint>> pointwpmap3 = CacheContext.grouppointmap;
|
|
|
+
|
|
|
+ if (pointwpmap.containsKey(wpId)){
|
|
|
+ wtpointmap = pointwpmap.get(wpId);
|
|
|
+ }else if (pointwpmap1.containsKey(wpId)) {
|
|
|
+ wtpointmap = pointwpmap1.get(wpId);
|
|
|
+ }else if (pointwpmap2.containsKey(wpId)){
|
|
|
+ wtpointmap = pointwpmap2.get(wpId);
|
|
|
+ }else if (pointwpmap3.containsKey(wpId)){
|
|
|
+ wtpointmap = pointwpmap3.get(wpId);
|
|
|
+ }
|
|
|
+
|
|
|
String month = wtpointmap.get(ContantXk.YFDL).getNemCode();
|
|
|
String rfdl = wtpointmap.get(ContantXk.RFDL).getNemCode();
|
|
|
|