From 417d0a5be24ceedc295ba58be7c7db43fbfd686f Mon Sep 17 00:00:00 2001
From: lidongdong <1459917685@qq.com>
Date: 星期四, 07 三月 2024 10:05:37 +0800
Subject: [PATCH] 修改双争双评问题列表没数据2
---
springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java | 203 ++++++++++++++++++++++++++++++++++++++++----------
1 files changed, 162 insertions(+), 41 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java
index 5d7fbdf..334b67c 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComPbMemberServiceImpl.java
@@ -1,37 +1,8 @@
package com.panzhihua.service_dangjian.service.impl;
-import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.stream.Collectors;
-
-import javax.annotation.Resource;
-
+import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.IdcardUtil;
import com.alibaba.fastjson.JSONObject;
-import com.google.common.collect.Lists;
-import com.panzhihua.common.enums.ComPbMemberRoleTypeEnum;
-import com.panzhihua.common.model.dtos.partybuilding.ComDataStatisticsOrgDto;
-import com.panzhihua.common.model.dtos.partybuilding.PageComDataStatisticsMemberDto;
-import com.panzhihua.common.model.vos.community.ComMngVolunteerMngVO;
-import com.panzhihua.common.model.vos.partybuilding.excel.ComDataStatisticsMemberExcelVo;
-import com.panzhihua.common.model.vos.partybuilding.excel.ComPbCheckUnitErrorExcelVO;
-import com.panzhihua.common.model.vos.partybuilding.excel.ComPbMemberRoleErrorExcelVo;
-import com.panzhihua.common.model.vos.partybuilding.excel.ComPbMemberRoleExcelVo;
-import com.panzhihua.common.service.community.CommunityService;
-import com.panzhihua.common.service.user.UserService;
-import com.panzhihua.service_dangjian.entity.ComPbCheckUnit;
-import io.swagger.annotations.ApiModelProperty;
-import org.springframework.beans.BeanUtils;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-import org.springframework.util.CollectionUtils;
-import org.springframework.util.ObjectUtils;
-
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -39,18 +10,42 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.constants.UserConstants;
import com.panzhihua.common.exceptions.PartyBuildingMemberException;
+import com.panzhihua.common.model.dtos.community.PageMemberForInviteDTO;
+import com.panzhihua.common.model.dtos.partybuilding.ComDataStatisticsOrgDto;
+import com.panzhihua.common.model.dtos.partybuilding.NewFightResourceSharingDTO;
+import com.panzhihua.common.model.dtos.partybuilding.PageComDataStatisticsMemberDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.partybuilding.*;
+import com.panzhihua.common.model.vos.partybuilding.excel.ComDataStatisticsMemberExcelVo;
+import com.panzhihua.common.model.vos.partybuilding.excel.ComPbMemberRoleExcelVo;
import com.panzhihua.common.model.vos.user.SysUserVO;
+import com.panzhihua.common.service.user.UserService;
import com.panzhihua.common.utlis.DateUtils;
import com.panzhihua.common.utlis.RichTextUtil;
import com.panzhihua.common.utlis.SensitiveUtil;
import com.panzhihua.common.utlis.StringUtils;
import com.panzhihua.service_dangjian.dao.*;
-import com.panzhihua.service_dangjian.model.dos.*;
+import com.panzhihua.service_dangjian.entity.ComActProject;
+import com.panzhihua.service_dangjian.model.dos.ComPbDynDO;
+import com.panzhihua.service_dangjian.model.dos.ComPbDynUserDO;
+import com.panzhihua.service_dangjian.model.dos.ComPbMemberDO;
+import com.panzhihua.service_dangjian.model.dos.ComPbOrgDO;
import com.panzhihua.service_dangjian.service.ComPbMemberService;
-
import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.ObjectUtils;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
import static java.util.Objects.nonNull;
@@ -77,9 +72,11 @@
@Resource
private ComPbDynUserDAO comPbDynUserDAO;
@Resource
- private CommunityService communityService;
- @Resource
private UserService userService;
+ @Autowired
+ private ComActProjectMapper comActProjectMapper;
+ @Autowired
+ private NewFightResourceSharingDAO newFightResourceSharingDAO;
/**
* 新增党员
@@ -212,6 +209,18 @@
*/
@Override
public R pagePartyOrganization(PagePartyOrganizationVO pagePartyOrganizationVO) {
+
+ Long communityId = pagePartyOrganizationVO.getCommunityId();
+
+ if (null != communityId){
+ List<Long> communityIds = comPbMemberDAO.selectIds(communityId);
+ if (CollUtil.isEmpty(communityIds)) {
+ communityIds = new ArrayList<>();
+ communityIds.add(communityId);
+ }
+ pagePartyOrganizationVO.setCommunityIds(communityIds);
+ }
+
Page page = new Page<>();
Long pageNum = pagePartyOrganizationVO.getPageNum();
Long pageSize = pagePartyOrganizationVO.getPageSize();
@@ -300,7 +309,22 @@
@Override
public R pagePartyCommittee(PartyCommitteeVO partyCommitteeVO) {
- return null;
+ Page page = new Page<>();
+ Long pageNum = partyCommitteeVO.getPageNum();
+ Long pageSize = partyCommitteeVO.getPageSize();
+ if (null == pageNum || 0 == pageNum) {
+ pageNum = 1l;
+ }
+ if (null == pageSize || 0 == pageSize) {
+ pageSize = 10l;
+ }
+ page.setSize(pageSize);
+ page.setCurrent(pageNum);
+ IPage<PartyCommitteeVO> iPage = comPbMemberRoleDAO.pagePartyOrganizations(page, partyCommitteeVO);
+ iPage.getRecords().forEach(record -> {
+ record.setPhone(SensitiveUtil.desensitizedPhoneNumber(record.getPhone()));
+ });
+ return R.ok(iPage);
}
// /**
@@ -508,8 +532,31 @@
}
@Override
- public R pageYnamic(PartyBuildingComPbDynVO partyBuildingComPbDynVO) {
- return null;
+ public R pageYnamic(PartyBuildingComPbDynVO partyBuildingComPbDynVO)
+ {
+ Page page = new Page<>();
+ Long pageNum = partyBuildingComPbDynVO.getPageNum();
+ Long pageSize = partyBuildingComPbDynVO.getPageSize();
+ if (null == pageNum) {
+ pageNum = 1l;
+ }
+ if (null == pageSize) {
+ pageSize = 10l;
+ }
+ page.setSize(pageSize);
+ page.setCurrent(pageNum);
+ IPage<PartyBuildingComPbDynVO> iPage = comPbDynDAO.pageYnamics(page, partyBuildingComPbDynVO);
+ List<PartyBuildingComPbDynVO> records = iPage.getRecords();
+ if (!(ObjectUtils.isEmpty(records))) {
+ records.forEach(partyBuildingComPbDynVO1 -> {
+ String content = partyBuildingComPbDynVO1.getContent();
+ if (!ObjectUtils.isEmpty(content)) {
+ String text = RichTextUtil.getText(content);
+ partyBuildingComPbDynVO1.setContentText(text);
+ }
+ });
+ }
+ return R.ok(iPage);
}
@Override
@@ -847,7 +894,7 @@
}
//查询左下数据
- statisticsVo = comPbMemberDAO.getOrgDataStatisticsLeftDown(communityId,orgIds,startTime,endTime);
+ statisticsVo = comPbMemberDAO.getOrgDataStatisticsLeftDown(communityId,orgIds,startTime,endTime,"");
if(statisticsVo != null){
statisticsOrgVo.setParticipateVolunteerActivityDuration(statisticsVo.getParticipateVolunteerActivityDuration());
statisticsOrgVo.setParticipateVolunteerActivityNum(statisticsVo.getParticipateVolunteerActivityNum());
@@ -858,8 +905,9 @@
}
//查询党员数据
- IPage<PartyBuildingMemberVO> partyMemberPage = comPbMemberDAO.getOrgDataStatisticsMember(new Page(statisticsOrgDto.getPageNum()
- ,statisticsOrgDto.getPageSize()),communityId,orgIds);
+ IPage<PartyBuildingMemberVO> partyMemberPage = comPbMemberDAO.getOrgDataStatisticsMember(
+ new Page(statisticsOrgDto.getPageNum()
+ ,statisticsOrgDto.getPageSize()),communityId,orgIds,"");
if(partyMemberPage.getRecords() != null && !partyMemberPage.getRecords().isEmpty()){
statisticsOrgVo.setPartyMemberList(partyMemberPage.getRecords());
}
@@ -871,7 +919,8 @@
List<String> completeEasyList = new ArrayList<>();
List<String> cumulativeEasyList = new ArrayList<>();
for (int i = 0; i < startDateList.size(); i++) {
- Map<String,Object> statisticsMap = comPbMemberDAO.getOrgDataStatisticsRightDown(communityId,orgIds, startDateList.get(i) + " 00:00:00", endDateList.get(i) + " 23:59:59");
+ Map<String,Object> statisticsMap = comPbMemberDAO.getOrgDataStatisticsRightDown(communityId,orgIds,
+ startDateList.get(i) + " 00:00:00", endDateList.get(i) + " 23:59:59");
if(statisticsMap != null){
completeWishList.add(statisticsMap.get("completeWishNum").toString());
cumulativeWishList.add(statisticsMap.get("cumulativeWishNum").toString());
@@ -1157,6 +1206,68 @@
}
@Override
+ public R getProject(ProjectVO projectVO) {
+ LambdaQueryWrapper<ComActProject> wrapper = new LambdaQueryWrapper<>();
+ wrapper.eq(ComActProject::getUnitId,projectVO.getUnitId());
+ wrapper.eq(projectVO.getSpeciality()!=null,ComActProject::getSpeciality,projectVO.getSpeciality());
+ wrapper.eq(projectVO.getProject()!=null,ComActProject::getProject,projectVO.getProject());
+ wrapper.orderByDesc(ComActProject::getCreateTime);
+ List<ComActProject> comActProjects = comActProjectMapper.selectList(wrapper);
+ return R.ok(comActProjects);
+ }
+
+ @Transactional(rollbackFor = Exception.class)
+ @Override
+ public R addProject(ProjectVO projectVO) {
+ Date date = new Date();
+ ComActProject comActProject = new ComActProject();
+ comActProject.setUnitId(projectVO.getUnitId());
+ comActProject.setUnitName(projectVO.getUnitName());
+ comActProject.setSpeciality(projectVO.getSpeciality());
+ comActProject.setProject(projectVO.getProject());
+ comActProject.setPhone(projectVO.getPhone());
+ comActProject.setImage(projectVO.getImage());
+ comActProject.setCreateTime(date);
+ comActProjectMapper.insert(comActProject);
+ // new_fight_resource_sharing
+ NewFightResourceSharingDTO dto = new NewFightResourceSharingDTO();
+ dto.setTitle(projectVO.getProject());
+ dto.setUnitId(String.valueOf(projectVO.getUnitId()));
+ dto.setMeritId(projectVO.getSpeciality());
+ dto.setImgUrl(projectVO.getImage());
+ dto.setPhone(projectVO.getPhone());
+ dto.setCommunityId(projectVO.getCommunityId());
+ dto.setCreationTime(date);
+ newFightResourceSharingDAO.addData(dto);
+ return R.ok();
+ }
+
+ @Override
+ public R updateProject(ProjectVO projectVO) {
+ LambdaQueryWrapper<ComActProject> wrapper = new LambdaQueryWrapper<>();
+ wrapper.eq(ComActProject::getUnitId,projectVO.getUnitId());
+ wrapper.eq(ComActProject::getId,projectVO.getId());
+ ComActProject actProject = comActProjectMapper.selectOne(wrapper);
+ actProject.setSpeciality(projectVO.getSpeciality());
+ actProject.setProject(projectVO.getProject());
+ actProject.setPhone(projectVO.getPhone());
+ if(projectVO.getImage() != null){
+ actProject.setImage(projectVO.getImage());
+ }
+ comActProjectMapper.updateById(actProject);
+ return R.ok();
+ }
+
+ @Override
+ public R deleteProject(ProjectVO projectVO) {
+ List<Long> ids = projectVO.getIds();
+ LambdaQueryWrapper<ComActProject> wrapper = new LambdaQueryWrapper<>();
+ wrapper.in(ComActProject::getId,ids);
+ comActProjectMapper.delete(wrapper);
+ return R.ok();
+ }
+
+ @Override
public R getPartyMember(String phone,Integer type) {
return R.ok(comPbMemberDAO.selectDetail(phone,type));
@@ -1166,4 +1277,14 @@
public R memberDetail(Long id) {
return R.ok(comPbMemberDAO.getDetailByApp(id));
}
+
+ /**
+ * 分页查询注册党员列表
+ * @param dto
+ * @return
+ */
+ @Override
+ public R pageRegisterMember(PageMemberForInviteDTO dto) {
+ return R.ok(comPbMemberDAO.pageRegisterMember(new Page(dto.getPageNum(), dto.getPageSize()), dto));
+ }
}
--
Gitblit v1.7.1