From fd097544833275ac3247cc14d1d1ba326c622146 Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Fri, 5 Jan 2024 14:31:24 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=95=B0=E6=8D=AE=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/IReplenishMybatisService.java     |  1 -
 .../oracle/service/ServiceExecutorStore.java  | 44 -------------------
 .../service/impl/DataFlickerServiceImpl.java  |  4 --
 .../service/impl/DataFlucServiceImpl.java     |  5 +--
 .../impl/DataHarmphasicIServiceImpl.java      |  5 +--
 .../impl/DataHarmphasicVServiceImpl.java      |  5 +--
 .../impl/DataHarmpowerPServiceImpl.java       |  5 +--
 .../impl/DataHarmpowerQServiceImpl.java       |  4 --
 .../impl/DataHarmpowerSServiceImpl.java       |  5 +--
 .../impl/DataHarmrateIServiceImpl.java        |  5 +--
 .../impl/DataHarmrateVServiceImpl.java        |  5 +--
 .../oracle/service/impl/DataIServiceImpl.java |  5 +--
 .../service/impl/DataInharmIServiceImpl.java  |  5 +--
 .../service/impl/DataInharmVServiceImpl.java  |  5 +--
 .../service/impl/DataPltServiceImpl.java      |  5 +--
 .../oracle/service/impl/DataVServiceImpl.java |  5 +--
 .../service/impl/DayFlickerServiceImpl.java   |  5 +--
 .../service/impl/DayFlucServiceImpl.java      |  5 +--
 .../impl/DayHarmphasicIServiceImpl.java       |  4 --
 .../impl/DayHarmphasicVServiceImpl.java       |  5 +--
 .../impl/DayHarmpowerPServiceImpl.java        |  4 --
 .../impl/DayHarmpowerQServiceImpl.java        |  5 +--
 .../impl/DayHarmpowerSServiceImpl.java        |  5 +--
 .../service/impl/DayHarmrateIServiceImpl.java |  5 +--
 .../service/impl/DayHarmrateVServiceImpl.java |  5 +--
 .../oracle/service/impl/DayIServiceImpl.java  |  5 +--
 .../service/impl/DayInharmIServiceImpl.java   |  5 +--
 .../service/impl/DayInharmVServiceImpl.java   |  5 +--
 .../service/impl/DayPltServiceImpl.java       |  5 +--
 .../oracle/service/impl/DayVServiceImpl.java  |  5 +--
 .../service/impl/LimitRateServiceImpl.java    |  5 +--
 .../service/impl/LimitTargetServiceImpl.java  |  5 +--
 .../oracle/controller/DataSyncController.java | 12 ++---
 33 files changed, 33 insertions(+), 170 deletions(-)
 delete mode 100644 oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java

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 39747dc..0ab3e6a 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
@@ -15,7 +15,6 @@ import java.util.List;
  */
 public interface IReplenishMybatisService<T> extends IService<T> {
 
-    ServiceType getServiceType();
 
     /***
      * 当批量插入数据量过大时，可以指定尺寸交给mybatis,每次插入多少条记录
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
deleted file mode 100644
index 0b7b7c9..0000000
--- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java
+++ /dev/null
@@ -1,44 +0,0 @@
-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 7f36b7e..ecad38e 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
@@ -50,10 +50,6 @@ public class DataFlickerServiceImpl extends ReplenishMybatisServiceImpl<DataFlic
     }
 
 
-    @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 56d2743..a987933 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
@@ -54,10 +54,7 @@ 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 0092a31..72e995a 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
@@ -51,9 +51,6 @@ 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 4e3d4de..9fac9e1 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
@@ -65,8 +65,5 @@ public class DataHarmphasicVServiceImpl extends ReplenishMybatisServiceImpl<Data
         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 f2b55d7..9875840 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
@@ -64,8 +64,5 @@ 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 54fd667..f833769 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
@@ -65,9 +65,5 @@ 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 622c618..c049960 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
@@ -65,9 +65,6 @@ 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 a06e656..1f9bb09 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
@@ -64,8 +64,5 @@ 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 5b38d45..d4e4680 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
@@ -64,8 +64,5 @@ 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 69d145c..4f4fc5e 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
@@ -64,8 +64,5 @@ 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 f8a2f7d..215ae4c 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
@@ -64,8 +64,5 @@ 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 611f005..1a0631b 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
@@ -64,8 +64,5 @@ 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 cb0f982..e975152 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
@@ -64,8 +64,5 @@ 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 dd8921a..7f331f3 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
@@ -64,8 +64,5 @@ 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 c380f9a..ecf1f2d 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
@@ -64,8 +64,5 @@ 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 22ec78f..42b673f 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
@@ -64,8 +64,5 @@ 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 fefd48f..b041b12 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
@@ -64,8 +64,4 @@ 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 dba1420..5f3c1d7 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
@@ -64,8 +64,5 @@ 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 0e3af39..75bed06 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
@@ -64,8 +64,4 @@ 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 837404e..4ce981d 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
@@ -64,8 +64,5 @@ 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 9321209..e1753b5 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
@@ -64,8 +64,5 @@ 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 3021aab..807293a 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
@@ -64,8 +64,5 @@ 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 f53a993..04463fc 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
@@ -64,8 +64,5 @@ 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 86e01e3..4878f9b 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
@@ -64,8 +64,5 @@ 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 1499197..763bda9 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
@@ -64,8 +64,5 @@ 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 e0fcc88..b57be02 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
@@ -64,8 +64,5 @@ 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 6aae9ae..dbdd129 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
@@ -63,8 +63,5 @@ 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 b517563..119f123 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
@@ -64,8 +64,5 @@ 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 fd94895..288fa6e 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
@@ -64,8 +64,5 @@ 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 4cb4bcd..9c49409 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
@@ -64,8 +64,5 @@ 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;
-    }
+
 }
diff --git a/oracle-data/oracle-target/src/main/java/com/njcn/oracle/controller/DataSyncController.java b/oracle-data/oracle-target/src/main/java/com/njcn/oracle/controller/DataSyncController.java
index 885f20e..1a252e9 100644
--- a/oracle-data/oracle-target/src/main/java/com/njcn/oracle/controller/DataSyncController.java
+++ b/oracle-data/oracle-target/src/main/java/com/njcn/oracle/controller/DataSyncController.java
@@ -4,7 +4,6 @@ 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;
@@ -33,17 +32,20 @@ import java.util.List;
 @AllArgsConstructor
 public class DataSyncController  {
 
-    private final ServiceExecutorStore serviceExecutorStore;
 
     @PostMapping("/dataSync")
     @ApiOperation("数据同步")
     @ApiImplicitParam(name = "componentParam", value = "组件数据", required = true)
-    public void dataSync(@RequestBody MigrationParam migrationParam) {
+    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);
+            IReplenishMybatisService executor = null;
+            try {
+                executor = (IReplenishMybatisService) SpringUtil.getBean(Class.forName("com.njcn.oracle.service.impl." + temp + "ServiceImpl"));
+            } catch (ClassNotFoundException e) {
+                throw new RuntimeException(e);
+            }
             List list = executor.queryData(migrationParam);
             if(CollectionUtil.isNotEmpty(list)){
                 executor.clearTargetData(migrationParam);