| | |
| | | import com.ycl.domain.entity.*; |
| | | import com.ycl.domain.form.*; |
| | | import com.ycl.domain.json.*; |
| | | import com.ycl.domain.vo.CustomerTaskVO; |
| | | import com.ycl.domain.vo.IndexCustomerTaskVO; |
| | | import com.ycl.domain.vo.ProjectProcessDetailVO; |
| | | import com.ycl.domain.vo.*; |
| | | import com.ycl.event.event.TaskLogEvent; |
| | | import com.ycl.mapper.ProjectEngineeringMapper; |
| | | import com.ycl.mapper.ProjectInfoMapper; |
| | |
| | | import com.ycl.service.*; |
| | | import com.ycl.common.base.Result; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.ycl.domain.vo.ProjectProcessVO; |
| | | import com.ycl.domain.query.ProjectProcessQuery; |
| | | import com.ycl.service.common.TaskCommonService; |
| | | import com.ycl.system.service.ISysDeptService; |
| | |
| | | IPage<ProjectProcessVO> page = PageUtil.getPage(query, ProjectProcessVO.class); |
| | | baseMapper.getPage(query, page); |
| | | for (ProjectProcessVO vo : page.getRecords()) { |
| | | vo.setChildren(TreeUtil.treeForProjectEng(baseMapper.getEngineeringList(vo.getId()))); |
| | | List<ProjectEngineeringVO> childList = baseMapper.getEngineeringList(vo.getId()); |
| | | childList.stream().forEach(child -> { |
| | | if (StringUtils.isNotBlank(child.getProcessDefId())) { |
| | | ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(child.getProcessDefId()).singleResult(); |
| | | if (Objects.nonNull(processDefinition)) { |
| | | child.setSuspended(processDefinition.isSuspended()); |
| | | child.setFlowableProcessName(processDefinition.getName() + "(v" + processDefinition.getVersion() + ")"); |
| | | child.setDeployId(processDefinition.getDeploymentId()); |
| | | } |
| | | } |
| | | }); |
| | | vo.setChildren(TreeUtil.treeForProjectEng(childList)); |
| | | vo.setStatus(vo.getProjectStatus()); |
| | | if (Objects.nonNull(vo.getProcessDefId())) { |
| | | if (StringUtils.isNotBlank(vo.getProcessDefId())) { |
| | | ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(vo.getProcessDefId()).singleResult(); |
| | | if (Objects.nonNull(processDefinition)) { |
| | | vo.setSuspended(processDefinition.isSuspended()); |
| | |
| | | variables.put(ProcessConstants.PROCESS_INITIATOR, sysUser.getUserId()); |
| | | // 将该项目的申请人(业主方)作为流程中某些环节的处理人 |
| | | variables.put(ProcessConstants.DATA_LAUNCH, "dept:" + createBy); |
| | | variables.put("a", 1); |
| | | ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefId, projectId + "", variables); |
| | | return processInstance.getId(); |
| | | } |
| | |
| | | taskVO.setTaskDefinitionKey(task.getTaskDefinitionKey()); |
| | | |
| | | // 流程项目信息 |
| | | ProjectInfo project = baseMapper.getProjectInfo(task.getProcessInstanceId()); |
| | | if (Objects.nonNull(project)) { |
| | | taskVO.setProjectId(project.getId()); |
| | | taskVO.setProjectName(project.getProjectName()); |
| | | } else { |
| | | continue; |
| | | ProjectProcess projectProcess = new LambdaQueryChainWrapper<>(baseMapper) |
| | | .eq(ProjectProcess::getProcessInsId, task.getProcessInstanceId()) |
| | | .one(); |
| | | String projectId = ""; |
| | | String projectName = ""; |
| | | if (Objects.nonNull(projectProcess)) { |
| | | if (projectProcess.getProjectType().equals(ProjectProcessTypeEnum.PROJECT)) { |
| | | ProjectInfo project = projectInfoMapper.selectById(projectProcess.getProjectId()); |
| | | if (Objects.nonNull(project)) { |
| | | projectId = projectProcess.getProjectId(); |
| | | projectName = project.getProjectName(); |
| | | } |
| | | } else if (projectProcess.getProjectType().equals(ProjectProcessTypeEnum.ENGINEERING)) { |
| | | ProjectEngineering engineering = projectEngineeringMapper.selectById(projectProcess.getProjectId()); |
| | | if (Objects.nonNull(engineering)) { |
| | | projectId = projectProcess.getProjectId(); |
| | | projectName = engineering.getProjectName(); |
| | | } |
| | | } |
| | | } |
| | | taskVO.setProjectId(projectId); |
| | | taskVO.setProjectName(projectName); |
| | | |
| | | // 流程发起人信息 |
| | | this.setPromoterInfo(taskVO); |
| | |
| | | * @param result |
| | | */ |
| | | public void getTodoTaskList(String projectId, String processInsId, String taskName, int pageSize, int pageNum, Result result) { |
| | | |
| | | TaskQuery taskQuery = taskService.createTaskQuery() |
| | | .active() |
| | | .processInstanceId(processInsId) |
| | |
| | | taskVO.getHandlerUnitId().add(sysUser.getDept().getDeptId()); |
| | | taskVO.getHandlerUnitName().add(sysUser.getDept().getDeptName()); |
| | | taskVO.getPromoterName().add(this.getUserShowName(sysUser)); |
| | | taskVO.getPromoterUnitName().add(sysUser.getDept().getDeptName()); |
| | | // if (sysUser.getDept().getAncestors()) |
| | | String[] str = sysUser.getDept().getAncestors().split(","); |
| | | if (str.length >= 4){ |
| | | taskVO.getPromoterUnitName().add(sysUser.getDept().getParentName() +"-"+sysUser.getDept().getDeptName()); |
| | | }else { |
| | | taskVO.getPromoterUnitName().add(sysUser.getDept().getDeptName()); |
| | | } |
| | | |
| | | } |
| | | } |
| | | // 绑定的是角色或者部门 |
| | |
| | | taskVO.getHandlerUnitId().add(dept.getDeptId()); |
| | | taskVO.getHandlerUnitName().add(dept.getDeptName()); |
| | | taskVO.getPromoterName().add(this.getDeptLeaderShowName(dept)); |
| | | taskVO.getPromoterUnitName().add(dept.getDeptName()); |
| | | String[] str = dept.getAncestors().split(","); |
| | | if (str.length >= 4){ |
| | | taskVO.getPromoterUnitName().add(dept.getParentName() +"-"+dept.getDeptName()); |
| | | }else { |
| | | taskVO.getPromoterUnitName().add(dept.getDeptName()); |
| | | } |
| | | |
| | | } |
| | | } |
| | | } else { |