diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/RelationalTargetApplication.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/RelationalTargetApplication.java new file mode 100644 index 0000000..4dafe35 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/RelationalTargetApplication.java @@ -0,0 +1,17 @@ +package com.njcn.relational; + +import org.mybatis.spring.annotation.MapperScan; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.scheduling.annotation.EnableScheduling; + +@SpringBootApplication(scanBasePackages = {"com.njcn.relational"} ) +@MapperScan(value = "com.njcn.relational") +@EnableScheduling +public class RelationalTargetApplication { + + public static void main(String[] args) { + SpringApplication.run(RelationalTargetApplication.class, args); + } + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/DynamicInsertMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/DynamicInsertMapper.java new file mode 100644 index 0000000..bf965b4 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/DynamicInsertMapper.java @@ -0,0 +1,4 @@ +package com.njcn.relational.mapper; + +public interface DynamicInsertMapper { +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataFlickerRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataFlickerRelationMapper.java new file mode 100644 index 0000000..d656588 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataFlickerRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataFlickerD; + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataFlickerRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataFlucRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataFlucRelationMapper.java new file mode 100644 index 0000000..94feeb8 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataFlucRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataFlucD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataFlucRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPhasicIRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPhasicIRelationMapper.java new file mode 100644 index 0000000..d79ca8b --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPhasicIRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataHarmPhasicID; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataHarmPhasicIRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPhasicVRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPhasicVRelationMapper.java new file mode 100644 index 0000000..6f240e0 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPhasicVRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataHarmPhasicVD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataHarmPhasicVRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerPRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerPRelationMapper.java new file mode 100644 index 0000000..a22b1de --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerPRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataHarmPowerPD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataHarmPowerPRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerQRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerQRelationMapper.java new file mode 100644 index 0000000..251e610 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerQRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataHarmPowerQD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataHarmPowerQRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerSRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerSRelationMapper.java new file mode 100644 index 0000000..a8e28fb --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmPowerSRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataHarmPowerSD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataHarmPowerSRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmRateIRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmRateIRelationMapper.java new file mode 100644 index 0000000..14f0724 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmRateIRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataHarmRateID; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataHarmRateIRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmRateVRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmRateVRelationMapper.java new file mode 100644 index 0000000..917db36 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataHarmRateVRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataHarmRateVD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataHarmRateVRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataIRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataIRelationMapper.java new file mode 100644 index 0000000..af25201 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataIRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataID; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataIRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataInHarmIRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataInHarmIRelationMapper.java new file mode 100644 index 0000000..33d9059 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataInHarmIRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataInHarmID; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataInHarmIRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataInHarmVRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataInHarmVRelationMapper.java new file mode 100644 index 0000000..36181ad --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataInHarmVRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataInHarmVD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataInHarmVRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataPltRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataPltRelationMapper.java new file mode 100644 index 0000000..1f35745 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataPltRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataPltD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataPltRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataVRelationMapper.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataVRelationMapper.java new file mode 100644 index 0000000..55f7c63 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/mapper/RStatDataVRelationMapper.java @@ -0,0 +1,16 @@ +package com.njcn.relational.mapper; + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.relational.pojo.po.RStatDataVD; + + +/** + *

+ * Mapper 接口 + *

+ */ +public interface RStatDataVRelationMapper extends MppBaseMapper { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/DynamicDataImportService.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/DynamicDataImportService.java new file mode 100644 index 0000000..35d698f --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/DynamicDataImportService.java @@ -0,0 +1,79 @@ +//package com.njcn.relational.service; +// +//import com.njcn.relational.utils.PowerDataParser; +//import lombok.AllArgsConstructor; +//import lombok.Data; +//import lombok.RequiredArgsConstructor; +//import org.apache.ibatis.session.ExecutorType; +//import org.apache.ibatis.session.SqlSession; +//import org.apache.ibatis.session.SqlSessionFactory; +//import org.springframework.stereotype.Service; +//import org.springframework.transaction.annotation.Transactional; +// +//import java.io.IOException; +//import java.util.List; +//import java.util.Map; +//import java.util.Set; +//import java.util.stream.Collectors; +//import java.util.stream.IntStream; +// +///** +// * @Author: cdf +// * @CreateTime: 2025-05-28 +// * @Description: +// */ +//@Service +//@RequiredArgsConstructor +//public class DynamicDataImportService { +// private final PowerDataParser powerDataParser; +// private final SqlSessionFactory sqlSessionFactory; +// +// @Transactional +// public void dynamicImportData(String filePath) throws IOException { +// Map>> tableDataMap = powerDataParser.parseMultiTableFile(filePath); +// +// // 批量大小设置为1000，可根据实际情况调整 +// final int batchSize = 1000; +// +// try (SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH)) { +// for (Map.Entry>> entry : tableDataMap.entrySet()) { +// String tableName = entry.getKey(); +// List> dataList = entry.getValue(); +// +// if (dataList.isEmpty()) continue; +// +// // 获取列名 +// Set columns = dataList.get(0).keySet(); +// +// // 分批处理 +// for (int i = 0; i < dataList.size(); i += batchSize) { +// List> batch = dataList.subList(i, Math.min(i + batchSize, dataList.size())); +// +// // 执行批量插入 +// sqlSession.insert("dynamicBatchInsert", new DynamicInsertParam( +// tableName, +// columns, +// batch, +// batch.size() +// )); +// +// // 定期刷新并清空缓存 +// sqlSession.flushStatements(); +// sqlSession.clearCache(); +// } +// System.out.println(tableName+"——表数据转移成功"); +// } +// } +// } +// +// +// +// @Data +// @AllArgsConstructor +// public static class DynamicInsertParam { +// private String tableName; +// private Set columns; +// private List> batchData; +// private int batchSize; +// } +//} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataFlicker.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataFlicker.java new file mode 100644 index 0000000..baee2f5 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataFlicker.java @@ -0,0 +1,17 @@ +package com.njcn.relational.service; + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataFlicker { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataFluc.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataFluc.java new file mode 100644 index 0000000..482c3d7 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataFluc.java @@ -0,0 +1,17 @@ +package com.njcn.relational.service; + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataFluc { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmRateI.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmRateI.java new file mode 100644 index 0000000..7518a6b --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmRateI.java @@ -0,0 +1,13 @@ +package com.njcn.relational.service; + + +import java.util.List; + +/** + * @author xy + */ +public interface InsertIDataHarmRateI { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmRateV.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmRateV.java new file mode 100644 index 0000000..8dcefce --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmRateV.java @@ -0,0 +1,14 @@ +package com.njcn.relational.service; + + + + +import java.util.List; + +/** + * @author xy + */ +public interface InsertIDataHarmRateV { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmphasicI.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmphasicI.java new file mode 100644 index 0000000..6fc8fcf --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmphasicI.java @@ -0,0 +1,19 @@ +package com.njcn.relational.service; + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataHarmphasicI { + + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmphasicV.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmphasicV.java new file mode 100644 index 0000000..edd79f6 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmphasicV.java @@ -0,0 +1,17 @@ +package com.njcn.relational.service; + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataHarmphasicV { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerP.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerP.java new file mode 100644 index 0000000..12f4816 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerP.java @@ -0,0 +1,18 @@ +package com.njcn.relational.service; + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataHarmpowerP { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerQ.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerQ.java new file mode 100644 index 0000000..d0768e8 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerQ.java @@ -0,0 +1,18 @@ +package com.njcn.relational.service; + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataHarmpowerQ { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerS.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerS.java new file mode 100644 index 0000000..fd84a5c --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataHarmpowerS.java @@ -0,0 +1,17 @@ +package com.njcn.relational.service; + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataHarmpowerS { + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataI.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataI.java new file mode 100644 index 0000000..6cba350 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataI.java @@ -0,0 +1,17 @@ +package com.njcn.relational.service; + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataI { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataInharmI.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataInharmI.java new file mode 100644 index 0000000..f2a1f70 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataInharmI.java @@ -0,0 +1,17 @@ +package com.njcn.relational.service; + + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 13:27【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataInharmI { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataInharmV.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataInharmV.java new file mode 100644 index 0000000..ff3ee14 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataInharmV.java @@ -0,0 +1,17 @@ +package com.njcn.relational.service; + + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 13:27【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataInharmV { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataPlt.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataPlt.java new file mode 100644 index 0000000..6d003a6 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataPlt.java @@ -0,0 +1,15 @@ +package com.njcn.relational.service; + + +import java.util.List; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface InsertIDataPlt { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataV.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataV.java new file mode 100644 index 0000000..189dac8 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/InsertIDataV.java @@ -0,0 +1,19 @@ +package com.njcn.relational.service; + + + + +import com.baomidou.mybatisplus.extension.service.IService; +import com.njcn.relational.pojo.po.RStatDataID; +import com.njcn.relational.pojo.po.RStatDataVD; + +import java.util.List; + +/** + * @author hongawen + * @version 1.0 + * @data 2024/11/7 10:54 + */ +public interface InsertIDataV extends IService { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataFlickerImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataFlickerImpl.java new file mode 100644 index 0000000..4777d05 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataFlickerImpl.java @@ -0,0 +1,21 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataFlicker; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataFlickerImpl implements InsertIDataFlicker { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataFlucImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataFlucImpl.java new file mode 100644 index 0000000..6c728f7 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataFlucImpl.java @@ -0,0 +1,21 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataFluc; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataFlucImpl implements InsertIDataFluc { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmRateIImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmRateIImpl.java new file mode 100644 index 0000000..0686608 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmRateIImpl.java @@ -0,0 +1,18 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataHarmRateI; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * @author xy + */ +@Service +@RequiredArgsConstructor +public class InsertDataHarmRateIImpl implements InsertIDataHarmRateI { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmRateVImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmRateVImpl.java new file mode 100644 index 0000000..ad6db79 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmRateVImpl.java @@ -0,0 +1,17 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataHarmRateV; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * @author xy + */ +@Service +@RequiredArgsConstructor +public class InsertDataHarmRateVImpl implements InsertIDataHarmRateV { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmphasicIImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmphasicIImpl.java new file mode 100644 index 0000000..1a5c4df --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmphasicIImpl.java @@ -0,0 +1,22 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataHarmphasicI; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataHarmphasicIImpl implements InsertIDataHarmphasicI { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmphasicVImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmphasicVImpl.java new file mode 100644 index 0000000..f1ac795 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmphasicVImpl.java @@ -0,0 +1,21 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataHarmphasicV; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataHarmphasicVImpl implements InsertIDataHarmphasicV { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerPImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerPImpl.java new file mode 100644 index 0000000..eb75b20 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerPImpl.java @@ -0,0 +1,21 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataHarmpowerP; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataHarmpowerPImpl implements InsertIDataHarmpowerP { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerQImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerQImpl.java new file mode 100644 index 0000000..7c31c97 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerQImpl.java @@ -0,0 +1,21 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataHarmpowerQ; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataHarmpowerQImpl implements InsertIDataHarmpowerQ { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerSImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerSImpl.java new file mode 100644 index 0000000..3c80930 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataHarmpowerSImpl.java @@ -0,0 +1,22 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataHarmpowerS; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataHarmpowerSImpl implements InsertIDataHarmpowerS { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataIImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataIImpl.java new file mode 100644 index 0000000..0efd929 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataIImpl.java @@ -0,0 +1,26 @@ +package com.njcn.relational.service.impl; + + +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.date.DatePattern; +import cn.hutool.core.date.LocalDateTimeUtil; +import com.njcn.relational.service.InsertIDataI; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + +import java.time.Instant; +import java.time.ZoneId; +import java.util.ArrayList; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataIImpl implements InsertIDataI { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataInharmIImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataInharmIImpl.java new file mode 100644 index 0000000..d7581af --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataInharmIImpl.java @@ -0,0 +1,21 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataInharmI; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * Description: + * Date: 2024/11/18 13:27【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataInharmIImpl implements InsertIDataInharmI { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataInharmVImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataInharmVImpl.java new file mode 100644 index 0000000..f2f9fff --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataInharmVImpl.java @@ -0,0 +1,22 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataInharmV; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * Description: + * Date: 2024/11/18 13:27【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataInharmVImpl implements InsertIDataInharmV { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataPltImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataPltImpl.java new file mode 100644 index 0000000..84436cc --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataPltImpl.java @@ -0,0 +1,20 @@ +package com.njcn.relational.service.impl; + + + +import com.njcn.relational.service.InsertIDataPlt; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + +/** + * Description: + * Date: 2024/11/18 11:17【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +@RequiredArgsConstructor +public class InsertDataPltImpl implements InsertIDataPlt { + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataVImpl.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataVImpl.java new file mode 100644 index 0000000..9f78ec6 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/service/impl/InsertDataVImpl.java @@ -0,0 +1,24 @@ +package com.njcn.relational.service.impl; + + + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.relational.mapper.RStatDataVRelationMapper; +import com.njcn.relational.pojo.po.RStatDataVD; +import com.njcn.relational.service.InsertIDataI; +import com.njcn.relational.service.InsertIDataV; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + + +/** + * @author hongawen + * @version 1.0 + * @data 2024/11/7 10:54 + */ +@Service +@RequiredArgsConstructor +public class InsertDataVImpl extends ServiceImpl implements InsertIDataI { + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/BatchInsertUtils.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/BatchInsertUtils.java new file mode 100644 index 0000000..e96c3b7 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/BatchInsertUtils.java @@ -0,0 +1,41 @@ +//package com.njcn.relational.utils; +// +//import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; +//import com.baomidou.mybatisplus.extension.service.IService; +// +//import java.util.List; +// +///** +// * @Author: cdf +// * @CreateTime: 2025-05-21 +// * @Description: +// */ +//public class BatchInsertUtils { +// +// /** +// * 批量插入优化（适用于MySQL） +// * @param service IService实例 +// * @param list 数据列表 +// * @param batchSize 每批数量 +// */ +// public static boolean batchInsert(IService service, List list, int batchSize) { +// if (CollectionUtils.isEmpty(list)) { +// return true; +// } +// +// int total = list.size(); +// int batchCount = (total + batchSize - 1) / batchSize; +// +// for (int i = 0; i < batchCount; i++) { +// int from = i * batchSize; +// int to = Math.min((i + 1) * batchSize, total); +// List subList = list.subList(from, to); +// +// if (!service.saveBatch(subList)) { +// return false; +// } +// } +// return true; +// } +// +//} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/PowerDataParser.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/PowerDataParser.java new file mode 100644 index 0000000..36a9ebc --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/PowerDataParser.java @@ -0,0 +1,182 @@ +//package com.njcn.relational.utils; +// +//import org.springframework.stereotype.Component; +// +//import java.io.BufferedReader; +//import java.io.FileReader; +//import java.io.IOException; +// +//import java.text.ParseException; +//import java.text.SimpleDateFormat; +//import java.util.*; +// +//@Component +//public class PowerDataParser { +// +// private static final SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd"); +// private static final SimpleDateFormat DATE_TIME_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); +// +// public List> parseFile(String filePath) throws IOException { +// List> result = new ArrayList<>(); +// +// try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) { +// String line; +// boolean inDataBlock = false; +// String[] headers = null; +// String[] types = null; +// +// while ((line = reader.readLine()) != null) { +// line = line.trim(); +// +// if (line.startsWith("@DATA_BLOCK")) { +// inDataBlock = true; +// continue; +// } +// +// if (line.startsWith("")) { +// break; +// } +// +// if (!inDataBlock) continue; +// +// if (line.startsWith("%")) { +// // 数据类型定义行 +// types = line.substring(1).split(","); +// }else if(line.startsWith("/@")){ +// headers = line.substring(2).split(","); +// } else if (line.startsWith("#")) { +// // 数据行 +// String[] values = line.substring(1).split(","); +// Map data = parseDataLine(headers, types, values); +// if (data != null) { +// result.add(data); +// } +// } +// } +// } +// +// return result; +// } +// +// +// public Map>> parseMultiTableFile(String filePath) throws IOException { +// Map>> result = new LinkedHashMap<>(); +// String currentTable = null; +// List> currentData = null; +// String[] headers = null; +// String[] types = null; +// +// try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) { +// String line; +// while ((line = reader.readLine()) != null) { +// line = line.trim(); +// // 识别表开始标记 +// if (line.startsWith("<") && line.contains("::")) { +// currentTable = line.substring(line.indexOf("::") + 2, line.indexOf(">")); +// currentData = new ArrayList<>(); +// result.put(currentTable, currentData); +// continue; +// } +// +// if (currentTable == null) continue; +// +// // 数据块开始 +// if (line.startsWith("@DATA_BLOCK")) { +// headers = null; +// types = null; +// continue; +// } +// +// // 数据块结束 +// if (line.startsWith(" data = parseDataLine(headers, types, values); +// if (data != null && currentData != null) { +// currentData.add(data); +// } +// } +// } +// } +// } +// return result; +// } +// +// +// +// private Map parseDataLine(String[] headers, String[] types, String[] values) { +// if (headers == null || types == null || values == null || +// headers.length != values.length || headers.length != types.length) { +// return null; +// } +// +// Map data = new HashMap<>(); +// +// for (int i = 0; i < headers.length; i++) { +// String field = headers[i].trim(); +// String type = types[i].trim(); +// String value = values[i].trim(); +// +// try { +// if("-".equals(value)){ +// data.put(field, null); +// continue; +// } +// Object parsedValue = parseValue(value, type); +// data.put(field, parsedValue); +// } catch (ParseException e) { +// System.err.println("Error parsing value '" + value + "' for field '" + field + "' with type '" + type + "'"); +// data.put(field, null); +// } +// } +// +// return data; +// } +// +// private Object parseValue(String value, String type) throws ParseException { +// if (value == null || value.isEmpty() || "0E-8".equals(value)) { +// return getDefaultValue(type); +// } +// +// switch (type.toUpperCase()) { +// case "DATE": +// return DATE_FORMAT.parse(value); +// case "DATETIME": +// return DATE_TIME_FORMAT.parse(value); +// case "INT": +// return Integer.parseInt(value); +// case "DECIMAL": +// return Double.parseDouble(value); +// case "VARCHAR": +// return value; +// default: +// return value; +// } +// } +// +// private Object getDefaultValue(String type) { +// switch (type.toUpperCase()) { +// case "DATE": +// case "DATETIME": +// return null; +// case "INT": +// return 0; +// case "DECIMAL": +// return 0.0; +// case "VARCHAR": +// return ""; +// default: +// return null; +// } +// } +//} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/TableConfigManager.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/TableConfigManager.java new file mode 100644 index 0000000..3cc74e4 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/utils/TableConfigManager.java @@ -0,0 +1,38 @@ +//package com.njcn.relational.utils; +// +//import com.njcn.relational.config.TableConfig; +//import com.njcn.relational.pojo.po.RStatDataID; +//import org.springframework.stereotype.Component; +// +//import javax.annotation.PostConstruct; +//import java.util.HashMap; +//import java.util.Map; +// +///** +// * @Author: cdf +// * @CreateTime: 2025-05-28 +// * @Description: +// */ +//@Component +//public class TableConfigManager { +// private Map configMap = new HashMap<>(); +// +// @PostConstruct +// public void init() { +// // 注册r_stat_data_i_d表 +// registerRStatDataIDConfig(); +// // 注册其他表... +// } +// +// private void registerRStatDataIDConfig() { +// TableConfig config = new TableConfig(); +// config.setTableName("r_stat_data_i_d"); +// config.setEntityClass(RStatDataID.class); +// // 设置表头和数据类型... +// configMap.put("r_stat_data_i_d", config); +// } +// +// public TableConfig getConfig(String tableName) { +// return configMap.get(tableName); +// } +//} \ No newline at end of file diff --git a/relational_migration/relational_target/src/main/resources/application.yml b/relational_migration/relational_target/src/main/resources/application.yml new file mode 100644 index 0000000..f70b4ff --- /dev/null +++ b/relational_migration/relational_target/src/main/resources/application.yml @@ -0,0 +1,45 @@ +server: + port: 10556 + # 30分钟无操作就过期 + servlet: + context-path: + session: + timeout: 600m +spring: + application: + name: dmTransport + profiles: + #active: query_up + active: query_up + security: + user: + name: data_njcn + password: dnzl@#002 +#mybatis配置信息 +mybatis-plus: + #别名扫描 + type-aliases-package: com.njcn.relational.pojo + mapper-locations: classpath*:com/njcn/relational/mapper/mapping/*.xml + configuration: + call-setters-on-nulls: true + #驼峰命名 + 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 + +logging: + level: + root: info + +sync: + export: + #path: /home/d5000/liaoning/file-send/7/ + path: D:/data/export/ + import: + path: /home/import/ diff --git a/relational_migration/relational_target/src/main/resources/static/index.html b/relational_migration/relational_target/src/main/resources/static/index.html new file mode 100644 index 0000000..466c7ac --- /dev/null +++ b/relational_migration/relational_target/src/main/resources/static/index.html @@ -0,0 +1,553 @@ + + + + + + 数据同步管理系统 + + + + + +
+
+ +
+

+ 🗄️ 数据同步管理系统 + + {{ serverTypeName }} + +

+

relational_migration - 数据导入导出管理平台

+
+ + +
+
+
{{ fileCount }}
+
远程文件数量
+
+
+
{{ operationCount }}
+
操作次数
+
+
+
{{ lastOperationTime || '--' }}
+
最后操作时间
+
+
+ + +
+
⚙️ 环境切换（调试用）
+ + + + + + {{ serverTypeName }} + + + +
+ + +
+
📊 数据操作
+ + + + + + +
+ + 从二区库导出数据并上传横向隔离设备 + + + 从横向隔离设备拉取数据并入三区库 + + + 测试二区发送数据至横向隔离设备 + + + 测试三区从横向隔离设备消费数据 + +
+ + +
+ + +
+
📁 远程文件管理
+ + 获取横向隔离设备远程文件列表 + + +
+ + + + + + + +
+ + +
+ + +
+
🗑️ 本地文件清理
+ + + + + + + 清理二区服务器上生成的数据 + + + 清理三区服务器保留的数据 + + + +
+ + +
+
📋 操作日志
+
+
+ [{{ log.time }}] {{ log.message }} +
+
+ 暂无操作日志 +
+
+ + 清空日志 + +
+
+
+ + + + + + + + + + + diff --git a/relational_migration/relational_target/src/test/java/com/njcn/relational/RelationalTargetApplicationTests.java b/relational_migration/relational_target/src/test/java/com/njcn/relational/RelationalTargetApplicationTests.java new file mode 100644 index 0000000..bc03305 --- /dev/null +++ b/relational_migration/relational_target/src/test/java/com/njcn/relational/RelationalTargetApplicationTests.java @@ -0,0 +1,13 @@ +//package com.njcn.relational; +// +//import org.junit.jupiter.api.Test; +//import org.springframework.boot.test.context.SpringBootTest; +// +//@SpringBootTest +//class RelationalTargetApplicationTests { +// +// @Test +// void contextLoads() { +// } +// +//}