/*
|
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
|
*
|
* Redistribution and use in source and binary forms, with or without
|
* modification, are permitted provided that the following conditions are met:
|
*
|
* Redistributions of source code must retain the above copyright notice,
|
* this list of conditions and the following disclaimer.
|
* Redistributions in binary form must reproduce the above copyright
|
* notice, this list of conditions and the following disclaimer in the
|
* documentation and/or other materials provided with the distribution.
|
* Neither the name of the dreamlu.net developer nor the names of its
|
* contributors may be used to endorse or promote products derived from
|
* this software without specific prior written permission.
|
* Author: Chill 庄骞 (smallchill@163.com)
|
*/
|
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;
|
|
/**
|
* 公益报名与议事 服务实现类
|
*
|
* @author BladeX
|
* @since 2023-11-22
|
*/
|
@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) {
|
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;
|
}
|
}
|
}
|
