| | |
| | | import com.java110.core.base.smo.BaseServiceSMO; |
| | | import com.java110.core.factory.GenerateCodeFactory; |
| | | import com.java110.dto.PageDto; |
| | | import com.java110.dto.auditMessage.AuditMessageDto; |
| | | import com.java110.dto.oaWorkflowData.OaWorkflowDataDto; |
| | | import com.java110.dto.oaWorkflowXml.OaWorkflowXmlDto; |
| | | import com.java110.dto.audit.AuditMessageDto; |
| | | import com.java110.dto.oaWorkflow.OaWorkflowDataDto; |
| | | import com.java110.dto.oaWorkflow.OaWorkflowXmlDto; |
| | | import com.java110.dto.purchase.PurchaseApplyDto; |
| | | import com.java110.dto.user.UserDto; |
| | | import com.java110.dto.workflow.WorkflowDto; |
| | | import com.java110.entity.audit.AuditUser; |
| | | import com.java110.dto.oaWorkflow.WorkflowDto; |
| | | import com.java110.dto.audit.AuditUser; |
| | | import com.java110.intf.common.IOaWorkflowActivitiInnerServiceSMO; |
| | | import com.java110.intf.common.IWorkflowInnerServiceSMO; |
| | | import com.java110.intf.oa.IOaWorkflowDataInnerServiceSMO; |
| | | import com.java110.intf.store.IPurchaseApplyInnerServiceSMO; |
| | | import com.java110.intf.user.IUserInnerServiceSMO; |
| | | import com.java110.po.oaWorkflowData.OaWorkflowDataPo; |
| | | import com.java110.po.oaWorkflow.OaWorkflowDataPo; |
| | | import com.java110.po.purchase.PurchaseApplyPo; |
| | | import com.java110.utils.exception.SMOException; |
| | | import com.java110.utils.util.Assert; |
| | | import com.java110.utils.util.DateUtil; |
| | |
| | | @Autowired |
| | | private IOaWorkflowDataInnerServiceSMO oaWorkflowDataInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IPurchaseApplyInnerServiceSMO purchaseApplyInnerServiceSMOImpl; |
| | | |
| | | /** |
| | | * 启动流程 |
| | |
| | | if (tmp.getProcessInstanceId().equals(reqJson.getString("processInstanceId"))) { |
| | | task = tmp;//获取当前流程实例,当前申请人的待办任务 |
| | | break; |
| | | } |
| | | } |
| | | if (task == null) { |
| | | PurchaseApplyDto purchaseApplyDto = new PurchaseApplyDto(); |
| | | purchaseApplyDto.setApplyOrderId(reqJson.getString("id")); |
| | | List<PurchaseApplyDto> purchaseApplyList = purchaseApplyInnerServiceSMOImpl.queryPurchaseApplys(purchaseApplyDto); |
| | | if (purchaseApplyList != null && purchaseApplyList.size() == 1) { |
| | | PurchaseApplyPo purchaseApplyPo = new PurchaseApplyPo(); |
| | | purchaseApplyPo.setApplyOrderId(reqJson.getString("id")); |
| | | purchaseApplyPo.setStatusCd("1"); |
| | | purchaseApplyInnerServiceSMOImpl.updatePurchaseApply(purchaseApplyPo); |
| | | } |
| | | } |
| | | Assert.notNull(task, "未找到当前用户任务userId = " + reqJson.getString("createUserId")); |
| | |
| | | * |
| | | * @param user 用户信息{ |
| | | * processDefinitionKeys:[], |
| | | * |
| | | * } |
| | | * <p> |
| | | * } |
| | | */ |
| | | public List<JSONObject> getDefinitionKeysUserTasks(@RequestBody AuditUser user) { |
| | | TaskService taskService = processEngine.getTaskService(); |
| | |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 获取当前节点信息 |
| | | * |
| | | * @param reqJson{ taskId:'', |
| | | * startUserId:'' |
| | | * } |
| | | * @return |
| | | */ |
| | | public JSONObject getCurrentNodeTask(@RequestBody JSONObject reqJson) { |
| | | JSONObject curNode = new JSONObject(); |
| | | TaskService taskService = processEngine.getTaskService(); |
| | | Task task = taskService.createTaskQuery().taskId(reqJson.getString("taskId")).singleResult(); |
| | | if (task == null) { |
| | | throw new IllegalArgumentException("任务已处理"); |
| | | } |
| | | BpmnModel bpmnModel = repositoryService.getBpmnModel(task.getProcessDefinitionId()); |
| | | |
| | | FlowNode flowNode = (FlowNode) bpmnModel.getFlowElement(task.getTaskDefinitionKey()); |
| | | flowNode.getName(); |
| | | |
| | | curNode.put("curTaskName", flowNode.getName()); |
| | | return curNode; |
| | | } |
| | | |
| | | @Override |
| | | public List<JSONObject> nextAllNodeTaskList(@RequestBody JSONObject reqJson) { |
| | | List<JSONObject> tasks = new ArrayList<>(); |