From 24f2e1047e0260915ce6e401ec36763974531eed Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Thu, 27 Jun 2024 10:15:23 +0800
Subject: [PATCH] 积木报表+业主大会统计
---
src/main/java/org/springblade/modules/discuss/service/impl/PublicDiscussServiceImpl.java | 130 +++++++++++++++++++++++++++++++++++++++++++
1 files changed, 130 insertions(+), 0 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 aa99403..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
@@ -19,25 +19,39 @@
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;
/**
* 公益报名与议事 服务实现类
@@ -113,4 +127,120 @@
}
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