package com.engine.salary.service.impl;

import com.engine.core.impl.Service;
import com.engine.salary.biz.SISchemeBiz;
import com.engine.salary.cmd.sischeme.*;
import com.engine.salary.entity.sischeme.po.InsuranceSchemeDetailPO;
import com.engine.salary.entity.sischeme.po.InsuranceSchemePO;
import com.engine.salary.mapper.sischeme.InsuranceSchemeMapper;
import com.engine.salary.service.SISchemeService;
import com.engine.salary.util.db.MapperProxyFactory;
import org.apache.commons.collections4.CollectionUtils;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * @Author weaver_cl
 * @Description: TODO
 * @Date 2022/3/7
 * @Version V1.0
 **/
public class SISchemeServiceImpl extends Service implements SISchemeService {

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

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

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

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

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

    @Override
    public List<InsuranceSchemeDetailPO> queryListByInsuranceIdIsPayment(Long insuranceId, Integer isPayment) {
        return new SISchemeBiz().queryListByInsuranceIdIsPayment(insuranceId,isPayment);
    }

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

    @Override
    public Map<Long, String> getSchemeIdNameMap() {
        Map<Long, String> result = new HashMap<>();
        List<InsuranceSchemePO> insuranceSchemePOS = MapperProxyFactory.getProxy(InsuranceSchemeMapper.class).listAll();
        if (CollectionUtils.isNotEmpty(insuranceSchemePOS)) {
            result = insuranceSchemePOS.stream().collect(Collectors.toMap(InsuranceSchemePO::getId, InsuranceSchemePO::getSchemeName));
        }
        return result;
    }
}