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

package com.engine.salary.report.service.impl;

import com.alibaba.fastjson.JSON;
import com.engine.core.impl.Service;
import com.engine.salary.constant.SalaryDefaultTenantConstant;
import com.engine.salary.enums.sicategory.DeleteTypeEnum;
import com.engine.salary.exception.SalaryRunTimeException;
import com.engine.salary.mapper.report.SalaryStatisticsItemMapper;
import com.engine.salary.report.entity.param.SalaryStatisticsItemSaveParam;
import com.engine.salary.report.entity.po.SalaryStatisticsItemPO;
import com.engine.salary.report.enums.UnitTypeEnum;
import com.engine.salary.report.service.SalaryStatisticsItemService;
import com.engine.salary.util.SalaryAssert;
import com.engine.salary.util.SalaryI18nUtil;
import com.engine.salary.util.db.MapperProxyFactory;
import dm.jdbc.util.IdGenerator;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang.StringUtils;

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

/**
 * @Description: 薪酬报表自定义统计项目
 * @Author: wangxiangzhong
 * @Date: 2022/12/19 10:10
 */
public class SalaryStatisticsItemServiceImpl extends Service implements SalaryStatisticsItemService {


    private SalaryStatisticsItemMapper getSalaryStatisticsItemMapper() {
        return MapperProxyFactory.getProxy(SalaryStatisticsItemMapper.class);
    }

    @Override
    public SalaryStatisticsItemPO getById(Long id) {
        if (id == null) {
            return null;
        }
        return getSalaryStatisticsItemMapper().getById(id);
    }

    @Override
    public List<SalaryStatisticsItemPO> listByStatisticsReportId(Long statisticsReportId) {
        if (statisticsReportId == null) {
            return null;
        }
        return getSalaryStatisticsItemMapper().listSome(SalaryStatisticsItemPO.builder().statReportId(statisticsReportId).build());
    }

    public List<SalaryStatisticsItemPO> listByIds(Collection<Long> ids) {

        if (CollectionUtils.isEmpty(ids)) {
            return new ArrayList<>();
        }

        return getSalaryStatisticsItemMapper().listSome(SalaryStatisticsItemPO.builder().ids(ids).build());
    }

    @Override
    public String delete(Collection<Long> ids) {
        SalaryAssert.notEmpty(ids, SalaryI18nUtil.getI18nLabel(152638, "id不可为空"));
        List<SalaryStatisticsItemPO> list = this.listByIds(ids);
        if (CollectionUtils.isNotEmpty(list)) {
            getSalaryStatisticsItemMapper().deleteByIds(ids);
//            list.forEach(po -> {
//                LoggerContext<SubTablePO> loggerContext = new LoggerContext<>();
//                loggerContext.setTargetId(String.valueOf(po.getId()));
//                loggerContext.setTargetName(po.getItemName());
//                loggerContext.setOperateType(OperateTypeEnum.DELETE.getValue());
//                loggerContext.setOperateTypeName(SalaryI18nUtil.getI18nLabel(152639, "删除统计项目"));
//                loggerContext.setOperatedesc(SalaryI18nUtil.getI18nLabel(152639, "删除统计项目"));
//                salaryStatReportLoggerTemplate.write(loggerContext);
//            });
        }
        return StringUtils.EMPTY;
    }

    @Override
    public String save(SalaryStatisticsItemSaveParam saveParam) {
        // 新建
        if (Objects.isNull(saveParam.getId())) {
            if (Objects.isNull(saveParam.getStatReportId())) {
                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(163034, "统计报表id不能为空"));
            }
            if (CollectionUtils.isEmpty(saveParam.getItemValue())) {
                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(152640, "统计项目必填"));
            }
            if (StringUtils.isEmpty(saveParam.getItemName())) {
                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(152641, "统计项名称必填"));
            }

            List<SalaryStatisticsItemPO> itemPOList = listByStatisticsReportId(saveParam.getStatReportId());
            boolean isRepeat = itemPOList.stream().anyMatch(po -> saveParam.getItemName().equals(po.getItemName()));
            if (isRepeat) {
                throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(152642, "统计项目名称已经存在"));
            }

            List<Integer> indexValues = itemPOList.stream().map(SalaryStatisticsItemPO::getIndexValue).collect(Collectors.toList());
            Integer max = CollectionUtils.isEmpty(indexValues) ? 1 : Collections.max(indexValues);

            Date now = new Date();

            SalaryStatisticsItemPO subTableItemPO = SalaryStatisticsItemPO.builder()
                    .id(IdGenerator.generate())
                    .createTime(now)
                    .deleteType(DeleteTypeEnum.NOT_DELETED.getValue())
                    .itemName(saveParam.getItemName())
                    .itemValue(StringUtils.join(saveParam.getItemValue(), ","))
                    .countRule(JSON.toJSONString(saveParam.getCountRule()))
                    .sumRule(JSON.toJSONString(saveParam.getSumRule()))
                    .avgRule(JSON.toJSONString(saveParam.getAvgRule()))
                    .maxRule(JSON.toJSONString(saveParam.getMaxRule()))
                    .minRule(JSON.toJSONString(saveParam.getMinRule()))
                    .medianRule(JSON.toJSONString(saveParam.getMedianRule()))
                    .indexValue(max + 1)
                    .statReportId(saveParam.getStatReportId())
                    .unitType(saveParam.getUnitType() == null ? UnitTypeEnum.YUAN.getItem() : saveParam.getUnitType())
                    .creator((long)user.getUID())
                    .updateTime(now)
                    .tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
                    .build();
            getSalaryStatisticsItemMapper().insertIgnoreNull(subTableItemPO);

            // 记录操作日志
//            LoggerContext<SubTablePO> loggerContext = new LoggerContext<>();
//            loggerContext.setTargetId(String.valueOf(subTableItemPO.getId()));
//            loggerContext.setTargetName(subTableItemPO.getItemName());
//            loggerContext.setOperateType(OperateTypeEnum.ADD.getValue());
//            loggerContext.setOperateTypeName(SalaryI18nUtil.getI18nLabel(152643, "新增统计项目"));
//            loggerContext.setOperatedesc(SalaryI18nUtil.getI18nLabel(152643, "新增统计项目"));
//            salaryStatReportLoggerTemplate.write(loggerContext);
            // 更新
        } else {
            SalaryStatisticsItemPO itemPO = this.getById(saveParam.getId());
            SalaryAssert.notNull(itemPO, SalaryI18nUtil.getI18nLabel(152591, "统计项目不存在"));
            Optional.ofNullable(saveParam.getItemName()).ifPresent(itemPO::setItemName);

            if (Objects.nonNull(saveParam.getUnitType())) {
                itemPO.setUnitType(saveParam.getUnitType());
            } else {
                itemPO.setItemValue(StringUtils.join(saveParam.getItemValue(),","));
                itemPO.setCountRule(Objects.nonNull(saveParam.getCountRule()) ? JSON.toJSONString(saveParam.getCountRule()) : "");
                itemPO.setSumRule(Objects.nonNull(saveParam.getSumRule()) ? JSON.toJSONString(saveParam.getSumRule()) : "");
                itemPO.setAvgRule(Objects.nonNull(saveParam.getAvgRule()) ? JSON.toJSONString(saveParam.getAvgRule()) : "");
                itemPO.setMaxRule(Objects.nonNull(saveParam.getMaxRule()) ? JSON.toJSONString(saveParam.getMaxRule()) : "");
                itemPO.setMinRule(Objects.nonNull(saveParam.getMinRule()) ? JSON.toJSONString(saveParam.getMinRule()) : "");
                itemPO.setMedianRule(Objects.nonNull(saveParam.getMedianRule()) ? JSON.toJSONString(saveParam.getMedianRule()) : "");
            }

            getSalaryStatisticsItemMapper().updateIgnoreNull(itemPO);

            // 记录操作日志
//            LoggerContext<SubTablePO> loggerContext = new LoggerContext<>();
//            loggerContext.setTargetId(String.valueOf(itemPO.getId()));
//            loggerContext.setTargetName(itemPO.getItemName());
//            loggerContext.setOperateType(OperateTypeEnum.UPDATE.getValue());
//            loggerContext.setOperateTypeName(SalaryI18nUtil.getI18nLabel(152669, "更新统计项目"));
//            loggerContext.setOperatedesc(SalaryI18nUtil.getI18nLabel(152669, "更新统计项目"));
//            salaryStatReportLoggerTemplate.write(loggerContext);
        }
        return StringUtils.EMPTY;
    }
}