Other/data-migration
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加数据同步代码

Browse Source
This commit is contained in:
hzj
2024-01-04 14:59:55 +08:00
parent 40fcdb036e
commit e962b6a6d7
36 changed files with 323 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/MigrationParam.java
View File

@@ -1,5 +1,6 @@
package com.njcn.oracle.bo.param;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.time.LocalDateTime;
@@ -9,9 +10,11 @@ import java.util.List;
public class MigrationParam {
//起始时间
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern="yyyy-MM-dd HH:mm:ss")
private LocalDateTime startTime;
//截止时间
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern="yyyy-MM-dd HH:mm:ss")
private LocalDateTime endTime;
//指标名，对应表映射后的实体名

57
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/ServiceType.java Normal file
View File

@@ -0,0 +1,57 @@
package com.njcn.oracle.bo.param;
import com.njcn.oracle.bo.po.*;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
/**
* Description:
* Date: 2024/1/4 13:54【需求编号】
*
* @author clam
* @version V1.0.0
*/
public enum ServiceType {
DataFlicker,
DataFluc,
DataHarmphasicI,
DataHarmphasicV,
DataHarmpowerP,
DataHarmpowerQ,
DataHarmpowerS,
DataHarmrateI,
DataHarmrateV,
DataInharmI,
DataInharmV,
DataI,
DataPlt,
DataV,
DayFlicker,
DayFluc,
DayHarmphasicI,
DayHarmphasicV,
DayHarmpowerP,
DayHarmpowerQ,
DayHarmpowerS,
DayHarmrateI,
DayHarmrateV,
DayInharmI,
DayInharmV,
DayI,
DayPlt,
DayV,
LimitRate,
LimitTarget;
/**
* 获取所有可执行的组件类型，
* 除了"目录"类型，其他都可以执行
* @return
*/
public static List<ServiceType> getExecutableTypes() {
return Arrays.stream(ServiceType.values()).collect(Collectors.toList());
}
}

58
oracle-data/oracle-source/src/main/java/com/njcn/oracle/controller/DataSyncController.java Normal file
View File

@@ -0,0 +1,58 @@
package com.njcn.oracle.controller;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.extra.spring.SpringUtil;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.mybatis.service.IReplenishMybatisService;
import com.njcn.oracle.service.ServiceExecutorStore;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* Description:
* Date: 2024/1/3 14:57【需求编号】
*
* @author clam
* @version V1.0.0
*/
@Validated
@Slf4j
@RestController
@RequestMapping("/data")
@Api(tags = "数据同步")
@AllArgsConstructor
public class DataSyncController {
private final ServiceExecutorStore serviceExecutorStore;
@PostMapping("/dataSync")
@ApiOperation("新增组件")
@ApiImplicitParam(name = "componentParam", value = "组件数据", required = true)
public void dataSync(@RequestBody MigrationParam migrationParam) {
List<String> tableNames = migrationParam.getTableNames();
tableNames.stream().forEach(temp->{
// IReplenishMybatisService executor = (IReplenishMybatisService)SpringUtil.getBean("com.njcn.oracle.service.impl." + temp + "ServiceImpl");
IReplenishMybatisService executor = serviceExecutorStore.getExecutor(temp);
List list = executor.queryData(migrationParam);
if(CollectionUtil.isNotEmpty(list)){
executor.clearTargetData(migrationParam);
executor.insertBatchByDB(list);
}
});
}
}

3
oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java
View File

@@ -2,6 +2,7 @@ package com.njcn.oracle.mybatis.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataFlicker;
import java.time.LocalDateTime;
@@ -14,6 +15,8 @@ import java.util.List;
*/
public interface IReplenishMybatisService<T> extends IService<T> {
ServiceType getServiceType();
/***
* 当批量插入数据量过大时，可以指定尺寸交给mybatis,每次插入多少条记录
* @author hongawen

2
oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/impl/ReplenishMybatisServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.oracle.mybatis.mapper.BatchBaseMapper;
import com.njcn.oracle.mybatis.service.IReplenishMybatisService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StopWatch;
@@ -15,6 +16,7 @@ import java.util.List;
* @version 1.0.0
* @date 2023年06月06日 18:16
*/
@Service
public abstract class ReplenishMybatisServiceImpl<M extends BatchBaseMapper<T>, T> extends ServiceImpl<BatchBaseMapper<T>, T> implements IReplenishMybatisService<T> {
@Override

44
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java Normal file
View File

@@ -0,0 +1,44 @@
package com.njcn.oracle.service;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.mybatis.service.IReplenishMybatisService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.tuple.Pair;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* Description:
* Date: 2024/1/4 13:43【需求编号】
*
* @author clam
* @version V1.0.0
*/
@Service
@Slf4j
public class ServiceExecutorStore {
private final Map<String, IReplenishMybatisService> annotationMap = new HashMap<>();
@Autowired
public ServiceExecutorStore(List<IReplenishMybatisService> Services) {
for (IReplenishMybatisService executor : Services) {
annotationMap.put(executor.getServiceType().name(),executor);
}
for (ServiceType type : ServiceType.getExecutableTypes()) {
log.info("ServiceType [{}] doesn't have ServiceType executor", type);
}
}
public IReplenishMybatisService getExecutor(String serviceType) {
IReplenishMybatisService executor = annotationMap.get(serviceType);
return executor;
}
}

8
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java
View File

@@ -4,8 +4,10 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataFlicker;
import com.njcn.oracle.mapper.DataFlickerMapper;
import com.njcn.oracle.mybatis.service.IReplenishMybatisService;
import com.njcn.oracle.mybatis.service.impl.ReplenishMybatisServiceImpl;
import com.njcn.oracle.service.IDataFlickerService;
import org.springframework.stereotype.Service;
@@ -47,6 +49,12 @@ public class DataFlickerServiceImpl extends ReplenishMybatisServiceImpl<DataFlic
this.baseMapper.delete(lambdaQueryWrapper);
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataFlicker;
}
/**
* 默认500分片，如果字段超过20以上，建议重写方法调整为1000分片，重写时不要忘记@DS注解
*

5
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlucServiceImpl.java
View File

@@ -3,6 +3,7 @@ package com.njcn.oracle.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataFluc;
import com.njcn.oracle.mapper.DataFlucMapper;
import com.njcn.oracle.mybatis.service.impl.ReplenishMybatisServiceImpl;
@@ -53,6 +54,10 @@ public class DataFlucServiceImpl extends ReplenishMybatisServiceImpl<DataFlucMap
System.out.printf("DataFluc总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataFluc;
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicIServiceImpl.java
View File

@@ -3,6 +3,7 @@ package com.njcn.oracle.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataHarmphasicI;
import com.njcn.oracle.mapper.DataHarmphasicIMapper;
import com.njcn.oracle.mybatis.service.impl.ReplenishMybatisServiceImpl;
@@ -50,6 +51,9 @@ public class DataHarmphasicIServiceImpl extends ReplenishMybatisServiceImpl<Data
stopWatch.stop();
System.out.printf("DataHarmphasicI总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataHarmphasicI;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicVServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataHarmphasicV;
import com.njcn.oracle.bo.po.DataHarmphasicV;
import com.njcn.oracle.mapper.DataHarmphasicVMapper;
@@ -63,4 +64,9 @@ public class DataHarmphasicVServiceImpl extends ReplenishMybatisServiceImpl<Data
stopWatch.stop();
System.out.printf("DataHarmphasicV总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataHarmphasicV;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerPServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataHarmpowerP;
import com.njcn.oracle.bo.po.DataHarmpowerP;
import com.njcn.oracle.mapper.DataHarmpowerPMapper;
@@ -63,5 +64,8 @@ public class DataHarmpowerPServiceImpl extends ReplenishMybatisServiceImpl<DataH
stopWatch.stop();
System.out.printf("DataHarmpowerP总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataHarmpowerP;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerQServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataHarmpowerQ;
import com.njcn.oracle.bo.po.DataHarmpowerQ;
import com.njcn.oracle.mapper.DataHarmpowerQMapper;
@@ -64,4 +65,9 @@ public class DataHarmpowerQServiceImpl extends ReplenishMybatisServiceImpl<DataH
System.out.printf("DataHarmpowerQ总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataHarmpowerQ;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerSServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataHarmpowerS;
import com.njcn.oracle.bo.po.DataHarmpowerS;
import com.njcn.oracle.mapper.DataHarmpowerSMapper;
@@ -64,4 +65,9 @@ public class DataHarmpowerSServiceImpl extends ReplenishMybatisServiceImpl<DataH
System.out.printf("DataHarmpowerS总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataHarmpowerS;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateIServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataHarmrateI;
import com.njcn.oracle.bo.po.DataHarmrateI;
import com.njcn.oracle.mapper.DataHarmrateIMapper;
@@ -63,5 +64,8 @@ public class DataHarmrateIServiceImpl extends ReplenishMybatisServiceImpl<DataHa
stopWatch.stop();
System.out.printf("DataHarmrateI总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataHarmrateI;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateVServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataHarmrateV;
import com.njcn.oracle.bo.po.DataHarmrateV;
import com.njcn.oracle.mapper.DataHarmrateVMapper;
@@ -63,5 +64,8 @@ public class DataHarmrateVServiceImpl extends ReplenishMybatisServiceImpl<DataHa
stopWatch.stop();
System.out.printf("DataHarmrateV总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataHarmrateV;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataIServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataI;
import com.njcn.oracle.bo.po.DataI;
import com.njcn.oracle.mapper.DataIMapper;
@@ -63,5 +64,8 @@ public class DataIServiceImpl extends ReplenishMybatisServiceImpl<DataIMapper, D
stopWatch.stop();
System.out.printf("DataI总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataI;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmIServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataInharmI;
import com.njcn.oracle.bo.po.DataInharmI;
import com.njcn.oracle.mapper.DataInharmIMapper;
@@ -63,5 +64,8 @@ public class DataInharmIServiceImpl extends ReplenishMybatisServiceImpl<DataInha
stopWatch.stop();
System.out.printf("DataInharmI总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataInharmI;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmVServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataInharmV;
import com.njcn.oracle.bo.po.DataInharmV;
import com.njcn.oracle.mapper.DataInharmVMapper;
@@ -63,5 +64,8 @@ public class DataInharmVServiceImpl extends ReplenishMybatisServiceImpl<DataInha
stopWatch.stop();
System.out.printf("DataInharmV总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataInharmV;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataPltServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataPlt;
import com.njcn.oracle.bo.po.DataPlt;
import com.njcn.oracle.mapper.DataPltMapper;
@@ -63,5 +64,8 @@ public class DataPltServiceImpl extends ReplenishMybatisServiceImpl<DataPltMappe
stopWatch.stop();
System.out.printf("DataPlt总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataPlt;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataVServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DataV;
import com.njcn.oracle.bo.po.DataV;
import com.njcn.oracle.mapper.DataVMapper;
@@ -63,5 +64,8 @@ public class DataVServiceImpl extends ReplenishMybatisServiceImpl<DataVMapper, D
stopWatch.stop();
System.out.printf("DataV总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DataV;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlickerServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayFlicker;
import com.njcn.oracle.bo.po.DayFlicker;
import com.njcn.oracle.mapper.DayFlickerMapper;
@@ -63,5 +64,8 @@ public class DayFlickerServiceImpl extends ReplenishMybatisServiceImpl<DayFlicke
stopWatch.stop();
System.out.printf("DayFlicker总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayFlicker;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlucServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayFluc;
import com.njcn.oracle.bo.po.DayFluc;
import com.njcn.oracle.mapper.DayFlucMapper;
@@ -63,5 +64,8 @@ public class DayFlucServiceImpl extends ReplenishMybatisServiceImpl<DayFlucMappe
stopWatch.stop();
System.out.printf("DayFluc总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayFluc;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicIServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayHarmphasicI;
import com.njcn.oracle.bo.po.DayHarmphasicI;
import com.njcn.oracle.mapper.DayHarmphasicIMapper;
@@ -63,5 +64,8 @@ public class DayHarmphasicIServiceImpl extends ReplenishMybatisServiceImpl<DayHa
stopWatch.stop();
System.out.printf("DayHarmphasicI总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayHarmphasicI;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicVServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayHarmphasicV;
import com.njcn.oracle.bo.po.DayHarmphasicV;
import com.njcn.oracle.mapper.DayHarmphasicVMapper;
@@ -63,5 +64,8 @@ public class DayHarmphasicVServiceImpl extends ReplenishMybatisServiceImpl<DayHa
stopWatch.stop();
System.out.printf("DayHarmphasicV总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayHarmphasicV;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerPServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayHarmpowerP;
import com.njcn.oracle.bo.po.DayHarmpowerP;
import com.njcn.oracle.mapper.DayHarmpowerPMapper;
@@ -63,5 +64,8 @@ public class DayHarmpowerPServiceImpl extends ReplenishMybatisServiceImpl<DayHar
stopWatch.stop();
System.out.printf("DayHarmpowerP总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayHarmpowerP;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerQServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayHarmpowerQ;
import com.njcn.oracle.bo.po.DayHarmpowerQ;
import com.njcn.oracle.mapper.DayHarmpowerQMapper;
@@ -63,5 +64,8 @@ public class DayHarmpowerQServiceImpl extends ReplenishMybatisServiceImpl<DayHar
stopWatch.stop();
System.out.printf("DayHarmpowerQ总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayHarmpowerQ;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerSServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayHarmpowerS;
import com.njcn.oracle.bo.po.DayHarmpowerS;
import com.njcn.oracle.mapper.DayHarmpowerSMapper;
@@ -63,5 +64,8 @@ public class DayHarmpowerSServiceImpl extends ReplenishMybatisServiceImpl<DayHar
stopWatch.stop();
System.out.printf("DayHarmpowerS总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayHarmpowerS;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateIServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayHarmrateI;
import com.njcn.oracle.bo.po.DayHarmrateI;
import com.njcn.oracle.mapper.DayHarmrateIMapper;
@@ -63,5 +64,8 @@ public class DayHarmrateIServiceImpl extends ReplenishMybatisServiceImpl<DayHarm
stopWatch.stop();
System.out.printf("DayHarmrateI总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayHarmrateI;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateVServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayHarmrateV;
import com.njcn.oracle.bo.po.DayHarmrateV;
import com.njcn.oracle.mapper.DayHarmrateVMapper;
@@ -63,5 +64,8 @@ public class DayHarmrateVServiceImpl extends ReplenishMybatisServiceImpl<DayHarm
stopWatch.stop();
System.out.printf("DayHarmrateV总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayHarmrateV;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayIServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayI;
import com.njcn.oracle.bo.po.DayI;
import com.njcn.oracle.mapper.DayIMapper;
@@ -63,5 +64,8 @@ public class DayIServiceImpl extends ReplenishMybatisServiceImpl<DayIMapper, Day
stopWatch.stop();
System.out.printf("DayI总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayI;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmIServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayInharmI;
import com.njcn.oracle.bo.po.DayInharmI;
import com.njcn.oracle.mapper.DayInharmIMapper;
@@ -63,5 +64,8 @@ public class DayInharmIServiceImpl extends ReplenishMybatisServiceImpl<DayInharm
stopWatch.stop();
System.out.printf("DayInharmI总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayInharmI;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmVServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayInharmV;
import com.njcn.oracle.bo.po.DayInharmV;
import com.njcn.oracle.mapper.DayInharmVMapper;
@@ -63,5 +64,8 @@ public class DayInharmVServiceImpl extends ReplenishMybatisServiceImpl<DayInharm
stopWatch.stop();
System.out.printf("DayInharmV总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayInharmV;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayPltServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayPlt;
import com.njcn.oracle.bo.po.DayPlt;
import com.njcn.oracle.mapper.DayPltMapper;
@@ -62,5 +63,8 @@ public class DayPltServiceImpl extends ReplenishMybatisServiceImpl<DayPltMapper,
stopWatch.stop();
System.out.printf("DayPlt总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayPlt;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayVServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.DayV;
import com.njcn.oracle.bo.po.DayV;
import com.njcn.oracle.mapper.DayVMapper;
@@ -63,5 +64,8 @@ public class DayVServiceImpl extends ReplenishMybatisServiceImpl<DayVMapper, Day
stopWatch.stop();
System.out.printf("DayV总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.DayV;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitRateServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.LimitRate;
import com.njcn.oracle.bo.po.LimitRate;
import com.njcn.oracle.mapper.LimitRateMapper;
@@ -63,5 +64,8 @@ public class LimitRateServiceImpl extends ReplenishMybatisServiceImpl<LimitRateM
stopWatch.stop();
System.out.printf("LimitRate总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.LimitRate;
}
}

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitTargetServiceImpl.java
View File

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType;
import com.njcn.oracle.bo.po.LimitTarget;
import com.njcn.oracle.bo.po.LimitTarget;
import com.njcn.oracle.mapper.LimitTargetMapper;
@@ -63,5 +64,8 @@ public class LimitTargetServiceImpl extends ReplenishMybatisServiceImpl<LimitTar
stopWatch.stop();
System.out.printf("LimitTarget总计:%d条，耗时执行时长：%f 秒.%n", data.size(), stopWatch.getTotalTimeSeconds());
}
@Override
public ServiceType getServiceType() {
return ServiceType.LimitTarget;
}
}