sunsail云平台后端管理项目工程
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
luoyb
2021-03-12 a704eb0aced975b55f39d71591ef87f2539e1263 
 febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpBaseInfoServiceImpl.java


@@ -1,57 +1,48 @@


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.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.constant.FebsConstant;


import cc.mrbird.febs.common.core.entity.constant.StringConstant;


import cc.mrbird.febs.common.core.entity.system.Dept;


import cc.mrbird.febs.common.core.entity.system.DicItem;


import cc.mrbird.febs.common.core.entity.system.Position;


import cc.mrbird.febs.common.core.entity.system.SysConfig;


import cc.mrbird.febs.common.core.exception.FebsException;


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.common.core.utils.*;


import cc.mrbird.febs.common.redis.service.RedisService;


import cc.mrbird.febs.server.hr.entity.*;


import cc.mrbird.febs.server.hr.feign.IRemoteDeptService;


import cc.mrbird.febs.server.hr.feign.IRemoteDicItemService;


import cc.mrbird.febs.server.hr.feign.IRemotePositionService;


import cc.mrbird.febs.server.hr.feign.IRemoteUserService;


import cc.mrbird.febs.server.hr.mapper.EmpContractInfoMapper;


import cc.mrbird.febs.server.hr.mapper.*;


import cc.mrbird.febs.server.hr.properties.FebsServerHrProperties;


import cc.mrbird.febs.server.hr.service.IEmpContractInfoService;


import cc.mrbird.febs.server.hr.service.IEmpBaseInfoService;


import cc.mrbird.febs.server.hr.service.IEmpDimissionLogService;


import cc.mrbird.febs.server.hr.service.IEmpJobChangeService;


import cn.hutool.core.date.DateUnit;


import cc.mrbird.febs.server.hr.util.PoiExportExcel;


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 org.springframework.validation.annotation.Validated;


import org.apache.commons.lang3.StringUtils;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Propagation;


import org.springframework.transaction.annotation.Transactional;




import javax.servlet.http.HttpServletResponse;


import java.io.FileInputStream;


import java.io.IOException;


import java.io.InputStream;


import java.io.OutputStream;


import java.util.*;


import java.util.function.Consumer;


import java.util.stream.Collectors;




/**


 * name:EmpBaseinfo


@@ -74,9 +65,20 @@


    private final EmpContractInfoMapper empContractInfoMapper;


    private final FebsServerHrProperties properties;


    private final IRemoteDeptService remoteDeptService;


    private final String operatorId = Optional.ofNullable(FebsUtil.getCurrentUser())


            .map(u -> u.getUserId().toString())


            .orElse("1");


    private final EmpWorkExperienceMapper empWorkExperienceMapper;


    private final EmpPhysicalExamMapper empPhysicalExamMapper;


    private final EmpJobChangeMapper empJobChangeMapper;


    private final EmpLeaveInfoMapper empLeaveInfoMapper;


    private final EmpUnemploymentMapper empUnemploymentMapper;


    private final EmpDimissionAttendMapper empDimissionAttendMapper;


    private final EmpInsuranceMapper empInsuranceMapper;


    private final EmpAccidentCasesMapper empAccidentCasesMapper;


    private final EmpLaborTroubleMapper empLaborTroubleMapper;


    private final EmpBadRecordMapper empBadRecordMapper;


    private final EmpRemarkInfoMapper empRemarkInfoMapper;


    private final IRemoteDicItemService remoteDicItemService;


    private final EmpOccupationalMapper empOccupationalMapper;


    private final IRemotePositionService remotePositionService;




    @Override


    public IPage<EmpBaseInfo> findEmpBaseInfos(QueryRequest request, EmpBaseInfo empBaseInfo) {


@@ -86,27 +88,30 @@


    @Override


    public IPage<EmpBaseInfo> findZsEmpBaseInfos(QueryRequest request, EmpBaseInfo empBaseInfo) {


        Page<EmpBaseInfo> page = new Page<>(request.getPageNum(), request.getPageSize());


        SortUtil.handlePageSort(request, page, "createTime", FebsConstant.ORDER_DESC, true);


        IPage<EmpBaseInfo> iPage = empBaseInfoMapper.selectPageVo(page, createQueryWrapper(empBaseInfo));


        //设置部门


        List<EmpBaseInfo> list = setDeptName(iPage.getRecords());


        // List<EmpBaseInfo> list = setDeptName(iPage.getRecords());


        List<EmpBaseInfo> list = iPage.getRecords();


        List<DicItem> 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.setEmpStatusName("0".equals(p.getEmpStatus()) ? "在职" : "离职");


            //保险类型


            p.setInsuranceTypeName(dicItems.stream()


                    .filter(k -> DicCode.INSURANCETYPE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getInsuranceType()))


                    .findFirst()


                    .map(DicItem::getDicItemName)


                    .orElse("汉族"));


                    .orElse("未知"));


            //员工类别


            p.setEmpTypeName(dicItems.stream()


                    .filter(k -> DicCode.EMPTYPE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getEmpType()))


                    .findFirst()


                    .map(DicItem::getDicItemName)


                    .orElse("汉族"));


                    .orElse("正式工"));


            // 设置民族


            p.setNationName(dicItems.stream()


                    .filter(k -> DicCode.NATION.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getNation()))


@@ -137,6 +142,16 @@


                    .findFirst()


                    .map(DicItem::getDicItemName)


                    .orElse("未知"));


            p.setEntryTypeName(dicItems.stream()


                    .filter(k -> DicCode.IN_OUT_TYPE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getEntryType()))


                    .findFirst()


                    .map(DicItem::getDicItemName)


                    .orElse(""));


            p.setDimissionTypeName(dicItems.stream()


                    .filter(k -> DicCode.IN_OUT_TYPE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getDimissionType()))


                    .findFirst()


                    .map(DicItem::getDicItemName)


                    .orElse(""));


        });


        iPage.setRecords(list);


        return iPage;


@@ -152,6 +167,7 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public void createEmpBaseInfo(EmpBaseInfo empBaseInfo) {


        String operatorId = Optional.of(FebsUtil.getUserId()).orElse("1");


        EmpBaseInfo dbInfo = this.getEmpBaseInfo(empBaseInfo);


        if (dbInfo == null) {


            empBaseInfo.setEmpId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE));


@@ -173,6 +189,7 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public void updateEmpBaseInfo(EmpBaseInfo empBaseInfo) {


        String operatorId = Optional.of(FebsUtil.getUserId()).orElse("1");


        if (StrUtil.isNotBlank(empBaseInfo.getImagePath())) {


            String path = properties.getEmpBaseInfoPath() + empBaseInfo.getEmpId() + ".png";


            if (MyUtil.generateImage(empBaseInfo.getImagePath(), path)) {


@@ -209,6 +226,7 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public void logicDelEmpBaseInfo(String ids) {


        String operatorId = Optional.of(FebsUtil.getUserId()).orElse("1");


        String[] str = ids.split(",");


        List<String> list = new ArrayList<>(Arrays.asList(str));


        empBaseInfoMapper.logicDeleteByIds(list, operatorId);


@@ -232,6 +250,11 @@


                    .findFirst()


                    .map(Dept::getDeptName)


                    .orElse(""));


            empBaseInfo.setAllDeptName(depts.stream()


                    .filter(k -> k.getDeptId().equals(empBaseInfo.getDeptId()))


                    .findFirst()


                    .map(Dept::getAllDeptName)


                    .orElse(""));


        }


        return empBaseInfoList;


    }


@@ -241,18 +264,16 @@


        QueryWrapper<EmpBaseInfo> queryWrapper = new QueryWrapper<>();


        queryWrapper.lambda().eq(EmpBaseInfo::getEmpNumb, empBaseInfo.getEmpNumb())


                .ne(EmpBaseInfo::getDelFlag, 1);


        if (empBaseInfo.getEmpId()!=null) {


        if (empBaseInfo.getEmpId() != null) {


            queryWrapper.lambda().ne(EmpBaseInfo::getEmpId, empBaseInfo.getEmpId());


        }




        if (this.count(queryWrapper) <= 0) {


            return false;


        }


        return true;


        return this.count(queryWrapper) > 0;


    }




    @Override


    public boolean momentToNormal(String ids) {


        String operatorId = Optional.of(FebsUtil.getUserId()).orElse("1");


        String[] str = ids.split(",");


        List<String> list = new ArrayList<>(Arrays.asList(str));


        return empBaseInfoMapper.momentToNormal(list, operatorId) > 0;


@@ -278,6 +299,7 @@


     */


    @Override


    public boolean closeEmpArchives(EmpDimissionLog empDimissionLog) {


        String operatorId = Optional.of(FebsUtil.getUserId()).orElse("1");


        String[] str = empDimissionLog.getEmpIds().split(",");


        List<String> list = new ArrayList<>(Arrays.asList(str));


        String[] strDate = empDimissionLog.getEntryDates().split(",");


@@ -307,7 +329,6 @@


            switch (flag) {


                case 1:


                    //解除合同




                    empContractInfoMapper.terminateContract(new ArrayList<>(Arrays.asList(empDimissionLog.getEmpIds().split(StringConstant.COMMA))), operatorId);


                    break;


                case 2:


@@ -334,6 +355,7 @@


     */


    @Override


    public boolean changeEmpJob(EmpJobChange empJobChange) {


        String operatorId = Optional.of(FebsUtil.getUserId()).orElse("1");


        String[] str = empJobChange.getEmpIds().split(",");


        List<String> list = new ArrayList<>(Arrays.asList(str));


        String[] strName = empJobChange.getEmpNames().split(",");


@@ -377,7 +399,7 @@


     */


    @Override


    @Transactional(rollbackFor = Exception.class)


    public void importEmpBaseInfo(List<List<Object>> listObject, List<String> returnList) {


    public void importEmpBaseInfo(List<List<Object>> listObject, List<String> returnList,List<DicItem> dicItems) {


        for (List<Object> list : listObject) {


            if (list.size() == 0) {


                continue;


@@ -390,49 +412,121 @@


            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<Dept> depts = CastUtil.castList(redisService.get("depts"), Dept.class);


            empBaseInfo.setDeptName(list.get(3).toString());


            Dept dept = depts.stream().filter(d -> d.getDeptName().equals(list.get(3).toString())).findFirst().orElse(null);


            empBaseInfo.setDeptName(list.get(2).toString());


            Dept dept = depts.stream().filter(d -> d.getDeptName().equals(list.get(2).toString())).findFirst().orElse(null);


            if (null == dept) {


                returnList.add(StrUtil.format("导入员工基本信息异常: 出现位置第{}行, 原因:{}部门不存在", listObject.indexOf(list) + 1, list.get(3).toString()));


                returnList.add(StrUtil.format("导入员工基本信息异常: 出现位置第{}行, 原因:{}部门不存在", listObject.indexOf(list) + 1, list.get(2).toString()));


                continue;


            }




            empBaseInfo.setAllDeptName(dept.getAllDeptName());




            empBaseInfo.setDeptId(dept.getDeptId());


            empBaseInfo.setJobName(list.get(4).toString());


            empBaseInfo.setEmpType(list.get(5).toString());


            List<Position> positionList = CastUtil.castList(redisService.get("position"), Position.class);


            if (null==positionList){


                positionList = remotePositionService.setPositionRedis();


                if (null==positionList){


                    returnList.add(StrUtil.format("导入员工基本信息异常: 出现位置第{}行, 原因:{}获取岗位为空，请设置岗位", listObject.indexOf(list) + 1, list.get(3).toString()));


                    continue;


                }


            }


            Position position = positionList.stream().filter(d -> d.getPositionName().equals(list.get(3).toString())).findFirst().orElse(null);


            if (null == position){


                returnList.add(StrUtil.format("导入员工基本信息异常: 出现位置第{}行, 原因:{}获取岗位为空", listObject.indexOf(list) + 1, list.get(3).toString()));


                continue;


            }


            empBaseInfo.setJobId(position.getPositionId());


            empBaseInfo.setJobName(list.get(3).toString());


            empBaseInfo.setEmpName(list.get(4).toString());


            empBaseInfo.setCertificateNumb(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()));




            //民族


            DicItem  dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"nation")&&StrUtil.equals(j.getDicItemName(),list.get(7).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setNation(dicItem.getDicItemCode());


            }


            empBaseInfo.setPolitics(list.get(11).toString());


            if (StringUtils.isNotBlank(list.get(12).toString())) {


                empBaseInfo.setEntryDate(DateUtil.parseDate(list.get(12).toString()));




            //婚姻状况


              dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"marriage")&&StrUtil.equals(j.getDicItemName(),list.get(8).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setMarriage(dicItem.getDicItemCode());


            }


            empBaseInfo.setEducation(list.get(13).toString());


            if (StringUtils.isNotBlank(list.get(14).toString())) {


                empBaseInfo.setSeniority(Integer.valueOf(list.get(14).toString()));




            if (StringUtils.isNotBlank(list.get(9).toString())) {


                empBaseInfo.setStature(Integer.valueOf(list.get(9).toString()));


            }


            empBaseInfo.setNativePlace(list.get(15).toString());


            empBaseInfo.setCensusAddress(list.get(16).toString());


            empBaseInfo.setCurrentAddress(list.get(17).toString());


            //政治面貌


            dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(), "plitical")&&StrUtil.equals(j.getDicItemName(),list.get(10).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setPolitics(dicItem.getDicItemCode());


            }




            if (StringUtils.isNotBlank(list.get(11).toString())) {


                empBaseInfo.setEntryDate(DateUtil.parseDate(list.get(11).toString()));


            }




            //最高学历


            dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"education")&&StrUtil.equals(j.getDicItemName(),list.get(12).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setEducation(dicItem.getDicItemCode());


            }




            if (StringUtils.isNotBlank(list.get(13).toString())) {


                empBaseInfo.setSeniority(Integer.valueOf(list.get(13).toString()));


            }




            //籍贯


            dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"nativePlace")&&StrUtil.equals(j.getDicItemName(),list.get(14).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setNativePlace(dicItem.getDicItemCode());


            }




            empBaseInfo.setCensusAddress(list.get(15).toString());


            empBaseInfo.setCurrentAddress(list.get(16).toString());




            dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"empType")&&StrUtil.equals(j.getDicItemName(),list.get(17).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setEmpType(dicItem.getDicItemCode());


            }




            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());


            //保险类型


            dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"insuranceType")&&StrUtil.equals(j.getDicItemName(),list.get(24).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setInsuranceType(dicItem.getDicItemCode());


            }




            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());


            //员工手册


            dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"handbookStatus")&&StrUtil.equals(j.getDicItemName(),list.get(28).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setHandbookStatus(dicItem.getDicItemCode());


            }




            //工作证


            dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"empCardStatus")&&StrUtil.equals(j.getDicItemName(),list.get(29).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setEmpCardStatus(dicItem.getDicItemCode());


            }






            empBaseInfo.setCertificateList(list.get(30).toString());


            empBaseInfo.setDelFlag(2);


            //入职类型


            dicItem =dicItems.parallelStream().filter(j->StrUtil.equalsIgnoreCase(j.getDicCode(),"lztype")&&StrUtil.equals(j.getDicItemName(),list.get(31).toString())).findFirst().orElse(null);


            if (null!=dicItem){


                empBaseInfo.setEntryType(dicItem.getDicItemCode());


            }


            empBaseInfo.setEmpStatus("0");


            this.save(empBaseInfo);


        }


@@ -692,7 +786,7 @@


        }




        //离职员工总数


        Integer empStatus = this.baseMapper.selectCount(new QueryWrapper<EmpBaseInfo>().eq("empStatus", 1));


        Integer empStatus = this.baseMapper.selectCount(new QueryWrapper<EmpBaseInfo>().eq("delFlag", 0).eq("empStatus", 1));


        if (empStatus != null) {


            stringObjectMap.put("lzyg", empStatus);


        }


@@ -806,30 +900,6 @@


        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;


    }




@@ -844,64 +914,102 @@


        //人员的状态，0-在职 1-离职 2-退休


        if (StringUtils.isNotBlank(empBaseInfo.getEmpStatus())) {


            queryWrapper.in("a.EmpStatus", empBaseInfo.getEmpStatus().split(","));


        } else {


            queryWrapper.in("a.EmpStatus", 0);


        }


        // 下面的条件就是人员的属性条件，条件之间是或的关系


        if (this.checkQueryCondition(empBaseInfo)) {


        if (StringUtils.isNotBlank(empBaseInfo.getEmpCardStatus())) {


            queryWrapper.in("a.empCardStatus", empBaseInfo.getEmpCardStatus().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getHandbookStatus())) {


            queryWrapper.in("a.handBookStatus", empBaseInfo.getHandbookStatus().split(","));


        }


        // 关键词查询，是或的关系


        if (StringUtils.isNotBlank(empBaseInfo.getBaseKey())) {


            queryWrapper.and(p -> {


                if (StringUtils.isNotBlank(empBaseInfo.getEmpNumb())) {


                    p.like("a.EmpNumb", empBaseInfo.getEmpNumb());


                }


                if (StringUtils.isNotBlank(empBaseInfo.getEmpName())) {


                    p.or().like("a.EmpName", empBaseInfo.getEmpName());


                }


                if (StringUtils.isNotBlank(empBaseInfo.getDeptName())) {


                    p.or().like("a.DeptName", empBaseInfo.getDeptName());


                }


                if (StringUtils.isNotBlank(empBaseInfo.getCertificateNumb())) {


                    p.or().like("a.CertificateNumb", empBaseInfo.getCertificateNumb());


                }


                if (StringUtils.isNotBlank(empBaseInfo.getEntryDateStr())) {


                    p.or().between("a.EntryDate", empBaseInfo.getEntryDateStr().split(",")[0], empBaseInfo.getEntryDateStr().split(",")[1]);


                }


                if (StringUtils.isNotBlank(empBaseInfo.getDimissionDateStr())) {


                    p.or().between("a.DimissionDate", empBaseInfo.getDimissionDateStr().split(",")[0], empBaseInfo.getDimissionDateStr().split(",")[1]);


                }


                if (StringUtils.isNotBlank(empBaseInfo.getSex())) {


                    p.or().in("a.Sex", empBaseInfo.getSex().split(","));


                }


                if (StringUtils.isNotBlank(empBaseInfo.getEducation())) {


                    p.or().in("a.Education", empBaseInfo.getEducation().split(","));


                }


                if (StringUtils.isNotBlank(empBaseInfo.getPolitics())) {


                    p.or().in("a.Politics", empBaseInfo.getPolitics().split(","));


                }


                if (StringUtils.isNotBlank(empBaseInfo.getAgeStr())) {


                    String[] ages = empBaseInfo.getAgeStr().split(",");


                    Consumer<QueryWrapper<EmpBaseInfo>> consumer = new Consumer<QueryWrapper<EmpBaseInfo>>() {


                        public void accept(QueryWrapper<EmpBaseInfo> wrapper) {


                            for (int i = 0; i < ages.length; i++) {


                                String ageBtn = ages[i];


                                wrapper.or().between("a.Age", ageBtn.split("-")[0], ageBtn.split("-")[1]);


                            }


                        }


                    };


                    p.or().and(consumer);


                }


                if (StringUtils.isNotBlank(empBaseInfo.getArchivesStatus())) {


                    p.or().in("a.ArchivesStatus", empBaseInfo.getArchivesStatus().split(","));


                }


                if (StringUtils.isNotBlank(empBaseInfo.getInsuranceType())) {


                    p.or().in("a.InsuranceType", empBaseInfo.getInsuranceType().split(","));


                }


                if (StringUtils.isNotBlank(empBaseInfo.getHandbookStatus())) {


                    p.or().in("a.HandbookStatus", empBaseInfo.getHandbookStatus().split(","));


                }


                if (StringUtils.isNotBlank(empBaseInfo.getEmpCardStatus())) {


                    p.or().in("a.EmpCardStatus", empBaseInfo.getEmpCardStatus().split(","));


                }


                p.like("a.EmpNumb", empBaseInfo.getBaseKey());


                p.or().like("a.allDeptName", empBaseInfo.getBaseKey());


                p.or().like("a.empName", empBaseInfo.getBaseKey());


                p.or().like("a.CertificateNumb", empBaseInfo.getBaseKey());


                p.or().like("a.archivesNumb", empBaseInfo.getBaseKey());


                p.or().like("a.stature", empBaseInfo.getBaseKey());


                p.or().like("a.seniority", empBaseInfo.getBaseKey());


                p.or().like("a.nativePlace", empBaseInfo.getBaseKey());


                p.or().like("a.censusAddress", empBaseInfo.getBaseKey());


                p.or().like("a.guardNumb", empBaseInfo.getBaseKey());


                p.or().like("a.telePhone", empBaseInfo.getBaseKey());


                p.or().like("a.socialNumb", empBaseInfo.getBaseKey());


                p.or().like("a.bankName", empBaseInfo.getBaseKey());


                p.or().like("a.bankNumb", empBaseInfo.getBaseKey());


                p.or().like("a.family", empBaseInfo.getBaseKey());


                p.or().like("a.certificateList", empBaseInfo.getBaseKey());


            });


        }




        if (StringUtils.isNotBlank(empBaseInfo.getEmpNumb())) {


            queryWrapper.like("a.EmpNumb", empBaseInfo.getEmpNumb());


        }


        if (StringUtils.isNotBlank(empBaseInfo.getEmpName())) {


            queryWrapper.like("a.EmpName", empBaseInfo.getEmpName());


        }


        if (StringUtils.isNotBlank(empBaseInfo.getDeptName())) {


            queryWrapper.like("a.allDeptName", empBaseInfo.getDeptName());


        }


        if (StringUtils.isNotBlank(empBaseInfo.getCertificateNumb())) {


            queryWrapper.like("a.CertificateNumb", empBaseInfo.getCertificateNumb());


        }


        if (StringUtils.isNotBlank(empBaseInfo.getEntryDateStr())) {


            queryWrapper.between("a.EntryDate", empBaseInfo.getEntryDateStr().split(",")[0], empBaseInfo.getEntryDateStr().split(",")[1]);


        }


        if (StringUtils.isNotBlank(empBaseInfo.getDimissionDateStr())) {


            queryWrapper.between("a.DimissionDate", empBaseInfo.getDimissionDateStr().split(",")[0], empBaseInfo.getDimissionDateStr().split(",")[1]);


        }


        if (StringUtils.isNotBlank(empBaseInfo.getSex())) {


            queryWrapper.in("a.Sex", empBaseInfo.getSex().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getEducation())) {


            queryWrapper.in("a.Education", empBaseInfo.getEducation().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getPolitics())) {


            queryWrapper.in("a.Politics", empBaseInfo.getPolitics().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getAgeStr())) {


            String[] ages = empBaseInfo.getAgeStr().split(",");


            Consumer<QueryWrapper<EmpBaseInfo>> consumer = new Consumer<QueryWrapper<EmpBaseInfo>>() {


                @Override


                public void accept(QueryWrapper<EmpBaseInfo> wrapper) {


                    for (int i = 0; i < ages.length; i++) {


                        String ageBtn = ages[i];


                        wrapper.or().between("a.Age", ageBtn.split("-")[0], ageBtn.split("-")[1]);


                    }


                }


            };


            queryWrapper.and(consumer);


        }


        if (StringUtils.isNotBlank(empBaseInfo.getArchivesStatus())) {


            queryWrapper.in("a.ArchivesStatus", empBaseInfo.getArchivesStatus().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getInsuranceType())) {


            queryWrapper.in("a.InsuranceType", empBaseInfo.getInsuranceType().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getHandbookStatus())) {


            queryWrapper.in("a.HandbookStatus", empBaseInfo.getHandbookStatus().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getEmpCardStatus())) {


            queryWrapper.in("a.EmpCardStatus", empBaseInfo.getEmpCardStatus().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getEmpType())) {


            queryWrapper.in("a.empType", empBaseInfo.getEmpType().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getEntryType())) {


            queryWrapper.in("a.entryType", empBaseInfo.getEntryType().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getDimissionType())) {


            queryWrapper.in("a.dimissionType", empBaseInfo.getDimissionType().split(","));


        }


        if (StringUtils.isNotBlank(empBaseInfo.getInOutType())) {


            queryWrapper.and(p->{


                p.in("a.dimissionType", empBaseInfo.getInOutType().split(","));


                p.or().in("a.entryType",empBaseInfo.getInOutType().split(","));


            });


            //queryWrapper.in("a.dimissionType", empBaseInfo.getDimissionType().split(","));


        }


        queryWrapper.in("c.dept_Id", remoteDeptService.userRightDepts().split(StringConstant.COMMA));


        return queryWrapper;


@@ -927,4 +1035,178 @@


        }




    }




    @Override


    public EmpBaseInfo getEmpBaseInfoByEmpNumb(String empNumb) {


        try {


            return this.getOne(new LambdaQueryWrapper<EmpBaseInfo>().eq(EmpBaseInfo::getEmpNumb, empNumb).ne(EmpBaseInfo::getDelFlag, 1));


        } catch (Exception e) {


            return null;


        }




    }




    @Override


    public void exportEmpAll(HttpServletResponse response, EmpBaseInfo empBaseinfo) throws IOException {


        //获取字典


        List<DicItem> dicItemList = remoteDicItemService.getAllDicitemsAll();


        Map<String, Object> map = new HashMap<>();




        List<Long> itemCode = dicItemList.stream().map(i -> i.getDicId()).distinct().collect(Collectors.toList());


        itemCode.stream().forEach(i -> {


            List<DicItem> dicItems = dicItemList.stream().filter(j -> j.getDicId().equals(i)).collect(Collectors.toList());


            Map<String, Object> itemMap = new HashMap<>();


            dicItems.stream().forEach(dicItem -> itemMap.put(dicItem.getDicItemCode(), dicItem.getDicItemName()));


            map.put(dicItems.get(0).getDicCode().toLowerCase(), itemMap);


        });


        List<String> sheetNames = new ArrayList<>();


        sheetNames.add("基本信息");


        //基本信息


        QueryRequest request = new QueryRequest();


        request.setPageSize(25535);


        request.setPageNum(1);


        List<EmpBaseInfo> exportList = this.findZsEmpBaseInfos(request, empBaseinfo).getRecords();


        List<Map<String, Object>> listMapDicItem = new ArrayList();


        listMapDicItem.add(map);


        String exportField = "archivesNumb, deptName, jobName, empName, certificateNumb, certificateValidity, sexName, nationName, age, marriageName, stature, birthdate, politicsName, empTypeName, educationName, nativePlaceName, censusAddress, currentAddress, guardNumb, returnReceipt, archivesStatusName, bankName, bankNumb, telePhone, entryDate, InsuranceTypeName, socialNumb, introducer, seniority, empCardStatusName, certificateList, urgencyPhone, handbookStatusName, family, empStatusName, dimissionDate";


        List<Map<String, Object>> allList = PoiExportExcel.getDataList(exportField, exportList, null);


        Page<EmpBaseInfo> page = new Page<>(request.getPageNum(), request.getPageSize());


        List<Long> empIds = exportList.stream().map(i -> i.getEmpId()).collect(Collectors.toList());




        //工作经历


        IPage<EmpWorkExperience> workExperienceIPage = empWorkExperienceMapper.selectPageVo(page, new QueryWrapper<EmpWorkExperience>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (workExperienceIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpWorkExperience.class);


            List<Map<String, Object>> allListEmpWork = PoiExportExcel.getDataList(exportField, workExperienceIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpWork.get(0));


            sheetNames.add("工作经历");


        }




        //体检信息


        IPage<EmpPhysicalExam> empPhysicalExamIPage = empPhysicalExamMapper.selectPageVo(page, new QueryWrapper<EmpPhysicalExam>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empPhysicalExamIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpWorkExperience.class);


            List<Map<String, Object>> allListEmpPhysical = PoiExportExcel.getDataList(exportField, empPhysicalExamIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpPhysical.get(0));


            sheetNames.add("体检信息");


        }




        //调岗记录


        IPage<EmpJobChange> jobChangeIPage = empJobChangeMapper.selectPageVoBean(page, new QueryWrapper<EmpJobChange>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (jobChangeIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpJobChange.class);


            List<Map<String, Object>> allListjobChangeI = PoiExportExcel.getDataList(exportField, jobChangeIPage.getRecords(), listMapDicItem);


            allList.add(allListjobChangeI.get(0));


            sheetNames.add("调岗记录");


        }




        //合同信息


        IPage<EmpContractInfo> empContractInfoIPage = empContractInfoMapper.selectPageVo(page, new QueryWrapper<EmpContractInfo>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empContractInfoIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpContractInfo.class);


            List<Map<String, Object>> allListEmpContractInfo = PoiExportExcel.getDataList(exportField, empContractInfoIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpContractInfo.get(0));


            sheetNames.add("合同信息");


        }




        //入离职记录


        IPage<EmpDimissionAttend> empDimissionAttendIPage = empDimissionAttendMapper.selectPageVo(page, new QueryWrapper<EmpDimissionAttend>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empDimissionAttendIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpDimissionAttend.class);


            List<Map<String, Object>> allListEmpDimissionAtt = PoiExportExcel.getDataList(exportField, empDimissionAttendIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpDimissionAtt.get(0));


            sheetNames.add("入离职记录");


        }




        //请假记录


        IPage<EmpLeaveInfo> empLeaveInfoIPage = empLeaveInfoMapper.selectPageVo(page, new QueryWrapper<EmpLeaveInfo>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empLeaveInfoIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpLeaveInfo.class);


            List<Map<String, Object>> allListEmpLoeaveInfo = PoiExportExcel.getDataList(exportField, empLeaveInfoIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpLoeaveInfo.get(0));


            sheetNames.add("请假记录");


        }






        //失业金领取


        IPage<EmpUnemployment> empUnemploymentIPage = empUnemploymentMapper.selectPageVo(page, new QueryWrapper<EmpUnemployment>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empUnemploymentIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpUnemployment.class);


            List<Map<String, Object>> allListEmpUnemployment = PoiExportExcel.getDataList(exportField, empUnemploymentIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpUnemployment.get(0));


            sheetNames.add("失业金领取");


        }




        //社保申请


        IPage<EmpInsurance> empInsuranceIPage = empInsuranceMapper.selectPageVo(page, new QueryWrapper<EmpInsurance>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empInsuranceIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpInsurance.class);


            List<Map<String, Object>> allListEmpInsurance = PoiExportExcel.getDataList(exportField, empInsuranceIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpInsurance.get(0));


            sheetNames.add("社保申请");


        }






        //意外险案件


        IPage<EmpAccidentCases> empAccidentCasesIPage = empAccidentCasesMapper.selectPageVo(page, new QueryWrapper<EmpInsurance>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empAccidentCasesIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpAccidentCases.class);


            List<Map<String, Object>> allListEmpAccidentCases = PoiExportExcel.getDataList(exportField, empAccidentCasesIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpAccidentCases.get(0));


            sheetNames.add("意外险案件");


        }




        //工伤案件


        IPage<EmpOccupational> empOccupationalIPage = empOccupationalMapper.selectPageVo(page, new QueryWrapper<EmpOccupational>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empOccupationalIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpOccupational.class);


            List<Map<String, Object>> allListEmpOccupational = PoiExportExcel.getDataList(exportField, empOccupationalIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpOccupational.get(0));


            sheetNames.add("工伤案件");


        }




        //劳资案件


        IPage<EmpLaborTrouble> empLaborTroubleIPage = empLaborTroubleMapper.selectPageVo(page, new QueryWrapper<EmpInsurance>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empLaborTroubleIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpLaborTrouble.class);


            List<Map<String, Object>> allListEmpLaborTrouble = PoiExportExcel.getDataList(exportField, empLaborTroubleIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpLaborTrouble.get(0));


            sheetNames.add("劳资案件");


        }






        //不良记录


        IPage<EmpBadRecord> empBadRecordIPage = empBadRecordMapper.selectPageVo(page, new QueryWrapper<EmpInsurance>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empBadRecordIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpBadRecord.class);


            List<Map<String, Object>> allListEmpBadRecord = PoiExportExcel.getDataList(exportField, empBadRecordIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpBadRecord.get(0));


            sheetNames.add("不良记录");


        }






        //备注信息


        IPage<EmpRemarkInfo> empRemarkInfoIPage = empRemarkInfoMapper.selectPageVo(page, new QueryWrapper<EmpRemarkInfo>().in("a.empId", empIds).ne("a.delFlag", 1));


        if (empRemarkInfoIPage.getRecords().size() != 0) {


            exportField = FebsUtil.reflectAnnotation(EmpRemarkInfo.class);


            List<Map<String, Object>> allListEmpRemarkInfo = PoiExportExcel.getDataList(exportField, empRemarkInfoIPage.getRecords(), listMapDicItem);


            allList.add(allListEmpRemarkInfo.get(0));


            sheetNames.add("备注信息");


        }






        boolean result = PoiExportExcel.exportCommonExcelMultiSheet(response, "在职员工列表", allList, sheetNames);


    }




    @Override


    public boolean verifyCertificateNumb(EmpBaseInfo empBaseInfo) {


        QueryWrapper<EmpBaseInfo> queryWrapper = new QueryWrapper<>();


        queryWrapper.lambda().eq(EmpBaseInfo::getCertificateNumb, empBaseInfo.getCertificateNumb())


                .ne(EmpBaseInfo::getDelFlag, 1);;


        if (empBaseInfo.getEmpId()!=null) {


            queryWrapper.lambda().ne(EmpBaseInfo::getEmpId, empBaseInfo.getEmpId());


        }




        return this.count(queryWrapper) > 0;


    }


}