package cn.iocoder.yudao.module.hrm.service.salary;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.hrm.controller.admin.salary.vo.HrmEmployeeSocialSecurityImportExcelVO;
import cn.iocoder.yudao.module.hrm.controller.admin.salary.vo.HrmEmployeeSocialSecurityImportReqVO;
import cn.iocoder.yudao.module.hrm.controller.admin.salary.vo.HrmEmployeeSocialSecurityImportRespVO;
import cn.iocoder.yudao.module.hrm.controller.admin.salary.vo.HrmEmployeeSocialSecurityPageReqVO;
import cn.iocoder.yudao.module.hrm.dal.dataobject.employee.HrmEmployeeDO;
import cn.iocoder.yudao.module.hrm.dal.dataobject.salary.HrmEmployeeSocialSecurityDO;
import cn.iocoder.yudao.module.hrm.dal.dataobject.salary.HrmSocialSecuritySchemeDO;
import cn.iocoder.yudao.module.hrm.dal.mysql.employee.HrmEmployeeMapper;
import cn.iocoder.yudao.module.hrm.dal.mysql.salary.HrmEmployeeSocialSecurityMapper;
import cn.iocoder.yudao.module.hrm.dal.mysql.salary.HrmSocialSecuritySchemeMapper;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.filterList;
import static cn.iocoder.yudao.module.hrm.enums.ErrorCodeConstants.*;

/**
 * 员工社保公积金档案 Service 实现类
 *
 * @author 超级管理员
 */
@Service
@Validated
public class HrmEmployeeSocialSecurityServiceImpl implements HrmEmployeeSocialSecurityService {

    @Resource
    private HrmEmployeeSocialSecurityMapper employeeSocialSecurityMapper;
    @Resource
    private HrmEmployeeMapper employeeMapper;
    @Resource
    private HrmSocialSecuritySchemeMapper schemeMapper;

    @Override
    public Long createEmployeeSocialSecurity(HrmEmployeeSocialSecurityDO socialSecurity) {
        employeeSocialSecurityMapper.insert(socialSecurity);
        return socialSecurity.getId();
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void batchCreateEmployeeSocialSecurity(List<HrmEmployeeSocialSecurityDO> socialSecurityList) {
        for (HrmEmployeeSocialSecurityDO socialSecurity : socialSecurityList) {
            employeeSocialSecurityMapper.insert(socialSecurity);
        }
    }

    @Override
    public void updateEmployeeSocialSecurity(HrmEmployeeSocialSecurityDO socialSecurity) {
        validateEmployeeSocialSecurityExists(socialSecurity.getId());
        employeeSocialSecurityMapper.updateById(socialSecurity);
    }

    @Override
    public void deleteEmployeeSocialSecurity(Long id) {
        validateEmployeeSocialSecurityExists(id);
        employeeSocialSecurityMapper.deleteById(id);
    }

    @Override
    public HrmEmployeeSocialSecurityDO getEmployeeSocialSecurity(Long id) {
        return employeeSocialSecurityMapper.selectById(id);
    }

    @Override
    public PageResult<HrmEmployeeSocialSecurityDO> getEmployeeSocialSecurityPage(HrmEmployeeSocialSecurityPageReqVO pageReqVO) {
        return employeeSocialSecurityMapper.selectPage(pageReqVO);
    }

    @Override
    public HrmEmployeeSocialSecurityDO getLatestEmployeeSocialSecurity(Long userId) {
        return employeeSocialSecurityMapper.selectLatestByUserId(userId);
    }

    @Override
    public List<HrmEmployeeSocialSecurityDO> getEmployeeSocialSecurityList(Long userId) {
        return employeeSocialSecurityMapper.selectListByUserId(userId);
    }

    private void validateEmployeeSocialSecurityExists(Long id) {
        if (employeeSocialSecurityMapper.selectById(id) == null) {
            throw exception(EMPLOYEE_SOCIAL_SECURITY_NOT_EXISTS);
        }
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public HrmEmployeeSocialSecurityImportRespVO importEmployeeSocialSecurityList(
            List<HrmEmployeeSocialSecurityImportExcelVO> importList, HrmEmployeeSocialSecurityImportReqVO importReqVO) {
        // 1. 校验非空
        importList = filterList(importList, item -> StrUtil.isNotBlank(item.getEmployeeName()));
        if (CollUtil.isEmpty(importList)) {
            throw exception(EMPLOYEE_SOCIAL_SECURITY_IMPORT_LIST_IS_EMPTY);
        }
        // 2. 逐条处理
        HrmEmployeeSocialSecurityImportRespVO respVO = HrmEmployeeSocialSecurityImportRespVO.builder()
                .createNames(new ArrayList<>())
                .updateNames(new ArrayList<>())
                .failureNames(new LinkedHashMap<>())
                .build();
        importList.forEach(importSocialSecurity -> {
            try {
                // 2.1 解析员工
                HrmEmployeeDO employee = employeeMapper.selectByName(importSocialSecurity.getEmployeeName());
                if (employee == null) {
                    throw exception(EMPLOYEE_SOCIAL_SECURITY_EMPLOYEE_NOT_EXISTS, importSocialSecurity.getEmployeeName());
                }
                // 2.2 解析方案
                Long schemeId = null;
                if (StrUtil.isNotBlank(importSocialSecurity.getSchemeName())) {
                    HrmSocialSecuritySchemeDO scheme = schemeMapper.selectByName(importSocialSecurity.getSchemeName());
                    if (scheme == null) {
                        throw exception(EMPLOYEE_SOCIAL_SECURITY_SCHEME_NOT_EXISTS, importSocialSecurity.getSchemeName());
                    }
                    schemeId = scheme.getId();
                }
                // 2.3 生效日期必填
                if (importSocialSecurity.getEffectiveDate() == null) {
                    respVO.getFailureNames().put(importSocialSecurity.getEmployeeName(), "生效日期不能为空");
                    return;
                }
                // 2.4 判断是否存在（按员工+生效日期唯一）
                HrmEmployeeSocialSecurityDO existSocialSecurity = employeeSocialSecurityMapper
                        .selectByUserIdAndEffectiveDate(employee.getId(), importSocialSecurity.getEffectiveDate());
                if (existSocialSecurity == null) {
                    // 2.4.1 新增
                    HrmEmployeeSocialSecurityDO socialSecurity = BeanUtils.toBean(importSocialSecurity, HrmEmployeeSocialSecurityDO.class)
                            .setUserId(employee.getId()).setSocialSecuritySchemeId(schemeId);
                    if (socialSecurity.getStatus() == null) {
                        socialSecurity.setStatus(0);
                    }
                    employeeSocialSecurityMapper.insert(socialSecurity);
                    respVO.getCreateNames().add(importSocialSecurity.getEmployeeName());
                    return;
                }
                // 2.4.2 已存在，判断是否允许更新
                if (!importReqVO.getUpdateSupport()) {
                    respVO.getFailureNames().put(importSocialSecurity.getEmployeeName(),
                            StrUtil.format(EMPLOYEE_SOCIAL_SECURITY_EXISTS.getMsg(), importSocialSecurity.getEmployeeName()));
                    return;
                }
                HrmEmployeeSocialSecurityDO updateSocialSecurity = BeanUtils.toBean(importSocialSecurity, HrmEmployeeSocialSecurityDO.class)
                        .setId(existSocialSecurity.getId()).setUserId(employee.getId()).setSocialSecuritySchemeId(schemeId);
                if (updateSocialSecurity.getStatus() == null) {
                    updateSocialSecurity.setStatus(0);
                }
                employeeSocialSecurityMapper.updateById(updateSocialSecurity);
                respVO.getUpdateNames().add(importSocialSecurity.getEmployeeName());
            } catch (ServiceException ex) {
                respVO.getFailureNames().put(importSocialSecurity.getEmployeeName(), ex.getMessage());
            }
        });
        return respVO;
    }

}