From 44b55dd34d09090fe6fdeb7d2428efe9e775424c Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期三, 13 八月 2025 22:54:14 +0800
Subject: [PATCH] 增加流程文件下载接口
---
blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/ReplaceFlowService.java | 81 +++++++++++++++++++++++++++++-----------
1 files changed, 58 insertions(+), 23 deletions(-)
diff --git a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/ReplaceFlowService.java b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/ReplaceFlowService.java
index 63ee94c..a44762d 100644
--- a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/ReplaceFlowService.java
+++ b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/ReplaceFlowService.java
@@ -8,6 +8,9 @@
import org.flowable.engine.runtime.ProcessInstance;
import org.flowable.task.api.Task;
import org.simpleframework.xml.core.Replace;
+import org.springblade.core.log.exception.ServiceException;
+import org.springblade.core.oss.OssTemplate;
+import org.springblade.core.oss.model.BladeFile;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.mdm.basesetting.machine.MachineService;
import org.springblade.mdm.basesetting.machine.entity.Machine;
@@ -15,14 +18,19 @@
import org.springblade.mdm.flow.entity.FlowProgramFile;
import org.springblade.mdm.flow.entity.ReplaceProgramFile;
import org.springblade.mdm.flow.vo.ReplaceFlowStartVO;
+import org.springblade.mdm.flow.vo.ReplaceUploadVO;
import org.springblade.mdm.flow.vo.TaskAssignVO;
import org.springblade.mdm.program.entity.NcNode;
import org.springblade.mdm.program.service.NcNodeService;
+import org.springblade.mdm.program.service.NodeDeptQueryService;
import org.springblade.mdm.program.vo.NcNodeVO;
import org.springblade.mdm.utils.EntityUtil;
+import org.springblade.mdm.utils.ProgramFileNameCheckUtil;
import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.multipart.MultipartFile;
import java.util.Arrays;
import java.util.HashMap;
@@ -34,18 +42,19 @@
@Service
public class ReplaceFlowService {
private final NcNodeService nodeService;
- private final TaskService taskService;
private final RuntimeService runtimeService;
+ private final TaskService taskService;
private final IdentityService identityService;
private final FlowProgramFileService flowProgramFileService;
private final ReplaceProgramFileService replaceProgramFileService;
- private final MachineService machineService;
-
+ private final NodeDeptQueryService nodeDeptQueryService;
+ private OssTemplate ossTemplate;
public static final String NODE_ID = "nodeId";
/**
* 杞淳锛屽苟璁板綍鑷繁鐨勫娉ㄤ俊鎭�
* @param nodeId 鏇挎崲鐨勮妭鐐筰d
*/
+ /*
@Transactional
public void prestart(long nodeId,String tempInstanceId) {
List<NcNode> fileNodes = nodeService.lambdaQuery()
@@ -67,6 +76,8 @@
flowProgramFileService.save(newFile);
}
}
+
+ */
@Transactional
public NcNodeVO pre(long nodeId, String tempInstanceId) {
@@ -96,6 +107,8 @@
NcNodeVO vo = new NcNodeVO();
BeanUtils.copyProperties(node, vo);
vo.setProcessInstanceId(tempInstanceId);
+
+ vo.setWorkshop(nodeDeptQueryService.getWorkshopNameByMachineCode(node.getMachineCode()));
return vo;
}
@@ -130,36 +143,58 @@
vars.put(FlowContants.PRODUCT_MODEL,programPackage.getProductModel());
vars.put(NODE_ID, startVO.getNodeId());
+
+ vars.put("comment", startVO.getComment());
identityService.setAuthenticatedUserId(String.valueOf(AuthUtil.getUserId()));//璁剧疆娴佺▼鍙戣捣浜�
ProcessInstance inst = runtimeService.startProcessInstanceByKey(FlowContants.REPLACE_PROCESS_KEY,startVO.getNodeId()+"",vars);
//replaceProgramFileService.lambdaUpdate().eq(ReplaceProgramFile::getTempId,startVO.getTempId()).set(ReplaceProgramFile::getProcessInstanceId,inst.getProcessInstanceId());
+ /*
+ Task startTask = taskService.createTaskQuery()
+ .processInstanceId(inst.getId())
+ .singleResult();
+
+ // 娣诲姞璇勮
+ taskService.addComment(startTask.getId(), inst.getProcessInstanceId(),startVO.getComment());
+ */
flowProgramFileService.lambdaUpdate()
.eq(FlowProgramFile::getProcessInstanceId,startVO.getTempInstanceId())
.set(FlowProgramFile::getProcessInstanceId,inst.getProcessInstanceId()).update();
- /*
- List<ReplaceProgramFile> repFiles = replaceProgramFileService.lambdaQuery().eq(ReplaceProgramFile::getTempId,startVO.getTempId()).list();
-
- for(ReplaceProgramFile repFile : repFiles) {
- FlowProgramFile flowProgramFile = new FlowProgramFile();
- BeanUtils.copyProperties(repFile, flowProgramFile);
- flowProgramFile.setProgramName(programPackge.getName());
-
- EntityUtil.clearBaseProperties(flowProgramFile);
- flowProgramFile.setProcessInstanceId(inst.getId());
- flowProgramFile.setIsCured(0);
-
- flowProgramFileService.save(flowProgramFile);
- }
-
- //鏆傛椂娉ㄩ噴锛屾祴璇曟柟渚�
- replaceProgramFileService.deleteByTempId(startVO.getTempId());
-
- */
- //return inst.getProcessInstanceId();
}
+
+ /**
+ * 涓婁紶绋嬪簭寰愭枃浠讹紙缂栧埗鑺傜偣璋冪敤锛�
+ * @param uploadVO 涓婁紶瀵硅薄
+ */
+ public void uploadReplaceProgramFile(ReplaceUploadVO uploadVO) {
+
+ //FlowProgramProperties progProps= flowCommonService.getProgramProperties(uploadVO.getProcessInstanceId());
+ MultipartFile file = uploadVO.getFile();
+ if(file.getSize() == 0){
+ throw new ServiceException("绋嬪簭鏂囦欢涓嶅彲涓虹┖鏂囦欢");
+ }
+ FlowProgramProperties progProps = new FlowProgramProperties();
+ progProps.setDrawingNo(uploadVO.getDrawingNo());
+ progProps.setProcessNo(uploadVO.getProcessNo());
+ progProps.setProcessEdition(uploadVO.getProcessEdition());
+
+ ProgramFileNameCheckUtil.checkFilename(file.getOriginalFilename(),progProps);
+
+ String programName = NcNodeService.genProgramName(progProps.getDrawingNo(),progProps.getProcessNo());
+
+ BladeFile bfile = ossTemplate.putFile(file);
+
+ FlowProgramFile progFile = new FlowProgramFile();
+ progFile.setName(file.getOriginalFilename());
+ progFile.setOssName(bfile.getName());
+ progFile.setProcessInstanceId(uploadVO.getProcessInstanceId());
+ progFile.setProgramName(programName);
+
+ flowProgramFileService.save(progFile);
+
+ }
}
--
Gitblit v1.9.3