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

package com.engine.salary.service.impl;

import com.cloudstore.eccom.pc.table.WeaTableColumn;
import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.salary.biz.SIArchivesBiz;
import com.engine.salary.cmd.siarchives.SIArchivesTipsCmd;
import com.engine.salary.entity.siarchives.param.InsuranceArchivesListParam;
import com.engine.salary.entity.siarchives.param.InsuranceArchivesSaveParam;
import com.engine.salary.entity.siarchives.po.InsuranceArchivesEmployeePO;
import com.engine.salary.entity.taxagent.dto.TaxAgentEmployeeDTO;
import com.engine.salary.entity.taxagent.po.TaxAgentPO;
import com.engine.salary.enums.sicategory.WelfareTypeEnum;
import com.engine.salary.mapper.siarchives.SocialSchemeMapper;
import com.engine.salary.service.SIArchivesService;
import com.engine.salary.service.TaxAgentService;
import com.engine.salary.util.SalaryEntityUtil;
import com.engine.salary.util.SalaryI18nUtil;
import com.engine.salary.util.db.MapperProxyFactory;
import com.engine.salary.util.excel.ExcelUtil;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import weaver.general.Util;
import weaver.hrm.User;

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

/**
 * @Author weaver_cl
 * @Description: TODO
 * @Date 2022/3/11
 * @Version V1.0
 **/
public class SIArchivesServiceImpl extends Service implements SIArchivesService {

    private SIArchivesBiz siArchivesBiz = new SIArchivesBiz();

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


    @Override
    public Map<String, Object> getTips(Map<String, Object> params) {
        return commandExecutor.execute(new SIArchivesTipsCmd(params, user));
    }

    @Override
    public Map<String, Object> getBaseForm(Map<String, Object> params) {
        long currentEmployeeId = user.getUID();
        Boolean needAuth = getTaxAgentService(user).isNeedAuth(currentEmployeeId);
        Collection<TaxAgentPO> taxAgentPOS = getTaxAgentService(user).listAllTaxAgentsAsAdmin(currentEmployeeId);

        Map<String, Object> apidatas = new HashMap<>(16);
        SIArchivesBiz siArchivesBiz = new SIArchivesBiz();
        siArchivesBiz.setNeedAuth(needAuth);
        siArchivesBiz.setTaxAgentPOS(taxAgentPOS);
        WelfareTypeEnum welfareTypeEnum = (WelfareTypeEnum) params.get("welfareTypeEnum");
        Long employeeId = Long.valueOf(Util.null2String(params.get("employeeId")));
        apidatas = siArchivesBiz.getBaseForm(welfareTypeEnum, employeeId, (long) user.getUID(), user);
        return apidatas;
    }

    @Override
    public Map<String, Object> getPaymentForm(Map<String, Object> params) {
        Map<String, Object> apidatas = new HashMap<>(16);
        SIArchivesBiz siArchivesBiz = new SIArchivesBiz();
        WelfareTypeEnum welfareTypeEnum = (WelfareTypeEnum) params.get("welfareTypeEnum");
        Long employeeId = Long.valueOf(Util.null2String(params.get("employeeId")));
        Long schemeId = Long.valueOf(Util.null2String(params.get("schemeId")));
        apidatas = siArchivesBiz.getPaymentForm(user, welfareTypeEnum, employeeId, (long) user.getUID(), schemeId);
        return apidatas;
    }


    @Override
    public String insert(InsuranceArchivesSaveParam param) {
        SIArchivesBiz siArchivesBiz = new SIArchivesBiz();
        siArchivesBiz.insert(param, (long) user.getUID());
        return null;
    }

    @Override
    public Map<String, Object> listPage(InsuranceArchivesListParam param) {
        long currentEmployeeId = user.getUID();

        Boolean needAuth = getTaxAgentService(user).isNeedAuth(currentEmployeeId);
        param.setNeedAuth(needAuth);
        if (needAuth) {
            List<TaxAgentEmployeeDTO> taxAgentEmployeeDTOS = getTaxAgentService(user).listTaxAgentAndEmployee(currentEmployeeId);
            Set<Long> employeeIds = SalaryEntityUtil.properties(taxAgentEmployeeDTOS, TaxAgentEmployeeDTO::getEmployeeId);
            param.setTaxAgentEmployeeIds(employeeIds);
        }

        Map<String, Object> apidatas = new HashMap<>(16);
        SIArchivesBiz siArchivesBiz = new SIArchivesBiz();
        apidatas = siArchivesBiz.listPage(param, (long) user.getUID());
        return apidatas;
    }

    @Override
    public Map<String, Object> getSearchCondition(Map<String, Object> param) {
        Map<String, Object> apidatas = new HashMap<>(16);
        SIArchivesBiz siArchivesBiz = new SIArchivesBiz();
        apidatas = siArchivesBiz.getSearchCondition(user);
        return apidatas;
    }

    @Override
    public XSSFWorkbook export(InsuranceArchivesListParam param) {
        InsuranceArchivesListParam request = InsuranceArchivesListParam.builder().build();
        if (param.getHireDate() != null && param.getHireDate().length == 2) {
            param.setHiredateStart(param.getHireDate()[0]);
            param.setHiredateEnd(param.getHireDate()[1]);
        }
        if (param.getDimissionDate() != null && param.getDimissionDate().length == 2) {
            param.setDimissionDateStart(param.getDimissionDate()[0]);
            param.setDimissionDateEnd(param.getDimissionDate()[1]);
        }
        if (Objects.equals("fromQuickSearch", param.getDataSource())) {
            request.setStatuses(param.getStatuses());
            request.setKeyword(param.getUserName());
        } else {
            request = param;
        }
        request.setPageSize(null);
        request.setStartNum(null);
        List<InsuranceArchivesEmployeePO> insuranceArchivesEmployeePOS = listPageEmployeePOS(request);
        if (insuranceArchivesEmployeePOS == null) {
            insuranceArchivesEmployeePOS = new ArrayList<>();
        }
        List<Map<String, Object>> records = siArchivesBiz.buildTableData(insuranceArchivesEmployeePOS);
        List<WeaTableColumn> columns = siArchivesBiz.buildWeaTableColumns(insuranceArchivesEmployeePOS, user.getUID());

        //工作簿list
        List<List<Object>> excelSheetData = new ArrayList<>();

        //工作簿名称
        String sheetName = SalaryI18nUtil.getI18nLabel(85368, "社保福利档案");        //表头
        //表头
        excelSheetData.add(Arrays.asList(columns.stream().map(WeaTableColumn::getText).toArray(String[]::new)));
        //工作簿数据
        List<List<Object>> rows = new LinkedList<>();
        for (Map<String, Object> recordData : records) {
            List<Object> row = new LinkedList<>();
            for (WeaTableColumn column : columns) {
                row.add(recordData.get(column.getColumn()));
            }
            rows.add(row);
        }
        excelSheetData.addAll(rows);
        return ExcelUtil.genWorkbookV2(excelSheetData, sheetName);

    }

    @Override
    public List<InsuranceArchivesEmployeePO> listPageEmployeePOS(InsuranceArchivesListParam param) {
        long currentEmployeeId = user.getUID();
        Boolean needAuth = getTaxAgentService(user).isNeedAuth(currentEmployeeId);
        if (needAuth) {
            List<TaxAgentEmployeeDTO> taxAgentEmployeeDTOS = getTaxAgentService(user).listTaxAgentAndEmployee(currentEmployeeId);
            Set<Long> employeeIds = SalaryEntityUtil.properties(taxAgentEmployeeDTOS, TaxAgentEmployeeDTO::getEmployeeId);
            List<InsuranceArchivesEmployeePO> list = MapperProxyFactory.getProxy(SocialSchemeMapper.class).queryEmployeeList(param);
            return list.stream().filter(f -> employeeIds.contains(f.getEmployeeId())).collect(Collectors.toList());
        }

        return MapperProxyFactory.getProxy(SocialSchemeMapper.class).queryEmployeeList(param);
    }


}