Merge branch 'dev' of http://git.elinkit.com.cn:7070/r/epmet-cloud into dev

epmet-module/gov-org/gov-org-server/src/main/resources/mapper/StaffLoginLogDao.xml

@@ -92,7 +92,7 @@
         COUNT(DISTINCT(l.STAFF_ID)) accountActivityCount,
         COUNT(DISTINCT(ag.USER_ID)) accountCount,
         a.ID agencyId,
-        a.ALL_PARENT_NAME agencyName
+        CONCAT(a.ALL_PARENT_NAME,a.ORGANIZATION_NAME)  agencyName
         FROM
         customer_agency a
         LEFT JOIN staff_login_log l ON a.ID = l.AGENCY_ID

epmet-module/resi-partymember/resi-partymember-client/src/main/java/com/epmet/resi/partymember/dto/partymember/result/PartymemberPortraitResultDTO.java

@@ -0,0 +1,41 @@
+package com.epmet.resi.partymember.dto.partymember.result;
+
+import com.alibaba.excel.annotation.ExcelIgnore;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.alibaba.excel.annotation.write.style.ColumnWidth;
+import lombok.Data;
+
+/**
+ * @Description 烟台管理平台党员画像
+ * @Author yzm
+ * @Date 2023/4/20 13:32
+ */
+@Data
+public class PartymemberPortraitResultDTO {
+    @ExcelIgnore
+    private String userId;
+
+    @ColumnWidth(15)
+    @ExcelProperty(value = "姓名",order = 1)
+    private String name;
+
+    @ColumnWidth(20)
+    @ExcelProperty(value = "手机号",order = 2)
+    private String mobile;
+
+    @ColumnWidth(20)
+    @ExcelProperty(value = "证件号",order = 3)
+    private String idCard;
+
+    @ColumnWidth(15)
+    @ExcelProperty(value = "年龄",order = 4)
+    private String age;
+
+    @ColumnWidth(15)
+    @ExcelProperty(value = "学历",order = 5)
+    private String education;
+
+    @ExcelIgnore
+    private String icResiUser;
+}
+

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/IcPartyOrgService.java

@@ -158,4 +158,12 @@ public interface IcPartyOrgService extends BaseService<IcPartyOrgEntity> {
      */
     void editPrincipal(EditPrincipalFormDTO formDTO);
 
+    /**
+     * 获取工作人员所属组织下的党组织
+     * @param customerId
+     * @param staffId
+     * @return
+     */
+    IcPartyOrgEntity getIcPartyOrg(String customerId,String staffId);
+
 }

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgServiceImpl.java

@@ -503,4 +503,28 @@ public class IcPartyOrgServiceImpl extends BaseServiceImpl<IcPartyOrgDao, IcPart
         baseDao.editPrincipal(formDTO);
     }
 
+    /**
+     * 获取工作人员所属组织下的党组织
+     *
+     * @param customerId
+     * @param staffId
+     * @return
+     */
+    @Override
+    public IcPartyOrgEntity getIcPartyOrg(String customerId, String staffId) {
+        CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(customerId, staffId);
+        if (null == staffInfo) {
+            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "获取工作人员信息失败", "获取工作人员信息失败");
+        }
+        // 获取工作人员所属组织同级的党组织
+        LambdaQueryWrapper<IcPartyOrgEntity> orgWrapper = new LambdaQueryWrapper<>();
+        orgWrapper.eq(IcPartyOrgEntity::getCustomerId, customerId);
+        orgWrapper.eq(IcPartyOrgEntity::getAgencyId, staffInfo.getAgencyId());
+        orgWrapper.ne(IcPartyOrgEntity::getPartyOrgType, NumConstant.FIVE_STR);
+        IcPartyOrgEntity icPartyOrgEntity = baseDao.selectOne(orgWrapper);
+        if (null == icPartyOrgEntity) {
+            log.warn("当前工作人员所属组织下，暂无党组织，当前");
+        }
+        return icPartyOrgEntity;
+    }
 }

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/controller/IcPartyMemberController.java

@@ -4,21 +4,18 @@ import com.alibaba.excel.EasyExcel;
 import com.alibaba.excel.ExcelWriter;
 import com.alibaba.excel.write.metadata.WriteSheet;
 import com.alibaba.fastjson.JSON;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.epmet.commons.tools.annotation.LoginUser;
 import com.epmet.commons.tools.annotation.MaskResponse;
 import com.epmet.commons.tools.aop.NoRepeatSubmit;
 import com.epmet.commons.tools.constant.AppClientConstant;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.constant.ServiceConstant;
-import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
 import com.epmet.commons.tools.dto.result.OptionDataResultDTO;
 import com.epmet.commons.tools.exception.EpmetErrorCode;
 import com.epmet.commons.tools.exception.EpmetException;
 import com.epmet.commons.tools.exception.ExceptionUtils;
 import com.epmet.commons.tools.feign.ResultDataResolver;
 import com.epmet.commons.tools.page.PageData;
-import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.*;
 import com.epmet.commons.tools.utils.poi.excel.handler.FreezeAndFilter;
@@ -33,14 +30,15 @@ import com.epmet.dto.form.IcPartyMemberListFormDTO;
 import com.epmet.dto.result.ImportTaskCommonResultDTO;
 import com.epmet.dto.result.PartyMemberAgeResultDTO;
 import com.epmet.dto.result.PartyMemberEducationResultDTO;
-import com.epmet.modules.partyOrg.dao.IcPartyOrgDao;
 import com.epmet.modules.partyOrg.entity.IcPartyOrgEntity;
+import com.epmet.modules.partyOrg.service.IcPartyOrgService;
 import com.epmet.modules.partymember.excel.IcPartyMemberExcel;
 import com.epmet.modules.partymember.service.IcPartyMemberService;
 import com.epmet.resi.partymember.dto.partymember.IcPartyMemberDTO;
 import com.epmet.resi.partymember.dto.partymember.form.IcPartyMemberFromDTO;
 import com.epmet.resi.partymember.dto.partymember.result.IcPartyInfoResultDTO;
 import com.epmet.resi.partymember.dto.partymember.result.IcPartyMemberResultDTO;
+import com.epmet.resi.partymember.dto.partymember.result.PartymemberPortraitResultDTO;
 import com.epmet.utils.ImportTaskUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
@@ -59,10 +57,7 @@ import java.io.InputStream;
 import java.io.PrintWriter;
 import java.net.URLEncoder;
 import java.nio.file.Path;
-import java.util.ArrayList;
+import java.util.*;
-import java.util.Collections;
-import java.util.List;
-import java.util.UUID;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
@@ -79,8 +74,10 @@ public class IcPartyMemberController implements ResultDataResolver {
 
     @Autowired
     private IcPartyMemberService icPartyMemberService;
+    // @Autowired
+    // private IcPartyOrgDao icPartyOrgDao;
     @Autowired
-    private IcPartyOrgDao icPartyOrgDao;
+    private IcPartyOrgService icPartyOrgService;
 
     @RequestMapping("page")
     @MaskResponse(fieldNames = { "mobile", "idCard" }, fieldsMaskType = { MaskResponse.MASK_TYPE_MOBILE, MaskResponse.MASK_TYPE_ID_CARD })
@@ -230,6 +227,26 @@ public class IcPartyMemberController implements ResultDataResolver {
         return new Result();
     }
 
+
+    /**
+     * @describe: 统计分析-党员年龄范围统计
+     * @author wangtong
+     * @date 2022/5/23 10:19
+     * @params [formDTO]
+     * @return com.epmet.commons.tools.utils.Result<java.util.List<com.epmet.commons.tools.dto.result.OptionDataResultDTO>>
+     */
+    @PostMapping("partymemberagestatistics")
+    public Result<List<OptionDataResultDTO>> partyMemberAgeStatistics(@LoginUser TokenDto tokenDto,@RequestBody IcPartyMemberFormDTO formDTO) {
+        if(StringUtils.isBlank(formDTO.getOrgId())){
+            IcPartyOrgEntity org =icPartyOrgService.getIcPartyOrg(tokenDto.getCustomerId(),tokenDto.getUserId());
+            if (null == org) {
+                return new Result<List<OptionDataResultDTO>>().ok(new ArrayList<>());
+            }
+            formDTO.setOrgId(org.getId());
+        }
+        return new Result<List<OptionDataResultDTO>>().ok(icPartyMemberService.partyMemberAgeStatistics(formDTO));
+    }
+
     /**
     * @describe: 统计分析-党员学历统计
     * @author wangtong
@@ -240,7 +257,7 @@ public class IcPartyMemberController implements ResultDataResolver {
     @PostMapping("partymembereducationstatistics")
     public Result<List<OptionDataResultDTO>> partyMemberEducationStatistics(@LoginUser TokenDto tokenDto, @RequestBody IcPartyMemberFormDTO formDTO) {
         if(StringUtils.isBlank(formDTO.getOrgId())){
-            IcPartyOrgEntity org = setOrgId(tokenDto);
+            IcPartyOrgEntity org= icPartyOrgService.getIcPartyOrg(tokenDto.getCustomerId(),tokenDto.getUserId());
             if (null == org) {
                 return new Result<List<OptionDataResultDTO>>().ok(new ArrayList<>());
             }
@@ -260,7 +277,7 @@ public class IcPartyMemberController implements ResultDataResolver {
     @MaskResponse(fieldNames = {"mobile"}, fieldsMaskType = {MaskResponse.MASK_TYPE_MOBILE})
     public Result<PageData<PartyMemberAgeResultDTO>> partyMemberAgelist(@LoginUser TokenDto tokenDto,@RequestBody IcPartyMemberListFormDTO formDTO) {
         if(StringUtils.isBlank(formDTO.getOrgId())){
-            IcPartyOrgEntity org = setOrgId(tokenDto);
+            IcPartyOrgEntity org= icPartyOrgService.getIcPartyOrg(tokenDto.getCustomerId(),tokenDto.getUserId());
             if (null == org) {
                 return new Result<PageData<PartyMemberAgeResultDTO>>().ok(new PageData<>(Collections.emptyList(), 0));
             }
@@ -280,7 +297,7 @@ public class IcPartyMemberController implements ResultDataResolver {
     @MaskResponse(fieldNames = {"mobile"}, fieldsMaskType = {MaskResponse.MASK_TYPE_MOBILE})
     public Result<PageData<PartyMemberEducationResultDTO>> partyMemberEducationlist(@LoginUser TokenDto tokenDto,@RequestBody IcPartyMemberListFormDTO formDTO) {
         if(StringUtils.isBlank(formDTO.getOrgId())){
-            IcPartyOrgEntity org = setOrgId(tokenDto);
+            IcPartyOrgEntity org= icPartyOrgService.getIcPartyOrg(tokenDto.getCustomerId(),tokenDto.getUserId());
             if (null == org) {
                 return new Result<PageData<PartyMemberEducationResultDTO>>().ok(new PageData<>(Collections.emptyList(), 0));
             }
@@ -289,43 +306,116 @@ public class IcPartyMemberController implements ResultDataResolver {
         return new Result<PageData<PartyMemberEducationResultDTO>>().ok(icPartyMemberService.getPartyMemberEducationList(formDTO));
     }
 
+
     /**
-    * @describe: 统计分析-党员年龄范围统计
+     * 烟台党员画像列表接口，将上方两个接口，合为一个
-    * @author wangtong
+     * @param formDTO
-    * @date 2022/5/23 10:19
+     * @return
-    * @params [formDTO]
+     */
-    * @return com.epmet.commons.tools.utils.Result<java.util.List<com.epmet.commons.tools.dto.result.OptionDataResultDTO>>
+    @PostMapping("partymember-portrait-list")
-    */
+    @MaskResponse(fieldNames = {"mobile","idCard"}, fieldsMaskType = {MaskResponse.MASK_TYPE_MOBILE,MaskResponse.MASK_TYPE_ID_CARD})
-    @PostMapping("partymemberagestatistics")
+    public Result<PageData<PartymemberPortraitResultDTO>> queryPartyMemberPortraitList(@RequestBody IcPartyMemberListFormDTO formDTO) {
-    public Result<List<OptionDataResultDTO>> partyMemberAgeStatistics(@LoginUser TokenDto tokenDto,@RequestBody IcPartyMemberFormDTO formDTO) {
+        return new Result<PageData<PartymemberPortraitResultDTO>>().ok(icPartyMemberService.queryPartyMemberPortraitList(formDTO));
-        if(StringUtils.isBlank(formDTO.getOrgId())){
+    }
-            IcPartyOrgEntity org = setOrgId(tokenDto);
+
-            if (null == org) {
+
-                return new Result<List<OptionDataResultDTO>>().ok(new ArrayList<>());
+    /**
+     * 烟台党员画像列表-导出
+     * @param formDTO
+     * @return
+     */
+    @NoRepeatSubmit
+    @PostMapping("partymember-portrait-export")
+    public void partymemberPortraitExport(@RequestBody IcPartyMemberListFormDTO formDTO, HttpServletResponse response) throws Exception {
+        ExcelWriter excelWriter = null;
+        formDTO.setPageSize(NumConstant.TEN_THOUSAND);
+        formDTO.setIsPage(true);
+        String fileName=getPartymemberPortraitFileName(formDTO.getCodeType(),formDTO.getCode());
+        try {
+            excelWriter = EasyExcel.write(ExcelUtils.getOutputStreamForExcel(fileName, response), PartymemberPortraitResultDTO.class).build();
+            WriteSheet writeSheet = EasyExcel.writerSheet("Sheet1").registerWriteHandler(new FreezeAndFilter()).build();
+            PageData<PartymemberPortraitResultDTO> data = null;
+            List<PartymemberPortraitResultDTO> list = null;
+            do {
+                data = icPartyMemberService.queryPartyMemberPortraitList(formDTO);
+                list = data.getList();
+                formDTO.setPageNo(formDTO.getPageNo() + NumConstant.ONE);
+                excelWriter.write(list, writeSheet);
+            } while (org.apache.commons.collections4.CollectionUtils.isNotEmpty(list) && list.size() == formDTO.getPageSize());
+        } catch (EpmetException e) {
+            response.reset();
+            response.setCharacterEncoding("UTF-8");
+            response.setHeader("content-type", "application/json; charset=UTF-8");
+            PrintWriter printWriter = response.getWriter();
+            Result<Object> result = new Result<>().error(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), e.getMsg());
+            printWriter.write(JSON.toJSONString(result));
+            printWriter.close();
+        } catch (Exception e) {
+            log.error("党员画像列表导出exception", e);
+        } finally {
+            if (excelWriter != null) {
+                excelWriter.finish();
             }
-            formDTO.setOrgId(org.getId());
         }
-        return new Result<List<OptionDataResultDTO>>().ok(icPartyMemberService.partyMemberAgeStatistics(formDTO));
     }
 
     /**
-    * @describe: 组装党组织信息
+     * 烟台党员画像列表-导出
-    * @author wangtong
+     * @return 返回导出excel的文件名
-    * @date 2022/7/8 16:46
+     */
-    * @params [tokenDto, formDTO]
+    private String getPartymemberPortraitFileName(String codeType, String code) {
-    * @return com.epmet.modules.partyOrg.entity.IcPartyOrgEntity
+        String name = "党员画像";
-    */
+        if ("age".equals(codeType)) {
-    public IcPartyOrgEntity setOrgId(TokenDto tokenDto){
+            switch (code) {
-        CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(tokenDto.getCustomerId(),tokenDto.getUserId());
+                case NumConstant.ZERO_STR:
-        if (null == staffInfo) {
+                    name = "50岁以下党员信息";
-            throw new EpmetException("获取工作人员信息失败");
+                    break;
+                case NumConstant.ONE_STR:
+                    name = "50-59岁党员信息";
+                    break;
+                case NumConstant.TWO_STR:
+                    name = "60-69岁党员信息";
+                    break;
+                case NumConstant.THREE_STR:
+                    name = "70-79岁党员信息";
+                    break;
+                case NumConstant.FOUR_STR:
+                    name = "80岁以上党员信息";
+                    break;
+                default:
+                    name = "";
+                    break;
+            }
+        }else if ("education".equals(codeType)) {
+            switch (code) {
+                case NumConstant.ZERO_STR:
+                    name = "小学及文盲党员信息";
+                    break;
+                case NumConstant.ONE_STR:
+                    name = "初中学历党员信息";
+                    break;
+                case NumConstant.TWO_STR:
+                    name = "高中学历党员信息";
+                    break;
+                case NumConstant.THREE_STR:
+                    name = "大专学历党员信息";
+                    break;
+                case NumConstant.FOUR_STR:
+                    name = "本科学历党员信息";
+                    break;
+                case NumConstant.FIVE_STR:
+                    name = "硕士学历党员信息";
+                    break;
+                case NumConstant.SIX_STR:
+                    name = "博士学历党员信息";
+                    break;
+                default:
+                    name = "党员画像";
+                    break;
+            }
         }
-        //获取工作人员所属组织同级的党组织
+        String fileName=name+DateUtils.format(new Date()) + ".xlsx";
-        LambdaQueryWrapper<IcPartyOrgEntity> orgWrapper = new LambdaQueryWrapper<>();
+        return fileName;
-        orgWrapper.eq(IcPartyOrgEntity::getCustomerId, tokenDto.getCustomerId());
-        orgWrapper.eq(IcPartyOrgEntity::getAgencyId, staffInfo.getAgencyId());
-        orgWrapper.ne(IcPartyOrgEntity::getPartyOrgType, NumConstant.FIVE_STR);
-        return icPartyOrgDao.selectOne(orgWrapper);
     }
 
 

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/dao/IcPartyMemberDao.java

@@ -65,7 +65,10 @@ public interface IcPartyMemberDao extends BaseDao<IcPartyMemberEntity> {
     * @params [orgId, code]
     * @return java.util.List<com.epmet.dto.result.PartyMemberEducationResultDTO>
     */
-    List<PartyMemberEducationResultDTO> getPartyMemberEducationList(@Param("agencyId") String agencyId,@Param("orgId") String orgId,@Param("code")  String code);
+    List<PartyMemberEducationResultDTO> getPartyMemberEducationList(@Param("agencyId") String agencyId,
+                                                                    @Param("orgId") String orgId,
+                                                                    @Param("code")  String code,
+                                                                    @Param("codeType") String codeType);
 
     /**
     * @describe: 党员年龄范围统计

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/IcPartyMemberService.java

@@ -8,6 +8,7 @@ import com.epmet.dto.form.IcPartyMemberFormDTO;
 import com.epmet.dto.form.IcPartyMemberListFormDTO;
 import com.epmet.dto.result.PartyMemberAgeResultDTO;
 import com.epmet.dto.result.PartyMemberEducationResultDTO;
+import com.epmet.resi.partymember.dto.partymember.result.PartymemberPortraitResultDTO;
 import com.epmet.modules.partymember.entity.IcPartyMemberEntity;
 import com.epmet.resi.partymember.dto.partymember.IcPartyMemberDTO;
 import com.epmet.resi.partymember.dto.partymember.form.IcPartyMemberFromDTO;
@@ -150,4 +151,11 @@ public interface IcPartyMemberService extends BaseService<IcPartyMemberEntity> {
     void execAsyncExcelImport(Path filePath, String importTaskId);
 
     IcPartyInfoResultDTO partyInfo(TokenDto tokenDto);
+
+    /**
+     * 烟台管理平台党员画像，列表查询
+     * @param formDTO
+     * @return
+     */
+    PageData<PartymemberPortraitResultDTO> queryPartyMemberPortraitList(IcPartyMemberListFormDTO formDTO);
 }

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/IcPartyMemberServiceImpl.java

@@ -10,7 +10,6 @@ import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.constant.StrConstant;
 import com.epmet.commons.tools.dto.form.DictListFormDTO;
-import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
 import com.epmet.commons.tools.dto.result.DictListResultDTO;
 import com.epmet.commons.tools.dto.result.OptionDataResultDTO;
 import com.epmet.commons.tools.enums.DictTypeEnum;
@@ -22,7 +21,6 @@ import com.epmet.commons.tools.exception.ExceptionUtils;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.feign.ResultDataResolver;
 import com.epmet.commons.tools.page.PageData;
-import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.*;
 import com.epmet.constants.ImportTaskConstants;
@@ -49,6 +47,7 @@ import com.epmet.resi.partymember.dto.partymember.IcPartyMemberDTO;
 import com.epmet.resi.partymember.dto.partymember.form.IcPartyMemberFromDTO;
 import com.epmet.resi.partymember.dto.partymember.result.IcPartyInfoResultDTO;
 import com.epmet.resi.partymember.dto.partymember.result.IcPartyMemberResultDTO;
+import com.epmet.resi.partymember.dto.partymember.result.PartymemberPortraitResultDTO;
 import com.epmet.utils.ImportTaskUtils;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -106,17 +105,9 @@ public class IcPartyMemberServiceImpl extends BaseServiceImpl<IcPartyMemberDao,
 
     @Override
     public PageData<IcPartyMemberResultDTO> page(TokenDto tokenDto, IcPartyMemberFromDTO formDTO) {
-        CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(tokenDto.getCustomerId(), tokenDto.getUserId());
-        if (null == staffInfo) {
-            throw new EpmetException("获取工作人员信息失败");
-        }
         if (StringUtils.isBlank(formDTO.getPartyOrgId())) {
             //获取工作人员所属组织同级的党组织
-            LambdaQueryWrapper<IcPartyOrgEntity> orgWrapper = new LambdaQueryWrapper<>();
+            IcPartyOrgEntity org = icPartyOrgService.getIcPartyOrg(tokenDto.getCustomerId(),tokenDto.getUserId());
-            orgWrapper.eq(IcPartyOrgEntity::getCustomerId, tokenDto.getCustomerId());
-            orgWrapper.eq(IcPartyOrgEntity::getAgencyId, staffInfo.getAgencyId());
-            orgWrapper.ne(IcPartyOrgEntity::getPartyOrgType, NumConstant.FIVE_STR);
-            IcPartyOrgEntity org = icPartyOrgDao.selectOne(orgWrapper);
             if (null == org) {
                 return new PageData<>(Collections.emptyList(), 0);
             }
@@ -177,17 +168,8 @@ public class IcPartyMemberServiceImpl extends BaseServiceImpl<IcPartyMemberDao,
 
     @Override
     public IcPartyMemberDTO get(TokenDto tokenDto, String id) {
-
-        CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(tokenDto.getCustomerId(), tokenDto.getUserId());
-        if (null == staffInfo) {
-            throw new EpmetException("获取工作人员信息失败");
-        }
         //获取工作人员所属组织同级的党组织
-        LambdaQueryWrapper<IcPartyOrgEntity> orgWrapper = new LambdaQueryWrapper<>();
+        IcPartyOrgEntity orgInfo=icPartyOrgService.getIcPartyOrg(tokenDto.getCustomerId(),tokenDto.getUserId());
-        orgWrapper.eq(IcPartyOrgEntity::getCustomerId, tokenDto.getCustomerId());
-        orgWrapper.eq(IcPartyOrgEntity::getAgencyId, staffInfo.getAgencyId());
-        orgWrapper.ne(IcPartyOrgEntity::getPartyOrgType, NumConstant.FIVE_STR);
-        IcPartyOrgEntity orgInfo = icPartyOrgDao.selectOne(orgWrapper);
         if (null == orgInfo) {
             throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "党组织不存在", "党组织不存在");
         }
@@ -450,7 +432,7 @@ public class IcPartyMemberServiceImpl extends BaseServiceImpl<IcPartyMemberDao,
             PageHelper.startPage(formDTO.getPageNo(), formDTO.getPageSize());
             List<PartyMemberAgeResultDTO> list = baseDao.getPartyMemberAgeList(formDTO.getAgencyId(),formDTO.getOrgId(), formDTO.getCode());
             PageInfo<PartyMemberAgeResultDTO> pageInfo = new PageInfo<>(list);
-            return new PageData<>(list, pageInfo.getTotal());
+            return new PageData<>(list, pageInfo.getTotal(),formDTO.getPageSize());
         }
         List<PartyMemberAgeResultDTO> list = baseDao.getPartyMemberAgeList(formDTO.getAgencyId(),formDTO.getOrgId(), formDTO.getCode());
         return new PageData<>(list, null == list?NumConstant.ZERO:list.size());
@@ -460,23 +442,23 @@ public class IcPartyMemberServiceImpl extends BaseServiceImpl<IcPartyMemberDao,
     public PageData<PartyMemberEducationResultDTO> getPartyMemberEducationList(IcPartyMemberListFormDTO formDTO) {
         if (formDTO.getIsPage()) {
             PageHelper.startPage(formDTO.getPageNo(), formDTO.getPageSize());
-            List<PartyMemberEducationResultDTO> list = baseDao.getPartyMemberEducationList(formDTO.getAgencyId(),formDTO.getOrgId(), formDTO.getCode());
+            List<PartyMemberEducationResultDTO> list = baseDao.getPartyMemberEducationList(formDTO.getAgencyId(),formDTO.getOrgId(), formDTO.getCode(),"education");
-            Result<Map<String, String>> mapResult = epmetAdminOpenFeignClient.dictMap(DictTypeEnum.EDUCATION.getCode());
             PageInfo<PartyMemberEducationResultDTO> pageInfo = new PageInfo<>(list);
-            if (CollectionUtils.isNotEmpty(list)) {
+            // Result<Map<String, String>> mapResult = epmetAdminOpenFeignClient.dictMap(DictTypeEnum.EDUCATION.getCode());
-                list.forEach(item -> {
+            // if (CollectionUtils.isNotEmpty(list)) {
-                    item.setEducation(null == mapResult.getData().get(item.getEducation()) ? "" : mapResult.getData().get(item.getEducation()));
+            //     list.forEach(item -> {
-                });
+            //         item.setEducation(null == mapResult.getData().get(item.getEducation()) ? "" : mapResult.getData().get(item.getEducation()));
-            }
+            //     });
-            return new PageData<>(list, pageInfo.getTotal());
+            // }
-        }
+            return new PageData<>(list, pageInfo.getTotal(),formDTO.getPageSize());
-        List<PartyMemberEducationResultDTO> list = baseDao.getPartyMemberEducationList(formDTO.getAgencyId(),formDTO.getOrgId(), formDTO.getCode());
+        }
-        Result<Map<String, String>> mapResult = epmetAdminOpenFeignClient.dictMap(DictTypeEnum.EDUCATION.getCode());
+        List<PartyMemberEducationResultDTO> list = baseDao.getPartyMemberEducationList(formDTO.getAgencyId(),formDTO.getOrgId(), formDTO.getCode(),"education");
-        if (CollectionUtils.isNotEmpty(list)) {
+        // Result<Map<String, String>> mapResult = epmetAdminOpenFeignClient.dictMap(DictTypeEnum.EDUCATION.getCode());
-            list.forEach(item -> {
+        // if (CollectionUtils.isNotEmpty(list)) {
-                item.setEducation(null == mapResult.getData().get(item.getEducation()) ? "" : mapResult.getData().get(item.getEducation()));
+        //     list.forEach(item -> {
-            });
+        //         item.setEducation(null == mapResult.getData().get(item.getEducation()) ? "" : mapResult.getData().get(item.getEducation()));
-        }
+        //     });
+        // }
         return new PageData<>(list, null == list?NumConstant.ZERO:list.size());
 
     }
@@ -734,5 +716,39 @@ public class IcPartyMemberServiceImpl extends BaseServiceImpl<IcPartyMemberDao,
         return resultDTO;
     }
 
+    /**
+     * 烟台管理平台党员画像，列表查询
+     *
+     * @param formDTO
+     * @return
+     */
+    @Override
+    public PageData<PartymemberPortraitResultDTO> queryPartyMemberPortraitList(IcPartyMemberListFormDTO formDTO) {
+        if (StringUtils.isBlank(formDTO.getOrgId())) {
+            // 当前工作人员所属组织下的，党组织
+            IcPartyOrgEntity org= icPartyOrgService.getIcPartyOrg(EpmetRequestHolder.getLoginUserCustomerId(),EpmetRequestHolder.getLoginUserId());
+            if (null == org) {
+                return new PageData<>(Collections.emptyList(), 0, formDTO.getPageSize());
+            }
+            formDTO.setOrgId(org.getId());
+        }
+        if ("age".equals(formDTO.getCodeType())) {
+            PageHelper.startPage(formDTO.getPageNo(), formDTO.getPageSize());
+            List<PartyMemberAgeResultDTO> list = baseDao.getPartyMemberAgeList(formDTO.getAgencyId(), formDTO.getOrgId(), formDTO.getCode());
+            PageInfo pageInfo = new PageInfo<>(list);
+
+            List<PartymemberPortraitResultDTO> resultDTOList = ConvertUtils.sourceToTarget(list, PartymemberPortraitResultDTO.class);
+            return new PageData<>(resultDTOList, pageInfo.getTotal(), formDTO.getPageSize());
+
+        }
+        // else if ("education".equals(formDTO.getCodeType())) {
+        PageHelper.startPage(formDTO.getPageNo(), formDTO.getPageSize());
+        List<PartyMemberEducationResultDTO> list = baseDao.getPartyMemberEducationList(formDTO.getAgencyId(), formDTO.getOrgId(), formDTO.getCode(),formDTO.getCodeType());
+        PageInfo pageInfo = new PageInfo<>(list);
+
+        List<PartymemberPortraitResultDTO> resultDTOList = ConvertUtils.sourceToTarget(list, PartymemberPortraitResultDTO.class);
+        return new PageData<>(resultDTOList, pageInfo.getTotal(), formDTO.getPageSize());
+    }
+
 
 }

epmet-module/resi-partymember/resi-partymember-server/src/main/resources/mapper/partymember/IcPartyMemberDao.xml

@@ -165,7 +165,9 @@
             NAME,
             MOBILE,
             age,
-            IC_RESI_USER
+            IC_RESI_USER,
+            ID_CARD,
+            education
         FROM
             (
                 SELECT
@@ -173,14 +175,16 @@
                     NAME,
                     MOBILE,
                     age,
-                    CASE
+                    (CASE
                     WHEN age < 50 THEN '0'
                     WHEN age >= 50 AND age <= 59 THEN '1'
                     WHEN age >= 60 AND age <= 69 THEN '2'
                     WHEN age >= 70 AND age <= 79 THEN '3'
                     ELSE '4'
-                    END AS ageGroup,
+                    END )AS ageGroup,
-                    IC_RESI_USER
+                    IC_RESI_USER,
+                    ID_CARD,
+                    education
                 FROM
                     (
                         SELECT
@@ -188,7 +192,20 @@
                             NAME,
                             MOBILE,
                             YEAR (FROM_DAYS(DATEDIFF(NOW(),SUBSTRING( ID_CARD, 7, 8 )))) AS age,
-                            IC_RESI_USER
+                            IC_RESI_USER,
+                            ID_CARD,
+                            (
+                                case when CULTURE='0' then '小学及文盲'
+                                when CULTURE='1' then '初中'
+                                when CULTURE='2' then '高中'
+                                when CULTURE='3' then '大专'
+                                when CULTURE='4' then '本科'
+                                when CULTURE='5' then '硕士'
+                                when CULTURE='6' then '博士'
+                                when CULTURE='7' then '中专'
+                                else ''
+                                end
+                            )as education
                         FROM
                             ic_party_member
                         WHERE
@@ -206,22 +223,37 @@
         <if test="null != code and '' != code">
             WHERE ageGroup = #{code}
         </if>
-        ORDER BY CONVERT(NAME USING GBK) ASC
+        ORDER BY ID ASC
     </select>
     <select id="getPartyMemberEducationList" resultType="com.epmet.dto.result.PartyMemberEducationResultDTO">
         SELECT
             ID AS "userId",
             NAME,
             MOBILE,
-            CULTURE AS education,
+            ID_CARD,
+            (
+                case when CULTURE='0' then '小学及文盲'
+                when CULTURE='1' then '初中'
+                when CULTURE='2' then '高中'
+                when CULTURE='3' then '大专'
+                when CULTURE='4' then '本科'
+                when CULTURE='5' then '硕士'
+                when CULTURE='6' then '博士'
+                when CULTURE='7' then '中专'
+                else ''
+                end
+            )as education,
+            YEAR (FROM_DAYS(DATEDIFF(NOW(),SUBSTRING( ID_CARD, 7, 8 )))) AS age,
             IC_RESI_USER
         FROM
             ic_party_member
         WHERE
             DEL_FLAG = '0'
-            AND CULTURE IS NOT NULL
+            <if test="null != codeType and 'education' == codeType">
-            <if test="null != code and '' != code">
+                AND CULTURE IS NOT NULL
-                AND CULTURE = #{code}
+                <if test="null != code and '' != code">
+                    AND CULTURE = #{code}
+                </if>
             </if>
             <choose>
                 <when test='orgId != "" and orgId != null'>
@@ -231,7 +263,7 @@
                     AND (AGENCY_ID = #{agencyId} OR AGENCY_PIDS LIKE CONCAT('%',#{agencyId},'%'))
                 </otherwise>
             </choose>
-        ORDER BY CONVERT(NAME USING GBK) ASC
+        ORDER BY ID ASC
     </select>
     <select id="getPartyMemberAgeStatistics"
             resultType="com.epmet.commons.tools.dto.result.OptionDataResultDTO">

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/IcPartyMemberListFormDTO.java

@@ -15,9 +15,20 @@ public class IcPartyMemberListFormDTO extends PageFormDTO implements Serializabl
 
     private static final long serialVersionUID = -6085134769034337175L;
 
+    /**
+     * 党组织id
+     */
     private String orgId;
 
     private String code;
 
     private String agencyId;
+
+    /**
+     * 烟台党员画像列表接口，将上方两个接口，合为一个
+     * 年龄：age
+     * 学历：education
+     * 如果不传默认查询所有党员
+     */
+    private String codeType;
 }

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/PartyMemberAgeResultDTO.java

@@ -14,7 +14,17 @@ public class PartyMemberAgeResultDTO implements Serializable {
     private static final long serialVersionUID = 3421162784157903637L;
     private String userId;
     private String name;
+
+    private String idCard;
+
     private String age;
+    /**
+     * 烟台党员画像列表接口，将上方两个接口，合为一个
+     * 在这个dto里增加了education
+     */
+    private String education;
+
+
     private String mobile;
     private String icResiUser;
 }

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/PartyMemberEducationResultDTO.java

@@ -14,6 +14,13 @@ public class PartyMemberEducationResultDTO implements Serializable {
     private static final long serialVersionUID = -5042362121277863249L;
     private String userId;
     private String name;
+    private String idCard;
+    /**
+     * 烟台党员画像列表接口，将上方两个接口，合为一个
+     * 在这个dto里增加了age
+     */
+    private String age;
+
     private String education;
     private String mobile;
     private String icResiUser;