From dc01577b31204fd3c80645b45d81ff693f79a985 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期三, 10 九月 2025 23:04:20 +0800
Subject: [PATCH] 程序包名增加版次

---
 blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/DNCSendBackService.java |   55 +++++++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 41 insertions(+), 14 deletions(-)

diff --git a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/DNCSendBackService.java b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/DNCSendBackService.java
index a9dfc6a..e34f27a 100644
--- a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/DNCSendBackService.java
+++ b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/DNCSendBackService.java
@@ -5,6 +5,7 @@
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.io.FilenameUtils;
+import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.mp.base.BizServiceImpl;
@@ -25,6 +26,10 @@
 import org.springblade.mdm.program.entity.NcNode;
 import org.springblade.mdm.program.entity.NcProgramExchange;
 import org.springblade.mdm.program.mapper.NcProgramExchangeMapper;
+import org.springblade.mdm.program.service.programannotation.AnnotationProcessor;
+import org.springblade.mdm.program.service.programannotation.DefaultProcessor;
+import org.springblade.mdm.program.service.programannotation.FanucProcessor;
+import org.springblade.mdm.program.service.programannotation.MachineAnnotationConfig;
 import org.springblade.mdm.program.vo.DncSendBackData;
 import org.springblade.mdm.program.vo.DncSendBackFile;
 import org.springblade.mdm.program.vo.ProgramAnnotation;
@@ -36,11 +41,13 @@
 import org.springframework.web.multipart.MultipartFile;
 
 import java.io.*;
+import java.lang.annotation.Annotation;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.StandardOpenOption;
 import java.time.Duration;
 import java.util.*;
+import java.util.regex.Pattern;
 import java.util.zip.ZipEntry;
 import java.util.zip.ZipFile;
 
@@ -62,6 +69,10 @@
 	private final DncBackFileService dncBackFileService;
 	private final MachineService machineService;
 	private final ParamService paramService;
+	private final MachineAnnotationConfig machineAnnotationConfig;
+
+	private final FanucProcessor fanucProcessor;
+	private final DefaultProcessor defaultProcessor;
 	/**
 	 * 鍋忕鍗曟枃浠舵湯灏剧殑妯″紡锛歅+鏁板瓧
 	 */
@@ -134,12 +145,13 @@
 				DncSendBackData progData = new DncSendBackData();
 				String folderName = StringUtils.removeEnd(entryName,"/");
 
-				PackageAndProcessEdition pkgAndEdition = parseProgramPackageFromFolderName(folderName);
-				String packageName = pkgAndEdition.getProgramPackageName();
-				String processEdition = pkgAndEdition.getProcessEdition();
+				//PackageAndProcessEdition pkgAndEdition = parseProgramPackageFromFolderName(folderName);
+				String packageName = folderName;//pkgAndEdition.getProgramPackageName();
+				//String processEdition = pkgAndEdition.getProcessEdition();
+				/*
 				if(StringUtils.isBlank(packageName) || StringUtils.isBlank(processEdition)){
-					throw new ServiceException("鍖呭唴鏂囦欢澶瑰悕鏍煎紡閿欒搴旇涓篬闆剁粍浠跺彿-宸ュ簭鍙�-宸ュ簭鐗堟]:"+folderName);
-				}
+					throw new ServiceException("鍖呭唴鏂囦欢澶瑰悕鏍煎紡閿欒锛屽簲璇ヤ负[闆剁粍浠跺彿-宸ュ簭鍙�-宸ュ簭鐗堟]:"+folderName);
+				}*/
 
 				progData.setProgramName(packageName);
 				String statusLine;
@@ -147,20 +159,32 @@
 				if(optFilename.isPresent()){
 					entry = zipFile.getEntry(optFilename.get());
 					InputStream ins = zipFile.getInputStream(entry);
+					ByteArrayInputStream bais = new ByteArrayInputStream(IOUtils.toByteArray(ins));;
 					progData.setFileBackTime(DateUtil.fromInstant(entry.getLastModifiedTime().toInstant()));
-					statusLine = FileContentUtil.readLineAt(ins,2);
+					//machineAnnotationConfig.getConfigMap().get(machine.getcon)
+					Pattern fanucPattern = Pattern.compile("^[oO]\\d{4}");
+					String testLine = FileContentUtil.readLineAt(bais,2);//TODO,fanuc杩欒鏄笅鍙戣矾寰勶紝鍏朵粬鏈哄櫒鏄姸鎬�
+					bais.reset();
+					//boolean isFanuc = fanucPattern.matcher(testLine).matches();
+					boolean isFanuc = !StringUtils.containsAny(testLine,"(SQ)","(GH)","(PL)");
+					if(isFanuc){
+						statusLine = FileContentUtil.readLineAt(bais,3);//fanuc鐨勭姸鎬佽绗�4琛�
+					}else{
+						statusLine = testLine;
+					}
+
 					if(statusLine.contains("SQ")){
 						//璇曞垏
-						programPackageNode = ncNodeService.getLastEditionTryingProgramPackage(packageName,processEdition);
+						programPackageNode = ncNodeService.getLastEditionTryingProgramPackage(packageName);//,processEdition
 					}else if(statusLine.contains("GH")){
 						//鍥哄寲
-						programPackageNode = ncNodeService.getLastEditionCuredProgramPackage(packageName,processEdition);
+						programPackageNode = ncNodeService.getLastEditionCuredProgramPackage(packageName);
 					}else if(statusLine.contains("PL")){
 						//鍋忕
-						programPackageNode =ncNodeService.getLastEditionDeviationProgramPackage(packageName,processEdition);
+						programPackageNode =ncNodeService.getLastEditionDeviationProgramPackage(packageName);
 					}else{
 						//鏌ヨ鏄惁杞﹀簥锛屾槸杞﹀簥鍙互鏀捐繃锛屾寜璇曞垏澶勭悊
-						programPackageNode = ncNodeService.getLastEditionTryingProgramPackage(packageName,processEdition);
+						programPackageNode = ncNodeService.getLastEditionTryingProgramPackage(packageName);
 						if(programPackageNode!=null){
 							Machine machine = machineService.getByCode(programPackageNode.getMachineCode());
 							String chechuangVal = paramService.turninngValue();
@@ -205,10 +229,10 @@
 	 * @param folderName 鏂囦欢澶瑰悕
 	 * @return 缁撴瀯鏁版嵁
 	 */
+	/*
 	PackageAndProcessEdition parseProgramPackageFromFolderName(String folderName){
 		int index = StringUtils.lastIndexOf(folderName,'-');
 		String processEditon = "";
-		String temp;
 		String packageName = "";
 		if(index != -1){
 			processEditon = folderName.substring(index+1);
@@ -219,7 +243,7 @@
 		result.setProgramPackageName(packageName);
 		result.setProcessEdition(processEditon);
 		return result;
-	}
+	}*/
 
 	/**
 	 * 鍏ュ簱鍥炰紶鏂囦欢,骞跺惎鍔ㄥ浐鍖栨祦绋�
@@ -269,8 +293,8 @@
 			for(String dir : dirList){
 				String folderName = StringUtils.removeEnd(dir,"/");
 
-				PackageAndProcessEdition pkgAndEdition = parseProgramPackageFromFolderName(folderName);
-				String programPackageName = pkgAndEdition.getProgramPackageName();
+				//PackageAndProcessEdition pkgAndEdition = folderName;//parseProgramPackageFromFolderName(folderName);
+				String programPackageName = folderName; //pkgAndEdition.getProgramPackageName();
 
 				Optional<NcNode> optPackageNode = allAcceptPackages.stream().filter(node -> StringUtils.equals(node.getName(),programPackageName)).findFirst();
 
@@ -414,4 +438,7 @@
 	private String programPackageName;
 	private String processEdition;
 
+	public String programName(){
+		return programPackageName+"-"+processEdition;
+	}
 }

--
Gitblit v1.9.3