package cc.mrbird.febs.server.hr.service.impl; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.InputStream; import java.io.OutputStream; import java.util.*; import java.util.function.Consumer; import cc.mrbird.febs.common.core.entity.system.SysConfig; import cc.mrbird.febs.common.core.utils.MyUtil; import cc.mrbird.febs.server.hr.entity.EmpDimissionLog; import cc.mrbird.febs.server.hr.entity.EmpJobChange; import cc.mrbird.febs.server.hr.feign.IRemoteUserService; import cc.mrbird.febs.server.hr.properties.FebsServerHrProperties; 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 cn.hutool.core.util.StrUtil; 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; import org.springframework.util.FileSystemUtils; import javax.servlet.http.HttpServletResponse; /** * 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 implements IEmpBaseInfoService { private final RedisService redisService; private final IRemoteUserService iRemoteUserService; private final EmpBaseInfoMapper empBaseInfoMapper; private final IEmpDimissionLogService dimissionLogService; private final IEmpJobChangeService jobChangeService; private final FebsServerHrProperties properties; private final String operatorId = Optional.ofNullable(FebsUtil.getCurrentUser()) .map(u -> u.getUserId().toString()) .orElse("1"); @Override public IPage findEmpBaseInfos(QueryRequest request, EmpBaseInfo empBaseInfo) { return this.findZsEmpBaseInfos(request, empBaseInfo); } @Override public IPage findZsEmpBaseInfos(QueryRequest request, EmpBaseInfo empBaseInfo) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage iPage = this.page(page, createQueryWrapper(empBaseInfo)); //设置部门 List list = setDeptName(iPage.getRecords()); List dicItems = CastUtil.castList(redisService.get("dicItems"), DicItem.class); list.forEach(p -> { p.setSexName("1".equals(p.getSex()) ? "男" : "女"); p.setArchivesStatusName("0".equals(p.getArchivesStatus()) ? "未移交" : "已移交"); p.setEmpCardStatusName("1".equals(p.getEmpCardStatus()) ? "未发" : "已发"); p.setHandbookStatusName("1".equals(p.getHandbookStatus()) ? "未发" : "已发"); //保险类型 p.setInsuranceTypeName(dicItems.stream() .filter(k -> DicCode.INSURANCETYPE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getInsuranceType())) .findFirst() .map(DicItem::getDicItemName) .orElse("汉族")); //员工类别 p.setEmpTypeName(dicItems.stream() .filter(k -> DicCode.EMPTYPE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getEmpType())) .findFirst() .map(DicItem::getDicItemName) .orElse("汉族")); // 设置民族 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 findEmpBaseInfos(EmpBaseInfo empBaseInfo) { LambdaQueryWrapper 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()); } if (StrUtil.isNotBlank(empBaseInfo.getImagePath())) { String path = properties.getEmpBaseInfoPath() + empBaseInfo.getEmpId() + ".png"; if (MyUtil.generateImage(empBaseInfo.getImagePath(), path)) { empBaseInfo.setImagePath(empBaseInfo.getEmpId() + ".png"); } ; } empBaseInfo.setCreator(operatorId); empBaseInfo.setModifier(operatorId); this.saveOrUpdate(empBaseInfo); } @Override @Transactional(rollbackFor = Exception.class) public void updateEmpBaseInfo(EmpBaseInfo empBaseInfo) { if (StrUtil.isNotBlank(empBaseInfo.getImagePath())) { String path = properties.getEmpBaseInfoPath() + empBaseInfo.getEmpId() + ".png"; if (MyUtil.generateImage(empBaseInfo.getImagePath(), path)) { empBaseInfo.setImagePath(empBaseInfo.getEmpId() + ".png"); } } 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 wrapper = new LambdaQueryWrapper<>(); // TODO 设置删除条件 this.remove(wrapper); } /** * 根据Id批量逻辑删除记录 *

* 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 list = new ArrayList<>(Arrays.asList(str)); empBaseInfoMapper.logicDeleteByIds(list, operatorId); } /** * 设置员工部门名称 *

* date 2021-02-02 21:43 * * @param empBaseInfoList 人员信息列表 * @return java.util.List * @author: luoyibo */ private List setDeptName(List empBaseInfoList) { List 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 queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(EmpBaseInfo::getEmpNumb, empBaseInfo.getEmpNumb()); EmpBaseInfo tempEmpBaseInfo = this.getOne(queryWrapper); if (tempEmpBaseInfo == null) { return false; } return !empBaseInfo.getEmpNumb().equals(tempEmpBaseInfo.getEmpNumb()); } @Override public boolean momentToNormal(String ids) { String[] str = ids.split(","); List list = new ArrayList<>(Arrays.asList(str)); return empBaseInfoMapper.momentToNormal(list, operatorId) > 0; } @Override public EmpBaseInfo getEmpBaseInfo(EmpBaseInfo empBaseInfo) { QueryWrapper 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 * * @param empDimissionLog * @return boolean * @author: luoyibo */ @Override public boolean closeEmpArchives(EmpDimissionLog empDimissionLog) { String[] str = empDimissionLog.getEmpIds().split(","); List 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); } EmpBaseInfo empBaseInfo = this.getById(dimissionLog.getEmpId()); //禁用账户 iRemoteUserService.updateStatus(empBaseInfo.getCertificateNumb()); return empBaseInfoMapper.closeEmpArchives(list, empDimissionLog.getDimissionType(), empDimissionLog.getDimissionDate(), empDimissionLog.getRemark(), operatorId) > 0; } /** * 员工岗位变更 *

* date 2021-02-18 20:32 * * @param empJobChange 1 * @return boolean * @author: luoyibo */ @Override public boolean changeEmpJob(EmpJobChange empJobChange) { String[] str = empJobChange.getEmpIds().split(","); List 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 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> listObject) { for (List list : listObject) { EmpBaseInfo empBaseInfo = new EmpBaseInfo(); empBaseInfo.setEmpId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE)); empBaseInfo.setArchivesNumb(list.get(0).toString()); empBaseInfo.setEmpNumb(list.get(1).toString()); empBaseInfo.setEmpName(list.get(2).toString()); List depts = CastUtil.castList(redisService.get("depts"), Dept.class); empBaseInfo.setDeptName(list.get(3).toString()); Long deptId = depts.stream().filter(d -> d.getDeptName().equals(list.get(3).toString())).findFirst().get() .getDeptId(); empBaseInfo.setDeptId(deptId); empBaseInfo.setJobName(list.get(4).toString()); empBaseInfo.setEmpType(list.get(5).toString()); empBaseInfo.setSex("男".equals(list.get(6).toString()) ? "1" : "2"); empBaseInfo.setNation(list.get(7).toString()); empBaseInfo.setCertificateNumb(list.get(8).toString()); empBaseInfo.setMarriage(list.get(9).toString()); if (StringUtils.isNotBlank(list.get(10).toString())) { empBaseInfo.setStature(Integer.valueOf(list.get(10).toString())); } empBaseInfo.setPolitics(list.get(11).toString()); if (StringUtils.isNotBlank(list.get(12).toString())) { empBaseInfo.setEntryDate(DateUtil.parseDate(list.get(12).toString())); } empBaseInfo.setEducation(list.get(13).toString()); if (StringUtils.isNotBlank(list.get(14).toString())) { empBaseInfo.setSeniority(Integer.valueOf(list.get(14).toString())); } empBaseInfo.setNativePlace(list.get(15).toString()); empBaseInfo.setCensusAddress(list.get(16).toString()); empBaseInfo.setCurrentAddress(list.get(17).toString()); empBaseInfo.setGuardNumb(list.get(18).toString()); empBaseInfo.setReturnReceipt(list.get(19).toString()); empBaseInfo.setTelePhone(list.get(20).toString()); empBaseInfo.setIntroducer(list.get(21).toString()); empBaseInfo.setBankName(list.get(22).toString()); empBaseInfo.setBankNumb(list.get(23).toString()); empBaseInfo.setInsuranceType(list.get(24).toString()); empBaseInfo.setSocialNumb(list.get(25).toString()); empBaseInfo.setFamily(list.get(26).toString()); empBaseInfo.setUrgencyPhone(list.get(27).toString()); empBaseInfo.setHandbookStatus(list.get(28).toString()); empBaseInfo.setEmpCardStatus(list.get(29).toString()); empBaseInfo.setCertificateList(list.get(30).toString()); empBaseInfo.setEmpStatus("0"); this.save(empBaseInfo); } } @Override public void getImage(String empId, HttpServletResponse response) throws Exception { EmpBaseInfo empBaseInfo = this.getById(empId); if (StrUtil.isBlank(empBaseInfo.getImagePath())) { return; } String path = properties.getEmpBaseInfoPath() + empBaseInfo.getEmpId() + ".png"; try (InputStream inputStream = new FileInputStream(path); OutputStream out = response.getOutputStream()) { //byte数组用于存放图片字节数据 byte[] buff = new byte[inputStream.available()]; inputStream.read(buff); inputStream.close(); //设置发送到客户端的响应内容类型 response.setContentType("image/png"); out.write(buff); } } @Override public IPage baseInfoList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; List 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 list = setDeptName(iPage.getRecords()); List 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 baseInfoHeList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage 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 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 empBaseInfoCqList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //q出勤人数 员工加班 员工旷工 iPage = this.empBaseInfoMapper.empBaseInfoCqList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoQjList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //员工请假 iPage = this.empBaseInfoMapper.empBaseInfoQjList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoTjList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //员工体检 iPage = this.empBaseInfoMapper.empBaseInfoTjList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoLzList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //劳资案件 iPage = this.empBaseInfoMapper.empBaseInfoLzList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoTgList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //调岗 iPage = this.empBaseInfoMapper.empBaseInfoTgList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoGsList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //工伤案件 iPage = this.empBaseInfoMapper.empBaseInfoGsList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoYwList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //意外险案件 iPage = this.empBaseInfoMapper.empBaseInfoYwList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoSbList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //社保 iPage = this.empBaseInfoMapper.empBaseInfoSbList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoSyjList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //失业金 iPage = this.empBaseInfoMapper.empBaseInfoSyjList(page, index, btime, etime, name, number); return iPage; } @Override public IPage empBaseInfoBlList(String index, String btime, String etime, String pageSize, String pageNum, String number, String name) { Page page = new Page(new Long(pageNum), new Long(pageSize)); IPage iPage = null; //不良记录 iPage = this.empBaseInfoMapper.empBaseInfoBlList(page, index, btime, etime, name, number); return iPage; } @Override public Map countBaseInfoList(String index, String btime, String etime) { List sysConfig = this.baseMapper.sysConfig(); String manOld = ""; String womanOld = ""; if (sysConfig.size() > 0) { manOld = sysConfig.get(0).getConfigValue(); womanOld = sysConfig.get(1).getConfigValue(); } //在职员工,正式员工,临时员工,超龄员工 Map stringObjectMap = this.baseMapper.countBaseInfoList(index, btime, etime, manOld, womanOld); //正常离职,自动离职,公司辞退 判断条件创建日期 Map 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().eq("empStatus", 1)); if (empStatus != null) { stringObjectMap.put("lzyg", empStatus); } //解除合同 判断条件离职申请日期 Map 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 yxhtObjectMap = this.baseMapper.countYxhtBaseInfoList(index, btime, etime); if (yxhtObjectMap != null) { stringObjectMap.put("yxht", yxhtObjectMap.get("yxht").toString()); } //新签合同,续签合同 判断条件合同签订日期 Map 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 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 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; } /** * * 检查是否是带条件查询 * * date 2021-02-26 13:49 * @author: luoyibo * @param empBaseInfo 人员参数 * @return boolean */ private boolean checkQueryCondition(EmpBaseInfo empBaseInfo){ int hasCondition = 0; if (StringUtils.isNotBlank(empBaseInfo.getEmpNumb())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getEmpName())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getDeptName())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getCertificateNumb())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getEntryDateStr())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getDimissionDateStr())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getSex())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getEducation())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getPolitics())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getAgeStr())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getArchivesStatus())) { hasCondition = hasCondition|1; } if (StringUtils.isNotBlank(empBaseInfo.getInsuranceType())) { hasCondition = hasCondition|1; } return hasCondition==1; } private LambdaQueryWrapper createQueryWrapper(EmpBaseInfo empBaseInfo){ LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); //记录的状态,0-正常 1-删除 2-暂存 if(StringUtils.isNotBlank(empBaseInfo.getDelFlag().toString())) { queryWrapper.eq(EmpBaseInfo::getDelFlag, empBaseInfo.getDelFlag()); } else{ queryWrapper.eq(EmpBaseInfo::getDelFlag, 0); } //人员的状态,0-在职 1-离职 2-退休 if (StringUtils.isNotBlank(empBaseInfo.getEmpStatus())) { queryWrapper.in(EmpBaseInfo::getEmpStatus, empBaseInfo.getEmpStatus().split(",")); } else{ queryWrapper.in(EmpBaseInfo::getEmpStatus, 0); } // 下面的条件就是人员的属性条件,条件之间是或的关系 if(this.checkQueryCondition(empBaseInfo)){ queryWrapper.and(p -> { if (StringUtils.isNotBlank(empBaseInfo.getEmpNumb())) { p.like(EmpBaseInfo::getEmpNumb, empBaseInfo.getEmpNumb()); } if (StringUtils.isNotBlank(empBaseInfo.getEmpName())) { p.or().like(EmpBaseInfo::getEmpName, empBaseInfo.getEmpName()); } if (StringUtils.isNotBlank(empBaseInfo.getDeptName())) { p.or().like(EmpBaseInfo::getDeptName, empBaseInfo.getDeptName()); } if (StringUtils.isNotBlank(empBaseInfo.getCertificateNumb())) { p.or().like(EmpBaseInfo::getCertificateNumb, empBaseInfo.getCertificateNumb()); } if (StringUtils.isNotBlank(empBaseInfo.getEntryDateStr())) { p.or().between(EmpBaseInfo::getEntryDate, empBaseInfo.getEntryDateStr().split(",")[0], empBaseInfo.getEntryDateStr().split(",")[1]); } if (StringUtils.isNotBlank(empBaseInfo.getDimissionDateStr())) { p.or().between(EmpBaseInfo::getDimissionDate, empBaseInfo.getDimissionDateStr().split(",")[0], empBaseInfo.getDimissionDateStr().split(",")[1]); } if (StringUtils.isNotBlank(empBaseInfo.getSex())) { p.or().in(EmpBaseInfo::getSex, empBaseInfo.getSex().split(",")); } if (StringUtils.isNotBlank(empBaseInfo.getEducation())) { p.or().in(EmpBaseInfo::getEducation, empBaseInfo.getEducation().split(",")); } if (StringUtils.isNotBlank(empBaseInfo.getPolitics())) { p.or().in(EmpBaseInfo::getPolitics, empBaseInfo.getPolitics().split(",")); } if (StringUtils.isNotBlank(empBaseInfo.getAgeStr())) { String[] ages = empBaseInfo.getAgeStr().split(","); Consumer> consumer = new Consumer>() { @Override public void accept(LambdaQueryWrapper wrapper) { for (int i = 0; i < ages.length; i++) { String ageBtn = ages[i]; wrapper.or().between(EmpBaseInfo::getAge, ageBtn.split("-")[0], ageBtn.split("-")[1]); } } }; p.or().and(consumer); } if (StringUtils.isNotBlank(empBaseInfo.getArchivesStatus())) { p.or().in(EmpBaseInfo::getArchivesStatus, empBaseInfo.getArchivesStatus().split(",")); } if (StringUtils.isNotBlank(empBaseInfo.getInsuranceType())) { p.or().in(EmpBaseInfo::getInsuranceType, empBaseInfo.getInsuranceType().split(",")); } if (StringUtils.isNotBlank(empBaseInfo.getHandbookStatus())) { p.or().in(EmpBaseInfo::getHandbookStatus, empBaseInfo.getHandbookStatus().split(",")); } if (StringUtils.isNotBlank(empBaseInfo.getEmpCardStatus())) { p.or().in(EmpBaseInfo::getEmpCardStatus, empBaseInfo.getEmpCardStatus().split(",")); } }); } return queryWrapper; } }