Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

前置日志联调

Browse Source
This commit is contained in:
hzj
2025-07-04 16:21:55 +08:00
parent 764c327558
commit f6e69e13bd
3 changed files with 15 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/po/influx/DataHarmpowerP.java
View File

@@ -281,9 +281,9 @@ public class DataHarmpowerP {
influxDBDataHarmpowerP.setP50(Objects.isNull(dataHarmpowerP.getP50())?0.00:dataHarmpowerP.getP50()); influxDBDataHarmpowerP.setP50(Objects.isNull(dataHarmpowerP.getP50())?0.00:dataHarmpowerP.getP50());
} }
else if (valueType.equals("MAX")){ else if (valueType.equals("MAX")){
influxDBDataHarmpowerP.setDf(Objects.isNull(dataHarmpowerP.getDf())?0.00:dataHarmpowerP.getDf()); influxDBDataHarmpowerP.setDf(Objects.isNull(dataHarmpowerP.getDf())?0.00:dataHarmpowerP.getDfMax());
influxDBDataHarmpowerP.setPf(Objects.isNull(dataHarmpowerP.getPf())?0.00:dataHarmpowerP.getPf()); influxDBDataHarmpowerP.setPf(Objects.isNull(dataHarmpowerP.getPf())?0.00:dataHarmpowerP.getPfMax());
influxDBDataHarmpowerP.setP(Objects.isNull(dataHarmpowerP.getP())?0.00:dataHarmpowerP.getP()); influxDBDataHarmpowerP.setP(Objects.isNull(dataHarmpowerP.getP())?0.00:dataHarmpowerP.getPMax());
influxDBDataHarmpowerP.setP1(Objects.isNull(dataHarmpowerP.getP1Max())?0.00:dataHarmpowerP.getP1Max()); influxDBDataHarmpowerP.setP1(Objects.isNull(dataHarmpowerP.getP1Max())?0.00:dataHarmpowerP.getP1Max());
influxDBDataHarmpowerP.setP2(Objects.isNull(dataHarmpowerP.getP2Max())?0.00:dataHarmpowerP.getP2Max()); influxDBDataHarmpowerP.setP2(Objects.isNull(dataHarmpowerP.getP2Max())?0.00:dataHarmpowerP.getP2Max());
@@ -337,9 +337,9 @@ public class DataHarmpowerP {
influxDBDataHarmpowerP.setP50(Objects.isNull(dataHarmpowerP.getP50Max())?0.00:dataHarmpowerP.getP50Max()); influxDBDataHarmpowerP.setP50(Objects.isNull(dataHarmpowerP.getP50Max())?0.00:dataHarmpowerP.getP50Max());
} }
else if (valueType.equals("MIN")){ else if (valueType.equals("MIN")){
influxDBDataHarmpowerP.setDf(Objects.isNull(dataHarmpowerP.getDf())?0.00:dataHarmpowerP.getDf()); influxDBDataHarmpowerP.setDf(Objects.isNull(dataHarmpowerP.getDf())?0.00:dataHarmpowerP.getDfMin());
influxDBDataHarmpowerP.setPf(Objects.isNull(dataHarmpowerP.getPf())?0.00:dataHarmpowerP.getPf()); influxDBDataHarmpowerP.setPf(Objects.isNull(dataHarmpowerP.getPf())?0.00:dataHarmpowerP.getPfMin());
influxDBDataHarmpowerP.setP(Objects.isNull(dataHarmpowerP.getP())?0.00:dataHarmpowerP.getP()); influxDBDataHarmpowerP.setP(Objects.isNull(dataHarmpowerP.getP())?0.00:dataHarmpowerP.getPMin());
influxDBDataHarmpowerP.setP1(Objects.isNull(dataHarmpowerP.getP1Min())?0.00:dataHarmpowerP.getP1Min()); influxDBDataHarmpowerP.setP1(Objects.isNull(dataHarmpowerP.getP1Min())?0.00:dataHarmpowerP.getP1Min());
influxDBDataHarmpowerP.setP2(Objects.isNull(dataHarmpowerP.getP2Min())?0.00:dataHarmpowerP.getP2Min()); influxDBDataHarmpowerP.setP2(Objects.isNull(dataHarmpowerP.getP2Min())?0.00:dataHarmpowerP.getP2Min());
@@ -393,9 +393,9 @@ public class DataHarmpowerP {
influxDBDataHarmpowerP.setP50(Objects.isNull(dataHarmpowerP.getP50Min())?0.00:dataHarmpowerP.getP50Min()); influxDBDataHarmpowerP.setP50(Objects.isNull(dataHarmpowerP.getP50Min())?0.00:dataHarmpowerP.getP50Min());
} }
else if (valueType.equals("CP95")){ else if (valueType.equals("CP95")){
influxDBDataHarmpowerP.setDf(Objects.isNull(dataHarmpowerP.getDf())?0.00:dataHarmpowerP.getDf()); influxDBDataHarmpowerP.setDf(Objects.isNull(dataHarmpowerP.getDf())?0.00:dataHarmpowerP.getDfCp95());
influxDBDataHarmpowerP.setPf(Objects.isNull(dataHarmpowerP.getPf())?0.00:dataHarmpowerP.getPf()); influxDBDataHarmpowerP.setPf(Objects.isNull(dataHarmpowerP.getPf())?0.00:dataHarmpowerP.getPfCp95());
influxDBDataHarmpowerP.setP(Objects.isNull(dataHarmpowerP.getP())?0.00:dataHarmpowerP.getP()); influxDBDataHarmpowerP.setP(Objects.isNull(dataHarmpowerP.getP())?0.00:dataHarmpowerP.getPCp95());
influxDBDataHarmpowerP.setP1(Objects.isNull(dataHarmpowerP.getP1Cp95())?0.00:dataHarmpowerP.getP1Cp95()); influxDBDataHarmpowerP.setP1(Objects.isNull(dataHarmpowerP.getP1Cp95())?0.00:dataHarmpowerP.getP1Cp95());
influxDBDataHarmpowerP.setP2(Objects.isNull(dataHarmpowerP.getP2Cp95())?0.00:dataHarmpowerP.getP2Cp95()); influxDBDataHarmpowerP.setP2(Objects.isNull(dataHarmpowerP.getP2Cp95())?0.00:dataHarmpowerP.getP2Cp95());

6
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/po/influx/DataHarmpowerQ.java
View File

@@ -274,7 +274,7 @@ public class DataHarmpowerQ {
influxDBDataHarmpowerQ.setQ50(Objects.isNull(dataHarmpowerQ.getQ50())?0.00:dataHarmpowerQ.getQ50()); influxDBDataHarmpowerQ.setQ50(Objects.isNull(dataHarmpowerQ.getQ50())?0.00:dataHarmpowerQ.getQ50());
} }
else if (valueType.equals("MAX")){ else if (valueType.equals("MAX")){
influxDBDataHarmpowerQ.setQ(Objects.isNull(dataHarmpowerQ.getQ())?0.00:dataHarmpowerQ.getQ()); influxDBDataHarmpowerQ.setQ(Objects.isNull(dataHarmpowerQ.getQ())?0.00:dataHarmpowerQ.getQMax());
influxDBDataHarmpowerQ.setQ1(Objects.isNull(dataHarmpowerQ.getQ1Max())?0.00:dataHarmpowerQ.getQ1Max()); influxDBDataHarmpowerQ.setQ1(Objects.isNull(dataHarmpowerQ.getQ1Max())?0.00:dataHarmpowerQ.getQ1Max());
influxDBDataHarmpowerQ.setQ2(Objects.isNull(dataHarmpowerQ.getQ2Max())?0.00:dataHarmpowerQ.getQ2Max()); influxDBDataHarmpowerQ.setQ2(Objects.isNull(dataHarmpowerQ.getQ2Max())?0.00:dataHarmpowerQ.getQ2Max());
@@ -328,7 +328,7 @@ public class DataHarmpowerQ {
influxDBDataHarmpowerQ.setQ50(Objects.isNull(dataHarmpowerQ.getQ50Max())?0.00:dataHarmpowerQ.getQ50Max()); influxDBDataHarmpowerQ.setQ50(Objects.isNull(dataHarmpowerQ.getQ50Max())?0.00:dataHarmpowerQ.getQ50Max());
} }
else if (valueType.equals("MIN")){ else if (valueType.equals("MIN")){
influxDBDataHarmpowerQ.setQ(Objects.isNull(dataHarmpowerQ.getQ())?0.00:dataHarmpowerQ.getQ()); influxDBDataHarmpowerQ.setQ(Objects.isNull(dataHarmpowerQ.getQ())?0.00:dataHarmpowerQ.getQMin());
influxDBDataHarmpowerQ.setQ1(Objects.isNull(dataHarmpowerQ.getQ1Min())?0.00:dataHarmpowerQ.getQ1Min()); influxDBDataHarmpowerQ.setQ1(Objects.isNull(dataHarmpowerQ.getQ1Min())?0.00:dataHarmpowerQ.getQ1Min());
influxDBDataHarmpowerQ.setQ2(Objects.isNull(dataHarmpowerQ.getQ2Min())?0.00:dataHarmpowerQ.getQ2Min()); influxDBDataHarmpowerQ.setQ2(Objects.isNull(dataHarmpowerQ.getQ2Min())?0.00:dataHarmpowerQ.getQ2Min());
@@ -382,7 +382,7 @@ public class DataHarmpowerQ {
influxDBDataHarmpowerQ.setQ50(Objects.isNull(dataHarmpowerQ.getQ50Min())?0.00:dataHarmpowerQ.getQ50Min()); influxDBDataHarmpowerQ.setQ50(Objects.isNull(dataHarmpowerQ.getQ50Min())?0.00:dataHarmpowerQ.getQ50Min());
} }
else if (valueType.equals("CP95")){ else if (valueType.equals("CP95")){
influxDBDataHarmpowerQ.setQ(Objects.isNull(dataHarmpowerQ.getQ())?0.00:dataHarmpowerQ.getQ()); influxDBDataHarmpowerQ.setQ(Objects.isNull(dataHarmpowerQ.getQ())?0.00:dataHarmpowerQ.getQCp95());
influxDBDataHarmpowerQ.setQ1(Objects.isNull(dataHarmpowerQ.getQ1Cp95())?0.00:dataHarmpowerQ.getQ1Cp95()); influxDBDataHarmpowerQ.setQ1(Objects.isNull(dataHarmpowerQ.getQ1Cp95())?0.00:dataHarmpowerQ.getQ1Cp95());
influxDBDataHarmpowerQ.setQ2(Objects.isNull(dataHarmpowerQ.getQ2Cp95())?0.00:dataHarmpowerQ.getQ2Cp95()); influxDBDataHarmpowerQ.setQ2(Objects.isNull(dataHarmpowerQ.getQ2Cp95())?0.00:dataHarmpowerQ.getQ2Cp95());

6
data-processing/data-processing-api/src/main/java/com/njcn/dataProcess/po/influx/DataHarmpowerS.java
View File

@@ -272,7 +272,7 @@ public class DataHarmpowerS {
influxDBDataHarmpowerS.setS50(Objects.isNull(dataHarmpowerS.getS50())?0.00:dataHarmpowerS.getS50()); influxDBDataHarmpowerS.setS50(Objects.isNull(dataHarmpowerS.getS50())?0.00:dataHarmpowerS.getS50());
} }
else if (valueType.equals("MAX")){ else if (valueType.equals("MAX")){
influxDBDataHarmpowerS.setS(Objects.isNull(dataHarmpowerS.getS())?0.00:dataHarmpowerS.getS()); influxDBDataHarmpowerS.setS(Objects.isNull(dataHarmpowerS.getS())?0.00:dataHarmpowerS.getSMax());
influxDBDataHarmpowerS.setS1(Objects.isNull(dataHarmpowerS.getS1Max())?0.00:dataHarmpowerS.getS1Max()); influxDBDataHarmpowerS.setS1(Objects.isNull(dataHarmpowerS.getS1Max())?0.00:dataHarmpowerS.getS1Max());
influxDBDataHarmpowerS.setS2(Objects.isNull(dataHarmpowerS.getS2Max())?0.00:dataHarmpowerS.getS2Max()); influxDBDataHarmpowerS.setS2(Objects.isNull(dataHarmpowerS.getS2Max())?0.00:dataHarmpowerS.getS2Max());
@@ -326,7 +326,7 @@ public class DataHarmpowerS {
influxDBDataHarmpowerS.setS50(Objects.isNull(dataHarmpowerS.getS50Max())?0.00:dataHarmpowerS.getS50Max()); influxDBDataHarmpowerS.setS50(Objects.isNull(dataHarmpowerS.getS50Max())?0.00:dataHarmpowerS.getS50Max());
} }
else if (valueType.equals("MIN")){ else if (valueType.equals("MIN")){
influxDBDataHarmpowerS.setS(Objects.isNull(dataHarmpowerS.getS())?0.00:dataHarmpowerS.getS()); influxDBDataHarmpowerS.setS(Objects.isNull(dataHarmpowerS.getS())?0.00:dataHarmpowerS.getSMin());
influxDBDataHarmpowerS.setS1(Objects.isNull(dataHarmpowerS.getS1Min())?0.00:dataHarmpowerS.getS1Min()); influxDBDataHarmpowerS.setS1(Objects.isNull(dataHarmpowerS.getS1Min())?0.00:dataHarmpowerS.getS1Min());
influxDBDataHarmpowerS.setS2(Objects.isNull(dataHarmpowerS.getS2Min())?0.00:dataHarmpowerS.getS2Min()); influxDBDataHarmpowerS.setS2(Objects.isNull(dataHarmpowerS.getS2Min())?0.00:dataHarmpowerS.getS2Min());
@@ -380,7 +380,7 @@ public class DataHarmpowerS {
influxDBDataHarmpowerS.setS50(Objects.isNull(dataHarmpowerS.getS50Min())?0.00:dataHarmpowerS.getS50Min()); influxDBDataHarmpowerS.setS50(Objects.isNull(dataHarmpowerS.getS50Min())?0.00:dataHarmpowerS.getS50Min());
} }
else if (valueType.equals("CP95")){ else if (valueType.equals("CP95")){
influxDBDataHarmpowerS.setS(Objects.isNull(dataHarmpowerS.getS())?0.00:dataHarmpowerS.getS()); influxDBDataHarmpowerS.setS(Objects.isNull(dataHarmpowerS.getS())?0.00:dataHarmpowerS.getSCp95());
influxDBDataHarmpowerS.setS1(Objects.isNull(dataHarmpowerS.getS1Cp95())?0.00:dataHarmpowerS.getS1Cp95()); influxDBDataHarmpowerS.setS1(Objects.isNull(dataHarmpowerS.getS1Cp95())?0.00:dataHarmpowerS.getS1Cp95());
influxDBDataHarmpowerS.setS2(Objects.isNull(dataHarmpowerS.getS2Cp95())?0.00:dataHarmpowerS.getS2Cp95()); influxDBDataHarmpowerS.setS2(Objects.isNull(dataHarmpowerS.getS2Cp95())?0.00:dataHarmpowerS.getS2Cp95());