| | |
| | | import org.springblade.core.tool.support.Kv; |
| | | import org.springblade.core.tool.utils.Func; |
| | | import org.springblade.core.tool.utils.StringUtil; |
| | | import org.springblade.mdm.basesetting.machine.entity.Machine; |
| | | import org.springblade.mdm.basesetting.machine.service.MachineService; |
| | | import org.springblade.mdm.commons.service.ParamService; |
| | | import org.springblade.mdm.commons.service.UserCommonService; |
| | | import org.springblade.mdm.flow.constants.FlowContants; |
| | | import org.springblade.mdm.flow.constants.FlowVariableContants; |
| | | import org.springblade.mdm.flow.service.FlowCommonService; |
| | | import org.springblade.mdm.flow.service.FlowProgramFileService; |
| | | import org.springblade.mdm.flow.service.FlowProgramProperties; |
| | | import org.springblade.mdm.program.entity.NcNode; |
| | | import org.springblade.mdm.program.service.NcNodeAutoCreateService; |
| | | import org.springblade.mdm.program.service.NcNodeService; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | public class TryFlowCompleteService extends AbstractFlowCompleteService { |
| | | @Autowired |
| | | private FlowProgramFileService flowProgramFileService; |
| | | |
| | | @Autowired |
| | | private NcNodeService ncNodeService; |
| | | @Autowired |
| | | private NcNodeAutoCreateService ncNodeAutoCreateService; |
| | | private ParamService paramService; |
| | | @Autowired |
| | | private FlowCommonService flowCommonService; |
| | | @Autowired |
| | | private UserCommonService userCommonService; |
| | | @Autowired |
| | | private MachineService machineService; |
| | | |
| | | @Transactional |
| | | @Override |
| | | public void completeTask(String taskId, String processInstanceId, String comment, Map<String, Object> variables) { |
| | | Task task = currentTask(taskId); |
| | | String operateResult = this.getApproveResult(variables); |
| | | |
| | | if(task.getTaskDefinitionKey().equals("programmingTask")) {//编制节点 |
| | | flowProgramFileService.checkProgramFiles(processInstanceId,FlowContants.Y.equals(operateResult)); |
| | | } |
| | | if (StringUtil.isNoneBlank(processInstanceId, comment)) { |
| | | taskService.addComment(taskId, processInstanceId, comment); |
| | | } |
| | | // 非空判断 |
| | | if (Func.isEmpty(variables)) { |
| | | variables = Kv.create(); |
| | | } |
| | | variables.put(FlowContants.LAST_STEP_USER_NICKNAME, AuthUtil.getNickName()); |
| | | String operateResult = this.getApproveResult(variables); |
| | | |
| | | FlowProgramProperties props = flowCommonService.getProgramProperties(processInstanceId); |
| | | if(!variables.containsKey("assignee")) { |
| | | throw new ServiceException("请指定流程下一步处理人"); |
| | | } |
| | | |
| | | if(task.getTaskDefinitionKey().equals("programmingTask") ) {//编制节点 |
| | | //记录实际编程员 |
| | | variables.put(FlowVariableContants.ACT_PROGRAMMER,Func.toStr(AuthUtil.getUserId())); |
| | | String programOnMachine = Func.toStr(variables.getOrDefault("programOnMachine",FlowContants.N));//是否现场编程 |
| | | if(this.needUploadProgramFile(props.getMachineCode()) && programOnMachine.equals(FlowContants.N)) { |
| | | flowProgramFileService.checkProgramFiles(processInstanceId, FlowContants.Y.equals(operateResult)); |
| | | } |
| | | }else if(task.getTaskDefinitionKey().equals("teamLeaderTask")){ |
| | | if(FlowContants.Y.equals(operateResult)) { |
| | | runtimeService.setVariable(task.getExecutionId(),FlowContants.PROGRAMMER_NAME,userCommonService.getUserNameById(Func.toLong(variables.get("assignee")))); |
| | | } |
| | | }else if(task.getTaskDefinitionKey().equals("check")){ |
| | | variables.put(FlowVariableContants.ACT_CHECKER,Func.toStr(AuthUtil.getUserId())); |
| | | }else if(task.getTaskDefinitionKey().equals("approveTask")){ |
| | | variables.put(FlowVariableContants.ACT_SENIOR,Func.toStr(AuthUtil.getUserId())); |
| | | } |
| | | variables.remove("programOnMachine");//其他节点,忽略现场编程标记 |
| | | if (StringUtil.isNoneBlank(processInstanceId, comment)) { |
| | | taskService.addComment(taskId, processInstanceId, comment); |
| | | } |
| | | |
| | | variables.put(FlowContants.LAST_STEP_USER_NICKNAME, AuthUtil.getNickName()); |
| | | |
| | | addApproveRecord(taskId,comment,variables); |
| | | |
| | | if(task.getTaskDefinitionKey().equals("approveTask") && FlowContants.Y.equals(operateResult)) { |
| | | //试切流程,或者 偏离流程 高师通过的时候创建节点 |
| | | //createProgramNodes(processInstanceId); |
| | | } |
| | | variables.remove(FlowContants.PROCESS_EDITION);//不要升版了 |
| | | //if(!"confirmIsUseableTask".equals(task.getTaskDefinitionKey())){ |
| | | |
| | | if("confirmIsUseableTask".equals(task.getTaskDefinitionKey())){ |
| | | //工序版次不一致,并且审核通过(可用)是,才更新为新的versionNumber |
| | | //FlowProgramProperties progProperties = flowCommonService.getProgramProperties(processInstanceId); |
| | | variables.put(FlowContants.CURE_PROGRAM_USEABLE,operateResult); |
| | | |
| | | //if(FlowContants.Y.equals(operateResult) && FlowContants.N.equals(progProperties.getIsProcessEditionSame())) { |
| | | //确认程序可用 且 工序版次不一致,进入校对。这里需要升级程序的版本号 |
| | | // Long curedNodeId = progProperties.getCuredNodeId(); |
| | | // ncNodeService.upgradeVersionNumber(curedNodeId); |
| | | //} |
| | | if(FlowContants.Y.equals(operateResult)) { |
| | | //判定可用,记录为实际编程员 |
| | | variables.put(FlowVariableContants.ACT_PROGRAMMER,Func.toStr(AuthUtil.getUserId())); |
| | | } |
| | | } |
| | | taskService.complete(taskId, variables); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 是否需要上传文件(车床不需要) |
| | | * @param machineCode 机床编码 |
| | | * @return 是否需要上传 |
| | | */ |
| | | boolean needUploadProgramFile(String machineCode){ |
| | | boolean need; |
| | | Machine machine = machineService.getByCode(machineCode); |
| | | String turning = paramService.turninngValue(); |
| | | need = !StringUtils.equals(turning,machine.getMachineSpec()); |
| | | return need; |
| | | } |
| | | |
| | | } |