From d199f6e3f9a3d24f0b463fb12e551f4860003f54 Mon Sep 17 00:00:00 2001 From: zhangyongzhangyong <2012005003@qq.coom> Date: Mon, 24 Aug 2020 13:37:33 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=A7=E5=B1=8F=E6=95=B0=E6=8D=AE=E9=87=87?= =?UTF-8?q?=E9=9B=86=E5=92=8C=E6=8C=87=E6=A0=87=E9=87=87=E9=9B=86=20=20?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=A2=9E=E5=8A=A0=E6=B3=A8=E8=A7=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/FactIndexCollectServiceImpl.java | 10 ++++++++++ .../screen/impl/ScreenCollServiceImpl.java | 19 +++++++++++++++++++ 2 files changed, 29 insertions(+) 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 formDTO, String customerId) {