package com.engine.salary.service.impl;

import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.StrUtil;
import com.cloudstore.eccom.pc.table.WeaTableColumn;
import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.hrmelog.entity.dto.LoggerContext;
import com.engine.salary.component.SalaryWeaTable;
import com.engine.salary.config.SalaryElogConfig;
import com.engine.salary.constant.SalaryDefaultTenantConstant;
import com.engine.salary.encrypt.EncryptUtil;
import com.engine.salary.entity.datacollection.DataCollectionEmployee;
import com.engine.salary.entity.employeedeclare.po.EmployeeDeclarePO;
import com.engine.salary.entity.extemp.po.ExtEmpPO;
import com.engine.salary.entity.salaryarchive.dto.SalaryArchiveListDTO;
import com.engine.salary.entity.taxagent.po.TaxAgentPO;
import com.engine.salary.entity.taxdeclaration.bo.TaxDeclarationValueList;
import com.engine.salary.entity.taxdeclaration.dto.ContrastListDTO;
import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationValueListDTO;
import com.engine.salary.entity.taxdeclaration.param.ContrastQueryParam;
import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationValueListQueryParam;
import com.engine.salary.entity.taxdeclaration.param.TaxDeclareRecordDetailSaveParam;
import com.engine.salary.entity.taxdeclaration.po.*;
import com.engine.salary.enums.OperateTypeEnum;
import com.engine.salary.enums.salaryaccounting.EmployeeTypeEnum;
import com.engine.salary.enums.salaryitem.SalaryDataTypeEnum;
import com.engine.salary.enums.salarysob.DeclareReportTypeEnum;
import com.engine.salary.enums.salarysob.IncomeCategoryEnum;
import com.engine.salary.enums.sicategory.DeleteTypeEnum;
import com.engine.salary.enums.taxdeclaration.SourceEnum;
import com.engine.salary.exception.SalaryRunTimeException;
import com.engine.salary.mapper.taxdeclaration.TaxDeclarationValueMapper;
import com.engine.salary.mapper.taxdeclaration.TaxDeclareRecordMapper;
import com.engine.salary.remote.tax.client.DeclareClient;
import com.engine.salary.remote.tax.response.declare.GetDeclareTaxResultFeedbackResponse;
import com.engine.salary.service.*;
import com.engine.salary.util.*;
import com.engine.salary.util.db.IdGenerator;
import com.engine.salary.util.db.MapperProxyFactory;
import com.engine.salary.util.excel.ExcelUtilPlus;
import com.engine.salary.util.page.PageInfo;
import com.engine.salary.util.page.SalaryPageUtil;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.wbi.core.entity.WeaResultMsg;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.beans.BeanUtils;
import weaver.general.Util;
import weaver.hrm.User;

import java.math.BigDecimal;
import java.util.*;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.stream.Collectors;

/**
 * 个税申报表
 * <p>Copyright: Copyright (c) 2023</p>
 * <p>Company: 泛微软件</p>
 *
 * @author qiantao
 * @version 1.0
 **/
@Slf4j
public class TaxDeclarationValueServiceImpl extends Service implements TaxDeclarationValueService {
    public EncryptUtil encryptUtil = new EncryptUtil();

    private TaxDeclarationValueMapper getTaxDeclarationValueMapper() {
        return MapperProxyFactory.getProxy(TaxDeclarationValueMapper.class);
    }

    private TaxDeclareRecordMapper getTaxDeclareRecordMapper() {
        return MapperProxyFactory.getProxy(TaxDeclareRecordMapper.class);
    }

    private TaxDeclareStatusService getTaxDeclareStatusService(User user) {
        return ServiceUtil.getService(TaxDeclareStatusServiceImpl.class, user);
    }


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

    private ExtEmpService getExtEmpService(User user) {
        return ServiceUtil.getService(ExtEmpServiceImpl.class, user);
    }

    private EmployeeDeclareService getEmployeeDeclareService(User user) {
        return ServiceUtil.getService(EmployeeDeclareServiceImpl.class, user);
    }

    private TaxReportColumnService getTaxReportColumnService(User user) {
        return ServiceUtil.getService(TaxReportColumnServiceImpl.class, user);
    }

    private TaxDeclarationService getTaxDeclarationService(User user) {
        return ServiceUtil.getService(TaxDeclarationServiceImpl.class, user);
    }

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

    @Override
    public PageInfo<TaxDeclarationValuePO> listPageByTaxDeclarationIds(TaxDeclarationValueListQueryParam queryParam, Collection<Long> taxDeclarationIds, String keyword) {
        List<TaxDeclarationValuePO> taxDeclarationValuePOS = getTaxDeclarationValueMapper().listSome(TaxDeclarationValuePO.builder().taxDeclarationIds(taxDeclarationIds).build());
        // 根据关键词查人员信息
        if (StringUtils.isNotBlank(keyword)) {
            List<DataCollectionEmployee> employeeList = getSalaryEmployeeService(user).listByKeyword(keyword);
            List<Long> empIds = employeeList.stream().map(DataCollectionEmployee::getEmployeeId).collect(Collectors.toList());
            taxDeclarationValuePOS = taxDeclarationValuePOS.stream().filter(po -> empIds.contains(po.getEmployeeId())).collect(Collectors.toList());
        }
        taxDeclarationValuePOS = decryptBatch(taxDeclarationValuePOS);
        return SalaryPageUtil.buildPage(queryParam.getCurrent(), queryParam.getPageSize(), taxDeclarationValuePOS, TaxDeclarationValuePO.class);
    }

    @Override
    public List<TaxDeclarationValuePO> listByTaxDeclarationIds(Collection<Long> taxDeclarationIds) {
        List<TaxDeclarationValuePO> taxDeclarationValues = getTaxDeclarationValueMapper().listSome(TaxDeclarationValuePO.builder().taxDeclarationIds(taxDeclarationIds).build());
        return decryptBatch(taxDeclarationValues);
    }

    @Override
    public List<TaxDeclarationValuePO> listByTaxDeclarationId(Long taxDeclarationId) {
        List<TaxDeclarationValuePO> taxDeclarationValues = getTaxDeclarationValueMapper().listSome(TaxDeclarationValuePO.builder().taxDeclarationId(taxDeclarationId).build());
        return decryptBatch(taxDeclarationValues);
    }

    @Override
    public List<TaxDeclarationValuePO> listByTaxDeclarationIdsNoDecrypt(Collection<Long> taxDeclarationIds) {
        return getTaxDeclarationValueMapper().listSome(TaxDeclarationValuePO.builder().taxDeclarationIds(taxDeclarationIds).build());
    }

    @Override
    public TaxDeclarationValueListDTO convert2List(TaxDeclarationPO taxDeclaration, List<TaxDeclarationValuePO> taxDeclarationValues) {
        // 查询个税申报表表头
        IncomeCategoryEnum incomeCategoryEnum = SalaryEnumUtil.enumMatchByValue(taxDeclaration.getIncomeCategory(), IncomeCategoryEnum.class);
        List<TaxReportColumnPO> taxReportColumns = getTaxReportColumnService(user).listByIncomeCategory(incomeCategoryEnum, 0);
        // 人员id
        Set<Long> employeeIds = SalaryEntityUtil.properties(taxDeclarationValues, TaxDeclarationValuePO::getEmployeeId);
        // 查询报送的人员
        List<EmployeeDeclarePO> employeeDeclares = getEmployeeDeclareService(user).listByTaxCycleAndTaxAgentIdAndEmployeeIds(taxDeclaration.getTaxCycle(), taxDeclaration.getTaxAgentId(), employeeIds);
        // 查询人员信息
        List<Long> simpleEmployeeIds = taxDeclarationValues.stream().filter(taxDeclarationValue -> taxDeclarationValue.getEmployeeType() == null || Objects.equals(taxDeclarationValue.getEmployeeType(), EmployeeTypeEnum.ORGANIZATION.getValue())).map(TaxDeclarationValuePO::getEmployeeId).distinct().collect(Collectors.toList());
        List<DataCollectionEmployee> simpleEmployees = getSalaryEmployeeService(user).getEmployeeByIdsAll(simpleEmployeeIds);
        // 查询外部人员
        List<Long> extEmployeeIds = taxDeclarationValues.stream().filter(taxDeclarationValue -> Objects.equals(taxDeclarationValue.getEmployeeType(), EmployeeTypeEnum.EXT_EMPLOYEE.getValue())).map(TaxDeclarationValuePO::getEmployeeId).collect(Collectors.toList());
        List<ExtEmpPO> extEmployees = getExtEmpService(user).getExtEmpByIds(extEmployeeIds);

        // 列表表头
        List<WeaTableColumn> weaTableColumns = TaxDeclarationValueList.buildTableColumns(taxReportColumns);
        // 列表数据
        List<Map<String, Object>> data = TaxDeclarationValueList.buildTableData(incomeCategoryEnum, taxReportColumns, taxDeclarationValues, employeeDeclares, simpleEmployees, extEmployees, false);

        return new TaxDeclarationValueListDTO().setColumns(weaTableColumns).setData(data);
    }

    @Override
    public void batchSave(List<TaxDeclarationValuePO> taxDeclarationValues) {
        if (CollectionUtils.isNotEmpty(taxDeclarationValues)) {
            // 加密
            taxDeclarationValues.forEach(taxDeclarationValue -> taxDeclarationValue.setResultValueJson(JsonUtil.toJsonString(taxDeclarationValue.getResultValue())));
            taxDeclarationValues = encryptUtil.encryptList(taxDeclarationValues, TaxDeclarationValuePO.class);
            // 分批保存
            List<List<TaxDeclarationValuePO>> partition = Lists.partition(taxDeclarationValues, 100);
            for (List<TaxDeclarationValuePO> subTaxDeclarationValues : partition) {
                subTaxDeclarationValues.forEach(getTaxDeclarationValueMapper()::insertIgnoreNull);
            }
        }
    }

    @Override
    public void batchEdit(List<TaxDeclarationValuePO> taxDeclarationValues) {
        if (CollectionUtils.isNotEmpty(taxDeclarationValues)) {
            // 加密
            taxDeclarationValues.forEach(taxDeclarationValue -> taxDeclarationValue.setResultValueJson(JsonUtil.toJsonString(taxDeclarationValue.getResultValue())));
            taxDeclarationValues = encryptUtil.encryptList(taxDeclarationValues, TaxDeclarationValuePO.class);
            // 分批保存
            List<List<TaxDeclarationValuePO>> partition = Lists.partition(taxDeclarationValues, 100);
            for (List<TaxDeclarationValuePO> subTaxDeclarationValues : partition) {
                subTaxDeclarationValues.forEach(getTaxDeclarationValueMapper()::updateIgnoreNull);
            }
        }
    }

    @Override
    public void save(TaxDeclareRecordDetailSaveParam param) {
        TaxDeclarationPO taxDeclaration = getTaxDeclarationService(user).getById(param.getTaxDeclarationId());
        if (taxDeclaration == null) {
            throw new SalaryRunTimeException("个税申报表不存在！");
        }

        Long taxDeclareRecordId = taxDeclaration.getTaxDeclareRecordId();
        TaxDeclareRecordPO declareRecordPO = getTaxDeclareRecordMapper().getById(taxDeclareRecordId);
        if (declareRecordPO == null) {
            throw new SalaryRunTimeException("个税申报记录不存在！");
        }

        TaxDeclarationValuePO po = TaxDeclarationValuePO.builder().id(IdGenerator.generate()).taxDeclarationId(param.getTaxDeclarationId()).taxDeclareRecordId(taxDeclareRecordId).employeeId(param.getEmployeeId()).employeeType(param.getEmployeeType()).resultValue(param.getTaxReportColumnValues()).resultValueJson(JsonUtil.toJsonString(param.getTaxReportColumnValues())).createTime(new Date()).updateTime(new Date()).source(SourceEnum.ADD.getValue()).creator((long) user.getUID()).deleteType(0).tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY).build();
        TaxDeclarationValuePO po4log = new TaxDeclarationValuePO();
        BeanUtils.copyProperties(po, po4log);
        encryptUtil.encrypt(po, TaxDeclarationValuePO.class);
        getTaxDeclarationValueMapper().insertIgnoreNull(po);

        // 记录日志
        TaxAgentPO taxAgent = getTaxAgentService(user).getById(taxDeclaration.getTaxAgentId());
        LoggerContext<TaxDeclarationPO> loggerContext = new LoggerContext<>();
        loggerContext.setUser(user);
        loggerContext.setTargetId(po.getTaxDeclareRecordId().toString());
        loggerContext.setTargetName(SalaryI18nUtil.getI18nLabel(0, "个税扣缴义务人「{0}」,税款所属期「{1}」,人员id「{3}」")
                .replace("{0}", taxAgent.getName())
                .replace("{1}", SalaryDateUtil.getFormatYearMonth(declareRecordPO.getTaxCycle()))
                .replace("{2}", po.getEmployeeId().toString()));
        loggerContext.setOperateType(OperateTypeEnum.ADD.getValue());
        loggerContext.setOperateTypeName(SalaryI18nUtil.getI18nLabel(0, "新增人员"));
        loggerContext.setOperatedesc(SalaryI18nUtil.getI18nLabel(0, "新增人员"));
        loggerContext.setNewValues(po4log);
        SalaryElogConfig.taxDeclarationLoggerTemplate.write(loggerContext);

        //新增年终奖
        if (IncomeCategoryEnum.ONETIME_ANNUAL_BONUS.getValue().equals(taxDeclaration.getIncomeCategory())) {
            autoAddWagesDeclare(declareRecordPO);
        }
    }

    @Override
    public void edit(TaxDeclareRecordDetailSaveParam param) {
        TaxDeclarationValuePO po = getById(param.getId());
        TaxDeclarationValuePO oldPo = new TaxDeclarationValuePO();
        BeanUtils.copyProperties(po, oldPo);
        po.setResultValue(param.getTaxReportColumnValues());
        po.setResultValueJson(JsonUtil.toJsonString(param.getTaxReportColumnValues()));
        po.setUpdateTime(new Date());
        po.setSource(SourceEnum.EDIT.getValue());
        encryptUtil.encrypt(po, TaxDeclarationValuePO.class);
        getTaxDeclarationValueMapper().updateIgnoreNull(po);
        TaxDeclarationValuePO po4log = getTaxDeclarationValueMapper().getById(po.getId());

        // 记录日志
        TaxDeclareRecordPO taxDeclareRecordPO = getTaxDeclareRecordMapper().getById(po.getTaxDeclareRecordId());
        TaxAgentPO taxAgent = getTaxAgentService(user).getById(taxDeclareRecordPO.getTaxAgentId());
        LoggerContext<TaxDeclarationValuePO> loggerContext = new LoggerContext<>();
        loggerContext.setUser(user);
        loggerContext.setTargetId(po.getTaxDeclareRecordId().toString());
        loggerContext.setTargetName(SalaryI18nUtil.getI18nLabel(0, "个税扣缴义务人「{0}」税款所属期「{1}」人员id「{3}」")
                .replace("{0}", taxAgent.getName())
                .replace("{1}", SalaryDateUtil.getFormatYearMonth(taxDeclareRecordPO.getTaxCycle()))
                .replace("{2}", po.getEmployeeId().toString()));
        loggerContext.setOperateType(OperateTypeEnum.UPDATE.getValue());
        loggerContext.setOperateTypeName(SalaryI18nUtil.getI18nLabel(0, "修改个税申报数据"));
        loggerContext.setOperatedesc(SalaryI18nUtil.getI18nLabel(0, "修改个税申报数据"));
        loggerContext.setOldValues(oldPo);
        loggerContext.setNewValues(po4log);
        SalaryElogConfig.taxDeclarationLoggerTemplate.write(loggerContext);
    }

    @Override
    public TaxDeclarationValuePO getById(Long id) {
        TaxDeclarationValuePO po = getTaxDeclarationValueMapper().getById(id);
        if (po == null) {
            throw new SalaryRunTimeException("个税申报明细不存在！");
        }
        encryptUtil.decrypt(po, TaxDeclarationValuePO.class);
        po.setResultValue(JsonUtil.parseMap(po.getResultValueJson(), String.class));

        return po;
    }

    @Override
    public void deleteByTaxDeclareRecordIds(Collection<Long> taxDeclareRecordIds) {
        if (CollectionUtils.isEmpty(taxDeclareRecordIds)) {
            return;
        }
        getTaxDeclarationValueMapper().deleteBytaxDeclareRecordIds(taxDeclareRecordIds);
    }

    private List<TaxDeclarationValuePO> decryptBatch(List<TaxDeclarationValuePO> taxDeclarationValues) {
        if (CollectionUtils.isEmpty(taxDeclarationValues)) {
            return Collections.emptyList();
        }
        // 解密
        taxDeclarationValues = encryptUtil.decryptList(taxDeclarationValues, TaxDeclarationValuePO.class);
        taxDeclarationValues.forEach(salaryAcctResultValue -> {
            salaryAcctResultValue.setResultValue(JsonUtil.parseMap(salaryAcctResultValue.getResultValueJson(), String.class));
        });
        return taxDeclarationValues;
    }


    @Override
    public void autoAddWagesDeclare(TaxDeclareRecordPO taxDeclareRecord) {

        Long taxDeclareRecordId = taxDeclareRecord.getId();
        Date now = new Date();

        //非正常薪资的人员
        List<Long> notWagesEmpIds = getTaxDeclarationValueMapper().queryNotWagesEmpIds(taxDeclareRecordId);
        if (CollectionUtils.isEmpty(notWagesEmpIds)) {
            return;
        }

        //正常薪资人员
        List<Long> wagesEmpIds = getTaxDeclarationValueMapper().queryWagesEmpIds(taxDeclareRecordId);

        //比较差异
        List<Long> autoAddIds = notWagesEmpIds.stream().filter(id -> !wagesEmpIds.contains(id)).collect(Collectors.toList());
        if (CollectionUtils.isEmpty(autoAddIds)) {
            return;
        }

        //正常薪资的表头
        List<TaxReportColumnPO> taxReportColumns = getTaxReportColumnService(user).listByIncomeCategory(IncomeCategoryEnum.WAGES_AND_SALARIES, 0);
        Map<String, String> valueMap = Maps.newHashMap();
        for (TaxReportColumnPO taxReportColumn : taxReportColumns) {
            String value = Objects.equals(taxReportColumn.getDataType(), SalaryDataTypeEnum.NUMBER.getValue()) ? "0.00" : "";
            valueMap.put(taxReportColumn.getReportColumnDataIndex(), value);
        }

        //当前申报表是否含正常申报
        List<TaxDeclarationPO> list = getTaxDeclarationService(user).listByTaxDeclareRecordId(taxDeclareRecordId, IncomeCategoryEnum.WAGES_AND_SALARIES.getValue());
        TaxDeclarationPO taxDeclarationPO;
        if (CollectionUtils.isNotEmpty(list)) {
            if (list.size() > 1) {
                throw new SalaryRunTimeException("存在多条正常工资薪金申报表数据");
            }
            taxDeclarationPO = list.get(0);
        } else {
            taxDeclarationPO = TaxDeclarationPO.builder().id(IdGenerator.generate()).taxDeclareRecordId(taxDeclareRecordId).incomeCategory(IncomeCategoryEnum.WAGES_AND_SALARIES.getValue()).taxAgentId(taxDeclareRecord.getTaxAgentId()).salaryMonth(taxDeclareRecord.getSalaryMonth()).taxCycle(taxDeclareRecord.getTaxCycle()).description(taxDeclareRecord.getRemark()).controlView(0).creator((long) user.getUID()).createTime(now).updateTime(now).deleteType(DeleteTypeEnum.NOT_DELETED.getValue()).tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY).build();
            List<TaxDeclarationPO> taxList = new ArrayList<>();
            getTaxDeclarationService(user).saveBatch(taxList);
        }

        //组装数据，自动补足
        List<TaxDeclarationValuePO> autoAddValuePOs = autoAddIds.stream().map((empId -> {
            TaxDeclarationValuePO taxDeclarationValue = TaxDeclarationValuePO.builder().id(IdGenerator.generate()).taxDeclareRecordId(taxDeclarationPO.getTaxDeclareRecordId()).taxDeclarationId(taxDeclarationPO.getId()).employeeType(0).employeeId(empId).resultValue(valueMap).tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY).creator((long) user.getUID()).deleteType(DeleteTypeEnum.NOT_DELETED.getValue()).createTime(now).updateTime(now).source(SourceEnum.AUTO.getValue()).build();
            return taxDeclarationValue;
        })).collect(Collectors.toList());
        batchSave(autoAddValuePOs);
    }


    @Override
    public Map<String, Object> contrast(ContrastQueryParam param) {

        TaxDeclarationPO taxDeclaration = getTaxDeclarationService(user).getById(param.getTaxDeclarationId());
        if (taxDeclaration == null) {
            throw new SalaryRunTimeException("无申报表");
        }

        TaxDeclareRecordPO taxDeclareRecordPO = getTaxDeclareRecordMapper().getById(taxDeclaration.getTaxDeclareRecordId());
        if (taxDeclareRecordPO == null) {
            throw new SalaryRunTimeException("申报记录不存在！");
        }

        Integer reportType = IncomeCategoryEnum.parseByValue(taxDeclaration.getIncomeCategory()).getReportType().getValue();
        TaxDeclareStatusPO taxDeclareStatus = getTaxDeclareStatusService(user).getTaxDeclareStatus(taxDeclareRecordPO.getId(), reportType);

        //线上数据
        DeclareClient declareClient = new DeclareClient(taxDeclareRecordPO.getTaxAgentId());
        GetDeclareTaxResultFeedbackResponse declareTaxResultFeedbackResponse = declareClient.getDeclareTaxResultFeedback(taxDeclareStatus.getDeclareRequestId());

        Map<String, List<List<Object>>> onlineDataMap = new HashMap<>();
        List<TaxDeclarationPO> list = getTaxDeclarationService(user).listByTaxDeclareRecordId(taxDeclareRecordPO.getId());
        list.stream()
                .map(TaxDeclarationPO::getIncomeCategory)
                .map(IncomeCategoryEnum::parseByValue)
                .filter(Objects::nonNull)
                .filter(e -> e.getReportType() == DeclareReportTypeEnum.parseByValue(reportType))
                .forEach(e -> e.parseGetDeclareTaxResultFeedbackResponse(onlineDataMap, declareTaxResultFeedbackResponse));

        Map<String, Object> resultList = new HashMap<>();
        List<TaxDeclarationValuePO> taxDeclarationValues = listByTaxDeclarationId(taxDeclaration.getId());

        // 查询个税申报表表头
        IncomeCategoryEnum incomeCategoryEnum = SalaryEnumUtil.enumMatchByValue(taxDeclaration.getIncomeCategory(), IncomeCategoryEnum.class);
        List<TaxReportColumnPO> taxReportColumns = getTaxReportColumnService(user).listByIncomeCategory(incomeCategoryEnum);
        List<String> columns = SalaryEntityUtil.properties(taxReportColumns, TaxReportColumnPO::getReportColumnName, Collectors.toList());
        // 人员id
        Set<Long> employeeIds = SalaryEntityUtil.properties(taxDeclarationValues, TaxDeclarationValuePO::getEmployeeId);
        // 查询报送的人员
        List<EmployeeDeclarePO> employeeDeclares = getEmployeeDeclareService(user).listByTaxCycleAndTaxAgentIdAndEmployeeIds(taxDeclaration.getTaxCycle(), taxDeclaration.getTaxAgentId(), employeeIds);
        // 查询人员信息
        List<Long> simpleEmployeeIds = taxDeclarationValues.stream().filter(taxDeclarationValue -> taxDeclarationValue.getEmployeeType() == null || Objects.equals(taxDeclarationValue.getEmployeeType(), EmployeeTypeEnum.ORGANIZATION.getValue())).map(TaxDeclarationValuePO::getEmployeeId).distinct().collect(Collectors.toList());
        List<DataCollectionEmployee> simpleEmployees = getSalaryEmployeeService(user).getEmployeeByIdsAll(simpleEmployeeIds);
        // 查询外部人员
        List<Long> extEmployeeIds = taxDeclarationValues.stream().filter(taxDeclarationValue -> Objects.equals(taxDeclarationValue.getEmployeeType(), EmployeeTypeEnum.EXT_EMPLOYEE.getValue())).map(TaxDeclarationValuePO::getEmployeeId).collect(Collectors.toList());
        List<ExtEmpPO> extEmployees = getExtEmpService(user).getExtEmpByIds(extEmployeeIds);

        // 列表数据
        List<Map<String, Object>> localList = TaxDeclarationValueList.buildTableData(incomeCategoryEnum, taxReportColumns, taxDeclarationValues, employeeDeclares, simpleEmployees, extEmployees, true);


        Map<String, Map<String, Object>> localMap = new HashMap<>();
        for (Map<String, Object> map : localList) {
            String no = map.getOrDefault("证件号码", "").toString();
            localMap.put(no, map);
        }

        List<List<Object>> onlineData = onlineDataMap.get(incomeCategoryEnum.getDefaultLabel());
        List<Object> heads = onlineData.get(0);
        List<List<Object>> data = onlineData.subList(1, onlineData.size());
        List<Map<String, Object>> onlineMap = new ArrayList<>();
        for (int i = 0; i < data.size(); i++) {
            List<Object> row = data.get(i);
            Map<String, Object> m = new HashMap<>();
            for (int j = 0; j < heads.size(); j++) {
                String key = heads.get(j).toString();
                m.put(key, row.get(j));
            }
            onlineMap.add(m);
        }

        Map<String, Map<String, Object>> onlineNoMap = new HashMap<>();
        for (Map<String, Object> map : onlineMap) {
            String no = map.getOrDefault("证件号码", "").toString();
            onlineNoMap.put(no, map);
        }

        List<String> onlyShowColumns = new ArrayList<>();
        List<Map<String, Object>> oneResultList = new ArrayList<>();
        for (Map<String, Object> local : localList) {
            AtomicBoolean hasDiff = new AtomicBoolean(false);
            Map<String, Object> result = new HashMap<>();
            result.put("工号", local.get("工号"));
            result.put("姓名", local.get("姓名"));
            result.put("证件类型", local.get("证件类型"));
            result.put("证件号码", local.get("证件号码"));
            String no = local.getOrDefault("证件号码", "").toString();
            Map<String, Object> online = onlineNoMap.get(no);
            if (online == null) {
                log.warn("线上没有该条数据，请检查！证件号码：{}", no);
                continue;
            }

            taxReportColumns.stream().map(TaxReportColumnPO::getReportColumnName).forEach(col -> {
                ContrastListDTO dto = new ContrastListDTO();
                // 系统值
                String localValue = Util.null2String(local.get(col));
                // 线上值
                String onlineValue = Util.null2String(online.get(col));
                dto.setLocal(localValue);
                dto.setOnline(onlineValue);
                if (NumberUtil.isNumber(localValue) && NumberUtil.isNumber(onlineValue)) {
                    BigDecimal diff = new BigDecimal(localValue).subtract(new BigDecimal(onlineValue));
                    if (diff.compareTo(new BigDecimal(0)) != 0) {
                        dto.setDiff(diff);
                        onlyShowColumns.add(col);
                        hasDiff.set(true);
                    }
                } else if ((StrUtil.isBlank(localValue) && ("0.00".equals(onlineValue) || "0".equals(onlineValue))) || (StrUtil.isBlank(onlineValue) && ("0.00".equals(localValue) || "0".equals(localValue)))) {
                    //短路
                } else {
                    if (!Objects.equals(localValue, onlineValue)) {
                        dto.setDiff(localValue);
                        onlyShowColumns.add(col);
                        hasDiff.set(true);
                    }
                }
                result.put(col, dto);
            });
            if (param.isOnlyShowDiffEmp()) {
                if (hasDiff.get()) {
                    oneResultList.add(result);
                }
            } else {
                oneResultList.add(result);
            }
        }

        List<String> finalOnlyShowColumns = onlyShowColumns.stream().distinct().collect(Collectors.toList());
        List<String> headerList = new ArrayList<>();
        headerList.add("工号");
        headerList.add("姓名");
        headerList.add("证件类型");
        headerList.add("证件号码");
        headerList.addAll((param.isOnlyShowDiffItem() ? finalOnlyShowColumns : columns).stream().collect(Collectors.toList()));
        resultList.put("columns", headerList);
        resultList.put("pageInfo", SalaryPageUtil.buildPage(param.getCurrent(), param.getPageSize(), oneResultList));

        // 显示定制列
        List<WeaTableColumn> weaColumns = new ArrayList<>();
        weaColumns.add(new WeaTableColumn("100px", SalaryI18nUtil.getI18nLabel(0, "工号"), "工号"));
        weaColumns.add(new WeaTableColumn("100px", SalaryI18nUtil.getI18nLabel(0, "姓名"), "姓名"));
        weaColumns.add(new WeaTableColumn("100px", SalaryI18nUtil.getI18nLabel(0, "证件类型"), "证件类型"));
        weaColumns.add(new WeaTableColumn("100px", SalaryI18nUtil.getI18nLabel(0, "证件号码"), "证件号码"));
        for (TaxReportColumnPO columnPO : taxReportColumns) {
            weaColumns.add(new WeaTableColumn("100px", columnPO.getReportColumnName(), columnPO.getReportColumnName()));
        }

        SalaryWeaTable<SalaryArchiveListDTO> table = new SalaryWeaTable<SalaryArchiveListDTO>(user, TaxDeclarationValueListDTO.class);
        table.setColumns(weaColumns);
        WeaResultMsg result = new WeaResultMsg(false);
        result.putAll(table.makeDataResult());
        result.success();

        resultList.put("dataKey", result.getResultMap());
        return resultList;

    }

    @Override
    public XSSFWorkbook exportContrast(ContrastQueryParam param) {
        param.setPageSize(1000000000);
        param.setCurrent(1);
        // 获取线下对比结果
        Map<String, Object> contrastMap = contrast(param);
        List<String> header = ((List<String>) contrastMap.get("columns"));
        PageInfo<Map<String, Object>> pageInfo = (PageInfo<Map<String, Object>>) contrastMap.get("pageInfo");
        List<Map<String, Object>> list = pageInfo.getList();

        List<WeaTableColumn> empInfoColumns = new ArrayList<>();
        empInfoColumns.add(new WeaTableColumn("100px", "工号", "jobNum"));
        empInfoColumns.add(new WeaTableColumn("100px", "姓名", "username"));
        empInfoColumns.add(new WeaTableColumn("100px", "证件类型", "cardType"));
        empInfoColumns.add(new WeaTableColumn("100px", "证件号码", "cardNum"));

        List<String> empInfoList = empInfoColumns.stream().map(WeaTableColumn::getText).collect(Collectors.toList());
        header = header.stream().filter(h -> !empInfoList.contains(h)).collect(Collectors.toList());
        if (CollectionUtils.isNotEmpty(param.getColumns())) {
            List<String> finalHeader = header;
            header = param.getColumns().stream().filter(col -> finalHeader.contains(col)).collect(Collectors.toList());
        }

        return ExcelUtilPlus.genWorkbook4TaxDeclareContrast(empInfoColumns, header, list, "在线对比结果");

    }

    @Override
    public void deleteById(Long deleteId) {
        getTaxDeclarationValueMapper().deleteByIds(Collections.singletonList(deleteId));
    }
}