| | |
| | | package com.panzhihua.service_community.service.impl; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | import javax.annotation.Resource; |
| | | |
| | | import com.panzhihua.common.utlis.*; |
| | | import com.panzhihua.service_community.dao.*; |
| | | import com.panzhihua.service_community.entity.SysUser; |
| | | import org.apache.commons.lang3.ObjectUtils; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import cn.hutool.core.collection.CollectionUtil; |
| | | import cn.hutool.core.collection.ListUtil; |
| | | import cn.hutool.core.util.PageUtil; |
| | | import cn.hutool.core.collection.CollUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.panzhihua.common.constants.NeighborCircleConstants; |
| | | import com.panzhihua.common.model.dtos.neighbor.AddComActNeighborCircleAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborAddBrowseAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborCircleAdminDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborCircleAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborCircleDetailAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborCommentAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborCommentReplyAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborFabulousAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborForwardAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ComActNeighborReplyAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.DeleteNeighborCircleAppDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.DetailNeighborAllCommentByAdminDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.DetailNeighborCommentReplyByAdminDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ServiceStaticBackstageDTO; |
| | | import com.panzhihua.common.model.dtos.neighbor.ServiceStaticDTO; |
| | | import com.panzhihua.common.model.dtos.ExcelDO; |
| | | import com.panzhihua.common.model.dtos.PartyExcelDO; |
| | | 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.ActivityAnalysisVO; |
| | | import com.panzhihua.common.model.vos.neighbor.AddNeighborCircleAdminVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ChangeCommentReplyStatusByAdminVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ChangeCommentStatusByAdminVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ComActNeighborCircleAdminVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ComActNeighborCircleAppVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ComActNeighborCircleCommentAppVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ComActNeighborCircleCommentReplyAppVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ComActNeighborCircleDetailAppVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ComActNeighborCommentByAdminVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ComActNeighborCommentReplyAppVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ComActNeighborCommentReplyByAdminVO; |
| | | import com.panzhihua.common.model.vos.neighbor.DetailNeighborCircleAdminVO; |
| | | import com.panzhihua.common.model.vos.neighbor.EditNeighborCircleAdminVO; |
| | | import com.panzhihua.common.model.vos.neighbor.PartyMemberAnalysisVO; |
| | | import com.panzhihua.common.model.vos.neighbor.ServiceStaticsVO; |
| | | import com.panzhihua.common.model.vos.neighbor.UnitActivityAnalysisVO; |
| | | import com.panzhihua.common.model.vos.common.PbCheckUnitStatisticsVo; |
| | | import com.panzhihua.common.model.vos.neighbor.*; |
| | | import com.panzhihua.common.model.vos.user.AdministratorsUserVO; |
| | | 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.model.dos.ComActActivityDO; |
| | | import com.panzhihua.service_community.model.dos.ComActDO; |
| | | import com.panzhihua.service_community.model.dos.ComActNeighborCircleBrowseDO; |
| | | import com.panzhihua.service_community.model.dos.ComActNeighborCircleCommentDO; |
| | | import com.panzhihua.service_community.model.dos.ComActNeighborCircleCommentReplyDO; |
| | | import com.panzhihua.service_community.model.dos.ComActNeighborCircleDO; |
| | | import com.panzhihua.service_community.model.dos.ComActNeighborCircleFabulousDO; |
| | | import com.panzhihua.service_community.model.dos.ComActNeighborCircleTopicDO; |
| | | import com.panzhihua.service_community.model.dos.ComPbMemberDO; |
| | | import com.panzhihua.service_community.entity.NewFightNeedProblemClaim; |
| | | import com.panzhihua.service_community.entity.NewFightNeedProblemInventory; |
| | | 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 cn.hutool.core.collection.ListUtil; |
| | | import cn.hutool.core.util.PageUtil; |
| | | import com.panzhihua.service_community.util.ExcelUtils; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.ObjectUtils; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import javax.annotation.Resource; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.math.BigDecimal; |
| | | import java.text.DecimalFormat; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | |
| | | /** |
| | | * @auther lyq |
| | |
| | | private ComPbCheckUnitDao comPbCheckUnitDao; |
| | | @Resource |
| | | private SysUserDao sysUserDao; |
| | | @Autowired |
| | | private NewFightNeedProblemClaimMapper newFightNeedProblemClaimMapper; |
| | | @Autowired |
| | | private NewFightNeedProblemInventoryMapper newFightNeedProblemInventoryMapper; |
| | | /** |
| | | * 分页查询邻里圈列表 |
| | | * |
| | |
| | | // } |
| | | // } |
| | | // } |
| | | Long communityId = neighborCircleAppDTO.getCommunityId(); |
| | | if(null != communityId){ |
| | | List<Long> communityIds = comActDAO.selectIds(communityId); |
| | | if (CollUtil.isEmpty(communityIds)) { |
| | | communityIds = new ArrayList<>(); |
| | | communityIds.add(communityId); |
| | | } |
| | | neighborCircleAppDTO.setCommunityIds(communityIds); |
| | | } |
| | | Page userPage = new Page(neighborCircleAppDTO.getPageNum(), neighborCircleAppDTO.getPageSize()); |
| | | IPage<ComActNeighborCircleAppVO> doPager = this.baseMapper.pageNeighborByApp(userPage, neighborCircleAppDTO); |
| | | if (!doPager.getRecords().isEmpty()) { |
| | |
| | | if (StringUtils.isNotEmpty(addNeighborCircleAppDTO.getPhone())) { |
| | | neighborCircleDO.setReleasePhone(addNeighborCircleAppDTO.getPhone()); |
| | | } |
| | | |
| | | //判断当前邻里圈是否需要审核 |
| | | if(addNeighborCircleAppDTO.getIsExamine().equals(AddComActNeighborCircleAppDTO.isExamine.no)){ |
| | | //当邻里圈不需要审核才进入自动审核 |
| | |
| | | |
| | | @Override |
| | | public R pageNeighborByAdmin(ComActNeighborCircleAdminDTO neighborCircleAdminDTO) { |
| | | Long communityId = neighborCircleAdminDTO.getCommunityId(); |
| | | if(null != communityId){ |
| | | List<Long> communityIds = comActDAO.selectIds(communityId); |
| | | if (CollUtil.isEmpty(communityIds)) { |
| | | communityIds = new ArrayList<>(); |
| | | communityIds.add(communityId); |
| | | } |
| | | neighborCircleAdminDTO.setCommunityIds(communityIds); |
| | | } |
| | | Page page = new Page(neighborCircleAdminDTO.getPageNum(), neighborCircleAdminDTO.getPageSize()); |
| | | IPage<ComActNeighborCircleAdminVO> doPager = this.baseMapper.pageNeighborByAdmin(page, neighborCircleAdminDTO); |
| | | doPager.getRecords().forEach(data -> { |
| | |
| | | } |
| | | } |
| | | }); |
| | | return R.ok(doPager); |
| | | } |
| | | @Override |
| | | public R pageNeighborByBigScreen(ComActNeighborCircleAdminDTO neighborCircleAdminDTO) { |
| | | Page page = new Page(neighborCircleAdminDTO.getPageNum(), neighborCircleAdminDTO.getPageSize()); |
| | | IPage<ComActNeighborCircleAdminVO> doPager = this.baseMapper.pageNeighborByBigScreen(page, neighborCircleAdminDTO); |
| | | return R.ok(doPager); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | if (comActNeighborCircleCommentDAO.insert(circleCommentDO) > 0) { |
| | | SysUser sysUser=sysUserDao.selectById(neighborCircleDO.getSolveId()); |
| | | 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().substring(0,10)+"..","packageB/pages/partySecond/problemDetails/index?id="+neighborCircleDO.getId()+"&type=888"); |
| | | 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().substring(0,10)+"..","packageB/pages/partySecond/problemDetails/index?id="+neighborCircleDO.getId()+"&type=777"); |
| | | 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(); |
| | |
| | | |
| | | @Override |
| | | public R detailNeighborByAdmin(Long id) { |
| | | ComActNeighborCircleDetailAppVO comActNeighborCircleDO = |
| | | this.baseMapper.neighborDetailByApp(id); |
| | | ComActNeighborCircleDetailAppVO comActNeighborCircleDO = baseMapper.neighborDetailByApp(id); |
| | | if (comActNeighborCircleDO == null) { |
| | | return R.fail("id有误"); |
| | | } |
| | |
| | | if (comActNeighborCircleDO.getTopicId() != null) { |
| | | ComActNeighborCircleTopicDO circleTopicDO = |
| | | comActNeighborCircleTopicMapper.selectById(comActNeighborCircleDO.getTopicId()); |
| | | vo.setTopicName(circleTopicDO.getName()); |
| | | if(circleTopicDO!=null && !StringUtils.isEmpty(circleTopicDO.getName())) |
| | | { |
| | | vo.setTopicName(circleTopicDO.getName()); |
| | | } |
| | | |
| | | } |
| | | return R.ok(vo); |
| | | } |
| | |
| | | public R orderAndSolve(EditNeighborCircleAdminVO editNeighborCircleAdminVO) { |
| | | ComActNeighborCircleDO comActNeighborCircleDO=new ComActNeighborCircleDO(); |
| | | BeanUtils.copyProperties(editNeighborCircleAdminVO,comActNeighborCircleDO); |
| | | if(comActNeighborCircleDO.getSolveStatus()!=null){ |
| | | if(comActNeighborCircleDO.getSolveStatus()!=null && comActNeighborCircleDO.getSolveStatus() == 3){ |
| | | comActNeighborCircleDO.setSolveTime(new Date()); |
| | | } |
| | | if(comActNeighborCircleDO.getOrderStatus()!=null){ |
| | |
| | | } |
| | | int result=this.baseMapper.updateById(comActNeighborCircleDO); |
| | | if(result>0){ |
| | | SysUser sysUser=sysUserDao.selectById(comActNeighborCircleDO.getReleaseId()); |
| | | 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 (comActNeighborCircleDO.getBelongType()==2){ |
| | | WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你反馈的问题已被人认领",comActNeighborCircleDO.getReleaseContent().substring(0,10)+"..","packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=888"); |
| | | 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 (comActNeighborCircleDO.getBelongType()==3){ |
| | | WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你反馈的需求已被人认领",comActNeighborCircleDO.getReleaseContent().substring(0,10)+"..","packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=777"); |
| | | 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()!=null){ |
| | | 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 (comActNeighborCircleDO.getBelongType()==2){ |
| | | WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你反馈的问题已被人处理",comActNeighborCircleDO.getReleaseContent().substring(0,10)+"..","packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=888"); |
| | | 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 (comActNeighborCircleDO.getBelongType()==3){ |
| | | WxUtil.sendLongTimeTemplate(sysUser.getOpenid(),util.getAccessToken(),"你反馈的需求已被人处理",comActNeighborCircleDO.getReleaseContent().substring(0,10)+"..","packageB/pages/partySecond/problemDetails/index?id="+comActNeighborCircleDO.getId()+"&type=777"); |
| | | 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(); |
| | |
| | | @Override |
| | | public R serviceStatic(ServiceStaticDTO serviceStaticDTO) { |
| | | ServiceStaticsVO serviceStaticsVO = new ServiceStaticsVO(); |
| | | if (serviceStaticDTO.getCheckUnitId() != null) { |
| | | if (serviceStaticDTO.getCheckUnitId() != null && serviceStaticDTO.getCheckUnitId()> 0) |
| | | { |
| | | //单位服务统计 |
| | | 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()); |
| | | |
| | | List<ServiceDetailStaticsVO> serviceDetailStaticsVOList=this.baseMapper.selectServiceDetailList(serviceStaticDTO.getCheckUnitId(), |
| | | serviceStaticDTO.getYear(), serviceStaticDTO.getServiceType()); |
| | | |
| | | |
| | | if(serviceStaticDTO.getServiceType()==null || serviceStaticDTO.getServiceType()==1) |
| | | { |
| | | List<NewFightNeedProblemClaim> list=baseMapper.getNewServiceNum("",serviceStaticDTO.getCheckUnitId()+""); |
| | | if(list.size()>0) |
| | | { |
| | | //设置次数 |
| | | int timeNum=serviceStaticsVO.getTimes()+list.size(); |
| | | serviceStaticsVO.setTimes(timeNum); |
| | | //设置服务时间 |
| | | double hours=serviceStaticsVO.getHours(); |
| | | |
| | | for (NewFightNeedProblemClaim item:list) |
| | | { |
| | | ServiceDetailStaticsVO newItem=new ServiceDetailStaticsVO(); |
| | | |
| | | String Ltime=item.getServiceTime(); |
| | | if(!StringUtils.isEmpty(Ltime)) |
| | | { |
| | | double time=(Double.valueOf(Ltime)/3600000); |
| | | DecimalFormat df = new DecimalFormat("#.##"); |
| | | String formattedNumber = df.format(time); |
| | | double result = Double.parseDouble(formattedNumber); |
| | | |
| | | hours=hours+result; |
| | | |
| | | newItem.setServiceTime(result); |
| | | item.setServiceTime(result+""); |
| | | } |
| | | newItem.setIsNew("2"); |
| | | newItem.setServiceId(Long.valueOf(item.getTaskId())); |
| | | newItem.setServiceType(1); |
| | | newItem.setServiceAt(item.getCreationTime()); |
| | | serviceDetailStaticsVOList.add(newItem); |
| | | } |
| | | DecimalFormat df = new DecimalFormat("#.##"); |
| | | String formattedNumber = df.format(hours); |
| | | double result = Double.parseDouble(formattedNumber); |
| | | serviceStaticsVO.setHours(result); |
| | | } |
| | | } |
| | | serviceStaticsVO.setServiceDetailStaticsList(serviceDetailStaticsVOList); |
| | | } |
| | | else |
| | | { |
| | | //个人服务统计 |
| | | |
| | | |
| | | 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())); |
| | | |
| | | serviceStaticsVO = this.baseMapper.selectStatsUser(serviceStaticDTO.getPhone(),checkUnitId+"", serviceStaticDTO.getYear()); |
| | | |
| | | List<ServiceDetailStaticsVO> serviceDetailStaticsVOList=this.baseMapper.selectServiceDetailListForPersonal(checkUnitId, serviceStaticDTO.getPhone(), |
| | | serviceStaticDTO.getYear(), serviceStaticDTO.getServiceType()); |
| | | |
| | | if(serviceStaticDTO.getServiceType()==null || serviceStaticDTO.getServiceType()==1) |
| | | { |
| | | //获取新需求服务列表 |
| | | List<NewFightNeedProblemClaim> list=baseMapper.getNewServiceNum(serviceStaticDTO.getPhone(),""); |
| | | |
| | | if(list.size()>0) |
| | | { |
| | | //设置次数 |
| | | int timeNum=serviceStaticsVO.getTimes()+list.size(); |
| | | //设置服务时间 |
| | | double hours=serviceStaticsVO.getHours(); |
| | | serviceStaticsVO.setTimes(timeNum); |
| | | for (NewFightNeedProblemClaim item:list) |
| | | { |
| | | ServiceDetailStaticsVO newItem=new ServiceDetailStaticsVO(); |
| | | |
| | | String Ltime=item.getServiceTime(); |
| | | if(!StringUtils.isEmpty(Ltime)) |
| | | { |
| | | double time=(Double.valueOf(Ltime)/3600000); |
| | | DecimalFormat df = new DecimalFormat("#.##"); |
| | | String formattedNumber = df.format(time); |
| | | double result = Double.parseDouble(formattedNumber); |
| | | |
| | | hours=hours+result; |
| | | |
| | | newItem.setServiceTime(result); |
| | | item.setServiceTime(result+""); |
| | | } |
| | | newItem.setIsNew("2"); |
| | | newItem.setServiceId(Long.valueOf(item.getTaskId())); |
| | | newItem.setServiceType(1); |
| | | newItem.setServiceAt(item.getCreationTime()); |
| | | serviceDetailStaticsVOList.add(newItem); |
| | | } |
| | | |
| | | DecimalFormat df = new DecimalFormat("#.##"); |
| | | String formattedNumber = df.format(hours); |
| | | double result = Double.parseDouble(formattedNumber); |
| | | serviceStaticsVO.setHours(result); |
| | | } |
| | | } |
| | | |
| | | serviceStaticsVO.setServiceDetailStaticsList(serviceDetailStaticsVOList); |
| | | } |
| | | return R.ok(serviceStaticsVO); |
| | | } |
| | | |
| | | @Override |
| | | public R institutionalUnitServiceAnalysis(Integer year, Integer type, Integer range, Long communityId,Integer page,Integer size,String belongTo,Long unitId) { |
| | | public R institutionalUnitServiceAnalysis(Integer year, Integer type, Integer range, Long communityId, |
| | | Integer page,Integer size,String belongTo,Long unitId,String searchContent) { |
| | | 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,communityId); |
| | | List<UnitActivityAnalysisVO> unitActivityAnalysisVOS = comActNeighborCircleDAO.institutionalUnitServiceAnalysis(beginTime, endTime, belongTo,communityId,unitId); |
| | | //获取单位活动统计数据(活动) |
| | | List<UnitActivityAnalysisVO> unitActivityAnalysisVOS1 = comActNeighborCircleDAO.institutionalUnitActivityAnalysis(beginTime, endTime, belongTo,communityId); |
| | | List<UnitActivityAnalysisVO> unitActivityAnalysisVOS1 = comActNeighborCircleDAO.institutionalUnitActivityAnalysis(beginTime, endTime, belongTo,communityId,unitId); |
| | | //获取新双挣双评清单任务 |
| | | List<UnitActivityAnalysisVO> newTaskList=comActNeighborCircleDAO.getNewTaskList(beginTime, endTime, belongTo,communityId); |
| | | |
| | | if (unitActivityAnalysisVOS.size()>0){ |
| | | for (UnitActivityAnalysisVO unitActivityAnalysisVO : unitActivityAnalysisVOS){ |
| | | if (ObjectUtils.isNotEmpty(unitActivityAnalysisVO)){ |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | if (newTaskList.size()>0){ |
| | | for (UnitActivityAnalysisVO item : newTaskList){ |
| | | if (ObjectUtils.isNotEmpty(item)){ |
| | | if (ObjectUtils.isNotEmpty(item.getUnitId())){ |
| | | //设置单位名称 |
| | | item.setUnitName(comActDAO.selectUnitName(item.getUnitId())); |
| | | //统计活动表中的活动信息 |
| | | } |
| | | if (ObjectUtils.isNotEmpty(item.getCommunityId())){ |
| | | item.setCommunityName(comActDAO.selectById(item.getCommunityId()).getName()); |
| | | } |
| | | |
| | | Double time=(item.getServiceTime()/3600000); |
| | | DecimalFormat df = new DecimalFormat("#.##"); |
| | | String formattedNumber = df.format(time); |
| | | Double result = Double.parseDouble(formattedNumber); |
| | | item.setServiceTime(result); |
| | | } |
| | | } |
| | | } |
| | | |
| | | //活动表数据处理 |
| | | if (unitActivityAnalysisVOS1.size()>0){ |
| | | for (UnitActivityAnalysisVO vo : unitActivityAnalysisVOS1) { |
| | |
| | | Map<String, Integer> param = alreadyAnalysis(vo.getUnitId(), unitActivityAnalysisVOS); |
| | | if (param.get("flag")==1){ |
| | | //已有数据,将时长,次数相加 |
| | | Integer serviceTime = vo.getServiceTime(); |
| | | Double serviceTime = vo.getServiceTime(); |
| | | Integer serviceTimes = vo.getServiceTimes(); |
| | | unitActivityAnalysisVOS.get(param.get("index")).setServiceTime(unitActivityAnalysisVOS.get(param.get("index")).getServiceTime()+serviceTime); |
| | | unitActivityAnalysisVOS.get(param.get("index")).setServiceTimes(unitActivityAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes); |
| | | }else { |
| | | //新数据,获取单位,社区名 |
| | | vo.setUnitName(comActDAO.selectUnitName(vo.getUnitId())); |
| | | if (ObjectUtils.isNotEmpty(vo.getCommunityId())) { |
| | | vo.setCommunityName(comActDAO.selectById(vo.getCommunityId()).getName()); |
| | | if (ObjectUtils.isNotEmpty(vo.getCommunityId())) |
| | | { |
| | | ComActDO actDO=comActDAO.selectById(vo.getCommunityId()); |
| | | if(actDO!=null && !StringUtils.isEmpty(actDO.getName())) |
| | | { |
| | | vo.setCommunityName(actDO.getName()); |
| | | } |
| | | } |
| | | unitActivityAnalysisVOS.add(vo); |
| | | } |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | if (newTaskList.size()>0){ |
| | | for (UnitActivityAnalysisVO item : newTaskList){ |
| | | if (ObjectUtils.isNotEmpty(item)){ |
| | | |
| | | if (ObjectUtils.isNotEmpty(item.getUnitId())){ |
| | | //判断邻里圈统计中是否已有该单位数据 |
| | | Map<String, Integer> param = alreadyAnalysis(item.getUnitId(), unitActivityAnalysisVOS); |
| | | if (param.get("flag")==1){ |
| | | //已有数据,将时长,次数相加 |
| | | Double serviceTime = unitActivityAnalysisVOS.get(param.get("index")).getServiceTime()+item.getServiceTime(); |
| | | Integer serviceTimes = item.getServiceTimes(); |
| | | |
| | | DecimalFormat df2 = new DecimalFormat("#.##"); |
| | | String formattedNumber2 = df2.format(serviceTime); |
| | | Double result2 = Double.parseDouble(formattedNumber2); |
| | | |
| | | unitActivityAnalysisVOS.get(param.get("index")).setServiceTime(result2); |
| | | unitActivityAnalysisVOS.get(param.get("index")).setServiceTimes(unitActivityAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes); |
| | | }else { |
| | | //新数据,获取单位,社区名 |
| | | item.setUnitName(comActDAO.selectUnitName(item.getUnitId())); |
| | | if (ObjectUtils.isNotEmpty(item.getCommunityId())) |
| | | { |
| | | ComActDO actDO=comActDAO.selectById(item.getCommunityId()); |
| | | if(actDO!=null && !StringUtils.isEmpty(actDO.getName())) |
| | | { |
| | | item.setCommunityName(actDO.getName()); |
| | | } |
| | | } |
| | | |
| | | unitActivityAnalysisVOS.add(item); |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | //获取党员活动统计数据 |
| | | List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo,communityId,unitId); |
| | | List<PartyMemberAnalysisVO> partyMemberAnalysisVOS1 = comActNeighborCircleDAO.institutionalPartyMemberActAnalysis(beginTime, endTime, belongTo,communityId,unitId); |
| | | List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo,communityId,unitId,searchContent); |
| | | List<PartyMemberAnalysisVO> partyMemberAnalysisVOS1 = comActNeighborCircleDAO.institutionalPartyMemberActAnalysis(beginTime, endTime, belongTo,communityId,unitId,searchContent); |
| | | //获取新双挣双评清单任务 |
| | | List<PartyMemberAnalysisVO> newPartyMemberList = comActNeighborCircleDAO.getNewPartyMemberTaskList(beginTime, endTime, belongTo,communityId,unitId,searchContent); |
| | | 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(); |
| | | Double 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); |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | if (newPartyMemberList.size()>0){ |
| | | for (PartyMemberAnalysisVO item : newPartyMemberList) |
| | | { |
| | | Double time=(item.getServiceTime()/3600000); |
| | | DecimalFormat df = new DecimalFormat("#.##"); |
| | | String formattedNumber = df.format(time); |
| | | Double result = Double.parseDouble(formattedNumber); |
| | | item.setServiceTime(result); |
| | | if (ObjectUtils.isNotEmpty(item)){ |
| | | if (ObjectUtils.isNotEmpty(item.getMemberId())){ |
| | | Map<String, Integer> param = memberAlreadyAnalysis(item.getMemberId(), partyMemberAnalysisVOS); |
| | | if (param.get("flag")==1){ |
| | | Double serviceTime = partyMemberAnalysisVOS.get(param.get("index")).getServiceTime()+item.getServiceTime(); |
| | | Integer serviceTimes = item.getServiceTimes(); |
| | | |
| | | DecimalFormat df1 = new DecimalFormat("#.##"); |
| | | String formattedNumber1 = df1.format(serviceTime); |
| | | Double result1 = Double.parseDouble(formattedNumber1); |
| | | |
| | | partyMemberAnalysisVOS.get(param.get("index")).setServiceTime(result1); |
| | | partyMemberAnalysisVOS.get(param.get("index")).setServiceTimes(partyMemberAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes); |
| | | }else{ |
| | | |
| | | |
| | | partyMemberAnalysisVOS.add(item); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | //报道单位统计积分 |
| | | List<NewFightNeedProblemInventory> allList = newFightNeedProblemInventoryMapper.selectAll(); |
| | | Map<Long, String> awardMap = allList.stream().filter(Objects::nonNull).collect(Collectors.toMap(NewFightNeedProblemInventory::getId, NewFightNeedProblemInventory::getAward)); |
| | | for (UnitActivityAnalysisVO unitVO : unitActivityAnalysisVOS) { |
| | | |
| | | Long unitId1 = unitVO.getUnitId(); |
| | | LambdaQueryWrapper<NewFightNeedProblemClaim> wrapper = new LambdaQueryWrapper<>(); |
| | | wrapper.eq(NewFightNeedProblemClaim::getUnitId,String.valueOf(unitId1)); |
| | | List<NewFightNeedProblemClaim> inventories = newFightNeedProblemClaimMapper.selectList(wrapper); |
| | | Map<String, Long> collectMap = inventories.stream() |
| | | .collect(Collectors.groupingBy(NewFightNeedProblemClaim::getTaskId, Collectors.counting())); |
| | | long sum = 0l; |
| | | if(unitVO.getAwardSum()!=null) |
| | | { |
| | | sum=unitVO.getAwardSum(); |
| | | } |
| | | //任务id集合 |
| | | List<String> taskIds = inventories.stream().map(NewFightNeedProblemClaim::getTaskId).distinct().collect(Collectors.toList()); |
| | | for (String taskId : taskIds) { |
| | | // NewFightNeedProblemInventory newFightNeedProblemInventory = newFightNeedProblemInventoryMapper.selectById(taskId); |
| | | // String award = newFightNeedProblemInventory.getAward(); |
| | | String award = awardMap.get(Long.parseLong(taskId)); |
| | | Long count = collectMap.get(taskId); |
| | | if(!StringUtils.isEmpty(award) ) |
| | | { |
| | | long i = Long.parseLong(award) * count; |
| | | sum = sum + i; |
| | | } |
| | | } |
| | | unitVO.setAwardSum(sum); |
| | | } |
| | | |
| | | //报道党员统计积分 |
| | | for (PartyMemberAnalysisVO memberAnalysisVO : partyMemberAnalysisVOS) |
| | | { |
| | | if(memberAnalysisVO!=null) |
| | | { |
| | | Long userId = memberAnalysisVO.getMemberId(); |
| | | LambdaQueryWrapper<NewFightNeedProblemClaim> wrapper = new LambdaQueryWrapper<>(); |
| | | wrapper.eq(NewFightNeedProblemClaim::getUserId,userId); |
| | | List<NewFightNeedProblemClaim> newFightNeedProblemInventories = newFightNeedProblemClaimMapper.selectList(wrapper); |
| | | long sumAward = 0l; |
| | | |
| | | if(memberAnalysisVO.getPartyCount()!=null) |
| | | { |
| | | sumAward=memberAnalysisVO.getPartyCount(); |
| | | } |
| | | |
| | | for (NewFightNeedProblemClaim inventory : newFightNeedProblemInventories) { |
| | | String taskId = inventory.getTaskId(); |
| | | NewFightNeedProblemInventory newFightNeedProblemInventory = newFightNeedProblemInventoryMapper.selectById(taskId); |
| | | |
| | | if(newFightNeedProblemInventory!=null && !StringUtils.isEmpty(newFightNeedProblemInventory.getAward())) |
| | | { |
| | | String award = newFightNeedProblemInventory.getAward(); |
| | | |
| | | if(!StringUtils.isEmpty(award) ) |
| | | { |
| | | sumAward = Long.parseLong(award) + sumAward; |
| | | } |
| | | } |
| | | |
| | | } |
| | | memberAnalysisVO.setPartyCount(sumAward); |
| | | } |
| | | } |
| | | |
| | | //统计总时长和总次数 |
| | | Integer unitServiceCount=0; |
| | | Integer unitServiceTotalTime=0; |
| | | Double unitServiceTotalTime=0.0; |
| | | Integer memberServiceCount=0; |
| | | Integer memberServiceTotalTome=0; |
| | | Double memberServiceTotalTome=0.0; |
| | | long awardSumCount=0L; |
| | | long partySumCount=0L; |
| | | for (UnitActivityAnalysisVO vo : unitActivityAnalysisVOS) { |
| | | //避免空指针 |
| | | if (ObjectUtils.isNotEmpty(vo)){ |
| | | if (ObjectUtils.isNotEmpty(vo.getServiceTime())){ |
| | | unitServiceCount+=vo.getServiceTime(); |
| | | unitServiceTotalTime+=vo.getServiceTime(); |
| | | } |
| | | if (ObjectUtils.isNotEmpty(vo.getServiceTimes())){ |
| | | unitServiceTotalTime+=vo.getServiceTimes(); |
| | | unitServiceCount+=vo.getServiceTimes(); |
| | | } |
| | | } |
| | | } |
| | |
| | | //避免空指针 |
| | | if (ObjectUtils.isNotEmpty(vo)){ |
| | | if (ObjectUtils.isNotEmpty(vo.getServiceTime())){ |
| | | memberServiceCount+=vo.getServiceTime(); |
| | | memberServiceTotalTome+=vo.getServiceTime(); |
| | | } |
| | | if (ObjectUtils.isNotEmpty(vo.getServiceTimes())){ |
| | | memberServiceTotalTome+=vo.getServiceTimes(); |
| | | memberServiceCount+=vo.getServiceTimes(); |
| | | } |
| | | } |
| | | } |
| | | for (UnitActivityAnalysisVO vo : unitActivityAnalysisVOS) { |
| | | if(ObjectUtils.isNotEmpty(vo)){ |
| | | if(ObjectUtils.isNotEmpty(vo.getAwardSum())){ |
| | | awardSumCount += vo.getAwardSum(); |
| | | } |
| | | } |
| | | } |
| | | for (PartyMemberAnalysisVO memberAnalysisVO : partyMemberAnalysisVOS) { |
| | | if(ObjectUtils.isNotEmpty(memberAnalysisVO)){ |
| | | if(ObjectUtils.isNotEmpty(memberAnalysisVO.getPartyCount())){ |
| | | partySumCount += memberAnalysisVO.getPartyCount(); |
| | | } |
| | | } |
| | | } |
| | | activityVO.setAwardSumCount(awardSumCount); |
| | | activityVO.setPartySumCount(partySumCount); |
| | | activityVO.setUnitServiceTotalCount(unitServiceCount); |
| | | activityVO.setUnitServiceTotalTime(unitServiceTotalTime); |
| | | 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"); |
| | | |
| | | ListUtil.reverse(unitActivityAnalysisVOS); |
| | | ListUtil.reverse(partyMemberAnalysisVOS); |
| | | |
| | | }else if (type.equals(2)){ |
| | | //按次数排序 |
| | | ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTimes"); |
| | | ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTimes"); |
| | | |
| | | ListUtil.reverse(unitActivityAnalysisVOS); |
| | | ListUtil.reverse(partyMemberAnalysisVOS); |
| | | }else if(type.equals(3)){ |
| | | //按积分排序 |
| | | ListUtil.sortByProperty(unitActivityAnalysisVOS,"awardSum"); |
| | | ListUtil.reverse(unitActivityAnalysisVOS); |
| | | // ListUtil.sortByProperty(unitActivityAnalysisVOS,""); |
| | | } |
| | | } |
| | | else |
| | | { |
| | | //按时长排序 |
| | | ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTime"); |
| | | ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTime"); |
| | | |
| | | ListUtil.reverse(unitActivityAnalysisVOS); |
| | | ListUtil.reverse(partyMemberAnalysisVOS); |
| | | } |
| | | //处理分页 |
| | | PageVO<List<UnitActivityAnalysisVO>> unitPage=new PageVO<>(); |
| | | PageVO<List<PartyMemberAnalysisVO>> memberPage=new PageVO<>(); |
| | |
| | | } |
| | | activityVO.setUnitList(unitPage); |
| | | activityVO.setPartyMemberList(memberPage); |
| | | |
| | | //党员数据 聚合 |
| | | Map<String, Double> map = new HashMap<>(); |
| | | partyMemberAnalysisVOS.forEach(vo->{ |
| | | String name = vo.getBelongTo(); |
| | | Double time = vo.getServiceTime(); |
| | | if (map.containsKey(name)) { |
| | | time += map.get(name); |
| | | } |
| | | map.put(name, time); |
| | | }); |
| | | if(CollectionUtil.isNotEmpty(map)){ |
| | | List<PbCheckUnitStatisticsVo> list = new ArrayList<>(); |
| | | map.keySet().forEach(vo->{ |
| | | PbCheckUnitStatisticsVo dto = new PbCheckUnitStatisticsVo(); |
| | | dto.setBelongTo(vo); |
| | | dto.setServiceTime(map.get(vo)); |
| | | list.add(dto); |
| | | }); |
| | | activityVO.setGroupPartyCount(list); |
| | | } |
| | | return R.ok(activityVO); |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public List<ExcelDO> export(Integer year, String belongTo, Long communityId) throws Exception { |
| | | List<ExcelDO> excelDOList = new ArrayList<>(); |
| | | String beginTime=null; |
| | | String endTime=null; |
| | | if (null != year){ |
| | | //设置开始,截止时间 |
| | | beginTime=year.toString().concat("-01-01"); |
| | | endTime=year.toString().concat("-12-31"); |
| | | } |
| | | //获取单位活动统计数据(邻里圈) |
| | | List<UnitActivityAnalysisVO> unitActivityAnalysisVOS = comActNeighborCircleDAO.institutionalUnitServiceAnalysis(beginTime, endTime, belongTo,communityId,null); |
| | | //获取单位活动统计数据(活动) |
| | | List<UnitActivityAnalysisVO> unitActivityAnalysisVOS1 = comActNeighborCircleDAO.institutionalUnitActivityAnalysis(beginTime, endTime, belongTo,communityId,null); |
| | | if (!unitActivityAnalysisVOS.isEmpty()){ |
| | | for (UnitActivityAnalysisVO unitActivityAnalysisVO : unitActivityAnalysisVOS){ |
| | | if (ObjectUtils.isNotEmpty(unitActivityAnalysisVO)){ |
| | | if (ObjectUtils.isNotEmpty(unitActivityAnalysisVO.getUnitId())){ |
| | | //设置单位名称 |
| | | unitActivityAnalysisVO.setUnitName(comActDAO.selectUnitName(unitActivityAnalysisVO.getUnitId())); |
| | | //统计活动表中的活动信息 |
| | | } |
| | | if (ObjectUtils.isNotEmpty(unitActivityAnalysisVO.getCommunityId())){ |
| | | unitActivityAnalysisVO.setCommunityName(comActDAO.selectById(unitActivityAnalysisVO.getCommunityId()).getName()); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | //活动表数据处理 |
| | | if (!unitActivityAnalysisVOS1.isEmpty()){ |
| | | for (UnitActivityAnalysisVO vo : unitActivityAnalysisVOS1) { |
| | | if(ObjectUtils.isNotEmpty(vo)){ |
| | | if (ObjectUtils.isNotEmpty(vo.getUnitId())){ |
| | | //判断邻里圈统计中是否已有该单位数据 |
| | | Map<String, Integer> param = alreadyAnalysis(vo.getUnitId(), unitActivityAnalysisVOS); |
| | | if (param.get("flag")==1){ |
| | | //已有数据,将时长,次数相加 |
| | | Double serviceTime = vo.getServiceTime(); |
| | | Integer serviceTimes = vo.getServiceTimes(); |
| | | unitActivityAnalysisVOS.get(param.get("index")).setServiceTime(unitActivityAnalysisVOS.get(param.get("index")).getServiceTime()+serviceTime); |
| | | unitActivityAnalysisVOS.get(param.get("index")).setServiceTimes(unitActivityAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes); |
| | | }else { |
| | | //新数据,获取单位,社区名 |
| | | vo.setUnitName(comActDAO.selectUnitName(vo.getUnitId())); |
| | | if (ObjectUtils.isNotEmpty(vo.getCommunityId())) |
| | | { |
| | | ComActDO actDO=comActDAO.selectById(vo.getCommunityId()); |
| | | if(actDO!=null && !StringUtils.isEmpty(actDO.getName())) |
| | | { |
| | | vo.setCommunityName(actDO.getName()); |
| | | } |
| | | } |
| | | unitActivityAnalysisVOS.add(vo); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | List<NewFightNeedProblemInventory> allList = newFightNeedProblemInventoryMapper.selectAll(); |
| | | Map<Long, String> awardMap = allList.stream().filter(Objects::nonNull).collect(Collectors.toMap(NewFightNeedProblemInventory::getId, NewFightNeedProblemInventory::getAward)); |
| | | for (UnitActivityAnalysisVO unitVO : unitActivityAnalysisVOS) { |
| | | |
| | | Long unitId1 = unitVO.getUnitId(); |
| | | LambdaQueryWrapper<NewFightNeedProblemClaim> wrapper = new LambdaQueryWrapper<>(); |
| | | wrapper.eq(NewFightNeedProblemClaim::getUnitId,String.valueOf(unitId1)); |
| | | List<NewFightNeedProblemClaim> inventories = newFightNeedProblemClaimMapper.selectList(wrapper); |
| | | Map<String, Long> collectMap = inventories.stream() |
| | | .collect(Collectors.groupingBy(NewFightNeedProblemClaim::getTaskId, Collectors.counting())); |
| | | long sum = 0L; |
| | | //任务id集合 |
| | | List<String> taskIds = inventories.stream().map(NewFightNeedProblemClaim::getTaskId).distinct().collect(Collectors.toList()); |
| | | for (String taskId : taskIds) { |
| | | // NewFightNeedProblemInventory newFightNeedProblemInventory = newFightNeedProblemInventoryMapper.selectById(taskId); |
| | | // String award = newFightNeedProblemInventory.getAward(); |
| | | String award = awardMap.get(Long.parseLong(taskId)); |
| | | Long count = collectMap.get(taskId); |
| | | long i = Long.parseLong(award) * count; |
| | | sum = sum + i; |
| | | } |
| | | unitVO.setAwardSum(sum); |
| | | } |
| | | for (UnitActivityAnalysisVO vo : unitActivityAnalysisVOS) { |
| | | ExcelDO excelDO = new ExcelDO(); |
| | | excelDO.setBelongTo(vo.getBelongTo()); |
| | | excelDO.setOrgName(vo.getOrgName()); |
| | | excelDO.setUnitName(vo.getUnitName()); |
| | | excelDO.setCommunityName(vo.getCommunityName()); |
| | | excelDO.setServiceTime(vo.getServiceTime()); |
| | | excelDO.setAwardSum(vo.getAwardSum()); |
| | | excelDOList.add(excelDO); |
| | | } |
| | | return excelDOList; |
| | | } |
| | | |
| | | @Override |
| | | public List<PartyExcelDO> partyExcel(Integer year, String belongTo, Long communityId,Long unitId) { |
| | | String beginTime=null; |
| | | String endTime=null; |
| | | if (null != year){ |
| | | //设置开始,截止时间 |
| | | beginTime=year.toString().concat("-01-01"); |
| | | endTime=year.toString().concat("-12-31"); |
| | | } |
| | | //获取党员活动统计数据 |
| | | List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo,communityId,unitId,null); |
| | | List<PartyMemberAnalysisVO> partyMemberAnalysisVOS1 = comActNeighborCircleDAO.institutionalPartyMemberActAnalysis(beginTime, endTime, belongTo,communityId,unitId,null); |
| | | 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){ |
| | | Double 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); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | //报道党员统计积分 |
| | | for (PartyMemberAnalysisVO memberAnalysisVO : partyMemberAnalysisVOS) { |
| | | Long userId = memberAnalysisVO.getMemberId(); |
| | | LambdaQueryWrapper<NewFightNeedProblemClaim> wrapper = new LambdaQueryWrapper<>(); |
| | | wrapper.eq(NewFightNeedProblemClaim::getUserId,userId); |
| | | List<NewFightNeedProblemClaim> newFightNeedProblemInventories = newFightNeedProblemClaimMapper.selectList(wrapper); |
| | | long sumAward = 0L; |
| | | for (NewFightNeedProblemClaim inventory : newFightNeedProblemInventories) { |
| | | String taskId = inventory.getTaskId(); |
| | | NewFightNeedProblemInventory newFightNeedProblemInventory = newFightNeedProblemInventoryMapper.selectById(taskId); |
| | | String award = newFightNeedProblemInventory.getAward(); |
| | | sumAward = Long.parseLong(award) + sumAward; |
| | | } |
| | | memberAnalysisVO.setPartyCount(sumAward); |
| | | } |
| | | List<PartyExcelDO> list = new ArrayList<>(); |
| | | for (PartyMemberAnalysisVO memberAnalysisVO : partyMemberAnalysisVOS) { |
| | | PartyExcelDO partyExcelDO = new PartyExcelDO(); |
| | | partyExcelDO.setBelongTo(memberAnalysisVO.getBelongTo()); |
| | | partyExcelDO.setOrgName(memberAnalysisVO.getOrgName()); |
| | | partyExcelDO.setUnitName(memberAnalysisVO.getUnitName()); |
| | | partyExcelDO.setMemberName(memberAnalysisVO.getMemberName()); |
| | | partyExcelDO.setBelongCommunity(memberAnalysisVO.getBelongCommunity()); |
| | | partyExcelDO.setServiceTimes(memberAnalysisVO.getServiceTimes()); |
| | | partyExcelDO.setServiceTime(memberAnalysisVO.getServiceTime()); |
| | | partyExcelDO.setPartyCount(memberAnalysisVO.getPartyCount()); |
| | | list.add(partyExcelDO); |
| | | } |
| | | return list; |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public R serviceStaticBackstage(ServiceStaticBackstageDTO serviceStaticDTO) { |