diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/indexcollect/impl/FactIndexCollectServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/indexcollect/impl/FactIndexCollectServiceImpl.java
index ced6e555e2..cd767ff580 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/indexcollect/impl/FactIndexCollectServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/indexcollect/impl/FactIndexCollectServiceImpl.java
@@ -1,6 +1,8 @@
 package com.epmet.service.indexcollect.impl;
 
+import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.constant.DataSourceConstant;
 import com.epmet.dao.indexcoll.*;
 import com.epmet.dto.indexcollect.form.*;
 import com.epmet.service.indexcollect.FactIndexCollectService;
@@ -34,6 +36,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
     @Autowired
     private FactIndexGovrnAblityDeptMonthlyDao factIndexGovrnAblityDeptMonthlyDao;
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertGridPartyMemberData(List<GridPartyMemberDataFormDTO> formDTO, String customerId) {
@@ -47,6 +50,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertGridPartyAbility(List<GridPartyAbilityFormDTO> formDTO, String customerId) {
@@ -60,6 +64,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertOrgPartyAbility(List<OrgPartyAbilityFormDTO> formDTO, String customerId) {
@@ -77,6 +82,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertGridServiceAbility(List<GridServiceAbilityFormDTO> formDTO, String customerId) {
@@ -90,6 +96,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertOrgServiceAbility(List<OrgServiceAbilityFormDTO> formDTO, String customerId) {
@@ -107,6 +114,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertGridGovrnAbility(List<GridGovrnAbilityFormDTO> formDTO, String customerId) {
@@ -120,6 +128,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertOrgGovrnAbility(List<OrgGovrnAbilityFormDTO> formDTO, String customerId) {
@@ -137,6 +146,7 @@ public class FactIndexCollectServiceImpl implements FactIndexCollectService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertDeptGovrnAbility(List<DeptGovrnAbilityFormDTO> formDTO, String customerId) {
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/screen/impl/ScreenCollServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/screen/impl/ScreenCollServiceImpl.java
index e67ebf4b60..b5e65fd193 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/screen/impl/ScreenCollServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/screen/impl/ScreenCollServiceImpl.java
@@ -17,10 +17,12 @@
 
 package com.epmet.service.screen.impl;
 
+import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.constant.CompareConstant;
+import com.epmet.constant.DataSourceConstant;
 import com.epmet.dao.screen.*;
 import com.epmet.dto.screencoll.form.*;
 import com.epmet.entity.screen.ScreenEventImgDataEntity;
@@ -78,6 +80,8 @@ public class ScreenCollServiceImpl implements ScreenCollService {
     private ScreenPioneerDataDao screenPioneerDataDao;
     @Autowired
     private ScreenIndexDataYearlyDao screenIndexDataYearlyDao;
+
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertPartyUserRankData(List<PartyUserRankDataFormDTO> formDTO,String customerId) {
@@ -92,6 +96,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertPartyLinkMassesData(List<PartyLinkMassesDataFormDTO> formDTO, String customerId) {
@@ -106,6 +111,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertPartyBranchData(List<PartyBranchDataFormDTO> formDTO, String customerId) {
@@ -123,6 +129,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertOrgRankData(List<OrgRankDataFormDTO> formDTO, String customerId) {
@@ -140,6 +147,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertGovernRankData(List<GovernRankDataFormDTO> formDTO, String customerId) {
@@ -157,6 +165,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertEventData(List<EventDataFormDTO> formDTO, String customerId) {
@@ -184,6 +193,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertDifficultyData(List<DifficultyDataFormDTO> formDTO, String customerId) {
@@ -196,6 +206,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertCpcbaseData(List<CpcBaseDataFormDTO> formDTO, String customerId) {
@@ -210,6 +221,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertIndexDataMonthly(List<IndexDataMonthlyFormDTO> formDTO, String customerId) {
@@ -227,6 +239,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertIndexDataYearly(List<IndexDataYearlyFormDTO> formDTO, String customerId) {
@@ -243,6 +256,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertCustomerDept(List<CustomerDeptFormDTO> formDTO, String customerId) {
@@ -257,6 +271,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertCustomerGrid(List<CustomerGridFormDTO> formDTO, String customerId) {
@@ -271,6 +286,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertCustomerAgency(List<CustomerAgencyFormDTO> formDTO, String customerId) {
@@ -285,6 +301,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertUserTotalData(List<UserTotalDataFormDTO> formDTO, String customerId) {
@@ -299,6 +316,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertUserJoin(List<UserJoinFormDTO> formDTO, String customerId) {
@@ -413,6 +431,7 @@ public class ScreenCollServiceImpl implements ScreenCollService {
         }
     }
 
+    @DataSource(value = DataSourceConstant.STATS, datasourceNameFromArg = true)
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void insertPioneerData(List<PioneerDataFormDTO> formDTO, String customerId) {