package org.springblade.mdm.flow.service;
|
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.flowable.engine.IdentityService;
|
import org.flowable.engine.RuntimeService;
|
import org.flowable.engine.runtime.ProcessInstance;
|
import org.springblade.core.secure.utils.AuthUtil;
|
import org.springblade.mdm.flow.constants.FlowConstant;
|
import org.springblade.mdm.flow.constants.FlowVariableConstant;
|
import org.springblade.mdm.flow.entity.FlowProgramFile;
|
import org.springblade.mdm.program.entity.NcNode;
|
import org.springblade.mdm.program.service.NcNodeService;
|
import org.springblade.mdm.utils.EntityUtil;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 固化流程服务
|
*/
|
@Slf4j
|
@Service
|
@AllArgsConstructor
|
public class CureFlowService {
|
|
private final RuntimeService runtimeService;
|
|
private final IdentityService identityService;
|
private final NcNodeService ncNodeService;
|
|
private final FlowProgramFileService flowProgramFileService;
|
private final FlowCommonService flowCommonService;
|
|
/**
|
* 启动固化流程
|
*/
|
@Transactional
|
public void startCureNew(Map<Long, List<FlowProgramFile>> pkgIdFileMap) {
|
pkgIdFileMap.forEach(this::startOneNew);
|
}
|
|
/**
|
* 启动一调程序的固化流程
|
* @param nodeId
|
* @param fileList
|
*/
|
private void startOneNew(Long nodeId, List<FlowProgramFile> fileList) {
|
Map<String, Object> vars = new HashMap<>();
|
NcNode programPackage = this.ncNodeService.getById(nodeId);
|
vars.put(FlowConstant.NODE_ID,programPackage.getId());
|
|
flowCommonService.putFlowVariablesByNode(vars,programPackage);
|
|
flowCommonService.putDefaultAssignees(vars,programPackage.getDrawingNo(),null);
|
vars.put(FlowVariableConstant.ASSIGNEE,vars.get(FlowVariableConstant.PROGRAMMER));
|
identityService.setAuthenticatedUserId(String.valueOf(AuthUtil.getUserId()));//设置流程发起人
|
vars.put(FlowVariableConstant.LAST_STEP_USER_NICKNAME, AuthUtil.getNickName());
|
|
if(programPackage.getDeviation() != null) {
|
vars.put(FlowVariableConstant.MY_PROCESS_NAME, "临时更改单回传");
|
vars.put(FlowVariableConstant.TITLE,programPackage.getName()+"-临时更改单回传");//自动增加标题
|
}else {
|
vars.put(FlowVariableConstant.MY_PROCESS_NAME, "固化流程");
|
vars.put(FlowVariableConstant.TITLE,programPackage.getName()+"-"+programPackage.getProcessEdition()+"-固化");//自动增加标题
|
}
|
ProcessInstance inst = runtimeService.startProcessInstanceByKey(FlowConstant.CURE_PROCESS_KEY,"0",vars);
|
|
//更新程序包名节点的流程实例id
|
programPackage.setProcessInstanceId(inst.getProcessInstanceId());
|
ncNodeService.updateById(programPackage);
|
|
for(FlowProgramFile flowProgramFile : fileList){
|
flowProgramFile.setProcessInstanceId(inst.getProcessInstanceId());
|
}
|
this.flowProgramFileService.saveBatch(fileList);
|
|
addPreviousOtherFiles(programPackage.getId(),inst.getProcessInstanceId());
|
|
log.info("启动固化流程完成，实例id={}", inst.getId());
|
}
|
|
/**
|
* 复制试切阶段的其他文件给固化流程
|
* @param previousNodeId 试切阶段的节点id
|
* @param newProcessInstanceId 新的固化流程实例id
|
*/
|
void addPreviousOtherFiles(Long previousNodeId,String newProcessInstanceId) {
|
List<NcNode> previousFileNodes = ncNodeService.getProgramFilesByPackageId(previousNodeId);
|
for(NcNode fileNode : previousFileNodes){
|
|
FlowProgramFile progFile = flowProgramFileService.getById(fileNode.getFlowProgramFileId());
|
if(!progFile.isProgram()){
|
FlowProgramFile newProgFile = new FlowProgramFile();
|
BeanUtils.copyProperties(progFile,newProgFile);
|
EntityUtil.clearBaseProperties(newProgFile);
|
newProgFile.setProcessInstanceId(newProcessInstanceId);
|
|
flowProgramFileService.save(newProgFile);
|
}
|
}
|
}
|
}
|
