产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liding
5 小时以前 dd69bfc1fb8e5e28dde754fab7f23bfb1a18faa5 
 src/main/java/com/ruoyi/staff/service/impl/StaffOnJobServiceImpl.java


@@ -7,6 +7,7 @@


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.common.exception.base.BaseException;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.common.utils.poi.ExcelUtil;


import com.ruoyi.dto.WordDateDto;


import com.ruoyi.project.system.domain.SysDept;


@@ -33,10 +34,7 @@


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.multipart.MultipartFile;




import java.io.File;


import java.io.FileOutputStream;


import java.io.OutputStreamWriter;


import java.io.StringWriter;


import java.io.*;


import java.nio.charset.StandardCharsets;


import java.time.Instant;


import java.time.LocalDate;


@@ -67,8 +65,9 @@




    //在职员工台账分页查询


    @Override


    public IPage<StaffOnJobDto> staffOnJobListPage(Page page, StaffOnJob staffOnJob) {


        return staffOnJobMapper.staffOnJobListPage(page,staffOnJob);


    public IPage<StaffOnJobDto> staffOnJobListPage(Page page, StaffOnJobDto staffOnJob) {


        IPage<StaffOnJobDto> staffOnJobDtoIPage = staffOnJobMapper.staffOnJobListPage(page, staffOnJob);


        return staffOnJobDtoIPage;


    }




    //新增入职


@@ -83,6 +82,7 @@


        }




        // 创建入职数据


        syncStudyInfoFromEducation(staffOnJobPrams);


        staffOnJobPrams.setContractExpireTime(staffOnJobPrams.getContractEndTime());


        staffOnJobPrams.setStaffState(1);


        staffOnJobMapper.insert(staffOnJobPrams);


@@ -108,7 +108,8 @@


        // 创建合同记录


        StaffContract staffContract = new StaffContract();


        staffContract.setStaffOnJobId(staffOnJobPrams.getId());


        staffContract.setContractTerm(staffOnJobPrams.getContractTerm());


        String contractTerm = staffOnJobPrams.getContractTerm();


        staffContract.setContractTerm(StringUtils.isNotEmpty(contractTerm) ? contractTerm : null);


        staffContract.setContractStartTime(staffOnJobPrams.getContractStartTime());


        staffContract.setContractEndTime(staffOnJobPrams.getContractEndTime());


        return staffContractMapper.insert(staffContract);


@@ -141,6 +142,7 @@


        // 绑定子表数据


        bingingStaffOnJobExtra(id,staffOnJobParams);


        // 更新员工数据


        syncStudyInfoFromEducation(staffOnJobParams);


        staffOnJobParams.setContractExpireTime(staffOnJobParams.getContractEndTime());


        return staffOnJobMapper.updateById(staffOnJobParams);


    }


@@ -158,6 +160,7 @@


                    .forEach(staff -> staff.setStaffOnJobId(id)); // 赋值


            staffEducationService.saveBatch(staffOnJobPrams.getStaffEducationList());


        }




        // 新增工作经历


        if(CollectionUtils.isNotEmpty(staffOnJobPrams.getStaffWorkExperienceList())){


            staffOnJobPrams.getStaffWorkExperienceList().stream()


@@ -172,6 +175,28 @@


                    .forEach(staff -> staff.setStaffOnJobId(id)); // 赋值


            staffEmergencyContactServiceImpl.saveBatch(staffOnJobPrams.getStaffEmergencyContactList());


        }


    }




    private void syncStudyInfoFromEducation(StaffOnJob staffOnJobPrams) {


        if (staffOnJobPrams == null || CollectionUtils.isEmpty(staffOnJobPrams.getStaffEducationList())) {


            if (staffOnJobPrams != null) {


                staffOnJobPrams.setFirstStudy("/");


                staffOnJobPrams.setProfession("/");


            }


            return;


        }


        Optional<StaffEducation> matchedEducation = staffOnJobPrams.getStaffEducationList().stream()


                .filter(Objects::nonNull)


                .filter(education -> StringUtils.isNotEmpty(education.getMajor()))


                .findFirst();


        if (matchedEducation.isPresent()) {


            StaffEducation education = matchedEducation.get();


            staffOnJobPrams.setFirstStudy(education.getEducation());


            staffOnJobPrams.setProfession(education.getMajor());


            return;


        }


        staffOnJobPrams.setFirstStudy("/");


        staffOnJobPrams.setProfession("/");


    }






@@ -294,41 +319,36 @@




    @Override


    @Transactional(rollbackFor = Exception.class)


    public Boolean importData(MultipartFile file) {


        try {


            ExcelUtil<StaffOnJobExcelDto> util = new ExcelUtil<>(StaffOnJobExcelDto.class);


            List<StaffOnJobExcelDto> staffOnJobs = util.importExcel(file.getInputStream());


            if (CollectionUtils.isEmpty(staffOnJobs)){


                return false;


            }


            // 获取所有部门数据


            List<SysDept> sysDepts = sysDeptMapper.selectList(Wrappers.<SysDept>lambdaQuery().eq(SysDept::getDelFlag, 0));


            // 获取所有角色数据


            List<SysRole> sysRoles = sysRoleMapper.selectRoleAll();


            staffOnJobs.forEach(staffOnJob -> {


                StaffOnJobDto staffOnJobDto = new StaffOnJobDto();


                BeanUtils.copyProperties(staffOnJob, staffOnJobDto);


                // 通过名称获取部门id


                staffOnJobDto.setSysDeptId(// ... existing code ...


                        sysDepts.stream()


                            .filter(dept -> dept.getDeptName() != null && dept.getDeptName().equals(staffOnJob.getSysDeptName()))


                            .findFirst()


                            .map(SysDept::getDeptId)


                            .orElse(null)


                        );


                // 通过名称获取角色id


                staffOnJobDto.setRoleId(sysRoles.stream()


                        .filter(role -> role.getRoleName() != null && role.getRoleName().equals(staffOnJob.getRoleName()))


                        .findFirst()


                        .map(SysRole::getRoleId)


                        .orElse( null));


                add(staffOnJobDto);


            });


            return true;


        } catch (Exception e) {


            e.printStackTrace();


    public Boolean importData(MultipartFile file) throws IOException {


        ExcelUtil<StaffOnJobExcelDto> util = new ExcelUtil<>(StaffOnJobExcelDto.class);


        List<StaffOnJobExcelDto> staffOnJobs = util.importExcel(file.getInputStream());


        if (CollectionUtils.isEmpty(staffOnJobs)){


            return false;


        }


        // 获取所有部门数据


        List<SysDept> sysDepts = sysDeptMapper.selectList(Wrappers.<SysDept>lambdaQuery().eq(SysDept::getDelFlag, 0));


        // 获取所有角色数据


        List<SysRole> sysRoles = sysRoleMapper.selectRoleAll();


        staffOnJobs.forEach(staffOnJob -> {


            StaffOnJobDto staffOnJobDto = new StaffOnJobDto();


            BeanUtils.copyProperties(staffOnJob, staffOnJobDto);


            // 通过名称获取部门id


            staffOnJobDto.setSysDeptId(


                    sysDepts.stream()


                        .filter(dept -> dept.getDeptName() != null && dept.getDeptName().equals(staffOnJob.getSysDeptName()))


                        .findFirst()


                        .map(SysDept::getDeptId)


                        .orElse(null)


                    );


            // 通过名称获取角色id


            staffOnJobDto.setRoleId(sysRoles.stream()


                    .filter(role -> role.getRoleName() != null && role.getRoleName().equals(staffOnJob.getRoleName()))


                    .findFirst()


                    .map(SysRole::getRoleId)


                    .orElse( null));


            add(staffOnJobDto);


        });


        return true;


    }