package org.jeecg.modules.dnc.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.IdWorker; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.apache.shiro.SecurityUtils; import org.jeecg.common.api.vo.FileUploadResult; import org.jeecg.common.api.vo.Result; import org.jeecg.common.exception.JeecgBootException; import org.jeecg.common.system.vo.LoginUser; import org.jeecg.modules.dnc.entity.*; import org.jeecg.modules.dnc.exception.ExceptionCast; import org.jeecg.modules.dnc.ext.NcTxtFilePathInfo; import org.jeecg.modules.dnc.listener.FileMonitorConfig; import org.jeecg.modules.dnc.mapper.DocInfoMapper; import org.jeecg.modules.dnc.request.DocInfoQueryRequest; import org.jeecg.modules.dnc.request.DocInfoUploadRequest; import org.jeecg.modules.dnc.response.*; import org.jeecg.modules.dnc.service.*; import org.jeecg.modules.dnc.utils.CamelToSnakeRegex; import org.jeecg.modules.dnc.utils.ValidateUtil; import org.jeecg.modules.dnc.utils.file.FileUtilS; import org.jeecg.modules.dncFlow.entity.DispatchFile; import org.jeecg.modules.dncFlow.service.IDispatchFileService; import org.jeecg.modules.flowable.apithird.business.entity.FlowMyBusiness; import org.jeecg.modules.flowable.apithird.business.service.IFlowMyBusinessService; import org.jeecg.modules.flowable.service.IFlowTaskService; import org.jeecg.modules.mdc.entity.MdcEquipment; import org.jeecg.modules.mdc.service.IMdcEquipmentService; import org.jeecg.modules.system.entity.SysParams; import org.jeecg.modules.system.service.IMdcProductionService; import org.jeecg.modules.system.service.ISysParamsService; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Scanner; import java.util.stream.Collectors; @Service public class DocInfoServiceImpl extends ServiceImpl implements IDocInfoService { @Autowired private FileMonitorConfig config; @Autowired private IMdcEquipmentService iMdcEquipmentService; @Autowired private IMdcProductionService iMdcProductionService; @Autowired private IDocClassificationService docClassificationService; @Autowired private IDocFileService docFileService; @Autowired private IFileOperateService fileOperateService; @Autowired @Lazy private IDocRelativeService docRelativeService; @Autowired private IDispatchFileService dispatchFileService; @Autowired private ISysParamsService sysParamsService; @Autowired @Lazy private IComponentInfoService componentInfoService; @Autowired @Lazy private IGuideCardBatchService guideCardBatchService; @Autowired private IFlowMyBusinessService flowMyBusinessService; @Autowired private IFlowTaskService flowTaskService; /*备份处理*/ @Override @Transactional(rollbackFor = {Exception.class}) public boolean addDocInfo(MultipartFile file, DocInfoUploadRequest uploadRequest) { if(file == null || file.isEmpty() || uploadRequest == null) ExceptionCast.cast(CommonCode.INVALID_PARAM); if(!ValidateUtil.validateString(uploadRequest.getAttributionId()) || !ValidateUtil.validateInteger(uploadRequest.getAttributionType())) ExceptionCast.cast(DocumentCode.DOC_ATTRIBUTE_ERROR); if(!ValidateUtil.validateString(uploadRequest.getDocClassCode())) ExceptionCast.cast(DocumentCode.DOC_CLASS_ERROR); DocClassification docClass = docClassificationService.getByCode(uploadRequest.getDocClassCode()); if(docClass == null) ExceptionCast.cast(DocumentCode.DOC_CLASS_ERROR); String fileName = FileUtilS.getFilenameNonSuffix(file.getOriginalFilename()); String fileNameAll = file.getOriginalFilename(); DocInfo en = findByAttrAndDocName(fileName, uploadRequest.getAttributionType(), uploadRequest.getAttributionId()); //针对存在的处理 if(en != null) ExceptionCast.cast(DocumentCode.DOC_IS_EXIST); FileUploadResult fileUploadResult = FileUtilS.uploadFile(file); if(fileUploadResult == null) ExceptionCast.cast(DocumentCode.DOC_UPLOAD_ERROR); DocInfo docInfo = new DocInfo(); String docId = IdWorker.getIdStr(); docInfo.setDocId(docId); docInfo.setSyncStatus(2); docInfo.setDocName(fileUploadResult.getFileName()); docInfo.setDocSuffix(fileUploadResult.getFileSuffix()); docInfo.setDocStatus(1); DocRelative docRelative = new DocRelative(); docRelative.setAttributionId(uploadRequest.getAttributionId()); docRelative.setDocId(docInfo.getDocId()); docRelative.setAttributionType(uploadRequest.getAttributionType()); docRelative.setClassificationId(docClass.getClassificationId()); boolean b = docRelativeService.save(docRelative); if (uploadRequest.getAttributionType()==2){ //查询借用的部件 List borrowComponentInfoList=componentInfoService.list(new QueryWrapper().eq("borrow_id", uploadRequest.getAttributionId())); if (!borrowComponentInfoList.isEmpty()) { borrowComponentInfoList.forEach(item->{ DocRelative borrowDocRelative = new DocRelative(); BeanUtil.copyProperties(docRelative,borrowDocRelative); borrowDocRelative.setAttributionId(item.getComponentId()); borrowDocRelative.setId(null); docRelativeService.save(borrowDocRelative); }); } } if(!b) ExceptionCast.cast(DocumentCode.DOC_UPLOAD_ERROR); DocFile docFile = new DocFile(); docFile.setDocId(docInfo.getDocId()); docFile.setFileName(fileUploadResult.getFileName()); docFile.setFileEncodeName(fileUploadResult.getFileEncodeName()); docFile.setFilePath(fileUploadResult.getFilePath()); docFile.setFileSize(fileUploadResult.getFileSize()); docFile.setFileSuffix(fileUploadResult.getFileSuffix()); b = docFileService.addDocFile(docFile); if(!b) ExceptionCast.cast(DocumentCode.DOC_UPLOAD_ERROR); docInfo.setPublishVersion(docFile.getDocVersion()); docInfo.setPublishFileId(docFile.getFileId()); //COPY MdcEquipment mdcEquipment= iMdcEquipmentService.getById(uploadRequest.getAttributionId()); if (mdcEquipment != null) { List strings = iMdcProductionService.findListParentTreeAll(mdcEquipment.getId()); boolean copyFileNc = false; if (strings != null && !strings.isEmpty()) { String path = org.apache.commons.lang3.StringUtils.join(strings.toArray(), "/"); copyFileNc = FileUtilS.copyFile(fileUploadResult.getFilePath()+"/" + fileUploadResult.getFileEncodeName(), path+ "/" + mdcEquipment.getEquipmentId() ,fileNameAll); if (!copyFileNc) { ExceptionCast.cast(ActivitiCode.ACT_FILE_ERROR); } else { FileUtilS.deleteZipFromToSend(path + "/"+ mdcEquipment.getEquipmentId(), docFile.getFileName(),docFile.getFileSuffix()); } } else { copyFileNc =FileUtilS.copyFile(fileUploadResult.getFilePath()+"/" + fileUploadResult.getFileEncodeName(), mdcEquipment.getEquipmentId() ,fileNameAll); if (!copyFileNc) { ExceptionCast.cast(ActivitiCode.ACT_FILE_ERROR); } else { FileUtilS.deleteZipFromToSend(fileUploadResult.getFilePath()+"/" + fileUploadResult.getFileEncodeName() + "/"+ mdcEquipment.getEquipmentId(), docFile.getFileName(),docFile.getFileSuffix()); } } } boolean saveBool = super.save(docInfo); if (uploadRequest.getDocClassCode().equals("NC")||uploadRequest.getDocClassCode().equals("other")){ SysParams sysParams=sysParamsService.getSysPramBySettingKey("nc_dispatch_file"); if (sysParams ==null){ throw new JeecgBootException("未配置导入NC与电子图版是否触发审签流程，请联系管理员"); }else { if (saveBool&&sysParams.getSettingValue().equals("1")){ //触发审签 DispatchFile dispatchFile = new DispatchFile(); dispatchFile.setDocId(docInfo.getDocId()); dispatchFile.setFileId(docFile.getFileId()); dispatchFile.setAttributionId(uploadRequest.getAttributionId()); dispatchFile.setAttributionType(String.valueOf(uploadRequest.getAttributionType())); dispatchFile.setDocClassCode(uploadRequest.getDocClassCode()); dispatchFileService.saveDispatchFile(dispatchFile); } } } if (uploadRequest.getDocClassCode().equals("NC")){ boolean savaGuideCardBatch=guideCardBatchService.importGuideCardBatch(docInfo.getDocId(),uploadRequest.getAttributionId(),uploadRequest.getAttributionType()); if (!savaGuideCardBatch) { ExceptionCast.cast(DocumentCode.DOC_BATCH_ERROR); } } return saveBool; } @Override @Transactional(rollbackFor = {Exception.class}) public boolean addDocInfoRec(String pathFile,File fileRec) { if (StringUtils.isEmpty(pathFile)) { return false; } MultipartFile file = FileUtilS.fileToMultipartFile(fileRec); DocClassification docClass = docClassificationService.getByCode("REC"); if(docClass == null) { ExceptionCast.cast(DocumentCode.DOC_CLASS_ERROR); } //根据设备编号查询数据 Integer recNum = pathFile.lastIndexOf("\\rec\\"); if (recNum == -1) { return false; } String recF = pathFile.substring(0,recNum);//将返回def}ab Integer equipmentId = recF.lastIndexOf("\\"); String deviceNo = recF.substring(equipmentId+1); if (StringUtils.isEmpty(deviceNo)) { return false; } MdcEquipment mdcEquipment = iMdcEquipmentService.findEquipmentNameByEquipmentId(deviceNo); if (mdcEquipment == null) { return false; } String fileName = FileUtilS.getFilenameNonSuffix(file.getOriginalFilename()); FileUploadResult fileUploadResult = FileUtilS.uploadFile(file); if(fileUploadResult == null) { return false; } DocInfo en = findByAttrAndDocName(fileName, 7, mdcEquipment.getId()); if(en != null) { return false; } DocInfo docInfo = new DocInfo(); String docId = IdWorker.getIdStr(); docInfo.setDocId(docId); docInfo.setDocName(fileUploadResult.getFileName()); docInfo.setDocSuffix(fileUploadResult.getFileSuffix()); docInfo.setDocStatus(1); docInfo.setSyncStatus(2); DocRelative docRelative = new DocRelative(); docRelative.setAttributionId(mdcEquipment.getId()); docRelative.setDocId(docInfo.getDocId()); docRelative.setAttributionType(7); docRelative.setClassificationId(docClass.getClassificationId()); boolean b = docRelativeService.save(docRelative); if(!b) { ExceptionCast.cast(DocumentCode.DOC_UPLOAD_ERROR); } DocFile docFile = new DocFile(); docFile.setDocId(docInfo.getDocId()); docFile.setFileName(fileUploadResult.getFileName()); docFile.setFileEncodeName(fileUploadResult.getFileEncodeName()); docFile.setFilePath(fileUploadResult.getFilePath()); docFile.setFileSize(fileUploadResult.getFileSize()); docFile.setFileSuffix(fileUploadResult.getFileSuffix()); b = docFileService.addDocFile(docFile); if(!b) { return false; } docInfo.setPublishVersion(docFile.getDocVersion()); docInfo.setPublishFileId(docFile.getFileId()); boolean saveBool = super.save(docInfo); return saveBool; } /** * 解析NC文档通用方法 * @param pathFile,fileRec * @return */ @Override @Transactional(rollbackFor = {Exception.class}) public boolean addDocInfoAnalysisGwNcService(String pathFile,File file) throws FileNotFoundException { String line; int count = 0; String loFilePath = config.getPaths().get(0)+"/" + file.getName(); FileInputStream fis = new FileInputStream(loFilePath); NcTxtFilePathInfo result = new NcTxtFilePathInfo(); Scanner sc = new Scanner(fis, "UTF-8"); while (count < 8 && sc.hasNext()) { line = sc.nextLine(); if (count ==0) { result.setFileTxtName(line.trim()); } else if (count ==1) { result.setFileNcName(line.trim()); }else if (count ==2) { result.setOrigFileName(line.trim()); }else if (count ==3) { result.setOrigFileSuffix(line.trim()); }else if (count ==4) { result.setFilePath(line.trim()); }else if (count ==5) { result.setEquipmentId(line.trim()); }else if (count ==6) { result.setFileAddOrDelete(Integer.valueOf(line.trim())); }else if (count == 7) { result.setFileSize(line.trim()); } count++; } sc.close(); if (result.getFileAddOrDelete() != null ) { if ( result.getFileAddOrDelete()==1) { String path = config.getPaths().get(0) +"/" + result.getFileNcName()+ ".NC"; if (org.apache.commons.lang3.StringUtils.isNotBlank(result.getFileNcName()) && result.getFileNcName().equals("null")) { //文件待处理 //备份数据 FileUtilS.deleteFileNewRec(loFilePath); } File ncFile = new File(path); //已经存在文件需要备份 String size = String.valueOf(ncFile.length()); if (!size.equals(result.getFileSize())) { return false; } boolean bool = this.addDocInfoRecService(result.getEquipmentId(), ncFile,result.getOrigFileSuffix(), FileUtilS.getFilenameNonSuffix(result.getOrigFileName()) ,result.getFilePath()); if (bool) { FileUtilS.deleteFileNewRec(path); FileUtilS.deleteFileNewRec(loFilePath); }else { return false; } } } return true; } /** * 程序回传（涉密解析工控） * @param pathFile */ @Override @Transactional(rollbackFor = {Exception.class}) public boolean addDocInfoAnalysisSmwNcService(String pathFile,File fileRec){ //确认解析目录 return true; } /** * 文档解析 * todo 修改创建文件关联关系，改成固定docId，去除创建DocInfo * @param equipmentId * @param fileRec * @param fileNameSuffix * @param fileNameNew * @param filePath * @return */ @Override @Transactional(rollbackFor = {Exception.class}) public boolean addDocInfoRecService(String equipmentId,File fileRec,String fileNameSuffix,String fileNameNew,String filePath ) { if (StringUtils.isEmpty(filePath)) { return false; } MultipartFile file = FileUtilS.fileToMultipartFile(fileRec); DocClassification docClass = docClassificationService.getByCode("REC"); if(docClass == null) { ExceptionCast.cast(DocumentCode.DOC_CLASS_ERROR); } //根据设备编号查询数据 if (StringUtils.isEmpty(equipmentId)) { return false; } MdcEquipment mdcEquipment = iMdcEquipmentService.findEquipmentNameByEquipmentId(equipmentId); if (mdcEquipment == null) { return false; } String fileName = FileUtilS.getFilenameNonSuffix(file.getOriginalFilename()); FileUploadResult fileUploadResult = FileUtilS.uploadFileUpdateFileName(file,fileNameNew,fileNameSuffix); if(fileUploadResult == null) { return false; } DocInfo en = findByAttrAndDocName(fileName, 7, mdcEquipment.getId()); if(en != null) { return false; } DocInfo docInfo = new DocInfo(); String docId = IdWorker.getIdStr(); docInfo.setDocId(docId); docInfo.setDocName(fileUploadResult.getFileName()); docInfo.setDocSuffix(fileUploadResult.getFileSuffix()); docInfo.setDocStatus(1); docInfo.setSyncStatus(2); DocRelative docRelative = new DocRelative(); docRelative.setAttributionId(mdcEquipment.getId()); docRelative.setDocId(docInfo.getDocId()); docRelative.setAttributionType(7); docRelative.setClassificationId(docClass.getClassificationId()); boolean b = docRelativeService.save(docRelative); if(!b) { ExceptionCast.cast(DocumentCode.DOC_UPLOAD_ERROR); } DocFile docFile = new DocFile(); docFile.setDocId(docInfo.getDocId()); docFile.setFileName(fileUploadResult.getFileName()); docFile.setFileEncodeName(fileUploadResult.getFileEncodeName()); docFile.setFilePath(fileUploadResult.getFilePath()); docFile.setFileSize(fileUploadResult.getFileSize()); docFile.setFileSuffix(fileUploadResult.getFileSuffix()); b = docFileService.addDocFile(docFile); if(!b) { return false; } docInfo.setPublishVersion(docFile.getDocVersion()); docInfo.setPublishFileId(docFile.getFileId()); boolean saveBool = super.save(docInfo); return saveBool; } @Override @Transactional(rollbackFor = {Exception.class}) public boolean editDocInfo(String id, DocInfo docInfo) { if(!ValidateUtil.validateString(id) || docInfo == null) ExceptionCast.cast(CommonCode.INVALID_PARAM); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); DocInfo asDoc = findByAttrAndDocNameNotThis(docInfo.getDocName(), docInfo.getAttributionType(), docInfo.getAttributionId(), id); if(asDoc != null) ExceptionCast.cast(DocumentCode.DOC_IS_EXIST); docInfo.setDocId(id); docInfo.setDocStatus(null); docInfo.setDocSuffix(null); docInfo.setClassificationId(null); docInfo.setPublishFileId(null); docInfo.setPublishVersion(null); return super.updateById(docInfo); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean deleteDocInfo(String id,String attrType,String attrId) { if(!ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); if(en.getDocStatus() != 1) ExceptionCast.cast(DocumentCode.DOC_DEL_ERROR); //查询对应的关系 if ("2".equals(attrType)) { //判断部件引用 ComponentInfo componentInfo=componentInfoService.getById(attrId); if(componentInfo!=null&&componentInfo.getBorrowId()!=null){ //借用的部件，只删除自己的关系 DocRelative docRelative=docRelativeService.getOne(new QueryWrapper() .eq("attribution_id", attrId).eq("attribution_type", 2).eq("doc_id",id)); if(docRelative!=null){ docRelativeService.removeById(docRelative.getId()); return true; } } } FileOperate operate = fileOperateService.getByDocId(id); if(operate != null) ExceptionCast.cast(DocumentCode.DOC_IS_OPERATING); boolean b = docFileService.deleteByDocId(id); if(!b) ExceptionCast.cast(CommonCode.FAIL); b = docRelativeService.deleteByDocId(id); if(!b) ExceptionCast.cast(CommonCode.FAIL); //强制结束流程 删除用户的此待办任务 List dispatchFiles=dispatchFileService.list(new QueryWrapper().eq("doc_id",id)); if (dispatchFiles != null && !dispatchFiles.isEmpty()) { FlowMyBusiness flowMyBusiness = flowMyBusinessService.selectByDataId(dispatchFiles.get(0).getId()); if (flowMyBusiness != null) { flowTaskService.end(flowMyBusiness.getProcessInstanceId(), "删除文档"); } } return super.removeById(id); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean pushDocFile(String id, MultipartFile file) { if(file == null || file.isEmpty() || !ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if(!ValidateUtil.validateString(user.getUsername())) ExceptionCast.cast(UcenterCode.UCENTER_ACCOUNT_NOT_EXIST); FileOperate operate = fileOperateService.getByDocId(id); if(operate == null || !user.getUsername().equals(operate.getCreateBy())) ExceptionCast.cast(DocumentCode.DOC_OPERATE_PUSH_FAIL); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); List deviceList = docRelativeService.findDeviceByDocId(en.getDocId()); if(deviceList != null && !deviceList.isEmpty()) ExceptionCast.cast(DocumentCode.DOC_DEVICE_EXIST); String suffix = FileUtilS.getFileSuffix(file.getOriginalFilename()); if(ValidateUtil.validateString(en.getDocSuffix())) { if(!en.getDocSuffix().equals(suffix)) { ExceptionCast.cast(DocumentCode.DOC_SUFFIX_ERROR); } }else { if(ValidateUtil.validateString(suffix)) { ExceptionCast.cast(DocumentCode.DOC_SUFFIX_ERROR); } } FileUploadResult fileUploadResult = FileUtilS.uploadFile(file); DocFile docFile = new DocFile(); docFile.setDocId(id); docFile.setFileName(fileUploadResult.getFileName()); docFile.setFileEncodeName(fileUploadResult.getFileEncodeName()); docFile.setFilePath(fileUploadResult.getFilePath()); docFile.setFileSize(fileUploadResult.getFileSize()); docFile.setFileSuffix(fileUploadResult.getFileSuffix()); boolean b = fileOperateService.deleteByDocId(id); if(!b) ExceptionCast.cast(CommonCode.FAIL); b= docFileService.addDocFile(docFile); if(!b) ExceptionCast.cast(CommonCode.FAIL); en.setPublishVersion(docFile.getDocVersion()); en.setPublishFileId(docFile.getFileId()); return super.updateById(en); } @Override @Transactional(rollbackFor = {Exception.class}) public DocFile checkDocInfo(String id) { if(!ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); if(en.getDocStatus() != 1) ExceptionCast.cast(DocumentCode.DOC_OPERATE_FAIL); if(!ValidateUtil.validateString(en.getPublishFileId())) ExceptionCast.cast(DocumentCode.DOC_PUBLISH_FILE_NONE); FileOperate operate = fileOperateService.getByDocId(id); if(operate != null) ExceptionCast.cast(DocumentCode.DOC_IS_OPERATING); operate = new FileOperate(); operate.setDocId(id); boolean b = fileOperateService.save(operate); if(!b) ExceptionCast.cast(DocumentCode.DOC_OPERATE_FAIL); DocFile fileInfo = docFileService.getById(en.getPublishFileId()); if(fileInfo == null) ExceptionCast.cast(DocumentCode.DOC_PUBLISH_FILE_NOT_EXIST); return fileInfo; } @Override @Transactional(rollbackFor = {Exception.class}) public boolean publishDocInfo(String id) { if(!ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); if(en.getDocStatus() != 1) ExceptionCast.cast(DocumentCode.DOC_PUBLISH_ERROR); if(!ValidateUtil.validateString(en.getPublishFileId())) ExceptionCast.cast(DocumentCode.DOC_PUBLISH_FILE_NONE); DocFile pubFile = docFileService.getById(en.getPublishFileId()); if(pubFile == null) ExceptionCast.cast(DocumentCode.DOC_FILE_ERROR); FileOperate operate = fileOperateService.getByDocId(id); if(operate != null) ExceptionCast.cast(DocumentCode.DOC_IS_OPERATING); DocFile old = docFileService.getDocFileNearest(en.getDocId()); if(old == null) ExceptionCast.cast(DocumentCode.DOC_PUBLISH_FILE_NONE); if(old.getDocVersion().contains(".")) { DocFile docFile = new DocFile(); BeanUtils.copyProperties(pubFile, docFile); docFile.setFileId(null); docFile.setDocVersion(old.getDocVersion().substring(0, 1)); boolean b = docFileService.save(docFile); if(!b) ExceptionCast.cast(CommonCode.FAIL); return super.lambdaUpdate().eq(DocInfo::getDocId, id).set(DocInfo::getDocStatus, 2).set(DocInfo::getPublishFileId, docFile.getFileId()) .set(DocInfo::getPublishVersion, docFile.getDocVersion()).update(); }else { return super.lambdaUpdate().eq(DocInfo::getDocId, id).set(DocInfo::getDocStatus, 2).set(DocInfo::getPublishFileId, old.getFileId()) .set(DocInfo::getPublishVersion, old.getDocVersion()).update(); } } @Override @Transactional(rollbackFor = {Exception.class}) public boolean republishDocInfo(String id) { if(!ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); if(en.getDocStatus() != 2) ExceptionCast.cast(DocumentCode.DOC_REPUBLISH_ERROR); return super.lambdaUpdate().eq(DocInfo::getDocId, id).set(DocInfo::getDocStatus, 1).update(); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean pigeonholeDocInfo(String id) { if(!ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); if(en.getDocStatus() == 3) ExceptionCast.cast(DocumentCode.DOC_PIGEONHOLE_ERROR); FileOperate operate = fileOperateService.getByDocId(id); if(operate != null) ExceptionCast.cast(DocumentCode.DOC_IS_OPERATING); return super.lambdaUpdate().eq(DocInfo::getDocId, id).set(DocInfo::getDocStatus, 3).update(); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean cancelPullDocInfo(String id) { if(!ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if(!ValidateUtil.validateString(user.getUsername())) ExceptionCast.cast(UcenterCode.UCENTER_ACCOUNT_NOT_EXIST); FileOperate operate = fileOperateService.getByDocId(id); if(operate == null || !user.getUsername().equals(operate.getCreateBy())) ExceptionCast.cast(DocumentCode.DOC_CANCEL_PULL_ERROR); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); return fileOperateService.deleteByDocId(id); } @Override public Result findPageList(int page, int size, DocInfoQueryRequest docQuery) { if(page < 1 || size < 1) { ExceptionCast.cast(CommonCode.INVALID_PAGE); } if(docQuery == null || !ValidateUtil.validateString(docQuery.getAttributionId()) || !ValidateUtil.validateInteger(docQuery.getAttributionType()) || !ValidateUtil.validateString(docQuery.getDocClassCode())) { ExceptionCast.cast(CommonCode.INVALID_PARAM); } DocClassification docClassification = docClassificationService.getByCode(docQuery.getDocClassCode()); if(docClassification == null) { ExceptionCast.cast(CommonCode.INVALID_PAGE); } IPage pageData = new Page<>(page, size); // LambdaQueryWrapper lambdaQuery = Wrappers.lambdaQuery(); // lambdaQuery.eq(DocInfo::getAttributionType, docQuery.getAttributionType()).eq(DocInfo::getAttributionId, docQuery.getAttributionId()) // .eq(DocInfo::getClassificationId, docClassification.getClassificationId()); QueryWrapper queryWrapper = Wrappers.query(); queryWrapper.eq("r.attribution_type", docQuery.getAttributionType()).eq("r.attribution_id", docQuery.getAttributionId()) .eq("r.classification_id", docClassification.getClassificationId()); if (StringUtils.isNotEmpty(docQuery.getDocName())) { int dotIndex = docQuery.getDocName().lastIndexOf("."); if (dotIndex == -1) { queryWrapper.like("u.doc_name", docQuery.getDocName()); } else { String[] docNameArr = docQuery.getDocName().split("\\."); queryWrapper.like(StrUtil.isNotEmpty(docNameArr[0]), "u.doc_name", docNameArr[0]); queryWrapper.eq(StrUtil.isNotEmpty(docNameArr[1]), "u.doc_suffix", docNameArr[1]); } } getDocQuery(docQuery, queryWrapper); IPage docInfoIPage = super.getBaseMapper().findDocExtList(pageData, queryWrapper); return Result.ok(docInfoIPage); } private void getDocQuery(DocInfoQueryRequest docQuery, QueryWrapper queryWrapper) { if (docQuery.getDocStatus() != null && docQuery.getDocStatus().contains(",")) { String[] docStatusArray = docQuery.getDocStatus().split(","); List docStatusList = Arrays.stream(docStatusArray).map(Integer::parseInt).collect(Collectors.toList()); queryWrapper.in("u.doc_status",docStatusList); }else { queryWrapper.eq(StrUtil.isNotEmpty(docQuery.getDocStatus()),"u.doc_status",docQuery.getDocStatus()); } if (docQuery.getDocDispatchStatus() != null && docQuery.getDocDispatchStatus().contains(",")) { String[] docDispatchStatusArray = docQuery.getDocDispatchStatus().split(","); List docDispatchStatusList = Arrays.stream(docDispatchStatusArray).map(Integer::parseInt).collect(Collectors.toList()); queryWrapper.in("u.doc_dispatch_status",docDispatchStatusList); }else { queryWrapper.eq(StrUtil.isNotEmpty(docQuery.getDocDispatchStatus()),"u.doc_dispatch_status",docQuery.getDocDispatchStatus()); } if (StrUtil.isNotEmpty(docQuery.getPullStatus())){ if (("1").equals(docQuery.getPullStatus())){ queryWrapper.isNull("o.doc_id"); }else if (("2").equals(docQuery.getPullStatus())){ queryWrapper.isNotNull("o.doc_id"); } } queryWrapper.ge(StrUtil.isNotEmpty(docQuery.getStartTime()),"u.create_time",docQuery.getStartTime()+" 00:00:00"); queryWrapper.le(StrUtil.isNotEmpty(docQuery.getEndTime()),"u.create_time",docQuery.getEndTime()+" 23:59:59"); if (StrUtil.isNotEmpty(docQuery.getColumn())){ if (("desc").equals(docQuery.getOrder())){ queryWrapper.orderByDesc("u."+ CamelToSnakeRegex.camelToSnake(docQuery.getColumn())); }else { queryWrapper.orderByAsc("u."+CamelToSnakeRegex.camelToSnake(docQuery.getColumn())); } } } @Override public DocInfo getByDocAttrAndDocId(String docId, Integer attrType, String attributeId) { if(!ValidateUtil.validateString(docId) || !ValidateUtil.validateString(attributeId) || !ValidateUtil.validateInteger(attrType)) return null; List list = super.getBaseMapper().getByDocAttrAndDocId(docId, attrType, attributeId); if(list == null || list.size() != 1) return null; return list.get(0); } @Override public DocFile previewDocFile(String id) { if(!ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); DocFile fileInfo = docFileService.getById(en.getPublishFileId()); if(fileInfo == null) ExceptionCast.cast(DocumentCode.DOC_PUBLISH_FILE_NOT_EXIST); return fileInfo; } @Override @Transactional(rollbackFor = {Exception.class}) public boolean deleteByProductId(String productId) { if(!ValidateUtil.validateString(productId)) ExceptionCast.cast(CommonCode.INVALID_PARAM); Integer attrType = 1; boolean b = docFileService.deleteByDocAttr(attrType, productId); if(!b) ExceptionCast.cast(CommonCode.FAIL); b = deleteByDocAttr(attrType, productId); if(!b) ExceptionCast.cast(CommonCode.FAIL); return docRelativeService.deleteByDocAttr(attrType, productId); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean deleteByComponentId(String componentId) { if(!ValidateUtil.validateString(componentId)) ExceptionCast.cast(CommonCode.INVALID_PARAM); Integer attrType = 2; boolean b = docFileService.deleteByDocAttr(attrType, componentId); if(!b) ExceptionCast.cast(CommonCode.FAIL); b = deleteByDocAttr(attrType, componentId); if(!b) ExceptionCast.cast(CommonCode.FAIL); return docRelativeService.deleteByDocAttr(attrType, componentId); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean deleteByPartsId(String partsId) { if(!ValidateUtil.validateString(partsId)) ExceptionCast.cast(CommonCode.INVALID_PARAM); Integer attrType = 3; boolean b = docFileService.deleteByDocAttr(attrType, partsId); if(!b) ExceptionCast.cast(CommonCode.FAIL); b = deleteByDocAttr(attrType, partsId); if(!b) ExceptionCast.cast(CommonCode.FAIL); return docRelativeService.deleteByDocAttr(attrType, partsId); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean deleteByDeviceId(String deviceId) { if(!ValidateUtil.validateString(deviceId)) ExceptionCast.cast(CommonCode.INVALID_PARAM); Integer attrType = 7; /*boolean b = docFileService.deleteByDocAttr(attrType, deviceId); if(!b) ExceptionCast.cast(CommonCode.FAIL); b = deleteByDocAttr(attrType, deviceId); if(!b) ExceptionCast.cast(CommonCode.FAIL);*/ return docRelativeService.deleteByDocAttr(attrType, deviceId); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean deleteByProcessId(String processId) { if(!ValidateUtil.validateString(processId)) ExceptionCast.cast(CommonCode.INVALID_PARAM); Integer attrType = 5; boolean b = docFileService.deleteByDocAttr(attrType, processId); if(!b) ExceptionCast.cast(CommonCode.FAIL); b = deleteByDocAttr(attrType, processId); if(!b) { ExceptionCast.cast(CommonCode.FAIL); } return docRelativeService.deleteByDocAttr(attrType, processId); } /** * 删除工步下的所有文档 * @param stepId * @return */ @Override @Transactional(rollbackFor = {Exception.class}) public boolean deleteByStepId(String stepId){ if(!ValidateUtil.validateString(stepId)) ExceptionCast.cast(CommonCode.INVALID_PARAM); Integer attrType = 6; boolean b = docFileService.deleteByDocAttr(attrType, stepId); if(!b) ExceptionCast.cast(CommonCode.FAIL); b = deleteByDocAttr(attrType, stepId); if(!b) { ExceptionCast.cast(CommonCode.FAIL); } return docRelativeService.deleteByDocAttr(attrType, stepId); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean deleteByDocAttr(Integer attrType, String attrId) { int i = super.getBaseMapper().deleteByDocAttr(attrType, attrId); return i >= 0; } @Override @Transactional(rollbackFor = {Exception.class}) public ResponseResult pullDocFile(HttpServletRequest request, HttpServletResponse response, String id) { DocFile docFile = checkDocInfo(id); if(!ValidateUtil.validateString(docFile.getFilePath()) || !ValidateUtil.validateString(docFile.getFileName()) || /*!ValidateUtil.validateString(docFile.getFileSuffix()) ||*/ !ValidateUtil.validateString(docFile.getFileEncodeName())) return new ResponseResult(CommonCode.FAIL); String fileName; if(ValidateUtil.validateString(docFile.getFileSuffix())) { fileName = docFile.getFileName() + "." + docFile.getFileSuffix(); }else { fileName = docFile.getFileName(); } String filePath = docFile.getFilePath(); String fileEncodeName = docFile.getFileEncodeName(); FileUtilS.downLoadFile(response, fileEncodeName, filePath, fileName); return null; } @Override public DocInfo findByAttrAndDocName(String docName, Integer attrType, String attrId) { List docInfoList = super.getBaseMapper().findByAttrAndDocName(docName, attrType, attrId); if(docInfoList == null || docInfoList.isEmpty()) return null; return docInfoList.get(0); } @Override public DocInfo findByAttrAndDocNameNotThis(String docName, Integer attrType, String attrId, String docId) { List docInfoList = super.getBaseMapper().findByAttrAndDocName(docName, attrType, attrId); if(docInfoList == null || docInfoList.isEmpty()) return null; for(DocInfo docInfo : docInfoList) { if(!docId.equals(docInfo.getDocId())) { return docInfo; } } return null; } @Override public List getByDocId(String docId) { return super.getBaseMapper().getByDocId(docId); } @Override public IPage findPageListByDevice(int page, int size, DocInfoQueryRequest docQuery) { if(page < 1 || size < 1) { ExceptionCast.cast(CommonCode.INVALID_PAGE); } if(docQuery == null || !ValidateUtil.validateString(docQuery.getAttributionId()) || !ValidateUtil.validateInteger(docQuery.getAttributionType()) || !ValidateUtil.validateString(docQuery.getDocClassCode())) { ExceptionCast.cast(CommonCode.INVALID_PARAM); } DocClassification docClassification = docClassificationService.getByCode(docQuery.getDocClassCode()); if(docClassification == null) { ExceptionCast.cast(CommonCode.INVALID_PAGE); } IPage pageData = new Page<>(page, size); QueryWrapper queryWrapper = Wrappers.query(); queryWrapper.eq("r.attribution_type", docQuery.getAttributionType()) .eq("r.attribution_id", docQuery.getAttributionId()) .eq("r.classification_id", docClassification.getClassificationId()); if (StringUtils.isNotEmpty(docQuery.getDocName())) { int dotIndex = docQuery.getDocName().lastIndexOf("."); if (dotIndex == -1) { queryWrapper.like("u.doc_name", docQuery.getDocName()); } else { String[] docNameArr = docQuery.getDocName().split("\\."); queryWrapper.like(StrUtil.isNotEmpty(docNameArr[0]), "u.doc_name", docNameArr[0]); queryWrapper.eq(StrUtil.isNotEmpty(docNameArr[1]), "u.doc_suffix", docNameArr[1]); } } if (docQuery.getDocStatus() != null && docQuery.getDocStatus().contains(",")) { String[] docStatusArray = docQuery.getDocStatus().split(","); List docStatusList = Arrays.stream(docStatusArray).map(Integer::parseInt).collect(Collectors.toList()); queryWrapper.in("u.doc_status",docStatusList); }else { queryWrapper.eq(StrUtil.isNotEmpty(docQuery.getDocStatus()),"u.doc_status",docQuery.getDocStatus()); } if (docQuery.getDocDispatchStatus() != null && docQuery.getDocDispatchStatus().contains(",")) { String[] docDispatchStatusArray = docQuery.getDocDispatchStatus().split(","); List docDispatchStatusList = Arrays.stream(docDispatchStatusArray).map(Integer::parseInt).collect(Collectors.toList()); queryWrapper.in("u.doc_dispatch_status",docDispatchStatusList); }else { queryWrapper.eq(StrUtil.isNotEmpty(docQuery.getDocDispatchStatus()),"u.doc_dispatch_status",docQuery.getDocDispatchStatus()); } if (StrUtil.isNotEmpty(docQuery.getPullStatus())){ if (("1").equals(docQuery.getPullStatus())){ queryWrapper.isNull("o.doc_id"); }else if (("2").equals(docQuery.getPullStatus())){ queryWrapper.isNotNull("o.doc_id"); } } if (docQuery.getSyncStatus()!=null){ if (docQuery.getSyncStatus()==1){ queryWrapper.isNotNull("t.sync_flag"); }else if (docQuery.getSyncStatus()==2){ queryWrapper.isNull("t.sync_flag"); } } queryWrapper.ge(StrUtil.isNotEmpty(docQuery.getStartTime()),"u.create_time",docQuery.getStartTime()+" 00:00:00"); queryWrapper.le(StrUtil.isNotEmpty(docQuery.getEndTime()),"u.create_time",docQuery.getEndTime()+" 23:59:59"); if (("desc").equals(docQuery.getOrder())){ queryWrapper.orderByDesc("u."+ CamelToSnakeRegex.camelToSnake(docQuery.getColumn())); }else { queryWrapper.orderByAsc("u."+CamelToSnakeRegex.camelToSnake(docQuery.getColumn())); } IPage docInfoIPage = super.getBaseMapper().findDeviceDocExtList(pageData, queryWrapper); if (docInfoIPage != null && docInfoIPage.getRecords() != null && !docInfoIPage.getRecords().isEmpty()) { for (DocInfo d : docInfoIPage.getRecords()) { d.setSyncStatus(2); } } return docInfoIPage; } @Override public List findList(DocInfoQueryRequest docQuery) { if(docQuery == null || !ValidateUtil.validateString(docQuery.getAttributionId()) || !ValidateUtil.validateInteger(docQuery.getAttributionType()) || !ValidateUtil.validateString(docQuery.getDocClassCode())) { ExceptionCast.cast(CommonCode.INVALID_PARAM); } DocClassification docClassification = docClassificationService.getByCode(docQuery.getDocClassCode()); if(docClassification == null) { ExceptionCast.cast(CommonCode.INVALID_PAGE); } QueryWrapper queryWrapper = Wrappers.query(); queryWrapper.eq(StrUtil.isNotEmpty(docQuery.getDocId()),"u.doc_id",docQuery.getDocId()); queryWrapper.eq("r.attribution_type", docQuery.getAttributionType()).eq("r.attribution_id", docQuery.getAttributionId()) .eq("r.classification_id", docClassification.getClassificationId()); if (StringUtils.isNotEmpty(docQuery.getDocName())) { int dotIndex = docQuery.getDocName().lastIndexOf("."); if (dotIndex == -1) { queryWrapper.like("u.doc_name", docQuery.getDocName()); } else { String[] docNameArr = docQuery.getDocName().split("\\."); queryWrapper.like(StrUtil.isNotEmpty(docNameArr[0]), "u.doc_name", docNameArr[0]); queryWrapper.eq(StrUtil.isNotEmpty(docNameArr[1]), "u.doc_suffix", docNameArr[1]); } } getDocQuery(docQuery, queryWrapper); return super.getBaseMapper().findDocExtList(queryWrapper); } /** * 通过一组attributionId,docClassCode,attributionType查询可指派的文档信息列表 * @param docQuery * @return */ @Override public List findListByDocQuery(DocInfoQueryRequest docQuery){ if(docQuery == null || !ValidateUtil.validateString(docQuery.getAttributionIds()) || !ValidateUtil.validateInteger(docQuery.getAttributionType()) || !ValidateUtil.validateString(docQuery.getDocClassCode())) { ExceptionCast.cast(CommonCode.INVALID_PARAM); } DocClassification docClassification = docClassificationService.getByCode(docQuery.getDocClassCode()); if(docClassification == null) { ExceptionCast.cast(CommonCode.INVALID_PAGE); } List attributionIds = Arrays.asList(docQuery.getAttributionIds().split(",")); QueryWrapper queryWrapper = Wrappers.query(); queryWrapper.eq(StrUtil.isNotEmpty(docQuery.getDocId()),"u.doc_id",docQuery.getDocId()); queryWrapper.eq("r.attribution_type", docQuery.getAttributionType()) .in("r.attribution_id", attributionIds) .eq("r.classification_id", docClassification.getClassificationId()); if (StringUtils.isNotEmpty(docQuery.getDocName())) { int dotIndex = docQuery.getDocName().lastIndexOf("."); if (dotIndex == -1) { queryWrapper.like("u.doc_name", docQuery.getDocName()); } else { String[] docNameArr = docQuery.getDocName().split("\\."); queryWrapper.like(StrUtil.isNotEmpty(docNameArr[0]), "u.doc_name", docNameArr[0]); queryWrapper.eq(StrUtil.isNotEmpty(docNameArr[1]), "u.doc_suffix", docNameArr[1]); } } getDocQuery(docQuery, queryWrapper); return super.getBaseMapper().findDocExtList(queryWrapper); } @Override public List getByProcessIds(List streams) { List ids = new ArrayList<>(); for(ProcessStream s : streams) { ids.add(s.getProcessId()); } DocClassification docClassification = docClassificationService.getByCode("NC"); if(docClassification == null) { ExceptionCast.cast(CommonCode.INVALID_PAGE); } QueryWrapper queryWrapper = Wrappers.query(); queryWrapper.in("r.attribution_id", ids) .eq("r.classification_id", docClassification.getClassificationId()) .ne("u.doc_status", 3).isNotNull("u.publish_file_id"); return super.getBaseMapper().findDocExtList(queryWrapper); } @Override @Transactional(rollbackFor = {Exception.class}) public boolean batchRemoveDocInfo(String[] docIds,String attrType,String attrId) { if(docIds == null || docIds.length < 1) ExceptionCast.cast(CommonCode.INVALID_PARAM); for(String docId : docIds) { this.deleteDocInfo(docId,attrType,attrId); } return true; } @Override public ResponseResult downloadDocFile(HttpServletRequest request, HttpServletResponse response, String id) { if(!ValidateUtil.validateString(id)) ExceptionCast.cast(CommonCode.INVALID_PARAM); DocInfo en = super.getById(id); if(en == null) ExceptionCast.cast(DocumentCode.DOC_NOT_EXIST); if(!ValidateUtil.validateString(en.getPublishFileId())) ExceptionCast.cast(DocumentCode.DOC_PUBLISH_FILE_NONE); DocFile docFile = docFileService.getById(en.getPublishFileId()); if(docFile == null) ExceptionCast.cast(DocumentCode.DOC_PUBLISH_FILE_NOT_EXIST); if(!ValidateUtil.validateString(docFile.getFilePath()) || !ValidateUtil.validateString(docFile.getFileName()) || /*!ValidateUtil.validateString(docFile.getFileSuffix()) ||*/ !ValidateUtil.validateString(docFile.getFileEncodeName())) return new ResponseResult(CommonCode.FAIL); String fileName; if(ValidateUtil.validateString(docFile.getFileSuffix())) { fileName = docFile.getFileName() + "." + docFile.getFileSuffix(); }else { fileName = docFile.getFileName(); } String filePath = docFile.getFilePath(); String fileEncodeName = docFile.getFileEncodeName(); FileUtilS.downLoadFile(response, fileEncodeName, filePath, fileName); return null; } }