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.activiti.response.ActivitiCode;
|
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.*;
|
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.nc.service.impl.DeviceInfoServiceImpl;
|
import com.lxzn.webservice.DncWebService;
|
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 {
|
@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;
|
@Autowired
|
private DeviceInfoServiceImpl deviceInfoService;
|
@Autowired
|
private IDeviceGroupService deviceGroupService;
|
/**
|
* 获取NC文件及属性信息(集成PLM)
|
*
|
* @param msg
|
* @return
|
*/
|
@WebMethod
|
@Override
|
@Transactional
|
public MesResultModel syncPlmNcLogProgram(@WebParam(name = "msg") String msg) {
|
log.info("NC文件及属性信息原始数据 === {}", msg);
|
List<PlmProgramSource> plmProgramSourceList = JSONObject.parseArray(msg, PlmProgramSource.class);
|
AtomicReference<MesResultModel> mesResultModel= new AtomicReference<>(new MesResultModel());
|
plmProgramSourceList.forEach(item -> {
|
mesResultModel.set(setPlmTree(item));
|
});
|
return mesResultModel.get();
|
}
|
|
/**
|
* 封装树结构
|
1. 产品 集成数据
|
2、部件 按照部门（车间 ae8nc_plant ）维度建立
|
3、零件 图号（零件号、零件名称） ae8part_no
|
4、工序 工艺ID（工艺规程编号/临规编号）
|
5. nc文件 （工序下）
|
6.机床型号与机床操作系统组成设备类与工序进行绑定
|
* @param plmProgramSource
|
* @return
|
*/
|
public MesResultModel setPlmTree(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<PartsDepartment> partsDepartPermList = new ArrayList<>();
|
List<PermissionStream> partsPermList = new ArrayList<>();
|
List<PartsPermission> 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<PermissionStream> 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<ProcessStream> addProcessList = new ArrayList<>();
|
List<ProcessStream> 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<String,byte[]> 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;
|
}
|
|
/**
|
* 封装树结构
|
* 1. 产品 集成数据
|
* 2、部件 按照部门（车间 nc_plant_name ）维度建立
|
* 3、零件 图号（零件号、零件名称） part_no
|
* 4、工序 工艺ID（工艺规程编号/临规编号）
|
* 5. nc文件 （工序下）
|
* 6.机床型号与机床操作系统组成设备类与工序进行绑定
|
* 集成3DE挂树
|
* @param thirdDeProgramSource
|
* @return
|
*/
|
@Override
|
@Transactional
|
public MesResultModel processThirdDEProgram(ThirdDeProgramSource thirdDeProgramSource) {
|
MesResultModel model = new MesResultModel();
|
model.setSuccFlag("成功");
|
|
try {
|
log.info("3DE NC文件及属性信息原始数据 === {}", JSONObject.toJSONString(thirdDeProgramSource));
|
|
// 产品 - 使用默认的3DE产品
|
ProductInfo productInfo = productInfoService.getByProductNo("3DE");
|
if (productInfo == null) {
|
return createErrorModel(model, "3DE产品层级异常,请联系开发人员");
|
}
|
|
// 部件 - 按照车间维度建立
|
ComponentInfo componentInfo = componentInfoService.getByCode(thirdDeProgramSource.getNcPlantNo());
|
if (componentInfo == null) {
|
componentInfo = new ComponentInfo();
|
componentInfo.setComponentId(IdWorker.getIdStr());
|
componentInfo.setComponentCode(thirdDeProgramSource.getNcPlantNo());
|
componentInfo.setComponentName(thirdDeProgramSource.getNcPlantName());
|
componentInfo.setComponentStatus(1);
|
componentInfo.setRankLevel(1);
|
componentInfo.setParentId(productInfo.getProductId());
|
componentInfo.setProductId(productInfo.getProductId());
|
|
if (!componentInfoService.save(componentInfo)) {
|
return createErrorModel(model, "添加3DE部件层级失败,请联系开发人员");
|
}
|
if (!savePermissionList(componentInfo, productInfo.getProductId())) {
|
return createErrorModel(model, "添加3DE部件权限失败,请联系开发人员");
|
}
|
}
|
|
// 零件 - 图号（零件号、零件名称）
|
PartsInfo partsInfo = partsInfoService.getByCode(thirdDeProgramSource.getPartNo());
|
if (partsInfo == null) {
|
partsInfo = new PartsInfo();
|
partsInfo.setPartsId(IdWorker.getIdStr());
|
partsInfo.setComponentId(componentInfo.getComponentId());
|
partsInfo.setProductId(productInfo.getProductId());
|
partsInfo.setPartsStatus(1);
|
partsInfo.setPartsCode(thirdDeProgramSource.getPartNo());
|
partsInfo.setPartsName(thirdDeProgramSource.getPartName());
|
partsInfo.setPartsModel(thirdDeProgramSource.getPartNo());
|
|
if (!partsInfoService.save(partsInfo)) {
|
return createErrorModel(model, "添加3DE零件层级失败,请联系开发人员");
|
}
|
// 添加零件权限
|
if (!savePartsPermission(partsInfo, productInfo.getProductId())) {
|
return createErrorModel(model, "添加3DE零件权限失败,请联系开发人员");
|
}
|
}
|
|
// 工序 - 工艺ID（工艺规程编号/临规编号）
|
ProcessStream processStream = processStreamService.findByProcessNoAndPartsId(
|
thirdDeProgramSource.getSkgxId(), partsInfo.getPartsId());
|
List<ProcessStream> addProcessList = new ArrayList<>();
|
List<ProcessStream> updateProcessList = new ArrayList<>();
|
|
if (processStream == null) {
|
processStream = new ProcessStream();
|
processStream.setProcessId(IdWorker.getIdStr());
|
processStream.setProductId(productInfo.getProductId());
|
processStream.setComponentId(componentInfo.getComponentId());
|
processStream.setPartsId(partsInfo.getPartsId());
|
processStream.setProcessCode(thirdDeProgramSource.getSkgxId());
|
processStream.setProcessName(thirdDeProgramSource.getSkgxName());
|
processStream.setCraftVersion(thirdDeProgramSource.getRevisionNo()); // 设置工艺版本
|
|
// 设备信息处理
|
DeviceManagement deviceManagement = deviceManagementService.findEquipmentIdsFromEqId(
|
thirdDeProgramSource.getNcPlantName(), thirdDeProgramSource.getEquipmentId());
|
|
if (deviceManagement != null && StringUtils.isNotEmpty(deviceManagement.getEquipmentIds())) {
|
processStream.setProcessingEquipmentCode(deviceManagement.getEquipmentIds());
|
} else {
|
processStream.setProcessingEquipmentCode(thirdDeProgramSource.getEquipmentId());
|
}
|
processStream.setProcessingEquipmentOs(thirdDeProgramSource.getNcOs());
|
processStream.setProcessingEquipmentModel(thirdDeProgramSource.getNcJcid());
|
addProcessList.add(processStream);
|
} else {
|
// 更新时检查版本是否变更
|
if (!Objects.equals(processStream.getCraftVersion(), thirdDeProgramSource.getRevisionNo())) {
|
processStream.setCraftVersion(thirdDeProgramSource.getRevisionNo());
|
}
|
processStream.setProcessName(thirdDeProgramSource.getSkgxName());
|
updateProcessList.add(processStream);
|
}
|
|
if (!addProcessList.isEmpty() && !processStreamService.saveBatch(addProcessList)) {
|
return createErrorModel(model, "添加3DE工序失败,请联系开发人员");
|
}
|
|
if (!updateProcessList.isEmpty() && !processStreamService.updateBatchById(updateProcessList)) {
|
return createErrorModel(model, "更新3DE工序失败,请联系开发人员");
|
}
|
|
// 文档分类
|
DocClassification ncDocClass = docClassificationService.getByCode("NC");
|
if (ncDocClass == null) {
|
return createErrorModel(model, "NC文档分类不存在,请联系开发人员");
|
}
|
|
// send文档分类
|
DocClassification sendDocClass = docClassificationService.getByCode("SEND");
|
if (sendDocClass == null) {
|
return createErrorModel(model, "SEND文档分类不存在,请联系开发人员");
|
}
|
|
// 处理NC文件
|
if (thirdDeProgramSource.getNcFiles() != null && !thirdDeProgramSource.getNcFiles().isEmpty()) {
|
for (Map.Entry<String, byte[]> entry : thirdDeProgramSource.getNcFiles().entrySet()) {
|
String fileName = entry.getKey();
|
byte[] fileContent = entry.getValue();
|
String suffix = FileUtil.getFileSuffix(fileName);
|
String baseName = FileUtil.getFilenameNonSuffix(fileName);
|
|
// 查找现有文档
|
DocInfo docInfo = docInfoService.findByAttrAndDocName(baseName, 5,
|
processStream.getProcessId(), suffix);
|
|
FileUploadResult fileUploadResult = FileUtil.uploadFileByFileNameAndFis(
|
fileName, new ByteArrayInputStream(fileContent));
|
|
if (fileUploadResult == null) {
|
return createErrorModel(model, "上传3DE NC文件失败");
|
}
|
|
boolean success;
|
if (docInfo == null) {
|
// 新增文档
|
docInfo = new DocInfo();
|
String docId = IdWorker.getIdStr();
|
docInfo.setDocId(docId);
|
docInfo.setDocName(fileUploadResult.getFileName());
|
docInfo.setDocSuffix(fileUploadResult.getFileSuffix());
|
docInfo.setDocStatus(5);
|
|
// 创建文档关联
|
DocRelative docRelative = new DocRelative();
|
docRelative.setAttributionId(processStream.getProcessId());
|
docRelative.setDocId(docInfo.getDocId());
|
docRelative.setAttributionType(5);
|
docRelative.setClassificationId(ncDocClass.getClassificationId());
|
|
if (!docRelativeService.save(docRelative)) {
|
return createErrorModel(model, "创建3DE文档关联失败");
|
}
|
|
// 保存文档文件
|
if (getFile(docInfo, fileUploadResult, docFileService)) {
|
return createErrorModel(model, "保存3DE文档文件失败");
|
}
|
|
success = docInfoService.save(docInfo);
|
|
// 获取最新文档文件
|
DocFile docFile = docFileService.getDocFileNearest(docId);
|
|
// 添加到设备
|
if (!linkToDevice(thirdDeProgramSource.getEquipmentId(), docInfo.getDocId(), docFile, sendDocClass)) {
|
return createErrorModel(model, "添加设备文档关联失败");
|
}
|
} else {
|
// 更新文档 - 处理版本控制
|
if (StringUtils.isNotEmpty(processStream.getCraftVersion()) &&
|
StringUtils.isNotEmpty(thirdDeProgramSource.getRevisionNo())) {
|
// 版本变更，保存旧版本文件
|
if (!Objects.equals(processStream.getCraftVersion(), thirdDeProgramSource.getRevisionNo())) {
|
this.createFileOldNcPathAndCopyFor3DE(docInfo, thirdDeProgramSource);
|
}
|
}
|
|
DocFile docFile = getDocFile(docInfo, fileUploadResult);
|
success = docFileService.addDocFile(docFile);
|
|
if (success) {
|
docInfo.setPublishVersion(docFile.getDocVersion());
|
docInfo.setPublishFileId(docFile.getFileId());
|
success = docInfoService.updateById(docInfo);
|
|
// 更新设备关联
|
if (!updateDeviceLink(thirdDeProgramSource.getEquipmentId(), docInfo.getDocId(), sendDocClass)) {
|
return createErrorModel(model, "更新设备文档关联失败");
|
}
|
}
|
}
|
|
if (!success) {
|
return createErrorModel(model, "处理3DE NC文件失败");
|
}
|
}
|
}
|
|
return model;
|
} catch (Exception e) {
|
log.error("处理3DE程序数据异常: {}", e.getMessage(), e);
|
return createErrorModel(model, "处理3DE程序数据异常: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 添加到设备
|
*/
|
private boolean linkToDevice(String equipmentId, String docId, DocFile docFile, DocClassification sendDocClass) {
|
try {
|
DeviceInfo deviceInfo = deviceInfoService.getByDeviceNo(equipmentId);
|
if (deviceInfo == null) {
|
log.error("DNC中设备不存在: {}", equipmentId);
|
return false;
|
}
|
DocRelative deviceDocRelative = new DocRelative();
|
deviceDocRelative.setAttributionId(deviceInfo.getDeviceId());
|
deviceDocRelative.setDocId(docId);
|
deviceDocRelative.setAttributionType(4);
|
deviceDocRelative.setClassificationId(sendDocClass.getClassificationId());
|
boolean saved = docRelativeService.save(deviceDocRelative);
|
if (!saved) {
|
log.error("保存设备文档关联失败: device={}, doc={}", equipmentId, docId);
|
return false;
|
}
|
// 复制文件到设备路径
|
List<String> groupPaths = deviceGroupService.findListParentTreeAll(deviceInfo.getGroupId());
|
if (groupPaths != null && !groupPaths.isEmpty()) {
|
String devicePath = String.join("/", groupPaths) + "/" + deviceInfo.getDeviceNo();
|
// 复制文件
|
boolean copySuccess = FileUtil.copyFileNc(
|
docFile.getFilePath(),
|
devicePath,
|
docFile.getFileEncodeName(),
|
docFile.getFileName(),
|
docFile.getFileSuffix());
|
|
if (!copySuccess) {
|
log.error("文件复制失败: {} -> {}", docFile.getFilePath(), devicePath);
|
return false;
|
}
|
|
// 删除旧版本文件
|
FileUtil.deleteZipFromToSend(
|
devicePath,
|
docFile.getFileName(),
|
docFile.getFileSuffix());
|
}
|
|
return true;
|
} catch (Exception e) {
|
log.error("添加设备文档关联异常: {}", e.getMessage(), e);
|
return false;
|
}
|
}
|
|
/**
|
* 更新设备关联
|
*/
|
private boolean updateDeviceLink(String equipmentId, String docId, DocClassification sendDocClass) {
|
try {
|
DeviceInfo deviceInfo = deviceInfoService.getByDeviceNo(equipmentId);
|
if (deviceInfo == null) {
|
log.error("DNC中设备不存在: {}", equipmentId);
|
return false;
|
}
|
|
// 检查关联是否已存在
|
DocRelative existingRel = docRelativeService.findDocRelative(docId,sendDocClass.getClassificationId(), 4,deviceInfo.getDeviceId());
|
if (existingRel == null) {
|
// 创建新关联
|
DocRelative deviceDocRelative = new DocRelative();
|
deviceDocRelative.setAttributionId(deviceInfo.getDeviceId());
|
deviceDocRelative.setDocId(docId);
|
deviceDocRelative.setAttributionType(4);
|
deviceDocRelative.setClassificationId(sendDocClass.getClassificationId());
|
return docRelativeService.save(deviceDocRelative);
|
}
|
return true;
|
} catch (Exception e) {
|
log.error("更新设备关联异常: {}", e.getMessage(), e);
|
return false;
|
}
|
}
|
|
/**
|
* 为3DE数据创建旧版本NC文件备份
|
*/
|
private boolean createFileOldNcPathAndCopyFor3DE(DocInfo docInfo, ThirdDeProgramSource thirdDeProgramSource) {
|
DocFile docFile = docFileService.getDocFileNearest(docInfo.getDocId());
|
if (docFile == null) {
|
log.error("未找到最近版本的3DE文档文件，docId: {}", docInfo.getDocId());
|
return false;
|
}
|
String directoryPath = String.join(File.separator,
|
"3de_bak",
|
thirdDeProgramSource.getNcPlantName(),
|
thirdDeProgramSource.getPartNo(),
|
thirdDeProgramSource.getSkgxId(),
|
"");
|
|
File directory = new File(directoryPath);
|
if (!directory.exists() && !directory.mkdirs()) {
|
log.error("创建3DE目录失败: {}", 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(sourcePath, targetPath, StandardCopyOption.REPLACE_EXISTING);
|
log.info("3DE文件复制成功: {} -> {}", docFile.getFilePath(), targetFilePath);
|
return true;
|
} catch (IOException e) {
|
log.error("3DE文件复制失败: {}", e.getMessage(), e);
|
if (directory.exists() && isDirectoryEmpty(directory)) {
|
directory.delete();
|
}
|
return false;
|
}
|
}
|
|
/**
|
* 保存零件权限
|
*/
|
private boolean savePartsPermission(PartsInfo partsInfo, String productId) {
|
List<PermissionStream> oldPermissionList = permissionStreamService.getAllByProductId(productId);
|
if (CollectionUtils.isEmpty(oldPermissionList)) {
|
return true;
|
}
|
|
List<PartsDepartment> partsDepartPermList = new ArrayList<>();
|
List<PermissionStream> partsPermList = new ArrayList<>();
|
List<PartsPermission> partsUserPermList = new ArrayList<>();
|
|
for (PermissionStream p : oldPermissionList) {
|
if (ValidateUtil.validateString(p.getUserId())) {
|
// 用户权限
|
PartsPermission permission = new PartsPermission();
|
permission.setPartsId(partsInfo.getPartsId());
|
permission.setUserId(p.getUserId());
|
partsUserPermList.add(permission);
|
|
PermissionStream stream = new PermissionStream();
|
stream.setUserId(p.getUserId());
|
stream.setProductId(partsInfo.getProductId());
|
stream.setComponentId(partsInfo.getComponentId());
|
stream.setPartsId(partsInfo.getPartsId());
|
partsPermList.add(stream);
|
}
|
|
if (ValidateUtil.validateString(p.getDepartId())) {
|
// 部门权限
|
PartsDepartment department = new PartsDepartment();
|
department.setPartsId(partsInfo.getPartsId());
|
department.setDepartId(p.getDepartId());
|
partsDepartPermList.add(department);
|
|
PermissionStream stream = new PermissionStream();
|
stream.setProductId(partsInfo.getProductId());
|
stream.setComponentId(partsInfo.getComponentId());
|
stream.setPartsId(partsInfo.getPartsId());
|
stream.setDepartId(p.getDepartId());
|
partsPermList.add(stream);
|
}
|
}
|
|
boolean success = true;
|
if (!partsUserPermList.isEmpty()) {
|
success = success && partsPermissionService.saveBatch(partsUserPermList);
|
}
|
if (!partsDepartPermList.isEmpty()) {
|
success = success && partsDepartmentService.saveBatch(partsDepartPermList);
|
}
|
if (!partsPermList.isEmpty()) {
|
success = success && permissionStreamService.saveBatch(partsPermList);
|
}
|
|
return success;
|
}
|
|
private MesResultModel createErrorModel(MesResultModel model, String errorMsg) {
|
model.setSuccFlag("失败");
|
model.setError(errorMsg);
|
return model;
|
}
|
|
/**
|
* 创建升版文件保存地址并复制文件
|
* 层级结构: 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;
|
}
|
|
|
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<PermissionStream> oldPermissionList = permissionStreamService.getAllByProductId(totalOrSonId);
|
//权限
|
List<ComponentDepartment> componentDepartmentList = new ArrayList<>();
|
List<PermissionStream> componentDepartPermList = new ArrayList<>();
|
List<ComponentPermission> 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<String, String> extractNcFilesWithNamesFromZip(String zipFilePath) throws IOException {
|
// 用于存储文件名和对应文件内容的映射
|
Map<String, String> 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;
|
}
|
}
|
