From 8b166031ec3f3c424f15050217b3ba32bc0771fa Mon Sep 17 00:00:00 2001
From: cdf <857448963@qq.com>
Date: Wed, 17 Jun 2026 09:23:57 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BE=BD=E5=AE=81=E4=BA=8C=E4=B8=89=E5=8C=BA?=
=?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=BF=81=E7=A7=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
pom.xml | 1 +
relational_migration/pom.xml | 40 +
relational_migration/relational_comm/pom.xml | 127 +++
.../GlobalBusinessExceptionHandler.java | 29 +
.../relational/mapper/DynamicSyncMapper.java | 59 ++
.../mapper/SyncTableConfigMapper.java | 23 +
.../mapper/mapping/DynamicSyncMapper.xml | 19 +
.../njcn/relational/pojo/bo/BaseEntity.java | 55 ++
.../relational/pojo/bo/DownloadResult.java | 23 +
.../njcn/relational/pojo/bo/UploadResult.java | 25 +
.../relational/pojo/commEnum/TableEnum.java | 86 ++
.../pojo/dto/DynamicRelationTable.java | 22 +
.../relational/pojo/po/RMpEventDetailD.java | 47 ++
.../relational/pojo/po/RMpEventDetailM.java | 47 ++
.../relational/pojo/po/RMpEventDetailQ.java | 47 ++
.../relational/pojo/po/RMpEventDetailY.java | 47 ++
.../relational/pojo/po/RMpPollutionD.java | 56 ++
.../relational/pojo/po/RStatComassesDPO.java | 119 +++
.../relational/pojo/po/RStatDataFlickerD.java | 50 ++
.../relational/pojo/po/RStatDataFlucD.java | 47 ++
.../pojo/po/RStatDataHarmPhasicID.java | 191 +++++
.../pojo/po/RStatDataHarmPhasicVD.java | 191 +++++
.../pojo/po/RStatDataHarmPowerPD.java | 200 +++++
.../pojo/po/RStatDataHarmPowerQD.java | 194 +++++
.../pojo/po/RStatDataHarmPowerSD.java | 191 +++++
.../pojo/po/RStatDataHarmRateID.java | 191 +++++
.../pojo/po/RStatDataHarmRateVD.java | 191 +++++
.../njcn/relational/pojo/po/RStatDataID.java | 209 +++++
.../relational/pojo/po/RStatDataInHarmID.java | 191 +++++
.../relational/pojo/po/RStatDataInHarmVD.java | 191 +++++
.../relational/pojo/po/RStatDataPltD.java | 44 +
.../njcn/relational/pojo/po/RStatDataVD.java | 224 +++++
.../relational/pojo/po/RStatIntegrityD.java | 43 +
.../pojo/po/RStatLimitQualifiedD.java | 450 ++++++++++
.../relational/pojo/po/RStatLimitRateD.java | 468 ++++++++++
.../pojo/po/RStatLimitRateDetailD.java | 450 ++++++++++
.../relational/pojo/po/RStatLimitTargetD.java | 469 +++++++++++
.../relational/pojo/po/RStatOnlineRateD.java | 45 +
.../pojo/po/RStatOrgIntegrityD.java | 42 +
.../pojo/po/RStatPollutionOrgD.java | 54 ++
.../pojo/po/RStatPollutionOrgM.java | 53 ++
.../pojo/po/RStatPollutionOrgQ.java | 53 ++
.../pojo/po/RStatPollutionOrgY.java | 53 ++
.../pojo/po/RStatPollutionSubstationD.java | 53 ++
.../pojo/po/RStatPollutionSubstationM.java | 53 ++
.../pojo/po/RStatPollutionSubstationQ.java | 53 ++
.../pojo/po/RStatPollutionSubstationY.java | 53 ++
.../relational/pojo/po/SyncTableConfig.java | 45 +
.../com/njcn/relational/pojo/po/User.java | 148 ++++
.../relational_target/pom.xml | 72 ++
.../com/njcn/relational/ann/SyncTable.java | 20 +
.../com/njcn/relational/config/Security.java | 19 +
.../controller/DataTransportController.java | 162 ++++
.../com/njcn/relational/job/importJob.java | 58 ++
.../com/njcn/relational/job/reportJob.java | 56 ++
.../relational/serializer/BlobSerializer.java | 37 +
.../relational/serializer/ClobSerializer.java | 34 +
.../service/SyncTableConfigService.java | 490 +++++++++++
.../service/SyncTableParseService.java | 796 ++++++++++++++++++
.../njcn/relational/utils/BlobConverter.java | 60 ++
.../njcn/relational/utils/SftpUploadUtil.java | 533 ++++++++++++
.../src/main/resources/application-insert.yml | 35 +
.../main/resources/application-insert_up.yml | 36 +
.../src/main/resources/application-query.yml | 35 +
.../main/resources/application-query_up.yml | 36 +
.../src/main/resources/logback-spring.xml | 81 ++
.../src/main/resources/static/js/axios.min.js | 3 +
.../resources/static/js/element-ui-index.js | 1 +
.../main/resources/static/js/element-ui.css | 1 +
.../src/main/resources/static/js/vue.min.js | 6 +
.../src/main/resources/static/login.html | 28 +
71 files changed, 8361 insertions(+)
create mode 100644 relational_migration/pom.xml
create mode 100644 relational_migration/relational_comm/pom.xml
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/exception/GlobalBusinessExceptionHandler.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/DynamicSyncMapper.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/SyncTableConfigMapper.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/mapping/DynamicSyncMapper.xml
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/bo/BaseEntity.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/bo/DownloadResult.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/bo/UploadResult.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/commEnum/TableEnum.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/dto/DynamicRelationTable.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RMpEventDetailD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RMpEventDetailM.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RMpEventDetailQ.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RMpEventDetailY.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RMpPollutionD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatComassesDPO.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataFlickerD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataFlucD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataHarmPhasicID.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataHarmPhasicVD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataHarmPowerPD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataHarmPowerQD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataHarmPowerSD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataHarmRateID.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataHarmRateVD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataID.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataInHarmID.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataInHarmVD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataPltD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatDataVD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatIntegrityD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatLimitQualifiedD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatLimitRateD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatLimitRateDetailD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatLimitTargetD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatOnlineRateD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatOrgIntegrityD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatPollutionOrgD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatPollutionOrgM.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatPollutionOrgQ.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatPollutionOrgY.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatPollutionSubstationD.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatPollutionSubstationM.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatPollutionSubstationQ.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/RStatPollutionSubstationY.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SyncTableConfig.java
create mode 100644 relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/User.java
create mode 100644 relational_migration/relational_target/pom.xml
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/ann/SyncTable.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/config/Security.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/controller/DataTransportController.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/job/importJob.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/job/reportJob.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/serializer/BlobSerializer.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/serializer/ClobSerializer.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/service/SyncTableConfigService.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/service/SyncTableParseService.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/utils/BlobConverter.java
create mode 100644 relational_migration/relational_target/src/main/java/com/njcn/relational/utils/SftpUploadUtil.java
create mode 100644 relational_migration/relational_target/src/main/resources/application-insert.yml
create mode 100644 relational_migration/relational_target/src/main/resources/application-insert_up.yml
create mode 100644 relational_migration/relational_target/src/main/resources/application-query.yml
create mode 100644 relational_migration/relational_target/src/main/resources/application-query_up.yml
create mode 100644 relational_migration/relational_target/src/main/resources/logback-spring.xml
create mode 100644 relational_migration/relational_target/src/main/resources/static/js/axios.min.js
create mode 100644 relational_migration/relational_target/src/main/resources/static/js/element-ui-index.js
create mode 100644 relational_migration/relational_target/src/main/resources/static/js/element-ui.css
create mode 100644 relational_migration/relational_target/src/main/resources/static/js/vue.min.js
create mode 100644 relational_migration/relational_target/src/main/resources/static/login.html
diff --git a/pom.xml b/pom.xml
index cb5ed70..449ce43 100644
--- a/pom.xml
+++ b/pom.xml
@@ -12,6 +12,7 @@
influx-data
manufact_influx_data
filesync
+ relational_migration
pom
diff --git a/relational_migration/pom.xml b/relational_migration/pom.xml
new file mode 100644
index 0000000..b552b38
--- /dev/null
+++ b/relational_migration/pom.xml
@@ -0,0 +1,40 @@
+
+
+ 4.0.0
+
+
+ com.njcn
+ data-migration
+ 1.0.0
+
+
+ relational_migration
+ pom
+
+
+
+ 8
+ 8
+ UTF-8
+
+
+
+ relational_comm
+ relational_target
+
+
+
+
+
+
+ net.bytebuddy
+ byte-buddy
+ 1.12.10
+
+
+
+
+
+
+
diff --git a/relational_migration/relational_comm/pom.xml b/relational_migration/relational_comm/pom.xml
new file mode 100644
index 0000000..2064aa7
--- /dev/null
+++ b/relational_migration/relational_comm/pom.xml
@@ -0,0 +1,127 @@
+
+
+ 4.0.0
+
+
+ com.njcn
+ relational_migration
+ 1.0.0
+
+
+ relational_comm
+
+
+ 1.8
+ UTF-8
+ UTF-8
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ cn.hutool
+ hutool-all
+
+
+
+ commons-io
+ commons-io
+
+
+
+ org.bouncycastle
+ bcprov-jdk15on
+
+
+
+ org.apache.commons
+ commons-compress
+ 1.21
+
+
+
+ org.projectlombok
+ lombok
+ ${lombok.version}
+
+
+
+
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+ ${mybatis.version}
+
+
+
+ com.alibaba
+ druid-spring-boot-starter
+ ${druid.version}
+
+
+
+ mysql
+ mysql-connector-java
+ ${mysql.version}
+
+
+
+
+ com.dameng
+ DmJdbcDriver18
+ 8.1.1.193
+
+
+
+ com.baomidou
+ mybatis-plus-generator
+ ${mybatis-plus-generator.version}
+
+
+
+ com.baomidou
+ mybatis-plus-boot-starter
+ ${mybatis-plus.version}
+
+
+ com.github.jeffreyning
+ mybatisplus-plus
+ ${mybatis-plus.jeffreyning.version}
+
+
+
+ com.github.xiaoymin
+ knife4j-spring-boot-starter
+ ${knife4j.version}
+
+
+
+
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.1
+
+ 1.8
+ 1.8
+ UTF-8
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
+
+
diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/exception/GlobalBusinessExceptionHandler.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/exception/GlobalBusinessExceptionHandler.java
new file mode 100644
index 0000000..6d50b30
--- /dev/null
+++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/exception/GlobalBusinessExceptionHandler.java
@@ -0,0 +1,29 @@
+package com.njcn.relational.exception;
+
+
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+/**
+ * 全局通用业务异常处理器
+ *
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2021年04月20日 18:04
+ */
+@Slf4j
+@AllArgsConstructor
+@RestControllerAdvice
+public class GlobalBusinessExceptionHandler {
+
+
+
+ @ExceptionHandler(Exception.class)
+ public void handleException(Exception e) {
+ log.error("系统异常--------------------", e);
+ e.printStackTrace();
+ }
+
+}
diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/DynamicSyncMapper.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/DynamicSyncMapper.java
new file mode 100644
index 0000000..97d16fd
--- /dev/null
+++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/DynamicSyncMapper.java
@@ -0,0 +1,59 @@
+package com.njcn.relational.mapper;
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface DynamicSyncMapper {
+
+ /**
+ * 获取表所有列名(指定Schema)
+ */
+ @Select("SELECT COLUMN_NAME FROM ALL_TAB_COLUMNS " +
+ "WHERE TABLE_NAME = #{tableName} " +
+ "AND OWNER = #{schema} " +
+ "ORDER BY COLUMN_ID")
+ List getTableColumns(@Param("tableName") String tableName,
+ @Param("schema") String schema);
+
+ /**
+ * 获取当前用户/Schema
+ */
+ @Select("SELECT USER FROM DUAL")
+ String getCurrentUser();
+
+ /**
+ * 分页查询
+ */
+ @Select("SELECT * FROM ${tableName} LIMIT #{limit} OFFSET #{offset}")
+ List