From 9482da2cabd082e616d3f1ba4bcd69dd0d6ea9c6 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Tue, 23 Jun 2020 00:46:27 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=84=E7=BB=87=E8=83=BD=E5=8A=9B-=E7=94=A8?=
=?UTF-8?q?=E6=88=B7=E7=9B=B8=E5=85=B3=EF=BC=9A=E7=9B=B4=E5=B1=9E=E7=BD=91?=
=?UTF-8?q?=E6=A0=BC=E6=9F=B1=E7=8A=B6=E5=9B=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../main/java/com/epmet/dto/DimAgencyDTO.java | 60 ---------
.../main/java/com/epmet/dto/DimGridDTO.java | 45 +++++++
.../result/user/UserSubAgencyResultDTO.java | 3 +
.../dto/result/user/UserSubGridResDTO.java | 21 +++
.../dto/result/user/UserSubGridResultDTO.java | 8 +-
.../com/epmet/dao/user/UserAnalysisDao.java | 31 +++++
.../user/impl/UserAnalysisServiceImpl.java | 127 +++++++++++++++---
.../resources/mapper/user/UserAnalysisDao.xml | 49 ++++++-
8 files changed, 263 insertions(+), 81 deletions(-)
create mode 100644 epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/DimGridDTO.java
create mode 100644 epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/result/user/UserSubGridResDTO.java
diff --git a/epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/DimAgencyDTO.java b/epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/DimAgencyDTO.java
index 03bf9ad3c2..243404052e 100644
--- a/epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/DimAgencyDTO.java
+++ b/epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/DimAgencyDTO.java
@@ -20,7 +20,6 @@ package com.epmet.dto;
import lombok.Data;
import java.io.Serializable;
-import java.util.Date;
/**
@@ -44,63 +43,4 @@ public class DimAgencyDTO implements Serializable {
*/
private String agencyName;
- /**
- * 客户ID
- */
- private String customerId;
-
- /**
- * 上级组织机构ID，根组织为0
- */
- private String pid;
-
- /**
- * 所有上级组织机构ID(以英文:隔开)
- */
- private String pids;
-
- /**
- * 所有上级名称,以-连接
- */
- private String allParentName;
-
- /**
- * 机关级别（社区级：community，
-乡（镇、街道）级:street,
-区县级: district,
-市级: city
-省级:province）
- */
- private String level;
-
- /**
- * 删除标识0未删除1已删除
- */
- private String delFlag;
-
- /**
- * 乐观锁
- */
- private Integer revision;
-
- /**
- * 创建人
- */
- private String createdBy;
-
- /**
- * 创建时间
- */
- private Date createdTime;
-
- /**
- * 更新人
- */
- private String updatedBy;
-
- /**
- * 更新时间
- */
- private Date updatedTime;
-
}
\ No newline at end of file
diff --git a/epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/DimGridDTO.java b/epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/DimGridDTO.java
new file mode 100644
index 0000000000..8487d6d220
--- /dev/null
+++ b/epmet-module/data-report/data-report-client/src/main/java/com/epmet/dto/DimGridDTO.java
@@ -0,0 +1,45 @@
+/**
+ * Copyright 2018 人人开源 https://www.renren.io
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see selectSubAgencyList(String myAgencyId);
+ /**
+ * @return java.util.List
+ * @param myAgencyId
+ * @author yinzuomei
+ * @description 根据机关id,查询它下面的直属网格列表
+ * @Date 2020/6/22 23:51
+ **/
+ List selectSubGridList(String myAgencyId);
+
/**
* @param myAgencyId
* @return com.epmet.user.result.UserSummaryInfoResultDTO
@@ -64,4 +75,24 @@ public interface UserAnalysisDao {
* @Date 2020/6/22 22:38
**/
List selectRegSubAgencyRes(@Param("dateId") String dateId ,@Param("agencyId")String agencyId);
+
+ /**
+ * @param dateId 20200618日期
+ * @param agencyId 用户所属机关id
+ * @return java.util.List
+ * @author yinzuomei
+ * @description 参与用户：机关下，直属网格用户分析
+ * @Date 2020/6/23 0:18
+ **/
+ List selectParticipationSubGridRes(@Param("dateId") String dateId, @Param("agencyId") String agencyId);
+
+ /**
+ * @param dateId 20200618日期
+ * @param agencyId 用户所属机关id
+ * @return java.util.List
+ * @author yinzuomei
+ * @description 注册用户：机关下，直属网格用户分析
+ * @Date 2020/6/23 0:18
+ **/
+ List selectRegSubGridRes(@Param("dateId")String dateId, @Param("agencyId") String agencyId);
}
diff --git a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/service/user/impl/UserAnalysisServiceImpl.java b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/service/user/impl/UserAnalysisServiceImpl.java
index 9db779d348..dbc4d20f2e 100644
--- a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/service/user/impl/UserAnalysisServiceImpl.java
+++ b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/service/user/impl/UserAnalysisServiceImpl.java
@@ -1,6 +1,7 @@
package com.epmet.service.user.impl;
import com.alibaba.fastjson.JSON;
+import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.security.user.LoginUserUtil;
import com.epmet.commons.tools.utils.DateUtils;
@@ -8,6 +9,7 @@ import com.epmet.commons.tools.utils.Result;
import com.epmet.constant.UserAnalysisConstant;
import com.epmet.dao.user.UserAnalysisDao;
import com.epmet.dto.DimAgencyDTO;
+import com.epmet.dto.DimGridDTO;
import com.epmet.dto.form.LoginUserDetailsFormDTO;
import com.epmet.dto.form.user.UserIncrTrendFormDTO;
import com.epmet.dto.form.user.UserSubAgencyFormDTO;
@@ -108,8 +110,9 @@ public class UserAnalysisServiceImpl implements UserAnalysisService {
//获取用户所属机关id
String myAgencyId = this.getMyAgency();
//初始化横坐标（用户所机关的下级机关列表）
- List returnList = this.initUserSubAgencyResultDTO(myAgencyId);
- if(CollectionUtils.isEmpty(returnList)){
+ List dimList = this.initUserSubAgencyResultDTO(myAgencyId);
+ if(CollectionUtils.isEmpty(dimList)){
+ logger.info(String.format("当前机关(agencyId=%s)下没有下级机关",myAgencyId));
return new ArrayList<>();
}
//根据入参，查询注册用户或者参与用户的（机关、按日的查询结果）
@@ -124,33 +127,38 @@ public class UserAnalysisServiceImpl implements UserAnalysisService {
myAgencyId);
}
//根据维度表进行对比
- for(UserSubAgencyResDTO userSubAgencyResDTO:userSubAgencyResDTOList){
- for(UserSubAgencyResultDTO returnResultDTO:returnList){
- if(returnResultDTO.getAgencyId().equals(userSubAgencyResDTO.getAgencyId())){
+ for(UserSubAgencyResultDTO dimInitResultDto:dimList){
+ boolean flag=false;
+ for(UserSubAgencyResDTO userSubAgencyResDTO:userSubAgencyResDTOList){
+ if(dimInitResultDto.getAgencyId().equals(userSubAgencyResDTO.getAgencyId())){
+ flag=true;
//居民、热心居民、党员总数，用于排序
- returnResultDTO.setTotal(userSubAgencyResDTO.getPartymemberTotal()
+ dimInitResultDto.setTotal(userSubAgencyResDTO.getPartymemberTotal()
+userSubAgencyResDTO.getWarmHeartedTotal()
+userSubAgencyResDTO.getResiTotal());
- switch(returnResultDTO.getType()){
+ switch(dimInitResultDto.getType()){
case UserAnalysisConstant.REGISTERED_RESI:
- returnResultDTO.setValue(userSubAgencyResDTO.getResiTotal());
+ dimInitResultDto.setValue(userSubAgencyResDTO.getResiTotal());
break;
case UserAnalysisConstant.WARMHEARTED:
- returnResultDTO.setValue(userSubAgencyResDTO.getWarmHeartedTotal());
+ dimInitResultDto.setValue(userSubAgencyResDTO.getWarmHeartedTotal());
break;
case UserAnalysisConstant.PARTYMEMBER:
- returnResultDTO.setValue(userSubAgencyResDTO.getPartymemberTotal());
+ dimInitResultDto.setValue(userSubAgencyResDTO.getPartymemberTotal());
break;
default:
break;
}
}
}
+ if(!flag){
+ logger.error(String.format("各机关注册用户数缺少记录:date_id=%s,agencyId=%s",formDTO.getDateId(),dimInitResultDto.getAgencyId()));
+ }
}
//返回集合按照total降序排序
- List newList = returnList.stream().sorted(Comparator.comparing(UserSubAgencyResultDTO::getTotal))
+ List returnList = dimList.stream().sorted(Comparator.comparing(UserSubAgencyResultDTO::getTotal))
.collect(Collectors.toList());
- return newList;
+ return returnList;
}
private List initUserSubAgencyResultDTO(String myAgencyId) {
@@ -161,25 +169,25 @@ public class UserAnalysisServiceImpl implements UserAnalysisService {
UserSubAgencyResultDTO resi=new UserSubAgencyResultDTO();
resi.setAgencyId(agencyDTO.getId());
resi.setName(agencyDTO.getAgencyName());
- resi.setValue(0);
+ resi.setValue(NumConstant.ZERO);
resi.setType(UserAnalysisConstant.REGISTERED_RESI);
- resi.setTotal(0);
+ resi.setTotal(NumConstant.ZERO);
list.add(resi);
//热心居民
UserSubAgencyResultDTO warm=new UserSubAgencyResultDTO();
warm.setAgencyId(agencyDTO.getId());
warm.setName(agencyDTO.getAgencyName());
- warm.setValue(0);
+ warm.setValue(NumConstant.ZERO);
warm.setType(UserAnalysisConstant.WARMHEARTED);
- warm.setTotal(0);
+ warm.setTotal(NumConstant.ZERO);
list.add(warm);
//党员
UserSubAgencyResultDTO party=new UserSubAgencyResultDTO();
party.setAgencyId(agencyDTO.getId());
party.setName(agencyDTO.getAgencyName());
- party.setValue(0);
+ party.setValue(NumConstant.ZERO);
party.setType(UserAnalysisConstant.PARTYMEMBER);
- party.setTotal(0);
+ party.setTotal(NumConstant.ZERO);
list.add(party);
}
return list;
@@ -194,7 +202,88 @@ public class UserAnalysisServiceImpl implements UserAnalysisService {
**/
@Override
public List subGrid(UserSubGridFormDTO formDTO) {
- return null;
+ //获取用户所属机关id
+ String myAgencyId = this.getMyAgency();
+ //初始化横坐标（用户所机关的直属网格）
+ List dimList = this.initUserSubGridResultDTO(myAgencyId);
+ if(CollectionUtils.isEmpty(dimList)){
+ logger.info(String.format("当前机关(agencyId=%s)下没有网格",myAgencyId));
+ return new ArrayList<>();
+ }
+ //根据入参，查询注册用户或者参与用户的（机关、按日的查询结果）
+ List userSubGridResDTOS=new ArrayList<>();
+ if (UserAnalysisConstant.PARTI_FLAG.equals(formDTO.getRegOrPartiFlag())) {
+ //参与用户
+ userSubGridResDTOS=userAnalysisDao.selectParticipationSubGridRes(formDTO.getDateId(),myAgencyId);
+ } else {
+ //注册用户
+ userSubGridResDTOS=userAnalysisDao.selectRegSubGridRes(formDTO.getDateId(),myAgencyId);
+ }
+ //根据维度表进行对比
+ for(UserSubGridResultDTO dimInitResultDto:dimList){
+ boolean flag=false;
+ for(UserSubGridResDTO userSubGridResDTO:userSubGridResDTOS){
+ if(dimInitResultDto.getGridId().equals(userSubGridResDTO.getGridId())){
+ flag=true;
+ //居民、热心居民、党员总数，用于排序
+ dimInitResultDto.setTotal(userSubGridResDTO.getPartymemberTotal()
+ +userSubGridResDTO.getWarmHeartedTotal()
+ +userSubGridResDTO.getResiTotal());
+ switch(dimInitResultDto.getType()){
+ case UserAnalysisConstant.REGISTERED_RESI:
+ dimInitResultDto.setValue(userSubGridResDTO.getResiTotal());
+ break;
+ case UserAnalysisConstant.WARMHEARTED:
+ dimInitResultDto.setValue(userSubGridResDTO.getWarmHeartedTotal());
+ break;
+ case UserAnalysisConstant.PARTYMEMBER:
+ dimInitResultDto.setValue(userSubGridResDTO.getPartymemberTotal());
+ break;
+ default:
+ break;
+ }
+ }
+ }
+ if(!flag){
+ logger.error(String.format("直属网格注册用户数缺少记录:date_id=%s,gridId=%s",formDTO.getDateId(),dimInitResultDto.getGridId()));
+ }
+ }
+ //返回集合按照total降序排序
+ List returnList = dimList.stream().sorted(Comparator.comparing(UserSubGridResultDTO::getTotal))
+ .collect(Collectors.toList());
+ return returnList;
+ }
+
+ private List initUserSubGridResultDTO(String myAgencyId) {
+ List list=new ArrayList<>();
+ List gridList=userAnalysisDao.selectSubGridList(myAgencyId);
+ for(DimGridDTO grid:gridList){
+ //居民
+ UserSubGridResultDTO resi=new UserSubGridResultDTO();
+ resi.setGridId(grid.getId());
+ resi.setName(grid.getGridName());
+ resi.setValue(NumConstant.ZERO);
+ resi.setType(UserAnalysisConstant.REGISTERED_RESI);
+ resi.setTotal(NumConstant.ZERO);
+ list.add(resi);
+ //热心居民
+ UserSubGridResultDTO warm=new UserSubGridResultDTO();
+ warm.setGridId(grid.getId());
+ warm.setName(grid.getGridName());
+ warm.setValue(NumConstant.ZERO);
+ warm.setType(UserAnalysisConstant.WARMHEARTED);
+ warm.setTotal(NumConstant.ZERO);
+ list.add(warm);
+ //党员
+ UserSubGridResultDTO party=new UserSubGridResultDTO();
+ party.setGridId(grid.getId());
+ party.setName(grid.getGridName());
+ party.setValue(NumConstant.ZERO);
+ party.setType(UserAnalysisConstant.PARTYMEMBER);
+ party.setTotal(NumConstant.ZERO);
+ list.add(party);
+ }
+ return list;
}
/**
diff --git a/epmet-module/data-report/data-report-server/src/main/resources/mapper/user/UserAnalysisDao.xml b/epmet-module/data-report/data-report-server/src/main/resources/mapper/user/UserAnalysisDao.xml
index efd1888940..f00dc28baf 100644
--- a/epmet-module/data-report/data-report-server/src/main/resources/mapper/user/UserAnalysisDao.xml
+++ b/epmet-module/data-report/data-report-server/src/main/resources/mapper/user/UserAnalysisDao.xml
@@ -13,6 +13,20 @@
da.DEL_FLAG = '0'
AND da.AGENCY_DIM_TYPE = 'all'
AND da.PID =#{myAgencyId}
+ order by CONVERT ( da.AGENCY_NAME USING gbk ) ASC
+
+
+
+
+ SELECT
+ dg.id,
+ dg.GRID_NAME
+ FROM
+ dim_grid dg
+ WHERE
+ DEL_FLAG = '0'
+ AND dg.AGENCY_ID = #{myAgencyId}
+ order by CONVERT ( dg.GRID_NAME USING gbk ) ASC
@@ -35,7 +49,7 @@
LIMIT 1
-
+
SELECT
@@ -99,4 +113,37 @@
and m.DATE_ID=#{dateId}
order by m.REG_TOTAL desc
+
+
+
+ SELECT
+ m.GRID_ID,
+ m.AGENCY_ID,
+ m.REG_TOTAL,
+ M.RESI_TOTAL,
+ m.WARM_HEARTED_TOTAL,
+ m.PARTYMEMBER_TOTAL
+ FROM
+ fact_participation_user_grid_daily m
+ WHERE
+ m.DEL_FLAG = '0'
+ AND m.DATE_ID=#{dateId}
+ AND m.AGENCY_ID = #{agencyId}
+
+
+
+ SELECT
+ m.GRID_ID,
+ m.AGENCY_ID,
+ m.REG_TOTAL,
+ M.RESI_TOTAL,
+ m.WARM_HEARTED_TOTAL,
+ m.PARTYMEMBER_TOTAL
+ FROM
+ fact_reg_user_grid_daily m
+ WHERE
+ m.DEL_FLAG = '0'
+ AND m.DATE_ID = #{dateId}
+ AND m.AGENCY_ID = #{agencyId}
+
\ No newline at end of file