xx

孔祥富

2021-03-10 67abd83ce5d31a6dde9d744a80350c9c05fbb6dd

 febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpOccupationalServiceImpl.java

@@ -7,6 +7,12 @@
import java.util.List;
import java.util.Optional;

import cc.mrbird.febs.common.core.constant.DicCode;
import cc.mrbird.febs.common.core.entity.system.DicItem;
import cc.mrbird.febs.common.core.exception.FebsException;
import cc.mrbird.febs.server.hr.constant.MyConstant;
import cc.mrbird.febs.server.hr.entity.EmpAccidentCases;
import cc.mrbird.febs.server.hr.entity.EmpBaseInfo;
import cc.mrbird.febs.server.hr.service.IEmpBaseInfoService;
import cn.hutool.core.util.StrUtil;
import org.apache.commons.lang3.StringUtils;
@@ -88,23 +94,36 @@
         queryWrapper.eq("a.SettleStatus", empOccupational.getSettleStatus());
      }
      if (StringUtils.isNotBlank(empOccupational.getEmpStatus())) {
         queryWrapper.eq("a.EmpStatus", empOccupational.getEmpStatus());
         queryWrapper.in("a.EmpStatus", empOccupational.getEmpStatus().split(","));
      }
      queryWrapper.in("c.dept_Id", remoteDeptService.userRightDepts().split(StringConstant.COMMA));
        Page<EmpOccupational> page = new Page<>(request.getPageNum(), request.getPageSize());
        return empOccupationalMapper.selectPageVo(page, queryWrapper);
        IPage<EmpOccupational> pageList = empOccupationalMapper.selectPageVo(page, queryWrapper);
        List<EmpOccupational> list = pageList.getRecords();
        //处理数据字典
        pageList.setRecords(covertDicItemName(list));
        return pageList;
    }

    @Override
    public List<EmpOccupational> findEmpOccupationals(EmpOccupational empOccupational) {
        LambdaQueryWrapper<EmpOccupational> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(EmpOccupational::getDelFlag, empOccupational.getDelFlag());
        return this.baseMapper.selectList(queryWrapper);
        List<EmpOccupational> list = this.baseMapper.selectList(queryWrapper);
        return covertDicItemName(list);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void createEmpOccupational(EmpOccupational empOccupational) {
    public void createEmpOccupational(EmpOccupational empOccupational) throws FebsException {
        LambdaQueryWrapper<EmpOccupational> lambdaQueryWrapper = new LambdaQueryWrapper<>();
        lambdaQueryWrapper.eq(EmpOccupational::getEmpId, empOccupational.getEmpId());
        lambdaQueryWrapper.eq(EmpOccupational::getInjuredTime, empOccupational.getInjuredTime());
        lambdaQueryWrapper.ne(EmpOccupational::getDelFlag,1);
        if (this.count(lambdaQueryWrapper) > 0) {
            throw new FebsException(MyConstant.MESSAGE);
        }

        empOccupational.setOccupationalId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE));
        if(empOccupational.getSubmitTime()==null){
            empOccupational.setSubmitTime(empOccupational.getInjuredTime());
@@ -180,13 +199,13 @@
            returnList.add(StrUtil.format("导入员工工伤案件异常: 出现位置第{}行, 原因:{}部门不存在",listObject.indexOf(list)+1,list.get(1).toString()));
            continue;
         }
         Long empId = empBaseInfoService.getEmpIdByEmpNumb(list.get(0).toString());
         if (null == empId){
         EmpBaseInfo empBaseInfo = empBaseInfoService.getEmpBaseInfoByEmpNumb(list.get(0).toString());
         if (null == empBaseInfo){
            returnList.add(StrUtil.format("导入员工工伤案件异常: 出现位置第{}行, 原因:{}员工编号不存在",listObject.indexOf(list)+1,list.get(0).toString()));
            continue;
         }
         empOccupational.setDelFlag(2);
         empOccupational.setEmpId(empId);
         empOccupational.setEmpId(empBaseInfo.getEmpId());
         empOccupational.setDeptName(list.get(1).toString());
         empOccupational.setDeptId(dept.getDeptId());
         empOccupational.setJobName(list.get(2).toString());
@@ -205,7 +224,7 @@
            empOccupational.setHospitalizatioFlag("未住院".equals(list.get(12).toString()) ? 0 : 1);
         }
         if (StringUtils.isNotBlank(list.get(13).toString())) {
            empOccupational.setBedNumb(list.get(14).toString());
            empOccupational.setBedNumb(list.get(13).toString());
         }
         if (StringUtils.isNotBlank(list.get(14).toString())) {
            empOccupational.setReportTime(DateUtil.parseDate(list.get(14).toString()));
@@ -230,7 +249,22 @@
         if (StringUtils.isNotBlank(list.get(22).toString())) {
            empOccupational.setSettleDate(DateUtil.parseDate(list.get(22).toString()));
         }
         empOccupational.setEmpStatus(empBaseInfo.getEmpStatus());
         this.save(empOccupational);
       }
    }

    private List<EmpOccupational> covertDicItemName(List<EmpOccupational> list){
        List<DicItem> dicItems = CastUtil.castList(redisService.get("dicItems"), DicItem.class);
        list.parallelStream().forEachOrdered(p -> {
            // 设置结案状态
            p.setSettleStatusName(dicItems.stream()
                    .filter(k -> DicCode.SETTLE_STATUS.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getSettleStatus().toString()))
                    .findFirst()
                    .map(DicItem::getDicItemName)
                    .orElse(""));
        });

        return list;
    }
}