package com.engine.salary.service.impl;

import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.hrm.biz.OrganizationShowSetBiz;
import com.engine.salary.biz.EmployBiz;
import com.engine.salary.biz.SalarySobRangeBiz;
import com.engine.salary.entity.salarysob.bo.SalarySobRangeSaveBO;
import com.engine.salary.entity.salarysob.dto.SalarySobRangeListDTO;
import com.engine.salary.entity.salarysob.param.SalarySobRangeQueryParam;
import com.engine.salary.entity.salarysob.param.SalarySobRangeSaveParam;
import com.engine.salary.entity.salarysob.po.SalarySobPO;
import com.engine.salary.entity.salarysob.po.SalarySobRangePO;
import com.engine.salary.enums.salarysob.TargetTypeEnum;
import com.engine.salary.exception.SalaryRunTimeException;
import com.engine.salary.service.SalarySobRangeService;
import com.engine.salary.service.SalarySobService;
import com.engine.salary.util.SalaryEntityUtil;
import com.engine.salary.util.SalaryI18nUtil;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.math.NumberUtils;
import weaver.hrm.User;

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

/**
 * 薪资账套人员范围
 * <p>Copyright: Copyright (c) 2022</p>
 * <p>Company: 泛微软件</p>
 *
 * @author qiantao
 * @version 1.0
 **/
public class SalarySobRangeServiceImpl extends Service implements SalarySobRangeService {

    private SalarySobRangeBiz salarySobRangeMapper = new SalarySobRangeBiz();
    private EmployBiz employBiz = new EmployBiz();
    OrganizationShowSetBiz orgBiz = new OrganizationShowSetBiz();


    private SalarySobService getSalarySobService(User user) {
        return (SalarySobService) ServiceUtil.getService(SalarySobServiceImpl.class, user);
    }


//    private ComInfoCache comInfoCache;
//    private LoggerTemplate salarySobLoggerTemplate;

    @Override
    public List<SalarySobRangePO> listByIds(Collection<Long> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return Collections.emptyList();
        }
        return salarySobRangeMapper.listSome(SalarySobRangePO.builder().ids(ids).build());
    }

    @Override
    public List<SalarySobRangePO> listBySalarySobIdAndIncludeType(Long salarySobId, Integer includeType) {
        return salarySobRangeMapper.listSome(SalarySobRangePO.builder().salarySobId(salarySobId).includeType(includeType).build());
    }

    @Override
    public List<SalarySobRangeListDTO> listPageByParamAndIncludeType(SalarySobRangeQueryParam queryParam, Integer includeType) {
        // 查询人员范围
        List<SalarySobRangePO> salarySobRangePOS = listBySalarySobIdAndIncludeType(queryParam.getSalarySobId(), includeType);
        // 查询人员信息
        List<Object> employeeIds = salarySobRangePOS.stream()
                .filter(e -> Objects.equals(e.getTargetType(), TargetTypeEnum.EMPLOYEE.getValue()))
                .map(SalarySobRangePO::getTargetId)
                .collect(Collectors.toList());
//    todo 缓存获取人员信息    List<HrmEmployeeComInfo> employeeComInfos = comInfoCache.getCacheList(HrmEmployeeComInfo.class, employeeIds);
        //1、获取人员信息


        // 查询部门信息
        Map<Long, String> deptMap = new HashMap<>();
        salarySobRangePOS.stream()
                .filter(e -> Objects.equals(e.getTargetType(), TargetTypeEnum.DEPT.getValue()))
                .map(SalarySobRangePO::getTargetId)
                .forEach(id -> {
                    deptMap.put(id, orgBiz.getDepartmentShow(String.valueOf(id), "0", "-"));
                });
// todo       List<HrmDepartmentComInfo> departmentComInfos = comInfoCache.getCacheList(HrmDepartmentComInfo.class, departmentIds);

//        String departmentShow = orgBiz.getDepartmentShow(departmentIds.stream().map(String::valueOf).collect(Collectors.joining(",")), "0", "-");
//        Arrays.asList(departmentShow.split(","));

//        // 查询岗位信息
//        List<Object> positionIds = salarySobRangePOS.stream()
//                .filter(e -> Objects.equals(e.getTargetType(), TargetTypeEnum.POSITION.getValue()))
//                .map(SalarySobRangePO::getTargetId)
//                .collect(Collectors.toList());
//        List<HrmPositionComInfo> positionComInfos = comInfoCache.getCacheList(HrmPositionComInfo.class, positionIds);
//        // 分页参数
//        Page<SalarySobRangeListDTO> dtoPage = SalaryPageUtil.buildPage(queryParam.getCurrent(), queryParam.getPageSize());
//        // 薪资账套的人员范围po转换成列表dto
//        List<SalarySobRangeListDTO> salarySobRangeListDTOS = SalarySobRangeBO.convert2ListDTO(salarySobRangePOS, employeeComInfos, departmentComInfos, positionComInfos);
//        // 根据对象名称过滤
//        if (StringUtils.isNotEmpty(queryParam.getTargetName())) {
//            salarySobRangeListDTOS = salarySobRangeListDTOS.stream()
//                    .filter(salarySobRangeListDTO -> salarySobRangeListDTO.getTargetName().contains(queryParam.getTargetName()))
//                    .collect(Collectors.toList());
//        }
//        // 填充总数和当页数据
//        dtoPage.setTotal(salarySobRangeListDTOS.size());
//        dtoPage.setRecords(SalaryPageUtil.subList((int) dtoPage.getCurrent(), (int) dtoPage.getSize(), salarySobRangeListDTOS));
//        return dtoPage;
        return null;
    }

    @Override
    public void save(SalarySobRangeSaveParam saveParam) {
        // 查询薪资账套
        SalarySobPO salarySobPO = getSalarySobService(user).getById(saveParam.getSalarySobId());
        if (Objects.isNull(salarySobPO)) {
            throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(98379, "参数错误，薪资账套不存在或者已被删除"));
        }
        // 查询已有的人员范围
        List<SalarySobRangePO> salarySobRangePOS = listBySalarySobIdAndIncludeType(saveParam.getSalarySobId(), saveParam.getIncludeType());
        // 处理一下本次的保存参数（如果原来添加过对应的人员（/部门/岗位），那么本次不需要新增，只需要更新）
        SalarySobRangeSaveBO.Result result = SalarySobRangeSaveBO.handle(salarySobRangePOS, saveParam, (long) user.getUID());
        // 保存
        if (CollectionUtils.isNotEmpty(result.getNeedInsertSalarySobRanges())) {
            salarySobRangeMapper.batchInsert(result.getNeedInsertSalarySobRanges());
        }
        if (CollectionUtils.isNotEmpty(result.getNeedUpdateSalarySobRanges())) {
            result.getNeedUpdateSalarySobRanges().forEach(e -> salarySobRangeMapper.updateById(e));
        }
        // todo 记录日志
//        String operateTypeName = Objects.equals(saveParam.getIncludeType(), NumberUtils.INTEGER_ONE) ?
//                SalaryI18nUtil.getI18nLabel(98601, "关联人员范围新增对象") : SalaryI18nUtil.getI18nLabel(98602, "从范围中排除新增对象");
//        LoggerContext<SalarySobRangeSaveParam> loggerContext = new LoggerContext<>();
//        loggerContext.setTargetId("" + salarySobPO.getId());
//        loggerContext.setTargetName(salarySobPO.getName());
//        loggerContext.setOperateType(OperateTypeEnum.UPDATE.getValue());
//        loggerContext.setOperateTypeName(operateTypeName);
//        loggerContext.setOperatedesc(operateTypeName);
//        loggerContext.setNewValues(saveParam);
//        salarySobLoggerTemplate.write(loggerContext);
    }

    @Override
    public void deleteByIds(Collection<Long> ids) {
        // 查询薪资账套的人员范围
        List<SalarySobRangePO> salarySobRangePOS = listByIds(ids);
        if (CollectionUtils.isEmpty(salarySobRangePOS)) {
            throw new SalaryRunTimeException(SalaryI18nUtil.getI18nLabel(98604, "数据不存在或已被删除"));
        }
        ids = SalaryEntityUtil.properties(salarySobRangePOS, SalarySobRangePO::getId);
        // 删除薪资账套的人员范围
        salarySobRangeMapper.deleteByIds(ids);
        // 查询薪资账套
        Set<Long> salarySobIds = SalaryEntityUtil.properties(salarySobRangePOS, SalarySobRangePO::getSalarySobId);
        List<SalarySobPO> salarySobPOS = getSalarySobService(user).listByIds(salarySobIds);
        // 是"关联人员范围"还是"从范围中排除"
        Integer includeType = salarySobRangePOS.get(0).getIncludeType();
        // todo 记录日志
        String operateTypeName = Objects.equals(includeType, NumberUtils.INTEGER_ONE) ?
                SalaryI18nUtil.getI18nLabel(98605, "关联人员范围删除对象") : SalaryI18nUtil.getI18nLabel(98606, "从范围中排除删除对象");
//        salarySobPOS.forEach(salarySobPO -> {
//            LoggerContext<SalarySobPO> loggerContext = new LoggerContext<>();
//            loggerContext.setTargetId("" + salarySobPO.getId());
//            loggerContext.setTargetName(salarySobPO.getName());
//            loggerContext.setOperateType(OperateTypeEnum.DELETE.getValue());
//            loggerContext.setOperateTypeName(operateTypeName);
//            loggerContext.setOperatedesc(operateTypeName);
//        });
    }

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