| | |
| | | import com.panzhihua.common.model.vos.LoginUserInfoVO; |
| | | import com.panzhihua.common.model.vos.PageVO; |
| | | import com.panzhihua.common.service.user.UserService; |
| | | import com.panzhihua.common.utlis.SensitiveUtil; |
| | | import com.panzhihua.service_community.entity.ComPbCheckUnit; |
| | | import com.panzhihua.service_community.service.ComActNeighborCircleTopicService; |
| | | import org.apache.commons.lang3.ObjectUtils; |
| | |
| | | import com.panzhihua.service_community.service.ComActNeighborCircleService; |
| | | |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.util.CollectionUtils; |
| | | import org.springframework.web.bind.annotation.RequestParam; |
| | | |
| | | /** |
| | | * @auther lyq |
| | |
| | | circleDetailAppVO.setName(actDO.getName()); |
| | | } |
| | | } |
| | | if(circleDetailAppVO.getOrderType()==2){ |
| | | AdministratorsUserVO user1 = this.baseMapper.selectUserByUserId(circleDetailAppVO.getSolveId()); |
| | | circleDetailAppVO.setSolveName(user1.getName()); |
| | | } |
| | | if(circleDetailAppVO.getOrderType()==1){ |
| | | ComPbCheckUnit comPbCheckUnit=comPbCheckUnitDao.selectById(circleDetailAppVO.getSolveUnitId()); |
| | | if(comPbCheckUnit!=null){ |
| | | circleDetailAppVO.setSolveName(comPbCheckUnit.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()); |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | 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( |
| | |
| | | ComActNeighborCircleCommentDO circleCommentDO = |
| | | comActNeighborCircleCommentDAO.selectById(fabulousAppDTO.getServiceId()); |
| | | if (circleCommentDO != null) { |
| | | |
| | | circleCommentDO.setFabulousNum(circleCommentDO.getFabulousNum() + 1); |
| | | comActNeighborCircleCommentDAO.updateById(circleCommentDO); |
| | | //计算需要增加的热度值 |
| | |
| | | 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.getOrderType()==2){ |
| | | AdministratorsUserVO user1 = this.baseMapper.selectUserByUserId(comActNeighborCircleDO.getSolveId()); |
| | | vo.setSolveName(user1.getName()); |
| | | if(user!=null){ |
| | | vo.setReleaseName(user.getName()); |
| | | vo.setImageUrl(user.getImageUrl()); |
| | | } |
| | | if(comActNeighborCircleDO.getOrderType()==1){ |
| | | ComPbCheckUnit comPbCheckUnit=comPbCheckUnitDao.selectById(comActNeighborCircleDO.getSolveUnitId()); |
| | | if(comPbCheckUnit!=null){ |
| | | vo.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()); |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | @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; |
| | |
| | | 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)){ |
| | |
| | | } |
| | | } |
| | | //获取党员活动统计数据 |
| | | List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo); |
| | | List<PartyMemberAnalysisVO> partyMemberAnalysisVOS1 = comActNeighborCircleDAO.institutionalPartyMemberActAnalysis(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)){ |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | //统计总时长和总次数 |
| | | Integer unitServiceCount=0; |
| | | Integer unitServiceTotalTime=0; |
| | |
| | | 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<>(); |
| | |
| | | return null; |
| | | } |
| | | |
| | | @Override |
| | | public R selectCount(Integer type, String phone,Long communityId) { |
| | | return R.ok(this.baseMapper.selectCount(type,phone,communityId)); |
| | | } |
| | | |
| | | /** |
| | | * 判断活动统计列表中是否已有该单位的数据 |
| | | * */ |