135 lines
6.0 KiB
Java
135 lines
6.0 KiB
Java
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.sicategory.po.ICategoryPO;
|
||
import com.engine.salary.entity.sischeme.dto.InsuranceSchemeListDTO;
|
||
import com.engine.salary.entity.sischeme.param.InsuranceSchemeParam;
|
||
import com.engine.salary.entity.sischeme.po.InsuranceSchemeDetailPO;
|
||
import com.engine.salary.entity.sischeme.po.InsuranceSchemePO;
|
||
import com.engine.salary.enums.sicategory.DeleteTypeEnum;
|
||
import com.engine.salary.enums.sicategory.IsPaymentEnum;
|
||
import com.engine.salary.enums.sicategory.PaymentTypeEnum;
|
||
import com.engine.salary.mapper.sicategory.ICategoryMapper;
|
||
import com.engine.salary.mapper.sischeme.InsuranceSchemeDetailMapper;
|
||
import com.engine.salary.mapper.sischeme.InsuranceSchemeMapper;
|
||
import com.engine.salary.service.SISchemeService;
|
||
import com.engine.salary.util.SalaryAssert;
|
||
import com.engine.salary.util.SalaryEnumUtil;
|
||
import com.engine.salary.util.SalaryI18nUtil;
|
||
import com.engine.salary.util.db.MapperProxyFactory;
|
||
import com.engine.salary.util.page.PageInfo;
|
||
import com.engine.salary.util.page.PageUtil;
|
||
import org.apache.commons.collections4.CollectionUtils;
|
||
import org.apache.commons.lang3.StringUtils;
|
||
|
||
import java.util.*;
|
||
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;
|
||
}
|
||
|
||
@Override
|
||
public PageInfo<InsuranceSchemeListDTO> list(InsuranceSchemeParam queryParam) {
|
||
SalaryAssert.notNull(queryParam.getWelfareTypeEnum(), SalaryI18nUtil.getI18nLabel( 84026, "参数错误"));
|
||
PageUtil.start(queryParam.getCurrent(), queryParam.getPageSize());
|
||
List<InsuranceSchemePO> insuranceSchemePOS = MapperProxyFactory.getProxy(InsuranceSchemeMapper.class).listByWelfareType(queryParam.getWelfareTypeEnum().getValue());
|
||
List<InsuranceSchemeListDTO> collect = insuranceSchemePOS.stream().map(item ->
|
||
InsuranceSchemeListDTO.builder()
|
||
.id(item.getId())
|
||
.paymentType(SalaryI18nUtil.getI18nLabel( buildPaymentTypeEnum(item.getPaymentType()).getLabelId(),
|
||
buildPaymentTypeEnum(item.getPaymentType()).getDefaultLabel()))
|
||
.schemeName(item.getSchemeName())
|
||
.paymentArea(item.getPaymentArea())
|
||
.paymentScope(buildPaymentScope(item.getId()))
|
||
.remarks(item.getRemarks())
|
||
.build()
|
||
).collect(Collectors.toList());
|
||
PageInfo<InsuranceSchemeListDTO> pageInfo = new PageInfo<>(collect,InsuranceSchemeListDTO.class);
|
||
return pageInfo;
|
||
}
|
||
|
||
|
||
public PaymentTypeEnum buildPaymentTypeEnum(Integer value) {
|
||
return SalaryEnumUtil.enumMatchByValue(value, PaymentTypeEnum.values(), PaymentTypeEnum.class);
|
||
}
|
||
|
||
|
||
/**
|
||
* 组装社保福利方案列表页【缴纳范围】
|
||
* 1、到福利方案明细表查询该方案id下面有哪些福利
|
||
* 2、去重（福利是分个人和公司的，明细表中查询出来的福利id会重复）
|
||
* 3、根据查询出来的福利id，去福利表里面查询福利的名称
|
||
* 4、组装，以“、”分割
|
||
*
|
||
* @param id 福利方案主表id
|
||
* @return result
|
||
*/
|
||
public String buildPaymentScope(Long id) {
|
||
List<String> collect = queryInsuranceSchemeDetailList(id).stream().map(InsuranceSchemeDetailPO::getInsuranceId).distinct().collect(Collectors.toList())
|
||
.stream().map(this::queryInsuranceName).collect(Collectors.toList());
|
||
return StringUtils.join(collect, "、");
|
||
}
|
||
|
||
public Collection<InsuranceSchemeDetailPO> queryInsuranceSchemeDetailList(Long id) {
|
||
List<InsuranceSchemeDetailPO> insuranceSchemeDetailPOS = MapperProxyFactory.getProxy(InsuranceSchemeDetailMapper.class).queryInsuranceSchemeDetailList(id, IsPaymentEnum.YES.getValue());
|
||
return insuranceSchemeDetailPOS;
|
||
}
|
||
|
||
public String queryInsuranceName(Long id) {
|
||
ICategoryPO insuranceCategoryPO = MapperProxyFactory.getProxy(ICategoryMapper.class).getById(id);
|
||
return insuranceCategoryPO == null ? "" : Objects.isNull(insuranceCategoryPO.getInsuranceName()) ? "" : insuranceCategoryPO.getInsuranceName();
|
||
}
|
||
}
|