| | |
| | | * @param taskBo 参数 |
| | | */ |
| | | @Override |
| | | public TableDataInfo<TaskVo> getTaskWaitByPage(TaskBo taskBo) { |
| | | PageQuery pageQuery = new PageQuery(); |
| | | pageQuery.setPageNum(taskBo.getPageNum()); |
| | | pageQuery.setPageSize(taskBo.getPageSize()); |
| | | public TableDataInfo<TaskVo> getPageByTaskWait(TaskBo taskBo, PageQuery pageQuery) { |
| | | QueryWrapper<TaskVo> queryWrapper = new QueryWrapper<>(); |
| | | List<RoleDTO> roles = LoginHelper.getLoginUser().getRoles(); |
| | | String userId = String.valueOf(LoginHelper.getUserId()); |
| | |
| | | * @param taskBo 参数 |
| | | */ |
| | | @Override |
| | | public TableDataInfo<TaskVo> getAllTaskWaitByPage(TaskBo taskBo) { |
| | | public TableDataInfo<TaskVo> getPageByAllTaskWait(TaskBo taskBo, PageQuery pageQuery) { |
| | | TaskQuery query = QueryUtils.taskQuery(); |
| | | if (StringUtils.isNotBlank(taskBo.getName())) { |
| | | query.taskNameLike("%" + taskBo.getName() + "%"); |
| | |
| | | query.processDefinitionKey(taskBo.getProcessDefinitionKey()); |
| | | } |
| | | query.orderByTaskCreateTime().desc(); |
| | | List<Task> taskList = query.listPage(taskBo.getPageNum(), taskBo.getPageSize()); |
| | | List<Task> taskList = query.listPage(pageQuery.getFirstNum(), pageQuery.getPageSize()); |
| | | List<ProcessInstance> processInstanceList = null; |
| | | if (CollUtil.isNotEmpty(taskList)) { |
| | | Set<String> processInstanceIds = StreamUtils.toSet(taskList, Task::getProcessInstanceId); |
| | |
| | | * @param taskBo 参数 |
| | | */ |
| | | @Override |
| | | public TableDataInfo<TaskVo> getTaskFinishByPage(TaskBo taskBo) { |
| | | public TableDataInfo<TaskVo> getPageByTaskFinish(TaskBo taskBo, PageQuery pageQuery) { |
| | | String userId = String.valueOf(LoginHelper.getUserId()); |
| | | HistoricTaskInstanceQuery query = QueryUtils.hisTaskInstanceQuery(); |
| | | query.taskAssignee(userId).finished().orderByHistoricTaskInstanceStartTime().desc(); |
| | |
| | | if (StringUtils.isNotBlank(taskBo.getProcessDefinitionKey())) { |
| | | query.processDefinitionKey(taskBo.getProcessDefinitionKey()); |
| | | } |
| | | List<HistoricTaskInstance> taskInstanceList = query.listPage(taskBo.getPageNum(), taskBo.getPageSize()); |
| | | List<HistoricTaskInstance> taskInstanceList = query.listPage(pageQuery.getFirstNum(), pageQuery.getPageSize()); |
| | | List<HistoricProcessInstance> historicProcessInstanceList = null; |
| | | if (CollUtil.isNotEmpty(taskInstanceList)) { |
| | | Set<String> processInstanceIds = StreamUtils.toSet(taskInstanceList, HistoricTaskInstance::getProcessInstanceId); |
| | |
| | | * @param taskBo 参数 |
| | | */ |
| | | @Override |
| | | public TableDataInfo<TaskVo> getTaskCopyByPage(TaskBo taskBo) { |
| | | PageQuery pageQuery = new PageQuery(); |
| | | pageQuery.setPageNum(taskBo.getPageNum()); |
| | | pageQuery.setPageSize(taskBo.getPageSize()); |
| | | public TableDataInfo<TaskVo> getPageByTaskCopy(TaskBo taskBo, PageQuery pageQuery) { |
| | | QueryWrapper<TaskVo> queryWrapper = new QueryWrapper<>(); |
| | | String userId = String.valueOf(LoginHelper.getUserId()); |
| | | if (StringUtils.isNotBlank(taskBo.getName())) { |
| | |
| | | * @param taskBo 参数 |
| | | */ |
| | | @Override |
| | | public TableDataInfo<TaskVo> getAllTaskFinishByPage(TaskBo taskBo) { |
| | | public TableDataInfo<TaskVo> getPageByAllTaskFinish(TaskBo taskBo, PageQuery pageQuery) { |
| | | HistoricTaskInstanceQuery query = QueryUtils.hisTaskInstanceQuery(); |
| | | query.finished().orderByHistoricTaskInstanceStartTime().desc(); |
| | | if (StringUtils.isNotBlank(taskBo.getName())) { |
| | |
| | | if (StringUtils.isNotBlank(taskBo.getProcessDefinitionKey())) { |
| | | query.processDefinitionKey(taskBo.getProcessDefinitionKey()); |
| | | } |
| | | List<HistoricTaskInstance> taskInstanceList = query.listPage(taskBo.getPageNum(), taskBo.getPageSize()); |
| | | List<HistoricTaskInstance> taskInstanceList = query.listPage(pageQuery.getFirstNum(), pageQuery.getPageSize()); |
| | | List<HistoricProcessInstance> historicProcessInstanceList = null; |
| | | if (CollUtil.isNotEmpty(taskInstanceList)) { |
| | | Set<String> processInstanceIds = StreamUtils.toSet(taskInstanceList, HistoricTaskInstance::getProcessInstanceId); |
| | |
| | | } |
| | | HistoricProcessInstance historicProcessInstance = QueryUtils.hisInstanceQuery() |
| | | .processInstanceBusinessKey(task.getProcessInstanceId()).singleResult(); |
| | | if (ObjectUtil.isNotEmpty(historicProcessInstance) && BusinessStatusEnum.TERMINATION.getStatus().equals(historicProcessInstance.getBusinessStatus())) { |
| | | throw new ServiceException("该单据已终止!"); |
| | | } |
| | | BusinessStatusEnum.checkInvalidStatus(historicProcessInstance.getBusinessStatus()); |
| | | try { |
| | | if (StringUtils.isBlank(terminationBo.getComment())) { |
| | | terminationBo.setComment(LoginHelper.getLoginUser().getNickname() + "终止了申请"); |
| | |
| | | ExecutionChildByExecutionIdCmd childByExecutionIdCmd = new ExecutionChildByExecutionIdCmd(task.getExecutionId()); |
| | | List<ExecutionEntity> executionEntities = managementService.executeCommand(childByExecutionIdCmd); |
| | | //校验单据 |
| | | if (BusinessStatusEnum.BACK.getStatus().equals(processInstance.getBusinessStatus())) { |
| | | throw new ServiceException("该单据已退回!"); |
| | | } |
| | | BusinessStatusEnum.checkBackStatus(processInstance.getBusinessStatus()); |
| | | //判断是否有多个任务 |
| | | List<Task> taskList = QueryUtils.taskQuery(processInstanceId).list(); |
| | | //申请人节点 |