diff --git a/ktg-mes/src/main/java/com/ktg/mes/md/mapper/AP0AEMapper.java b/ktg-mes/src/main/java/com/ktg/mes/md/mapper/AP0AEMapper.java
index 8420a33..c0ae759 100644
--- a/ktg-mes/src/main/java/com/ktg/mes/md/mapper/AP0AEMapper.java
+++ b/ktg-mes/src/main/java/com/ktg/mes/md/mapper/AP0AEMapper.java
@@ -1,11 +1,15 @@
 package com.ktg.mes.md.mapper;
 
+import com.ktg.common.annotation.DataSource;
+import com.ktg.common.enums.DataSourceType;
 import com.ktg.mes.md.domain.AP0AE;
 
 import java.util.List;
 
 public interface AP0AEMapper {
+    @DataSource(DataSourceType.SQLSERVER)
     List<AP0AE> selectOutNewData();
 
+    @DataSource(DataSourceType.SQLSERVER)
     int updateOutDataToOld(AP0AE ap0ae);
 }
diff --git a/ktg-mes/src/main/java/com/ktg/mes/md/service/impl/AP0AEServiceImpl.java b/ktg-mes/src/main/java/com/ktg/mes/md/service/impl/AP0AEServiceImpl.java
index d4bc8eb..f875b27 100644
--- a/ktg-mes/src/main/java/com/ktg/mes/md/service/impl/AP0AEServiceImpl.java
+++ b/ktg-mes/src/main/java/com/ktg/mes/md/service/impl/AP0AEServiceImpl.java
@@ -15,7 +15,6 @@ public class AP0AEServiceImpl implements IAP0AEService {
     @Autowired
     private AP0AEMapper aP0AEMapper;
 
-    @DataSource(DataSourceType.SQLSERVER)
     @Override
     public List<AP0AE> selectOutNewData() {
         return this.aP0AEMapper.selectOutNewData();