From faac288706795428b127304b70664218d97e302a Mon Sep 17 00:00:00 2001 From: wangchao Date: Fri, 9 Oct 2020 11:03:47 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E7=83=AD=E5=BF=83=E5=B8=82=E6=B0=91/?= =?UTF-8?q?=E5=85=9A=E5=91=98=E5=BE=97=E5=88=86=E6=97=B6=E6=8C=89=E7=85=A7?= =?UTF-8?q?=E5=AE=A2=E6=88=B7Id=E6=B8=85=E9=99=A4=E5=8E=86=E5=8F=B2?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=86=8D=E6=8F=92=E5=85=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../evaluationindex/screen/ScreenPartyUserRankDataDao.java | 2 +- .../impl/ScreenGrassrootsGovernDataAbsorptionServiceImpl.java | 3 ++- .../screen/ScreenPartyUserRankDataService.java | 2 +- .../screen/impl/ScreenPartyUserRankDataServiceImpl.java | 4 ++-- .../evaluationindex/screen/ScreenPartyUserRankDataDao.xml | 1 - 5 files changed, 6 insertions(+), 6 deletions(-) diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPartyUserRankDataDao.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPartyUserRankDataDao.java index 35132261cc..559bb482d9 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPartyUserRankDataDao.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/screen/ScreenPartyUserRankDataDao.java @@ -52,7 +52,7 @@ public interface ScreenPartyUserRankDataDao extends BaseDao dataList,String customerId,String dateId); + void dataClean(List dataList,String customerId); } \ No newline at end of file diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenPartyUserRankDataServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenPartyUserRankDataServiceImpl.java index 0c6815db71..8e11fe379b 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenPartyUserRankDataServiceImpl.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ScreenPartyUserRankDataServiceImpl.java @@ -55,11 +55,11 @@ public class ScreenPartyUserRankDataServiceImpl extends BaseServiceImpl dataList, String customerId, String dateId) { + public void dataClean(List dataList, String customerId) { if(!CollectionUtils.isEmpty(dataList)) { int affectedRows; do { - affectedRows = baseDao.deleteBatchByCustomerIdAndDateId(customerId, dateId); + affectedRows = baseDao.deleteBatchByCustomerIdAndDateId(customerId); } while (affectedRows > NumConstant.ZERO); baseDao.insertBatch(dataList); } diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPartyUserRankDataDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPartyUserRankDataDao.xml index 1404eeb70c..66fc4cf716 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPartyUserRankDataDao.xml +++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/screen/ScreenPartyUserRankDataDao.xml @@ -12,7 +12,6 @@ delete from screen_party_user_rank_data where CUSTOMER_ID = #{customerId} - AND DATA_END_TIME = #{dateId} limit 1000; From 442941a6702c4f37fd03145e2d89a93fcfc2d800 Mon Sep 17 00:00:00 2001 From: sunyuchao Date: Fri, 9 Oct 2020 11:04:25 +0800 Subject: [PATCH 2/4] =?UTF-8?q?=E7=BB=84=E7=BB=87=E6=9C=88=E5=BA=A6?= =?UTF-8?q?=E6=8C=87=E6=95=B0=E6=8E=A5=E5=8F=A3=E8=B0=83=E6=95=B4=E5=85=BC?= =?UTF-8?q?=E5=AE=B9=E5=A4=A7=E5=B1=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../screen/dto/form/IndexScoreFormDTO.java | 6 ++++-- .../evaluationindex/screen/impl/IndexServiceImpl.java | 9 +++++++-- .../mapper/screen/ScreenIndexDataMonthlyDao.xml | 10 ++++++---- 3 files changed, 17 insertions(+), 8 deletions(-) diff --git a/epmet-module/data-report/data-report-client/src/main/java/com/epmet/evaluationindex/screen/dto/form/IndexScoreFormDTO.java b/epmet-module/data-report/data-report-client/src/main/java/com/epmet/evaluationindex/screen/dto/form/IndexScoreFormDTO.java index 70a7b6d36b..e75abb9f63 100644 --- a/epmet-module/data-report/data-report-client/src/main/java/com/epmet/evaluationindex/screen/dto/form/IndexScoreFormDTO.java +++ b/epmet-module/data-report/data-report-client/src/main/java/com/epmet/evaluationindex/screen/dto/form/IndexScoreFormDTO.java @@ -21,13 +21,15 @@ public class IndexScoreFormDTO implements Serializable { private String orgId; /** * 类型（组织：agency 网格：grid） + * 大屏接口此字段值为空 */ - @NotBlank(message = "数据类型不能为空",groups = {IndexScoreFormDTO.AddUserInternalGroup.class}) + //@NotBlank(message = "数据类型不能为空",groups = {IndexScoreFormDTO.AddUserInternalGroup.class}) private String orgType; /** * 月份Id eg：202009 + * 大屏接口此字段值为空 */ - @NotBlank(message = "月份Id不能为空",groups = {IndexScoreFormDTO.AddUserInternalGroup.class}) + //@NotBlank(message = "月份Id不能为空",groups = {IndexScoreFormDTO.AddUserInternalGroup.class}) private String monthId; public interface AddUserInternalGroup {} diff --git a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/IndexServiceImpl.java b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/IndexServiceImpl.java index fe09c575db..385ec49fcc 100644 --- a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/IndexServiceImpl.java +++ b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/IndexServiceImpl.java @@ -2,6 +2,7 @@ package com.epmet.datareport.service.evaluationindex.screen.impl; import com.epmet.commons.dynamic.datasource.annotation.DataSource; import com.epmet.commons.tools.constant.NumConstant; +import com.epmet.commons.tools.utils.DateUtils; import com.epmet.constant.DataSourceConstant; import com.epmet.datareport.dao.evaluationindex.screen.ScreenIndexDataMonthlyDao; import com.epmet.datareport.dao.evaluationindex.screen.ScreenIndexDataYearlyDao; @@ -268,13 +269,17 @@ public class IndexServiceImpl implements IndexService { @Override public IndexScoreResultDTO indexScore(IndexScoreFormDTO formDTO) { //screen_index_data_monthly 根据组织id和月份获取月度指标得分 - //1.根据组织或网格Id以及月份Id查询各项月度指数得分 + //1.大屏接口 orgType和monthId字段不传值，默认查询上一个月数据 + if(null==formDTO.getMonthId()||"".equals(formDTO.getMonthId())){ + formDTO.setMonthId(DateUtils.getBeforeNMonth(1)); + } + //2.根据组织或网格Id以及月份Id查询各项月度指数得分 IndexScoreResultDTO resultDTO = screenIndexDataMonthlyDao.selectMonthData(formDTO); if (null == resultDTO) { return resultDTO; } - //2.将数据改成正确格式 四舍五入保留一位小数 权重转成百分比 + //3.将数据改成正确格式 四舍五入保留一位小数 权重转成百分比 NumberFormat nf = NumberFormat.getPercentInstance(); nf.setMaximumFractionDigits(1); diff --git a/epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenIndexDataMonthlyDao.xml b/epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenIndexDataMonthlyDao.xml index f7f35e0712..f35e7a490c 100644 --- a/epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenIndexDataMonthlyDao.xml +++ b/epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenIndexDataMonthlyDao.xml @@ -176,18 +176,20 @@ From bcafa9c1eb2806a5adfc9b48cffcd26d24f0910b Mon Sep 17 00:00:00 2001 From: zxc <1272811460@qq.com> Date: Fri, 9 Oct 2020 11:10:06 +0800 Subject: [PATCH 3/4] =?UTF-8?q?=E5=8E=BB=E9=99=A4=20throw=20new?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../extract/toscreen/impl/PublicPartExtractServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/PublicPartExtractServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/PublicPartExtractServiceImpl.java index bd126af18c..0cc8aa4c00 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/PublicPartExtractServiceImpl.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/PublicPartExtractServiceImpl.java @@ -96,7 +96,7 @@ public class PublicPartExtractServiceImpl implements PublicPartExtractService { List orgList = dimGridService.getGridListByCustomerId(formDTO.getCustomerId()); if (CollectionUtils.isEmpty(orgList)) { log.warn("抽取【公众参与-人均议题】，获取组织数据失败"); - throw new RenException("抽取【公众参与-人均议题】，获取组织数据失败"); + return; } //构建组织数据 Map insertMap = new HashMap<>(); @@ -172,7 +172,7 @@ public class PublicPartExtractServiceImpl implements PublicPartExtractService { List orgList = dimAgencyService.getAgencyListByCustomerId(formDTO.getCustomerId()); if (CollectionUtils.isEmpty(orgList)) { log.warn("抽取【公众参与-人均议题】，获取组织数据失败"); - throw new RenException("抽取【公众参与-人均议题】，获取组织数据失败"); + return; } //构建组织数据 Map insertMap = new HashMap<>(); From 70e438a85c226981bcfc4f2fe6f8b6fa4c5867ec Mon Sep 17 00:00:00 2001 From: wangchao Date: Fri, 9 Oct 2020 11:13:58 +0800 Subject: [PATCH 4/4] =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=89=A7=E8=A1=8C?= =?UTF-8?q?=E5=86=99=E5=85=A5=E7=83=AD=E5=BF=83=E5=B8=82=E6=B0=91=E7=A7=AF?= =?UTF-8?q?=E5=88=86=E6=95=B0=E6=8D=AE=E6=97=B6=E6=B7=BB=E5=8A=A0trycatch?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../toscreen/impl/ScreenExtractServiceImpl.java | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/ScreenExtractServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/ScreenExtractServiceImpl.java index 2edbaac99b..6229433fa7 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/ScreenExtractServiceImpl.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/toscreen/impl/ScreenExtractServiceImpl.java @@ -233,13 +233,15 @@ public class ScreenExtractServiceImpl implements ScreenExtractService { }catch (Exception e){ log.error("党建引领抽取到大屏失败，参数为："+ JSON.toJSONString(formDTO), e); } - - //基层治理 - 热心市民 screen_party_user_rank_data - ScreenCentralZoneDataFormDTO param = new ScreenCentralZoneDataFormDTO(); - param.setCustomerId(customerId); - param.setDateId(monthId); - screenGrassrootsGovernDataAbsorptionService.userScoreDataHub(param); - + try { + //基层治理 - 热心市民 screen_party_user_rank_data + ScreenCentralZoneDataFormDTO param = new ScreenCentralZoneDataFormDTO(); + param.setCustomerId(customerId); + param.setDateId(monthId); + screenGrassrootsGovernDataAbsorptionService.userScoreDataHub(param); + }catch(Exception e){ + log.error("大屏热心市民/党员得分数据写入失败，参数为：{}",JSON.toJSONString(formDTO)); + } //此方法保持在最后即可 计算指标分数 todo 优化 手动创建线程池 控制任务数量 ExecutorService pool = Executors.newSingleThreadExecutor(); pool.submit(() -> {