package com.ruoyi.system.service.impl;

import cn.afterturn.easypoi.excel.ExcelImportUtil;
import cn.afterturn.easypoi.excel.entity.ImportParams;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.google.common.collect.Sets;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.system.dto.TIntegralSettlementDTO;
import com.ruoyi.system.export.IntegralSettlementImport;
import com.ruoyi.system.model.TAppUser;
import com.ruoyi.system.model.TIntegralSettlement;
import com.ruoyi.system.mapper.TIntegralSettlementMapper;
import com.ruoyi.system.query.TIntegralSettlementDetailQuery;
import com.ruoyi.system.query.TIntegralSettlementQuery;
import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.system.service.TAppUserService;
import com.ruoyi.system.service.TIntegralSettlementService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.system.vo.TIntegralSettlementDetailVO;
import com.ruoyi.system.vo.TIntegralSettlementVO;
import lombok.Cleanup;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.InputStream;
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;

/**
 * <p>
 * 积分结算记录 服务实现类
 * </p>
 *
 * @author xiaochen
 * @since 2025-12-08
 */
@Slf4j
@Service
@RequiredArgsConstructor(onConstructor_ = @Lazy)
public class TIntegralSettlementServiceImpl extends ServiceImpl<TIntegralSettlementMapper, TIntegralSettlement> implements TIntegralSettlementService {
    private final TAppUserService appUserService;
    private final ISysUserService sysUserService;

    @Override
    public Page<TIntegralSettlementVO> getSettlementPageList(TIntegralSettlementQuery query) {
        Page<TIntegralSettlementVO> page = new Page<>(query.getPageNum(), query.getPageSize());
        page.setRecords(baseMapper.selectSettlementPageList(page, query));
        return page;
    }

    @Override
    public void importData(MultipartFile file, TIntegralSettlementDTO dto) {
        try {
            ImportParams importParams = new ImportParams();
            importParams.setTitleRows(0);
            importParams.setHeadRows(1);
            @Cleanup
            InputStream inputStream = file.getInputStream();
            List<IntegralSettlementImport> list = ExcelImportUtil.importExcel(inputStream, IntegralSettlementImport.class, importParams);
            // 保存主表
            Map<String, Integer> allAppUserIdMap = getAllAppUserIdMap(list);
            List<TIntegralSettlement> saveList = list.stream().map(item -> {
                TIntegralSettlement model = new TIntegralSettlement();
                model.setSettlementInterval(dto.getSettlementInterval());
                model.setSettlementStartTime(dto.getSettlementStartTime());
                model.setSettlementEndTime(dto.getSettlementEndTime());
                model.setAppUserId(allAppUserIdMap.get(item.getCode()));
                model.setTotalSettlementIntegral(item.getTotalSettlementIntegral());
                model.setCreateUserId(SecurityUtils.getUserId().intValue());
                model.setRemark(item.getRemark());
                return model;
            }).collect(Collectors.toList());
            saveBatch(saveList);
        } catch (Exception e) {
            log.error("导入积分结算异常", e);
            throw new ServiceException("导入积分结算异常");
        }
    }

    private Map<String, Integer> getAllAppUserIdMap(List<IntegralSettlementImport> list) {
        Set<String> codeList = list.stream().map(IntegralSettlementImport::getCode).collect(Collectors.toSet());
        if (CollUtil.isNotEmpty(codeList)) {
            List<TAppUser> appUserList = appUserService.lambdaQuery().in(TAppUser::getCode, codeList)
                    .ne(TAppUser::getStatus, 3).list();
            Set<String> existCodeList = appUserList.stream().map(TAppUser::getCode).collect(Collectors.toSet());
            Sets.SetView<String> difference = Sets.difference(codeList, existCodeList);
            if (CollUtil.isNotEmpty(difference)) {
                throw new ServiceException("推荐码不存在或已停用：" + String.join(",", difference));
            }
            Map<String, Integer> appUserIdMap = appUserList.stream().collect(Collectors.toMap(TAppUser::getCode, TAppUser::getId));
            return appUserIdMap;
        }
        return Collections.emptyMap();
    }

    @Override
    public TIntegralSettlementVO getDetail(Integer id) {
        TIntegralSettlement integralSettlement = this.getById(id);
        TIntegralSettlementVO tIntegralSettlementVO = BeanUtil.copyProperties(integralSettlement, TIntegralSettlementVO.class);
        if (Objects.nonNull(integralSettlement)) {
            List<TIntegralSettlement> list = this.lambdaQuery().eq(TIntegralSettlement::getSettlementInterval, integralSettlement.getSettlementInterval()).list();
            Integer total = list.stream().mapToInt(TIntegralSettlement::getTotalSettlementIntegral).sum();
            tIntegralSettlementVO.setTotalSettlementIntegral(total);
            SysUser sysUser = sysUserService.selectUserById(Long.valueOf(integralSettlement.getCreateUserId()));
            tIntegralSettlementVO.setCreateUserName(Objects.nonNull(sysUser) ? sysUser.getNickName() : "");
        }
        return tIntegralSettlementVO;
    }

    @Override
    public Page<TIntegralSettlementDetailVO> getSettlementDetailPageList(TIntegralSettlementDetailQuery query) {
        TIntegralSettlement integralSettlement = getById(query.getId());
        if (Objects.isNull(integralSettlement)) {
            throw new ServiceException("积分结算记录不存在");
        }
        query.setSettlementInterval(integralSettlement.getSettlementInterval());
        Page<TIntegralSettlementDetailVO> page = new Page<>(query.getPageNum(), query.getPageSize());
        page.setRecords(baseMapper.getSettlementDetailPageList(page, query));
        return page;
    }
}