package com.ruoyi.dz.service.impl;

import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

import cn.hutool.core.util.RandomUtil;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
import com.ruoyi.common.annotation.Excel;
import com.ruoyi.common.core.domain.entity.SysDept;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.enums.ExamType;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.criteria.CardCriteria;
import com.ruoyi.dz.domain.*;
import com.ruoyi.dz.mapper.*;
import com.ruoyi.enums.*;
import com.ruoyi.system.mapper.SysDeptMapper;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ruoyi.dz.service.IDzCardsService;
import org.springframework.transaction.annotation.Transactional;

import javax.validation.ValidationException;

/**
 * 学习卡Service业务层处理
 * 
 * @author ruoyi
 * @date 2025-09-12
 */
@Service
public class DzCardsServiceImpl implements IDzCardsService 
{
    @Autowired
    private DzCardsMapper dzCardsMapper;
    @Autowired
    private DzCardsOpenMapper dzCardsOpenMapper;
    @Autowired
    private DzAgentMapper dzAgentMapper;
    @Autowired
    private SysDeptMapper sysDeptMapper;
    @Autowired
    private DzSchoolMapper dzSchoolMapper;
    @Autowired
    private DzClassesMapper dzClassesMapper;

    private final String format = "%d%08d";

    /**
     * 查询学习卡
     * 
     * @param cardId 学习卡主键
     * @return 学习卡
     */
    @Override
    public DzCards selectDzCardsByCardId(Long cardId)
    {
        return dzCardsMapper.selectDzCardsByCardId(cardId);
    }

    @Override
    public DzCards selectDzCardsByCardNo(String cardNo)
    {
        DzCards cond = new DzCards();
        cond.setCardNo(cardNo);
        List<DzCards> list = dzCardsMapper.selectDzCardsList(cond);
        return list.size() != 1 ? null : list.get(0);
    }

    private List<DzCards> fillNames(List<DzCards> list) {
        Set<Long> classIdSet = Sets.newHashSet();
        Set<Long> schoolIdSet = Sets.newHashSet();
        Set<Long> deptIdSet = Sets.newHashSet();
        Set<Long> agentIdSet = Sets.newHashSet();
        for(DzCards c : list) {
            if(null != c.getClassId()) {
                classIdSet.add(c.getClassId());
            }
            if(null != c.getAssignSchoolId()) {
                schoolIdSet.add(c.getAssignSchoolId());
            }
            if(null != c.getSchoolId()) {
                schoolIdSet.add(c.getSchoolId());
            }
            if(null != c.getCampusId()) {
                schoolIdSet.add(c.getCampusId());
            }
            if(null != c.getDeptId()) {
                deptIdSet.add(c.getDeptId());
            }
            if(null != c.getLeafAgentId()) {
                agentIdSet.add(c.getLeafAgentId());
            }
            if(null != c.getAgentId()) {
                agentIdSet.add(c.getAgentId());
            }
        }
        Map<Long, String> deptMap = !deptIdSet.isEmpty() ? sysDeptMapper.selectDeptByIds(deptIdSet).stream().collect(Collectors.toMap(SysDept::getDeptId, SysDept::getDeptName)) : Maps.newHashMap();
        Map<Long, String> schoolMap = !schoolIdSet.isEmpty() ? dzSchoolMapper.selectDzSchoolListByIds(schoolIdSet).stream().collect(Collectors.toMap(DzSchool::getId, DzSchool::getName)) : Maps.newHashMap();;
        Map<Long, String> agentMap = !agentIdSet.isEmpty() ? dzAgentMapper.selectDzAgentByAgentIds(agentIdSet).stream().collect(Collectors.toMap(DzAgent::getAgentId, DzAgent::getName)) : Maps.newHashMap();
        Map<Long, String> classesMap = !classIdSet.isEmpty() ? dzClassesMapper.selectClassesByIds(classIdSet).stream().collect(Collectors.toMap(DzClasses::getClassId, DzClasses::getName)) : Maps.newHashMap();
        for(DzCards c : list) {
            c.setClassName(classesMap.get(c.getClassId()));
            c.setAssignSchoolName(schoolMap.get(c.getAssignSchoolId()));
            c.setSchoolName(schoolMap.get(c.getSchoolId()));
            c.setCampusName(schoolMap.get(c.getCampusId()));
            c.setDeptName(deptMap.get(c.getDeptId()));
            if(null != c.getAgentId()) {
                String name = agentMap.get(c.getAgentId());
                c.setAgentName(null != c.getLeafAgentId() && !c.getLeafAgentId().equals(c.getAgentId()) ? agentMap.get(c.getLeafAgentId()) + "(" + name + ")" : name);
            }
        }
        return list;
    }

    /**
     * 查询学习卡列表
     * 
     * @param dzCards 学习卡
     * @return 学习卡
     */
    @Override
    public List<DzCards> selectDzCardsList(DzCards dzCards)
    {
        return fillNames(dzCardsMapper.selectDzCardsList(dzCards));
    }

    /**
     * 新增学习卡
     * 
     * @param dzCards 学习卡
     * @return 结果
     */
    @Override
    public int insertDzCards(DzCards dzCards)
    {
        dzCards.setCreateTime(DateUtils.getNowDate());
        return dzCardsMapper.insertDzCards(dzCards);
    }

    /**
     * 修改学习卡
     * 
     * @param dzCards 学习卡
     * @return 结果
     */
    @Override
    public int updateDzCards(DzCards dzCards)
    {
        dzCards.setUpdateTime(DateUtils.getNowDate());
        return dzCardsMapper.updateDzCards(dzCards);
    }

    /**
     * 批量删除学习卡
     * 
     * @param cardIds 需要删除的学习卡主键
     * @return 结果
     */
    @Override
    public int deleteDzCardsByCardIds(Long[] cardIds)
    {
        return dzCardsMapper.deleteDzCardsByCardIds(cardIds);
    }

    /**
     * 删除学习卡信息
     * 
     * @param cardId 学习卡主键
     * @return 结果
     */
    @Override
    public int deleteDzCardsByCardId(Long cardId)
    {
        return dzCardsMapper.deleteDzCardsByCardId(cardId);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void issueCard(Long deptId, CardType type, Integer count) {
        Long maxNo = dzCardsMapper.selectMaxNo(type.getVal());
        if(null == maxNo) {
            maxNo = type.getVal() * 10000000L;
        }
        for(Integer i = 1; i <= count; i++) {
            DzCards c = new DzCards();
            c.setType(type.getVal());
            c.setCardNo(String.valueOf(maxNo + i));
            c.setPassword(RandomUtil.randomNumbers(6));
            c.setDistributeStatus(CardDistributeStatus.Free.getVal());
            c.setStatus(CardStatus.Free.getVal());
            c.setTimeStatus(CardTimeStatus.Valid.getVal());
            c.setPayStatus(PayStatus.UnPay.getVal());
            c.setIsSettlement(0);
            c.setDeptId(deptId);
            dzCardsMapper.insertDzCards(c);
        }
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void assignCard(Long agentId, Long leafAgentId, String beginNo, String endNo, String location, ExamType examType, Long schoolId) {
        CardCriteria cond = new CardCriteria();
        cond.setStartNo(beginNo);
        cond.setEndNo(endNo);
        DzCards dzCards = new DzCards();
        dzCardsMapper.selectListByCond(cond).stream().forEach(c -> {
            dzCards.setCardId(c.getCardId());
            if(null != c.getAgentId() && !c.getAgentId().equals(agentId)) {
                throw new ValidationException("卡分配错误");
            }
            dzCards.setAgentId(agentId);
            dzCards.setLeafAgentId(leafAgentId);
            dzCards.setDistributeTime(DateUtils.getNowDate());
            dzCards.setAssignLocation(location);
            dzCards.setAssignExamType(null != examType ? examType.name() : null);
            dzCards.setAssignSchoolId(schoolId);
            dzCards.setDistributeStatus(CardDistributeStatus.Assign.getVal());
            dzCards.setPayStatus(PayStatus.Paid.getVal()); // TODO 暂时分配即开卡
            dzCards.setStatus(CardStatus.Paid.getVal());
            dzCardsMapper.updateDzCards(dzCards);
        });
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean openCard(Long agentId, String location, Long schoolId, String beginNo, String endNo) {
        DzCardsOpen newOpen = new DzCardsOpen();
        newOpen.setAgentId(agentId);
        newOpen.setStartNo(beginNo);
        newOpen.setEndNo(endNo);
        newOpen.setEndDate(DateUtils.addDays(DateUtils.getNowDate(), 14)); // TODO MF 卡默认有效期
        newOpen.setSchoolId(schoolId);
        newOpen.setLocation(location);
        newOpen.setSender(SecurityUtils.getLoginUser().getUser().getNickName());
        newOpen.setIsReopen(0);
        newOpen.setStatus(RequestStatus.Accept.getVal());
        dzCardsOpenMapper.insertDzCardsOpen(newOpen);
        // TODO MF 检查已经使用的或无效的
        CardCriteria cond = new CardCriteria();
        cond.setStartNo(beginNo);
        cond.setEndNo(endNo);
        List<DzCards> cards = dzCardsMapper.selectListByCond(cond);
        if(cards.stream().filter(t -> !t.getPayStatus().equals(PayStatus.UnPay.getVal())).count() > 0) {
            throw new ValidationException("请求打开已开卡: " + beginNo + "-" + endNo);
        }
        DzAgent dzAgent = dzAgentMapper.selectDzAgentByAgentId(agentId);
        DzCards dzCards = new DzCards();
        cards.stream().forEach(c -> {
            dzCards.setCardId(c.getCardId());
            dzCards.setPayTime(DateUtils.getNowDate());
            dzCards.setPayStatus(PayStatus.Paid.getVal());
            dzCards.setStatus(CardStatus.Paid.getVal());
            dzCards.setDistributeStatus(CardDistributeStatus.Assign.getVal());
            dzCards.setAssignLocation(location);
            dzCards.setAssignSchoolId(schoolId);
            if(null != dzAgent.getParentId()) {
                dzCards.setAgentId(dzAgent.getParentId());
                dzCards.setLeafAgentId(dzAgent.getAgentId());
            } else {
                dzCards.setAgentId(dzAgent.getAgentId());
                dzCards.setLeafAgentId(dzAgent.getAgentId());
            }
            dzCardsMapper.updateDzCards(dzCards);
        });
        // TODO MF 检查已经使用的或无效的
        return true;
    }

    @Override
    public Boolean requestOpenCard(DzCardsOpen dzCardsOpen) {
        SysUser sysUser = SecurityUtils.getLoginUser().getUser();
        if(UserTypeEnum.Agent.getVal().equals(sysUser.getUserType())) {
            dzCardsOpen.setAgentId(sysUser.getUserTypeId());
        }
        dzCardsOpen.setStatus(RequestStatus.Submit.getVal());
        dzCardsOpen.setEndDate(DateUtils.addDays(DateUtils.getNowDate(), 14));
        dzCardsOpen.setIsReopen(0);
        dzCardsOpenMapper.insertDzCardsOpen(dzCardsOpen);
        return true;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean confirmOpenCard(DzCardsOpen dzCardsOpen, SysUser sysUser) {
        DzCardsOpen exist = dzCardsOpenMapper.selectDzCardsOpenById(dzCardsOpen.getId());
        if(UserTypeEnum.Agent.getVal().equals(sysUser.getUserType()) && !exist.getAgentId().equals(dzCardsOpen.getAgentId())) {
            throw new ValidationException("不可修改他人申请");
        }
        if(RequestStatus.Accept.getVal().equals(exist.getStatus())) {
            throw new ValidationException("不可修改已经通过的申请");
        }
        if(!RequestStatus.Submit.getVal().equals(exist.getStatus())) {
            throw new ValidationException("状态无效");
        }
        DzCardsOpen upOpen = new DzCardsOpen();
        upOpen.setId(dzCardsOpen.getId());
        upOpen.setStatus(RequestStatus.Accept.getVal().equals(dzCardsOpen.getStatus()) ? RequestStatus.Accept.getVal() : RequestStatus.Reject.getVal());
        upOpen.setAuditDesc(dzCardsOpen.getAuditDesc());

        if(RequestStatus.Accept.getVal().equals(upOpen.getStatus())) {
            CardCriteria cond = new CardCriteria();
            cond.setStartNo(exist.getStartNo());
            cond.setEndNo(exist.getEndNo());
            List<DzCards> cards = dzCardsMapper.selectListByCond(cond);
            if(cards.stream().filter(t -> !t.getPayStatus().equals(PayStatus.UnPay.getVal())).count() > 0) {
                throw new ValidationException("重复打开已开卡: " + exist.getStartNo() + "-" + exist.getEndNo());
            }
            DzCards dzCards = new DzCards();
            cards.stream().forEach(c -> {
                dzCards.setCardId(c.getCardId());
                dzCards.setAssignLocation(exist.getLocation());
                dzCards.setAssignSchoolId(exist.getSchoolId());
                DzAgent dzAgent = dzAgentMapper.selectDzAgentByAgentId(exist.getAgentId());
                if(null != dzAgent.getParentId()) {
                    dzCards.setAgentId(dzAgent.getParentId());
                    dzCards.setLeafAgentId(dzAgent.getAgentId());
                } else {
                    dzCards.setAgentId(dzAgent.getAgentId());
                    dzCards.setLeafAgentId(dzAgent.getAgentId());
                }
                dzCards.setPayTime(DateUtils.getNowDate());
                dzCards.setPayStatus(PayStatus.Paid.getVal());
                dzCards.setStatus(CardStatus.Paid.getVal());
                dzCards.setDistributeStatus(CardDistributeStatus.Assign.getVal());
                dzCardsMapper.updateDzCards(dzCards);
            });
        }
        dzCardsOpenMapper.updateDzCardsOpen(upOpen);
        return true;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void changeCard(CardAction action, Long[] cardIds) {
        List<DzCards> cards = dzCardsMapper.selectCardsByCardIds(cardIds);;
        DzCards up = new DzCards();
        if(CardAction.Pay.equals(action)) {
            if(cards.stream().filter(t -> !t.getPayStatus().equals(PayStatus.UnPay.getVal())).count() > 0) {
                throw new ValidationException("重复支付已支付卡: " + StringUtils.join(cardIds, ","));
            }
            up.setPayStatus(PayStatus.Paid.getVal());
            up.setStatus(CardStatus.Paid.getVal());
            up.setPayTime(DateUtils.getNowDate());
        } else if(CardAction.Close.equals(action)) {
            if(cards.stream().filter(t -> t.getDistributeStatus().equals(CardDistributeStatus.Close.getVal())).count() > 0) {
                throw new ValidationException("重复关闭卡: " + StringUtils.join(cardIds, ","));
            }
            up.setDistributeStatus(CardDistributeStatus.Close.getVal());
            up.setCloseTime(DateUtils.getNowDate());
        } else if(CardAction.ReOpen.equals(action)) {
            if(cards.stream().filter(t -> !t.getDistributeStatus().equals(CardDistributeStatus.Close.getVal())).count() > 0) {
                throw new ValidationException("重开非关闭卡: " + StringUtils.join(cardIds, ","));
            }
            up.setDistributeStatus(CardDistributeStatus.Assign.getVal());
        } else if(CardAction.Refund.equals(action)) {
            if(cards.stream().filter(t -> t.getPayStatus().equals(PayStatus.Refund.getVal())).count() > 0) {
                throw new ValidationException("重复退款: " + StringUtils.join(cardIds, ","));
            }
            up.setDistributeStatus(CardDistributeStatus.Close.getVal());
            up.setPayStatus(PayStatus.Refund.getVal());
            up.setRefundTime(DateUtils.getNowDate());
        } else {
            throw new ValidationException("无效操作");
        }
        for(Long cardId : cardIds) {
            up.setCardId(cardId);
            dzCardsMapper.updateDzCards(up);
        }
    }

    public Boolean changeCampus(Long campusId, String beginNo, String endNo) {
        CardCriteria cond = new CardCriteria();
        cond.setStartNo(beginNo);
        cond.setEndNo(endNo);
        List<DzCards> cards = dzCardsMapper.selectListByCond(cond);
        DzCards dzCards = new DzCards();
        cards.stream().forEach(c -> {
            dzCards.setCardId(c.getCardId());
            dzCards.setCampusId(campusId);
            dzCardsMapper.updateDzCards(dzCards);
        });
        return true;
    }
}