From 02c7b7d7aa76303e7ab5b224359b78fd25a26dc0 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期二, 12 八月 2025 14:51:21 +0800
Subject: [PATCH] 批量审核接口改进

---
 blade-service/blade-mdm/src/main/java/org/springblade/mdm/program/service/DNCSendBackService.java |   31 +++++++++++++++++++++----------
 1 files changed, 21 insertions(+), 10 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 775e09c..f6ab47a 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
@@ -2,6 +2,7 @@
 package org.springblade.mdm.program.service;
 
 import com.alibaba.fastjson.JSONObject;
+import io.netty.util.internal.StringUtil;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
@@ -23,6 +24,7 @@
 import org.springblade.mdm.program.entity.NcProgramExchange;
 import org.springblade.mdm.program.mapper.NcProgramExchangeMapper;
 import org.springblade.mdm.program.vo.DncSendBackData;
+import org.springblade.mdm.utils.EntityUtil;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -63,6 +65,13 @@
 	 */
 	public List<DncSendBackData> dncSendBackUpload(MultipartFile file) {
 		List<DncSendBackData> list;
+		if(file == null || file.isEmpty()){
+			throw new ServiceException("鏂囦欢涓虹┖");
+		}
+
+		if(!StringUtils.endsWith(file.getOriginalFilename(),".zip")){
+			throw new ServiceException("鏂囦欢蹇呴』涓簔ip鍖� ");
+		}
 		try {
 			BladeFile bfile = ossTemplate.putFile(file);//涓婁紶锛屼緵鍚庣画鍏ュ簱浣跨敤
 			//璁剧疆涓�涓紦瀛橈紝2灏忔椂杩囨湡
@@ -106,7 +115,7 @@
 					NcNode programPackageNode = ncNodeService.getLastEditionTryingProgramPackage(packageName);
 					NcNode curedProgramPkg = ncNodeService.getLastEditionCuredProgramPackage(packageName);
 
-					if(programPackageNode!=null && curedProgramPkg != null) {//鏃犲浐鍖栫▼搴忥紝鎵嶆斁鍏ュ垪琛�
+					if(programPackageNode!=null && curedProgramPkg == null) {//鏃犲浐鍖栫▼搴忥紝鎵嶆斁鍏ュ垪琛�
 						//NcNode programPackageNode = pkgList.get(0);
 						progData.setId(programPackageNode.getId());
 						progData.setProgramName(packageName);
@@ -209,7 +218,7 @@
 				}
 				NcNode newProgramPkg = new NcNode();
 				BeanUtils.copyProperties(oriProgramPkg, newProgramPkg);
-				clearBaseProperties(newProgramPkg);
+				EntityUtil.clearBaseProperties(newProgramPkg);
 				newProgramPkg.setIsLastEdition(1);
 				ncNodeService.save(newProgramPkg);
 				newProgramPackageNodeList.add(newProgramPkg);
@@ -235,7 +244,7 @@
 
 						NcNode newProgramNode = new NcNode();
 						BeanUtils.copyProperties(oldProgramNode, newProgramNode);
-						clearBaseProperties(newProgramNode);
+						EntityUtil.clearBaseProperties(newProgramNode);
 						newProgramNode.setIsLastEdition(1);
 						newProgramNode.setParentId(newProgramPkg.getId());
 						newProgramNode.setParentIds(newProgramPkg.getParentIds()+","+newProgramPkg.getId());
@@ -244,10 +253,10 @@
 
 						FlowProgramFile oldFlowFile = flowProgramFileService.getById(newProgramNode.getFlowProgramFileId());
 
-						FlowProgramFile newFlowFile = new FlowProgramFile();//TODO
+						FlowProgramFile newFlowFile = new FlowProgramFile();
 						BeanUtils.copyProperties(oldFlowFile, newFlowFile);
 						newFlowFile.setProcessInstanceId(null);
-						clearBaseProperties(newFlowFile);
+						EntityUtil.clearBaseProperties(newFlowFile);
 
 						try {
 							InputStream ins = zipFile.getInputStream(zipFile.getEntry(entryName));
@@ -259,9 +268,11 @@
 						newProgramNode.setFlowProgramFile(newFlowFile);
 						newProgramNode.setVersionNumber(oldProgramNode.genNewVersionNumber());
 						newProgramNodes.add(newProgramNode);
-						oldProgramNode.setIsLastEdition(0);
-						oldProgramNode.setIsLocked(1);
-						ncNodeService.updateById(oldProgramNode);
+						//鏃ц妭鐐瑰鐞嗭紝鍜嬪姙锛熷鏋滃鍑哄伐鎺х綉 閲嶅瀵煎嚭鍛紵锛宨sLastEdition涓嶇敤璁剧疆浜嗭紝鍥犱负 绋嬪簭鍖呰妭鐐� 鏄柊鐨�
+						//TODO 寰呴獙璇�
+						//oldProgramNode.setIsLastEdition(鍘熸潵鏄�0);
+						//oldProgramNode.setIsLocked(1);
+						//ncNodeService.updateById(oldProgramNode);
 					}
 				});
 
@@ -295,7 +306,7 @@
 		entity.setCreateUser(jsonObject.getLong("createUser"));
 		entity.setUpdateUser(jsonObject.getLong("updateUser"));
 	}
-
+	/*
 	void clearBaseProperties(BizEntity entity){
 		entity.setId(null);
 		entity.setCreateTime(null);
@@ -303,5 +314,5 @@
 		entity.setStatus(null);
 		entity.setCreateUser(null);
 		entity.setUpdateUser(null);
-	}
+	}*/
 }

--
Gitblit v1.9.3