|
@@ -13,10 +13,7 @@ import com.gyee.generation.util.realtimesource.IEdosUtil;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.Date;
|
|
|
-import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
+import java.util.*;
|
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
import java.util.stream.Collectors;
|
|
@@ -90,7 +87,7 @@ public class RegionCalreService {
|
|
|
zsspjfsPoint = powerstationPointMap.get(ContantXk.SSPJFS);
|
|
|
zsspjgzdPoint = powerstationPointMap.get(ContantXk.SSPJGZD);
|
|
|
}
|
|
|
-
|
|
|
+ ProBasicPowerstationPoint zaqtsPoint = powerstationPointMap.get(ContantXk.AQTS);
|
|
|
ProBasicPowerstationPoint zsszglPoint = powerstationPointMap.get(ContantXk.SSZGL);
|
|
|
ProBasicPowerstationPoint zsszllglPoint = powerstationPointMap.get(ContantXk.SSZLLGL);
|
|
|
ProBasicPowerstationPoint zsszbzglPoint = powerstationPointMap.get(ContantXk.SSZBZGL);
|
|
@@ -156,6 +153,8 @@ public class RegionCalreService {
|
|
|
AtomicInteger gcComCount = new AtomicInteger();
|
|
|
AtomicInteger finalGcComCount = gcComCount;
|
|
|
AtomicInteger finalFcComCount = fcComCount;
|
|
|
+
|
|
|
+ List<Double> aqtsList = new ArrayList<>();
|
|
|
companys.stream().forEach(company->{
|
|
|
if (company.getJrCapacity()>0){
|
|
|
finalGcComCount.getAndIncrement();
|
|
@@ -179,6 +178,8 @@ public class RegionCalreService {
|
|
|
sspjgzdPoint = powerstationPointMap1.get(ContantXk.SSPJGZD);
|
|
|
|
|
|
}
|
|
|
+
|
|
|
+ ProBasicPowerstationPoint aqtsPoint = powerstationPointMap1.get(ContantXk.AQTS);
|
|
|
ProBasicPowerstationPoint sszglPoint = powerstationPointMap1.get(ContantXk.SSZGL);
|
|
|
ProBasicPowerstationPoint sszllglPoint = powerstationPointMap1.get(ContantXk.SSZLLGL);
|
|
|
ProBasicPowerstationPoint sszbzglPoint = powerstationPointMap1.get(ContantXk.SSZBZGL);
|
|
@@ -209,11 +210,18 @@ public class RegionCalreService {
|
|
|
ProBasicPowerstationPoint sltsPoint = powerstationPointMap1.get(ContantXk.SLTS);
|
|
|
ProBasicPowerstationPoint lxtsPoint = powerstationPointMap1.get(ContantXk.TXZDTS);
|
|
|
|
|
|
+ try {
|
|
|
+ double temp = edosUtil.getSectionData(aqtsPoint, currentDate.getTime()).getPointValueInDouble();
|
|
|
+ aqtsList.add(temp);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+
|
|
|
if (type.equals("-1")){
|
|
|
ProBasicPowerstationPoint finalSspjfsfsPoint = sspjfsPoint;
|
|
|
sspjfs.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(finalSspjfsfsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(finalSspjfsfsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -225,7 +233,7 @@ public class RegionCalreService {
|
|
|
ProBasicPowerstationPoint finalSspjgzdPoint = sspjgzdPoint;
|
|
|
sspjgzd.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(finalSspjgzdPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(finalSspjgzdPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -236,7 +244,7 @@ public class RegionCalreService {
|
|
|
ProBasicPowerstationPoint finalSspjfsfsPoint = sspjfsPoint;
|
|
|
sspjfs.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(finalSspjfsfsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(finalSspjfsfsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -245,7 +253,7 @@ public class RegionCalreService {
|
|
|
ProBasicPowerstationPoint finalSspjgzdPoint = sspjgzdPoint;
|
|
|
sspjgzd.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(finalSspjgzdPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(finalSspjgzdPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -254,7 +262,7 @@ public class RegionCalreService {
|
|
|
}
|
|
|
sszgl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -262,7 +270,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zllgl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszllglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszllglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -270,7 +278,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zbzgl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszbzglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszbzglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -278,7 +286,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
znhglzs.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(ssznhglzsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(ssznhglzsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -286,7 +294,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zzygl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszzyglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszzyglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -294,7 +302,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zkygl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszkyglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszkyglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -302,7 +310,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zycgl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszycglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszycglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -313,7 +321,7 @@ public class RegionCalreService {
|
|
|
|
|
|
gztsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(gztsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(gztsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -321,7 +329,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
cngzmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(cnslmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(cnslmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -329,7 +337,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
jxtsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(jxtsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(jxtsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -337,7 +345,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
cnjxmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(cnjxmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(cnjxmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -345,7 +353,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
djtsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(djtsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(djtsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -353,7 +361,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
qxjclmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(qxjclmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(qxjclmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -361,7 +369,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
sdtjmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sdtjmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sdtjmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -369,7 +377,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
xntsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(xntsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(xntsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -377,7 +385,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
xdtjmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(xdtjmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(xdtjmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -385,7 +393,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
xdjclmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(xdjclmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(xdjclmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -393,7 +401,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
cwsldwmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(cwsldwmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(cwsldwmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -401,7 +409,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
cwsltqmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(cwsltqmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(cwsltqmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -409,7 +417,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
lxtsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(lxtsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(lxtsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -417,7 +425,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
txzdmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(txzdmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(txzdmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -425,7 +433,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
djts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(djtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(djtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -433,7 +441,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
yxts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(yxtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(yxtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -441,7 +449,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
gzts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(gztsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(gztsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -449,7 +457,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
whts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(whtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(whtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -457,7 +465,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
xdts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(xdtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(xdtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -465,7 +473,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
slts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sltsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sltsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -473,7 +481,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
lxts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(lxtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(lxtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -498,6 +506,9 @@ public class RegionCalreService {
|
|
|
resultList.add(PointUtil.createPointData(currentDate,sspjfs.get()/fcComCount.doubleValue(),zsspjfsPoint.getNemCode(),zsspjfsPoint.getName()));
|
|
|
resultList.add(PointUtil.createPointData(currentDate,sspjgzd.get()/gcComCount.doubleValue(),zsspjgzdPoint.getNemCode(),zsspjgzdPoint.getName()));
|
|
|
}
|
|
|
+ Double aqts = Collections.max(aqtsList);
|
|
|
+
|
|
|
+ resultList.add(PointUtil.createPointData(currentDate,aqts,zaqtsPoint.getNemCode(),zaqtsPoint.getName()));
|
|
|
resultList.add(PointUtil.createPointData(currentDate,sszgl.get(),zsszglPoint.getNemCode(),zsszglPoint.getName()));
|
|
|
resultList.add(PointUtil.createPointData(currentDate,zllgl.get(),zsszllglPoint.getNemCode(),zsszllglPoint.getName()));
|
|
|
resultList.add(PointUtil.createPointData(currentDate,zbzgl.get(),zsszbzglPoint.getNemCode(),zsszbzglPoint.getName()));
|
|
@@ -550,6 +561,8 @@ public class RegionCalreService {
|
|
|
zsspjgzdPoint = powerstationPointMap.get(ContantXk.SSPJGZD);
|
|
|
}
|
|
|
|
|
|
+ ProBasicPowerstationPoint zaqtsPoint = powerstationPointMap.get(ContantXk.AQTS);
|
|
|
+
|
|
|
ProBasicPowerstationPoint zsszglPoint = powerstationPointMap.get(ContantXk.SSZGL);
|
|
|
ProBasicPowerstationPoint zsszllglPoint = powerstationPointMap.get(ContantXk.SSZLLGL);
|
|
|
ProBasicPowerstationPoint zsszbzglPoint = powerstationPointMap.get(ContantXk.SSZBZGL);
|
|
@@ -611,8 +624,10 @@ public class RegionCalreService {
|
|
|
AtomicReference<Double> slts = new AtomicReference<>((double) 0);
|
|
|
AtomicReference<Double> djts = new AtomicReference<>((double) 0);
|
|
|
|
|
|
-
|
|
|
+ List<Double> aqtsList = new ArrayList<>();
|
|
|
wps.stream().forEach(wp->{
|
|
|
+
|
|
|
+
|
|
|
Map<String, ProBasicPowerstationPoint> powerstationPointMap1 = wppointmap.get(wp.getId());
|
|
|
|
|
|
ProBasicPowerstationPoint sspjfsPoint = null;
|
|
@@ -625,6 +640,7 @@ public class RegionCalreService {
|
|
|
sspjgzdPoint = powerstationPointMap1.get(ContantXk.SSPJGZD);
|
|
|
|
|
|
}
|
|
|
+ ProBasicPowerstationPoint aqtsPoint = powerstationPointMap1.get(ContantXk.AQTS);
|
|
|
|
|
|
ProBasicPowerstationPoint sszglPoint = powerstationPointMap1.get(ContantXk.SSZGL);
|
|
|
ProBasicPowerstationPoint sszllglPoint = powerstationPointMap1.get(ContantXk.SSZLLGL);
|
|
@@ -656,11 +672,19 @@ public class RegionCalreService {
|
|
|
ProBasicPowerstationPoint sltsPoint = powerstationPointMap1.get(ContantXk.SLTS);
|
|
|
ProBasicPowerstationPoint lxtsPoint = powerstationPointMap1.get(ContantXk.TXZDTS);
|
|
|
|
|
|
+
|
|
|
+ try {
|
|
|
+ double temp = edosUtil.getSectionData(aqtsPoint, currentDate.getTime()).getPointValueInDouble();
|
|
|
+ aqtsList.add(temp);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+
|
|
|
if (wp.getId().contains("_FDC_")){
|
|
|
ProBasicPowerstationPoint finalSspjfsPoint = sspjfsPoint;
|
|
|
sspjfs.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(finalSspjfsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(finalSspjfsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -671,7 +695,7 @@ public class RegionCalreService {
|
|
|
ProBasicPowerstationPoint finalSspjgzdPoint = sspjgzdPoint;
|
|
|
sspjgzd.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(finalSspjgzdPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(finalSspjgzdPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -680,7 +704,7 @@ public class RegionCalreService {
|
|
|
}
|
|
|
sszgl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -688,7 +712,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zllgl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszllglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszllglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -696,7 +720,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zbzgl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszbzglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszbzglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -704,7 +728,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
znhglzs.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(ssznhglzsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(ssznhglzsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -712,7 +736,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zzygl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszzyglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszzyglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -720,7 +744,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zkygl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszkyglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszkyglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -728,7 +752,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
zycgl.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sszycglPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sszycglPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -740,7 +764,7 @@ public class RegionCalreService {
|
|
|
|
|
|
gztsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(gztsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(gztsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -748,7 +772,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
cngzmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(cnslmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(cnslmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -756,7 +780,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
jxtsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(jxtsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(jxtsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -764,7 +788,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
cnjxmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(cnjxmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(cnjxmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -772,7 +796,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
djtsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(djtsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(djtsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -780,7 +804,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
qxjclmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(qxjclmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(qxjclmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -788,7 +812,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
sdtjmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sdtjmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sdtjmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -796,7 +820,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
xntsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(xntsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(xntsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -804,7 +828,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
xdtjmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(xdtjmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(xdtjmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -812,7 +836,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
xdjclmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(xdjclmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(xdjclmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -820,7 +844,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
cwsldwmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(cwsldwmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(cwsldwmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -828,7 +852,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
cwsltqmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(cwsltqmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(cwsltqmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -836,7 +860,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
lxtsmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(lxtsmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(lxtsmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -844,7 +868,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
txzdmx.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(txzdmxPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(txzdmxPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -852,7 +876,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
djts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(djtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(djtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -860,7 +884,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
yxts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(yxtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(yxtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -868,7 +892,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
gzts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(gztsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(gztsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -876,7 +900,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
whts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(whtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(whtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -884,7 +908,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
xdts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(xdtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(xdtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -892,7 +916,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
slts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(sltsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(sltsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -900,7 +924,7 @@ public class RegionCalreService {
|
|
|
});
|
|
|
lxts.updateAndGet(v -> {
|
|
|
try {
|
|
|
- return new Double((double) (v + edosUtil.getSectionData(lxtsPoint, currentDate.getTime() / 1000).getPointValueInDouble()));
|
|
|
+ return new Double((double) (v + edosUtil.getSectionData(lxtsPoint, currentDate.getTime()).getPointValueInDouble()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -917,6 +941,9 @@ public class RegionCalreService {
|
|
|
resultList.add(PointUtil.createPointData(currentDate,sspjfs.get()/fdcsize,zsspjfsPoint.getNemCode(),zsspjfsPoint.getName()));
|
|
|
resultList.add(PointUtil.createPointData(currentDate,sspjgzd.get()/gdcsize,zsspjgzdPoint.getNemCode(),zsspjgzdPoint.getName()));
|
|
|
}
|
|
|
+
|
|
|
+ Double aqts = Collections.max(aqtsList);
|
|
|
+ resultList.add(PointUtil.createPointData(currentDate,aqts,zaqtsPoint.getNemCode(),zaqtsPoint.getName()));
|
|
|
resultList.add(PointUtil.createPointData(currentDate,sszgl.get(),zsszglPoint.getNemCode(),zsszglPoint.getName()));
|
|
|
resultList.add(PointUtil.createPointData(currentDate,zllgl.get(),zsszllglPoint.getNemCode(),zsszllglPoint.getName()));
|
|
|
resultList.add(PointUtil.createPointData(currentDate,zbzgl.get(),zsszbzglPoint.getNemCode(),zsszbzglPoint.getName()));
|