package com.lxzn.webservice.impl; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.IdWorker; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.lxzn.activiti.service.IAssignFileStreamService; import com.lxzn.framework.domain.filesystem.response.FileUploadResult; import com.lxzn.framework.domain.nc.*; import com.lxzn.framework.domain.nc.response.DocumentCode; import com.lxzn.framework.domain.webservice.DispatchInfo; import com.lxzn.framework.domain.webservice.PlmProgramSourceInfo; import com.lxzn.framework.domain.webservice.ProcedureFinish; import com.lxzn.framework.domain.webservice.request.NcProgramInfo; import com.lxzn.framework.domain.webservice.request.PlmProgramSource; import com.lxzn.framework.exception.ExceptionCast; import com.lxzn.framework.model.response.CommonCode; import com.lxzn.framework.utils.CxfClientUtil; import com.lxzn.framework.utils.HttpRequest; import com.lxzn.framework.utils.ValidateUtil; import com.lxzn.framework.utils.ZipUtil; import com.lxzn.framework.utils.file.FileUtil; import com.lxzn.nc.service.*; import com.lxzn.webservice.DncWebService; import com.lxzn.framework.domain.webservice.request.WsDispatch; import com.lxzn.framework.domain.webservice.request.WsProcedureFinish; import com.lxzn.webservice.ext.MesResultModel; import com.lxzn.webservice.service.IDispatchInfoService; import com.lxzn.webservice.service.IPlmProgramSourceInfoService; import com.lxzn.webservice.service.IProcedureFinishService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.io.FilenameUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.jws.WebMethod; import javax.jws.WebParam; import javax.jws.WebService; import java.io.*; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.nio.file.StandardCopyOption; import java.util.*; import java.util.concurrent.atomic.AtomicReference; import java.util.stream.Collectors; import java.util.zip.ZipEntry; import java.util.zip.ZipFile; import java.util.zip.ZipInputStream; /** * @Author: Lius * @CreateTime: 2025-02-27 * @Description: */ @Service @WebService(name = "DncWebService", targetNamespace = "http://lxzn.webservice.com", endpointInterface = "com.lxzn.webservice.DncWebService" ) @Slf4j public class DncWebServiceImpl implements DncWebService { @Value("${ncPdm.file_path}") private String filePath; /** * url */ @Value("${webservice.url}") private String url; /** * namespace */ @Value("${webservice.namespace}") private String namespace; /** * method */ @Value("${webservice.method}") private String method; @Resource private IDispatchInfoService dispatchInfoService; @Resource private IProcedureFinishService procedureFinishService; @Resource private IDeviceInfoService deviceInfoService; @Resource private IAssignFileStreamService assignFileStreamService; @Resource private IPlmProgramSourceInfoService iPlmProgramSourceInfoService; @Autowired private IProductInfoService productInfoService; @Autowired private IComponentInfoService componentInfoService; @Autowired private IPermissionStreamService permissionStreamService; @Autowired private IComponentDepartmentService componentDepartmentService; @Autowired private IComponentPermissionService componentPermissionService; @Autowired private IPartsInfoService partsInfoService; @Autowired private IPartsDepartmentService partsDepartmentService; @Autowired private IPartsPermissionService partsPermissionService; @Autowired private IProcessStreamService processStreamService; @Autowired private IDocInfoService docInfoService; @Autowired private IDocRelativeService docRelativeService; @Autowired private IDocFileService docFileService; @Autowired private IDocClassificationService docClassificationService; @Autowired private IDeviceManagementService deviceManagementService; /** * 派工任务下发接口 * @param msg * @return */ @Override public String issuedDispatchTask(@WebParam(name = "msg") String msg){ log.info("MES派工任务下发原始数据 === {}", msg); List wsDispatchList = JSONObject.parseArray(msg, WsDispatch.class); for (WsDispatch wsDispatch : wsDispatchList) { DispatchInfo dispatchInfo = new DispatchInfo(); BeanUtils.copyProperties(wsDispatch, dispatchInfo); dispatchInfoService.save(dispatchInfo); Map ncResult = disPatchTaskNc(dispatchInfo); if (ncResult.containsKey(false)) { // 返回具体的错误信息 return MesResultModel.error("NC任务下发失败: " + ncResult.get(false)); } } return MesResultModel.success("成功"); } /** * 下发程序 */ public Map disPatchTaskNc(DispatchInfo dispatchInfo) { String processCode = dispatchInfo.getOperationSeqNo() + "_" + dispatchInfo.getEquipmentId(); return assignFileStreamService.disPatchTaskNc(dispatchInfo.getEquipmentId(), dispatchInfo.getWorkshop(),dispatchInfo.getMdsItemCode(),processCode,dispatchInfo.getRevisionNo(),dispatchInfo.getId()); } /** * 完工 * * @param msg * @return */ @Override public String issuedProcedureFinish(String msg) { log.info("MES完工原始数据 === {}", msg); List wsProcedureFinishList = JSONObject.parseArray(msg, WsProcedureFinish.class); if (CollectionUtils.isEmpty(wsProcedureFinishList)) { return MesResultModel.error("MesResultModel"); } List procedureFinishList = wsProcedureFinishList.stream() .map(source -> { ProcedureFinish target = new ProcedureFinish(); BeanUtils.copyProperties(source, target); return target; }) .collect(Collectors.toList()); procedureFinishService.saveBatch(procedureFinishList); //DNC系统依据工单号删除设备结构树上对应的NC程序及工控网NC程序 for (ProcedureFinish procedureFinish : procedureFinishList) { //DNC系统依据工单号删除设备结构树上对应的NC程序及工控网NC程序 if (procedureFinish.getEndineStatus().equals("3")){ //删除设备结构树上对应的NC程序及工控网NC程序 ProductInfo productInfo = productInfoService.getByProductNo("PLM"); if (productInfo == null) { log.error("======= 产品层级异常,请联系开发人员======="); return MesResultModel.error("产品层级异常,请联系开发人员"); } List componentInfoList = componentInfoService.getByProductId(productInfo.getProductId()); List comlist = new ArrayList<>(); if (componentInfoList != null && !componentInfoList.isEmpty()) { for (ComponentInfo cc : componentInfoList) { comlist.add(cc.getComponentId()); } } else { return MesResultModel.error("无部件信息,请联系开发人员"); } String processCode=procedureFinish.getMdsItemCode(); PartsInfo part = partsInfoService.getByCodeAndComIdList(procedureFinish.getMdsItemCode(),comlist); if (part == null) { return MesResultModel.error("无此零件信息"+"__" + processCode+",请联系开发人员"); } processCode = processCode.split("_")[0]; //工序 ProcessStream stream = processStreamService.findByProcessEquipment(procedureFinish.getEquipmentId(), processCode,procedureFinish.getRevisionNo(),productInfo.getProductId(),part.getPartsId()); if (stream == null) { return MesResultModel.error("无此工序信息"+"__" + processCode+",请联系开发人员"); } //查询对应NC程序 List processStreamList = new ArrayList<>(); processStreamList.add(stream); List docFileList = docInfoService.getByProcessIds(processStreamList); if (docFileList == null || docFileList.isEmpty()) { return MesResultModel.error("无此NC程序" + "__" + processCode + ",请联系开发人员"); } docFileList.forEach(docFile -> { docInfoService.deleteDocInfo(docFile.getDocId()); }); } } log.info("接收MES完工原始数据成功！"); return MesResultModel.success("成功"); } /** * 获取NC文件及属性信息(集成PLM) * * @param msg * @return */ @WebMethod @Override @Transactional public MesResultModel syncPlmNcLogProgram(@WebParam(name = "msg") String msg) { log.info("NC文件及属性信息原始数据 === {}", msg); List plmProgramSourceList = JSONObject.parseArray(msg, PlmProgramSource.class); AtomicReference mesResultModel= new AtomicReference<>(new MesResultModel()); plmProgramSourceList.forEach(item -> { mesResultModel.set(setTree(item)); }); return mesResultModel.get(); } /** * 封装树结构 1. 产品 集成数据 2、部件 按照部门（车间 ae8nc_plant ）维度建立 3、零件 图号（零件号、零件名称） ae8part_no 4、工序 工艺ID（工艺规程编号/临规编号） 5. nc文件 （工序下） 6.机床型号与机床操作系统组成设备类与工序进行绑定 * @param plmProgramSource * @return */ public MesResultModel setTree(PlmProgramSource plmProgramSource) { MesResultModel model = new MesResultModel(); model.setSuccFlag("成功"); PlmProgramSourceInfo plmProgramSourceInfo = new PlmProgramSourceInfo(); BeanUtils.copyProperties(plmProgramSource, plmProgramSourceInfo); plmProgramSourceInfo.setMesStatus("0"); iPlmProgramSourceInfoService.save(plmProgramSourceInfo); // 产品 ProductInfo productInfo = productInfoService.getByProductNo("PLM"); if (productInfo == null) { log.error("======= 产品层级异常,请联系开发人员======="); return createErrorModel(model, "产品层级异常,请联系开发人员"); } // 部件 ComponentInfo compTotal = componentInfoService.getByCode(plmProgramSourceInfo.getCzkAe8nDivision()); if (compTotal == null) { compTotal = new ComponentInfo(); compTotal.setComponentCode(plmProgramSourceInfo.getCzkAe8nDivision()); compTotal.setProductId(productInfo.getProductId()); compTotal.setComponentName(plmProgramSourceInfo.getCzkAe8nDivision()); compTotal.setComponentStatus(1); compTotal.setRankLevel(1); compTotal.setParentId(productInfo.getProductId()); compTotal.setComponentId(IdWorker.getIdStr()); if (!componentInfoService.save(compTotal)) { return createErrorModel(model, "添加部件层级,请联系开发人员"); } if (!savePermissionList(compTotal, productInfo.getProductId())) { return createErrorModel(model, "添加权限失败,请联系开发人员"); } } // 3、零件 图号（零件号） ae8part_no PartsInfo part = partsInfoService.getByCode(plmProgramSourceInfo.getCzkAe8nPartNo()); if (part == null) { List partsDepartPermList = new ArrayList<>(); List partsPermList = new ArrayList<>(); List partsUserPermList = new ArrayList<>(); part = new PartsInfo(); part.setPartsId(IdWorker.getIdStr()); part.setComponentId(compTotal.getComponentId()); part.setProductId(compTotal.getProductId()); part.setPartsStatus(1); part.setPartsCode(plmProgramSourceInfo.getCzkAe8nPartNo()); part.setPartsName(plmProgramSourceInfo.getCzkAe8nPartName()); part.setPartsModel(plmProgramSourceInfo.getCzkAe8nPartNo()); if (!partsInfoService.save(part)) { return createErrorModel(model, "添加零件层级,请联系开发人员"); } // 权限 List oldPermissionList = permissionStreamService.getAllByProductId(productInfo.getProductId()); if (oldPermissionList != null && !oldPermissionList.isEmpty()) { for (PermissionStream p : oldPermissionList) { if (ValidateUtil.validateString(p.getUserId())) { // 用户权限 PartsPermission permission = new PartsPermission(); permission.setPartsId(part.getPartsId()); permission.setUserId(p.getUserId()); partsUserPermList.add(permission); PermissionStream stream = new PermissionStream(); stream.setUserId(p.getUserId()); stream.setProductId(part.getProductId()); stream.setComponentId(part.getComponentId()); stream.setPartsId(part.getPartsId()); partsPermList.add(stream); } if (ValidateUtil.validateString(p.getDepartId())) { // 部门权限 PartsDepartment department = new PartsDepartment(); department.setPartsId(part.getPartsId()); department.setDepartId(p.getDepartId()); partsDepartPermList.add(department); PermissionStream stream = new PermissionStream(); stream.setProductId(part.getProductId()); stream.setComponentId(part.getComponentId()); stream.setPartsId(part.getPartsId()); stream.setDepartId(p.getDepartId()); partsPermList.add(stream); } } if (!partsUserPermList.isEmpty() && !partsPermissionService.saveBatch(partsUserPermList)) { return createErrorModel(model, "添加权限失败,请联系开发人员"); } if (!partsDepartPermList.isEmpty() && !partsDepartmentService.saveBatch(partsDepartPermList)) { return createErrorModel(model, "添加权限失败,请联系开发人员"); } if (!partsPermList.isEmpty() && !permissionStreamService.saveBatch(partsPermList)) { return createErrorModel(model, "添加权限失败,请联系开发人员"); } } } // 4、工序 工艺ID（工艺规程编号/临规编号） List addProcessList = new ArrayList<>(); List updateProcessList = new ArrayList<>(); ProcessStream stream; // skgx_id String processCode = plmProgramSourceInfo.getCzkAe8nOpNo(); stream = processStreamService.findByProcessNoAndPartsId(processCode, part.getPartsId()); if (stream == null) { stream = new ProcessStream(); stream.setProcessId(IdWorker.getIdStr()); stream.setProductId(part.getProductId()); stream.setComponentId(part.getComponentId()); stream.setCraftVersion(plmProgramSourceInfo.getCzkAe8nOpRev()); stream.setPartsId(part.getPartsId()); stream.setProcessCode(processCode); stream.setProcessName(plmProgramSourceInfo.getCzkAe8nOpName()); /*数控工序号*/ stream.setCraftNo(plmProgramSourceInfo.getCzkAe8nOpNo()); /*机床操作系统 ae8nc_os*/ DeviceManagement deviceManagement = deviceManagementService.findEquipmentIdsFromEqId( plmProgramSourceInfo.getCzkAe8nDivision(), plmProgramSourceInfo.getCzkAe8nEquipNo()); if (deviceManagement != null && StringUtils.isNotEmpty(deviceManagement.getEquipmentIds())) { stream.setProcessingEquipmentCode(deviceManagement.getEquipmentIds()); } else { stream.setProcessingEquipmentCode(plmProgramSourceInfo.getCzkAe8nEquipNo()); } stream.setProcessingEquipmentOs(plmProgramSourceInfo.getCzkAe8nEquipsystem()); stream.setProcessingEquipmentModel(plmProgramSourceInfo.getCzkAe8nEquipmentModel()); addProcessList.add(stream); } else { stream.setProcessName(plmProgramSourceInfo.getCzkAe8nOpName()); updateProcessList.add(stream); } if (!addProcessList.isEmpty() && !processStreamService.saveBatch(addProcessList)) { return createErrorModel(model, "添加工序,请联系开发人员"); } if (!updateProcessList.isEmpty() && !processStreamService.updateBatchById(updateProcessList)) { return createErrorModel(model, "更新工序,请联系开发人员"); } // 下载数据并解压 DocClassification docClass = docClassificationService.getByCode("NC"); if (docClass == null) { return createErrorModel(model, "下载数据并解压数据失败,请联系开发人员"); } boolean b; try { File file = new File(plmProgramSource.getFileName()); if(file.exists() && file.isFile() && file.length() > 0) { if(plmProgramSource.getFiles() == null || plmProgramSource.getFiles().isEmpty()) { ExceptionCast.cast(CommonCode.FAIL); } for(Map.Entry entry : plmProgramSource.getNcfiles().entrySet()) { String suffix = FileUtil.getFileSuffix(entry.getKey()); DocInfo docInfo = docInfoService.findByAttrAndDocName(FileUtil.getFilenameNonSuffix(entry.getKey()), 5, stream.getProcessId(),suffix); //新增 FileUploadResult fileUploadResult = FileUtil.uploadFileByFileNameAndFis(entry.getKey(),new ByteArrayInputStream(entry.getValue())); if(fileUploadResult == null) { ExceptionCast.cast(DocumentCode.DOC_UPLOAD_ERROR); } if(docInfo == null) { docInfo = new DocInfo(); String docId = IdWorker.getIdStr(); docInfo.setDocId(docId); docInfo.setDocName(fileUploadResult.getFileName()); docInfo.setDocSuffix(fileUploadResult.getFileSuffix()); if (StrUtil.isNotEmpty(plmProgramSourceInfo.getCzkReleaseStatus())){ docInfo.setDocStatus(5); }else { docInfo.setDocStatus(4); } DocRelative docRelative = new DocRelative(); docRelative.setAttributionId(stream.getProcessId()); docRelative.setDocId(docInfo.getDocId()); docRelative.setAttributionType(5); docRelative.setClassificationId(docClass.getClassificationId()); b = docRelativeService.save(docRelative); if(!b) { return createErrorModel(model, "添加文件,请联系开发人员"); } if (getFile(docInfo, fileUploadResult, docFileService)) { return createErrorModel(model, "添加文件,请联系开发人员"); } b = docInfoService.save(docInfo); }else { if (StringUtils.isNotEmpty(stream.getCraftVersion())&&StringUtils.isNotEmpty(plmProgramSource.getCzkAe8nOpRev())) { //升版，保存原文件 if (!stream.getCraftVersion().equals(plmProgramSource.getCzkAe8nOpRev())) { this.createFileOldNcPathAndCopy(docInfo,plmProgramSourceInfo); } } DocFile docFile = getDocFile(docInfo, fileUploadResult); b = docFileService.addDocFile(docFile); if(!b){ return createErrorModel(model, "升版失败,请联系开发人员"); } docInfo.setPublishVersion(docFile.getDocVersion()); docInfo.setPublishFileId(docFile.getFileId()); b = docInfoService.updateById(docInfo); } if(!b){ return createErrorModel(model, "添加文件,请联系开发人员"); } } return model; } } catch (Exception e) { log.error(e.getMessage()); model.setSuccFlag("失败"); model.setError("下载数据并解压数据失败,请联系开发人员"); return model; } return model; } private MesResultModel createErrorModel(MesResultModel model, String errorMsg) { model.setSuccFlag("失败"); model.setError(errorMsg); return model; } /** * * NC程序齐套接口（MES）-DNC系统接收到PLM传的NC程序，将程序包对应的零件号、工序号、设备编号传给MES系统 * 定时扫描PlmProgramSourceInfo表中的数据，进行数据同步，每分钟同步一次 */ @Scheduled(cron = "0 0/1 * * * ?") @Transactional(rollbackFor = Exception.class) public void syncWorkmanship() { // 获取所有需要同步的数据 List plmProgramSourceInfos = iPlmProgramSourceInfoService.list( new LambdaQueryWrapper() .eq(PlmProgramSourceInfo::getMesStatus, "0") .orderByAsc(PlmProgramSourceInfo::getId) ); if (plmProgramSourceInfos.isEmpty()) { log.info("无待同步数据，跳过处理"); return; } List ncProgramInfos = plmProgramSourceInfos.stream().map(item -> { NcProgramInfo ncProgramInfo = new NcProgramInfo(); ncProgramInfo.setMdsItemCode(item.getCzkAe8nPartNo()); ncProgramInfo.setRevisionNo(item.getRevisionNo()); ncProgramInfo.setNcProgramName(item.getFileName()); ncProgramInfo.setOpreationSeqNo(item.getCzkAe8nOpNo()); ncProgramInfo.setEquipmentId(item.getCzkAe8nEquipNo()); ncProgramInfo.setWorkshop(item.getCzkAe8nDivision()); // ncProgramInfo.setMesId(item.getId()); // 确保生成符合要求的mesId // ncProgramInfo.setOperFlag(); return ncProgramInfo; }).collect(Collectors.toList()); log.info("WebService-NC程序齐套接口（MES）同步开始，时间: {}", new Date()); try { String jsonPayload = JSONObject.toJSONString(ncProgramInfos); log.debug("上报数据: {}", jsonPayload); // 调用WebService并获取详细响应 String result = CxfClientUtil.invokeService(url, jsonPayload, namespace, method); log.info("接口响应: {}", result); // 解析响应结果，只会有成功和失败 if (result.contains("成功")) { List toUpdate = new ArrayList<>(); plmProgramSourceInfos.forEach(item -> { item.setMesStatus("1"); toUpdate.add(item); }); // 批量更新状态 if (!toUpdate.isEmpty()) { iPlmProgramSourceInfoService.updateBatchById(toUpdate); log.info("成功更新{}条数据状态", toUpdate.size()); } }else { log.error("同步MES系统失败: {}", result); } } catch (Exception e) { log.error("同步MES系统失败: {}", e.getMessage(), e); // 仅标记处理失败的记录 plmProgramSourceInfos.forEach(item -> item.setMesStatus("0")); iPlmProgramSourceInfoService.updateBatchById(plmProgramSourceInfos); throw new RuntimeException("同步失败，已回滚状态", e); // 触发事务回滚 } } /** * 创建升版文件保存地址并复制文件 * 层级结构: plm_bak->ae8ncPlant(车间)->ae8partNo(零件图号)->skgxId(工序)->具体文件 * @param docInfo 文档信息 * @param plmProgramSourceInfo 程序源信息 * @return 操作成功返回true，失败返回false */ public boolean createFileOldNcPathAndCopy(DocInfo docInfo, PlmProgramSourceInfo plmProgramSourceInfo) { // 获取最近版本的文档文件 DocFile docFile = docFileService.getDocFileNearest(docInfo.getDocId()); if (docFile == null) { log.error("未找到最近版本的文档文件，docId: {}", docInfo.getDocId()); return false; } // 构建保存路径 String directoryPath = String.join(File.separator, "plm_bak", plmProgramSourceInfo.getCzkAe8nDivision(), plmProgramSourceInfo.getCzkAe8nPartNo(), plmProgramSourceInfo.getCzkAe8nOpNo(), ""); // 末尾添加分隔符 File directory = new File(directoryPath); // 创建目录（如果不存在） if (!directory.exists() && !directory.mkdirs()) { log.error("创建目录失败: {}", directoryPath); return false; } // 构建目标文件路径 String targetFileName = buildTargetFileName(docFile); String targetFilePath = directoryPath + targetFileName; // 复制源文件到目标路径 try { Path sourcePath = Paths.get(docFile.getFilePath()); Path targetPath = Paths.get(targetFilePath); // 使用Files.copy复制文件，REPLACE_EXISTING选项处理文件已存在的情况 Files.copy(sourcePath, targetPath, StandardCopyOption.REPLACE_EXISTING); log.info("文件复制成功: {} -> {}", docFile.getFilePath(), targetFilePath); return true; } catch (IOException e) { log.error("文件复制失败: {}", e.getMessage(), e); // 失败时删除已创建的空目录 if (directory.exists() && isDirectoryEmpty(directory)) { directory.delete(); } return false; } } /** * 构建目标文件名（包含版本信息） * 格式: 原文件名_V版本号.后缀 * 例如: drawing_V1.0.dwg */ private String buildTargetFileName(DocFile docFile) { String baseName = FilenameUtils.getBaseName(docFile.getFileName()); String version = docFile.getDocVersion() != null ? docFile.getDocVersion() : "1.0"; String suffix = docFile.getFileSuffix() != null ? docFile.getFileSuffix() : ""; // 确保版本号格式正确 if (!version.startsWith("V")) { version = "V" + version; } // 确保后缀以点开头 if (!suffix.isEmpty() && !suffix.startsWith(".")) { suffix = "." + suffix; } return baseName + "_" + version + suffix; } /** * 检查目录是否为空 */ private boolean isDirectoryEmpty(File directory) { if (!directory.isDirectory()) { return false; } String[] files = directory.list(); return files == null || files.length == 0; } private static String buildRequestBody(NcProgramInfo ncProgramInfo) { StringBuilder body = new StringBuilder(); body.append("mesId=").append(ncProgramInfo.getMesId()) .append("&mdsItemCode=").append(ncProgramInfo.getMdsItemCode()) .append("&revisionNo=").append(ncProgramInfo.getRevisionNo()) .append("&opreationSeqNo=").append(ncProgramInfo.getOpreationSeqNo()) .append("&equipmentId=").append(ncProgramInfo.getEquipmentId()) .append("&workshop=").append(ncProgramInfo.getWorkshop()); return body.toString(); } public static boolean getFile(DocInfo docInfo, FileUploadResult fileUploadResult, IDocFileService docFileService) { boolean b; DocFile docFile = new DocFile(); docFile.setDocId(docInfo.getDocId()); docFile.setFileName(fileUploadResult.getFileName()); docFile.setFileEncodeName(fileUploadResult.getEncodeFileName()); docFile.setFilePath(fileUploadResult.getFilePath()); docFile.setFileSize(fileUploadResult.getFileSize()); docFile.setFileSuffix(fileUploadResult.getFileSuffix()); b = docFileService.addDocFile(docFile); if(!b) { return true; } docInfo.setPublishVersion(docFile.getDocVersion()); docInfo.setPublishFileId(docFile.getFileId()); return false; } private static DocFile getDocFile(DocInfo docInfo, FileUploadResult fileUploadResult) { DocFile docFile = new DocFile(); docFile.setDocId(docInfo.getDocId()); docFile.setFileName(fileUploadResult.getFileName()); docFile.setFileEncodeName(fileUploadResult.getEncodeFileName()); docFile.setFilePath(fileUploadResult.getFilePath()); docFile.setFileSize(fileUploadResult.getFileSize()); docFile.setFileSuffix(fileUploadResult.getFileSuffix()); return docFile; } private boolean savePermissionList(ComponentInfo comp, String totalOrSonId) { boolean b; List oldPermissionList = permissionStreamService.getAllByProductId(totalOrSonId); //权限 List componentDepartmentList = new ArrayList<>(); List componentDepartPermList = new ArrayList<>(); List componentPermissionList = new ArrayList<>(); ComponentDepartment department; ComponentPermission permission; PermissionStream stream; if(oldPermissionList != null && !oldPermissionList.isEmpty()) { for (PermissionStream p : oldPermissionList) { if (ValidateUtil.validateString(p.getUserId())) { //部门权限 permission = new ComponentPermission(); permission.setComponentId(comp.getComponentId()); permission.setUserId(p.getUserId()); componentPermissionList.add(permission); stream = new PermissionStream(); stream.setUserId(p.getUserId()); stream.setProductId(comp.getProductId()); stream.setComponentId(comp.getComponentId()); componentDepartPermList.add(stream); } if (ValidateUtil.validateString(p.getDepartId())) { //用户权限 department = new ComponentDepartment(comp.getComponentId(), p.getDepartId()); componentDepartmentList.add(department); stream = new PermissionStream(comp.getProductId(), comp.getComponentId()); stream.setDepartId(p.getDepartId()); componentDepartPermList.add(stream); } } } if(!componentDepartmentList.isEmpty()) { b = componentDepartmentService.saveBatch(componentDepartmentList); if(!b) { return false; } } if(!componentPermissionList.isEmpty()) { b = componentPermissionService.saveBatch(componentPermissionList); if(!b) { return false; } } if(!componentDepartPermList.isEmpty()) { b = permissionStreamService.saveBatch(componentDepartPermList); if(!b) { return false; } } return true; } @Override public String readFileName(String itemCode){ return "pdm_" + itemCode + ".zip"; } /** * 从指定的 ZIP 压缩包中提取所有 .nc 文件的内容及其文件名 * * @param zipFilePath ZIP 压缩包的文件路径 * @return 包含文件名和对应文件内容的映射 * @throws IOException 如果在读取压缩包或文件内容时发生 I/O 错误 */ public static Map extractNcFilesWithNamesFromZip(String zipFilePath) throws IOException { // 用于存储文件名和对应文件内容的映射 Map ncFilesMap = new HashMap<>(); // 使用 try-with-resources 语句确保 ZipFile 资源被正确关闭 try (ZipFile zipFile = new ZipFile(zipFilePath)) { // 遍历压缩包中的每个条目 for (ZipEntry entry : zipFile.stream().collect(Collectors.toList())) { // 检查条目是否为 .nc 文件 if (entry.getName().endsWith(".nc")) { // 用于存储单个 .nc 文件的内容 StringBuilder content = new StringBuilder(); // 使用 try-with-resources 语句确保输入流和读取器资源被正确关闭 try (InputStream inputStream = zipFile.getInputStream(entry); BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) { String line; // 逐行读取文件内容 while ((line = reader.readLine()) != null) { content.append(line).append("\n"); } // 将文件名和文件内容添加到映射中 ncFilesMap.put(entry.getName(), content.toString()); } } } } return ncFilesMap; } }