| New file |
| | |
| | | package cc.mrbird.febs.server.hr.service.impl; |
| | | |
| | | import java.util.*; |
| | | |
| | | import cc.mrbird.febs.common.core.entity.system.SysConfig; |
| | | import cc.mrbird.febs.server.hr.entity.EmpDimissionLog; |
| | | import cc.mrbird.febs.server.hr.entity.EmpJobChange; |
| | | import cc.mrbird.febs.server.hr.service.IEmpDimissionLogService; |
| | | import cc.mrbird.febs.server.hr.service.IEmpJobChangeService; |
| | | import cn.hutool.core.date.DateUnit; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import cc.mrbird.febs.server.hr.entity.*; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Propagation; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | |
| | | import cc.mrbird.febs.common.core.constant.DicCode; |
| | | import cc.mrbird.febs.common.core.constant.ModuleCode; |
| | | import cc.mrbird.febs.common.core.entity.QueryRequest; |
| | | import cc.mrbird.febs.common.core.entity.system.Dept; |
| | | import cc.mrbird.febs.common.core.entity.system.DicItem; |
| | | import cc.mrbird.febs.common.core.utils.CastUtil; |
| | | import cc.mrbird.febs.common.core.utils.FebsUtil; |
| | | import cc.mrbird.febs.common.core.utils.SequenceUtil; |
| | | import cc.mrbird.febs.common.redis.service.RedisService; |
| | | import cc.mrbird.febs.server.hr.entity.EmpBaseInfo; |
| | | import cc.mrbird.febs.server.hr.feign.IRemoteDeptService; |
| | | import cc.mrbird.febs.server.hr.mapper.EmpBaseInfoMapper; |
| | | import cc.mrbird.febs.server.hr.service.IEmpBaseInfoService; |
| | | import lombok.RequiredArgsConstructor; |
| | | |
| | | /** |
| | | * name:EmpBaseinfo |
| | | * package:cc.mrbird.febs.server.hr.controller |
| | | * description:员工基本信息服务接口实现 |
| | | * |
| | | * @author luoyibo |
| | | * @date 2021-01-30 08:04:50 |
| | | * @since JDK1.8 |
| | | */ |
| | | @Service |
| | | @RequiredArgsConstructor |
| | | @Transactional(propagation = Propagation.SUPPORTS, readOnly = true) |
| | | class EmpBaseInfoServiceImpl extends ServiceImpl<EmpBaseInfoMapper, EmpBaseInfo> implements IEmpBaseInfoService { |
| | | private final RedisService redisService; |
| | | private final IRemoteDeptService remoteDeptService; |
| | | private final EmpBaseInfoMapper empBaseInfoMapper; |
| | | private final IEmpDimissionLogService dimissionLogService; |
| | | private final IEmpJobChangeService jobChangeService; |
| | | |
| | | private final String operatorId = Optional.ofNullable(FebsUtil.getCurrentUser()) |
| | | .map(u -> u.getUserId().toString()) |
| | | .orElse("1"); |
| | | |
| | | @Override |
| | | public IPage<EmpBaseInfo> findEmpBaseInfos(QueryRequest request, EmpBaseInfo empBaseInfo) { |
| | | LambdaQueryWrapper<EmpBaseInfo> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(EmpBaseInfo::getDelFlag, empBaseInfo.getDelFlag()); |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEmpNumb())) { |
| | | queryWrapper.like(EmpBaseInfo::getEmpNumb, empBaseInfo.getEmpNumb()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEmpName())) { |
| | | queryWrapper.like(EmpBaseInfo::getEmpName, empBaseInfo.getEmpName()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getCertificateNumb())) { |
| | | queryWrapper.like(EmpBaseInfo::getCertificateNumb, empBaseInfo.getCertificateNumb()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getDeptName())) { |
| | | queryWrapper.like(EmpBaseInfo::getDeptName, empBaseInfo.getDeptName()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEntryDateStr())) { |
| | | queryWrapper.between(EmpBaseInfo::getEntryDate, empBaseInfo.getEntryDateStr().split(",")[0], empBaseInfo.getEntryDateStr().split(",")[1]); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getDimissionDateStr())) { |
| | | queryWrapper.between(EmpBaseInfo::getDimissionDate, empBaseInfo.getDimissionDateStr().split(",")[0], empBaseInfo.getDimissionDateStr().split(",")[1]); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getSex())) { |
| | | queryWrapper.eq(EmpBaseInfo::getSex, empBaseInfo.getSex()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEducation())) { |
| | | queryWrapper.like(EmpBaseInfo::getEducation, empBaseInfo.getEducation()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getPolitics())) { |
| | | queryWrapper.like(EmpBaseInfo::getPolitics, empBaseInfo.getPolitics()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getAgeStr())) { |
| | | queryWrapper.between(EmpBaseInfo::getAge, empBaseInfo.getAgeStr().split(",")[0], empBaseInfo.getAgeStr().split(",")[1]); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getArchivesStatus())) { |
| | | queryWrapper.eq(EmpBaseInfo::getArchivesStatus, empBaseInfo.getArchivesStatus()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getInsuranceType())) { |
| | | queryWrapper.eq(EmpBaseInfo::getInsuranceType, empBaseInfo.getInsuranceType()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEmpStatus())) { |
| | | queryWrapper.eq(EmpBaseInfo::getEmpStatus, empBaseInfo.getEmpStatus()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getHandbookStatus())) { |
| | | queryWrapper.eq(EmpBaseInfo::getHandbookStatus, empBaseInfo.getHandbookStatus()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEmpCardStatus())) { |
| | | queryWrapper.eq(EmpBaseInfo::getEmpCardStatus, empBaseInfo.getEmpCardStatus()); |
| | | } |
| | | Page<EmpBaseInfo> page = new Page<>(request.getPageNum(), request.getPageSize()); |
| | | IPage<EmpBaseInfo> iPage = this.page(page, queryWrapper); |
| | | //设置部门 |
| | | List<EmpBaseInfo> list = setDeptName(iPage.getRecords()); |
| | | List<DicItem> dicItems = CastUtil.castList(redisService.get("dicItems"), DicItem.class); |
| | | list.forEach(p -> { |
| | | p.setSexName("1".equals(p.getSex()) ? "男" : "女"); |
| | | p.setEmpTypeName("1".equals(p.getEmpType()) ? "正式工" : "临时工"); |
| | | p.setInsuranceTypeName("1".equals(p.getInsuranceType()) ? "(深户)五险一档" : "(非深户)五险一档"); |
| | | p.setArchivesStatusName("0".equals(p.getArchivesStatus()) ? "未移交" : "已移交"); |
| | | // 设置民族 |
| | | p.setNationName(dicItems.stream() |
| | | .filter(k -> DicCode.NATION.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getNation())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("汉族")); |
| | | // 设置政治面貌 |
| | | p.setPoliticsName(dicItems.stream() |
| | | .filter(k -> DicCode.PLITICAL.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getPolitics())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("群众")); |
| | | // 设置婚姻状况 |
| | | p.setMarriageName(dicItems.stream() |
| | | .filter(k -> DicCode.MARRIAGE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getMarriage())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("未婚")); |
| | | // 设置学历 |
| | | p.setEducationName(dicItems.stream() |
| | | .filter(k -> DicCode.EDUCATION.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getEducation())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("无学历")); |
| | | // 设置籍贯 |
| | | p.setNativePlaceName(dicItems.stream() |
| | | .filter(k -> DicCode.NATIVEPLACE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getNativePlace())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("未知")); |
| | | }); |
| | | iPage.setRecords(list); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpBaseInfo> findZsEmpBaseInfos(QueryRequest request, EmpBaseInfo empBaseInfo) { |
| | | LambdaQueryWrapper<EmpBaseInfo> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(EmpBaseInfo::getDelFlag, empBaseInfo.getDelFlag()); |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEmpNumb())) { |
| | | queryWrapper.like(EmpBaseInfo::getEmpNumb, empBaseInfo.getEmpNumb()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEmpName())) { |
| | | queryWrapper.like(EmpBaseInfo::getEmpName, empBaseInfo.getEmpName()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getCertificateNumb())) { |
| | | queryWrapper.like(EmpBaseInfo::getCertificateNumb, empBaseInfo.getCertificateNumb()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getDeptName())) { |
| | | queryWrapper.like(EmpBaseInfo::getDeptName, empBaseInfo.getDeptName()); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEntryDateStr())) { |
| | | queryWrapper.between(EmpBaseInfo::getEntryDate, empBaseInfo.getEntryDateStr().split(",")[0], empBaseInfo.getEntryDateStr().split(",")[1]); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getDimissionDateStr())) { |
| | | queryWrapper.between(EmpBaseInfo::getDimissionDate, empBaseInfo.getDimissionDateStr().split(",")[0], empBaseInfo.getDimissionDateStr().split(",")[1]); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getSex())) { |
| | | queryWrapper.in(EmpBaseInfo::getSex, empBaseInfo.getSex().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEducation())) { |
| | | queryWrapper.in(EmpBaseInfo::getEducation, empBaseInfo.getEducation().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getPolitics())) { |
| | | queryWrapper.in(EmpBaseInfo::getPolitics, empBaseInfo.getPolitics().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getAgeStr())) { |
| | | String[] ages=empBaseInfo.getAgeStr().split(","); |
| | | for (int i = 0; i < ages.length; i++) { |
| | | String ageBtn=ages[i]; |
| | | queryWrapper.between(EmpBaseInfo::getAge, ageBtn.split("-")[0], ageBtn.split("-")[1]); |
| | | } |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getArchivesStatus())) { |
| | | queryWrapper.in(EmpBaseInfo::getArchivesStatus, empBaseInfo.getArchivesStatus().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getInsuranceType())) { |
| | | queryWrapper.in(EmpBaseInfo::getInsuranceType, empBaseInfo.getInsuranceType().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(empBaseInfo.getEmpStatus())) { |
| | | queryWrapper.in(EmpBaseInfo::getEmpStatus, empBaseInfo.getEmpStatus().split(",")); |
| | | } |
| | | Page<EmpBaseInfo> page = new Page<>(request.getPageNum(), request.getPageSize()); |
| | | IPage<EmpBaseInfo> iPage = this.page(page, queryWrapper); |
| | | //设置部门 |
| | | List<EmpBaseInfo> list = setDeptName(iPage.getRecords()); |
| | | List<DicItem> dicItems = CastUtil.castList(redisService.get("dicItems"), DicItem.class); |
| | | list.forEach(p -> { |
| | | p.setSexName("1".equals(p.getSex()) ? "男" : "女"); |
| | | p.setEmpTypeName("1".equals(p.getEmpType()) ? "正式工" : "临时工"); |
| | | p.setInsuranceTypeName("1".equals(p.getInsuranceType()) ? "(深户)五险一档" : "(非深户)五险一档"); |
| | | p.setArchivesStatusName("0".equals(p.getArchivesStatus()) ? "未移交" : "已移交"); |
| | | // 设置民族 |
| | | p.setNationName(dicItems.stream() |
| | | .filter(k -> DicCode.NATION.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getNation())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("汉族")); |
| | | // 设置政治面貌 |
| | | p.setPoliticsName(dicItems.stream() |
| | | .filter(k -> DicCode.PLITICAL.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getPolitics())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("群众")); |
| | | // 设置婚姻状况 |
| | | p.setMarriageName(dicItems.stream() |
| | | .filter(k -> DicCode.MARRIAGE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getMarriage())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("未婚")); |
| | | // 设置学历 |
| | | p.setEducationName(dicItems.stream() |
| | | .filter(k -> DicCode.EDUCATION.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getEducation())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("无学历")); |
| | | // 设置籍贯 |
| | | p.setNativePlaceName(dicItems.stream() |
| | | .filter(k -> DicCode.NATIVEPLACE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getNativePlace())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("未知")); |
| | | }); |
| | | iPage.setRecords(list); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public List<EmpBaseInfo> findEmpBaseInfos(EmpBaseInfo empBaseInfo) { |
| | | LambdaQueryWrapper<EmpBaseInfo> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(EmpBaseInfo::getDelFlag, empBaseInfo.getDelFlag()); |
| | | return this.baseMapper.selectList(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void createEmpBaseInfo(EmpBaseInfo empBaseInfo) { |
| | | EmpBaseInfo dbInfo = this.getEmpBaseInfo(empBaseInfo); |
| | | if(dbInfo==null) { |
| | | empBaseInfo.setEmpId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE)); |
| | | } else{ |
| | | empBaseInfo.setEmpId(dbInfo.getEmpId()); |
| | | } |
| | | empBaseInfo.setCreator(operatorId); |
| | | empBaseInfo.setModifier(operatorId); |
| | | this.saveOrUpdate(empBaseInfo); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void updateEmpBaseInfo(EmpBaseInfo empBaseInfo) { |
| | | EmpBaseInfo dbData = this.getById(empBaseInfo.getEmpId()); |
| | | empBaseInfo.setCreateTime(dbData.getCreateTime()); |
| | | empBaseInfo.setCreator(dbData.getCreator()); |
| | | empBaseInfo.setDelFlag(dbData.getDelFlag()); |
| | | empBaseInfo.setModifyTime(new Date()); |
| | | empBaseInfo.setModifier(operatorId); |
| | | this.saveOrUpdate(empBaseInfo); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void deleteEmpBaseInfo(EmpBaseInfo empBaseInfo) { |
| | | LambdaQueryWrapper<EmpBaseInfo> wrapper = new LambdaQueryWrapper<>(); |
| | | // TODO 设置删除条件 |
| | | this.remove(wrapper); |
| | | } |
| | | |
| | | /** |
| | | * 根据Id批量逻辑删除记录 |
| | | * <p> |
| | | * date 2021-01-28 10:48 |
| | | * |
| | | * @param ids 待删除Id |
| | | * @return void |
| | | * @author: luoyibo |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void logicDelEmpBaseInfo(String ids) { |
| | | String[] str = ids.split(","); |
| | | List<String> list = new ArrayList<>(Arrays.asList(str)); |
| | | empBaseInfoMapper.logicDeleteByIds(list, operatorId); |
| | | } |
| | | |
| | | /** |
| | | * 设置员工部门名称 |
| | | * <p> |
| | | * date 2021-02-02 21:43 |
| | | * |
| | | * @param empBaseInfoList 人员信息列表 |
| | | * @return java.util.List<cc.mrbird.febs.server.hr.entity.EmpBaseInfo> |
| | | * @author: luoyibo |
| | | */ |
| | | private List<EmpBaseInfo> setDeptName(List<EmpBaseInfo> empBaseInfoList) { |
| | | List<Dept> depts = CastUtil.castList(redisService.get("depts"), Dept.class); |
| | | for (EmpBaseInfo empBaseInfo : empBaseInfoList) { |
| | | // 设置部门 |
| | | empBaseInfo.setDeptName(depts.stream() |
| | | .filter(k -> k.getDeptId().equals(empBaseInfo.getDeptId())) |
| | | .findFirst() |
| | | .map(Dept::getDeptName) |
| | | .orElse("")); |
| | | } |
| | | return empBaseInfoList; |
| | | } |
| | | |
| | | @Override |
| | | public boolean verifyEmpNumb(EmpBaseInfo empBaseInfo) { |
| | | QueryWrapper<EmpBaseInfo> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.lambda().eq(EmpBaseInfo::getEmpNumb, empBaseInfo.getEmpNumb()); |
| | | EmpBaseInfo tempEmpBaseInfo = this.getOne(queryWrapper); |
| | | if (tempEmpBaseInfo == null) { |
| | | return false; |
| | | } |
| | | return !empBaseInfo.getEmpId().equals(tempEmpBaseInfo.getEmpId()); |
| | | } |
| | | |
| | | @Override |
| | | public boolean momentToNormal(String ids) { |
| | | String[] str = ids.split(","); |
| | | List<String> list = new ArrayList<>(Arrays.asList(str)); |
| | | return empBaseInfoMapper.momentToNormal(list, operatorId) > 0; |
| | | } |
| | | |
| | | @Override |
| | | public EmpBaseInfo getEmpBaseInfo(EmpBaseInfo empBaseInfo) { |
| | | QueryWrapper<EmpBaseInfo> queryWrapper = new QueryWrapper<>(); |
| | | if(StringUtils.isNotEmpty(empBaseInfo.getCertificateNumb())){ |
| | | queryWrapper.lambda().eq(EmpBaseInfo::getCertificateNumb, empBaseInfo.getCertificateNumb()); |
| | | } |
| | | return this.getOne(queryWrapper); |
| | | } |
| | | /** |
| | | * |
| | | * 关闭员工档案 |
| | | * |
| | | * date 2021-02-18 12:54 |
| | | * @author: luoyibo |
| | | * @param empDimissionLog |
| | | * @return boolean |
| | | */ |
| | | @Override |
| | | public boolean closeEmpArchives(EmpDimissionLog empDimissionLog) { |
| | | String[] str = empDimissionLog.getEmpIds().split(","); |
| | | List<String> list = new ArrayList<>(Arrays.asList(str)); |
| | | String[] strDate = empDimissionLog.getEntryDates().split(","); |
| | | EmpDimissionLog dimissionLog = null; |
| | | for (int i = 0,k=str.length; i < k; i++) { |
| | | dimissionLog = new EmpDimissionLog(); |
| | | dimissionLog.setCloseId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE)); |
| | | dimissionLog.setEmpId(Long.parseLong(str[i])); |
| | | dimissionLog.setEntryDate(DateUtil.parse(strDate[i],"yyyy-MM-dd")); |
| | | dimissionLog.setDimissionDate(empDimissionLog.getDimissionDate()); |
| | | dimissionLog.setDimissionType(empDimissionLog.getDimissionType()); |
| | | dimissionLog.setRemark(empDimissionLog.getRemark()); |
| | | dimissionLog.setSelfLeaveDay(empDimissionLog.getSelfLeaveDay()); |
| | | dimissionLog.setReporter(empDimissionLog.getReporter()); |
| | | dimissionLog.setCreator(operatorId); |
| | | dimissionLog.setModifier(operatorId); |
| | | |
| | | dimissionLogService.save(dimissionLog); |
| | | } |
| | | return empBaseInfoMapper.closeEmpArchives(list, empDimissionLog.getDimissionType(), empDimissionLog.getDimissionDate(), empDimissionLog.getRemark(), operatorId)>0; |
| | | } |
| | | /** |
| | | * |
| | | * 员工岗位变更 |
| | | * |
| | | * date 2021-02-18 20:32 |
| | | * @author: luoyibo |
| | | * @param empJobChange 1 |
| | | * @return boolean |
| | | */ |
| | | @Override |
| | | public boolean changeEmpJob(EmpJobChange empJobChange) { |
| | | String[] str = empJobChange.getEmpIds().split(","); |
| | | List<String> list = new ArrayList<>(Arrays.asList(str)); |
| | | String[] strName = empJobChange.getEmpNames().split(","); |
| | | String[] strDeptName = empJobChange.getOldDeptNames().split(","); |
| | | String[] strJobName = empJobChange.getOldJobNames().split(","); |
| | | |
| | | EmpJobChange saveChange = null; |
| | | |
| | | for (int i = 0,k=str.length; i <k ; i++) { |
| | | saveChange = new EmpJobChange(); |
| | | saveChange.setJobChangeId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE)); |
| | | saveChange.setEmpId(Long.parseLong(str[i])); |
| | | saveChange.setEmpName(strName[i]); |
| | | saveChange.setOldDeptName(strDeptName[i]); |
| | | saveChange.setOldJobName(strJobName[i]); |
| | | saveChange.setNewDeptName(empJobChange.getNewDeptName()); |
| | | saveChange.setNewJobName(empJobChange.getNewJobName()); |
| | | saveChange.setChangeType(empJobChange.getChangeType()); |
| | | saveChange.setChangeDate(empJobChange.getChangeDate()); |
| | | saveChange.setChangeReason(empJobChange.getChangeReason()); |
| | | saveChange.setCreator(operatorId); |
| | | saveChange.setModifier(operatorId); |
| | | |
| | | jobChangeService.save(saveChange); |
| | | |
| | | } |
| | | |
| | | Map<String, Object> mapParams = new HashMap<>(); |
| | | mapParams.put("deptId", empJobChange.getDeptId()); |
| | | mapParams.put("deptName", empJobChange.getNewDeptName()); |
| | | mapParams.put("jobId", empJobChange.getJobId()); |
| | | mapParams.put("jobName", empJobChange.getNewJobName()); |
| | | mapParams.put("operatorId", operatorId); |
| | | return empBaseInfoMapper.changeEmpJob(list,mapParams)>0; |
| | | } |
| | | |
| | | /** |
| | | * 导入员工 |
| | | * @param listObject |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void importEmpBaseInfo(List<List<Object>> listObject) { |
| | | for (List<Object> list : listObject) { |
| | | EmpBaseInfo empBaseInfo = new EmpBaseInfo(); |
| | | empBaseInfo.setEmpId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE)); |
| | | empBaseInfo.setEmpNumb(list.get(0).toString()); |
| | | List<Dept> depts = CastUtil.castList(redisService.get("depts"), Dept.class); |
| | | empBaseInfo.setDeptName(list.get(1).toString()); |
| | | Long deptId=depts.stream().filter(d -> d.getDeptName().equals(list.get(1).toString())).findFirst().get().getDeptId(); |
| | | empBaseInfo.setDeptId(deptId); |
| | | empBaseInfo.setJobName(list.get(2).toString()); |
| | | empBaseInfo.setEmpName(list.get(3).toString()); |
| | | empBaseInfo.setCertificateNumb(list.get(4).toString()); |
| | | empBaseInfo.setSex("男".equals(list.get(5).toString())?"1":"0"); |
| | | if (StringUtils.isNotBlank(list.get(6).toString())) { |
| | | empBaseInfo.setAge(Integer.valueOf(list.get(6).toString())); |
| | | } |
| | | empBaseInfo.setEducation(list.get(7).toString()); |
| | | empBaseInfo.setNativePlace(list.get(8).toString()); |
| | | empBaseInfo.setTelePhone(list.get(9).toString()); |
| | | if (StringUtils.isNotBlank(list.get(10).toString())) { |
| | | empBaseInfo.setEntryDate(DateUtil.parseDate(list.get(10).toString())); |
| | | } |
| | | empBaseInfo.setEmpStatus("0"); |
| | | this.save(empBaseInfo); |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public IPage<EmpBaseInfo> baseInfoList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpBaseInfo> page = new Page<EmpBaseInfo>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpBaseInfo> iPage =null; |
| | | List<SysConfig> sysConfig=this.baseMapper.sysConfig(); |
| | | String manOld=""; |
| | | String womanOld=""; |
| | | if(sysConfig.size()>0){ |
| | | manOld=sysConfig.get(0).getConfigValue(); |
| | | womanOld=sysConfig.get(1).getConfigValue(); |
| | | } |
| | | if("1".equals(number)){ //在职员工 |
| | | iPage = this.empBaseInfoMapper.zzbaseInfoList(page, index,btime,etime,name); |
| | | }else if("2".equals(number)){ //新进员工 |
| | | iPage = this.empBaseInfoMapper.xjbaseInfoList(page, index,btime,etime,name); |
| | | }else if("3".equals(number)){ //正式员工 |
| | | iPage = this.empBaseInfoMapper.zsbaseInfoList(page, index,btime,etime,name); |
| | | }else if("4".equals(number)){ //临时员工 |
| | | iPage = this.empBaseInfoMapper.lsbaseInfoList(page, index,btime,etime,name); |
| | | }else if("5".equals(number)){ //超龄员工 |
| | | iPage = this.empBaseInfoMapper.clbaseInfoList(page, index,btime,etime,name,manOld,womanOld); |
| | | }else if("6".equals(number)){ //离职员工总数 |
| | | iPage = this.empBaseInfoMapper.lzbaseInfoList(page, index,btime,etime,name); |
| | | }else if("7".equals(number)){ //辞职申请人数 |
| | | iPage = this.empBaseInfoMapper.cjbaseInfoList(page, index,btime,etime,name); |
| | | }else if("8".equals(number) || "9".equals(number) || "10".equals(number)){ //正常离职人数 ,自动离职人数 ,公司辞退人数 |
| | | iPage = this.empBaseInfoMapper.zcbaseInfoList(page, index,btime,etime,name,number); |
| | | }else if("11".equals(number)){ //身份证到期 |
| | | iPage = this.empBaseInfoMapper.sfzbaseInfoList(page, index,btime,etime,name); |
| | | } |
| | | //设置部门 |
| | | List<EmpBaseInfo> list = setDeptName(iPage.getRecords()); |
| | | List<DicItem> dicItems = CastUtil.castList(redisService.get("dicItems"), DicItem.class); |
| | | list.forEach(p -> { |
| | | p.setSexName("1".equals(p.getSex()) ? "男" : "女"); |
| | | if(StringUtils.isNotBlank(p.getEmpType())){ |
| | | p.setEmpTypeName("1".equals(p.getEmpType()) ? "正式工" : "临时工"); |
| | | } |
| | | if(StringUtils.isNotBlank(p.getDimissionType())){ |
| | | if("1".equals(p.getDimissionType())){ |
| | | p.setDimissionTypeName("正常离职"); |
| | | }else if("2".equals(p.getDimissionType())){ |
| | | p.setDimissionTypeName("自动离职"); |
| | | }else if("3".equals(p.getDimissionType())){ |
| | | p.setDimissionTypeName("公司劝退"); |
| | | }else if("4".equals(p.getDimissionType())){ |
| | | p.setDimissionTypeName("公司辞退"); |
| | | }else if("5".equals(p.getDimissionType())){ |
| | | p.setDimissionTypeName("试用期内"); |
| | | } |
| | | } |
| | | p.setInsuranceTypeName("1".equals(p.getInsuranceType()) ? "(深户)五险一档" : "(非深户)五险一档"); |
| | | p.setArchivesStatusName("0".equals(p.getArchivesStatus()) ? "未移交" : "已移交"); |
| | | // 设置民族 |
| | | p.setNationName(dicItems.stream() |
| | | .filter(k -> DicCode.NATION.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getNation())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("汉族")); |
| | | // 设置政治面貌 |
| | | p.setPoliticsName(dicItems.stream() |
| | | .filter(k -> DicCode.PLITICAL.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getPolitics())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("群众")); |
| | | // 设置婚姻状况 |
| | | p.setMarriageName(dicItems.stream() |
| | | .filter(k -> DicCode.MARRIAGE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getMarriage())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("未婚")); |
| | | // 设置学历 |
| | | p.setEducationName(dicItems.stream() |
| | | .filter(k -> DicCode.EDUCATION.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getEducation())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("无学历")); |
| | | // 设置籍贯 |
| | | p.setNativePlaceName(dicItems.stream() |
| | | .filter(k -> DicCode.NATIVEPLACE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getNativePlace())) |
| | | .findFirst() |
| | | .map(DicItem::getDicItemName) |
| | | .orElse("未知")); |
| | | }); |
| | | iPage.setRecords(list); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpBaseInfo> baseInfoHeList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpBaseInfo> page = new Page<EmpBaseInfo>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpBaseInfo> iPage =null; |
| | | if("11".equals(number) || "13".equals(number) || "14".equals(number)){ //有效合同 ,新签合同,续签合同 |
| | | iPage = this.empBaseInfoMapper.yxbaseInfoList(page, index,btime,etime,name,number); |
| | | }else if("12".equals(number)){ //到期合同 |
| | | iPage = this.empBaseInfoMapper.dqbaseInfoList(page, index,btime,etime,name); |
| | | }else if("15".equals(number)){ //解除合同 |
| | | iPage = this.empBaseInfoMapper.jcseInfoList(page, index,btime,etime,name); |
| | | } |
| | | //设置部门 |
| | | List<EmpBaseInfo> list = setDeptName(iPage.getRecords()); |
| | | list.forEach(p -> { |
| | | if("1".equals(p.getContractStatus())){ |
| | | p.setContractStatus("新签"); |
| | | }else if("2".equals(p.getContractStatus())){ |
| | | p.setContractStatus("续签"); |
| | | }else if("3".equals(p.getContractStatus())){ |
| | | p.setContractStatus("解除"); |
| | | }else if("4".equals(p.getContractStatus())){ |
| | | p.setContractStatus("到期"); |
| | | } |
| | | }); |
| | | iPage.setRecords(list); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpDimissionAttend> empBaseInfoCqList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpDimissionAttend> page = new Page<EmpDimissionAttend>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpDimissionAttend> iPage =null; |
| | | //q出勤人数 员工加班 员工旷工 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoCqList(page, index,btime,etime,name,number); |
| | | |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpLeaveInfo> empBaseInfoQjList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpLeaveInfo> page = new Page<EmpLeaveInfo>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpLeaveInfo> iPage =null; |
| | | //员工请假 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoQjList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpPhysicalExam> empBaseInfoTjList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpPhysicalExam> page = new Page<EmpPhysicalExam>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpPhysicalExam> iPage =null; |
| | | //员工体检 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoTjList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpLaborTrouble> empBaseInfoLzList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpLaborTrouble> page = new Page<EmpLaborTrouble>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpLaborTrouble> iPage =null; |
| | | //劳资案件 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoLzList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpJobChange> empBaseInfoTgList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpJobChange> page = new Page<EmpJobChange>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpJobChange> iPage =null; |
| | | //调岗 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoTgList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpOccupational> empBaseInfoGsList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpOccupational> page = new Page<EmpOccupational>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpOccupational> iPage =null; |
| | | //工伤案件 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoGsList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpAccidentCases> empBaseInfoYwList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpAccidentCases> page = new Page<EmpAccidentCases>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpAccidentCases> iPage =null; |
| | | //意外险案件 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoYwList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpInsurance> empBaseInfoSbList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpInsurance> page = new Page<EmpInsurance>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpInsurance> iPage =null; |
| | | //社保 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoSbList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpUnemployment> empBaseInfoSyjList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpUnemployment> page = new Page<EmpUnemployment>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpUnemployment> iPage =null; |
| | | //失业金 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoSyjList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public IPage<EmpBadRecord> empBaseInfoBlList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { |
| | | Page<EmpBadRecord> page = new Page<EmpBadRecord>(new Long(pageNum), new Long(pageSize)); |
| | | IPage<EmpBadRecord> iPage =null; |
| | | //不良记录 |
| | | iPage = this.empBaseInfoMapper.empBaseInfoBlList(page, index,btime,etime,name,number); |
| | | return iPage; |
| | | } |
| | | |
| | | @Override |
| | | public Map<String, Object> countBaseInfoList(String index, String btime, String etime) { |
| | | List<SysConfig> sysConfig=this.baseMapper.sysConfig(); |
| | | String manOld=""; |
| | | String womanOld=""; |
| | | if(sysConfig.size()>0){ |
| | | manOld=sysConfig.get(0).getConfigValue(); |
| | | womanOld=sysConfig.get(1).getConfigValue(); |
| | | } |
| | | //在职员工,正式员工,临时员工,超龄员工 |
| | | Map<String, Object> stringObjectMap = this.baseMapper.countBaseInfoList(index,btime,etime,manOld,womanOld); |
| | | //正常离职,自动离职,公司辞退 判断条件创建日期 |
| | | Map<String, Object> zclzObjectMap =this.baseMapper.countZcygBaseInfoList(index,btime,etime); |
| | | if(zclzObjectMap!=null){ |
| | | stringObjectMap.put("zclz",zclzObjectMap.get("zclz").toString()); |
| | | stringObjectMap.put("zdlz",zclzObjectMap.get("zdlz").toString()); |
| | | stringObjectMap.put("gsct",zclzObjectMap.get("gsct").toString()); |
| | | } |
| | | //新进员工 判断条件入职日期 |
| | | Integer xjygObjectMap =this.baseMapper.countXjygBaseInfoList(index,btime,etime); |
| | | if(xjygObjectMap!=null){ |
| | | stringObjectMap.put("xjyg",xjygObjectMap); |
| | | } |
| | | |
| | | //离职员工总数 |
| | | Integer empStatus = this.baseMapper.selectCount(new QueryWrapper<EmpBaseInfo>().eq("empStatus", 1)); |
| | | if(empStatus!=null){ |
| | | stringObjectMap.put("lzyg",empStatus); |
| | | } |
| | | //解除合同 判断条件离职申请日期 |
| | | Map<String, Object> lzygObjectMap =this.baseMapper.countLzygBaseInfoList(index,btime,etime); |
| | | if(lzygObjectMap!=null){ |
| | | stringObjectMap.put("jcht",lzygObjectMap.get("jcht").toString()); |
| | | } |
| | | //辞职申请员工总数 判断条件辞职申请日期 |
| | | Integer czygObjectMap =this.baseMapper.countCzygBaseInfoList(index,btime,etime); |
| | | if(czygObjectMap!=null){ |
| | | stringObjectMap.put("czyg",czygObjectMap); |
| | | } |
| | | //有效合同 判断条件合同签订日期 |
| | | Map<String, Object> yxhtObjectMap =this.baseMapper.countYxhtBaseInfoList(index,btime,etime); |
| | | if(yxhtObjectMap!=null){ |
| | | stringObjectMap.put("yxht",yxhtObjectMap.get("yxht").toString()); |
| | | } |
| | | //新签合同,续签合同 判断条件合同签订日期 |
| | | Map<String, Object> xqhtObjectMap =this.baseMapper.countXqhtBaseInfoList(index,btime,etime); |
| | | if(yxhtObjectMap!=null){ |
| | | stringObjectMap.put("xinqht",xqhtObjectMap.get("xinqht").toString()); |
| | | stringObjectMap.put("xqht",xqhtObjectMap.get("xqht").toString()); |
| | | } |
| | | //到期合同 判断条件合同结束时间 |
| | | Integer dqhtObjectMap =this.baseMapper.countDqhtBaseInfoList(index,btime,etime); |
| | | if(dqhtObjectMap!=null){ |
| | | stringObjectMap.put("dqht",dqhtObjectMap); |
| | | } |
| | | |
| | | //出勤人数,员工加班,员工旷工 判断条件考勤月份 本年,本月 |
| | | Map<String, Object> cqrsObjectMap =this.baseMapper.countCqrsBaseInfoList(index,btime,etime); |
| | | if(cqrsObjectMap!=null){ |
| | | stringObjectMap.put("cqrs",cqrsObjectMap.get("cqrs").toString()); |
| | | stringObjectMap.put("ygjb",cqrsObjectMap.get("ygjb").toString()); |
| | | stringObjectMap.put("ygkg",cqrsObjectMap.get("ygkg").toString()); |
| | | } |
| | | |
| | | //员工请假 判断条件到岗时间 |
| | | Integer ygqjObjectMap =this.baseMapper.countYgqjBaseInfoList(index,btime,etime); |
| | | if(ygqjObjectMap!=null){ |
| | | stringObjectMap.put("ygqj",ygqjObjectMap); |
| | | } |
| | | |
| | | //劳资案件 判断条件仲裁日期 |
| | | Integer lzajObjectMap =this.baseMapper.countLzajBaseInfoList(index,btime,etime); |
| | | if(lzajObjectMap!=null){ |
| | | stringObjectMap.put("lzaj",lzajObjectMap); |
| | | } |
| | | //工伤案件,意外险案件 判断条件受伤日期 |
| | | Map<String, Object> gsajObjectMap =this.baseMapper.countGsajBaseInfoList(index,btime,etime); |
| | | if(gsajObjectMap!=null){ |
| | | stringObjectMap.put("gsaj",gsajObjectMap.get("gsaj").toString()); |
| | | stringObjectMap.put("ywxaj",gsajObjectMap.get("ywxaj").toString()); |
| | | } |
| | | //社保申请 判断条件社保申请日期 |
| | | Integer sbsqObjectMap =this.baseMapper.countSbsqBaseInfoList(index,btime,etime); |
| | | if(sbsqObjectMap!=null){ |
| | | stringObjectMap.put("sbsq",sbsqObjectMap); |
| | | } |
| | | //失业金领取 判断条件失业金申请日期 |
| | | Integer syjObjectMap =this.baseMapper.countSyjBaseInfoList(index,btime,etime); |
| | | if(syjObjectMap!=null){ |
| | | stringObjectMap.put("syj",syjObjectMap); |
| | | } |
| | | //员工体检 判断条件体检日期 |
| | | Integer ygtjObjectMap =this.baseMapper.countYgtjBaseInfoList(index,btime,etime); |
| | | if(ygtjObjectMap!=null){ |
| | | stringObjectMap.put("ygtj",ygtjObjectMap); |
| | | } |
| | | //身份证到期 判断条件身份证有效时间 |
| | | Integer sfzObjectMap =this.baseMapper.countSfzBaseInfoList(index,btime,etime); |
| | | if(sfzObjectMap!=null){ |
| | | stringObjectMap.put("sfz",sfzObjectMap); |
| | | } |
| | | |
| | | //员工调岗 判断条件身份证有效时间 |
| | | Integer ygtgObjectMap =this.baseMapper.countYgtgBaseInfoList(index,btime,etime); |
| | | if(ygtgObjectMap!=null){ |
| | | stringObjectMap.put("ygtg",ygtgObjectMap); |
| | | } |
| | | |
| | | //不良记录 判断条件身份证有效时间 |
| | | Integer bljlObjectMap =this.baseMapper.countBljlBaseInfoList(index,btime,etime); |
| | | if(bljlObjectMap!=null){ |
| | | stringObjectMap.put("bljl",bljlObjectMap); |
| | | } |
| | | return stringObjectMap; |
| | | } |
| | | } |