| | |
| | | package com.whyc.service; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.github.pagehelper.PageHelper; |
| | | import com.github.pagehelper.PageInfo; |
| | | import com.whyc.dto.FileDirPath; |
| | | import com.whyc.dto.MaterialCheckDTO; |
| | | import com.whyc.dto.Response; |
| | | import com.whyc.mapper.MaterialMapper; |
| | | import com.whyc.pojo.Material; |
| | | import com.whyc.util.CommonUtil; |
| | | import com.whyc.util.FileUtil; |
| | | import com.whyc.pojo.*; |
| | | import com.whyc.util.DateUtil; |
| | | import com.whyc.util.*; |
| | | import org.apache.commons.codec.binary.Base64; |
| | | import org.apache.poi.openxml4j.exceptions.InvalidFormatException; |
| | | import org.apache.poi.ss.usermodel.*; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.FileCopyUtils; |
| | | import org.springframework.web.context.request.RequestContextHolder; |
| | | import org.springframework.web.context.request.ServletRequestAttributes; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import java.io.File; |
| | | import java.io.IOException; |
| | | import java.util.LinkedList; |
| | | import java.util.List; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.io.*; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | @Service |
| | | public class MaterialService { |
| | | @Autowired(required = false) |
| | | private MaterialMapper mapper; |
| | | |
| | | @Autowired |
| | | private MaterialHistoryService mhService; |
| | | |
| | | @Autowired |
| | | private AttachLockService attachLockService; |
| | | |
| | | //查询所有的散装件信息加设置了替换关系的子件信息 |
| | | /*public Response getAllMaterial(String category,String subCode,String subName,String subModel,int pageCurr,int pageSize) { |
| | | PageHelper.startPage(pageCurr,pageSize); |
| | |
| | | List<Material> list=mapper.selectList(wrapper);*//* |
| | | List<Material> list=mapper.getAllMaterial(category,subCode,subName,subModel); |
| | | PageInfo pageInfo=new PageInfo(list); |
| | | return new Response().setII(1,list.size()>0?true:false,pageInfo,"返回所有的散装件"); |
| | | return new Response().setII(1,list.size()>0,pageInfo,"返回所有的散装件"); |
| | | }*/ |
| | | //查询所有的散装件信息不分页 |
| | | /*public Response getMaterialWithoutSub(String parentModel, String subName,int version) { |
| | | List<Material> list=mapper.getMaterialWithoutSub(parentModel,subName,version); |
| | | return new Response().setII(1,list.size()>0?true:false,list,"返回子件没有添加过联系的散装件"); |
| | | return new Response().setII(1,list.size()>0,list,"返回子件没有添加过联系的散装件"); |
| | | }*/ |
| | | //删除散装件(将散装件标识为不可用) |
| | | /*public Response deleteMaterial(int id) { |
| | |
| | | wrapper.set("status",0); |
| | | wrapper.eq("id",id); |
| | | int bl=mapper.update(null,wrapper); |
| | | return new Response().setII(1,bl>0?true:false,bl,"将散装件标识为不可用"); |
| | | return new Response().setII(1,bl>0,bl,"将散装件标识为不可用"); |
| | | }*/ |
| | | |
| | | public List<Material> getList() { |
| | |
| | | |
| | | //查询所有物料(分页,模糊查询) |
| | | public Response getMaterialLimit(String subCode, String subName, String subModel, int pageCurr, int pageSize) { |
| | | PageHelper.startPage(pageCurr,pageSize); |
| | | PageHelper.startPage(pageCurr,pageSize); |
| | | List<Material> list=mapper.getMaterialLimit(subCode,subName,subModel); |
| | | String fileDirName = FileDirPath.getFileDirName(); |
| | | int flag=0; |
| | | // 返回是否存在附件 |
| | | if(list!=null&&list.size()>0){ |
| | | for (Material m:list) { |
| | | if(m.getFileUrl()!=null&&!m.getFileUrl().isEmpty()){ |
| | | File file = new File(fileDirName+File.separator+m.getFileUrl()); |
| | | if(!file.exists()) { |
| | | flag=0; |
| | | }else{ |
| | | String[] fileNames = file.list();//获取该文件夹下的所有文件以及目录的名字 |
| | | List attachFileList=new ArrayList(); |
| | | if(fileNames.length>0){ |
| | | flag=1; |
| | | for (int i=0;i<fileNames.length;i++){ |
| | | if(!fileNames[i].contains("-dwg.pdf")&&!fileNames[i].contains("-doc.pdf")) |
| | | attachFileList.add(fileNames[i]); |
| | | } |
| | | }else{ |
| | | flag=0; |
| | | } |
| | | m.setAttachFileList(attachFileList); |
| | | } |
| | | } |
| | | m.setHasAttachFlag(flag); |
| | | } |
| | | } |
| | | PageInfo pageInfo=new PageInfo(list); |
| | | return new Response().setII(1,list.size()>0?true:false,pageInfo,"查询所有物料(分页,模糊查询)"); |
| | | return new Response().setII(1,list.size()>0,pageInfo,"查询所有物料(分页,模糊查询)"); |
| | | } |
| | | //建立关联时查询所有的物料(不分页) |
| | | public Response getAllMaterialNoLimit() { |
| | |
| | | wrapper.ne("status",0); |
| | | wrapper.orderByAsc("id"); |
| | | List<Material> list=mapper.selectList(wrapper); |
| | | return new Response().setII(1,list.size()>0?true:false,list,"查询所有物料(不分页)"); |
| | | return new Response().setII(1,list.size()>0,list,"查询所有物料(不分页)"); |
| | | } |
| | | |
| | | public List<String> getListByCodeList(List<String> codeList) { |
| | |
| | | //获取路径下的所有文件 |
| | | List<String> fileUrlList = new LinkedList<>(); |
| | | List<String> dwgUrlList = null; |
| | | List<String> picUrlList = null; |
| | | List<String> materialUrlList = new LinkedList<>(); |
| | | |
| | | fileUrlList = FileUtil.getStaticFilePath(new File(fileUrl),fileUrlList); |
| | | dwgUrlList = fileUrlList.stream().filter(url->url.contains(".dwg")).collect(Collectors.toList()); |
| | | picUrlList = fileUrlList.stream().filter(url->url.contains(".png") || url.contains(".jpeg")).collect(Collectors.toList()); |
| | | //图纸的url预设 |
| | | dwgUrlList.forEach(dwgUrl-> { |
| | | materialList.forEach(material -> { |
| | |
| | | } |
| | | }); |
| | | }); |
| | | //图片的url预设 |
| | | //一定是有对应物料的,从excel内剥离的 |
| | | picUrlList.forEach(picUrl->{ |
| | | for (Material material : materialList){ |
| | | String filename = picUrl.substring(picUrl.lastIndexOf(File.separator) + 1,picUrl.lastIndexOf(".")); |
| | | String fileFullName = picUrl.substring(picUrl.lastIndexOf(File.separator) + 1); |
| | | if(material.getSubModel().toUpperCase().equals(filename.toUpperCase())){ |
| | | material.setPictureUrl("doc_file" + File.separator + "material" |
| | | + File.separator + fileFullName); |
| | | break; |
| | | } |
| | | } |
| | | }); |
| | | //图纸文件转移到正式文件夹 |
| | | String projectDir = CommonUtil.getProjectDir(); |
| | | String materialDir = projectDir + File.separator + "doc_file" + File.separator + "material"; |
| | |
| | | String dwgFullName = materialUrl.substring(materialUrl.lastIndexOf(File.separator) + 1); |
| | | try { |
| | | FileCopyUtils.copy(new File(materialUrl),new File(materialDir + File.separator + dwgFullName)); |
| | | } catch (IOException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | }); |
| | | picUrlList.forEach(picUrl->{ |
| | | String picFullName = picUrl.substring(picUrl.lastIndexOf(File.separator) + 1); |
| | | try { |
| | | FileCopyUtils.copy(new File(picUrl),new File(materialDir+File.separator+picFullName)); |
| | | } catch (IOException e) { |
| | | e.printStackTrace(); |
| | | } |
| | |
| | | private List<Material> getListByCodeAndModelList(List<Material> materialList) { |
| | | return mapper.getListByCodeAndModelList(materialList); |
| | | } |
| | | |
| | | public List<Material> getListByCodeAndModelList2(List<ProductBom> bomList) { |
| | | return mapper.getListByCodeAndModelList2(bomList); |
| | | } |
| | | |
| | | /** |
| | | * |
| | | * @param subCode 物料编码 |
| | | * @param subModel 物料型号 |
| | | * @param equalSubModel 是否等于物料型号,用于等于物料型号 或者 排除物料型号并且存在附件 |
| | | * @return |
| | | */ |
| | | public Material getByCodeAndModel(String subCode, String subModel, boolean equalSubModel) { |
| | | QueryWrapper<Material> query = Wrappers.query(); |
| | | query.eq("sub_code",subCode); |
| | | if(equalSubModel) { |
| | | query.eq("sub_model", subModel); |
| | | }else{ |
| | | query.ne("sub_model", subModel); |
| | | query.isNotNull("file_url"); |
| | | } |
| | | query.orderByDesc("id"); |
| | | query.last(" limit 1"); |
| | | return mapper.selectOne(query); |
| | | } |
| | | |
| | | public Response zipParse(MultipartFile file) throws IOException, InvalidFormatException { |
| | | List<Material> list = new LinkedList<>(); |
| | | Response response = new Response(); |
| | | //检查是否为zip |
| | | boolean isZip = Zip4jUtil.checkZipFileParam(file); |
| | | if(!isZip){ |
| | | return response.set(1,false,"上传的文件格式不是zip"); |
| | | } |
| | | //zip存储路径:doc_file/material_submit/${username}/{dateFormat}/${timeStamp} |
| | | String rootFile = CommonUtil.getRootFile(); |
| | | DocUser user = ActionUtil.getUser(); |
| | | String dateFormat = new SimpleDateFormat("YYYY-MM").format(new Date()); |
| | | long timeStamp = System.currentTimeMillis(); |
| | | String filePath = rootFile + File.separator + "material_submit" + File.separator + user.getName() + File.separator + dateFormat+ File.separator + timeStamp; |
| | | File parentFile = new File(filePath); |
| | | String originalFilename = file.getOriginalFilename(); |
| | | File zipFile = new File(filePath+File.separator+ originalFilename); |
| | | /*if(!zipFile.exists()){ |
| | | zipFile.mkdirs(); |
| | | }*/ |
| | | if (!parentFile.exists()) { |
| | | parentFile.mkdirs(); |
| | | } |
| | | file.transferTo(zipFile); |
| | | //解压文件夹 |
| | | Zip4jUtil.unPackZip(zipFile,null,filePath); |
| | | //遍历解压后的文件夹路径,解析excel |
| | | System.out.println(filePath); |
| | | List<String> fileList = new ArrayList<>(); |
| | | fileList = FileUtil.getStaticFilePath(parentFile,fileList); |
| | | for (int i = 0; i < fileList.size(); i++) { |
| | | String fileTempUrl = fileList.get(i); |
| | | //查询到xls数据 |
| | | if(fileTempUrl.contains(".xls")){ |
| | | File fileTemp = new File(fileTempUrl); |
| | | Workbook workbook = null; |
| | | workbook = WorkbookFactory.create(fileTemp); |
| | | List<? extends PictureData> allPictures = workbook.getAllPictures(); |
| | | //取第一个sheet表 |
| | | Sheet sheet = workbook.getSheetAt(0); |
| | | int lastRowNum = sheet.getLastRowNum(); |
| | | //取第三行,并以第三行开始 |
| | | Row rowTemp = sheet.getRow(1); |
| | | short lastCellNum = rowTemp.getLastCellNum(); |
| | | //先单独获取产品型号和版本号/分类 |
| | | Row row = sheet.getRow(1); |
| | | String type = row.getCell(1).getStringCellValue(); |
| | | |
| | | Row row2 = sheet.getRow(2); |
| | | String productModel = row2.getCell(5).getStringCellValue(); |
| | | Row row3 = sheet.getRow(3); |
| | | String productVersion = row3.getCell(5).getStringCellValue(); |
| | | for (int l = 8; l < lastRowNum-1; l++) { |
| | | Cell cellTemp = sheet.getRow(l).getCell(1); |
| | | cellTemp.setCellType(Cell.CELL_TYPE_STRING); |
| | | if(cellTemp.getStringCellValue().equals("")){ |
| | | break; |
| | | } |
| | | Material material = new Material(); |
| | | material.setCreateDate(new Date()); |
| | | |
| | | for (int m = 2; m < lastCellNum; m++) { |
| | | row = sheet.getRow(l); |
| | | Cell cell = row.getCell(m); |
| | | String cellValue = null; |
| | | int cellValueInt = 0; |
| | | Double cellValueDouble = null; |
| | | if(m == 3 || m==7){ |
| | | //cellValueDouble = cell.getNumericCellValue(); |
| | | //DecimalFormat decimalFormat = new DecimalFormat("0"); |
| | | //cellValue = decimalFormat.format(cellValueDouble); |
| | | cell.setCellType(Cell.CELL_TYPE_STRING); |
| | | } |
| | | cellValue = cell.getStringCellValue(); |
| | | |
| | | switch (m){ |
| | | //case 2:{material.setCategory(cellValue);}break; |
| | | case 3:{material.setSubCode(cellValue);}break; |
| | | case 4:{material.setSubName(cellValue);}break; |
| | | case 5:{material.setSubModel(cellValue);}break; |
| | | //case 6:{material.setMaterial(cellValue);}break; |
| | | //case 7:{material.setThickness(cellValue);}break; |
| | | //case 8:{material.setProducer(cellValue);}break; |
| | | //case 9:{material.setSurfaceDetail(cellValue);}break; |
| | | //case 10:{material.setNotes(cellValue);}break; |
| | | case 11:{ |
| | | //图片从1开始,0是yc logo |
| | | PictureData pictureData = allPictures.get(l - 7); |
| | | String suffix = pictureData.suggestFileExtension(); |
| | | String picturePath = filePath + File.separator + material.getSubModel() + "." + suffix; |
| | | String picturePathFront = "doc_file" + File.separator + "material_submit" + File.separator + user.getName() + File.separator + dateFormat + File.separator + timeStamp + File.separator + material.getSubModel() + "." + suffix; |
| | | byte[] data = pictureData.getData(); |
| | | FileOutputStream fileOutputStream = null; |
| | | File pictureFile = new File(picturePath); |
| | | fileOutputStream = new FileOutputStream(pictureFile); |
| | | fileOutputStream.write(data); |
| | | |
| | | material.setPictureUrl(picturePathFront); |
| | | }break; |
| | | } |
| | | } |
| | | list.add(material); |
| | | } |
| | | } |
| | | } |
| | | for (Material material : list) { |
| | | if(material.getSubName()==null ||material.getSubName().equals("")){ |
| | | return response.set(1,false,"拒绝解析,excel文件中记录包含名称为空的记录"); |
| | | } |
| | | } |
| | | //追加物料规范校验 暂时去除校验 |
| | | /*List<MaterialCheckDTO> checkList = list.stream().map(material -> { |
| | | MaterialCheckDTO dto = new MaterialCheckDTO(); |
| | | dto.setNum(material.getId()); |
| | | dto.setSubCode(material.getSubCode()); |
| | | dto.setSubName(material.getSubName()); |
| | | dto.setSubModel(material.getSubModel()); |
| | | return dto; |
| | | }).collect(Collectors.toList()); |
| | | List<MaterialCheckDTO> irregularList = CommonUtil.checkFormat(checkList); |
| | | if(irregularList.size()>0){ |
| | | return new Response().setII(1,false,irregularList,"名称或型号命名不规范"); |
| | | }*/ |
| | | return response.setII(1,true,list,filePath); |
| | | } |
| | | //根据物料id查询返回附件文件夹下所有的文件列表 |
| | | public Response getAttachByMaterialId(int materialId) { |
| | | String fileDirName = FileDirPath.getFileDirName(); |
| | | Material material=mapper.getAttachByMaterialId(materialId); |
| | | boolean flag=false; |
| | | List list=new ArrayList(); |
| | | if(material.getFileUrl()!=null&&!material.getFileUrl().isEmpty()){ |
| | | File file = new File(fileDirName+File.separator+material.getFileUrl()); |
| | | if(!file.exists()) { |
| | | flag=false; |
| | | }else{ |
| | | String[] fileNames = file.list();//获取该文件夹下的所有文件以及目录的名字 |
| | | if(fileNames.length>0){ |
| | | flag=true; |
| | | for (int i=0;i<fileNames.length;i++){ |
| | | if(!fileNames[i].contains("-dwg.pdf")&&!fileNames[i].contains("-doc.pdf")) |
| | | list.add(material.getFileUrl()+File.separator+fileNames[i]); |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | return new Response().setII(1,flag,list,"文件列表返回"); |
| | | } |
| | | //根据物料型号('-','_'之前的部分)查询物料的历史版本 |
| | | public Response getMaterialVersion(String subModel) { |
| | | List list=mapper.getMaterialVersion(subModel); |
| | | return new Response().setII(1,list.size()>0,list,"物料历史版本数据返回"); |
| | | } |
| | | //根据物料id查询物料信息 |
| | | public Response getMaterialById(int materialId) { |
| | | Material material=mapper.getMaterialById(materialId); |
| | | String fileDirName = FileDirPath.getFileDirName(); |
| | | List list=new ArrayList(); |
| | | if(material.getFileUrl()!=null&&!material.getFileUrl().isEmpty()){ |
| | | File file = new File(fileDirName+File.separator+material.getFileUrl()); |
| | | if(file.exists()) { |
| | | String[] fileNames = file.list();//获取该文件夹下的所有文件以及目录的名字 |
| | | if(fileNames.length>0){ |
| | | for (int i=0;i<fileNames.length;i++){ |
| | | if(!fileNames[i].contains("-dwg.pdf")&&!fileNames[i].contains("-doc.pdf")) |
| | | list.add(material.getFileUrl()+File.separator+fileNames[i]); |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | return new Response().setIII(1,material!=null,material,list,"物料历史版本数据返回"); |
| | | } |
| | | |
| | | /** |
| | | * @param multipartFileList 被追加的附件,zip集合 |
| | | * @param material |
| | | * @return 返回被追加文件的文件夹路径 |
| | | */ |
| | | @Transactional |
| | | public Response addAttachment(List<MultipartFile> multipartFileList, Material material) throws IOException { |
| | | List<String> currentFileList = new LinkedList<>(); |
| | | List<String> uploadingFileList = new LinkedList<>(); |
| | | |
| | | String subModel = material.getSubModel(); |
| | | subModel = MaterialSpecialCharUtil.transfer(subModel); |
| | | String dirPathDB = "doc_file" + File.separator + "material" + File.separator + material.getId() + "-"+ material.getSubCode() + "-" + subModel; |
| | | String dirPath = CommonUtil.getRootFile() + "material" + File.separator + material.getId() + "-"+ material.getSubCode() + "-" + subModel; |
| | | File dirFile = new File(dirPath); |
| | | |
| | | Date now = new Date(); |
| | | //long timestamp = now.getTime(); |
| | | String formattedTimestamp = DateUtil.YYYY_MM_DD_HH_MM_SS_UNION.format(now); |
| | | |
| | | boolean dirFileExist = true; |
| | | if(!dirFile.exists()){ |
| | | dirFile.mkdirs(); |
| | | dirFileExist = false; |
| | | } |
| | | for (int i = 0; i < multipartFileList.size(); i++) { |
| | | MultipartFile multipartFile = multipartFileList.get(i); |
| | | String originalFilename = multipartFile.getOriginalFilename(); |
| | | File zipFile = new File(dirPath + File.separator + originalFilename.substring(0,originalFilename.lastIndexOf(".")) + "_" + formattedTimestamp + originalFilename.substring(originalFilename.lastIndexOf("."))); |
| | | multipartFile.transferTo(zipFile); |
| | | } |
| | | /*//解压文件夹,删除原zip文件 |
| | | String unPackageDir = dirPath + File.separator + timestamp; |
| | | Zip4jUtil.unPackZip(zipFile, null, unPackageDir); |
| | | File unPackageFile = new File(unPackageDir); |
| | | File[] unPackageFileList = unPackageFile.listFiles(); |
| | | zipFile.delete(); |
| | | for (int i = 0; i < unPackageFileList.length; i++) { |
| | | File tempFile = unPackageFileList[i]; |
| | | if(tempFile.isDirectory()){ |
| | | FileUtil.deleteFile(unPackageFile); |
| | | if(!dirFileExist){ |
| | | FileUtil.deleteFile(dirFile); |
| | | } |
| | | return new Response().set(1,false,"拒绝上传:上传的压缩包存在文件夹"); |
| | | } |
| | | }*/ |
| | | |
| | | if(!dirFileExist){ |
| | | //路径不存在,说明是首次上传,设置物料对应的fileUrl |
| | | Material temp = new Material(); |
| | | temp.setId(material.getId()); |
| | | temp.setFileUrl(dirPathDB); |
| | | mapper.updateById(temp); |
| | | }/*else{ |
| | | //查询路径下现有的所有文件 |
| | | String[] fileArr = dirFile.list(); |
| | | currentFileList = Arrays.asList(fileArr); |
| | | }*/ |
| | | |
| | | /*//查询新上传的文件路径 |
| | | String[] unPackageFileArr = unPackageFile.list(); |
| | | uploadingFileList = Arrays.asList(unPackageFileArr); |
| | | for (String uploadingFile : uploadingFileList){ |
| | | if(currentFileList.contains(uploadingFile)){ |
| | | new File(unPackageDir + File.separator + uploadingFile) |
| | | .renameTo(new File(unPackageDir + File.separator + uploadingFile.substring(0,uploadingFile.lastIndexOf(".")) + "_" + formattedTimestamp + uploadingFile.substring(uploadingFile.lastIndexOf(".")))); |
| | | } |
| | | } |
| | | //上传的文件夹转移到正式路径 |
| | | org.aspectj.util.FileUtil.copyDir(unPackageFile,dirFile); |
| | | FileUtil.deleteFile(unPackageFile);*/ |
| | | |
| | | return new Response().set(1,true,"上传完成"); |
| | | } |
| | | |
| | | /** |
| | | * 转移 被复制的附件,到新的物料 |
| | | * @param materialDB .fileUrl 被复制的附件路径,例如:doc_file\material\8468-0109000512-SHIDA-2455-OLD-ZX_A01 |
| | | * @param material 新的物料 |
| | | * @return 返回被追加文件的文件夹路径 |
| | | */ |
| | | @Transactional |
| | | public Response transferCopiedAttachment(Material materialDB, Material material) throws IOException { |
| | | String fileUrlDir = materialDB.getFileUrl(); |
| | | String subModel = material.getSubModel(); |
| | | subModel = MaterialSpecialCharUtil.transfer(subModel); |
| | | String dirPathDB = "doc_file" + File.separator + "material" + File.separator + material.getId() + "-"+ material.getSubCode() + "-" + subModel; |
| | | String dirPath = CommonUtil.getRootFile() + "material" + File.separator + material.getId() + "-"+ material.getSubCode() + "-" + subModel; |
| | | File dirFile = new File(dirPath); |
| | | |
| | | if(!dirFile.exists()){ |
| | | |
| | | dirFile.mkdirs(); |
| | | } |
| | | FileUtil.copyDirectory(new File(CommonUtil.getProjectDir() + File.separator + fileUrlDir),dirFile); |
| | | |
| | | //设置物料对应的fileUrl及物料状态 |
| | | Material temp = new Material(); |
| | | temp.setId(material.getId()); |
| | | temp.setFileUrl(dirPathDB); |
| | | mapper.updateById(temp); |
| | | |
| | | attachLockService.getAndInsert(materialDB.getId(),material.getId()); |
| | | |
| | | |
| | | return new Response().set(1,true,"上传完成"); |
| | | } |
| | | |
| | | /** |
| | | * @param multipartFile 更新的图纸或图片 |
| | | * @param material |
| | | */ |
| | | @Transactional |
| | | public Response updatePicOrDwg(MultipartFile multipartFile, Material material) throws IOException { |
| | | List<String> currentFileList = new LinkedList<>(); |
| | | List<String> uploadingFileList = new LinkedList<>(); |
| | | String subModel = material.getSubModel(); |
| | | subModel = MaterialSpecialCharUtil.transfer(subModel); |
| | | String dirPathDB = "doc_file" + File.separator + "material" + File.separator + material.getSubCode() + "-" + subModel; |
| | | String dirPath = CommonUtil.getRootFile() + "material" + File.separator + material.getSubCode() + "-" + subModel; |
| | | File dirFile = new File(dirPath); |
| | | |
| | | Date now = new Date(); |
| | | //long timestamp = now.getTime(); |
| | | String formattedTimestamp = DateUtil.YYYY_MM_DD_HH_MM_SS_UNION.format(now); |
| | | |
| | | if (!dirFile.exists()) { |
| | | dirFile.mkdirs(); |
| | | } |
| | | |
| | | String originalFilename = multipartFile.getOriginalFilename(); |
| | | String fileSuffix = originalFilename.substring(originalFilename.lastIndexOf(".") + 1); |
| | | String fileFullName = File.separator + originalFilename.substring(0, originalFilename.lastIndexOf(".")) + "_" + formattedTimestamp + originalFilename.substring(originalFilename.lastIndexOf(".")); |
| | | File zipFile = new File(dirPath + fileFullName); |
| | | multipartFile.transferTo(zipFile); |
| | | |
| | | //路径不存在,说明是首次上传,设置物料对应的fileUrl |
| | | //同时在物料历史里面添加记录 |
| | | Material temp = new Material(); |
| | | MaterialHistory mh = new MaterialHistory(); |
| | | |
| | | temp.setId(material.getId()); |
| | | mh.setProductId(-1); |
| | | mh.setMaterialId(material.getId()); |
| | | int userId = ActionUtil.getUser().getId().intValue(); |
| | | mh.setUpUserId(userId); |
| | | mh.setCreateTime(now); |
| | | if(fileSuffix.equals("dwg")){ |
| | | temp.setDwgUrl(dirPathDB + fileFullName); |
| | | mh.setDwgUrl(dirPathDB + fileFullName); |
| | | }else { |
| | | temp.setPictureUrl(dirPathDB + fileFullName); |
| | | mh.setPictureUrl(dirPathDB + fileFullName); |
| | | } |
| | | mapper.updateById(temp); |
| | | mhService.insert(mh); |
| | | |
| | | return new Response().set(1, true, "上传完成"); |
| | | } |
| | | public Response dwgCompare(int materialId, int materialId2) throws IOException { |
| | | ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); |
| | | HttpServletResponse response = servletRequestAttributes.getResponse(); |
| | | |
| | | //获取各自物料的图纸 |
| | | String dwgUrl = mapper.selectById(materialId).getDwgUrl(); |
| | | String dwgUrl2 = mapper.selectById(materialId2).getDwgUrl(); |
| | | if(dwgUrl == null || dwgUrl2 == null){ |
| | | return new Response().set(1,false,"无法对比,所选物料至少有1个不存在图纸"); |
| | | } |
| | | String dwgFileStr = CommonUtil.getProjectDir() + File.separator + dwgUrl; |
| | | String dwgFileStr2 = CommonUtil.getProjectDir() + File.separator + dwgUrl2; |
| | | |
| | | String absoluteDwgPngPath = dwgFileStr.substring(0,dwgFileStr.lastIndexOf("."))+"-dwg.png"; |
| | | String absoluteDwgPngPath2 = dwgFileStr2.substring(0,dwgFileStr2.lastIndexOf("."))+"-dwg.png"; |
| | | if(!new File(absoluteDwgPngPath).exists()){ |
| | | DwgToPngUtil.dwg2png(new File(dwgFileStr)); |
| | | } |
| | | if(!new File(absoluteDwgPngPath2).exists()) { |
| | | DwgToPngUtil.dwg2png(new File(dwgFileStr2)); |
| | | } |
| | | |
| | | ByteArrayOutputStream stream = ImageDiff.compareImages(absoluteDwgPngPath, absoluteDwgPngPath2); |
| | | return new Response().setII(1,true, Base64.encodeBase64String(stream.toByteArray()),null); |
| | | //String fileName = "name.png"; |
| | | //OutputStream toClient = null; |
| | | //try { |
| | | // response.setContentType("application/octet-stream"); |
| | | // response.setHeader("Content-Disposition","attachment;filename=" + fileName); |
| | | // response.addHeader("Pragma", "no-cache"); |
| | | // response.addHeader("Cache-Control", "no-cache"); |
| | | // toClient = response.getOutputStream(); |
| | | // stream.writeTo(toClient); |
| | | // //toClient.write(stream.toByteArray()); |
| | | // toClient.flush(); |
| | | // toClient.close(); |
| | | //} catch (IOException e) { |
| | | // e.printStackTrace(); |
| | | //} |
| | | // |
| | | // |
| | | //return null; |
| | | } |
| | | |
| | | public void updateDwgUrlAndPicUrl(List<Material> materialUpdateList) { |
| | | mapper.updateDwgUrlAndPicUrl(materialUpdateList); |
| | | } |
| | | |
| | | public List<Material> getSameSubCodeAndModel(List<ProductBom> bomList) { |
| | | return mapper.getSameSubCodeAndModel(bomList); |
| | | } |
| | | |
| | | public void checkNaming(InputStream inputStream, HttpServletResponse response) throws IOException, InvalidFormatException { |
| | | List<MaterialCheckDTO> checkList = new LinkedList<>(); |
| | | Workbook workbook = null; |
| | | workbook = WorkbookFactory.create(inputStream); |
| | | inputStream.close(); |
| | | //取第一个sheet表 |
| | | Sheet sheet = workbook.getSheetAt(0); |
| | | int lastRowNum = sheet.getLastRowNum(); |
| | | for (int i = 1; i <= lastRowNum; i++) { |
| | | System.out.println(i); |
| | | //从第二行开始 |
| | | Row row = sheet.getRow(i); |
| | | Cell cell = row.getCell(0); |
| | | cell.setCellType(CellType.STRING); |
| | | String code = cell.getStringCellValue(); |
| | | String name = row.getCell(1).getStringCellValue(); |
| | | Cell cell2 = row.getCell(2); |
| | | cell2.setCellType(CellType.STRING); |
| | | String model = cell2.getStringCellValue(); |
| | | |
| | | MaterialCheckDTO dto = new MaterialCheckDTO(); |
| | | dto.setNum(i); |
| | | dto.setSubName(name); |
| | | dto.setSubCode(code); |
| | | dto.setSubModel(model); |
| | | checkList.add(dto); |
| | | } |
| | | List<MaterialCheckDTO> materialCheckDTOS = CommonUtil.checkFormat(checkList); |
| | | int size = materialCheckDTOS.size(); |
| | | //ECR编号,申请日期,申请人,变更描述,变更料号,变更型号,变更所属型号,处理方式,创建时间 |
| | | String[] title = new String[]{"序号","物料编码","物料名称","规格型号","不规范原因"}; |
| | | String[][] values = new String[size][]; //size行 |
| | | for (int i = 0; i < size; i++) { |
| | | values[i] = new String[5]; |
| | | MaterialCheckDTO dto = materialCheckDTOS.get(i); |
| | | values[i][0] = dto.getNum().toString(); |
| | | values[i][1] = dto.getSubCode(); |
| | | values[i][2] = dto.getSubName(); |
| | | values[i][3] = dto.getSubModel(); |
| | | values[i][4] = dto.getIrregularDesc(); |
| | | } |
| | | ExcelUtil.exportExcel("清单","物料",title,values,null,response); |
| | | } |
| | | |
| | | public Material getLastByCode(String code) { |
| | | QueryWrapper<Material> query = Wrappers.query(); |
| | | query.eq("sub_code",code).orderByDesc("id").last(" limit 1"); |
| | | return mapper.selectOne(query); |
| | | } |
| | | //物料推送弹窗使用 |
| | | public Response getMaterialDialog(String subCode, String subName, String subModel) { |
| | | List<Material> list=mapper.getMaterialLimit(subCode,subName,subModel); |
| | | String fileDirName = FileDirPath.getFileDirName(); |
| | | int flag=0; |
| | | Material m=new Material(); |
| | | // 返回是否存在附件 |
| | | if(list!=null&&list.size()>0){ |
| | | m=list.get(list.size()-1); |
| | | if(m.getFileUrl()!=null&&!m.getFileUrl().isEmpty()){ |
| | | File file = new File(fileDirName+File.separator+m.getFileUrl()); |
| | | if(!file.exists()) { |
| | | flag=0; |
| | | }else{ |
| | | String[] fileNames = file.list();//获取该文件夹下的所有文件以及目录的名字 |
| | | List attachFileList=new ArrayList(); |
| | | if(fileNames.length>0){ |
| | | flag=1; |
| | | for (int i=0;i<fileNames.length;i++){ |
| | | if(!fileNames[i].contains("-dwg.pdf")&&!fileNames[i].contains("-doc.pdf")) |
| | | attachFileList.add(fileNames[i]); |
| | | } |
| | | }else{ |
| | | flag=0; |
| | | } |
| | | m.setAttachFileList(attachFileList); |
| | | } |
| | | } |
| | | m.setHasAttachFlag(flag); |
| | | } |
| | | return new Response().setII(1,m!=null,m,"物料推送弹窗使用"); |
| | | } |
| | | } |