package com.engine.salary.service.impl;

import com.api.formmode.mybatis.util.SqlProxyHandle;
import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.salary.biz.EmployBiz;
import com.engine.salary.entity.datacollection.DataCollectionEmployee;
import com.engine.salary.entity.salarysob.bo.SalarySobRangeBO;
import com.engine.salary.entity.salarysob.param.SalarySobRangeEmpQueryParam;
import com.engine.salary.entity.salarysob.po.SalarySobRangePO;
import com.engine.salary.enums.UserStatusEnum;
import com.engine.salary.mapper.datacollection.EmployMapper;
import com.engine.salary.mapper.sys.SalarySysConfMapper;
import com.engine.salary.service.SalaryEmployeeService;
import com.engine.salary.service.SalarySobRangeService;
import com.engine.salary.sys.entity.po.SalarySysConfPO;
import com.engine.salary.util.SalaryEntityUtil;
import com.engine.salary.util.db.MapperProxyFactory;
import com.google.common.collect.Lists;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
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 SalaryEmployeeServiceImpl extends Service implements SalaryEmployeeService {

    private EmployBiz employBiz = new EmployBiz();

    private SalarySobRangeService getSalarySobRangeService(User user) {
        return ServiceUtil.getService(SalarySobRangeServiceImpl.class, user);
    }

    private EmployMapper getEmployMapper() {
        return MapperProxyFactory.getProxy(EmployMapper.class);
    }

    private SalarySysConfMapper getSalarySysConfMapper() {
        return SqlProxyHandle.getProxy(SalarySysConfMapper.class);
    }

    @Override
    public List<DataCollectionEmployee> listAll() {
        return employBiz.listEmployee();
    }

    @Override
    public List<DataCollectionEmployee> listAllForReport() {
        return getEmployMapper().listAllForReport();
    }

    @Override
    public List<DataCollectionEmployee> listBySalarySobId(Long salarySobId) {
        // 查询薪资账套的人员范围
        List<SalarySobRangePO> includeSalarySobRangePOS = getSalarySobRangeService(user).listBySalarySobIdAndIncludeType(salarySobId, NumberUtils.INTEGER_ONE);
        if (CollectionUtils.isEmpty(includeSalarySobRangePOS)) {
            return Collections.emptyList();
        }
        // 将薪资账套的人员范围转换成人员查询参数
        List<SalarySobRangeEmpQueryParam> includeQueryParams = SalarySobRangeBO.convert2EmployeeQueryParam(includeSalarySobRangePOS);
        // 根据上一步的查询参数查询人员
        List<DataCollectionEmployee> includeSalaryEmployees = employBiz.listByParams(includeQueryParams);
        if (CollectionUtils.isEmpty(includeSalaryEmployees)) {
            return Collections.emptyList();
        }
        //去重
        includeSalaryEmployees = includeSalaryEmployees.stream().distinct().collect(Collectors.toList());
        // 查询薪资账套的人员范围（从范围中排除）
        List<SalarySobRangePO> excludeSalarySobRangePOS = getSalarySobRangeService(user).listBySalarySobIdAndIncludeType(salarySobId, NumberUtils.INTEGER_ZERO);
        if (CollectionUtils.isNotEmpty(excludeSalarySobRangePOS)) {
            // 将薪资账套的人员范围转换成人员查询参数
            List<SalarySobRangeEmpQueryParam> excludeQueryParams = SalarySobRangeBO.convert2EmployeeQueryParam(excludeSalarySobRangePOS);
            // 根据上一步的查询参数查询人员
            List<DataCollectionEmployee> excludeSalaryEmployees = employBiz.listByParams(excludeQueryParams);
            // 需要排除的人员范围
            Set<Long> excludeEmployeeIds = SalaryEntityUtil.properties(excludeSalaryEmployees, DataCollectionEmployee::getEmployeeId);
            // 过滤人员
            includeSalaryEmployees = includeSalaryEmployees.stream()
                    .filter(salaryEmployee -> !excludeEmployeeIds.contains(salaryEmployee.getEmployeeId()))
                    .collect(Collectors.toList());
        }
        return includeSalaryEmployees;
    }

    @Override
    public List<DataCollectionEmployee> listByIds(List<Long> ids) {
        return employBiz.getEmployeeByIdsAll(ids);
    }

    @Override
    public DataCollectionEmployee getEmployeeById(Long employeeId) {
        return employBiz.getEmployeeById(employeeId);
    }

    @Override
    public List<DataCollectionEmployee> getEmployeeByIds(List<Long> simpleEmployeeIds) {
        if (CollectionUtils.isEmpty(simpleEmployeeIds)) {
            return new ArrayList<>();
        }
        List<DataCollectionEmployee> employeeList = new ArrayList<>();
        List<List<Long>> partition = Lists.partition(simpleEmployeeIds, 1000);
        for (List<Long> longs : partition) {
            employeeList.addAll(getEmployMapper().getEmployeeByIds(longs));
        }
        return employeeList;

    }


    public List<DataCollectionEmployee> filterEmployees(List<DataCollectionEmployee> employees, String userName, String deparmentName, String mobile) {
        List<DataCollectionEmployee> employeeSameIds = employees.stream().filter(e -> (StringUtils.isBlank(userName) || Objects.equals(e.getUsername(), userName))
                        && (StringUtils.isBlank(deparmentName) || Objects.equals(e.getDepartmentName(), deparmentName))
                        && (StringUtils.isBlank(mobile) || Objects.equals(e.getMobile(), mobile)))
                .collect(Collectors.toList());
        //存在离职和在职状态取在职状态
        employeeSameIds = employeeSameIds.stream()
                .filter(e -> UserStatusEnum.getNormalStatus().contains(e.getStatus()))
                .collect(Collectors.toList());

        return employeeSameIds;
    }

    @Override
    public List<DataCollectionEmployee> matchImportEmployee(List<DataCollectionEmployee> employeeList, String userName, String deparmentName, String mobile, String workcode, Long uid) {
        if (uid != null) {
            return employeeList.stream()
                    .filter(e -> Objects.equals(e.getEmployeeId(), uid))
                    .collect(Collectors.toList());
        }

        //查询对于人员信息导入筛选的全局配置
        SalarySysConfPO salarySysConfPO = getSalarySysConfMapper().getOneByCode("matchEmployeeMode");
        String confValue = (salarySysConfPO != null && salarySysConfPO.getConfValue() != null && !"".equals(salarySysConfPO.getConfValue())) ? salarySysConfPO.getConfValue() : "0";
        List<DataCollectionEmployee> employees = new ArrayList<>();
        //“0”代表姓名+部门+手机号的匹配原则，“1”代表工号为唯一匹配原则
        if ("0".equals(confValue)) {
            employees = employeeList.stream().filter(e -> (StringUtils.isBlank(userName) || Objects.equals(e.getUsername(), userName))
                            && (StringUtils.isBlank(deparmentName) || Objects.equals(e.getDepartmentName(), deparmentName))
                            && (StringUtils.isBlank(mobile) || Objects.equals(e.getMobile(), mobile)))
                    .collect(Collectors.toList());
        } else if ("1".equals(confValue)) {
            employees = employeeList.stream().filter(e -> (StringUtils.isBlank(workcode) || Objects.equals(e.getWorkcode(), workcode)))
                    .collect(Collectors.toList());
        }

        return employees;

    }
}