diff --git a/pqs-prepare/harmonic-prepare/pom.xml b/pqs-prepare/harmonic-prepare/pom.xml
index df35fad3a..2329377ca 100644
--- a/pqs-prepare/harmonic-prepare/pom.xml
+++ b/pqs-prepare/harmonic-prepare/pom.xml
@@ -14,8 +14,8 @@
8
8
- 1.18.6
- 1.3.0.Final
+ 1.18.12
+ 1.4.2.Final
@@ -82,7 +82,7 @@
org.mapstruct
- mapstruct-jdk8
+ mapstruct
${org.mapstruct.version}
@@ -91,6 +91,11 @@
mapstruct-processor
${org.mapstruct.version}
+
+ org.projectlombok
+ lombok-mapstruct-binding
+ 0.2.0
+
@@ -106,6 +111,31 @@
${project.version}
+
+
+ me.tongfei
+ progressbar
+ 0.5.3
+
+
+
+ com.squareup.okhttp3
+ okhttp
+ 4.8.1
+
+
+
+ io.minio
+ minio
+ 8.2.1
+
+
+ com.squareup.okhttp3
+ okhttp
+
+
+
+
com.njcn
prepare-api
@@ -116,16 +146,20 @@
com.baomidou
dynamic-datasource-spring-boot-starter
+ 3.5.1
+
com.oracle.database.jdbc
ojdbc8
+ 21.6.0.0
com.oracle.database.nls
orai18n
+ 21.1.0.0
@@ -160,7 +194,7 @@
build-image
- ${docker.operate}
+ site
build
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/AlgorithmParam.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/AlgorithmParam.java
new file mode 100644
index 000000000..12d317785
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/AlgorithmParam.java
@@ -0,0 +1,46 @@
+package com.njcn.prepare.harmonic.constant;
+
+
+/**
+ * @author qijian
+ */
+public interface AlgorithmParam {
+
+ /**
+ * 暂态/稳态
+ */
+ Integer TEMPORARY_STATE = 0;
+ Integer STEADY_STATE = 1;
+
+ /**
+ * 主网/配网
+ */
+ Integer MAIN_NET = 1;
+ Integer DIS_NET = 2;
+
+ /**
+ * 数据来源:Oracle/InfluxDB
+ */
+ Integer ORACLE_DATA = 0;
+ Integer INFLUX_DATA = 1;
+
+
+ /**
+ * 监测点数据完整率 统计间隔
+ */
+ Integer TIME_INTERVAL = 15;
+
+ /*
+ * 监测点暂态指标超标事件类型
+ * 0:扰动,1:暂降,2:暂升,3:中断,4:其他,5:录波
+ */
+ Integer DISTURBANCE= 0;
+ Integer SAG= 1;
+ Integer RISE= 2;
+ Integer INTERRUPT= 3;
+ Integer other= 4;
+ Integer RECORDING_WAVE= 5;
+
+
+
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/DictCache.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/DictCache.java
new file mode 100644
index 000000000..2de68d1b1
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/DictCache.java
@@ -0,0 +1,77 @@
+package com.njcn.prepare.harmonic.constant;
+
+import com.njcn.redis.utils.RedisUtil;
+import com.njcn.system.api.DicDataFeignClient;
+import com.njcn.system.enums.DicDataTypeEnum;
+import com.njcn.system.pojo.po.DictData;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
+import java.util.List;
+import java.util.Set;
+
+/**
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/25 16:21【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+
+@Component
+@Slf4j
+public class DictCache {
+
+ public static final String NAME_KEY = "DicCache:";
+ public static final String SPLIT_SIGN = "-";
+
+ private @Autowired
+ DicDataFeignClient dicDataFeignClient;
+
+ private @Autowired
+ RedisUtil redisUtil;
+ private @Autowired
+ RedisTemplate redisTemplate;
+
+ @PostConstruct
+ public void init(){
+ log.info("系统启动中。。。加载dictDataMap");
+ /*todo 后续将字典表全部加载*/
+ List data = dicDataFeignClient.getDicDataByTypeCode (DicDataTypeEnum.LINE_STATE.getCode ( )).getData ( );
+ List data2 = dicDataFeignClient.getDicDataByTypeCode (DicDataTypeEnum.DEV_STATUS.getCode ( )).getData ( );
+ List data3 = dicDataFeignClient.getDicDataByTypeCode (DicDataTypeEnum.LINE_SORT.getCode ( )).getData ( );
+
+ /*
+ * key:NAME_KEY前缀(清缓存使用)+SPLIT_SIGN(拼接符号)+DicDataTypeEnum+SPLIT_SIGN(拼接符号)+Code
+ * Value:id
+ * */
+ data.forEach (temp->{
+ redisUtil.saveByKey (NAME_KEY+SPLIT_SIGN+DicDataTypeEnum.LINE_STATE.getCode ( )+SPLIT_SIGN+temp.getCode (),temp.getId ());
+ });
+
+ data2.forEach (temp->{
+ redisUtil.saveByKey (NAME_KEY+SPLIT_SIGN+DicDataTypeEnum.DEV_STATUS.getCode ( )+SPLIT_SIGN+temp.getCode (),temp.getId ());
+ });
+
+ data3.forEach (temp->{
+ redisUtil.saveByKey (NAME_KEY+SPLIT_SIGN+DicDataTypeEnum.LINE_SORT.getCode ( )+SPLIT_SIGN+temp.getCode (),temp.getId ());
+ });
+
+
+ }
+
+ @PreDestroy
+ public void destroy(){
+ log.info("系统运行结束");
+ Set keys = redisTemplate.keys(NAME_KEY + "*");
+
+ redisTemplate.delete(keys);
+
+ }
+
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/InfluxdbPOConverter.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/InfluxdbPOConverter.java
index 80ca65c9a..8d48987af 100644
--- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/InfluxdbPOConverter.java
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/InfluxdbPOConverter.java
@@ -24,215 +24,215 @@ public interface InfluxdbPOConverter {
InfluxdbPOConverter INFLUXDB_PO_CONVERTER = Mappers.getMapper (InfluxdbPOConverter.class);
/*DataHarmRateVPO*/
- @Mapping(source = "v1", target = "fundamentalVoltageMax")
- @Mapping(source = "v2", target = "harmonicVoltageContent2Max")
- @Mapping(source = "v3", target = "harmonicVoltageContent3Max")
- @Mapping(source = "v4", target = "harmonicVoltageContent4Max")
- @Mapping(source = "v5", target = "harmonicVoltageContent5Max")
- @Mapping(source = "v6", target = "harmonicVoltageContent6Max")
- @Mapping(source = "v7", target = "harmonicVoltageContent7Max")
- @Mapping(source = "v8", target = "harmonicVoltageContent8Max")
- @Mapping(source = "v9", target = "harmonicVoltageContent9Max")
- @Mapping(source = "v10", target = "harmonicVoltageContent10Max")
- @Mapping(source = "v11", target = "harmonicVoltageContent11Max")
- @Mapping(source = "v12", target = "harmonicVoltageContent12Max")
- @Mapping(source = "v13", target = "harmonicVoltageContent13Max")
- @Mapping(source = "v14", target = "harmonicVoltageContent14Max")
- @Mapping(source = "v15", target = "harmonicVoltageContent15Max")
- @Mapping(source = "v16", target = "harmonicVoltageContent16Max")
- @Mapping(source = "v17", target = "harmonicVoltageContent17Max")
- @Mapping(source = "v18", target = "harmonicVoltageContent18Max")
- @Mapping(source = "v19", target = "harmonicVoltageContent19Max")
- @Mapping(source = "v20", target = "harmonicVoltageContent20Max")
- @Mapping(source = "v21", target = "harmonicVoltageContent21Max")
- @Mapping(source = "v22", target = "harmonicVoltageContent22Max")
- @Mapping(source = "v23", target = "harmonicVoltageContent23Max")
- @Mapping(source = "v24", target = "harmonicVoltageContent24Max")
- @Mapping(source = "v25", target = "harmonicVoltageContent25Max")
- @Mapping(source = "v26", target = "harmonicVoltageContent26Max")
- @Mapping(source = "v27", target = "harmonicVoltageContent27Max")
- @Mapping(source = "v28", target = "harmonicVoltageContent28Max")
- @Mapping(source = "v29", target = "harmonicVoltageContent29Max")
- @Mapping(source = "v30", target = "harmonicVoltageContent30Max")
- @Mapping(source = "v31", target = "harmonicVoltageContent31Max")
- @Mapping(source = "v32", target = "harmonicVoltageContent32Max")
- @Mapping(source = "v33", target = "harmonicVoltageContent33Max")
- @Mapping(source = "v34", target = "harmonicVoltageContent34Max")
- @Mapping(source = "v35", target = "harmonicVoltageContent35Max")
- @Mapping(source = "v36", target = "harmonicVoltageContent36Max")
- @Mapping(source = "v37", target = "harmonicVoltageContent37Max")
- @Mapping(source = "v38", target = "harmonicVoltageContent38Max")
- @Mapping(source = "v39", target = "harmonicVoltageContent39Max")
- @Mapping(source = "v40", target = "harmonicVoltageContent40Max")
- @Mapping(source = "v41", target = "harmonicVoltageContent41Max")
- @Mapping(source = "v42", target = "harmonicVoltageContent42Max")
- @Mapping(source = "v43", target = "harmonicVoltageContent43Max")
- @Mapping(source = "v44", target = "harmonicVoltageContent44Max")
- @Mapping(source = "v45", target = "harmonicVoltageContent45Max")
- @Mapping(source = "v46", target = "harmonicVoltageContent46Max")
- @Mapping(source = "v47", target = "harmonicVoltageContent47Max")
- @Mapping(source = "v48", target = "harmonicVoltageContent48Max")
- @Mapping(source = "v49", target = "harmonicVoltageContent49Max")
- @Mapping(source = "v50", target = "harmonicVoltageContent50Max")
+ @Mapping(source = "v1", target = "fundamentalVoltageMax" ,numberFormat = "#.000")
+ @Mapping(source = "v2", target = "harmonicVoltageContent2Max" ,numberFormat = "#.000")
+ @Mapping(source = "v3", target = "harmonicVoltageContent3Max" ,numberFormat = "#.000")
+ @Mapping(source = "v4", target = "harmonicVoltageContent4Max" ,numberFormat = "#.000")
+ @Mapping(source = "v5", target = "harmonicVoltageContent5Max" ,numberFormat = "#.000")
+ @Mapping(source = "v6", target = "harmonicVoltageContent6Max" ,numberFormat = "#.000")
+ @Mapping(source = "v7", target = "harmonicVoltageContent7Max" ,numberFormat = "#.000")
+ @Mapping(source = "v8", target = "harmonicVoltageContent8Max" ,numberFormat = "#.000")
+ @Mapping(source = "v9", target = "harmonicVoltageContent9Max" ,numberFormat = "#.000")
+ @Mapping(source = "v10", target = "harmonicVoltageContent10Max" ,numberFormat = "#.000")
+ @Mapping(source = "v11", target = "harmonicVoltageContent11Max" ,numberFormat = "#.000")
+ @Mapping(source = "v12", target = "harmonicVoltageContent12Max" ,numberFormat = "#.000")
+ @Mapping(source = "v13", target = "harmonicVoltageContent13Max" ,numberFormat = "#.000")
+ @Mapping(source = "v14", target = "harmonicVoltageContent14Max" ,numberFormat = "#.000")
+ @Mapping(source = "v15", target = "harmonicVoltageContent15Max" ,numberFormat = "#.000")
+ @Mapping(source = "v16", target = "harmonicVoltageContent16Max" ,numberFormat = "#.000")
+ @Mapping(source = "v17", target = "harmonicVoltageContent17Max" ,numberFormat = "#.000")
+ @Mapping(source = "v18", target = "harmonicVoltageContent18Max" ,numberFormat = "#.000")
+ @Mapping(source = "v19", target = "harmonicVoltageContent19Max" ,numberFormat = "#.000")
+ @Mapping(source = "v20", target = "harmonicVoltageContent20Max" ,numberFormat = "#.000")
+ @Mapping(source = "v21", target = "harmonicVoltageContent21Max" ,numberFormat = "#.000")
+ @Mapping(source = "v22", target = "harmonicVoltageContent22Max" ,numberFormat = "#.000")
+ @Mapping(source = "v23", target = "harmonicVoltageContent23Max" ,numberFormat = "#.000")
+ @Mapping(source = "v24", target = "harmonicVoltageContent24Max" ,numberFormat = "#.000")
+ @Mapping(source = "v25", target = "harmonicVoltageContent25Max" ,numberFormat = "#.000")
+ @Mapping(source = "v26", target = "harmonicVoltageContent26Max" ,numberFormat = "#.000")
+ @Mapping(source = "v27", target = "harmonicVoltageContent27Max" ,numberFormat = "#.000")
+ @Mapping(source = "v28", target = "harmonicVoltageContent28Max" ,numberFormat = "#.000")
+ @Mapping(source = "v29", target = "harmonicVoltageContent29Max" ,numberFormat = "#.000")
+ @Mapping(source = "v30", target = "harmonicVoltageContent30Max" ,numberFormat = "#.000")
+ @Mapping(source = "v31", target = "harmonicVoltageContent31Max" ,numberFormat = "#.000")
+ @Mapping(source = "v32", target = "harmonicVoltageContent32Max" ,numberFormat = "#.000")
+ @Mapping(source = "v33", target = "harmonicVoltageContent33Max" ,numberFormat = "#.000")
+ @Mapping(source = "v34", target = "harmonicVoltageContent34Max" ,numberFormat = "#.000")
+ @Mapping(source = "v35", target = "harmonicVoltageContent35Max" ,numberFormat = "#.000")
+ @Mapping(source = "v36", target = "harmonicVoltageContent36Max" ,numberFormat = "#.000")
+ @Mapping(source = "v37", target = "harmonicVoltageContent37Max" ,numberFormat = "#.000")
+ @Mapping(source = "v38", target = "harmonicVoltageContent38Max" ,numberFormat = "#.000")
+ @Mapping(source = "v39", target = "harmonicVoltageContent39Max" ,numberFormat = "#.000")
+ @Mapping(source = "v40", target = "harmonicVoltageContent40Max" ,numberFormat = "#.000")
+ @Mapping(source = "v41", target = "harmonicVoltageContent41Max" ,numberFormat = "#.000")
+ @Mapping(source = "v42", target = "harmonicVoltageContent42Max" ,numberFormat = "#.000")
+ @Mapping(source = "v43", target = "harmonicVoltageContent43Max" ,numberFormat = "#.000")
+ @Mapping(source = "v44", target = "harmonicVoltageContent44Max" ,numberFormat = "#.000")
+ @Mapping(source = "v45", target = "harmonicVoltageContent45Max" ,numberFormat = "#.000")
+ @Mapping(source = "v46", target = "harmonicVoltageContent46Max" ,numberFormat = "#.000")
+ @Mapping(source = "v47", target = "harmonicVoltageContent47Max" ,numberFormat = "#.000")
+ @Mapping(source = "v48", target = "harmonicVoltageContent48Max" ,numberFormat = "#.000")
+ @Mapping(source = "v49", target = "harmonicVoltageContent49Max" ,numberFormat = "#.000")
+ @Mapping(source = "v50", target = "harmonicVoltageContent50Max" ,numberFormat = "#.000")
public RMpHarmonicVRateReportD dataVPOTORMpHarmonicPReportDPOMax(DataHarmRateVPO dataVPO);
- @Mapping(source = "v1", target = "fundamentalVoltageMin")
- @Mapping(source = "v2", target = "harmonicVoltageContent2Min")
- @Mapping(source = "v3", target = "harmonicVoltageContent3Min")
- @Mapping(source = "v4", target = "harmonicVoltageContent4Min")
- @Mapping(source = "v5", target = "harmonicVoltageContent5Min")
- @Mapping(source = "v6", target = "harmonicVoltageContent6Min")
- @Mapping(source = "v7", target = "harmonicVoltageContent7Min")
- @Mapping(source = "v8", target = "harmonicVoltageContent8Min")
- @Mapping(source = "v9", target = "harmonicVoltageContent9Min")
- @Mapping(source = "v10", target = "harmonicVoltageContent10Min")
- @Mapping(source = "v11", target = "harmonicVoltageContent11Min")
- @Mapping(source = "v12", target = "harmonicVoltageContent12Min")
- @Mapping(source = "v13", target = "harmonicVoltageContent13Min")
- @Mapping(source = "v14", target = "harmonicVoltageContent14Min")
- @Mapping(source = "v15", target = "harmonicVoltageContent15Min")
- @Mapping(source = "v16", target = "harmonicVoltageContent16Min")
- @Mapping(source = "v17", target = "harmonicVoltageContent17Min")
- @Mapping(source = "v18", target = "harmonicVoltageContent18Min")
- @Mapping(source = "v19", target = "harmonicVoltageContent19Min")
- @Mapping(source = "v20", target = "harmonicVoltageContent20Min")
- @Mapping(source = "v21", target = "harmonicVoltageContent21Min")
- @Mapping(source = "v22", target = "harmonicVoltageContent22Min")
- @Mapping(source = "v23", target = "harmonicVoltageContent23Min")
- @Mapping(source = "v24", target = "harmonicVoltageContent24Min")
- @Mapping(source = "v25", target = "harmonicVoltageContent25Min")
- @Mapping(source = "v26", target = "harmonicVoltageContent26Min")
- @Mapping(source = "v27", target = "harmonicVoltageContent27Min")
- @Mapping(source = "v28", target = "harmonicVoltageContent28Min")
- @Mapping(source = "v29", target = "harmonicVoltageContent29Min")
- @Mapping(source = "v30", target = "harmonicVoltageContent30Min")
- @Mapping(source = "v31", target = "harmonicVoltageContent31Min")
- @Mapping(source = "v32", target = "harmonicVoltageContent32Min")
- @Mapping(source = "v33", target = "harmonicVoltageContent33Min")
- @Mapping(source = "v34", target = "harmonicVoltageContent34Min")
- @Mapping(source = "v35", target = "harmonicVoltageContent35Min")
- @Mapping(source = "v36", target = "harmonicVoltageContent36Min")
- @Mapping(source = "v37", target = "harmonicVoltageContent37Min")
- @Mapping(source = "v38", target = "harmonicVoltageContent38Min")
- @Mapping(source = "v39", target = "harmonicVoltageContent39Min")
- @Mapping(source = "v40", target = "harmonicVoltageContent40Min")
- @Mapping(source = "v41", target = "harmonicVoltageContent41Min")
- @Mapping(source = "v42", target = "harmonicVoltageContent42Min")
- @Mapping(source = "v43", target = "harmonicVoltageContent43Min")
- @Mapping(source = "v44", target = "harmonicVoltageContent44Min")
- @Mapping(source = "v45", target = "harmonicVoltageContent45Min")
- @Mapping(source = "v46", target = "harmonicVoltageContent46Min")
- @Mapping(source = "v47", target = "harmonicVoltageContent47Min")
- @Mapping(source = "v48", target = "harmonicVoltageContent48Min")
- @Mapping(source = "v49", target = "harmonicVoltageContent49Min")
- @Mapping(source = "v50", target = "harmonicVoltageContent50Min")
+ @Mapping(source = "v1", target = "fundamentalVoltageMin",numberFormat = "#.000")
+ @Mapping(source = "v2", target = "harmonicVoltageContent2Min",numberFormat = "#.000")
+ @Mapping(source = "v3", target = "harmonicVoltageContent3Min",numberFormat = "#.000")
+ @Mapping(source = "v4", target = "harmonicVoltageContent4Min",numberFormat = "#.000")
+ @Mapping(source = "v5", target = "harmonicVoltageContent5Min",numberFormat = "#.000")
+ @Mapping(source = "v6", target = "harmonicVoltageContent6Min",numberFormat = "#.000")
+ @Mapping(source = "v7", target = "harmonicVoltageContent7Min",numberFormat = "#.000")
+ @Mapping(source = "v8", target = "harmonicVoltageContent8Min",numberFormat = "#.000")
+ @Mapping(source = "v9", target = "harmonicVoltageContent9Min",numberFormat = "#.000")
+ @Mapping(source = "v10", target = "harmonicVoltageContent10Min",numberFormat = "#.000")
+ @Mapping(source = "v11", target = "harmonicVoltageContent11Min",numberFormat = "#.000")
+ @Mapping(source = "v12", target = "harmonicVoltageContent12Min",numberFormat = "#.000")
+ @Mapping(source = "v13", target = "harmonicVoltageContent13Min",numberFormat = "#.000")
+ @Mapping(source = "v14", target = "harmonicVoltageContent14Min",numberFormat = "#.000")
+ @Mapping(source = "v15", target = "harmonicVoltageContent15Min",numberFormat = "#.000")
+ @Mapping(source = "v16", target = "harmonicVoltageContent16Min",numberFormat = "#.000")
+ @Mapping(source = "v17", target = "harmonicVoltageContent17Min",numberFormat = "#.000")
+ @Mapping(source = "v18", target = "harmonicVoltageContent18Min",numberFormat = "#.000")
+ @Mapping(source = "v19", target = "harmonicVoltageContent19Min",numberFormat = "#.000")
+ @Mapping(source = "v20", target = "harmonicVoltageContent20Min",numberFormat = "#.000")
+ @Mapping(source = "v21", target = "harmonicVoltageContent21Min",numberFormat = "#.000")
+ @Mapping(source = "v22", target = "harmonicVoltageContent22Min",numberFormat = "#.000")
+ @Mapping(source = "v23", target = "harmonicVoltageContent23Min",numberFormat = "#.000")
+ @Mapping(source = "v24", target = "harmonicVoltageContent24Min",numberFormat = "#.000")
+ @Mapping(source = "v25", target = "harmonicVoltageContent25Min",numberFormat = "#.000")
+ @Mapping(source = "v26", target = "harmonicVoltageContent26Min",numberFormat = "#.000")
+ @Mapping(source = "v27", target = "harmonicVoltageContent27Min",numberFormat = "#.000")
+ @Mapping(source = "v28", target = "harmonicVoltageContent28Min",numberFormat = "#.000")
+ @Mapping(source = "v29", target = "harmonicVoltageContent29Min",numberFormat = "#.000")
+ @Mapping(source = "v30", target = "harmonicVoltageContent30Min",numberFormat = "#.000")
+ @Mapping(source = "v31", target = "harmonicVoltageContent31Min",numberFormat = "#.000")
+ @Mapping(source = "v32", target = "harmonicVoltageContent32Min",numberFormat = "#.000")
+ @Mapping(source = "v33", target = "harmonicVoltageContent33Min",numberFormat = "#.000")
+ @Mapping(source = "v34", target = "harmonicVoltageContent34Min",numberFormat = "#.000")
+ @Mapping(source = "v35", target = "harmonicVoltageContent35Min",numberFormat = "#.000")
+ @Mapping(source = "v36", target = "harmonicVoltageContent36Min",numberFormat = "#.000")
+ @Mapping(source = "v37", target = "harmonicVoltageContent37Min",numberFormat = "#.000")
+ @Mapping(source = "v38", target = "harmonicVoltageContent38Min",numberFormat = "#.000")
+ @Mapping(source = "v39", target = "harmonicVoltageContent39Min",numberFormat = "#.000")
+ @Mapping(source = "v40", target = "harmonicVoltageContent40Min",numberFormat = "#.000")
+ @Mapping(source = "v41", target = "harmonicVoltageContent41Min",numberFormat = "#.000")
+ @Mapping(source = "v42", target = "harmonicVoltageContent42Min",numberFormat = "#.000")
+ @Mapping(source = "v43", target = "harmonicVoltageContent43Min",numberFormat = "#.000")
+ @Mapping(source = "v44", target = "harmonicVoltageContent44Min",numberFormat = "#.000")
+ @Mapping(source = "v45", target = "harmonicVoltageContent45Min",numberFormat = "#.000")
+ @Mapping(source = "v46", target = "harmonicVoltageContent46Min",numberFormat = "#.000")
+ @Mapping(source = "v47", target = "harmonicVoltageContent47Min",numberFormat = "#.000")
+ @Mapping(source = "v48", target = "harmonicVoltageContent48Min",numberFormat = "#.000")
+ @Mapping(source = "v49", target = "harmonicVoltageContent49Min",numberFormat = "#.000")
+ @Mapping(source = "v50", target = "harmonicVoltageContent50Min",numberFormat = "#.000")
public RMpHarmonicVRateReportD dataVPOTORMpHarmonicPReportDPOMin(DataHarmRateVPO dataVPO);
- @Mapping(source = "v1", target = "fundamentalVoltageAvg")
- @Mapping(source = "v2", target = "harmonicVoltageContent2Avg")
- @Mapping(source = "v3", target = "harmonicVoltageContent3Avg")
- @Mapping(source = "v4", target = "harmonicVoltageContent4Avg")
- @Mapping(source = "v5", target = "harmonicVoltageContent5Avg")
- @Mapping(source = "v6", target = "harmonicVoltageContent6Avg")
- @Mapping(source = "v7", target = "harmonicVoltageContent7Avg")
- @Mapping(source = "v8", target = "harmonicVoltageContent8Avg")
- @Mapping(source = "v9", target = "harmonicVoltageContent9Avg")
- @Mapping(source = "v10", target = "harmonicVoltageContent10Avg")
- @Mapping(source = "v11", target = "harmonicVoltageContent11Avg")
- @Mapping(source = "v12", target = "harmonicVoltageContent12Avg")
- @Mapping(source = "v13", target = "harmonicVoltageContent13Avg")
- @Mapping(source = "v14", target = "harmonicVoltageContent14Avg")
- @Mapping(source = "v15", target = "harmonicVoltageContent15Avg")
- @Mapping(source = "v16", target = "harmonicVoltageContent16Avg")
- @Mapping(source = "v17", target = "harmonicVoltageContent17Avg")
- @Mapping(source = "v18", target = "harmonicVoltageContent18Avg")
- @Mapping(source = "v19", target = "harmonicVoltageContent19Avg")
- @Mapping(source = "v20", target = "harmonicVoltageContent20Avg")
- @Mapping(source = "v21", target = "harmonicVoltageContent21Avg")
- @Mapping(source = "v22", target = "harmonicVoltageContent22Avg")
- @Mapping(source = "v23", target = "harmonicVoltageContent23Avg")
- @Mapping(source = "v24", target = "harmonicVoltageContent24Avg")
- @Mapping(source = "v25", target = "harmonicVoltageContent25Avg")
- @Mapping(source = "v26", target = "harmonicVoltageContent26Avg")
- @Mapping(source = "v27", target = "harmonicVoltageContent27Avg")
- @Mapping(source = "v28", target = "harmonicVoltageContent28Avg")
- @Mapping(source = "v29", target = "harmonicVoltageContent29Avg")
- @Mapping(source = "v30", target = "harmonicVoltageContent30Avg")
- @Mapping(source = "v31", target = "harmonicVoltageContent31Avg")
- @Mapping(source = "v32", target = "harmonicVoltageContent32Avg")
- @Mapping(source = "v33", target = "harmonicVoltageContent33Avg")
- @Mapping(source = "v34", target = "harmonicVoltageContent34Avg")
- @Mapping(source = "v35", target = "harmonicVoltageContent35Avg")
- @Mapping(source = "v36", target = "harmonicVoltageContent36Avg")
- @Mapping(source = "v37", target = "harmonicVoltageContent37Avg")
- @Mapping(source = "v38", target = "harmonicVoltageContent38Avg")
- @Mapping(source = "v39", target = "harmonicVoltageContent39Avg")
- @Mapping(source = "v40", target = "harmonicVoltageContent40Avg")
- @Mapping(source = "v41", target = "harmonicVoltageContent41Avg")
- @Mapping(source = "v42", target = "harmonicVoltageContent42Avg")
- @Mapping(source = "v43", target = "harmonicVoltageContent43Avg")
- @Mapping(source = "v44", target = "harmonicVoltageContent44Avg")
- @Mapping(source = "v45", target = "harmonicVoltageContent45Avg")
- @Mapping(source = "v46", target = "harmonicVoltageContent46Avg")
- @Mapping(source = "v47", target = "harmonicVoltageContent47Avg")
- @Mapping(source = "v48", target = "harmonicVoltageContent48Avg")
- @Mapping(source = "v49", target = "harmonicVoltageContent49Avg")
- @Mapping(source = "v50", target = "harmonicVoltageContent50Avg")
+ @Mapping(source = "v1", target = "fundamentalVoltageAvg",numberFormat = "#.000")
+ @Mapping(source = "v2", target = "harmonicVoltageContent2Avg",numberFormat = "#.000")
+ @Mapping(source = "v3", target = "harmonicVoltageContent3Avg",numberFormat = "#.000")
+ @Mapping(source = "v4", target = "harmonicVoltageContent4Avg",numberFormat = "#.000")
+ @Mapping(source = "v5", target = "harmonicVoltageContent5Avg",numberFormat = "#.000")
+ @Mapping(source = "v6", target = "harmonicVoltageContent6Avg",numberFormat = "#.000")
+ @Mapping(source = "v7", target = "harmonicVoltageContent7Avg",numberFormat = "#.000")
+ @Mapping(source = "v8", target = "harmonicVoltageContent8Avg",numberFormat = "#.000")
+ @Mapping(source = "v9", target = "harmonicVoltageContent9Avg",numberFormat = "#.000")
+ @Mapping(source = "v10", target = "harmonicVoltageContent10Avg",numberFormat = "#.000")
+ @Mapping(source = "v11", target = "harmonicVoltageContent11Avg",numberFormat = "#.000")
+ @Mapping(source = "v12", target = "harmonicVoltageContent12Avg",numberFormat = "#.000")
+ @Mapping(source = "v13", target = "harmonicVoltageContent13Avg",numberFormat = "#.000")
+ @Mapping(source = "v14", target = "harmonicVoltageContent14Avg",numberFormat = "#.000")
+ @Mapping(source = "v15", target = "harmonicVoltageContent15Avg",numberFormat = "#.000")
+ @Mapping(source = "v16", target = "harmonicVoltageContent16Avg",numberFormat = "#.000")
+ @Mapping(source = "v17", target = "harmonicVoltageContent17Avg",numberFormat = "#.000")
+ @Mapping(source = "v18", target = "harmonicVoltageContent18Avg",numberFormat = "#.000")
+ @Mapping(source = "v19", target = "harmonicVoltageContent19Avg",numberFormat = "#.000")
+ @Mapping(source = "v20", target = "harmonicVoltageContent20Avg",numberFormat = "#.000")
+ @Mapping(source = "v21", target = "harmonicVoltageContent21Avg",numberFormat = "#.000")
+ @Mapping(source = "v22", target = "harmonicVoltageContent22Avg",numberFormat = "#.000")
+ @Mapping(source = "v23", target = "harmonicVoltageContent23Avg",numberFormat = "#.000")
+ @Mapping(source = "v24", target = "harmonicVoltageContent24Avg",numberFormat = "#.000")
+ @Mapping(source = "v25", target = "harmonicVoltageContent25Avg",numberFormat = "#.000")
+ @Mapping(source = "v26", target = "harmonicVoltageContent26Avg",numberFormat = "#.000")
+ @Mapping(source = "v27", target = "harmonicVoltageContent27Avg",numberFormat = "#.000")
+ @Mapping(source = "v28", target = "harmonicVoltageContent28Avg",numberFormat = "#.000")
+ @Mapping(source = "v29", target = "harmonicVoltageContent29Avg",numberFormat = "#.000")
+ @Mapping(source = "v30", target = "harmonicVoltageContent30Avg",numberFormat = "#.000")
+ @Mapping(source = "v31", target = "harmonicVoltageContent31Avg",numberFormat = "#.000")
+ @Mapping(source = "v32", target = "harmonicVoltageContent32Avg",numberFormat = "#.000")
+ @Mapping(source = "v33", target = "harmonicVoltageContent33Avg",numberFormat = "#.000")
+ @Mapping(source = "v34", target = "harmonicVoltageContent34Avg",numberFormat = "#.000")
+ @Mapping(source = "v35", target = "harmonicVoltageContent35Avg",numberFormat = "#.000")
+ @Mapping(source = "v36", target = "harmonicVoltageContent36Avg",numberFormat = "#.000")
+ @Mapping(source = "v37", target = "harmonicVoltageContent37Avg",numberFormat = "#.000")
+ @Mapping(source = "v38", target = "harmonicVoltageContent38Avg",numberFormat = "#.000")
+ @Mapping(source = "v39", target = "harmonicVoltageContent39Avg",numberFormat = "#.000")
+ @Mapping(source = "v40", target = "harmonicVoltageContent40Avg",numberFormat = "#.000")
+ @Mapping(source = "v41", target = "harmonicVoltageContent41Avg",numberFormat = "#.000")
+ @Mapping(source = "v42", target = "harmonicVoltageContent42Avg",numberFormat = "#.000")
+ @Mapping(source = "v43", target = "harmonicVoltageContent43Avg",numberFormat = "#.000")
+ @Mapping(source = "v44", target = "harmonicVoltageContent44Avg",numberFormat = "#.000")
+ @Mapping(source = "v45", target = "harmonicVoltageContent45Avg",numberFormat = "#.000")
+ @Mapping(source = "v46", target = "harmonicVoltageContent46Avg",numberFormat = "#.000")
+ @Mapping(source = "v47", target = "harmonicVoltageContent47Avg",numberFormat = "#.000")
+ @Mapping(source = "v48", target = "harmonicVoltageContent48Avg",numberFormat = "#.000")
+ @Mapping(source = "v49", target = "harmonicVoltageContent49Avg",numberFormat = "#.000")
+ @Mapping(source = "v50", target = "harmonicVoltageContent50Avg",numberFormat = "#.000")
public RMpHarmonicVRateReportD dataVPOTORMpHarmonicPReportDPOAvg(DataHarmRateVPO dataVPO);
- @Mapping(source = "v1", target = "fundamentalVoltage95")
- @Mapping(source = "v2", target = "harmonicVoltageContent295")
- @Mapping(source = "v3", target = "harmonicVoltageContent395")
- @Mapping(source = "v4", target = "harmonicVoltageContent495")
- @Mapping(source = "v5", target = "harmonicVoltageContent595")
- @Mapping(source = "v6", target = "harmonicVoltageContent695")
- @Mapping(source = "v7", target = "harmonicVoltageContent795")
- @Mapping(source = "v8", target = "harmonicVoltageContent895")
- @Mapping(source = "v9", target = "harmonicVoltageContent995")
- @Mapping(source = "v10", target = "harmonicVoltageContent1095")
- @Mapping(source = "v11", target = "harmonicVoltageContent1195")
- @Mapping(source = "v12", target = "harmonicVoltageContent1295")
- @Mapping(source = "v13", target = "harmonicVoltageContent1395")
- @Mapping(source = "v14", target = "harmonicVoltageContent1495")
- @Mapping(source = "v15", target = "harmonicVoltageContent1595")
- @Mapping(source = "v16", target = "harmonicVoltageContent1695")
- @Mapping(source = "v17", target = "harmonicVoltageContent1795")
- @Mapping(source = "v18", target = "harmonicVoltageContent1895")
- @Mapping(source = "v19", target = "harmonicVoltageContent1995")
- @Mapping(source = "v20", target = "harmonicVoltageContent2095")
- @Mapping(source = "v21", target = "harmonicVoltageContent2195")
- @Mapping(source = "v22", target = "harmonicVoltageContent2295")
- @Mapping(source = "v23", target = "harmonicVoltageContent2395")
- @Mapping(source = "v24", target = "harmonicVoltageContent2495")
- @Mapping(source = "v25", target = "harmonicVoltageContent2595")
- @Mapping(source = "v26", target = "harmonicVoltageContent2695")
- @Mapping(source = "v27", target = "harmonicVoltageContent2795")
- @Mapping(source = "v28", target = "harmonicVoltageContent2895")
- @Mapping(source = "v29", target = "harmonicVoltageContent2995")
- @Mapping(source = "v30", target = "harmonicVoltageContent3095")
- @Mapping(source = "v31", target = "harmonicVoltageContent3195")
- @Mapping(source = "v32", target = "harmonicVoltageContent3295")
- @Mapping(source = "v33", target = "harmonicVoltageContent3395")
- @Mapping(source = "v34", target = "harmonicVoltageContent3495")
- @Mapping(source = "v35", target = "harmonicVoltageContent3595")
- @Mapping(source = "v36", target = "harmonicVoltageContent3695")
- @Mapping(source = "v37", target = "harmonicVoltageContent3795")
- @Mapping(source = "v38", target = "harmonicVoltageContent3895")
- @Mapping(source = "v39", target = "harmonicVoltageContent3995")
- @Mapping(source = "v40", target = "harmonicVoltageContent4095")
- @Mapping(source = "v41", target = "harmonicVoltageContent4195")
- @Mapping(source = "v42", target = "harmonicVoltageContent4295")
- @Mapping(source = "v43", target = "harmonicVoltageContent4395")
- @Mapping(source = "v44", target = "harmonicVoltageContent4495")
- @Mapping(source = "v45", target = "harmonicVoltageContent4595")
- @Mapping(source = "v46", target = "harmonicVoltageContent4695")
- @Mapping(source = "v47", target = "harmonicVoltageContent4795")
- @Mapping(source = "v48", target = "harmonicVoltageContent4895")
- @Mapping(source = "v49", target = "harmonicVoltageContent4995")
- @Mapping(source = "v50", target = "harmonicVoltageContent5095")
+ @Mapping(source = "v1", target = "fundamentalVoltage95",numberFormat = "#.000")
+ @Mapping(source = "v2", target = "harmonicVoltageContent295",numberFormat = "#.000")
+ @Mapping(source = "v3", target = "harmonicVoltageContent395",numberFormat = "#.000")
+ @Mapping(source = "v4", target = "harmonicVoltageContent495",numberFormat = "#.000")
+ @Mapping(source = "v5", target = "harmonicVoltageContent595",numberFormat = "#.000")
+ @Mapping(source = "v6", target = "harmonicVoltageContent695",numberFormat = "#.000")
+ @Mapping(source = "v7", target = "harmonicVoltageContent795",numberFormat = "#.000")
+ @Mapping(source = "v8", target = "harmonicVoltageContent895",numberFormat = "#.000")
+ @Mapping(source = "v9", target = "harmonicVoltageContent995",numberFormat = "#.000")
+ @Mapping(source = "v10", target = "harmonicVoltageContent1095",numberFormat = "#.000")
+ @Mapping(source = "v11", target = "harmonicVoltageContent1195",numberFormat = "#.000")
+ @Mapping(source = "v12", target = "harmonicVoltageContent1295",numberFormat = "#.000")
+ @Mapping(source = "v13", target = "harmonicVoltageContent1395",numberFormat = "#.000")
+ @Mapping(source = "v14", target = "harmonicVoltageContent1495",numberFormat = "#.000")
+ @Mapping(source = "v15", target = "harmonicVoltageContent1595",numberFormat = "#.000")
+ @Mapping(source = "v16", target = "harmonicVoltageContent1695",numberFormat = "#.000")
+ @Mapping(source = "v17", target = "harmonicVoltageContent1795",numberFormat = "#.000")
+ @Mapping(source = "v18", target = "harmonicVoltageContent1895",numberFormat = "#.000")
+ @Mapping(source = "v19", target = "harmonicVoltageContent1995",numberFormat = "#.000")
+ @Mapping(source = "v20", target = "harmonicVoltageContent2095",numberFormat = "#.000")
+ @Mapping(source = "v21", target = "harmonicVoltageContent2195",numberFormat = "#.000")
+ @Mapping(source = "v22", target = "harmonicVoltageContent2295",numberFormat = "#.000")
+ @Mapping(source = "v23", target = "harmonicVoltageContent2395",numberFormat = "#.000")
+ @Mapping(source = "v24", target = "harmonicVoltageContent2495",numberFormat = "#.000")
+ @Mapping(source = "v25", target = "harmonicVoltageContent2595",numberFormat = "#.000")
+ @Mapping(source = "v26", target = "harmonicVoltageContent2695",numberFormat = "#.000")
+ @Mapping(source = "v27", target = "harmonicVoltageContent2795",numberFormat = "#.000")
+ @Mapping(source = "v28", target = "harmonicVoltageContent2895",numberFormat = "#.000")
+ @Mapping(source = "v29", target = "harmonicVoltageContent2995",numberFormat = "#.000")
+ @Mapping(source = "v30", target = "harmonicVoltageContent3095",numberFormat = "#.000")
+ @Mapping(source = "v31", target = "harmonicVoltageContent3195",numberFormat = "#.000")
+ @Mapping(source = "v32", target = "harmonicVoltageContent3295",numberFormat = "#.000")
+ @Mapping(source = "v33", target = "harmonicVoltageContent3395",numberFormat = "#.000")
+ @Mapping(source = "v34", target = "harmonicVoltageContent3495",numberFormat = "#.000")
+ @Mapping(source = "v35", target = "harmonicVoltageContent3595",numberFormat = "#.000")
+ @Mapping(source = "v36", target = "harmonicVoltageContent3695",numberFormat = "#.000")
+ @Mapping(source = "v37", target = "harmonicVoltageContent3795",numberFormat = "#.000")
+ @Mapping(source = "v38", target = "harmonicVoltageContent3895",numberFormat = "#.000")
+ @Mapping(source = "v39", target = "harmonicVoltageContent3995",numberFormat = "#.000")
+ @Mapping(source = "v40", target = "harmonicVoltageContent4095",numberFormat = "#.000")
+ @Mapping(source = "v41", target = "harmonicVoltageContent4195",numberFormat = "#.000")
+ @Mapping(source = "v42", target = "harmonicVoltageContent4295",numberFormat = "#.000")
+ @Mapping(source = "v43", target = "harmonicVoltageContent4395",numberFormat = "#.000")
+ @Mapping(source = "v44", target = "harmonicVoltageContent4495",numberFormat = "#.000")
+ @Mapping(source = "v45", target = "harmonicVoltageContent4595",numberFormat = "#.000")
+ @Mapping(source = "v46", target = "harmonicVoltageContent4695",numberFormat = "#.000")
+ @Mapping(source = "v47", target = "harmonicVoltageContent4795",numberFormat = "#.000")
+ @Mapping(source = "v48", target = "harmonicVoltageContent4895",numberFormat = "#.000")
+ @Mapping(source = "v49", target = "harmonicVoltageContent4995",numberFormat = "#.000")
+ @Mapping(source = "v50", target = "harmonicVoltageContent5095",numberFormat = "#.000")
public RMpHarmonicVRateReportD dataVPOTORMpHarmonicPReportDPO95(DataHarmRateVPO dataVPO);
@@ -1557,4 +1557,74 @@ public interface InfluxdbPOConverter {
@Mapping(source = "cp952.pf", target = "spPowerFactor95")
@Mapping(source = "cp952.df", target = "spFundamentalPowerFactor95")
public RMpMeasurePhaseReportD RMpMeasurePhaseReportDPOConverterCp95(DataVPO cp95, DataIPO cp951, DataHarmPowerPPO cp952, DataHarmPowerSPO cp953, DataHarmPowerQPO cp954);
+
+
+ /*RMpMeasureReportDPO*/
+ @Mapping(source = "max.freq", target = "frequencyMax")
+ @Mapping(source = "max.freqDev", target = "frequencyDeviationMax")
+ @Mapping(source = "max.VPos", target = "positiveSequenceVoltageMax")
+ @Mapping(source = "max.VNeg", target = "negativeSequenceVoltageMax")
+ @Mapping(source = "max.VZero", target = "zeroSequenceVoltageMax")
+ @Mapping(source = "max.VUnbalance", target = "negativeSequenceVoltageUnbalanceMax")
+ @Mapping(source = "max1.IPos", target = "positiveSequenceCurrentMax")
+ @Mapping(source = "max1.INeg", target = "negativeSequenceCurrentMax")
+ @Mapping(source = "max1.IZero", target = "zeroSequenceCurrentMax")
+ @Mapping(source = "max1.IUnbalance", target = "negativeSequenceCurrentUnbalanceMax")
+ @Mapping(source = "max2.p", target = "totalActivePowerMax")
+ @Mapping(source = "max2.pf", target = "tpPowerFactorMax")
+ @Mapping(source = "max2.df", target = "fundamentalPowerFactorMax")
+ @Mapping(source = "max4.q", target = "totalReactivePowerMax")
+ @Mapping(source = "max3.s", target = "totalApparentPowerMax")
+ public RMpMeasureReportD RMpMeasureReportDPOConverterMax(DataVPO max, DataIPO max1, DataHarmPowerPPO max2, DataHarmPowerSPO max3, DataHarmPowerQPO max4);
+
+ @Mapping(source = "min.freq", target = "frequencyMin")
+ @Mapping(source = "min.freqDev", target = "frequencyDeviationMin")
+ @Mapping(source = "min.VPos", target = "positiveSequenceVoltageMin")
+ @Mapping(source = "min.VNeg", target = "negativeSequenceVoltageMin")
+ @Mapping(source = "min.VZero", target = "zeroSequenceVoltageMin")
+ @Mapping(source = "min.VUnbalance", target = "negativeSequenceVoltageUnbalanceMin")
+ @Mapping(source = "min1.IPos", target = "positiveSequenceCurrentMin")
+ @Mapping(source = "min1.INeg", target = "negativeSequenceCurrentMin")
+ @Mapping(source = "min1.IZero", target = "zeroSequenceCurrentMin")
+ @Mapping(source = "min1.IUnbalance", target = "negativeSequenceCurrentUnbalanceMin")
+ @Mapping(source = "min2.p", target = "totalActivePowerMin")
+ @Mapping(source = "min2.pf", target = "tpPowerFactorMin")
+ @Mapping(source = "min2.df", target = "fundamentalPowerFactorMin")
+ @Mapping(source = "min4.q", target = "totalReactivePowerMin")
+ @Mapping(source = "min3.s", target = "totalApparentPowerMin")
+ public RMpMeasureReportD RMpMeasureReportDPOConverterMin(DataVPO min, DataIPO min1, DataHarmPowerPPO min2, DataHarmPowerSPO min3, DataHarmPowerQPO min4);
+
+ @Mapping(source = "avg.freq", target = "frequencyAvg")
+ @Mapping(source = "avg.freqDev", target = "frequencyDeviationAvg")
+ @Mapping(source = "avg.VPos", target = "positiveSequenceVoltageAvg")
+ @Mapping(source = "avg.VNeg", target = "negativeSequenceVoltageAvg")
+ @Mapping(source = "avg.VZero", target = "zeroSequenceVoltageAvg")
+ @Mapping(source = "avg.VUnbalance", target = "negativeSequenceVoltageUnbalanceAvg")
+ @Mapping(source = "avg1.IPos", target = "positiveSequenceCurrentAvg")
+ @Mapping(source = "avg1.INeg", target = "negativeSequenceCurrentAvg")
+ @Mapping(source = "avg1.IZero", target = "zeroSequenceCurrentAvg")
+ @Mapping(source = "avg1.IUnbalance", target = "negativeSequenceCurrentUnbalanceAvg")
+ @Mapping(source = "avg2.p", target = "totalActivePowerAvg")
+ @Mapping(source = "avg2.pf", target = "tpPowerFactorAvg")
+ @Mapping(source = "avg2.df", target = "fundamentalPowerFactorAvg")
+ @Mapping(source = "avg4.q", target = "totalReactivePowerAvg")
+ @Mapping(source = "avg3.s", target = "totalApparentPowerAvg")
+ public RMpMeasureReportD RMpMeasureReportDPOConverterAVg(DataVPO avg, DataIPO avg1, DataHarmPowerPPO avg2, DataHarmPowerSPO avg3, DataHarmPowerQPO avg4);
+
+ @Mapping(source = "cp95.freq", target = "frequency95")
+ @Mapping(source = "cp95.freqDev", target = "frequencyDeviation95")
+ @Mapping(source = "cp95.VPos", target = "positiveSequenceVoltage95")
+ @Mapping(source = "cp95.VNeg", target = "negativeSequenceVoltage95")
+ @Mapping(source = "cp95.VZero", target = "zeroSequenceVoltage95")
+ @Mapping(source = "cp95.VUnbalance", target = "negativeSequenceVoltageUnbalance95")
+ @Mapping(source = "cp951.IPos", target = "positiveSequenceCurrent95")
+ @Mapping(source = "cp951.INeg", target = "negativeSequenceCurrent95")
+ @Mapping(source = "cp951.IZero", target = "zeroSequenceCurrent95")
+ @Mapping(source = "cp951.IUnbalance", target = "negativeSequenceCurrentUnbalance95")
+ @Mapping(source = "cp952.p", target = "totalActivePower95")
+ @Mapping(source = "cp952.pf", target = "tpPowerFactor95")
+ @Mapping(source = "cp952.df", target = "fundamentalPowerFactor95")
+ @Mapping(source = "cp954.q", target = "totalReactivePower95")
+ @Mapping(source = "cp953.s", target = "totalApparentPower95")
+ public RMpMeasureReportD RMpMeasureReportDPOConverterCp95(DataVPO cp95, DataIPO cp951, DataHarmPowerPPO cp952, DataHarmPowerSPO cp953, DataHarmPowerQPO cp954);
}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/Param.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/Param.java
deleted file mode 100644
index e88c680eb..000000000
--- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/Param.java
+++ /dev/null
@@ -1,15 +0,0 @@
-package com.njcn.prepare.harmonic.constant;
-
-
-/**
- * @author qijian
- */
-public interface Param {
-
- /**
- * 稳态/固态
- */
- Integer SOLID_STATE = 0;
- Integer STEADY_STATE = 1;
-
-}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/PqsPrepareExceptionEnum.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/PqsPrepareExceptionEnum.java
new file mode 100644
index 000000000..e0b15eee8
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/PqsPrepareExceptionEnum.java
@@ -0,0 +1,29 @@
+package com.njcn.prepare.harmonic.constant;
+
+import lombok.Getter;
+
+/**
+ * 异常处理类
+ * @author qijian
+ * @version 1.0.0
+ * @date 2022年11月11日 09:56
+ */
+@Getter
+public enum PqsPrepareExceptionEnum {
+
+ /**
+ * 过程监督异常响应码的范围:
+ * A00550 ~ A00649
+ */
+ REDIS_NULL_EXCEPTION("A0001","redis缓存异常,重新加载redis"),
+ ;
+
+ private final String code;
+
+ private final String message;
+
+ PqsPrepareExceptionEnum(String code, String message) {
+ this.code = code;
+ this.message = message;
+ }
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/AreaCountController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/AreaCountController.java
new file mode 100644
index 000000000..d18789724
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/AreaCountController.java
@@ -0,0 +1,76 @@
+package com.njcn.prepare.harmonic.controller.area;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.prepare.harmonic.pojo.param.PrimaryGridParam;
+import com.njcn.prepare.harmonic.service.mysql.area.AreaCountService;
+import com.njcn.user.api.DeptFeignClient;
+import com.njcn.user.pojo.vo.PvTerminalTreeVO;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/13 11:14【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Slf4j
+@Api(tags = "区域统计(r_stat_org_d表数据需要先生成r_stat_abnormal_d,r_mp_integrity_d表)")
+@RestController
+@RequestMapping("AreaCount")
+@RequiredArgsConstructor
+public class AreaCountController extends BaseController {
+
+ private @Autowired
+ DeptFeignClient deptFeignClient;
+
+ private @Autowired
+ AreaCountService areaCountService;
+
+ @ApiOperation("区域统计有效接入监测点个数计算(r_stat_org_d表数据)")
+ @ApiImplicitParam(value = "primaryGridParam",name = "primaryGridParam",required = true)
+ @PostMapping("areaCountHanlder")
+ @OperateInfo(info = LogEnum.BUSINESS_MEDIUM)
+ public HttpResult areaCountHanlder(@RequestBody PrimaryGridParam primaryGridParam ){
+ log.info(LocalDateTime.now()+"areaCountHanlder开始执行");
+ String methodDescribe = getMethodDescribe("areaCountHanlder");
+ Boolean result = true;
+ List orgIdList = new ArrayList<> ();
+ if(CollectionUtils.isEmpty (primaryGridParam.getOrgIdList ())){
+ /*todo 不知道是否需要补招*/
+ List dept = deptFeignClient.allDeptList().getData();
+ orgIdList = dept.stream ( ).map (PvTerminalTreeVO::getId).collect (Collectors.toList ( ));
+ }else{
+ orgIdList = primaryGridParam.getOrgIdList ();
+ }
+ primaryGridParam.setOrgIdList (orgIdList);
+
+ areaCountService.areaCountHanlder (primaryGridParam);
+ if (result){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
+ } else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
+ }
+ }
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/PrimaryGridDataController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/PrimaryGridDataController.java
new file mode 100644
index 000000000..6f6befb15
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/PrimaryGridDataController.java
@@ -0,0 +1,114 @@
+package com.njcn.prepare.harmonic.controller.area;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.device.pms.api.PmsTerminalClient;
+import com.njcn.device.pms.pojo.po.PmsTerminal;
+import com.njcn.prepare.harmonic.pojo.param.PrimaryGridDataIntegrityParam;
+import com.njcn.prepare.harmonic.pojo.param.PrimaryGridParam;
+import com.njcn.prepare.harmonic.service.mysql.area.PrimaryGridDataService;
+import com.njcn.user.api.DeptFeignClient;
+import com.njcn.user.pojo.vo.PvTerminalTreeVO;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * Description:r_operating_index_d
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/24 14:31【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Slf4j
+@Api(tags = "主网单位数据统计(r_operating_index_d表数据需要先生成r_stat_abnormal_d,r_mp_integrity_d表)")
+@RestController
+@RequestMapping("primaryGridData")
+@RequiredArgsConstructor
+public class PrimaryGridDataController extends BaseController {
+
+ private @Autowired
+ PrimaryGridDataService primaryGridDataService;
+
+ private @Autowired
+ DeptFeignClient deptFeignClient;
+
+ private @Autowired
+ PmsTerminalClient pmsTerminalClient;
+
+
+ @ApiOperation("主网单位数据同步(r_operating_index_d表数据)")
+ @ApiImplicitParam(value = "primaryGridParam",name = "primaryGridParam",required = true)
+ @PostMapping("primaryGridDataHanlder")
+ @OperateInfo(info = LogEnum.BUSINESS_MEDIUM)
+ public HttpResult primaryGridDataHanlder(@RequestBody PrimaryGridParam primaryGridParam ){
+ log.info(LocalDateTime.now()+"primaryGridDataHanlder开始执行");
+ String methodDescribe = getMethodDescribe("primaryGridDataHanlder");
+ Boolean result = true;
+ List orgIdList = new ArrayList<> ();
+ if(CollectionUtils.isEmpty (primaryGridParam.getOrgIdList ())){
+ /*todo 不知道是否需要补招*/
+ List dept = deptFeignClient.allDeptList().getData();
+ orgIdList = dept.stream ( ).map (PvTerminalTreeVO::getId).collect (Collectors.toList ( ));
+ }else{
+ orgIdList = primaryGridParam.getOrgIdList ();
+ }
+ primaryGridParam.setOrgIdList (orgIdList);
+
+ primaryGridDataService.primaryGridDataHanlder (primaryGridParam);
+ if (result){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
+ } else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
+ }
+ }
+
+ @ApiOperation("主网终端数据完整率月统计")
+ @ApiImplicitParam(value = "primaryGridDataIntegrityParam",name = "primaryGridDataIntegrityParam",required = true)
+ @PostMapping("primaryGridDataIntegrityHanlder")
+ @OperateInfo(info = LogEnum.BUSINESS_MEDIUM)
+ public HttpResult primaryGridDataIntegrityHanlder(@RequestBody PrimaryGridDataIntegrityParam primaryGridDataIntegrityParam ){
+ log.info(LocalDateTime.now()+"primaryGridDataIntegrityHanlder开始执行");
+ String methodDescribe = getMethodDescribe("primaryGridDataIntegrityHanlder");
+ Boolean result = true;
+ List orgIdList = new ArrayList<> ();
+ if(CollectionUtils.isEmpty (primaryGridDataIntegrityParam.getDeviceId ())){
+ /*todo 不知道是否需要补招*/
+ List data = pmsTerminalClient.getTerminalSelectList ( ).getData ( );
+ orgIdList = data.stream ().map (PmsTerminal::getId).collect(Collectors.toList());
+ }else{
+ orgIdList = primaryGridDataIntegrityParam.getDeviceId ();
+ }
+ primaryGridDataIntegrityParam.setDeviceId (orgIdList);
+
+ primaryGridDataService.primaryGridDataIntegrityHanlder (primaryGridDataIntegrityParam);
+ if (result){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
+ } else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
+ }
+ }
+
+
+
+
+
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/RStatAbnormalDDataHanlderController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/RStatAbnormalDDataHanlderController.java
new file mode 100644
index 000000000..88cd3cf18
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/RStatAbnormalDDataHanlderController.java
@@ -0,0 +1,68 @@
+package com.njcn.prepare.harmonic.controller.area;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.prepare.harmonic.pojo.param.PrimaryGridParam;
+import com.njcn.prepare.harmonic.service.mysql.area.RStatAbnormalDPOService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/28 19:27【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Slf4j
+@Api(tags = "主网单位数据统计(r_stat_abnormal_d表数据)")
+@RestController
+@RequestMapping("AbnormalData")
+@RequiredArgsConstructor
+public class RStatAbnormalDDataHanlderController extends BaseController {
+
+ private @Autowired
+ RStatAbnormalDPOService rStatAbnormalDPOService;
+
+ @ApiOperation("主网单位数据同步(r_stat_abnormal_d表数据)")
+ @ApiImplicitParam(value = "primaryGridParam",name = "primaryGridParam",required = true)
+ @PostMapping("(rStatAbnormalDDataHanlder")
+ @OperateInfo(info = LogEnum.BUSINESS_MEDIUM)
+ public HttpResult rStatAbnormalDDataHanlder(@RequestBody PrimaryGridParam primaryGridParam ){
+ log.info(LocalDateTime.now()+"rStatAbnormalDDataHanlder开始执行");
+ String methodDescribe = getMethodDescribe("rStatAbnormalDDataHanlder");
+ Boolean result = true;
+ List orgIdList = new ArrayList<> ();
+ if(CollectionUtils.isEmpty (primaryGridParam.getOrgIdList ())){
+ /*todo 不知道是否需要补招*/
+ //orgIdList = lineFeignClient.getLineList ( ).getData ( );
+ }else{
+ orgIdList = primaryGridParam.getOrgIdList ();
+ }
+ primaryGridParam.setOrgIdList (orgIdList);
+ rStatAbnormalDPOService.rStatAbnormalDDataHanlder(primaryGridParam);
+ if (result){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
+ } else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
+ }
+ }
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/AlarmDetailController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/AlarmDetailController.java
new file mode 100644
index 000000000..3f4aea155
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/AlarmDetailController.java
@@ -0,0 +1,51 @@
+package com.njcn.prepare.harmonic.controller.line;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.constant.OperateType;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.service.mysql.line.AlarmDetailService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author qijian
+ * @date 2022/12/28
+ * 监测点指标告警明细
+ */
+@Validated
+@Slf4j
+@RestController
+@RequestMapping("/alarmDetail")
+@Api(tags = "监测点指标告警明细")
+@AllArgsConstructor
+public class AlarmDetailController extends BaseController {
+
+ private final AlarmDetailService alarmDetailService;
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+ @PostMapping("/alarmDetailAlarm")
+ @ApiOperation("监测点指标告警日统计")
+ @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+ public HttpResult alarmDetailAlarm(@RequestBody @Validated LineParam lineParam) {
+ String methodDescribe = getMethodDescribe("alarmDetailAlarm");
+ boolean res = alarmDetailService.alarmDetailAlarm(lineParam);
+ if(res){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe);
+ }
+ }
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DataExceptionController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DataExceptionController.java
new file mode 100644
index 000000000..5fedfebec
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DataExceptionController.java
@@ -0,0 +1,53 @@
+package com.njcn.prepare.harmonic.controller.line;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.constant.OperateType;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.device.pq.enums.DeviceResponseEnum;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.service.mysql.line.DataExceptionService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author qijian
+ * @date 2022/10/26
+ * 数据是否异常
+ */
+@Validated
+@Slf4j
+@RestController
+@RequestMapping("/dataException")
+@Api(tags = "数据是否异常")
+@AllArgsConstructor
+public class DataExceptionController extends BaseController {
+
+ private final DataExceptionService dataExceptionService;
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+ @PostMapping("/lineDataException")
+ @ApiOperation("监测点数据是否异常")
+ @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+ public HttpResult lineDataException(@RequestBody @Validated LineParam lineParam) {
+ String methodDescribe = getMethodDescribe("lineDataException");
+ DeviceResponseEnum deviceResponseEnum = dataExceptionService.lineDataException(lineParam);
+ if(deviceResponseEnum != null){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, deviceResponseEnum.getMessage(), methodDescribe);
+ }else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, "不存在数据异常!", methodDescribe);
+ }
+
+ }
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DataIntegrityRateController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DataIntegrityRateController.java
new file mode 100644
index 000000000..531d09be0
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DataIntegrityRateController.java
@@ -0,0 +1,52 @@
+package com.njcn.prepare.harmonic.controller.line;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.constant.OperateType;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.service.mysql.line.DataIntegrityRateService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author qijian
+ * @date 2022/10/26
+ * 数据完整率算法
+ */
+@Validated
+@Slf4j
+@RestController
+@RequestMapping("/dataIntegrityRate")
+@Api(tags = "数据完整率算法")
+@AllArgsConstructor
+public class DataIntegrityRateController extends BaseController {
+
+ private final DataIntegrityRateService dataIntegrityRateService;
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+ @PostMapping("/lineDataIntegrityRate")
+ @ApiOperation("监测点日数据完整率")
+ @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+ public HttpResult lineDataIntegrityRate(@RequestBody @Validated LineParam lineParam) {
+ String methodDescribe = getMethodDescribe("lineDataIntegrityRate");
+ boolean res = dataIntegrityRateService.lineDataIntegrityRate(lineParam);
+ if(res){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe);
+ }
+
+ }
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DistortionRateController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DistortionRateController.java
index 0c8dd1963..3a504b52f 100644
--- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DistortionRateController.java
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DistortionRateController.java
@@ -5,6 +5,7 @@ import com.njcn.common.pojo.enums.common.LogEnum;
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.device.pq.api.LineFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.mysql.line.DistortionRateService;
import com.njcn.web.controller.BaseController;
@@ -13,12 +14,17 @@ import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.util.CollectionUtils;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
/**
* @author xiaoyao
* @version 1.0.0
@@ -32,6 +38,7 @@ import org.springframework.web.bind.annotation.RestController;
public class DistortionRateController extends BaseController {
private final DistortionRateService distortionRateService;
+ private final LineFeignClient lineFeignClient;
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@PostMapping("/distortionRate")
@@ -42,4 +49,25 @@ public class DistortionRateController extends BaseController {
distortionRateService.distortionRate(lineParam);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @PostMapping("/distortionRateBySource")
+ @ApiOperation("谐波畸变率排名")
+ @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
+ public HttpResult distortionRateBySource(@RequestBody @Validated LineParam lineParam){
+ log.info(LocalDateTime.now()+"distortionRateBySource开始执行");
+ String methodDescribe = getMethodDescribe("distortionRateBySource");
+ List indexLists = new ArrayList<> ();
+ if(CollectionUtils.isEmpty (lineParam.getLineIds ())){
+ indexLists = lineFeignClient.getLineList ( ).getData ( );
+ }else{
+ indexLists = lineParam.getLineIds ();
+ }
+ lineParam.setLineIds (indexLists);
+
+ distortionRateService.distortionRateBySource (lineParam);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }
+
+
}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/PqsEventdetailController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/PqsEventdetailController.java
new file mode 100644
index 000000000..2858ea90f
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/PqsEventdetailController.java
@@ -0,0 +1,64 @@
+package com.njcn.prepare.harmonic.controller.line;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.device.pq.api.LineFeignClient;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.service.mysql.line.PqsEventdetailHandlerService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.util.CollectionUtils;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/28 13:47【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Slf4j
+@Api(tags = "监测点暂态指标超标明细")
+@RestController
+@RequestMapping("/eventdetail")
+@RequiredArgsConstructor
+public class PqsEventdetailController extends BaseController {
+
+ private final LineFeignClient lineFeignClient;
+
+ private final PqsEventdetailHandlerService pqsEventdetailHandlerService;
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+ @PostMapping("/eventdetailHandler")
+ @ApiOperation("监测点暂态指标处理")
+ @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
+ public HttpResult eventdetailHandler(@RequestBody @Validated LineParam lineParam){
+ log.info(LocalDateTime.now()+"eventdetailHandler始执行");
+ String methodDescribe = getMethodDescribe("eventdetailHandler");
+ List indexLists = new ArrayList<> ();
+ if(CollectionUtils.isEmpty (lineParam.getLineIds ())){
+ indexLists = lineFeignClient.getLineList ( ).getData ( );
+ }else{
+ indexLists = lineParam.getLineIds ();
+ }
+ lineParam.setLineIds (indexLists);
+
+ pqsEventdetailHandlerService.eventdetailHandler (lineParam);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/SteadyIndexExceedController.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/SteadyIndexExceedController.java
new file mode 100644
index 000000000..c3855a219
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/SteadyIndexExceedController.java
@@ -0,0 +1,96 @@
+package com.njcn.prepare.harmonic.controller.line;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.constant.OperateType;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.service.mysql.line.SteadyIndexExceedService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author qijian
+ * @date 2022/12/02
+ * 监测点稳态指标超标明细
+ */
+@Validated
+@Slf4j
+@RestController
+@RequestMapping("/steadyIndexExceed")
+@Api(tags = "监测点稳态指标超标明细")
+@AllArgsConstructor
+public class SteadyIndexExceedController extends BaseController {
+
+ private final SteadyIndexExceedService steadyIndexExceedService;
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+ @PostMapping("/isValueExceedID")
+ @ApiOperation("日统计I、II、III类监测点是否超标限值")
+ @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+ public HttpResult isValueExceedID(@RequestBody @Validated LineParam lineParam) {
+ String methodDescribe = getMethodDescribe("isValueExceedID");
+ boolean res = steadyIndexExceedService.isValueExceedID(lineParam);
+ if(res){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe);
+ }
+
+ }
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+ @PostMapping("/isValueExceedIID")
+ @ApiOperation("日统计I、II类监测点是否超标限值")
+ @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+ public HttpResult isValueExceedIID(@RequestBody @Validated LineParam lineParam) {
+ String methodDescribe = getMethodDescribe("isValueExceedIID");
+ boolean res = steadyIndexExceedService.isValueExceedIID(lineParam);
+ if(res){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe);
+ }
+
+ }
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+ @PostMapping("/isValueExceedIM")
+ @ApiOperation("月统计I、II、III类监测点是否超标限值")
+ @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+ public HttpResult isValueExceedIM(@RequestBody @Validated LineParam lineParam) {
+ String methodDescribe = getMethodDescribe("isValueExceedIM");
+ boolean res = steadyIndexExceedService.isValueExceedIM(lineParam);
+ if(res){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe);
+ }
+ }
+
+ @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+ @PostMapping("/isValueExceedIIM")
+ @ApiOperation("月统计I、II类监测点是否超标限值")
+ @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+ public HttpResult isValueExceedIIM(@RequestBody @Validated LineParam lineParam) {
+ String methodDescribe = getMethodDescribe("isValueExceedIIM");
+ boolean res = steadyIndexExceedService.isValueExceedIIM(lineParam);
+ if(res){
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }else {
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe);
+ }
+
+ }
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PmsMonitorPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PmsMonitorPOMapper.java
new file mode 100644
index 000000000..3f43155da
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PmsMonitorPOMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.PmsMonitorPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/25 10:10【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface PmsMonitorPOMapper extends BaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PmsTerminalPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PmsTerminalPOMapper.java
new file mode 100644
index 000000000..173f6cab2
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PmsTerminalPOMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.PmsTerminalPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/25 10:11【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface PmsTerminalPOMapper extends BaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PqsEventdetailMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PqsEventdetailMapper.java
new file mode 100644
index 000000000..921bbdac5
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/PqsEventdetailMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.oracle.PqsEventdetailPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/28 13:46【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface PqsEventdetailMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpDevEvaluateDetailPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpDevEvaluateDetailPOMapper.java
new file mode 100644
index 000000000..4b3d10a11
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpDevEvaluateDetailPOMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RMpDevEvaluateDetailPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/1 9:18【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RMpDevEvaluateDetailPOMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpIntegrityDPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpIntegrityDPOMapper.java
new file mode 100644
index 000000000..f5944899c
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpIntegrityDPOMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.RMpIntegrityDPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/25 14:33【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RMpIntegrityDPOMapper extends BaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpTargetWarnDMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpTargetWarnDMapper.java
new file mode 100644
index 000000000..d6a682846
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RMpTargetWarnDMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RMpTargetWarnDPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/15 11:00【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RMpTargetWarnDMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexDPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexDPOMapper.java
new file mode 100644
index 000000000..41c297b0d
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexDPOMapper.java
@@ -0,0 +1,19 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.ROperatingIndexDPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/25 10:01【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface ROperatingIndexDPOMapper extends MppBaseMapper {
+
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexMPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexMPOMapper.java
new file mode 100644
index 000000000..b38ec550f
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexMPOMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.ROperatingIndexMPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/30 13:59【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface ROperatingIndexMPOMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexQPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexQPOMapper.java
new file mode 100644
index 000000000..2460fa015
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexQPOMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.ROperatingIndexQPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/30 15:58【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface ROperatingIndexQPOMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexYPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexYPOMapper.java
new file mode 100644
index 000000000..7d01d512d
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/ROperatingIndexYPOMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.ROperatingIndexYPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/30 15:58【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface ROperatingIndexYPOMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatAbnormalDPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatAbnormalDPOMapper.java
new file mode 100644
index 000000000..d706167b2
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatAbnormalDPOMapper.java
@@ -0,0 +1,17 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RStatAbnormalDPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/11/28 19:31【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RStatAbnormalDPOMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatOrgDMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatOrgDMapper.java
new file mode 100644
index 000000000..be60d3c48
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatOrgDMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RStatOrgDPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/13 15:39【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RStatOrgDMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatOrgMMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatOrgMMapper.java
new file mode 100644
index 000000000..133e03ec3
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/RStatOrgMMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.area;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RStatOrgMPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/14 16:17【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RStatOrgMMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/PqsEventdetailMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/PqsEventdetailMapper.xml
new file mode 100644
index 000000000..2567b4ef5
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/PqsEventdetailMapper.xml
@@ -0,0 +1,37 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ EVENTDETAIL_INDEX, LINEID, TIMEID, MS, "DESCRIBE", WAVETYPE, PERSISTTIME, EVENTVALUE,
+ EVENTREASON, EVENTTYPE, EVENTASS_INDEX, DQTIME, DEALTIME, DEALFLAG, NUM, FILEFLAG,
+ FIRSTTIME, FIRSTTYPE, FIRSTMS, WAVENAME, ENERGY, SEVERITY, SAGSOURCE
+
+
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RMpDevEvaluateDetailPOMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RMpDevEvaluateDetailPOMapper.xml
new file mode 100644
index 000000000..9cdb25a16
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RMpDevEvaluateDetailPOMapper.xml
@@ -0,0 +1,18 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ data_date, device_id, dev_target_rate, dev_data_rate, dev_score, dev_effective_rate
+
+
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RMpTargetWarnDMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RMpTargetWarnDMapper.xml
new file mode 100644
index 000000000..8f1237fd7
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RMpTargetWarnDMapper.xml
@@ -0,0 +1,26 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ measurement_point_id, data_date, is_effective, is_harmonic, is_event, is_warn, is_v_dev_warn,
+ is_freq_warn, is_unbalance_warn, is_v_warn, is_flicker_warn, is_sag_warn, is_interrupt_warn
+
+
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexMPOMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexMPOMapper.xml
new file mode 100644
index 000000000..feb44edae
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexMPOMapper.xml
@@ -0,0 +1,27 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ org_no, data_date, measurement_run_points, transit_measurement_points, effective_access_measurement_count,
+ online_measurement_points, online_measurement_count, should_count, should_point_coverage,
+ data_integrity_rate, data_right_rate, index_integrity_rate, is_unusual
+
+
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexQPOMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexQPOMapper.xml
new file mode 100644
index 000000000..02fadbc05
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexQPOMapper.xml
@@ -0,0 +1,27 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ org_no, data_date, measurement_run_points, transit_measurement_points, effective_access_measurement_count,
+ online_measurement_points, online_measurement_count, should_count, should_point_coverage,
+ data_integrity_rate, data_right_rate, index_integrity_rate, is_unusual
+
+
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexYPOMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexYPOMapper.xml
new file mode 100644
index 000000000..3456db268
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/ROperatingIndexYPOMapper.xml
@@ -0,0 +1,27 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ org_no, data_date, measurement_run_points, transit_measurement_points, effective_access_measurement_count,
+ online_measurement_points, online_measurement_count, should_count, should_point_coverage,
+ data_integrity_rate, data_right_rate, index_integrity_rate, is_unusual
+
+
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RStatOrgDMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RStatOrgDMapper.xml
new file mode 100644
index 000000000..bffed23a1
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RStatOrgDMapper.xml
@@ -0,0 +1,24 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ org_no, data_date, measurement_type_class, data_type, all_count, effective_measurement,
+ harmonic_measurement, event_measurement, event_count, should_count, warn_count
+
+
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RStatOrgMMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RStatOrgMMapper.xml
new file mode 100644
index 000000000..6f13fe981
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/area/mapping/RStatOrgMMapper.xml
@@ -0,0 +1,37 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ org_no, data_date, measurement_type_class, all_count, effective_measurement_average,
+ effective_measurement_accrued, harmonic_measurement_average, harmonic_measurement_accrued,
+ harmonic_measurement_ratio_average, over_day_accrued, freq_pass_rate, v_dev_pass_rate,
+ flicker_pass_rate, event_measurement_average, event_measurement_accrued, event_measurement_ratio_average,
+ event_freq, event_count, should_count, warn_count, data_type
+
+
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/PmsAbnormalRulesMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/PmsAbnormalRulesMapper.java
new file mode 100644
index 000000000..e725138ab
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/PmsAbnormalRulesMapper.java
@@ -0,0 +1,13 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.device.pq.pojo.po.PmsAbnormalRules;
+
+/**
+ * PmsAbnormalRulesMapper
+ *
+ * @author qijian
+ * @date 2022/10/26
+ */
+public interface PmsAbnormalRulesMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailDMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailDMapper.java
new file mode 100644
index 000000000..7acad9319
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailDMapper.java
@@ -0,0 +1,27 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RMpEventDetailDPO;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/28 14:58【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RMpEventDetailDMapper extends MppBaseMapper {
+
+ int getSagTimes(@Param("lineId") String lineId, @Param("date") LocalDate date);
+
+ int getInterruptTimes(@Param("lineId") String lineId, @Param("date") LocalDate date);
+
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailMMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailMMapper.java
new file mode 100644
index 000000000..4798fb930
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailMMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RMpEventDetailMPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/28 14:58【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RMpEventDetailMMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailQMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailQMapper.java
new file mode 100644
index 000000000..7994bfa33
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailQMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RMpEventDetailQPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/28 14:58【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RMpEventDetailQMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailYMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailYMapper.java
new file mode 100644
index 000000000..cdecfa6ee
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpEventDetailYMapper.java
@@ -0,0 +1,18 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RMpEventDetailYPO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * Description:
+ * 接口文档访问地址:http://serverIP:port/swagger-ui.html
+ * Date: 2022/12/28 14:58【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Mapper
+public interface RMpEventDetailYMapper extends MppBaseMapper {
+}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpHarmonicVRateReportDPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpHarmonicVRateReportDPOMapper.java
index c99f4fe08..ee75fbda5 100644
--- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpHarmonicVRateReportDPOMapper.java
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpHarmonicVRateReportDPOMapper.java
@@ -2,6 +2,9 @@ package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.harmonic.pojo.po.RMpHarmonicVRateReportD;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDate;
/**
*
@@ -13,4 +16,7 @@ import com.njcn.harmonic.pojo.po.RMpHarmonicVRateReportD;
* @version V1.0.0
*/
public interface RMpHarmonicVRateReportDPOMapper extends MppBaseMapper {
+
+ double getMaxVoltageHarmonicThd95(@Param("lineId") String lineId, @Param("date") LocalDate date);
+
}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpIntegrityDMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpIntegrityDMapper.java
new file mode 100644
index 000000000..75e9898b0
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpIntegrityDMapper.java
@@ -0,0 +1,14 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.device.pq.pojo.po.RMpIntegrityD;
+
+/**
+ * RMpIntegrityDMapper
+ *
+ * @author qijian
+ * @date 2022/10/26
+ */
+public interface RMpIntegrityDMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasurePhaseReportDPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasurePhaseReportDPOMapper.java
index 84b3f2f44..3c7a5019d 100644
--- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasurePhaseReportDPOMapper.java
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasurePhaseReportDPOMapper.java
@@ -2,9 +2,12 @@ package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.harmonic.pojo.po.RMpMeasurePhaseReportD;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDate;
/**
- *
+ *
* Description:
* 接口文档访问地址:http://serverIP:port/swagger-ui.html
* Date: 2022/10/28 10:53【需求编号】
@@ -13,4 +16,6 @@ import com.njcn.harmonic.pojo.po.RMpMeasurePhaseReportD;
* @version V1.0.0
*/
public interface RMpMeasurePhaseReportDPOMapper extends MppBaseMapper {
+
+ double getMaxVDeUp(@Param("lineId") String lineId, @Param("date") LocalDate date);
}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasureReportDPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasureReportDPOMapper.java
index c38b58f38..c76b210bf 100644
--- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasureReportDPOMapper.java
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasureReportDPOMapper.java
@@ -2,6 +2,9 @@ package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.harmonic.pojo.po.RMpMeasureReportD;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDate;
/**
*
@@ -13,4 +16,8 @@ import com.njcn.harmonic.pojo.po.RMpMeasureReportD;
* @version V1.0.0
*/
public interface RMpMeasureReportDPOMapper extends MppBaseMapper {
+
+ double getMaxFrequencyDeviation(@Param("lineId") String lineId, @Param("date") LocalDate date);
+
+ double getMaxUnbalance95(@Param("lineId") String lineId, @Param("date") LocalDate date);
}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPartHarmonicDetailDMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPartHarmonicDetailDMapper.java
new file mode 100644
index 000000000..88ac204da
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPartHarmonicDetailDMapper.java
@@ -0,0 +1,20 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailD;
+import com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailM;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDate;
+
+/**
+ * RMpPartHarmonicDetailDMapper
+ *
+ * @author qijian
+ * @version 1.0.0
+ * @createTime 2022/12/5 - 15:21
+ */
+public interface RMpPartHarmonicDetailDMapper extends BaseMapper {
+
+ RMpPartHarmonicDetailM getPartSumByData(@Param("lineId") String lineId, @Param("startTime") LocalDate startTime, @Param("endTime") LocalDate endTime);
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPartHarmonicDetailMMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPartHarmonicDetailMMapper.java
new file mode 100644
index 000000000..a30fafdde
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPartHarmonicDetailMMapper.java
@@ -0,0 +1,15 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailM;
+
+/**
+ * RMpPartHarmonicDetailMMapper
+ *
+ * @author qijian
+ * @version 1.0.0
+ * @createTime 2022/12/12 - 15:21
+ */
+public interface RMpPartHarmonicDetailMMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPltReportDPOMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPltReportDPOMapper.java
index 4d448eb96..264a78cd5 100644
--- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPltReportDPOMapper.java
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPltReportDPOMapper.java
@@ -2,6 +2,9 @@ package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPltReportDPO;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDate;
/**
*
@@ -13,4 +16,7 @@ import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPltReportDPO;
* @version V1.0.0
*/
public interface RMpPltReportDPOMapper extends MppBaseMapper {
+
+ double getMaxFlashing(@Param("lineId") String lineId, @Param("date") LocalDate date);
+
}
\ No newline at end of file
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpSurplusHarmonicDetailDMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpSurplusHarmonicDetailDMapper.java
new file mode 100644
index 000000000..3ad681390
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpSurplusHarmonicDetailDMapper.java
@@ -0,0 +1,20 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.RMpSurplusHarmonicDetailD;
+import com.njcn.harmonic.pojo.po.RMpSurplusHarmonicDetailM;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDate;
+
+/**
+ * RMpSurplusHarmonicDetailDMapper
+ *
+ * @author qijian
+ * @version 1.0.0
+ * @createTime 2022/12/8 - 15:21
+ */
+public interface RMpSurplusHarmonicDetailDMapper extends BaseMapper {
+
+ RMpSurplusHarmonicDetailM getSurplusSumByData(@Param("lineId") String lineId, @Param("startTime") LocalDate startTime, @Param("endTime") LocalDate endTime);
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpSurplusHarmonicDetailMMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpSurplusHarmonicDetailMMapper.java
new file mode 100644
index 000000000..e3f824a66
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpSurplusHarmonicDetailMMapper.java
@@ -0,0 +1,15 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.harmonic.pojo.po.RMpSurplusHarmonicDetailM;
+
+/**
+ * RMpSurplusHarmonicDetailMMapper
+ *
+ * @author qijian
+ * @version 1.0.0
+ * @createTime 2022/12/12 - 15:21
+ */
+public interface RMpSurplusHarmonicDetailMMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatAbnormalDMapper.java b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatAbnormalDMapper.java
new file mode 100644
index 000000000..2e0f6780e
--- /dev/null
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatAbnormalDMapper.java
@@ -0,0 +1,14 @@
+package com.njcn.prepare.harmonic.mapper.mysql.line;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.device.pq.pojo.po.RStatAbnormalD;
+
+/**
+ * RStatAbnormalDMapper
+ *
+ * @author qijian
+ * @date 2022/10/26
+ */
+public interface RStatAbnormalDMapper extends BaseMapper {
+
+}
diff --git a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ExcelRptTempMapper.xml b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ExcelRptTempMapper.xml
index 45722ab87..dff7c3e7f 100644
--- a/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ExcelRptTempMapper.xml
+++ b/pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ExcelRptTempMapper.xml
@@ -2,7 +2,7 @@
-