package com.engine.salary.wrapper;

import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.salary.cache.SalaryCacheKey;
import com.engine.salary.entity.datacollection.DataCollectionEmployee;
import com.engine.salary.entity.salaryBill.dto.SalarySendCheckDTO;
import com.engine.salary.entity.salaryacct.bo.SalaryAcctConfig;
import com.engine.salary.entity.salaryacct.bo.SalaryAcctRecordBO;
import com.engine.salary.entity.salaryacct.dto.SalaryAcctEmployeeCountDTO;
import com.engine.salary.entity.salaryacct.dto.SalaryAcctRecordFormDTO;
import com.engine.salary.entity.salaryacct.dto.SalaryAcctRecordListDTO;
import com.engine.salary.entity.salaryacct.param.SalaryAcctBatParam;
import com.engine.salary.entity.salaryacct.param.SalaryAcctCalculateParam;
import com.engine.salary.entity.salaryacct.param.SalaryAcctRecordQueryParam;
import com.engine.salary.entity.salaryacct.param.SalaryAcctRecordSaveParam;
import com.engine.salary.entity.salaryacct.po.SalaryAcctRecordPO;
import com.engine.salary.entity.salaryacct.po.SalaryAcctSobConfigPO;
import com.engine.salary.entity.salarysob.dto.SalarySobCycleDTO;
import com.engine.salary.entity.salarysob.po.*;
import com.engine.salary.entity.taxagent.po.TaxAgentPO;
import com.engine.salary.enums.salaryaccounting.SalaryAcctRecordStatusEnum;
import com.engine.salary.exception.SalaryRunTimeException;
import com.engine.salary.service.*;
import com.engine.salary.service.impl.*;
import com.engine.salary.sys.constant.SalarySysConstant;
import com.engine.salary.sys.entity.po.SalarySysConfPO;
import com.engine.salary.sys.service.SalarySysConfService;
import com.engine.salary.sys.service.impl.SalarySysConfServiceImpl;
import com.engine.salary.util.SalaryDateUtil;
import com.engine.salary.util.SalaryEntityUtil;
import com.engine.salary.util.SalaryI18nUtil;
import com.engine.salary.util.SalarySobUtil;
import com.engine.salary.util.page.Column;
import com.engine.salary.util.page.PageInfo;
import com.engine.salary.util.valid.ValidUtil;
import com.engine.salary.wrapper.proxy.SalaryAcctRecordWrapperProxy;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.math.NumberUtils;
import weaver.hrm.User;

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

/**
 * 薪资核算记录
 * <p>Copyright: Copyright (c) 2022</p>
 * <p>Company: 泛微软件</p>
 *
 * @author qiantao
 * @version 1.0
 **/
public class SalaryAcctRecordWrapper extends Service implements SalaryAcctRecordWrapperProxy {

    private SalaryAcctRecordService getSalaryAcctRecordService(User user) {
        return ServiceUtil.getService(SalaryAcctRecordServiceImpl.class, user);
    }
    private SalaryAcctResultWrapper getSalaryAcctResultWrapper(User user) {
        return ServiceUtil.getService(SalaryAcctResultWrapper.class, user);
    }

    private SalarySobService getSalarySobService(User user) {
        return ServiceUtil.getService(SalarySobServiceImpl.class, user);
    }

    private SalaryAcctEmployeeService getSalaryAcctEmployeeService(User user) {
        return ServiceUtil.getService(SalaryAcctEmployeeServiceImpl.class, user);
    }

    private SalarySendService getSalarySendService(User user) {
        return ServiceUtil.getService(SalarySendServiceImpl.class, user);
    }

    private SalaryEmployeeService getSalaryEmployeeService(User user) {
        return ServiceUtil.getService(SalaryEmployeeServiceImpl.class, user);
    }

    private SalaryItemService getSalaryItemService(User user) {
        return ServiceUtil.getService(SalaryItemServiceImpl.class, user);
    }

    private TaxAgentService getTaxAgentService(User user) {
        return ServiceUtil.getService(TaxAgentServiceImpl.class, user);
    }

    private SalaryAcctSobConfigService getSalaryAcctSobConfigService(User user) {
        return ServiceUtil.getService(SalaryAcctSobConfigServiceImpl.class, user);
    }

    private SalaryCacheService getSalaryCacheService(User user) {
        return ServiceUtil.getService(SalaryCacheServiceImpl.class, user);
    }


    private SalaryApprovalRuleService getSalaryApprovalRuleService(User user) {
        return ServiceUtil.getService(SalaryApprovalRuleServiceImpl.class, user);
    }

    private SalarySysConfService getSalarySysConfService(User user) {
        return ServiceUtil.getService(SalarySysConfServiceImpl.class, user);
    }

//    private ComInfoCache comInfoCache;

    public PageInfo<SalaryAcctRecordListDTO> listPage(SalaryAcctRecordQueryParam queryParam) {

        // 处理历史数据将薪资账套中将关联人员状态转换为List
        SalarySobUtil.handleEmployeeStatusHistory();
        // 处理工资单发放历史数据
        getSalarySendService(user).handleHistory();
        // 查询薪资核算记录（分页）
        PageInfo<SalaryAcctRecordPO> page = getSalaryAcctRecordService(user).listPageByParam(queryParam);
        PageInfo<SalaryAcctRecordListDTO> dtoPage = new PageInfo<SalaryAcctRecordListDTO>(SalaryAcctRecordListDTO.class);
        dtoPage.setPageNum(queryParam.getCurrent());
        dtoPage.setPageSize(queryParam.getPageSize());
        dtoPage.setTotal(page.getTotal());
        List<SalaryAcctRecordPO> list = page.getList();
        if (CollectionUtils.isNotEmpty(list)) {
            // 查询薪资账套
            Set<Long> salarySobIds = SalaryEntityUtil.properties(list, SalaryAcctRecordPO::getSalarySobId);
            List<SalarySobPO> salarySobPOS = getSalarySobService(user).listByIds(salarySobIds);
            // 规则设置中是否开启薪资审批按钮，默认关闭
            SalarySysConfPO salaryApprovalStatusConf = getSalarySysConfService(user).getOneByCode(SalarySysConstant.SALARY_APPROVAL_STATUS);
            List<Long> needApprovalSalarySobIds = new ArrayList<>();
            // 默认可以重新核算、可以手动归档
            boolean approvalCanReCalc = true;
            boolean approvalCanFile = true;
            if (salaryApprovalStatusConf != null && salaryApprovalStatusConf.getConfValue().equals("1")) {
                // 开启了薪资审批，获取这开启审批的账套id
                List<SalaryApprovalRulePO> salaryApprovalRules = getSalaryApprovalRuleService(user).listBySalarySobIds(salarySobIds);
                needApprovalSalarySobIds = salaryApprovalRules.stream().filter(po -> po.getOpenApproval().equals(1)).map(SalaryApprovalRulePO::getSalarySobId).collect(Collectors.toList());

                // 获取 开启审批的核算记录允许重新核算设置，默认开启
                SalarySysConfPO approvalCanReCalcFileStatusPO = getSalarySysConfService(user).getOneByCode(SalarySysConstant.APPROVAL_CAN_RE_CALC_STATUS);
                approvalCanReCalc = approvalCanReCalcFileStatusPO == null ? true : approvalCanReCalcFileStatusPO.getConfValue().equals("1");
                // 获取 开启审批的核算记录允许手动归档，默认开启
                SalarySysConfPO approvalCanManualFileStatusPO = getSalarySysConfService(user).getOneByCode(SalarySysConstant.APPROVAL_CAN_MANUAL_FILE_STATUS);
                approvalCanFile = approvalCanManualFileStatusPO == null ? true : approvalCanManualFileStatusPO.getConfValue().equals("1");
            }
            // 查询薪资核算记录的创建人员的人员信息
            List<Long> employeeIds = SalaryEntityUtil.properties(list, SalaryAcctRecordPO::getCreator, Collectors.toList());
            List<DataCollectionEmployee> employeeComInfos = getSalaryEmployeeService(user).getEmployeeByIdsAll(employeeIds);
            // 查询薪资核算人数的数量
            Set<Long> salaryAcctRecordIds = SalaryEntityUtil.properties(list, SalaryAcctRecordPO::getId);
            List<SalaryAcctEmployeeCountDTO> salaryAcctEmployeeCountDTOS = getSalaryAcctEmployeeService(user).countBySalaryAcctRecordId(salaryAcctRecordIds);
            // 查询工资单的查询情况
            List<SalarySendCheckDTO> salarySendCheckResult = getSalarySendService(user).getSalarySendCheckResult(salaryAcctRecordIds);

            Set<Long> taxAgentIds = SalaryEntityUtil.properties(salarySobPOS, SalarySobPO::getTaxAgentId);
            List<TaxAgentPO> taxAgentPOS = getTaxAgentService(user).listByIds(taxAgentIds);
            // 转换成列表dto
            List<SalaryAcctRecordListDTO> salaryAcctRecordListDTOS = SalaryAcctRecordBO.convert2ListDTO(list, salarySobPOS, employeeComInfos, salaryAcctEmployeeCountDTOS, salarySendCheckResult, taxAgentPOS, needApprovalSalarySobIds, approvalCanFile, approvalCanReCalc);
            dtoPage.setList(salaryAcctRecordListDTOS);
            // 规则设置中是否开启审批功能，默认关闭
            if (CollectionUtils.isEmpty(needApprovalSalarySobIds)) {
                // 没有开启审批的
                List<Column> columnList = dtoPage.getColumns().stream().filter(col -> !col.getKey().equals("approvalStatus")).collect(Collectors.toList());
                dtoPage.clearAndSetColumns(columnList);
            }
        }
//        WeaTable<SalaryAcctRecordListDTO> weaTable = SalaryFormatUtil.<SalaryAcctRecordListDTO>getInstance().buildTable(SalaryAcctRecordListDTO.class, dtoPage);
        // 只有未归档时可以"核算"、"删除"、"归档"
        // 归档后、申报后可以"查看"、"重新核算"
//        for (int i = 0; i < page.getRecords().size(); i++) {
//            SalaryAcctRecordPO salaryAcctRecord = page.getRecords().get(i);
//            List<Permission> permissions = weaTable.getOperatesPermission().get(i);
//            for (int j = 0; j < permissions.size(); j++) {
//                Permission permission = permissions.get(j);
//                if ((j == 0 || j == 1 || j == 3) && !Objects.equals(salaryAcctRecord.getStatus(), SalaryAcctRecordStatusEnum.NOT_ARCHIVED.getValue())) {
//                    permission.setVisible(false);
//                    permission.setDisabled(false);
//                }
//                if ((j == 2 || j == 5) && Objects.equals(salaryAcctRecord.getStatus(), SalaryAcctRecordStatusEnum.NOT_ARCHIVED.getValue())) {
//                    permission.setVisible(false);
//                    permission.setDisabled(false);
//                }
//            }
//        }
        return dtoPage;
    }

    /**
     * @description 处理历史数据给薪资项目都增加个默认排序
     * @return null
     * @author Harryxzy
     * @date 2023/5/29 14:37
     */
//    private void generateSalaryItemSortedIndex() {
//        // 查询所有薪资项目
//        List<SalaryItemPO> salaryItemList = getSalaryItemService(user).listByParamOrderById(SalaryItemSearchParam.builder().build());
//        Optional<SalaryItemPO> needGenerate = salaryItemList.stream().filter(item -> item.getSortedIndex() == null).findFirst();
//        if(needGenerate.isPresent()){
//            Map<Integer, List<SalaryItemPO>> salaryItemMap = SalaryEntityUtil.group2Map(salaryItemList, SalaryItemPO::getUseInEmployeeSalary);
//            for(Map.Entry<Integer, List<SalaryItemPO>> entry : salaryItemMap.entrySet()){
//                List<SalaryItemPO> values = entry.getValue();
//                if(CollectionUtils.isNotEmpty(values)){
//                    // 将系统薪资项目放到最后
//                    values = values.stream()
//                            .sorted(Comparator.comparing(SalaryItemPO::getSystemType))
//                            .collect(Collectors.toList());
//                    // 添加默认sortedIndex
//                    AtomicInteger index = new AtomicInteger(values.size());
//                    values.stream().forEach(value -> value.setSortedIndex(index.getAndDecrement()));
//                    // 保存排序
//                    getSalaryItemService(user).batchUpdateSortedIndex(values);
//                }
//            }
//        }
//    }

    /**
     * 薪资核算记录详情
     *
     * @param id 薪资核算记录id
     * @return
     */
    public Map<String, Object> getForm(Long id) {
        SalaryAcctRecordFormDTO formDTO = new SalaryAcctRecordFormDTO();
        // 查询所有启用的薪资账套
        List<SalarySobPO> salarySobPOS = getSalarySobService(user).listByDisable(NumberUtils.INTEGER_ZERO);
        // 薪资核算详情表单中"薪资账套"的下拉选择项
        List<Map<String, Object>> salarySobs = salarySobPOS.stream()
                .map(salarySobPO -> {
                    Map<String, Object> map = new HashMap<>();
                    map.put("id", salarySobPO.getId());
                    map.put("name", salarySobPO.getName());
                    return map;
                })
                .collect(Collectors.toList());

        if (Objects.nonNull(id)) {
            // 查询薪资核算
            SalaryAcctRecordPO salaryAcctRecordPO = getSalaryAcctRecordService(user).getById(id);
            if (Objects.isNull(salaryAcctRecordPO)) {
                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(98747, "薪资核算记录不存在或已被删除"));
            }
            // 查询薪资账套
            SalarySobPO salarySobPO = getSalarySobService(user).getById(salaryAcctRecordPO.getSalarySobId());
            if (Objects.isNull(salarySobPO)) {
                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(98769, "薪资账套不存在或已被删除"));
            }
            // 转换成薪资核算记录详情dto
            formDTO.setId(salaryAcctRecordPO.getId())
                    .setSalarySobId(salarySobPO.getId())
                    .setSalarySobName(salarySobPO.getName())
                    .setSalaryMonth(SalaryDateUtil.localDate2YearMonth(salaryAcctRecordPO.getSalaryMonth()).toString())
                    .setDescription(salaryAcctRecordPO.getDescription());
        }
        // 转换成前端所需的数据格式
        Map<String, Object> result = new HashMap<>();
        result.put("formDTO", formDTO);
        result.put("salarySobs", salarySobs);
        return result;
    }

    /**
     * 薪资核算记录所用的薪资账套薪资周期、考勤周期……
     *
     * @param id 薪资核算记录的id
     * @return
     */
    public SalarySobCycleDTO getSalarySobCycleById(Long id) {
        return getSalaryAcctRecordService(user).getSalarySobCycleById(id);
    }

    /**
     * 保存
     *
     * @param saveParam 保存参数
     * @return
     */
    public Long save(SalaryAcctRecordSaveParam saveParam) {
        return getSalaryAcctRecordService(user).save(saveParam);
    }

    /**
     * 删除
     *
     * @param ids 薪资核算记录的id
     */
    public void delete(Collection<Long> ids) {
        getSalaryAcctRecordService(user).deleteByIds(ids);
    }

    /**
     * 归档
     *
     * @param id 薪资核算记录的id
     */
    public void file(Long id) {
        getSalaryAcctRecordService(user).file(id);
    }

    /**
     * 重新核算
     *
     * @param id 薪资核算记录的id
     */
    public void reCalculate(Long id) {
        getSalaryAcctRecordService(user).reCalculate(id);
    }


    /**
     * 判断是否存在合并计税
     *
     * @param id 主键id
     * @return
     */
    public Integer hasConsolidatedTax(Long id) {
        return getSalaryAcctRecordService(user).hasConsolidatedTax(id);
    }

    /**
     * @return void
     * @description 回算
     * @author Harryxzy
     * @date 2022/11/24 15:52
     */
    public void backCalculate(Long salaryAcctRecordId) {
        getSalaryAcctRecordService(user).backCalculate(salaryAcctRecordId);
    }


    /**
     * 薪资核算的账套配置是否已经发生变更
     *
     * @param id
     * @return true--发生了变更、false--没有发生变更
     */
    public boolean compareSobConfig(Long id) {
        SalaryAcctRecordPO salaryAcctRecord = getSalaryAcctRecordService(user).getById(id);
        if (salaryAcctRecord == null) {
            throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(156474, "参数错误，薪资核算记录不存在或已被删除"));
        }
        // 查询薪资核算记录已有的账套配置
        SalaryAcctSobConfigPO salaryAcctSobConfig = getSalaryAcctSobConfigService(user).getBySalaryAcctRecordId(false, id);
        // 查询最新的账套配置
        SalaryAcctSobConfigPO newSalaryAcctSobConfig = getSalaryAcctSobConfigService(user).initBySalaryAcctRecord(salaryAcctRecord);
        if (Objects.isNull(salaryAcctSobConfig)) {
            // 为避免并发造成的事物问题，需要做一下并发处理
            String cacheIndex = id.toString();
            String acctSobConfigFlag = getSalaryCacheService(user).get(SalaryCacheKey.ACCT_SOB_CONFIG + cacheIndex);
            if (acctSobConfigFlag != null && StringUtils.equals(acctSobConfigFlag, "TRUE")) {
                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(160540, "其他人员正在操作此条薪资核算记录，请稍后再试"));
            }
            getSalaryCacheService(user).set(SalaryCacheKey.ACCT_SOB_CONFIG + cacheIndex, "TRUE");
            getSalaryAcctSobConfigService(user).save(newSalaryAcctSobConfig);
            getSalaryCacheService(user).remove(SalaryCacheKey.ACCT_SOB_CONFIG + cacheIndex);
            return false;
        }

        // 如果薪资核算记录已经归档了，不再校验薪资核算的账套配置是否已经发生变更
        if (!Objects.equals(salaryAcctRecord.getStatus(), SalaryAcctRecordStatusEnum.NOT_ARCHIVED.getValue())) {
            return false;
        }

        SalaryAcctConfig config = SalaryAcctConfig.parse(salaryAcctSobConfig);
        SalaryAcctConfig newConfig = SalaryAcctConfig.parse(newSalaryAcctSobConfig);

        // 判断账套配置是否已经变更了
        SalarySobPO salarySobPO = config.getSalarySob();
        SalarySobPO newSalarySobPO = newConfig.getSalarySob();
        if (!ValidUtil.compare(salarySobPO, newSalarySobPO)) {
            return true;
        }

        List<SalarySobEmpFieldPO> salarySobEmpFields = config.getSalarySobEmpFields();
        List<SalarySobEmpFieldPO> newSalarySobEmpFields = newConfig.getSalarySobEmpFields();
        if (SalarySobEmpFieldPO.toCompareString(salarySobEmpFields).compareTo(SalarySobEmpFieldPO.toCompareString(newSalarySobEmpFields)) != 0) {
            return true;
        }

        List<SalarySobItemGroupPO> salarySobItemGroups = config.getSalarySobItemGroups();
        List<SalarySobItemGroupPO> newSalarySobItemGroups = newConfig.getSalarySobItemGroups();
        if (SalarySobItemGroupPO.toCompareString(salarySobItemGroups).compareTo(SalarySobItemGroupPO.toCompareString(newSalarySobItemGroups)) != 0) {
            return true;
        }

        List<SalarySobItemPO> salarySobItems = config.getSalarySobItems();
        List<SalarySobItemPO> newSalarySobItems = newConfig.getSalarySobItems();
        if (SalarySobItemPO.toCompareString(salarySobItems).compareTo(SalarySobItemPO.toCompareString(newSalarySobItems)) != 0) {
            return true;
        }

        List<SalarySobBackItemPO> salarySobBackItems = config.getSalarySobBackItems();
        List<SalarySobBackItemPO> newSalarySobBackItems = newConfig.getSalarySobBackItems();
        if (SalarySobBackItemPO.toCompareString(salarySobBackItems).compareTo(SalarySobBackItemPO.toCompareString(newSalarySobBackItems)) != 0) {
            return true;
        }
        return false;
    }

    /**
     * 更新薪资核算的账套配置
     *
     * @param id
     */
    public void updateSobConfig(Long id) {
        getSalaryAcctSobConfigService(user).updateBySalaryAcctRecordId(id);
    }


    public void batSave(SalaryAcctBatParam param) {
        getSalaryAcctRecordService(user).batSave(param);
    }


    public void batFile(SalaryAcctBatParam param) {
        getSalaryAcctRecordService(user).batFile(param);
    }

    public void batReCalculate(SalaryAcctBatParam param) {
        getSalaryAcctRecordService(user).batReCalculate(param);

    }

    public void batCalculate(SalaryAcctBatParam param) {
        List<Long> salaryAcctRecordIds = param.getSalaryAcctRecordIds();
        for (int i = 0; i < salaryAcctRecordIds.size(); i++) {
            Long recordId = salaryAcctRecordIds.get(i);
            SalaryAcctCalculateParam calculateParam = SalaryAcctCalculateParam.builder().salaryAcctRecordId(recordId).build();
            getSalaryAcctResultWrapper(user).calculate(calculateParam);
        }
    }
}