短信指定楼栋发送

linwe

2024-08-09 8b7258c9427882bb1798f1502eaa35184c6e374e

 src/main/java/org/springblade/modules/discuss/service/impl/PublicDiscussServiceImpl.java

@@ -17,12 +17,41 @@
package org.springblade.modules.discuss.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xxl.job.core.util.DateUtil;
import org.springblade.common.constant.CommonConstant;
import org.springblade.common.utils.SpringUtils;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.utils.Func;
import org.springblade.modules.article.entity.Article;
import org.springblade.modules.article.service.ArticleService;
import org.springblade.modules.discuss.dto.TopicsDTO;
import org.springblade.modules.discuss.entity.PublicDiscussEntity;
import org.springblade.modules.discuss.entity.UserTopicsEntity;
import org.springblade.modules.discuss.mapper.PublicDiscussMapper;
import org.springblade.modules.discuss.service.IPublicDiscussService;
import org.springblade.modules.discuss.service.ITopicsService;
import org.springblade.modules.discuss.service.IUserPublicEnrollService;
import org.springblade.modules.discuss.service.IUserTopicsService;
import org.springblade.modules.discuss.vo.PublicDiscussVO;
import org.springblade.modules.discuss.vo.UserTopicsVO;
import org.springblade.modules.district.entity.DistrictEntity;
import org.springblade.modules.district.service.IDistrictService;
import org.springblade.modules.house.entity.HouseholdEntity;
import org.springblade.modules.house.service.IHouseService;
import org.springblade.modules.house.service.IHouseholdService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 公益报名与议事 服务实现类
@@ -33,10 +62,185 @@
@Service
public class PublicDiscussServiceImpl extends ServiceImpl<PublicDiscussMapper, PublicDiscussEntity> implements IPublicDiscussService {

   @Resource
   private IUserPublicEnrollService iUserPublicEnrollService;

   @Resource
   private IUserTopicsService iUserTopicsService;

   @Override
   public IPage<PublicDiscussVO> selectPublicDiscussPage(IPage<PublicDiscussVO> page, PublicDiscussVO publicDiscuss) {
      return page.setRecords(baseMapper.selectPublicDiscussPage(page, publicDiscuss));
      List<PublicDiscussVO> publicDiscussVOS = baseMapper.selectPublicDiscussPage(page, publicDiscuss);
      for (PublicDiscussVO publicDiscussVO : publicDiscussVOS) {
         Long result = iUserPublicEnrollService.getCount(publicDiscussVO.getId());
         if (result != null) {
            publicDiscussVO.setEnrollCount(result.intValue());
         }
         UserTopicsVO userTopicsVo = new UserTopicsVO();
         userTopicsVo.setPublicDiscussId(publicDiscussVO.getId());
         Query query = new Query();
         query.setCurrent(1);
         query.setSize(10);
         IPage<UserTopicsVO> userTopicsVOIPage = iUserTopicsService.selectUserTopicsPage(Condition.getPage(query), userTopicsVo);
         if (userTopicsVOIPage != null) {
            Long total = userTopicsVOIPage.getTotal();
            publicDiscussVO.setTopsCount(total.intValue());
         }
      }
      return page.setRecords(publicDiscussVOS);
   }


   @Override
   public PublicDiscussVO getDetail(PublicDiscussVO publicDiscuss) {
      IHouseholdService householdService = SpringUtils.getBean(IHouseholdService.class);
      HouseholdEntity householdEntity = householdService.getOne(Wrappers.<HouseholdEntity>lambdaQuery()
         .eq(HouseholdEntity::getHouseCode, publicDiscuss.getHouseCode())
         .eq(HouseholdEntity::getAssociatedUserId, AuthUtil.getUserId())
         .eq(HouseholdEntity::getIsDeleted, 0)
         .last("limit 1"));
      if (householdEntity != null) {
         publicDiscuss.setHouseholdId(householdEntity.getId());
      }
      PublicDiscussVO publicDiscussVO = baseMapper.selectPublicDiscuss(publicDiscuss);
      publicDiscussVO.setDisabled(false);
      if (householdEntity != null) {
         // 一户一票
         IUserTopicsService bean = SpringUtils.getBean(IUserTopicsService.class);
         if (publicDiscussVO.getVoteRestrictions().equals(CommonConstant.NUMBER_ONE)) {
            long count = bean.count(Wrappers.<UserTopicsEntity>lambdaQuery()
               .eq(UserTopicsEntity::getHouseCode, publicDiscuss.getHouseCode())
               .eq(UserTopicsEntity::getArticleId, publicDiscussVO.getArticleId()));
            if (count > 0) {
               publicDiscussVO.setDisabled(true);
            }
         } else {
            // 一个一票
            long count = bean.count(Wrappers.<UserTopicsEntity>lambdaQuery()
               .eq(UserTopicsEntity::getHouseholdId, householdEntity.getId())
               .eq(UserTopicsEntity::getArticleId, publicDiscussVO.getArticleId()));
            if (count > 0) {
               publicDiscussVO.setDisabled(true);
            }
         }
         // 判断是否业主，只有业主可以投票
      }
      return publicDiscussVO;
   }

   @Override
   public Map<String, Object> GetPublicDiscussTotal(PublicDiscussVO publicDiscuss) {
      // 参与房屋投票的总数
      IDistrictService districtService = SpringUtils.getBean(IDistrictService.class);
      // 获取文章信息
      PublicDiscussEntity discussEntity = getOne(Wrappers.<PublicDiscussEntity>lambdaQuery().eq(PublicDiscussEntity::getArticleId, publicDiscuss.getArticleId()));
      ArticleService articleService = SpringUtils.getBean(ArticleService.class);
      Article serviceOne = articleService.getOne(Wrappers.<Article>lambdaQuery().eq(Article::getId, publicDiscuss.getArticleId()));
      String articleRange = serviceOne.getArticleRange();
      List<String> strings = Func.toStrList(articleRange);
      // 获取小区信息
      List<DistrictEntity> list = districtService.list(Wrappers.<DistrictEntity>lambdaQuery()
         .in(DistrictEntity::getId, strings));
      List<String> aoiCodeList = list.stream().map(districtEntity -> districtEntity.getAoiCode()).collect(Collectors.toList());

      IHouseService iHouseService = SpringUtils.getBean(IHouseService.class);
      // 获取小区房屋总数和面积
      Map<String, Object> buildingAreaStatistics = iHouseService.getHoseTotalAndAreaTotalByDistrictCode(aoiCodeList);
      // 获取投票数量和面积
      IUserTopicsService userTopicsService = SpringUtils.getBean(IUserTopicsService.class);
      Map<String, Object> userTopicsTotal = userTopicsService.getUserTopicsTotal(discussEntity.getArticleId());
      // 投票详情统计
      ITopicsService iTopicsService = SpringUtils.getBean(ITopicsService.class);
      List<TopicsDTO> userTopicsTotalByArticleId = iTopicsService.getTopicsTotalByArticleId(discussEntity.getArticleId());
      // 已投票房屋面积
      BigDecimal areaCount = (BigDecimal) userTopicsTotal.get("area");
      // 已投票房屋数量
      BigDecimal numberCount = BigDecimal.valueOf((Long) userTopicsTotal.get("number"));
      // 总房屋数量
      BigDecimal houseCount = BigDecimal.valueOf((Long) buildingAreaStatistics.get("houseCount"));
      // 总房屋面积
      BigDecimal houseAreaCount = (BigDecimal) buildingAreaStatistics.get("houseArea");

      // 已完成房屋投票数量占比
      if (houseCount.compareTo(BigDecimal.ZERO) > 0) {
         BigDecimal divide = numberCount.divide(houseCount, 4, BigDecimal.ROUND_HALF_UP);
         // 将结果乘以100得到百分比形式，然后设置为2位小数
         // 这里保持了原有的功能和精度要求
         userTopicsTotal.put("houseProportion", divide.multiply(BigDecimal.valueOf(100)).setScale(2));
      }
      if (houseAreaCount.compareTo(BigDecimal.ZERO) > 0) {
         // 已完成房屋投票面积占比
         BigDecimal divide1 = areaCount.divide(houseAreaCount, 4, BigDecimal.ROUND_HALF_UP);
         // 将结果乘以100得到百分比形式，然后设置为2位小数
         // 这里保持了原有的功能和精度要求
         userTopicsTotal.put("areaProportion", divide1.multiply(BigDecimal.valueOf(100)).setScale(2));
      }
      buildingAreaStatistics.putAll(userTopicsTotal);
      // 设置小区名称
      StringBuffer stringBuffer = new StringBuffer();
      for (DistrictEntity districtEntity : list) {
         if (stringBuffer.length() > 0) {
            stringBuffer.append(",");
         }
         stringBuffer.append(districtEntity.getName());
      }
      buildingAreaStatistics.put("districtName", stringBuffer.toString());
      // 设置当前时间并且格式化时间
      buildingAreaStatistics.put("time", DateUtil.format(new Date(), "yyyy-MM-dd"));
      return buildingAreaStatistics;
   }

   @Override
   public List<TopicsDTO> managementProtocol(PublicDiscussVO publicDiscuss, Integer type) {
      // 参与房屋投票的总数
      IDistrictService districtService = SpringUtils.getBean(IDistrictService.class);
      PublicDiscussEntity discussEntity = getOne(Wrappers.<PublicDiscussEntity>lambdaQuery().eq(PublicDiscussEntity::getArticleId, publicDiscuss.getArticleId()));
      ArticleService articleService = SpringUtils.getBean(ArticleService.class);
      Article serviceOne = articleService.getOne(Wrappers.<Article>lambdaQuery().eq(Article::getId, publicDiscuss.getArticleId()));
      String articleRange = serviceOne.getArticleRange();
      List<String> strings = Func.toStrList(articleRange);
      // 获取小区信息
      List<DistrictEntity> list = districtService.list(Wrappers.<DistrictEntity>lambdaQuery()
         .in(DistrictEntity::getId, strings));
      List<String> aoiCodeList = list.stream().map(districtEntity -> districtEntity.getAoiCode()).collect(Collectors.toList());
      // 投票详情统计
      ITopicsService iTopicsService = SpringUtils.getBean(ITopicsService.class);
      List<TopicsDTO> userTopicsTotalByArticleId = iTopicsService.getTopicsTotalByArticleId(discussEntity.getArticleId());
      // 按投票数量排序
      List<TopicsDTO> collect = userTopicsTotalByArticleId.stream().sorted(Comparator.comparing(TopicsDTO::getNumber).reversed()).collect(Collectors.toList());

      if (type == 2) {
         // 获取候选人
         List<TopicsDTO> candidate = collect.stream().filter(topicsDTO ->
               !(topicsDTO.getDiscussContent().equals("管理规约") || topicsDTO.getDiscussContent().equals("议事规则")))
            .collect(Collectors.toList());
         Integer candidateNumber = candidate.stream().map(TopicsDTO::getNumber).reduce(0, Integer::sum);
         // 计算投票的占比
         candidate.forEach(topicsDTO -> {
            BigDecimal number = new BigDecimal(topicsDTO.getNumber());
            BigDecimal total = new BigDecimal(candidateNumber);
            if (total.compareTo(BigDecimal.ZERO) > 0) {
               BigDecimal divide = number.divide(total, 4, BigDecimal.ROUND_HALF_UP);
               topicsDTO.setProportion(divide.multiply(BigDecimal.valueOf(100)).setScale(2));
            }
         });
         return candidate;
      } else {
         // 获取管理规约和议事规则
         List<TopicsDTO> managementProtocol = collect.stream().filter(topicsDTO ->
               topicsDTO.getDiscussContent().equals("管理规约") || topicsDTO.getDiscussContent().equals("议事规则"))
            .collect(Collectors.toList());
         Integer managementProtocolNumber = managementProtocol.stream().map(TopicsDTO::getNumber).reduce(0, Integer::sum);
         // 计算投票的占比
         managementProtocol.forEach(topicsDTO -> {
            BigDecimal number = new BigDecimal(topicsDTO.getNumber());
            BigDecimal total = new BigDecimal(managementProtocolNumber);
            if (total.compareTo(BigDecimal.ZERO) > 0) {
               BigDecimal divide = number.divide(total, 4, BigDecimal.ROUND_HALF_UP);
               topicsDTO.setProportion(divide.multiply(BigDecimal.valueOf(100)).setScale(2));
            }
         });
         return managementProtocol;
      }
   }
}