From 58bbe3419c8c7b120f13d9b9003f251e8b052987 Mon Sep 17 00:00:00 2001 From: hongawen <83944980@qq.com> Date: Tue, 6 Jun 2023 19:28:10 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96=E9=A1=B9=E7=9B=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .gitignore | 29 +- pom.xml | 150 ++ .../njcn/syncdata/HBSyncDataApplication.java | 21 + .../RDisMpMeasurePhaseReportDMapper.java | 16 + .../pojo/po/RDisMpMeasurePhaseReportD.java | 1441 +++++++++++++++++ .../IRDisMpMeasurePhaseReportDService.java | 19 + .../RDisMpMeasurePhaseReportDServiceImpl.java | 23 + src/main/resources/application.yml | 51 + src/main/resources/logback.xml | 141 ++ src/test/java/com/hongawen/BaseJunitTest.java | 18 + src/test/java/com/hongawen/TestMybatis.java | 53 + 11 files changed, 1958 insertions(+), 4 deletions(-) create mode 100644 pom.xml create mode 100644 src/main/java/com/njcn/syncdata/HBSyncDataApplication.java create mode 100644 src/main/java/com/njcn/syncdata/mapper/RDisMpMeasurePhaseReportDMapper.java create mode 100644 src/main/java/com/njcn/syncdata/pojo/po/RDisMpMeasurePhaseReportD.java create mode 100644 src/main/java/com/njcn/syncdata/service/IRDisMpMeasurePhaseReportDService.java create mode 100644 src/main/java/com/njcn/syncdata/service/impl/RDisMpMeasurePhaseReportDServiceImpl.java create mode 100644 src/main/resources/application.yml create mode 100644 src/main/resources/logback.xml create mode 100644 src/test/java/com/hongawen/BaseJunitTest.java create mode 100644 src/test/java/com/hongawen/TestMybatis.java diff --git a/.gitignore b/.gitignore index 9154f4c..4632c4b 100644 --- a/.gitignore +++ b/.gitignore @@ -1,6 +1,9 @@ -# ---> Java # Compiled class file *.class +*.iml +*.idea +target/ +logs/ # Log file *.log @@ -14,13 +17,31 @@ # Package Files # *.jar *.war -*.nar *.ear -*.zip *.tar.gz *.rar # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml hs_err_pid* -replay_pid* +*velocity.log* + +# Eclipse # +.classpath +.project +.settings/ + +.DS_Store + +_dockerCerts/ + +.factorypath + +node_modules/ +package-lock.json +yarn.lock + +rebel.xml + +!DmJdbcDriver18.jar +!kingbase8-8.6.0.jar \ No newline at end of file diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..dc5d1ed --- /dev/null +++ b/pom.xml @@ -0,0 +1,150 @@ + + + + org.springframework.boot + spring-boot-starter-parent + 2.2.2.RELEASE + + + 4.0.0 + + com.njcn + hb-sync-data + 1.0.0 + + jar + 河北数据同步项目 + + + + nexus-releases + Nexus Release Repository + http://192.168.1.13:8001/nexus/content/repositories/releases/ + + + nexus-snapshots + Nexus Snapshot Repository + http://192.168.1.13:8001/nexus/content/repositories/snapshots/ + + + + + + 192.168.1.13 + + http://${docker.server.url}:2375 + + ${docker.server.url}:8090 + + njcn + install + 1.8 + 8 + 8 + 2.8.0 + 5.7.9 + + + + + org.springframework.boot + spring-boot-starter-web + + + + org.springframework.boot + spring-boot-devtools + runtime + true + + + + + org.projectlombok + lombok + ${lombok.version} + + + + cn.hutool + hutool-all + ${hutool.version} + + + org.springframework.boot + spring-boot-starter-json + + + + + org.springframework.boot + spring-boot-starter-actuator + + + + org.springframework.boot + spring-boot-configuration-processor + true + + + + org.springframework.boot + spring-boot-starter-test + + + + + org.apache.commons + commons-lang3 + ${commons-lang3.version} + + + commons-io + commons-io + ${commons-io.version} + + + commons-codec + commons-codec + ${commons-codec.version} + + + + com.njcn + common-db + ${project.version} + + + com.njcn + common-core + + + com.njcn + common-web + + + + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + org.projectlombok + lombok + + + + + + + + + \ No newline at end of file diff --git a/src/main/java/com/njcn/syncdata/HBSyncDataApplication.java b/src/main/java/com/njcn/syncdata/HBSyncDataApplication.java new file mode 100644 index 0000000..1017f4e --- /dev/null +++ b/src/main/java/com/njcn/syncdata/HBSyncDataApplication.java @@ -0,0 +1,21 @@ +package com.njcn.syncdata; + +import lombok.extern.slf4j.Slf4j; +import org.mybatis.spring.annotation.MapperScan; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2023年06月06日 16:33 + */ +@Slf4j +@MapperScan("com.njcn.**.mapper") +@SpringBootApplication(scanBasePackages = "com.njcn") +public class HBSyncDataApplication { + public static void main(String[] args) { + SpringApplication.run(HBSyncDataApplication.class, args); + } + +} \ No newline at end of file diff --git a/src/main/java/com/njcn/syncdata/mapper/RDisMpMeasurePhaseReportDMapper.java b/src/main/java/com/njcn/syncdata/mapper/RDisMpMeasurePhaseReportDMapper.java new file mode 100644 index 0000000..a0296ec --- /dev/null +++ b/src/main/java/com/njcn/syncdata/mapper/RDisMpMeasurePhaseReportDMapper.java @@ -0,0 +1,16 @@ +package com.njcn.syncdata.mapper; + +import com.njcn.db.mapper.BatchBaseMapper; +import com.njcn.syncdata.pojo.po.RDisMpMeasurePhaseReportD; + +/** + *

+ * Mapper 接口 + *

+ * + * @author hongawen + * @since 2023-05-31 + */ +public interface RDisMpMeasurePhaseReportDMapper extends BatchBaseMapper { + +} diff --git a/src/main/java/com/njcn/syncdata/pojo/po/RDisMpMeasurePhaseReportD.java b/src/main/java/com/njcn/syncdata/pojo/po/RDisMpMeasurePhaseReportD.java new file mode 100644 index 0000000..698ef54 --- /dev/null +++ b/src/main/java/com/njcn/syncdata/pojo/po/RDisMpMeasurePhaseReportD.java @@ -0,0 +1,1441 @@ +package com.njcn.syncdata.pojo.po; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.time.LocalDateTime; + +/** + *

+ * + *

+ * + * @author hongawen + * @since 2023-05-31 + */ +@Data +@TableName(" ") +public class RDisMpMeasurePhaseReportD { + + private static final long serialVersionUID = 1L; + + /** + * 监测点编号 + */ + private String monitorId; + + /** + * 日期 + */ + private LocalDateTime datdate; + + /** + * 有效监测时长 + */ + private int monitoringDuration; + + /** + * 频率-最大值 + */ + private float frequencyMax; + + /** + * 频率-最小值 + */ + private float frequencyMin; + + /** + * 频率-平均值 + */ + private float frequencyAvg; + + /** + * 频率-95值 + */ + @TableField("FREQUENCY_95") + private float frequency95; + + /** + * 频率偏差-最大值 + */ + private float frequencyDeviationMax; + + /** + * 频率偏差-最小值 + */ + private float frequencyDeviationMin; + + /** + * 频率偏差-平均值 + */ + private float frequencyDeviationAvg; + + /** + * 频率偏差-95值 + */ + @TableField("FREQUENCY_DEVIATION_95") + private float frequencyDeviation95; + + /** + * 频率偏差超限时长 + */ + private int frequencyDeviationOverrunDuration; + + /** + * 相电压有效值-最大值 + */ + private float phaseVoltageEffectiveMax; + + /** + * 相电压有效值-最小值 + */ + private float phaseVoltageEffectiveMin; + + /** + * 相电压有效值-平均值 + */ + private float phaseVoltageEffectiveAvg; + + /** + * 相电压有效值-95值 + */ + @TableField("phase_voltage_effective_95") + private float phaseVoltageEffective95; + + /** + * 线电压有效值-最大值 + */ + private float lineVoltageEffectiveMax; + + /** + * 线电压有效值-最小值 + */ + private float lineVoltageEffectiveMin; + + /** + * 线电压有效值-平均值 + */ + private float lineVoltageEffectiveAvg; + + /** + * 线电压有效值-95值 + */ + @TableField("line_voltage_effective_95") + private float lineVoltageEffective95; + + /** + * 电压上偏差-最大值 + */ + private float vDeUpMax; + + /** + * 电压上偏差-最小值 + */ + private float vDeUpMin; + + /** + * 电压上偏差-平均值 + */ + private float vDeUpAvg; + + /** + * 电压上偏差-95值 + */ + @TableField("v_de_up_95") + private float vDeUp95; + + /** + * 电压下偏差-最大值 + */ + private float vDeLowMax; + + /** + * 电压下偏差-最小值 + */ + private float vDeLowMin; + + /** + * 电压下偏差-平均值 + */ + private float vDeLowAvg; + + /** + * 电压下偏差-95值 + */ + @TableField("v_de_low_95") + private float vDeLow95; + + /** + * 电压偏差超限时长 + */ + private int vDeOverrunDuration; + + /** + * 电流有效值-最大值 + */ + private float currentEffectiveMax; + + /** + * 电流有效值-最小值 + */ + private float currentEffectiveMin; + + /** + * 电流有效值-平均值 + */ + private float currentEffectiveAvg; + + /** + * 电流有效值-95值 + */ + @TableField("current_effective_95") + private float currentEffective95; + + /** + * 单相有功功率-最大值 + */ + private float spActivePowerMax; + + /** + * 单相有功功率-最小值 + */ + private float spActivePowerMin; + + /** + * 单相有功功率-平均值 + */ + private float spActivePowerAvg; + + /** + * 单相有功功率-95值 + */ + @TableField("SP_ACTIVE_POWER_95") + private float spActivePower_95; + + /** + * 单相视在功率-最大值 + */ + private float spApparentPowerMax; + + /** + * 单相视在功率-最小值 + */ + private float spApparentPowerMin; + + /** + * 单相视在功率-平均值 + */ + private float spApparentPowerAvg; + + /** + * 单相视在功率-95值 + */ + @TableField("SP_APPARENT_POWER_95") + private float spApparentPower95; + + /** + * 单相无功功率-最大值 + */ + private float spReactivePowerMax; + + /** + * 单相无功功率-最小值 + */ + private float spReactivePowerMin; + + /** + * 单相无功功率-平均值 + */ + private float spReactivePowerAvg; + + /** + * 单相无功功率-95值 + */ + @TableField("SP_REACTIVE_POWER_95") + private float spReactivePower95; + + /** + * 总有功功率-最大值 + */ + private float totalActivePowerMax; + + /** + * 总有功功率-最小值 + */ + private float totalActivePowerMin; + + /** + * 总有功功率-平均值 + */ + private float totalActivePowerAvg; + + /** + * 总有功功率-95值 + */ + @TableField("TOTAL_ACTIVE_POWER_95") + private float totalActivePower_95; + + /** + * 总视在功率-最大值 + */ + private float totalApparentPowerMax; + + /** + * 总视在功率-最小值 + */ + private float totalApparentPowerMin; + + /** + * 总视在功率-平均值 + */ + private float totalApparentPowerAvg; + + /** + * 总视在功率-95值 + */ + @TableField("TOTAL_APPARENT_POWER_95") + private float totalApparentPower95; + + /** + * 总无功功率-最大值 + */ + private float totalReactivePowerMax; + + /** + * 总无功功率-最小值 + */ + private float totalReactivePowerMin; + + /** + * 总无功功率-平均值 + */ + private float totalReactivePowerAvg; + + /** + * 总无功功率-95值 + */ + @TableField("TOTAL_REACTIVE_POWER_95") + private float totalReactivePower95; + + /** + * 三相功率因数-平均值 + */ + private float tpPowerFactorAvg; + + /** + * 相（线）电压基波有效值-最大值 + */ + private float fundamentalVoltageMax; + + /** + * 相（线）电压基波有效值-最小值 + */ + private float fundamentalVoltageMin; + + /** + * 相（线）电压基波有效值-平均值 + */ + private float fundamentalVoltageAvg; + + /** + * 相（线）电压基波有效值-95值 + */ + @TableField("FUNDAMENTAL_VOLTAGE_95") + private float fundamentalVoltage95; + + /** + * 基波电流-最大值 + */ + private float fundamentalCurrentMax; + + /** + * 基波电流-最小值 + */ + private float fundamentalCurrentMin; + + /** + * 基波电流-平均值 + */ + private float fundamentalCurrentAvg; + + /** + * 基波电流-95值 + */ + @TableField("FUNDAMENTAL_CURRENT_95") + private float fundamentalCurrent95; + + /** + * 基波有功功率-最大值 + */ + private float fundamentalActivePowerMax; + + /** + * 基波有功功率-最小值 + */ + private float fundamentalActivePowerMin; + + /** + * 基波有功功率-平均值 + */ + private float fundamentalActivePowerAvg; + + /** + * 基波有功功率-95值 + */ + @TableField("FUNDAMENTAL_ACTIVE_POWER_95") + private float fundamentalActivePower_95; + + /** + * 基波无功功率-最大值 + */ + private float fundamentalRateofworkMax; + + /** + * 基波无功功率-最小值 + */ + private float fundamentalRateofworkMin; + + /** + * 基波无功功率-平均值 + */ + private float fundamentalRateofworkAvg; + + /** + * 基波无功功率-95值 + */ + @TableField("FUNDAMENTAL_RATEOFWORK_95") + private float fundamentalRateofwork95; + + /** + * 单相基波功率因数-最大值 + */ + private float spFundamentalPowerFactorMax; + + /** + * 单相基波功率因数-最小值 + */ + private float spFundamentalPowerFactorMin; + + /** + * 单相基波功率因数-平均值 + */ + private float spFundamentalPowerFactorAvg; + + /** + * 单相基波功率因数-95值 + */ + @TableField("SP_FUNDAMENTAL_POWER_FACTOR_95") + private float spFundamentalPowerFactor95; + + /** + * 基波功率因数-最大值 + */ + private float fundamentalPowerFactorMax; + + /** + * 基波功率因数-最小值 + */ + private float fundamentalPowerFactorMin; + + /** + * 基波功率因数-平均值 + */ + private float fundamentalPowerFactorAvg; + + /** + * 基波功率因数-95值 + */ + @TableField("FUNDAMENTAL_POWER_FACTOR_95") + private float fundamentalPowerFactor95; + + /** + * 电压总谐波畸变率-最大值 + */ + private float voltageHarmonicWaveMax; + + /** + * 电压总谐波畸变率-最小值 + */ + private float voltageHarmonicWaveMin; + + /** + * 电压总谐波畸变率-平均值 + */ + private float voltageHarmonicWaveAvg; + + /** + * 电压总谐波畸变率-95值 + */ + @TableField("voltage_harmonic_wave_95") + private float voltageHarmonicWave95; + + /** + * 2次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_2Max; + + /** + * 2次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_2Min; + + /** + * 2次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_2Avg; + + /** + * 2次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_2_95") + private float harmonicVoltageContent_295; + + /** + * 3次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_3Max; + + /** + * 3次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_3Min; + + /** + * 3次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_3Avg; + + /** + * 3次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_3_95") + private float harmonicVoltageContent_395; + + /** + * 4次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_4Max; + + /** + * 4次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_4Min; + + /** + * 4次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_4Avg; + + /** + * 4次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_4_95") + private float harmonicVoltageContent_495; + + /** + * 5次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_5Max; + + /** + * 5次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_5Min; + + /** + * 5次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_5Avg; + + /** + * 5次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_5_95") + private float harmonicVoltageContent_595; + + /** + * 6次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_6Max; + + /** + * 6次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_6Min; + + /** + * 6次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_6Avg; + + /** + * 6次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_6_95") + private float harmonicVoltageContent_695; + + /** + * 7次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_7Max; + + /** + * 7次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_7Min; + + /** + * 7次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_7Avg; + + /** + * 7次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_7_95") + private float harmonicVoltageContent_795; + + /** + * 8次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_8Max; + + /** + * 8次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_8Min; + + /** + * 8次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_8Avg; + + /** + * 8次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_8_95") + private float harmonicVoltageContent_895; + + /** + * 9次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_9Max; + + /** + * 9次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_9Min; + + /** + * 9次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_9Avg; + + /** + * 9次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_9_95") + private float harmonicVoltageContent_995; + + /** + * 10次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_10Max; + + /** + * 10次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_10Min; + + /** + * 10次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_10Avg; + + /** + * 10次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_10_95") + private float harmonicVoltageContent_1095; + + /** + * 11次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_11Max; + + /** + * 11次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_11Min; + + /** + * 11次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_11Avg; + + /** + * 11次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_11_95") + private float harmonicVoltageContent_1195; + + /** + * 12次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_12Max; + + /** + * 12次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_12Min; + + /** + * 12次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_12Avg; + + /** + * 12次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_12_95") + private float harmonicVoltageContent_1295; + + /** + * 13次谐波电压含有率-最大值 + */ + private float harmonicVoltageContent_13Max; + + /** + * 13次谐波电压含有率-最小值 + */ + private float harmonicVoltageContent_13Min; + + /** + * 13次谐波电压含有率-平均值 + */ + private float harmonicVoltageContent_13Avg; + + /** + * 13次谐波电压含有率-95值 + */ + @TableField("HARMONIC_VOLTAGE_CONTENT_13_95") + private float harmonicVoltageContent_1395; + + /** + * 2次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_2Max; + + /** + * 2次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_2Min; + + /** + * 2次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_2Avg; + + /** + * 2次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_2_95") + private float harmonicCurrentEffective_295; + + /** + * 3次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_3Max; + + /** + * 3次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_3Min; + + /** + * 3次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_3Avg; + + /** + * 3次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_3_95") + private float harmonicCurrentEffective_395; + + /** + * 4次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_4Max; + + /** + * 4次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_4Min; + + /** + * 4次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_4Avg; + + /** + * 4次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_4_95") + private float harmonicCurrentEffective_495; + + /** + * 5次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_5Max; + + /** + * 5次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_5Min; + + /** + * 5次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_5Avg; + + /** + * 5次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_5_95") + private float harmonicCurrentEffective_595; + + /** + * 6次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_6Max; + + /** + * 6次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_6Min; + + /** + * 6次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_6Avg; + + /** + * 6次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_6_95") + private float harmonicCurrentEffective_695; + + /** + * 7次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_7Max; + + /** + * 7次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_7Min; + + /** + * 7次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_7Avg; + + /** + * 7次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_7_95") + private float harmonicCurrentEffective_795; + + /** + * 8次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_8Max; + + /** + * 8次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_8Min; + + /** + * 8次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_8Avg; + + /** + * 8次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_8_95") + private float harmonicCurrentEffective_895; + + /** + * 9次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_9Max; + + /** + * 9次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_9Min; + + /** + * 9次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_9Avg; + + /** + * 9次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_9_95") + private float harmonicCurrentEffective_995; + + /** + * 10次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_10Max; + + /** + * 10次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_10Min; + + /** + * 10次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_10Avg; + + /** + * 10次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_10_95") + private float harmonicCurrentEffective_1095; + + /** + * 11次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_11Max; + + /** + * 11次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_11Min; + + /** + * 11次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_11Avg; + + /** + * 11次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_11_95") + private float harmonicCurrentEffective_1195; + + /** + * 12次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_12Max; + + /** + * 12次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_12Min; + + /** + * 12次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_12Avg; + + /** + * 12次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_12_95") + private float harmonicCurrentEffective_1295; + + /** + * 13次谐波电流有效值-最大值 + */ + private float harmonicCurrentEffective_13Max; + + /** + * 13次谐波电流有效值-最小值 + */ + private float harmonicCurrentEffective_13Min; + + /** + * 13次谐波电流有效值-平均值 + */ + private float harmonicCurrentEffective_13Avg; + + /** + * 13次谐波电流有效值-95值 + */ + @TableField("harmonic_current_effective_13_95") + private float harmonicCurrentEffective_1395; + + /** + * 2次谐波有功功率-最大值 + */ + private float harmonicActivePower_2Max; + + /** + * 2次谐波有功功率-最小值 + */ + private float harmonicActivePower_2Min; + + /** + * 2次谐波有功功率-平均值 + */ + private float harmonicActivePower_2Avg; + + /** + * 2次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_2_95") + private float harmonicActivePower_295; + + /** + * 3次谐波有功功率-最大值 + */ + private float harmonicActivePower_3Max; + + /** + * 3次谐波有功功率-最小值 + */ + private float harmonicActivePower_3Min; + + /** + * 3次谐波有功功率-平均值 + */ + private float harmonicActivePower_3Avg; + + /** + * 3次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_3_95") + private float harmonicActivePower_395; + + /** + * 4次谐波有功功率-最大值 + */ + private float harmonicActivePower_4Max; + + /** + * 4次谐波有功功率-最小值 + */ + private float harmonicActivePower_4Min; + + /** + * 4次谐波有功功率-平均值 + */ + private float harmonicActivePower_4Avg; + + /** + * 4次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_4_95") + private float harmonicActivePower_495; + + /** + * 5次谐波有功功率-最大值 + */ + private float harmonicActivePower_5Max; + + /** + * 5次谐波有功功率-最小值 + */ + private float harmonicActivePower_5Min; + + /** + * 5次谐波有功功率-平均值 + */ + private float harmonicActivePower_5Avg; + + /** + * 5次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_5_95") + private float harmonicActivePower_595; + + /** + * 6次谐波有功功率-最大值 + */ + private float harmonicActivePower_6Max; + + /** + * 6次谐波有功功率-最小值 + */ + private float harmonicActivePower_6Min; + + /** + * 6次谐波有功功率-平均值 + */ + private float harmonicActivePower_6Avg; + + /** + * 6次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_6_95") + private float harmonicActivePower_695; + + /** + * 7次谐波有功功率-最大值 + */ + private float harmonicActivePower_7Max; + + /** + * 7次谐波有功功率-最小值 + */ + private float harmonicActivePower_7Min; + + /** + * 7次谐波有功功率-平均值 + */ + private float harmonicActivePower_7Avg; + + /** + * 7次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_7_95") + private float harmonicActivePower_795; + + /** + * 8次谐波有功功率-最大值 + */ + private float harmonicActivePower_8Max; + + /** + * 8次谐波有功功率-最小值 + */ + private float harmonicActivePower_8Min; + + /** + * 8次谐波有功功率-平均值 + */ + private float harmonicActivePower_8Avg; + + /** + * 8次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_8_95") + private float harmonicActivePower_895; + + /** + * 9次谐波有功功率-最大值 + */ + private float harmonicActivePower_9Max; + + /** + * 9次谐波有功功率-最小值 + */ + private float harmonicActivePower_9Min; + + /** + * 9次谐波有功功率-平均值 + */ + private float harmonicActivePower_9Avg; + + /** + * 9次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_9_95") + private float harmonicActivePower_995; + + /** + * 10次谐波有功功率-最大值 + */ + private float harmonicActivePower_10Max; + + /** + * 10次谐波有功功率-最小值 + */ + private float harmonicActivePower_10Min; + + /** + * 10次谐波有功功率-平均值 + */ + private float harmonicActivePower_10Avg; + + /** + * 10次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_10_95") + private float harmonicActivePower_1095; + + /** + * 11次谐波有功功率-最大值 + */ + private float harmonicActivePower_11Max; + + /** + * 11次谐波有功功率-最小值 + */ + private float harmonicActivePower_11Min; + + /** + * 11次谐波有功功率-平均值 + */ + private float harmonicActivePower_11Avg; + + /** + * 11次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_11_95") + private float harmonicActivePower_1195; + + /** + * 12次谐波有功功率-最大值 + */ + private float harmonicActivePower_12Max; + + /** + * 12次谐波有功功率-最小值 + */ + private float harmonicActivePower_12Min; + + /** + * 12次谐波有功功率-平均值 + */ + private float harmonicActivePower_12Avg; + + /** + * 12次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_12_95") + private float harmonicActivePower_1295; + + /** + * 13次谐波有功功率-最大值 + */ + private float harmonicActivePower_13Max; + + /** + * 13次谐波有功功率-最小值 + */ + private float harmonicActivePower_13Min; + + /** + * 13次谐波有功功率-平均值 + */ + private float harmonicActivePower_13Avg; + + /** + * 13次谐波有功功率-95值 + */ + @TableField("HARMONIC_ACTIVE_POWER_13_95") + private float harmonicActivePower_1395; + + /** + * 正序电压-最大值 + */ + private float positiveSequenceVoltageMax; + + /** + * 正序电压-最小值 + */ + private float positiveSequenceVoltageMin; + + /** + * 正序电压-平均值 + */ + private float positiveSequenceVoltageAvg; + + /** + * 正序电压-95值 + */ + @TableField("POSITIVE_SEQUENCE_VOLTAGE_95") + private float positiveSequenceVoltage95; + + /** + * 负序电压-最大值 + */ + private float negativeSequenceVoltageMax; + + /** + * 负序电压-最小值 + */ + private float negativeSequenceVoltageMin; + + /** + * 负序电压-平均值 + */ + private float negativeSequenceVoltageAvg; + + /** + * 负序电压-95值 + */ + @TableField("NEGATIVE_SEQUENCE_VOLTAGE_95") + private float negativeSequenceVoltage95; + + /** + * 零序电压-最大值 + */ + private float zeroSequenceVoltageMax; + + /** + * 零序电压-最小值 + */ + private float zeroSequenceVoltageMin; + + /** + * 零序电压-平均值 + */ + private float zeroSequenceVoltageAvg; + + /** + * 零序电压-95值 + */ + @TableField("ZERO_SEQUENCE_VOLTAGE_95") + private float zeroSequenceVoltage95; + + /** + * 负序电压不平衡度-最大值 + */ + private float negativeSequenceVoltageUnbalanceMax; + + /** + * 负序电压不平衡度-最小值 + */ + private float negativeSequenceVoltageUnbalanceMin; + + /** + * 负序电压不平衡度-平均值 + */ + private float negativeSequenceVoltageUnbalanceAvg; + + /** + * 负序电压不平衡度-95值 + */ + @TableField("NEGATIVE_SEQUENCE_VOLTAGE_UNBALANCE_95") + private float negativeSequenceVoltageUnbalance95; + + /** + * 零序电压不平衡度-最大值 + */ + private float zeroSequenceVoltageImbalanceMax; + + /** + * 零序电压不平衡度-最小值 + */ + private float zeroSequenceVoltageImbalanceMin; + + /** + * 零序电压不平衡度-平均值 + */ + private float zeroSequenceVoltageImbalanceAvg; + + /** + * 零序电压不平衡度-95值 + */ + @TableField("ZERO_SEQUENCE_VOLTAGE_IMBALANCE_95") + private float zeroSequenceVoltageImbalance95; + + /** + * 负序电流不平衡度-最大值 + */ + private float negativeSequenceCurrentUnbalanceMax; + + /** + * 负序电流不平衡度-最小值 + */ + private float negativeSequenceCurrentUnbalanceMin; + + /** + * 负序电流不平衡度-平均值 + */ + private float negativeSequenceCurrentUnbalanceAvg; + + /** + * 负序电流不平衡度-95值 + */ + @TableField("NEGATIVE_SEQUENCE_CURRENT_UNBALANCE_95") + private float negativeSequenceCurrentUnbalance95; + + /** + * 零序电流不平衡度-最大值 + */ + private float zeroSequenceCurrentImbalanceMax; + + /** + * 零序电流不平衡度-最小值 + */ + private float zeroSequenceCurrentImbalanceMin; + + /** + * 零序电流不平衡度-平均值 + */ + private float zeroSequenceCurrentImbalanceAvg; + + /** + * 零序电流不平衡度-95值 + */ + @TableField("ZERO_SEQUENCE_CURRENT_IMBALANCE_95") + private float zeroSequenceCurrentImbalance95; + + /** + * 台区潮流倒送负载率-最大值 + */ + private float flowBackflowOverloadLoadrateMax; + + /** + * 台区潮流倒送负载率-最小值 + */ + private float flowBackflowOverloadLoadrateMin; + + /** + * 台区潮流倒送负载率-平均值 + */ + private float flowBackflowOverloadLoadrateAvg; + + /** + * 台区潮流倒送负载率-95值 + */ + @TableField("Flow_backflow_overload_loadrate_95") + private float flowBackflowOverloadLoadrate95; + + /** + * 谐波电压超限时长 + */ + private int harmonicVoltageOverrunDuration; + + /** + * 三相电压不平衡度超限时长 + */ + private int tpVoltageUnbalanceOverrunDuration; + + /** + * 台区电压越上限（7%-15%）时长 + */ + @TableField("VOLTAGE_overrun_7_15_up_duration") + private int voltageOverrun715UpDuration; + + /** + * 台区电压越上限（15%及以上）时长 + */ + @TableField("VOLTAGE_overrun_15_up_duration") + private int voltageOverrun15UpDuration; + + /** + * 台区电压越下限时长 + */ + @TableField("VOLTAGE_overrun_down_duration") + private int voltageOverrunDownDuration; + + /** + * 台区潮流倒送时长 + */ + private int reversedDuration; + + /** + * 日应收五项指标分钟平均值数量 + */ + private int receivableTargetNum; + + /** + * 日实收五项指标分钟平均值数量 + */ + private int practicalTargetNum; + + +} diff --git a/src/main/java/com/njcn/syncdata/service/IRDisMpMeasurePhaseReportDService.java b/src/main/java/com/njcn/syncdata/service/IRDisMpMeasurePhaseReportDService.java new file mode 100644 index 0000000..1312f70 --- /dev/null +++ b/src/main/java/com/njcn/syncdata/service/IRDisMpMeasurePhaseReportDService.java @@ -0,0 +1,19 @@ +package com.njcn.syncdata.service; + + +import com.njcn.db.service.IReplenishMybatisService; +import com.njcn.syncdata.pojo.po.RDisMpMeasurePhaseReportD; + +import java.util.List; + +/** + *

+ * 服务类 + *

+ * + * @author hongawen + * @since 2023-05-31 + */ +public interface IRDisMpMeasurePhaseReportDService extends IReplenishMybatisService { + +} diff --git a/src/main/java/com/njcn/syncdata/service/impl/RDisMpMeasurePhaseReportDServiceImpl.java b/src/main/java/com/njcn/syncdata/service/impl/RDisMpMeasurePhaseReportDServiceImpl.java new file mode 100644 index 0000000..7b27f6c --- /dev/null +++ b/src/main/java/com/njcn/syncdata/service/impl/RDisMpMeasurePhaseReportDServiceImpl.java @@ -0,0 +1,23 @@ +package com.njcn.syncdata.service.impl; + +import com.njcn.db.service.impl.ReplenishMybatisServiceImpl; +import com.njcn.syncdata.mapper.RDisMpMeasurePhaseReportDMapper; +import com.njcn.syncdata.pojo.po.RDisMpMeasurePhaseReportD; +import com.njcn.syncdata.service.IRDisMpMeasurePhaseReportDService; +import org.springframework.stereotype.Service; + + +/** + *

+ * 服务实现类 + *

+ * + * @author hongawen + * @since 2023-05-31 + */ +@Service +public class RDisMpMeasurePhaseReportDServiceImpl extends ReplenishMybatisServiceImpl implements IRDisMpMeasurePhaseReportDService { + + + +} diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml new file mode 100644 index 0000000..123fcd1 --- /dev/null +++ b/src/main/resources/application.yml @@ -0,0 +1,51 @@ +server: + port: 10288 +spring: + application: + name: hbsyncdata + #数据库内容配置 + datasource: + druid: + driver-class-name: com.mysql.cj.jdbc.Driver + url: jdbc:mysql://101.132.25.239:13306/pqsinfo?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=CTT&rewriteBatchedStatements=true + username: root + password: njcnpqs + #初始化建立物理连接的个数、最小、最大连接数 + initial-size: 5 + min-idle: 5 + max-active: 50 + #获取连接最大等待时间，单位毫秒 + max-wait: 60000 + #链接保持空间而不被驱逐的最长时间，单位毫秒 + min-evictable-idle-time-millis: 300000 + validation-query: select 1 + test-while-idle: true + test-on-borrow: false + test-on-return: false + pool-prepared-statements: true + max-pool-prepared-statement-per-connection-size: 20 + jackson: + time-zone: GMT+8 + date-format: yyyy-MM-dd HH:mm:ss + locale: zh_CN + serialization: + # 格式化输出 + indent_output: false + +#mybatis配置信息 +mybatis-plus: + mapper-locations: classpath*:com/njcn/**/mapping/*.xml + configuration: + #驼峰命名 + map-underscore-to-camel-case: true + #配置sql日志输出 + log-impl: org.apache.ibatis.logging.stdout.StdOutImpl + #关闭日志输出 + #log-impl: org.apache.ibatis.logging.nologging.NoLoggingImpl + global-config: + db-config: + #指定主键生成策略 + id-type: assign_uuid +log: + commonLevel: info + diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml new file mode 100644 index 0000000..a5798a5 --- /dev/null +++ b/src/main/resources/logback.xml @@ -0,0 +1,141 @@ + + + + + + + + + + + + + + + + + + + + + + ${log.pattern} + + UTF-8 + + + + + + + + ${log.homeDir}/${log.projectName}/debug/debug.log + + + + + DEBUG + + ACCEPT + + DENY + + + + + + ${log.homeDir}/${log.projectName}/debug/debug.log.%d{yyyy-MM-dd}.%i.log + + 10MB + + ${log.maxHistory:-30} + + + + + + + + + + ${log.pattern} + + UTF-8 + + + + + + + INFO + ACCEPT + DENY + + + ${log.homeDir}/${log.projectName}/info/info.log + + + + ${log.homeDir}/${log.projectName}/info/info.log.%d{yyyy-MM-dd}.%i.log + + 10MB + ${log.maxHistory:-30} + + + + ${log.pattern} + + UTF-8 + + + + + + + + ${log.homeDir}/${log.projectName}/error/error.log + + + ERROR + ACCEPT + DENY + + + + ${log.homeDir}/${log.projectName}/error/error.log.%d{yyyy-MM-dd}.%i.log + + 10MB + ${log.maxHistory:-30} + + + + ${log.pattern} + + UTF-8 + + + + + + + + + + + + + + + + + + + + + + + diff --git a/src/test/java/com/hongawen/BaseJunitTest.java b/src/test/java/com/hongawen/BaseJunitTest.java new file mode 100644 index 0000000..b2b2330 --- /dev/null +++ b/src/test/java/com/hongawen/BaseJunitTest.java @@ -0,0 +1,18 @@ +package com.hongawen; + +import com.njcn.syncdata.HBSyncDataApplication; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.junit4.SpringRunner; +import org.springframework.test.context.web.WebAppConfiguration; + +/** + * @author hongawen + * @version 1.0.0 + * @createTime 2021年05月18日 16:24 + */ +@RunWith(SpringRunner.class) +@WebAppConfiguration +@SpringBootTest(classes = HBSyncDataApplication.class) +public class BaseJunitTest { +} diff --git a/src/test/java/com/hongawen/TestMybatis.java b/src/test/java/com/hongawen/TestMybatis.java new file mode 100644 index 0000000..e7c101a --- /dev/null +++ b/src/test/java/com/hongawen/TestMybatis.java @@ -0,0 +1,53 @@ +package com.hongawen; + +import cn.hutool.core.date.StopWatch; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.njcn.syncdata.pojo.po.RDisMpMeasurePhaseReportD; +import com.njcn.syncdata.service.IRDisMpMeasurePhaseReportDService; +import org.junit.Test; +import org.springframework.beans.factory.annotation.Autowired; + +import java.time.LocalDateTime; +import java.util.ArrayList; +import java.util.Collection; +import java.util.List; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2021年12月13日 16:52 + */ +public class TestMybatis extends BaseJunitTest { + + + + @Autowired + private IRDisMpMeasurePhaseReportDService irDisMpMeasurePhaseReportDService; + + + @Test + public void testManyFileds(){ + List data = new ArrayList<>(); + RDisMpMeasurePhaseReportD rDisMpMeasurePhaseReportD; + LocalDateTime localDateTime = LocalDateTime.now(); + for (int i = 0; i < 20000; i++) { + rDisMpMeasurePhaseReportD = new RDisMpMeasurePhaseReportD(); + rDisMpMeasurePhaseReportD.setMonitorId("jiancedianid"+i); + rDisMpMeasurePhaseReportD.setDatdate(localDateTime); + data.add(rDisMpMeasurePhaseReportD); + } + StopWatch stopWatch = new StopWatch(); + stopWatch.start(); + irDisMpMeasurePhaseReportDService.insertBatchBySlice(data,1000); + stopWatch.stop(); + System.out.printf("执行时长：%d 毫秒 总计 %d条记录.%n", stopWatch.getTotalTimeMillis(),data.size()); + } + + + + + + +}