| | |
| | | package cc.mrbird.febs.server.hr.service.impl; |
| | | |
| | | import cc.mrbird.febs.common.core.constant.ModuleCode; |
| | | import cc.mrbird.febs.common.core.entity.QueryRequest; |
| | | import cc.mrbird.febs.common.core.exception.FebsException; |
| | | import cc.mrbird.febs.common.core.utils.FebsUtil; |
| | | import cc.mrbird.febs.common.core.utils.MyUtil; |
| | | import cc.mrbird.febs.common.core.utils.SequenceUtil; |
| | | import cc.mrbird.febs.server.hr.entity.EmpAccessory; |
| | | import cc.mrbird.febs.server.hr.entity.EmpBaseInfo; |
| | | import cc.mrbird.febs.server.hr.entity.Label; |
| | | import cc.mrbird.febs.server.hr.feign.IRemoteDeptService; |
| | | import cc.mrbird.febs.server.hr.mapper.EmpAccessoryMapper; |
| | | import cc.mrbird.febs.server.hr.properties.FebsServerHrProperties; |
| | | import cc.mrbird.febs.server.hr.service.IEmpAccessoryService; |
| | | import cc.mrbird.febs.server.hr.service.IEmpBaseInfoService; |
| | | import cc.mrbird.febs.server.hr.service.ILabelService; |
| | | import cc.mrbird.febs.server.hr.vo.EmpAccessoryVO; |
| | | import cn.hutool.core.io.FileUtil; |
| | | import cn.hutool.core.lang.Dict; |
| | | import cn.hutool.core.lang.Snowflake; |
| | | import cn.hutool.core.util.IdUtil; |
| | | import cn.hutool.core.util.StrUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.transaction.annotation.Propagation; |
| | | import lombok.RequiredArgsConstructor; |
| | | import cn.hutool.core.util.ZipUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
| | | 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.entity.QueryRequest; |
| | | import lombok.RequiredArgsConstructor; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Propagation; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import javax.servlet.http.HttpServletRequest; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.io.*; |
| | | import java.util.*; |
| | | |
| | | /** |
| | | * 附件管理 Service实现 |
| | |
| | | @Service |
| | | @RequiredArgsConstructor |
| | | @Transactional(propagation = Propagation.SUPPORTS, readOnly = true) |
| | | @Slf4j |
| | | public class EmpAccessoryServiceImpl extends ServiceImpl<EmpAccessoryMapper, EmpAccessory> implements IEmpAccessoryService { |
| | | |
| | | private final ILabelService labelService; |
| | | private final EmpAccessoryMapper empAccessoryMapper; |
| | | private final FebsServerHrProperties properties; |
| | | private final IRemoteDeptService remoteDeptService; |
| | | |
| | | private final IEmpBaseInfoService empBaseInfoService; |
| | | /** |
| | | * 参数2为数据中心ID 参数1为终端ID |
| | | */ |
| | | private Snowflake snowflake = IdUtil.getSnowflake(ModuleCode.HR_FIlE, 1); |
| | | |
| | | @Override |
| | | public IPage<Map<String,Object>> findEmpAccessorys(QueryRequest request, EmpAccessoryVO vo) { |
| | | public IPage<Map<String, Object>> findEmpAccessorys(QueryRequest request, EmpAccessoryVO vo) { |
| | | QueryWrapper<EmpAccessoryVO> queryWrapper = new QueryWrapper<>(); |
| | | if (StrUtil.isNotBlank(vo.getEmpName())){ |
| | | queryWrapper.like("a.empName",vo.getEmpName()); |
| | | queryWrapper.eq("a.delFlag", 0); |
| | | if (StrUtil.isNotBlank(vo.getBasic())) { |
| | | queryWrapper.and(p -> { |
| | | p.like("a.empNumb", vo.getBasic()) |
| | | .or().like("a.allDeptName", vo.getBasic()) |
| | | .or().like("a.certificateNumb", vo.getBasic()) |
| | | .or().like("a.empName", vo.getBasic()) |
| | | .or().like("a.jobName", vo.getBasic()); |
| | | }); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getEmpNumb())){ |
| | | queryWrapper.like("a.empNumb",vo.getEmpNumb()); |
| | | if (StrUtil.isNotBlank(vo.getEmpName())) { |
| | | queryWrapper.like("a.empName", vo.getEmpName()); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getCertificateNumb())){ |
| | | queryWrapper.like("a.certificateNumb",vo.getCertificateNumb()); |
| | | if (StrUtil.isNotBlank(vo.getEmpNumb())) { |
| | | queryWrapper.like("a.empNumb", vo.getEmpNumb()); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getDeptName())){ |
| | | queryWrapper.like("a.deptName",vo.getDeptName()); |
| | | if (StrUtil.isNotBlank(vo.getCertificateNumb())) { |
| | | queryWrapper.like("a.certificateNumb", vo.getCertificateNumb()); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getEntryDate())){ |
| | | queryWrapper.between("a.entryDate",vo.getEntryDate().split(",")[0],vo.getEntryDate().split(",")[1]); |
| | | if (StrUtil.isNotBlank(vo.getDeptName())) { |
| | | queryWrapper.like("a.allDeptName", vo.getDeptName()); |
| | | } |
| | | if(StrUtil.isNotBlank(vo.getAge())){ |
| | | if(StrUtil.equals(vo.getAge(),"1")){ |
| | | queryWrapper.between("a.age",18,29); |
| | | }else if(StrUtil.equals(vo.getAge(),"2")){ |
| | | queryWrapper.between("a.age",30,39); |
| | | }else if(StrUtil.equals(vo.getAge(),"3")){ |
| | | queryWrapper.between("a.age",40,49); |
| | | }else if(StrUtil.equals(vo.getAge(),"4")){ |
| | | queryWrapper.between("a.age",50,59); |
| | | }else if(StrUtil.equals(vo.getAge(),"5")){ |
| | | queryWrapper.between("a.age",60,69); |
| | | }else if(StrUtil.equals(vo.getAge(),"6")){ |
| | | queryWrapper.ge("a.age",69); |
| | | |
| | | if (StrUtil.isNotBlank(vo.getEntryDate())) { |
| | | queryWrapper.between("a.entryDate", vo.getEntryDate().split(",")[0], vo.getEntryDate().split(",")[1]); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getAge())) { |
| | | String[] arr = vo.getAge().split(","); |
| | | for (String s : arr) { |
| | | if (StrUtil.equals(s, "18-29")) { |
| | | queryWrapper.or().between("a.age", 18, 29); |
| | | } |
| | | if (StrUtil.equals(s, "30-39")) { |
| | | queryWrapper.or().between("a.age", 30, 39); |
| | | } |
| | | if (StrUtil.equals(s, "40-49")) { |
| | | queryWrapper.or().between("a.age", 40, 49); |
| | | } |
| | | if (StrUtil.equals(s, "50-59")) { |
| | | queryWrapper.or().between("a.age", 50, 59); |
| | | } |
| | | if (StrUtil.equals(s, "60-69")) { |
| | | queryWrapper.or().between("a.age", 60, 69); |
| | | } |
| | | if (StrUtil.equals(s, "69-999")) { |
| | | queryWrapper.or().ge("a.age", 69); |
| | | } |
| | | } |
| | | |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getArchivesStatus())) { |
| | | queryWrapper.in("a.archivesStatus", vo.getArchivesStatus().split(",")); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getEducation())) { |
| | | queryWrapper.in("a.education", vo.getEducation().split(",")); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getSex())) { |
| | | queryWrapper.in("a.sex", vo.getSex().split(",")); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getInsuranceType())) { |
| | | queryWrapper.in("a.insuranceType", vo.getInsuranceType().split(",")); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getPolitics())) { |
| | | queryWrapper.in("a.politics", vo.getPolitics().split(",")); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getEmpStatus())) { |
| | | queryWrapper.in("a.empStatus", vo.getEmpStatus().split(",")); |
| | | } |
| | | if (StrUtil.isNotBlank(vo.getPolitics())) { |
| | | queryWrapper.in("a.politics", vo.getPolitics().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(vo.getHandbookStatus())) { |
| | | queryWrapper.in("a.HandbookStatus", vo.getHandbookStatus().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(vo.getEmpCardStatus())) { |
| | | queryWrapper.in("a.EmpCardStatus", vo.getEmpCardStatus().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(vo.getEmpType())) { |
| | | queryWrapper.in("a.empType", vo.getEmpType().split(",")); |
| | | } |
| | | if (StringUtils.isNotBlank(vo.getEntryType())) { |
| | | queryWrapper.in("a.entryType", vo.getEntryType().split(",")); |
| | | } |
| | | queryWrapper.inSql("c.dept_Id", remoteDeptService.userRightDepts()); |
| | | if (StrUtil.isNotBlank(vo.getFileName())){ |
| | | queryWrapper.like("acc.filesName", vo.getFileName()); |
| | | } |
| | | if (StrUtil.equals(vo.getField(),"empName")){ |
| | | if (StrUtil.equals(vo.getOrder(),"descending")){ |
| | | queryWrapper.orderByDesc("a.empName"); |
| | | }else{ |
| | | queryWrapper.orderByAsc("a.empName"); |
| | | } |
| | | }else if(StrUtil.equals(vo.getField(),"empNumb")){ |
| | | if (StrUtil.equals(vo.getOrder(),"descending")){ |
| | | queryWrapper.orderByDesc("a.empNumb"); |
| | | }else{ |
| | | queryWrapper.orderByAsc("a.empNumb"); |
| | | } |
| | | }else if(StrUtil.equals(vo.getField(),"deptName")){ |
| | | if (StrUtil.equals(vo.getOrder(),"descending")){ |
| | | queryWrapper.orderByDesc("deptName"); |
| | | }else{ |
| | | queryWrapper.orderByAsc("deptName"); |
| | | } |
| | | }else if(StrUtil.equals(vo.getField(),"jobName")){ |
| | | if (StrUtil.equals(vo.getOrder(),"descending")){ |
| | | queryWrapper.orderByDesc("a.jobName"); |
| | | }else{ |
| | | queryWrapper.orderByAsc("a.jobName"); |
| | | } |
| | | }else if(StrUtil.equals(vo.getField(),"certificateNumb")){ |
| | | if (StrUtil.equals(vo.getOrder(),"descending")){ |
| | | queryWrapper.orderByDesc("a.certificateNumb"); |
| | | }else{ |
| | | queryWrapper.orderByAsc("a.certificateNumb"); |
| | | } |
| | | } |
| | | if(StrUtil.isNotBlank(vo.getArchivesStatus())){ |
| | | if(!StrUtil.equals(vo.getArchivesStatus(),"-1")) { |
| | | queryWrapper.eq("a.archivesStatus", vo.getArchivesStatus()); |
| | | } |
| | | } |
| | | if(StrUtil.isNotBlank(vo.getEducation())){ |
| | | if(!StrUtil.equals(vo.getEducation(),"-1")) { |
| | | queryWrapper.eq("a.education", vo.getEducation()); |
| | | } |
| | | } |
| | | if(StrUtil.isNotBlank(vo.getSex())){ |
| | | if(!StrUtil.equals(vo.getSex(),"-1")) { |
| | | queryWrapper.eq("a.sex", vo.getSex()); |
| | | } |
| | | } |
| | | if(StrUtil.isNotBlank(vo.getInsuranceType())){ |
| | | if(!StrUtil.equals(vo.getInsuranceType(),"-1")) { |
| | | queryWrapper.eq("a.insuranceType", vo.getInsuranceType()); |
| | | } |
| | | } |
| | | if(StrUtil.isNotBlank(vo.getPolitics())){ |
| | | if(!StrUtil.equals(vo.getPolitics(),"-1")) { |
| | | queryWrapper.eq("a.politics", vo.getPolitics()); |
| | | } |
| | | } |
| | | queryWrapper.eq("a.delFlag",0); |
| | | |
| | | queryWrapper.groupBy(" a.delFlag,a.empName,a.empStatus,a.empId,a.certificateNumb,a.empNumb,deptName,a.jobName"); |
| | | Page<EmpAccessory> page = new Page<>(request.getPageNum(), request.getPageSize()); |
| | | String querySql = empAccessoryMapper.getQuerySql(); |
| | | return empAccessoryMapper.selectPageVo(page, queryWrapper,querySql); |
| | | // String querySql = empAccessoryMapper.getQuerySql(); |
| | | //List<Label> labelList = labelService.findLabels(new Label()); |
| | | IPage<Map<String, Object>> mapIPage = empAccessoryMapper.selectPageVo(page, queryWrapper); |
| | | mapIPage.getRecords().parallelStream().forEach(i->{ |
| | | List<Map<String, Object>> mapList = this.baseMapper.getEmpAccessoryNumber((Long) i.get("empId")); |
| | | mapList.parallelStream().forEach(j->i.put(j.get("labelCode").toString(),Integer.parseInt(j.get("number").toString()))); |
| | | }); |
| | | return mapIPage; |
| | | } |
| | | |
| | | @Override |
| | | public List<EmpAccessory> findEmpAccessorys(EmpAccessory empAccessory) { |
| | | LambdaQueryWrapper<EmpAccessory> queryWrapper = new LambdaQueryWrapper<>(); |
| | | // TODO 设置查询条件 |
| | | queryWrapper.eq(EmpAccessory::getDelFlag, 0); |
| | | if (null != empAccessory.getLabelid()) { |
| | | queryWrapper.eq(EmpAccessory::getLabelid, empAccessory.getLabelid()); |
| | | } |
| | | if (StrUtil.isNotBlank(empAccessory.getFilesname())) { |
| | | queryWrapper.like(EmpAccessory::getFilesname, empAccessory.getFilesname()); |
| | | } |
| | | if (null != empAccessory.getEmpid()) { |
| | | queryWrapper.eq(EmpAccessory::getEmpid, empAccessory.getEmpid()); |
| | | } |
| | | return this.baseMapper.selectList(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void createEmpAccessory(EmpAccessory empAccessory) { |
| | | this.save(empAccessory); |
| | | public void createEmpAccessory(Long labelid, MultipartFile file, Long empId) throws FebsException, IOException { |
| | | EmpBaseInfo empBaseInfo = empBaseInfoService.getById(empId); |
| | | String nameAndCertificateNumb = empBaseInfo.getEmpName() + "_" + empBaseInfo.getCertificateNumb() + "/"; |
| | | Dict dict = MyUtil.filesUpload(file, properties.getUploadSinglePath() + nameAndCertificateNumb, snowflake.nextIdStr()); |
| | | EmpAccessory accessory = new EmpAccessory(); |
| | | accessory.setCreatetime(new Date()); |
| | | accessory.setCreator(FebsUtil.getUserId()); |
| | | accessory.setDelFlag(0); |
| | | accessory.setEmpid(empId); |
| | | accessory.setFilesaddress(dict.getStr("newName")); |
| | | accessory.setFilesformat(StrUtil.isBlank(dict.getStr("suffix")) ? dict.getStr("suffix") : dict.getStr("suffix").substring(1)); |
| | | accessory.setAccessoryid(SequenceUtil.generateId(0L, ModuleCode.HR_FIlE)); |
| | | accessory.setFilesname(dict.getStr("fileName")); |
| | | accessory.setLabelid(labelid); |
| | | accessory.setModifier(FebsUtil.getUserId()); |
| | | accessory.setModifytime(new Date()); |
| | | accessory.setVersion(0); |
| | | this.save(accessory); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void updateEmpAccessory(EmpAccessory empAccessory) { |
| | | this.saveOrUpdate(empAccessory); |
| | | public void updateEmpAccessory(EmpAccessory empAccessory) throws FebsException { |
| | | if ( empAccessory.getFilesname().lastIndexOf(".")<=0){ |
| | | throw new FebsException("文件名格式错误"); |
| | | } |
| | | LambdaUpdateWrapper<EmpAccessory> wrapper = new LambdaUpdateWrapper<>(); |
| | | wrapper.eq(EmpAccessory::getAccessoryid,empAccessory.getAccessoryid()) |
| | | .set(EmpAccessory::getFilesname,empAccessory.getFilesname()).set(EmpAccessory::getFilesformat, empAccessory.getFilesname().substring( empAccessory.getFilesname().lastIndexOf(".")+1)); |
| | | this.update(wrapper); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void deleteEmpAccessory(EmpAccessory empAccessory) { |
| | | LambdaQueryWrapper<EmpAccessory> wapper = new LambdaQueryWrapper<>(); |
| | | // TODO 设置删除条件 |
| | | this.remove(wapper); |
| | | public void deleteEmpAccessory(String accessoryids) { |
| | | String[] arr = accessoryids.split(","); |
| | | LambdaUpdateWrapper<EmpAccessory> wapper = new LambdaUpdateWrapper<>(); |
| | | wapper.in(EmpAccessory::getAccessoryid, arr); |
| | | wapper.set(EmpAccessory::getDelFlag, 1); |
| | | wapper.set(EmpAccessory::getModifier, FebsUtil.getUserId()); |
| | | wapper.set(EmpAccessory::getModifytime, new Date()); |
| | | this.update(wapper); |
| | | |
| | | LambdaQueryWrapper<EmpAccessory> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.in(EmpAccessory::getAccessoryid, arr); |
| | | List<EmpAccessory> list = this.list(queryWrapper); |
| | | list.parallelStream().forEach(i -> { |
| | | EmpBaseInfo empBaseInfo = empBaseInfoService.getById(i.getEmpid()); |
| | | String nameAndCertificateNumb = empBaseInfo.getEmpName() + "_" + empBaseInfo.getCertificateNumb() + "/"; |
| | | FileUtil.del(properties.getUploadSinglePath() + nameAndCertificateNumb + "/" + i.getFilesaddress()); |
| | | }); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public void download(String accessoryids, HttpServletRequest request, HttpServletResponse response) { |
| | | String[] arr = accessoryids.split(","); |
| | | List<File> files = new ArrayList<>(); |
| | | List<String> fileName = new ArrayList<>(); |
| | | Arrays.stream(arr).forEach(i -> { |
| | | EmpAccessory accessory = this.getById(i); |
| | | EmpBaseInfo empBaseInfo = empBaseInfoService.getById(accessory.getEmpid()); |
| | | String nameAndCertificateNumb = empBaseInfo.getEmpName() + "_" + empBaseInfo.getCertificateNumb() + "/"; |
| | | files.add(new File(properties.getUploadSinglePath() + nameAndCertificateNumb + accessory.getFilesaddress())); |
| | | if (fileName.parallelStream().filter(filter -> StrUtil.equals(accessory.getFilesname(), filter)).count() == 0) { |
| | | fileName.add(accessory.getFilesname()); |
| | | } else { |
| | | fileName.add(accessory.getFilesname().substring(0,accessory.getFilesname().lastIndexOf(".")) + fileName.parallelStream().filter(filter -> StrUtil.equals(accessory.getFilesname(), filter)).count()+"."+accessory.getFilesformat()); |
| | | } |
| | | }); |
| | | MyUtil.download(request, response, files, fileName); |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public void mvFiles(String accessoryids, Long labelid, Long empId) { |
| | | String[] arr = accessoryids.split(","); |
| | | LambdaUpdateWrapper<EmpAccessory> wapper = new LambdaUpdateWrapper<>(); |
| | | wapper.in(EmpAccessory::getAccessoryid, arr); |
| | | wapper.set(EmpAccessory::getModifier, FebsUtil.getUserId()); |
| | | wapper.set(EmpAccessory::getModifytime, new Date()); |
| | | wapper.set(EmpAccessory::getLabelid, labelid); |
| | | this.update(wapper); |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public void singledownload(String empIds, Long labelid, HttpServletRequest request, HttpServletResponse response) throws IOException { |
| | | String[] arr = empIds.split(","); |
| | | //主文件夹 |
| | | String mianFileStr = properties.getUploadSinglePath() + snowflake.nextIdStr() + "/"; |
| | | FileUtil.mkdir(mianFileStr); |
| | | Arrays.stream(arr).forEach(i -> { |
| | | LambdaQueryWrapper<EmpAccessory> lambdaQueryWrapper = new LambdaQueryWrapper<>(); |
| | | lambdaQueryWrapper.eq(EmpAccessory::getEmpid, i); |
| | | lambdaQueryWrapper.eq(EmpAccessory::getDelFlag, 0); |
| | | if (!labelid.equals(-1L)) { |
| | | lambdaQueryWrapper.eq(EmpAccessory::getLabelid, labelid); |
| | | } |
| | | List<EmpAccessory> accessory = this.list(lambdaQueryWrapper); |
| | | EmpBaseInfo empBaseInfo = empBaseInfoService.getById(i); |
| | | String nameAndCertificateNumb = empBaseInfo.getEmpName() + "_" + empBaseInfo.getCertificateNumb() + "/"; |
| | | //创建个人文件夹 |
| | | String singlefileStr = mianFileStr + nameAndCertificateNumb; |
| | | FileUtil.mkdir(singlefileStr); |
| | | accessory.stream().forEach(a -> { |
| | | Label label = labelService.getById(a.getLabelid()); |
| | | FileUtil.copy(properties.getUploadSinglePath() + nameAndCertificateNumb + a.getFilesaddress(), singlefileStr + label.getLabelname() + "/" + a.getFilesname(), true); |
| | | }); |
| | | }); |
| | | ZipUtil.zip(mianFileStr); |
| | | try { |
| | | MyUtil.downloadFile(new File(new StringBuilder().append(mianFileStr, 0, mianFileStr.length() - 1).append(".zip").toString()), response); |
| | | } catch (IOException e) { |
| | | log.error("下载文件异常", e); |
| | | } |
| | | FileUtil.del(new StringBuilder().append(mianFileStr, 0, mianFileStr.length() - 1).append(".zip").toString()); |
| | | FileUtil.del(mianFileStr); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public Integer getLabelCount(Long labelId) { |
| | | LambdaQueryWrapper<EmpAccessory> wrapper = new LambdaQueryWrapper<>(); |
| | | wrapper.eq(EmpAccessory::getDelFlag, 0); |
| | | wrapper.eq(EmpAccessory::getLabelid, labelId); |
| | | return this.count(wrapper); |
| | | } |
| | | |
| | | @Override |
| | | public void autoInstall(String fileids) { |
| | | File[] list = FileUtil.ls(fileids); |
| | | for (File file : list) { |
| | | String[] fileName = file.getName().split("_"); |
| | | if (fileName.length<2){ |
| | | log.error(file.getName()); |
| | | continue; |
| | | } |
| | | List<EmpBaseInfo> empBaseInfo = empBaseInfoService.list(new LambdaQueryWrapper<EmpBaseInfo>().eq(EmpBaseInfo::getCertificateNumb, fileName[1]).ne(EmpBaseInfo::getDelFlag, 1)); |
| | | if (null == empBaseInfo ||0 == empBaseInfo.size()) { |
| | | continue; |
| | | } |
| | | File[] childlist = FileUtil.ls(fileids+"/"+file.getName()); |
| | | for (File file1 : childlist) { |
| | | EmpAccessory accessory = new EmpAccessory(); |
| | | if (file1.getName().indexOf("外皮")>=0||file1.getName().indexOf("外批")>=0){ |
| | | accessory.setLabelid(142445285230593L); |
| | | }else if (file1.getName().indexOf("心电图")>=0){ |
| | | accessory.setLabelid(142445218121729L); |
| | | }else if (file1.getName().indexOf("体检")>=0){ |
| | | accessory.setLabelid(142445218121729L); |
| | | }else if (file1.getName().indexOf("合同")>=0){ |
| | | accessory.setLabelid(142445285230593L); |
| | | }else if (file1.getName().indexOf("入职")>=0||file1.getName().indexOf("务工")>=0){ |
| | | accessory.setLabelid(143073554221057L); |
| | | }else if (file1.getName().indexOf("身份")>=0){ |
| | | accessory.setLabelid(143007818991617L); |
| | | }else if (file1.getName().indexOf("银行卡")>=0){ |
| | | accessory.setLabelid(143073768130561L); |
| | | }else if (file1.getName().indexOf("回执")>=0){ |
| | | accessory.setLabelid(143073617135617L); |
| | | }else if (file1.getName().indexOf("证")>=0){ |
| | | accessory.setLabelid(143073812170753L); |
| | | }else{ |
| | | accessory.setLabelid(143073866696705L); |
| | | } |
| | | |
| | | accessory.setCreatetime(new Date()); |
| | | accessory.setCreator(FebsUtil.getUserId()); |
| | | accessory.setDelFlag(0); |
| | | accessory.setEmpid(empBaseInfo.get(0).getEmpId()); |
| | | accessory.setFilesaddress(file1.getName()); |
| | | if (file1.getName().lastIndexOf(".") > 0) { |
| | | accessory.setFilesformat( file1.getName().substring(file1.getName().lastIndexOf(".")+1)); |
| | | } |
| | | accessory.setAccessoryid(SequenceUtil.generateId(0L, ModuleCode.HR_FIlE)); |
| | | accessory.setFilesname(file1.getName()); |
| | | accessory.setModifier(FebsUtil.getUserId()); |
| | | accessory.setModifytime(new Date()); |
| | | accessory.setVersion(0); |
| | | this.save(accessory); |
| | | } |
| | | |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void getImage(String accessoryid, HttpServletResponse response) throws Exception { |
| | | EmpAccessory empAccessory = this.getById(accessoryid); |
| | | if (StrUtil.isBlank(empAccessory.getFilesaddress())) { |
| | | return; |
| | | } |
| | | EmpBaseInfo empBaseInfo = empBaseInfoService.getById(empAccessory.getEmpid()); |
| | | String nameAndCertificateNumb = empBaseInfo.getEmpName() + "_" + empBaseInfo.getCertificateNumb() + "/"; |
| | | String path = properties.getUploadSinglePath() + nameAndCertificateNumb + empAccessory.getFilesaddress(); |
| | | try (InputStream inputStream = new FileInputStream(path); OutputStream out = response.getOutputStream()) { |
| | | //byte数组用于存放图片字节数据 |
| | | byte[] buff = new byte[inputStream.available()]; |
| | | inputStream.read(buff); |
| | | inputStream.close(); |
| | | if (empAccessory.getFilesformat().equals("tif")){ |
| | | //设置发送到客户端的响应内容类型 |
| | | response.setContentType("image/tiff"); |
| | | }else if (empAccessory.getFilesformat().equals("bmp")){ |
| | | response.setContentType("application/x-bmp"); |
| | | }else if (empAccessory.getFilesformat().equals("jpg")){ |
| | | response.setContentType("image/jpeg"); |
| | | }else if (empAccessory.getFilesformat().equals("png")){ |
| | | response.setContentType("image/png"); |
| | | }else if (empAccessory.getFilesformat().equals("gif")){ |
| | | response.setContentType("image/gif"); |
| | | } |
| | | out.write(buff); |
| | | } |
| | | } |
| | | } |