Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

zbj//1.r_stat_substation_d/m/q/y 调度

Browse Source
This commit is contained in:
zhangbaojian
2023-07-04 11:30:13 +08:00
parent 709109ca23
commit c9dbe3f861
1 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationServiceImpl.java
View File

@@ -779,7 +779,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationQPO.setEventCount(eventDetailSumAndCountM.containsKey("eventCountSum") ? rStatSubstationQPO.setEventCount(eventDetailSumAndCountM.containsKey("eventCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("eventCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("eventCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("eventMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("eventMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("eventCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("eventCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("eventMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("eventMeasurementCountSum").toString()));
rStatSubstationQPO.setEventFreq(Float.parseFloat(value)); rStatSubstationQPO.setEventFreq(Float.parseFloat(value));
@@ -790,7 +790,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationQPO.setSagCount(eventDetailSumAndCountM.containsKey("sagCountSum") ? rStatSubstationQPO.setSagCount(eventDetailSumAndCountM.containsKey("sagCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("sagCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("sagCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("sagMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("sagMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("sagCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("sagCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("sagMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("sagMeasurementCountSum").toString()));
rStatSubstationQPO.setSagFreq(Float.parseFloat(value)); rStatSubstationQPO.setSagFreq(Float.parseFloat(value));
@@ -801,7 +801,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationQPO.setSwellCount(eventDetailSumAndCountM.containsKey("swellCountSum") ? rStatSubstationQPO.setSwellCount(eventDetailSumAndCountM.containsKey("swellCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("swellCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("swellCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("swellMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("swellMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("swellCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("swellCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("swellMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("swellMeasurementCountSum").toString()));
rStatSubstationQPO.setSwellFreq(Float.parseFloat(value)); rStatSubstationQPO.setSwellFreq(Float.parseFloat(value));
@@ -812,7 +812,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationQPO.setInterruptCount(eventDetailSumAndCountM.containsKey("interruptCountSum") ? rStatSubstationQPO.setInterruptCount(eventDetailSumAndCountM.containsKey("interruptCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("interruptCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("interruptCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("interruptMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("interruptCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("interruptCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString()));
rStatSubstationQPO.setInterruptFreq(Float.parseFloat(value)); rStatSubstationQPO.setInterruptFreq(Float.parseFloat(value));
@@ -906,7 +906,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationQPO.setEventCount(eventDetailSumAndCountM.containsKey("eventCountSum") ? rStatSubstationQPO.setEventCount(eventDetailSumAndCountM.containsKey("eventCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("eventCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("eventCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("eventMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("eventMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("eventCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("eventCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("eventMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("eventMeasurementCountSum").toString()));
rStatSubstationQPO.setEventFreq(Float.parseFloat(value)); rStatSubstationQPO.setEventFreq(Float.parseFloat(value));
@@ -917,7 +917,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationQPO.setSagCount(eventDetailSumAndCountM.containsKey("sagCountSum") ? rStatSubstationQPO.setSagCount(eventDetailSumAndCountM.containsKey("sagCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("sagCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("sagCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("sagMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("sagMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("sagCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("sagCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("sagMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("sagMeasurementCountSum").toString()));
rStatSubstationQPO.setSagFreq(Float.parseFloat(value)); rStatSubstationQPO.setSagFreq(Float.parseFloat(value));
@@ -928,7 +928,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationQPO.setSwellCount(eventDetailSumAndCountM.containsKey("swellCountSum") ? rStatSubstationQPO.setSwellCount(eventDetailSumAndCountM.containsKey("swellCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("swellCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("swellCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("swellMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("swellMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("swellCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("swellCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("swellMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("swellMeasurementCountSum").toString()));
rStatSubstationQPO.setSwellFreq(Float.parseFloat(value)); rStatSubstationQPO.setSwellFreq(Float.parseFloat(value));
@@ -939,7 +939,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationQPO.setInterruptCount(eventDetailSumAndCountM.containsKey("interruptCountSum") ? rStatSubstationQPO.setInterruptCount(eventDetailSumAndCountM.containsKey("interruptCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("interruptCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("interruptCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("interruptMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("interruptCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("interruptCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString()));
rStatSubstationQPO.setInterruptFreq(Float.parseFloat(value)); rStatSubstationQPO.setInterruptFreq(Float.parseFloat(value));
@@ -1071,7 +1071,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationYPO.setEventCount(eventDetailSumAndCountM.containsKey("eventCountSum") ? rStatSubstationYPO.setEventCount(eventDetailSumAndCountM.containsKey("eventCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("eventCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("eventCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("eventMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("eventMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("eventCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("eventCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("eventMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("eventMeasurementCountSum").toString()));
rStatSubstationYPO.setEventFreq(Float.parseFloat(value)); rStatSubstationYPO.setEventFreq(Float.parseFloat(value));
@@ -1082,7 +1082,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationYPO.setSagCount(eventDetailSumAndCountM.containsKey("sagCountSum") ? rStatSubstationYPO.setSagCount(eventDetailSumAndCountM.containsKey("sagCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("sagCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("sagCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("sagMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("sagMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("sagCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("sagCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("sagMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("sagMeasurementCountSum").toString()));
rStatSubstationYPO.setSagFreq(Float.parseFloat(value)); rStatSubstationYPO.setSagFreq(Float.parseFloat(value));
@@ -1093,7 +1093,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationYPO.setSwellCount(eventDetailSumAndCountM.containsKey("swellCountSum") ? rStatSubstationYPO.setSwellCount(eventDetailSumAndCountM.containsKey("swellCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("swellCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("swellCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("swellMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("swellMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("swellCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("swellCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("swellMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("swellMeasurementCountSum").toString()));
rStatSubstationYPO.setSwellFreq(Float.parseFloat(value)); rStatSubstationYPO.setSwellFreq(Float.parseFloat(value));
@@ -1104,7 +1104,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationYPO.setInterruptCount(eventDetailSumAndCountM.containsKey("interruptCountSum") ? rStatSubstationYPO.setInterruptCount(eventDetailSumAndCountM.containsKey("interruptCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("interruptCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("interruptCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("interruptMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("interruptCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("interruptCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString()));
rStatSubstationYPO.setInterruptFreq(Float.parseFloat(value)); rStatSubstationYPO.setInterruptFreq(Float.parseFloat(value));
@@ -1198,7 +1198,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationYPO.setEventCount(eventDetailSumAndCountM.containsKey("eventCountSum") ? rStatSubstationYPO.setEventCount(eventDetailSumAndCountM.containsKey("eventCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("eventCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("eventCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("eventMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("eventMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("eventCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("eventCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("eventMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("eventMeasurementCountSum").toString()));
rStatSubstationYPO.setEventFreq(Float.parseFloat(value)); rStatSubstationYPO.setEventFreq(Float.parseFloat(value));
@@ -1209,7 +1209,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationYPO.setSagCount(eventDetailSumAndCountM.containsKey("sagCountSum") ? rStatSubstationYPO.setSagCount(eventDetailSumAndCountM.containsKey("sagCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("sagCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("sagCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("sagMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("sagMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("sagCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("sagCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("sagMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("sagMeasurementCountSum").toString()));
rStatSubstationYPO.setSagFreq(Float.parseFloat(value)); rStatSubstationYPO.setSagFreq(Float.parseFloat(value));
@@ -1220,7 +1220,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationYPO.setSwellCount(eventDetailSumAndCountM.containsKey("swellCountSum") ? rStatSubstationYPO.setSwellCount(eventDetailSumAndCountM.containsKey("swellCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("swellCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("swellCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("swellMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("swellMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("swellCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("swellCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("swellMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("swellMeasurementCountSum").toString()));
rStatSubstationYPO.setSwellFreq(Float.parseFloat(value)); rStatSubstationYPO.setSwellFreq(Float.parseFloat(value));
@@ -1231,7 +1231,7 @@ public class RStatSubstationServiceImpl implements RStatSubstationService {
rStatSubstationYPO.setInterruptCount(eventDetailSumAndCountM.containsKey("interruptCountSum") ? rStatSubstationYPO.setInterruptCount(eventDetailSumAndCountM.containsKey("interruptCountSum") ?
Integer.parseInt(eventDetailSumAndCountM.get("interruptCountSum").toString()) : 0); Integer.parseInt(eventDetailSumAndCountM.get("interruptCountSum").toString()) : 0);
if (!Objects.equals(0, eventDetailSumAndCountD.get("interruptMeasurementCountSum"))) { if (!Objects.equals("0", eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString())) {
String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("interruptCountSum").toString()) String value = df.format(Float.parseFloat(eventDetailSumAndCountM.get("interruptCountSum").toString())
/ Float.parseFloat(eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString())); / Float.parseFloat(eventDetailSumAndCountD.get("interruptMeasurementCountSum").toString()));
rStatSubstationYPO.setInterruptFreq(Float.parseFloat(value)); rStatSubstationYPO.setInterruptFreq(Float.parseFloat(value));