package com.panzhihua.service_community.service.impl;

import java.util.Date;

import javax.annotation.Resource;

import com.panzhihua.service_community.dao.ComBpActivityDAO;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.dtos.community.integral.ComActIntegralCommunityRankDTO;
import com.panzhihua.common.model.dtos.community.integral.ComActIntegralCountDTO;
import com.panzhihua.common.model.dtos.community.integral.admin.AddComActIntegralUserDTO;
import com.panzhihua.common.model.dtos.community.integral.admin.PageComActIntegralTradeDTO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.integral.admin.ComActIntegralUserTradeAdminVO;
import com.panzhihua.common.model.vos.community.integral.admin.IntegralUserVO;
import com.panzhihua.common.utlis.DateUtils;
import com.panzhihua.common.utlis.Snowflake;
import com.panzhihua.service_community.dao.ComActDiscussDAO;
import com.panzhihua.service_community.dao.ComActIntegralUserTradeMapper;
import com.panzhihua.service_community.dao.ComActQuestnaireDAO;
import com.panzhihua.service_community.model.dos.*;
import com.panzhihua.service_community.service.*;

import lombok.extern.slf4j.Slf4j;

import static java.util.Objects.nonNull;

/**
 * @auther lyq
 * @create 2021-07-28 16:03:18
 * @describe 用户积分账户交易记录服务实现类
 */
@Slf4j
@Service
public class ComActIntegralUserTradeServiceImpl extends
    ServiceImpl<ComActIntegralUserTradeMapper, ComActIntegralUserTradeDO> implements ComActIntegralUserTradeService {

    @Resource
    private ComActIntegralRuleService comActIntegralRuleService;
    @Resource
    private ComActIntegralUserService comActIntegralUserService;
    @Resource
    private ComActQuestnaireDAO comActQuestnaireDAO;
    @Resource
    private ComActIntegralUserChangeService comActIntegralUserChangeService;
    @Resource
    private ComActEasyPhotoService comActEasyPhotoService;
    @Resource
    private ComActMicroWishService comActMicroWishService;
    @Resource
    private ComActDiscussDAO comActDiscussDAO;
    @Resource
    private ComActDiscussOptionService comActDiscussOptionService;
    @Resource
    private ComActActivityService comActActivityService;
    @Resource
    private ComBpActivityDAO comBpActivityDAO;

    /**
     * 查询用户某个时间段交易数量
     * 
     * @param integralCountDTO
     *            请求参数
     * @return 交易数量
     */
    @Override
    public Integer getIntegralCount(ComActIntegralCountDTO integralCountDTO) {
        return this.baseMapper.getIntegralCount(integralCountDTO);
    }

    /**
     * 添加用户积分交易记录
     * 
     * @param userId
     *            用户id
     * @param integralId
     *            积分账户id
     * @param communityId
     *            社区id
     * @param serviceId
     *            交易业务id
     * @param serviceType
     *            交易业务类型（1.发布随手拍 2.发布微心愿 3.参与议事投票 4.社区活动-居民身份参与 " +
     *             "5.社区活动-党员身份参与 6.社区活动-志愿者身份参与 7.参与调查问卷 8.取消活动 9.参与单位党员活动）
     * @param amount
     *            交易积分数量
     * @param changeType
     *            变动类型（1.增加 2.减少）
     * @param remark
     *            交易备注
     * @param identityType
     *            交易身份类型（1.居民 2.党员 3.志愿者）
     * @param createBy
     *            操作人id
     */
    @Override
    public Long addIntegralTradeRecord(Long userId, Long integralId, Long communityId, Long serviceId,
        Integer serviceType, Integer amount, Integer changeType, String remark, Integer identityType, Long createBy) {
        ComActIntegralUserTradeDO integralUserTradeDO = new ComActIntegralUserTradeDO();
        integralUserTradeDO.setId(Snowflake.getId());
        integralUserTradeDO.setUserId(userId);
        integralUserTradeDO.setIntegralId(integralId);
        integralUserTradeDO.setCommunityId(communityId);
        integralUserTradeDO.setServiceId(serviceId);
        integralUserTradeDO.setServiceType(serviceType);
        integralUserTradeDO.setAmount(amount);
        integralUserTradeDO.setChangeType(changeType);
        integralUserTradeDO.setRemark(remark);
        integralUserTradeDO.setIdentityType(identityType);
        integralUserTradeDO.setCreateBy(createBy);
        integralUserTradeDO.setCreateAt(new Date());
        this.baseMapper.insert(integralUserTradeDO);
        return integralUserTradeDO.getId();
    }

    /**
     * 小程序-查询用户社区积分明细
     * 
     * @param communityTradeDTO
     *            请求参数
     * @return 用户社区积分明细
     */
    @Override
    public R getIntegralCommunityTradeApplets(ComActIntegralCommunityRankDTO communityTradeDTO) {
        if (communityTradeDTO.getType().equals(ComActIntegralCommunityRankDTO.type.resident)) {
            communityTradeDTO.setIdentityType(ComActIntegralCommunityRankDTO.identityType.resident);
        } else if (communityTradeDTO.getType().equals(ComActIntegralCommunityRankDTO.type.party)) {
            communityTradeDTO.setIdentityType(ComActIntegralCommunityRankDTO.identityType.party);
        } else if (communityTradeDTO.getType().equals(ComActIntegralCommunityRankDTO.type.volunteer)) {
            communityTradeDTO.setIdentityType(ComActIntegralCommunityRankDTO.identityType.volunteer);
        }
        return R.ok(this.baseMapper.getIntegralCommunityTradeApplets(
            new Page(communityTradeDTO.getPageNum(), communityTradeDTO.getPageSize()), communityTradeDTO));
    }

    /**
     * 社区后台-分页查询社区下积分明细记录
     * 
     * @param integralRuleDTO
     *            请求参数
     * @return 社区下积分明细记录
     */
    @Override
    public R getIntegralTradeListAdmin(PageComActIntegralTradeDTO integralRuleDTO) {
        IPage<ComActIntegralUserTradeAdminVO> userTradeAdminIPage = this.baseMapper.getIntegralTradeListAdmin(
            new Page(integralRuleDTO.getPageNum(), integralRuleDTO.getPageSize()), integralRuleDTO);
        if (!userTradeAdminIPage.getRecords().isEmpty()) {
            userTradeAdminIPage.getRecords().forEach(userTrade -> {
                StringBuilder sb = new StringBuilder();
                sb.append("居民");
                if (userTrade.getIsVolunteer().equals(ComActIntegralUserTradeAdminVO.isVolunteer.yes)) {
                    sb.append(",志愿者");
                }
                if (userTrade.getIsPartymember().equals(ComActIntegralUserTradeAdminVO.isPartymember.yes)) {
                    sb.append(",党员");
                }
                userTrade.setIdentity(sb.toString());
            });
        }
        return R.ok(userTradeAdminIPage);
    }

    /**
     * 给用户添加积分
     * 
     * @param integralUserDTO
     *            请求参数
     * @return 添加积分结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public R addIntegralTradeAdmin(AddComActIntegralUserDTO integralUserDTO) {
        // 判断增加积分类型 积分任务类型（1.发布随手拍 2.发布微心愿 3.参与议事投票 4.社区活动-居民身份参与 " +
        //            "5.社区活动-党员身份参与 6.社区活动-志愿者身份参与 7.参与调查问卷 8.取消活动 9.参与单位党员活动）
        Integer type = integralUserDTO.getIntegralType();
        // 业务id
        Long serviceId = integralUserDTO.getServiceId();
        // 用户id
        Long userId = integralUserDTO.getUserId();
        // 社区id
        Long communityId = integralUserDTO.getCommunityId();
        // 需要给用户增加的积分数量
        Integer amount = 0;
        // 用户增加积分的身份
        Integer identityType = 1;
        // 用户交易备注
        StringBuilder remark = new StringBuilder();
        // 当前时间
        Date nowDate = new Date();

        Integer changeType = ComActIntegralUserTradeDO.changeType.add;

        if (!type.equals(8) && !type.equals(4) && !type.equals(5) && !type.equals(6) && !type.equals(9)) {
            // 查询随手拍增加积分数量
            ComActIntegralRuleDO integralRuleDO =
                    comActIntegralRuleService.getOne(new QueryWrapper<ComActIntegralRuleDO>().lambda()
                            .eq(ComActIntegralRuleDO::getIntegralType, type).eq(ComActIntegralRuleDO::getCommunityId, communityId));
            if (integralRuleDO == null) {
                log.error("未查询到该社区积分规则，社区id：" + communityId);
                return R.fail("未查询到该社区积分规则，社区id：" + communityId);
            }
            // 判断规则是否有次数限制
            if (integralRuleDO.getIsRestrict().equals(ComActIntegralRuleDO.isRestrict.yes)) {
                Integer count = this.baseMapper.getIntegralCount(
                        getIntegralCountDTO(integralRuleDO.getType(), userId, communityId, integralRuleDO.getIntegralType()));
                if (count >= integralRuleDO.getCount()) {
                    log.error("该用户参加任务次数已达上限");
                    return R.fail("该用户参加任务次数已达上限");
                }
            }
            amount = integralRuleDO.getAmount();
        }

        switch (type) {
            case 1:
                remark.append("发布随手拍奖励积分");
                ComActEasyPhotoDO easyPhotoDO = comActEasyPhotoService.getById(serviceId);
                if (easyPhotoDO != null) {
                    remark.append("【");
                    remark.append(easyPhotoDO.getDetail());
                    remark.append("】");
                }
                break;
            case 2:
                remark.append("发布微心愿奖励积分");
                ComActMicroWishDO microWishDO = comActMicroWishService.getById(serviceId);
                if (microWishDO != null) {
                    remark.append("【");
                    remark.append(microWishDO.getWishName());
                    remark.append("】");
                }
                break;
            case 3:
                remark.append("参与议事投票奖励积分");
                if (integralUserDTO.getIsComment().equals(1)) {
                    ComActDiscussDO discussDO = comActDiscussDAO.selectById(serviceId);
                    if (discussDO != null) {
                        remark.append("【");
                        remark.append(discussDO.getDiscussSubject());
                        remark.append("】");
                    }
                } else {
                    ComActDiscussOptionDO discussOptionDO = comActDiscussOptionService.getById(serviceId);
                    if (discussOptionDO != null) {
                        ComActDiscussDO discussDO = comActDiscussDAO.selectById(discussOptionDO.getDiscussId());
                        if (discussDO != null) {
                            remark.append("【");
                            remark.append(discussDO.getVoteTitle());
                            remark.append("】");
                        }
                    }
                }
                break;
            case 7:
                // 查询调查问卷
                ComActQuestnaireDO questnaireDO = comActQuestnaireDAO.selectById(serviceId);
                if (questnaireDO == null) {
                    log.error("未查询到调查问卷记录,记录积分失败");
                    return R.fail("未查询到调查问卷记录,记录积分失败");
                }
                // 查询当前用户信息
                IntegralUserVO integralUser = this.baseMapper.getUserInfo(userId);
                if (integralUser == null) {
                    log.error("未查询到用户信息,记录积分失败");
                    return R.fail("未查询到用户信息,记录积分失败");
                }
                // 判断调查问卷调查的对象是什么身份，如果是党员和志愿者两种身份，则记录志愿者积分
                if (questnaireDO.getForParty().equals(1) && integralUser.getIsPartymember().equals(1)) {
                    identityType = 2;
                    if (questnaireDO.getForVolunteer().equals(1) && integralUser.getIsVolunteer().equals(1)) {
                        identityType = 3;
                    }
                }
                if (questnaireDO.getForVolunteer().equals(1) && integralUser.getIsVolunteer().equals(1)) {
                    identityType = 3;
                }
                remark.append("参与调查问卷奖励积分");
                remark.append("【");
                remark.append(questnaireDO.getTitle());
                remark.append("】");
                break;
            case 8:
                changeType = ComActIntegralUserTradeDO.changeType.reduce;
                amount = -integralUserDTO.getIntegral();
                remark.append(integralUserDTO.getRemark());
                identityType = integralUserDTO.getSignIdentity();
                break;
            case 4:
            case 5:
            case 6:
            case 9:
                identityType = integralUserDTO.getSignIdentity();
                remark.append(integralUserDTO.getRemark());
                amount = integralUserDTO.getIntegral();
                break;
            default:
                break;
        }

        // 查询用户积分账户
        ComActIntegralUserDO integralUserDO =
            comActIntegralUserService.getOne(new QueryWrapper<ComActIntegralUserDO>().lambda()
                .eq(ComActIntegralUserDO::getUserId, userId).eq(ComActIntegralUserDO::getCommunityId, communityId));
        if (integralUserDO == null) {
            integralUserDO = new ComActIntegralUserDO();
            integralUserDO.setCommunityId(communityId);
            integralUserDO.setUserId(userId);
            integralUserDO.setCreateAt(nowDate);
            integralUserDO.setStatus(ComActIntegralUserDO.status.yes);
            integralUserDO.setIntegralSum(0);
            integralUserDO.setIntegralAvailableSum(0);
            integralUserDO.setIntegralFrozenSum(0);
            integralUserDO.setIntegralParty(0);
            integralUserDO.setIntegralAvailableParty(0);
            integralUserDO.setIntegralFrozenParty(0);
            integralUserDO.setIntegralVolunteer(0);
            integralUserDO.setIntegralAvailableVolunteer(0);
            integralUserDO.setIntegralFrozenVolunteer(0);
            integralUserDO.setIntegralResident(0);
            integralUserDO.setIntegralAvailableResident(0);
            integralUserDO.setIntegralFrozenResident(0);
            comActIntegralUserService.save(integralUserDO);
        }
        if (integralUserDO.getStatus().equals(ComActIntegralUserDO.status.no)) {
            log.error("用户钱包已被禁用，记录积分失败，用户id：" + userId);
            return R.fail("用户钱包已被禁用，记录积分失败，用户id：" + userId);
        }
        Long integralId = integralUserDO.getId();
        // 记录变动前钱包金额
        Integer integralSum = integralUserDO.getIntegralSum();
        Integer integralAvailableSum = integralUserDO.getIntegralAvailableSum();
        Integer integralFrozenSum = integralUserDO.getIntegralFrozenSum();
        Integer integralParty = integralUserDO.getIntegralParty();
        Integer integralAvailableParty = integralUserDO.getIntegralAvailableParty();
        Integer integralFrozenParty = integralUserDO.getIntegralFrozenParty();
        Integer integralVolunteer = integralUserDO.getIntegralVolunteer();
        Integer integralAvailableVolunteer = integralUserDO.getIntegralAvailableVolunteer();
        Integer integralFrozenVolunteer = integralUserDO.getIntegralFrozenVolunteer();
        Integer integralResident = integralUserDO.getIntegralResident();
        Integer integralAvailableResident = integralUserDO.getIntegralAvailableResident();
        Integer integralFrozenResident = integralUserDO.getIntegralFrozenResident();

        // 根据不同身份，计算钱包金额
        int reduceAmount = 0;
        if (identityType.equals(ComActIntegralUserTradeDO.identityType.jm)) {
            int integralResidentNow = addIntegral(integralResident + amount);
            if (amount < 0) {
                reduceAmount = integralResident - integralResidentNow;
            }
            integralUserDO.setIntegralResident(integralResidentNow);
            integralUserDO.setIntegralAvailableResident(addIntegral(integralUserDO.getIntegralAvailableResident() + amount));
        } else if (identityType.equals(ComActIntegralUserTradeDO.identityType.dy)) {
            int integralPartyNow = addIntegral(integralParty + amount);
            if (amount < 0) {
                reduceAmount = integralParty - integralPartyNow;
            }
            integralUserDO.setIntegralParty(integralPartyNow);
            integralUserDO.setIntegralAvailableParty(addIntegral(integralUserDO.getIntegralAvailableParty() + amount));
        } else if (identityType.equals(ComActIntegralUserTradeDO.identityType.zyz)) {
            int integralVolunteerNow = addIntegral(integralVolunteer + amount);
            if (amount < 0) {
                reduceAmount = integralVolunteer - integralVolunteerNow;
            }
            integralUserDO.setIntegralVolunteer(integralVolunteerNow);
            integralUserDO.setIntegralAvailableVolunteer(addIntegral(integralUserDO.getIntegralAvailableVolunteer() + amount));
        }
        if (changeType == ComActIntegralUserTradeDO.changeType.reduce) {
            amount = reduceAmount;
            integralUserDO.setIntegralSum(addIntegral(integralSum - reduceAmount));
            integralUserDO.setIntegralAvailableSum(addIntegral(integralAvailableSum - reduceAmount));
        } else {
            integralUserDO.setIntegralSum(addIntegral(integralSum + amount));
            integralUserDO.setIntegralAvailableSum(addIntegral(integralAvailableSum + amount));
        }
        integralUserDO.setUpdateAt(nowDate);

        // 更新钱包
        comActIntegralUserService.updateById(integralUserDO);
        // 增加积分账户交易记录
        Long tradeId = this.addIntegralTradeRecord(userId, integralId, communityId, serviceId, type, amount,
                changeType, remark.toString(), identityType, 2L);
        // 增加积分账户变更记录
        comActIntegralUserChangeService.addIntegralUserChangeRecord(userId, integralId, communityId, integralSum,
            integralUserDO.getIntegralSum(), integralAvailableSum, integralUserDO.getIntegralAvailableSum(),
            integralFrozenSum, integralUserDO.getIntegralFrozenSum(), integralParty, integralUserDO.getIntegralParty(),
            integralAvailableParty, integralUserDO.getIntegralAvailableParty(), integralFrozenParty,
            integralUserDO.getIntegralFrozenParty(), integralVolunteer, integralUserDO.getIntegralVolunteer(),
            integralAvailableVolunteer, integralUserDO.getIntegralAvailableVolunteer(), integralFrozenVolunteer,
            integralUserDO.getIntegralFrozenVolunteer(), integralResident, integralUserDO.getIntegralResident(),
            integralAvailableResident, integralUserDO.getIntegralAvailableResident(), integralFrozenResident,
            integralUserDO.getIntegralFrozenResident(), tradeId);
        return R.ok();
    }

    /**
     * 获取积分详情
     * @param id
     * @return
     */
    @Override
    public R getUserIntegralDetail(Long id) {
        return R.ok(this.baseMapper.getUserIntegralDetail(id));
    }

    private int addIntegral(int integral) {
        return integral > 0 ? integral : 0;
    }

    /**
     * 根据类型、用户id、社区id构建查询请求参数
     * 
     * @param type
     *            类型
     * @param userId
     *            用户id
     * @param communityId
     *            社区id
     * @return 查询请求参数
     */
    private ComActIntegralCountDTO getIntegralCountDTO(Integer type, Long userId, Long communityId,
        Integer integralType) {
        ComActIntegralCountDTO integralCountDTO = new ComActIntegralCountDTO();
        integralCountDTO.setUserId(userId);
        integralCountDTO.setCommunityId(communityId);
        integralCountDTO.setServiceType(integralType);
        integralCountDTO.setType(ComActIntegralUserTradeDO.changeType.add);
        if (type.equals(ComActIntegralRuleDO.type.month)) {
            integralCountDTO.setStartTime(DateUtils.getFirstDayOfMonthString());
            integralCountDTO.setEndTime(DateUtils.getLastDayOfMonthString());
        } else if (type.equals(ComActIntegralRuleDO.type.day)) {
            integralCountDTO.setStartTime(DateUtils.getDayOfMonthString() + " 00:00:00");
            integralCountDTO.setEndTime(DateUtils.getDayOfMonthString() + " 23:59:59");
        }
        return integralCountDTO;
    }

}