From 8b7258c9427882bb1798f1502eaa35184c6e374e Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Fri, 09 Aug 2024 14:29:18 +0800
Subject: [PATCH] 短信指定楼栋发送
---
src/main/java/org/springblade/modules/discuss/service/impl/PublicDiscussServiceImpl.java | 206 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 205 insertions(+), 1 deletions(-)
diff --git a/src/main/java/org/springblade/modules/discuss/service/impl/PublicDiscussServiceImpl.java b/src/main/java/org/springblade/modules/discuss/service/impl/PublicDiscussServiceImpl.java
index c78aeb9..52b9ac7 100644
--- a/src/main/java/org/springblade/modules/discuss/service/impl/PublicDiscussServiceImpl.java
+++ b/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;
+ }
+ }
}
--
Gitblit v1.9.3