/*
 *      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;
		}
	}
}