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

package com.engine.salary.service.impl;

import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.salary.biz.SalarySobBiz;
import com.engine.salary.biz.SalarySobItemBiz;
import com.engine.salary.entity.salaryitem.po.SalaryItemPO;
import com.engine.salary.entity.salarysob.bo.SalarySobItemAggregateBO;
import com.engine.salary.entity.salarysob.bo.SalarySobItemSaveBO;
import com.engine.salary.entity.salarysob.dto.SalarySobItemAggregateDTO;
import com.engine.salary.entity.salarysob.param.SalarySobItemSaveParam;
import com.engine.salary.entity.salarysob.po.SalarySobEmpFieldPO;
import com.engine.salary.entity.salarysob.po.SalarySobItemGroupPO;
import com.engine.salary.entity.salarysob.po.SalarySobItemPO;
import com.engine.salary.entity.salarysob.po.SalarySobPO;
import com.engine.salary.exception.SalaryRunTimeException;
import com.engine.salary.service.*;
import com.engine.salary.util.SalaryEntityUtil;
import com.engine.salary.util.SalaryI18nUtil;
import com.weaver.excel.formula.api.entity.ExpressFormula;
import org.apache.commons.collections4.CollectionUtils;
import weaver.hrm.User;

import java.util.*;

/**
 * 薪资账套的薪资项目副本
 * <p>Copyright: Copyright (c) 2022</p>
 * <p>Company: 泛微软件</p>
 *
 * @author qiantao
 * @version 1.0
 **/
public class SalarySobItemServiceImpl extends Service implements SalarySobItemService {

    private SalarySobItemBiz salarySobItemMapper = new SalarySobItemBiz();
    private SalarySobBiz salarySobBiz = new SalarySobBiz();

    private SalarySobEmpFieldService getSalarySobEmpFieldService(User user) {
        return (SalarySobEmpFieldService) ServiceUtil.getService(SalarySobEmpFieldServiceImpl.class, user);
    }

    private SalarySobItemGroupService getSalarySobItemGroupService(User user) {
        return (SalarySobItemGroupService) ServiceUtil.getService(SalarySobItemGroupServiceImpl.class, user);
    }

    private SalaryFormulaService salaryFormulaService;
    private SalaryItemService salaryItemService;
//    private LoggerTemplate salarySobLoggerTemplate;

    @Override
    public List<SalarySobItemPO> list() {
        return salarySobItemMapper.listAll();
    }

    @Override
    public List<SalarySobItemPO> listBySalarySobId(Long salarySobId) {
        return salarySobItemMapper.listSome(SalarySobItemPO.builder().salarySobId(salarySobId).build());
    }

    @Override
    public List<SalarySobItemPO> listBySalarySobIds(Collection<Long> salarySobIds) {
        return salarySobItemMapper.listSome(SalarySobItemPO.builder().salarySobIds(salarySobIds).build());
    }

    @Override
    public List<SalarySobItemPO> listBySalarySobIdAndSalaryItemIdNotIn(Long salarySobId, Collection<Long> salaryItemIds) {
        return salarySobItemMapper.listSome(SalarySobItemPO.builder().salarySobId(salarySobId).salaryItemIds(salaryItemIds).build());
    }

    @Override
    public List<SalarySobItemPO> listBySalaryItemIds(Collection<Long> salaryItemIds) {
        if (CollectionUtils.isEmpty(salaryItemIds)) {
            return Collections.emptyList();
        }
        return salarySobItemMapper.listSome(SalarySobItemPO.builder().salaryItemIds(salaryItemIds).build());
    }

    @Override
    public List<SalaryItemPO> listBySalarySobId4SalaryItem(Long salarySobId) {
        // 查询薪资项目副本
        List<SalarySobItemPO> salarySobItemPOS = listBySalarySobId(salarySobId);
        if (CollectionUtils.isEmpty(salarySobItemPOS)) {
            return Collections.emptyList();
        }
        // 查询薪资项目
        Set<Long> salaryItemIds = SalaryEntityUtil.properties(salarySobItemPOS, SalarySobItemPO::getSalaryItemId);
        return salaryItemService.listByIds(salaryItemIds);
    }

    @Override
    public SalarySobItemAggregateDTO getAggregateBySalarySobId(Long salarySobId) {
        // 查询薪资账套
        SalarySobPO salarySobPO = salarySobBiz.getById(salarySobId);
        if (Objects.isNull(salarySobPO)) {
            throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(98379, "参数错误，薪资账套不存在或者已被删除"));
        }
        // 查询薪资账套的员工信息字段
        List<SalarySobEmpFieldPO> salarySobEmpFieldPOS = getSalarySobEmpFieldService(user).listBySalarySobId(salarySobId);
        // 查询薪资账套的薪资项目分类
        List<SalarySobItemGroupPO> salarySobItemGroupPOS = getSalarySobItemGroupService(user).listBySalarySobId(salarySobId);
        // 查询薪资账套的薪资项目副本
        List<SalarySobItemPO> salarySobItemPOS = listBySalarySobId(salarySobId);
        // 薪资账套的薪资项目副本所用的公式id
        Set<Long> formulaIds = SalaryEntityUtil.properties(salarySobItemPOS, SalarySobItemPO::getFormulaId);
        // 查询公式详情
        List<ExpressFormula> expressFormulas = salaryFormulaService.listExpressFormula(formulaIds);
        // 查询薪资账套的薪资项目副本所关联的薪资项目
        Set<Long> salaryItemIds = SalaryEntityUtil.properties(salarySobItemPOS, SalarySobItemPO::getSalaryItemId);
        List<SalaryItemPO> salaryItemPOS = salaryItemService.listByIds(salaryItemIds);
        // 转换成聚合dto
        SalarySobItemAggregateBO salarySobItemAggregateBO = new SalarySobItemAggregateBO(salarySobPO, salarySobEmpFieldPOS,
                salarySobItemGroupPOS, salarySobItemPOS, expressFormulas, salaryItemPOS);
        return salarySobItemAggregateBO.convert2AggregateDTO();
    }

    @Override
    public void save(SalarySobItemSaveParam saveParam) {
        // 查询薪资账套
        SalarySobPO salarySobPO = salarySobBiz.getById(saveParam.getSalarySobId());
        if (Objects.isNull(salarySobPO)) {
            throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(98379, "参数错误，薪资账套不存在或者已被删除"));
        }
        //todo
        // 删除薪资账套的员工信息字段
        getSalarySobEmpFieldService(user).deleteBySalarySobIds(Collections.singleton(saveParam.getSalarySobId()));
        // 删除薪资账套的薪资项目副本
        deleteBySalarySobIds(Collections.singleton(saveParam.getSalarySobId()));
        // 删除薪资账套的薪资项目分类
        getSalarySobItemGroupService(user).deleteBySalarySobIds(Collections.singleton(saveParam.getSalarySobId()));

        // 处理保存参数
        SalarySobItemSaveBO.Result result = SalarySobItemSaveBO.handle(saveParam,(long)user.getUID());
        // 保存薪资账套的员工信息字段
        if (CollectionUtils.isNotEmpty(result.getNeedInsertSalarySobEmpFields())) {
//            getSalarySobEmpFieldService(user).batchSave(result.getNeedInsertSalarySobEmpFields());
        }

        //先保存项目分类获取分类id
        List<SalarySobItemSaveParam.SalarySobItemGroupParam> itemGroups = saveParam.getItemGroups();
//        CollectionUtils.emptyIfNull()


        // 保存薪资账套的薪资项目副本
        if (CollectionUtils.isNotEmpty(result.getNeedInsertSalarySobItems())) {
            batchSave(result.getNeedInsertSalarySobItems());
        }
        // 保存薪资账套的薪资项目分类
        if (CollectionUtils.isNotEmpty(result.getNeedInsertSalarySobItemGroups())) {
            getSalarySobItemGroupService(user).batchSave(result.getNeedInsertSalarySobItemGroups());
        }
        //todo 记录日志
//        LoggerContext<SalarySobPO> loggerContext = new LoggerContext<>();
//        loggerContext.setTargetId("" + salarySobPO.getId());
//        loggerContext.setTargetName(salarySobPO.getName());
//        loggerContext.setOperateType(OperateTypeEnum.UPDATE.getValue());
//        loggerContext.setOperateTypeName(SalaryI18nUtil.getI18nLabel(98613, "编辑薪资账套薪资项目"));
//        loggerContext.setOperatedesc(SalaryI18nUtil.getI18nLabel(98613, "编辑薪资账套薪资项目"));
//        salarySobLoggerTemplate.write(loggerContext);
    }

    @Override
    public void batchSave(Collection<SalarySobItemPO> salarySobItemPOS) {
        salarySobItemMapper.batchInsert(salarySobItemPOS);
    }

    @Override
    public void deleteBySalarySobIds(Collection<Long> salarySobIds) {
        salarySobItemMapper.deleteBySalarySobIds(salarySobIds);
    }
}