diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/MigrationParam.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/MigrationParam.java
index 6a6f788..b531635 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/MigrationParam.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/MigrationParam.java
@@ -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;
 
     //指标名，对应表映射后的实体名
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/ServiceType.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/ServiceType.java
new file mode 100644
index 0000000..4ec7425
--- /dev/null
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/ServiceType.java
@@ -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());
+    }
+
+    }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/controller/DataSyncController.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/controller/DataSyncController.java
new file mode 100644
index 0000000..90c2ea5
--- /dev/null
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/controller/DataSyncController.java
@@ -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);
+            }
+
+        });
+
+    }
+
+
+
+}
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java
index bd090df..39747dc 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java
@@ -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
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/impl/ReplenishMybatisServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/impl/ReplenishMybatisServiceImpl.java
index db5fb69..8f0efbe 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/impl/ReplenishMybatisServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/impl/ReplenishMybatisServiceImpl.java
@@ -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
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java
new file mode 100644
index 0000000..0b7b7c9
--- /dev/null
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java
@@ -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;
+    }
+}
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java
index 36f7b79..7f36b7e 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java
@@ -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注解
      *
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlucServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlucServiceImpl.java
index 61214c0..56d2743 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlucServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlucServiceImpl.java
@@ -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;
+    }
 
 
 
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicIServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicIServiceImpl.java
index 23eab37..0092a31 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicIServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicIServiceImpl.java
@@ -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;
+    }
 
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicVServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicVServiceImpl.java
index eacff08..4e3d4de 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicVServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicVServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerPServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerPServiceImpl.java
index ed84093..f2b55d7 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerPServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerPServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerQServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerQServiceImpl.java
index 8426bba..54fd667 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerQServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerQServiceImpl.java
@@ -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;
+    }
+
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerSServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerSServiceImpl.java
index 1c3c240..622c618 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerSServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmpowerSServiceImpl.java
@@ -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;
+    }
+
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateIServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateIServiceImpl.java
index 330a1e6..a06e656 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateIServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateIServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateVServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateVServiceImpl.java
index 0664085..5b38d45 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateVServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmrateVServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataIServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataIServiceImpl.java
index f166db7..69d145c 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataIServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataIServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmIServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmIServiceImpl.java
index 48ec153..f8a2f7d 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmIServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmIServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmVServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmVServiceImpl.java
index ec4f76a..611f005 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmVServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataInharmVServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataPltServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataPltServiceImpl.java
index bd646f5..cb0f982 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataPltServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataPltServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataVServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataVServiceImpl.java
index 0ec51d4..dd8921a 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataVServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataVServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlickerServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlickerServiceImpl.java
index b087887..c380f9a 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlickerServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlickerServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlucServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlucServiceImpl.java
index a43caa2..22ec78f 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlucServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayFlucServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicIServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicIServiceImpl.java
index ff2fc40..fefd48f 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicIServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicIServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicVServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicVServiceImpl.java
index 40f16e1..dba1420 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicVServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmphasicVServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerPServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerPServiceImpl.java
index 389d923..0e3af39 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerPServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerPServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerQServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerQServiceImpl.java
index dd37285..837404e 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerQServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerQServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerSServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerSServiceImpl.java
index 3aded76..9321209 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerSServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmpowerSServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateIServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateIServiceImpl.java
index a7e9373..3021aab 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateIServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateIServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateVServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateVServiceImpl.java
index eafdd9a..f53a993 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateVServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayHarmrateVServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayIServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayIServiceImpl.java
index 6bc6e95..86e01e3 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayIServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayIServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmIServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmIServiceImpl.java
index f517318..1499197 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmIServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmIServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmVServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmVServiceImpl.java
index c94bca0..e0fcc88 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmVServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayInharmVServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayPltServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayPltServiceImpl.java
index 2fd7c62..6aae9ae 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayPltServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayPltServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayVServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayVServiceImpl.java
index 1dae5ba..b517563 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayVServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DayVServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitRateServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitRateServiceImpl.java
index 8d79fc5..fd94895 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitRateServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitRateServiceImpl.java
@@ -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;
+    }
 }
diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitTargetServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitTargetServiceImpl.java
index d61a5ea..4cb4bcd 100644
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitTargetServiceImpl.java
+++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/LimitTargetServiceImpl.java
@@ -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;
+    }
 }