From 3c884ccd7b51edf3b36840bf99de5edaa41a38a7 Mon Sep 17 00:00:00 2001
From: 张天森 <1292933220@qq.com>
Date: 星期三, 12 十月 2022 19:05:28 +0800
Subject: [PATCH] 三说会堂事件流程处理

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java |  288 +++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 229 insertions(+), 59 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
index 42b9d5e..81a9fb7 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
@@ -1,22 +1,7 @@
 package com.panzhihua.service_community.service.impl;
 
-import java.util.*;
-
-import javax.annotation.Resource;
-
 import cn.hutool.core.collection.ListUtil;
-import cn.hutool.core.util.NumberUtil;
 import cn.hutool.core.util.PageUtil;
-import com.panzhihua.common.model.vos.LoginUserInfoVO;
-import com.panzhihua.common.model.vos.PageVO;
-import com.panzhihua.common.service.user.UserService;
-import com.panzhihua.service_community.entity.ComPbCheckUnit;
-import com.panzhihua.service_community.service.ComActNeighborCircleTopicService;
-import org.apache.commons.lang3.ObjectUtils;
-import org.springframework.beans.BeanUtils;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -24,17 +9,27 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.panzhihua.common.constants.NeighborCircleConstants;
 import com.panzhihua.common.model.dtos.neighbor.*;
+import com.panzhihua.common.model.vos.PageVO;
 import com.panzhihua.common.model.vos.R;
 import com.panzhihua.common.model.vos.neighbor.*;
 import com.panzhihua.common.model.vos.user.AdministratorsUserVO;
-import com.panzhihua.common.utlis.DateUtils;
-import com.panzhihua.common.utlis.StringUtils;
+import com.panzhihua.common.service.user.UserService;
+import com.panzhihua.common.utlis.*;
 import com.panzhihua.service_community.dao.*;
+import com.panzhihua.service_community.entity.ComPbCheckUnit;
+import com.panzhihua.service_community.entity.SysUser;
 import com.panzhihua.service_community.model.dos.*;
 import com.panzhihua.service_community.service.ComActNeighborCircleBrowseService;
 import com.panzhihua.service_community.service.ComActNeighborCircleService;
-
+import com.panzhihua.service_community.service.ComActNeighborCircleTopicService;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.util.*;
 
 /**
  * @auther lyq
@@ -80,6 +75,8 @@
     private ComActActivityDAO comActActivityDAO;
     @Resource
     private ComPbCheckUnitDao comPbCheckUnitDao;
+    @Resource
+    private SysUserDao sysUserDao;
     /**
      * 分页查询邻里圈列表
      *
@@ -191,6 +188,7 @@
         if (StringUtils.isNotEmpty(addNeighborCircleAppDTO.getPhone())) {
             neighborCircleDO.setReleasePhone(addNeighborCircleAppDTO.getPhone());
         }
+
         //判断当前邻里圈是否需要审核
         if(addNeighborCircleAppDTO.getIsExamine().equals(AddComActNeighborCircleAppDTO.isExamine.no)){
             //当邻里圈不需要审核才进入自动审核
@@ -238,6 +236,18 @@
                 circleDetailAppVO.setName(actDO.getName());
             }
         }
+        if(circleDetailAppVO.getOrderType()!=null){
+            if(circleDetailAppVO.getOrderType()==2){
+                AdministratorsUserVO user1 = this.baseMapper.selectUserByUserId(circleDetailAppVO.getSolveId());
+                circleDetailAppVO.setSolveName(SensitiveUtil.replaceName(user1.getName()));
+            }
+            if(circleDetailAppVO.getOrderType()==1){
+                ComPbCheckUnit comPbCheckUnit=comPbCheckUnitDao.selectById(circleDetailAppVO.getSolveUnitId());
+                if(comPbCheckUnit!=null){
+                    circleDetailAppVO.setSolveName(comPbCheckUnit.getName());
+                }
+            }
+        }
 
         if (neighborCircleAppDTO.getUserId() != null) {
             // 查询邻里圈点赞信息
@@ -254,7 +264,12 @@
                 circleDetailAppVO.setHaveSign(2);
             }
         }
-
+        ComActActivityDO comActActivityDO=comActActivityDAO.selectOne(new QueryWrapper<ComActActivityDO>().lambda().eq(ComActActivityDO::getRelationId,neighborCircleAppDTO.getCircleId()));
+        if(comActActivityDO!=null){
+            circleDetailAppVO.setActivityDate(comActActivityDO.getCreateAt());
+            circleDetailAppVO.setActivityId(comActActivityDO.getId());
+            circleDetailAppVO.setActivityName(comActActivityDO.getActivityName());
+        }
         // 查询邻里圈下评论列表
         IPage<ComActNeighborCircleCommentAppVO> circleCommentAppPage =
             comActNeighborCircleCommentDAO.pageNeighborCommentByApp(
@@ -465,6 +480,7 @@
             ComActNeighborCircleCommentDO circleCommentDO =
                 comActNeighborCircleCommentDAO.selectById(fabulousAppDTO.getServiceId());
             if (circleCommentDO != null) {
+
                 circleCommentDO.setFabulousNum(circleCommentDO.getFabulousNum() + 1);
                 comActNeighborCircleCommentDAO.updateById(circleCommentDO);
                 //计算需要增加的热度值
@@ -569,6 +585,20 @@
         }
 
         if (comActNeighborCircleCommentDAO.insert(circleCommentDO) > 0) {
+            SysUser sysUser=sysUserDao.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId,neighborCircleDO.getSolveId()));
+            if(sysUser!=null) {
+                try {
+                    WxXCXTempSend util = new WxXCXTempSend();
+                    if (neighborCircleDO.getBelongType()==2){
+                        WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你有一条新的评价信息",neighborCircleDO.getReleaseContent().length()>10?neighborCircleDO.getReleaseContent().substring(0,10)+"..":neighborCircleDO.getReleaseContent(),"packageB/pages/partySecond/problemDetails/index?id="+neighborCircleDO.getId()+"&type=888");
+                    }
+                    if (neighborCircleDO.getBelongType()==3){
+                        WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你有一条新的评价信息",neighborCircleDO.getReleaseContent().length()>10?neighborCircleDO.getReleaseContent().substring(0,10)+"..":neighborCircleDO.getReleaseContent(),"packageB/pages/partySecond/problemDetails/index?id="+neighborCircleDO.getId()+"&type=777");
+                    }
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            }
             return R.ok();
         } else {
             return R.fail("评论失败");
@@ -711,16 +741,20 @@
         AdministratorsUserVO user = this.baseMapper.selectUserByUserId(comActNeighborCircleDO.getReleaseId());
         DetailNeighborCircleAdminVO vo = new DetailNeighborCircleAdminVO();
         BeanUtils.copyProperties(comActNeighborCircleDO, vo);
-        vo.setReleaseName(user.getName());
-        vo.setImageUrl(user.getImageUrl());
-        if(comActNeighborCircleDO.getSolveId()!=null){
-            AdministratorsUserVO user1 = this.baseMapper.selectUserByUserId(comActNeighborCircleDO.getSolveId());
-            comActNeighborCircleDO.setSolveName(user1.getName());
+        if(user!=null){
+            vo.setReleaseName(user.getName());
+            vo.setImageUrl(user.getImageUrl());
         }
-        if(comActNeighborCircleDO.getSolveUnitId()!=null){
-            ComPbCheckUnit comPbCheckUnit=comPbCheckUnitDao.selectById(comActNeighborCircleDO.getSolveUnitId());
-            if(comPbCheckUnit!=null){
-                comActNeighborCircleDO.setSolveName(comPbCheckUnit.getName());
+        if(comActNeighborCircleDO.getOrderType()!=null){
+            if(comActNeighborCircleDO.getOrderType()==2){
+                AdministratorsUserVO user1 = this.baseMapper.selectUserByUserId(comActNeighborCircleDO.getSolveId());
+                vo.setSolveName(user1.getName());
+            }
+            if(comActNeighborCircleDO.getOrderType()==1){
+                ComPbCheckUnit comPbCheckUnit=comPbCheckUnitDao.selectById(comActNeighborCircleDO.getSolveUnitId());
+                if(comPbCheckUnit!=null){
+                    vo.setSolveName(comPbCheckUnit.getName());
+                }
             }
         }
 
@@ -997,33 +1031,86 @@
         if(StringUtils.isNotEmpty(comActNeighborCircleDO.getComment())){
             comActNeighborCircleDO.setCommentTime(new Date());
         }
-        return R.ok(this.baseMapper.updateById(comActNeighborCircleDO));
+        int result=this.baseMapper.updateById(comActNeighborCircleDO);
+        if(result>0){
+            ComActNeighborCircleDO comActNeighborCircleDO1=this.baseMapper.selectById(comActNeighborCircleDO.getId());
+            if(comActNeighborCircleDO.getOrderStatus()!=null){
+                SysUser sysUser=sysUserDao.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId,comActNeighborCircleDO1.getReleaseId()));
+                if(sysUser!=null) {
+                    try {
+                        WxXCXTempSend util = new WxXCXTempSend();
+                        if (comActNeighborCircleDO1.getBelongType()==2){
+                            WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你反馈的问题已被人认领",comActNeighborCircleDO1.getReleaseContent().length()>10?comActNeighborCircleDO1.getReleaseContent().substring(0,10)+"..":comActNeighborCircleDO1.getReleaseContent(),"packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=888");
+                        }
+                        if (comActNeighborCircleDO1.getBelongType()==3){
+                            WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你反馈的需求已被人认领",comActNeighborCircleDO1.getReleaseContent().length()>10?comActNeighborCircleDO1.getReleaseContent().substring(0,10)+"..":comActNeighborCircleDO1.getReleaseContent(),"packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=777");
+                        }
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+            if(comActNeighborCircleDO.getSolveStatus()==3){
+                SysUser sysUser=sysUserDao.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId,comActNeighborCircleDO1.getReleaseId()));
+                if(sysUser!=null) {
+                    try {
+                        WxXCXTempSend util = new WxXCXTempSend();
+                        if (comActNeighborCircleDO1.getBelongType()==2){
+                            WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你反馈的问题已被人处理",comActNeighborCircleDO1.getReleaseContent().length()>10?comActNeighborCircleDO1.getReleaseContent().substring(0,10)+"..":comActNeighborCircleDO1.getReleaseContent(),"packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=888");
+                        }
+                        if (comActNeighborCircleDO1.getBelongType()==3){
+                            WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你反馈的需求已被人处理",comActNeighborCircleDO1.getReleaseContent().length()>10?comActNeighborCircleDO1.getReleaseContent().substring(0,10)+"..":comActNeighborCircleDO1.getReleaseContent(),"packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=777");
+                        }
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+            if(comActNeighborCircleDO.getSolveStatus()==4){
+                SysUser sysUser=sysUserDao.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId,comActNeighborCircleDO1.getSolveId()));
+                if(sysUser!=null) {
+                    try {
+                        WxXCXTempSend util = new WxXCXTempSend();
+                        if (comActNeighborCircleDO1.getBelongType()==2){
+                            WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你有一条新的评价信息",comActNeighborCircleDO1.getReleaseContent().length()>10?comActNeighborCircleDO1.getReleaseContent().substring(0,10)+"..":comActNeighborCircleDO1.getReleaseContent(),"packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=888");
+                        }
+                        if (comActNeighborCircleDO1.getBelongType()==3){
+                            WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你有一条新的评价信息",comActNeighborCircleDO1.getReleaseContent().length()>10?comActNeighborCircleDO1.getReleaseContent().substring(0,10)+"..":comActNeighborCircleDO1.getReleaseContent(),"packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=777");
+                        }
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+            return R.ok(result);
+        }
+        return R.fail();
     }
 
     @Override
     public R serviceStatic(ServiceStaticDTO serviceStaticDTO) {
-        ServiceStaticsVO serviceStaticsVO=new ServiceStaticsVO();
-        if(serviceStaticDTO.getCheckUnitId()!=null){
-            serviceStaticsVO=this.baseMapper.selectStatsCheckUnit(serviceStaticDTO.getCheckUnitId(),serviceStaticDTO.getYear());
-            serviceStaticsVO=this.baseMapper.selectStatsCheckUnit(serviceStaticDTO.getCheckUnitId(),serviceStaticDTO.getYear());
-            serviceStaticsVO.setServiceProjecList(this.baseMapper.selectListByCheckUnitId(serviceStaticDTO.getCheckUnitId(),serviceStaticDTO.getYear()));
-            serviceStaticsVO.setServiceActivityList(comActActivityDAO.selectListByRelationId(serviceStaticDTO.getCheckUnitId(),serviceStaticDTO.getYear()));
-        }
-        else {
-            serviceStaticsVO=this.baseMapper.selectStatsUser(serviceStaticDTO.getPhone(),serviceStaticDTO.getYear());
-            serviceStaticsVO.setServiceProjecList(this.baseMapper.selectListByPhone(serviceStaticDTO.getPhone(),serviceStaticDTO.getYear()));
-            ComPbMemberDO comPbMemberDO=comPbMemberDAO.selectOne(new QueryWrapper<ComPbMemberDO>().lambda().eq(ComPbMemberDO::getPhone,serviceStaticDTO.getPhone()).last("limit 1"));
-            if(comPbMemberDO!=null){
-                serviceStaticsVO.setWorkActivityList(comActActivityDAO.selectListByRelationId(comPbMemberDO.getCheckUnitId(),serviceStaticDTO.getYear()));
-                serviceStaticsVO.setServiceActivityList(comActActivityDAO.selectListByCommunityId(comPbMemberDO.getCommunityId(),serviceStaticDTO.getYear()));
+        ServiceStaticsVO serviceStaticsVO = new ServiceStaticsVO();
+        if (serviceStaticDTO.getCheckUnitId() != null) {
+            serviceStaticsVO =
+                this.baseMapper.selectStatsCheckUnit(serviceStaticDTO.getCheckUnitId(), serviceStaticDTO.getYear());
+            serviceStaticsVO.setServiceDetailStaticsList(this.baseMapper.selectServiceDetailList(serviceStaticDTO.getCheckUnitId(),
+                    serviceStaticDTO.getYear(), serviceStaticDTO.getServiceType()));
+        } else {
+            serviceStaticsVO = this.baseMapper.selectStatsUser(serviceStaticDTO.getPhone(), serviceStaticDTO.getYear());
+            ComPbMemberDO comPbMemberDO = comPbMemberDAO.selectOne(new QueryWrapper<ComPbMemberDO>().lambda()
+                    .eq(ComPbMemberDO::getPhone, serviceStaticDTO.getPhone()).last("limit 1"));
+            Long checkUnitId = null;
+            if (comPbMemberDO != null) {
+                checkUnitId = comPbMemberDO.getCheckUnitId();
             }
-
+            serviceStaticsVO.setServiceDetailStaticsList(this.baseMapper.selectServiceDetailListForPersonal(checkUnitId, serviceStaticDTO.getPhone(),
+                    serviceStaticDTO.getYear(), serviceStaticDTO.getServiceType()));
         }
         return R.ok(serviceStaticsVO);
     }
 
     @Override
-    public R institutionalUnitServiceAnalysis(Integer year, Integer type, Integer range, Long communityId,Integer page,Integer size,String belongTo) {
+    public R institutionalUnitServiceAnalysis(Integer year, Integer type, Integer range, Long communityId,Integer page,Integer size,String belongTo,Long unitId) {
         ActivityAnalysisVO activityVO=new ActivityAnalysisVO();
         String beginTime=null;
         String endTime=null;
@@ -1036,9 +1123,9 @@
         activityVO.setPartyMemberCount(comActDAO.selectUnitCount());
         activityVO.setUnitCount(comActDAO.selectMemberCount());
         //获取单位活动统计数据(邻里圈)
-        List<UnitActivityAnalysisVO> unitActivityAnalysisVOS = comActNeighborCircleDAO.institutionalUnitServiceAnalysis(beginTime, endTime, belongTo);
+        List<UnitActivityAnalysisVO> unitActivityAnalysisVOS = comActNeighborCircleDAO.institutionalUnitServiceAnalysis(beginTime, endTime, belongTo,communityId);
         //获取单位活动统计数据(活动)
-        List<UnitActivityAnalysisVO> unitActivityAnalysisVOS1 = comActNeighborCircleDAO.institutionalUnitActivityAnalysis(beginTime, endTime, belongTo);
+        List<UnitActivityAnalysisVO> unitActivityAnalysisVOS1 = comActNeighborCircleDAO.institutionalUnitActivityAnalysis(beginTime, endTime, belongTo,communityId);
         if (unitActivityAnalysisVOS.size()>0){
             for (UnitActivityAnalysisVO unitActivityAnalysisVO : unitActivityAnalysisVOS){
                 if (ObjectUtils.isNotEmpty(unitActivityAnalysisVO)){
@@ -1079,7 +1166,25 @@
             }
         }
         //获取党员活动统计数据
-        List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo);
+        List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo,communityId,unitId);
+        List<PartyMemberAnalysisVO> partyMemberAnalysisVOS1 = comActNeighborCircleDAO.institutionalPartyMemberActAnalysis(beginTime, endTime, belongTo,communityId,unitId);
+        if (partyMemberAnalysisVOS1.size()>0){
+            for (PartyMemberAnalysisVO vo : partyMemberAnalysisVOS1) {
+                if (ObjectUtils.isNotEmpty(vo)){
+                    if (ObjectUtils.isNotEmpty(vo.getMemberId())){
+                        Map<String, Integer> param = memberAlreadyAnalysis(vo.getMemberId(), partyMemberAnalysisVOS);
+                        if (param.get("flag")==1){
+                            Integer serviceTime = vo.getServiceTime();
+                            Integer serviceTimes = vo.getServiceTimes();
+                            partyMemberAnalysisVOS.get(param.get("index")).setServiceTime(partyMemberAnalysisVOS.get(param.get("index")).getServiceTime()+serviceTime);
+                            partyMemberAnalysisVOS.get(param.get("index")).setServiceTimes(partyMemberAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes);
+                        }else{
+                            partyMemberAnalysisVOS.add(vo);
+                        }
+                    }
+                }
+            }
+        }
         //统计总时长和总次数
         Integer unitServiceCount=0;
         Integer unitServiceTotalTime=0;
@@ -1112,17 +1217,17 @@
         activityVO.setPartyMemberServiceTotalCount(memberServiceCount);
         activityVO.setPartyMemberServiceTotalTime(memberServiceTotalTome);
         //处理排序
-        if (null != type){
-            if (type.equals(1)){
-                //按时长排序
-                ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTime");
-                ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTime");
-            }else if (type.equals(2)){
-                //按次数排序
-                ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTimes");
-                ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTimes");
-            }
-        }
+//        if (null != type){
+//            if (type.equals(1)){
+//                //按时长排序
+//                ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTime");
+//                ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTime");
+//            }else if (type.equals(2)){
+//                //按次数排序
+//                ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTimes");
+//                ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTimes");
+//            }
+//        }
         //处理分页
         PageVO<List<UnitActivityAnalysisVO>> unitPage=new PageVO<>();
         PageVO<List<PartyMemberAnalysisVO>> memberPage=new PageVO<>();
@@ -1152,6 +1257,48 @@
     @Override
     public R serviceStaticBackstage(ServiceStaticBackstageDTO serviceStaticDTO) {
         return null;
+    }
+
+    @Override
+    public R selectCount(Integer type, String phone,Long communityId) {
+        return R.ok(this.baseMapper.selectCount(type,phone,communityId));
+    }
+
+    /**
+     * 分页查询可关联清单列表
+     * @param neighborCircleAppDTO
+     * @return
+     */
+    @Override
+    public R pageRelationList(ComActNeighborCircleAppDTO neighborCircleAppDTO) {
+        Page userPage = new Page(neighborCircleAppDTO.getPageNum(), neighborCircleAppDTO.getPageSize());
+        IPage<ComActNeighborCircleAppVO> doPager = this.baseMapper.pageRelationList(userPage, neighborCircleAppDTO);
+        if (!doPager.getRecords().isEmpty()) {
+            for (ComActNeighborCircleAppVO circleAppVO : doPager.getRecords()) {
+                if (neighborCircleAppDTO.getUserId() != null) {
+                    // 查询点赞信息
+                    ComActNeighborCircleFabulousDO circleFabulousDO =
+                            comActNeighborCircleFabulousDAO.selectOne(new QueryWrapper<ComActNeighborCircleFabulousDO>()
+                                    .lambda().eq(ComActNeighborCircleFabulousDO::getParentId, circleAppVO.getId())
+                                    .eq(ComActNeighborCircleFabulousDO::getUserId, neighborCircleAppDTO.getUserId())
+                                    .eq(ComActNeighborCircleFabulousDO::getType, ComActNeighborCircleFabulousDO.type.llq)
+                                    .eq(ComActNeighborCircleFabulousDO::getIsEffective,
+                                            ComActNeighborCircleFabulousDO.isEffective.yes));
+                    if (circleFabulousDO != null) {
+                        circleAppVO.setHaveSign(1);
+                    } else {
+                        circleAppVO.setHaveSign(2);
+                    }
+                }
+                if (circleAppVO.getType() != null && circleAppVO.getType().equals(ComActNeighborCircleDO.type.admin)) {
+                    ComActDO actDO = comActDAO.selectById(circleAppVO.getCommunityId());
+                    if (actDO != null) {
+                        circleAppVO.setName(actDO.getName());
+                    }
+                }
+            }
+        }
+        return R.ok(doPager);
     }
 
     /**
@@ -1210,6 +1357,29 @@
         }
     }
 
+    /**
+     * 判断党员的统计是是否已存在
+     * */
+    public Map<String,Integer> memberAlreadyAnalysis(Long memberId,List<PartyMemberAnalysisVO> list){
+        Map<String,Integer> map=new HashMap<>();
+        if (memberId != null && list.size() > 0){
+            for (int i=0;i<list.size();i++) {
+                PartyMemberAnalysisVO vo = list.get(i);
+                if (ObjectUtils.isNotEmpty(vo)){
+                    if (ObjectUtils.isNotEmpty(vo.getMemberId())){
+                        if (memberId.equals(vo.getMemberId())){
+                            map.put("index",i );
+                            map.put("flag",1 );
+                            return map;
+                        }
+                    }
+                }
+            }
+        }
+        map.put("flag",0 );
+        return map;
+    }
+
 
 
 

--
Gitblit v1.7.1