weaver-hrm-salary/src/com/engine/salary/service/impl/SIRepairServiceImpl.java

package com.engine.salary.service.impl;

import com.alibaba.fastjson.JSON;
import com.engine.core.impl.Service;
import com.engine.salary.encrypt.EncryptUtil;
import com.engine.salary.entity.siaccount.param.SaveSupplementaryAccountParam;
import com.engine.salary.entity.siaccount.param.SupplementAccountBaseParam;
import com.engine.salary.entity.siaccount.po.InsuranceAccountDetailPO;
import com.engine.salary.entity.siarchives.po.*;
import com.engine.salary.entity.sicategory.po.ICategoryPO;
import com.engine.salary.enums.siaccount.ProjectTypeEnum;
import com.engine.salary.enums.sicategory.DataTypeEnum;
import com.engine.salary.exception.SalaryRunTimeException;
import com.engine.salary.mapper.siaccount.InsuranceAccountDetailMapper;
import com.engine.salary.mapper.siarchives.FundSchemeMapper;
import com.engine.salary.mapper.siarchives.OtherSchemeMapper;
import com.engine.salary.mapper.siarchives.SocialSchemeMapper;
import com.engine.salary.mapper.sicategory.ICategoryMapper;
import com.engine.salary.service.SIRepairService;
import com.engine.salary.util.SalaryEntityUtil;
import com.engine.salary.util.SalaryI18nUtil;
import com.engine.salary.util.db.MapperProxyFactory;
import com.google.common.collect.Maps;

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

/**
 * @Author: sy
 * @Description: 福利台账-补缴实现类
 * @Date: 2022/12/27
 **/
public class SIRepairServiceImpl extends Service implements SIRepairService {

    private EncryptUtil encryptUtil = new EncryptUtil();

    private InsuranceAccountDetailMapper getInsuranceAccountDetailMapper() {
        return MapperProxyFactory.getProxy(InsuranceAccountDetailMapper.class);
    }

    private SocialSchemeMapper getSocialSchemeMapper() {
        return MapperProxyFactory.getProxy(SocialSchemeMapper.class);
    }

    private FundSchemeMapper getFundSchemeMapper() {
        return MapperProxyFactory.getProxy(FundSchemeMapper.class);
    }

    private OtherSchemeMapper getOtherSchemeMapper() {
        return MapperProxyFactory.getProxy(OtherSchemeMapper.class);
    }

    /**
     * 获取指定月份的福利缴纳基数作为补缴基数
     * @param param
     * @return
     */
    @Override
    public List<Map<String, String>>  getSupplementPaymentForm(SupplementAccountBaseParam param) {

        Long paymentOrganization = param.getPaymentOrganization();
        String billMonth = param.getBillMonth();
        List<Integer> projects = param.getProjects();
        Long employeeId = param.getEmployeeId();

        List<InsuranceAccountDetailPO> detailPOList = getInsuranceAccountDetailMapper().queryNormalList(billMonth, paymentOrganization, employeeId);

        if (detailPOList.size() > 1) {
            throw new SalaryRunTimeException("该人员本次核算出现多组数据，请删除数据库中多余核算项");
        } else if (detailPOList.size() == 0) {
            throw new SalaryRunTimeException("数据不存在");
        } else {
            InsuranceAccountDetailPO targetDetailPO = detailPOList.get(0);
            encryptUtil.decrypt(targetDetailPO, InsuranceAccountDetailPO.class);

            String socialBaseString = targetDetailPO.getSocialPaymentBaseString();
            String fundBaseString = targetDetailPO.getFundPaymentBaseString();
            String otherBaseString = targetDetailPO.getOtherPaymentBaseString();

            Map<String, String> socialBaseMap = JSON.parseObject(socialBaseString, HashMap.class);
            Map<String, String> fundBaseMap = JSON.parseObject(fundBaseString, HashMap.class);
            Map<String, String> otherBaseMap = JSON.parseObject(otherBaseString, HashMap.class);

            Map<String, String> targetBaseMap = new HashMap<>();

            List<ICategoryPO> allCategoryList = MapperProxyFactory.getProxy(ICategoryMapper.class).listAll();
            Map<Long, String> categoryNameMap = SalaryEntityUtil.convert2Map(allCategoryList, ICategoryPO::getId, ICategoryPO::getInsuranceName);

            if (projects.contains(ProjectTypeEnum.ALL.getValue())) {
                targetBaseMap.putAll(socialBaseMap);
                targetBaseMap.putAll(fundBaseMap);
                targetBaseMap.putAll(otherBaseMap);
            }
            if (projects.contains(ProjectTypeEnum.SOCIAL.getValue())) {
                targetBaseMap.putAll(socialBaseMap);
            }
            if (!projects.contains(ProjectTypeEnum.SOCIAL.getValue())) {

                List<ICategoryPO> list = MapperProxyFactory.getProxy(ICategoryMapper.class).listByDataType(DataTypeEnum.SYSTEM.getValue());

                if (projects.contains(ProjectTypeEnum.ENDOWMENT_INSURANCE.getValue())) {
                    ICategoryPO insuranceCategoryPO = list.stream().filter(item -> SalaryI18nUtil.getI18nLabel(93113, "养老保险").equals(item.getInsuranceName())).findFirst()
                            .get();
                    targetBaseMap.put(insuranceCategoryPO.getId().toString(), socialBaseMap.get(insuranceCategoryPO.getId()));
                }
                if (projects.contains(ProjectTypeEnum.MEDICAL_INSURANCE.getValue())) {
                    ICategoryPO insuranceCategoryPO = list.stream().filter(item -> SalaryI18nUtil.getI18nLabel(93114, "医疗保险").equals(item.getInsuranceName())).findFirst()
                            .get();
                    targetBaseMap.put(insuranceCategoryPO.getId().toString(), socialBaseMap.get(insuranceCategoryPO.getId()));
                }


            }
            if (projects.contains(ProjectTypeEnum.FUND.getValue())) {
                targetBaseMap.putAll(fundBaseMap);

            }
            if (projects.contains(ProjectTypeEnum.OTHER.getValue())) {

                targetBaseMap.putAll(otherBaseMap);
            }

            List<Map<String, String>> resulit = new ArrayList();
            if (targetBaseMap.size() > 0) {
                for (Map.Entry<String, String> entry : targetBaseMap.entrySet()) {

                    Map<String, String> map = new HashMap<>();
                    map.put("insuranceId", entry.getKey());
                    map.put("insuranceName", categoryNameMap.get(Long.valueOf(entry.getKey())));
                    map.put("insuranceBase", entry.getValue());

                    resulit.add(map);
                }
            }
            return resulit;

        }


    }

    /**
     * 获取待编辑的补缴费用相关福利项
     */
    @Override
    public List<Map<String, String>> getPaymentGroup(SupplementAccountBaseParam param) {

        Long paymentOrganization = param.getPaymentOrganization();
        List<Integer> projects = param.getProjects();
        Long employeeId = param.getEmployeeId();
        InsuranceArchivesSocialSchemePO socialSchemePO = new InsuranceArchivesSocialSchemePO();
        InsuranceArchivesFundSchemePO fundSchemePO = new InsuranceArchivesFundSchemePO();
        InsuranceArchivesOtherSchemePO otherSchemePO = new InsuranceArchivesOtherSchemePO();

        List<InsuranceArchivesSocialSchemePO> socialSchemePOList = getSocialSchemeMapper().getSocialByEmployeeIdAndPayOrg(InsuranceArchivesEmployeePO.builder()
                .employeeId(employeeId)
                .paymentOrganization(paymentOrganization)
                .build());
        if (socialSchemePOList.size() > 0) {
            encryptUtil.decryptList(socialSchemePOList, InsuranceArchivesSocialSchemePO.class);
            socialSchemePO = socialSchemePOList.get(0);
        }

        List<InsuranceArchivesFundSchemePO> fundSchemePOList = getFundSchemeMapper().getFundByEmployeeIdAndPayOrg(InsuranceArchivesEmployeePO.builder()
                .employeeId(employeeId)
                .paymentOrganization(paymentOrganization)
                .build());
        if (fundSchemePOList.size() > 0) {
            encryptUtil.decryptList(fundSchemePOList, InsuranceArchivesFundSchemePO.class);
            fundSchemePO = fundSchemePOList.get(0);
        }

        List<InsuranceArchivesOtherSchemePO> otherSchemePOList = getOtherSchemeMapper().getOtherByEmployeeIdAndPayOrg(InsuranceArchivesEmployeePO.builder()
                .employeeId(employeeId)
                .paymentOrganization(paymentOrganization)
                .build());
        if (otherSchemePOList.size() > 0) {
            encryptUtil.decryptList(otherSchemePOList, InsuranceArchivesOtherSchemePO.class);
            otherSchemePO = otherSchemePOList.get(0);
        }

        List<ICategoryPO> allCategoryList = MapperProxyFactory.getProxy(ICategoryMapper.class).listAll();
        Map<Long, String> categoryNameMap = SalaryEntityUtil.convert2Map(allCategoryList, ICategoryPO::getId, ICategoryPO::getInsuranceName);

        List<Map<String, String>> resultList = new ArrayList<>();
        if (projects.contains(ProjectTypeEnum.ALL.getValue())) {
            if (socialSchemePO != null) {
                Map<String, String> socialMap = JSON.parseObject(socialSchemePO.getSocialPaymentBaseString(), new HashMap<String, String>().getClass());

                socialMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });

            }
            if (fundSchemePO != null) {
                Map<String, String> fundMap = JSON.parseObject(fundSchemePO.getFundPaymentBaseString(), new HashMap<String, String>().getClass());
                fundMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });

            }
            if (otherSchemePO != null) {
                Map<String, String> otherMap = JSON.parseObject(otherSchemePO.getOtherPaymentBaseString(), new HashMap<String, String>().getClass());
                otherMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });
            }
            return resultList;
        }
        if (projects.contains(ProjectTypeEnum.SOCIAL.getValue())) {
            if (socialSchemePO != null) {
                Map<String, String> socialMap = JSON.parseObject(socialSchemePO.getSocialPaymentBaseString(), new HashMap<String, String>().getClass());

                socialMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });

            }
        }
        if ((!projects.contains(ProjectTypeEnum.SOCIAL.getValue()))
                && (projects.contains(ProjectTypeEnum.ENDOWMENT_INSURANCE.getValue()))
                && (projects.contains(ProjectTypeEnum.MEDICAL_INSURANCE.getValue()))) {
            if (socialSchemePO != null) {
                Map<String, String> socialMap = JSON.parseObject(socialSchemePO.getSocialPaymentBaseString(), new HashMap<String, String>().getClass());
                socialMap = socialMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()) || "9002".equals(e.getKey()))
                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
                socialMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });

            }
        }
        if ((!projects.contains(ProjectTypeEnum.SOCIAL.getValue()))
                && (projects.contains(ProjectTypeEnum.ENDOWMENT_INSURANCE.getValue()))
                && (!projects.contains(ProjectTypeEnum.MEDICAL_INSURANCE.getValue()))) {
            if (socialSchemePO != null) {
                Map<String, String> socialMap = JSON.parseObject(socialSchemePO.getSocialPaymentBaseString(), new HashMap<String, String>().getClass());
                socialMap = socialMap.entrySet().stream().filter(e -> "9001".equals(e.getKey()))
                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));

                socialMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });

            }
        }
        if ((!projects.contains(ProjectTypeEnum.SOCIAL.getValue()))
                && (!projects.contains(ProjectTypeEnum.ENDOWMENT_INSURANCE.getValue()))
                && (projects.contains(ProjectTypeEnum.MEDICAL_INSURANCE.getValue()))) {
            if (socialSchemePO != null) {
                Map<String, String> socialMap = JSON.parseObject(socialSchemePO.getSocialPaymentBaseString(), new HashMap<String, String>().getClass());
                socialMap = socialMap.entrySet().stream().filter(e -> "9002".equals(e.getKey()))
                        .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
                socialMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });

            }
        }
        if (projects.contains(ProjectTypeEnum.FUND.getValue())) {
            if (fundSchemePO != null) {
                Map<String, String> fundMap = JSON.parseObject(fundSchemePO.getFundPaymentBaseString(), new HashMap<String, String>().getClass());

                fundMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });

            }
        }
        if (projects.contains(ProjectTypeEnum.OTHER.getValue())) {
            if (otherSchemePO != null) {
                Map<String, String> otherMap = JSON.parseObject(otherSchemePO.getOtherPaymentBaseString(), new HashMap<String, String>().getClass());

                otherMap.forEach((k, v) -> {
                    Map<String, String> perMap = new HashMap<>();
                    Map<String, String> comMap = new HashMap<>();
                    perMap.put("insuranceId", k);
                    perMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    perMap.put("paymentScope", "个人");

                    comMap.put("insuranceId", k);
                    comMap.put("insuranceName", categoryNameMap.get(Long.valueOf(k)));
                    comMap.put("paymentScope", "公司");

                    resultList.add(perMap);
                    resultList.add(comMap);
                });

            }
        }

        return resultList;
    }


}