| | |
| | | import com.ycl.domain.vo.IndexCustomerTaskVO; |
| | | import com.ycl.domain.vo.ProjectProcessDetailVO; |
| | | import com.ycl.event.event.TaskLogEvent; |
| | | import com.ycl.mapper.ProjectEngineeringMapper; |
| | | import com.ycl.mapper.ProjectInfoMapper; |
| | | import com.ycl.mapper.ProjectProcessMapper; |
| | | import com.ycl.service.*; |
| | |
| | | private final IdentityService identityService; |
| | | private final RepositoryService repositoryService; |
| | | private final ProjectInfoMapper projectInfoMapper; |
| | | private final ProjectEngineeringMapper projectEngineeringMapper; |
| | | private final HistoryService historyService; |
| | | private final ISysUserService sysUserService; |
| | | private final ISysRoleService sysRoleService; |
| | |
| | | // æ¥è¯¢è¯¥é¡¹ç®æ¯å¦å·²ç»ç»å®è¿æµç¨äºï¼æ£æ¥ç»å®çæµç¨æ¯å¦å¨è¿è¡ï¼å¨è¿è¡å°±å äº |
| | | ProjectProcess pp = new LambdaQueryChainWrapper<>(baseMapper) |
| | | .eq(ProjectProcess::getProjectId, form.getProjectId()) |
| | | .eq(ProjectProcess::getProjectType, form.getProjectType()) |
| | | .one(); |
| | | if (Objects.isNull(pp)) { |
| | | throw new RuntimeException("è¯¥é¡¹ç®æªç»å®æµç¨"); |
| | |
| | | } |
| | | } |
| | | } |
| | | Long unitId = null; |
| | | if (ProjectProcessTypeEnum.PROJECT.equals(form.getProjectType())) { |
| | | ProjectInfo project = new LambdaQueryChainWrapper<>(projectInfoMapper) |
| | | .select(ProjectInfo::getProjectOwnerUnit) |
| | | .eq(ProjectInfo::getId, form.getProjectId()) |
| | |
| | | if (Objects.isNull(project)) { |
| | | throw new RuntimeException("项ç®ä¸åå¨"); |
| | | } |
| | | SysDept dept = deptService.selectDeptById(project.getProjectOwnerUnit()); |
| | | unitId = project.getProjectOwnerUnit(); |
| | | } else if (ProjectProcessTypeEnum.ENGINEERING.equals(form.getProjectType())) { |
| | | ProjectEngineering projectEngineering = new LambdaQueryChainWrapper<>(projectEngineeringMapper) |
| | | .select(ProjectEngineering::getDepartment) |
| | | .eq(ProjectEngineering::getId, form.getProjectId()) |
| | | .one(); |
| | | if (Objects.isNull(projectEngineering)) { |
| | | throw new RuntimeException("å·¥ç¨ä¸åå¨"); |
| | | } |
| | | unitId = projectEngineering.getUnit(); |
| | | } |
| | | |
| | | SysDept dept = deptService.selectDeptById(unitId); |
| | | if (Objects.isNull(dept)) { |
| | | throw new RuntimeException("项ç®ä¸ä¸»åä½ä¸åå¨"); |
| | | throw new RuntimeException("ä¸ä¸»åä½ä¸åå¨"); |
| | | } |
| | | String processInsId = this.startPro(form.getProjectId(), form.getProcessDefId(), dept.getDeptId()); |
| | | new LambdaUpdateChainWrapper<>(baseMapper) |
| | | .eq(ProjectProcess::getProjectId, form.getProjectId()) |
| | | .eq(ProjectProcess::getProjectType, form.getProjectType()) |
| | | .set(ProjectProcess::getProcessDefId, form.getProcessDefId()) |
| | | .set(ProjectProcess::getProcessInsId, processInsId) |
| | | .set(ProjectProcess::getDataLaunch, project.getProjectOwnerUnit()) |
| | | .set(ProjectProcess::getDataLaunch, unitId) |
| | | .update(); |
| | | |
| | | return Result.ok("æµç¨åæ´æå"); |
| | |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Result startProcess(Long projectId, String processDefId) { |
| | | ProjectInfo project = projectInfoMapper.selectById(projectId); |
| | | public Result startProcess(ProjectProcessForm form) { |
| | | Long unitId = null; |
| | | if (ProjectProcessTypeEnum.PROJECT.equals(form.getProjectType())) { |
| | | ProjectInfo project = new LambdaQueryChainWrapper<>(projectInfoMapper) |
| | | .select(ProjectInfo::getProjectOwnerUnit) |
| | | .eq(ProjectInfo::getId, form.getProjectId()) |
| | | .one(); |
| | | if (Objects.isNull(project)) { |
| | | throw new RuntimeException("项ç®ä¸åå¨"); |
| | | } |
| | | SysDept dept = deptService.selectDeptById(project.getProjectOwnerUnit()); |
| | | if (Objects.isNull(dept)) { |
| | | throw new RuntimeException("项ç®ä¸ä¸»åä½ä¸åå¨"); |
| | | unitId = project.getProjectOwnerUnit(); |
| | | } else if (ProjectProcessTypeEnum.ENGINEERING.equals(form.getProjectType())) { |
| | | ProjectEngineering projectEngineering = new LambdaQueryChainWrapper<>(projectEngineeringMapper) |
| | | .select(ProjectEngineering::getDepartment) |
| | | .eq(ProjectEngineering::getId, form.getProjectId()) |
| | | .one(); |
| | | if (Objects.isNull(projectEngineering)) { |
| | | throw new RuntimeException("å·¥ç¨ä¸åå¨"); |
| | | } |
| | | String processInsId = this.startPro(projectId, processDefId, dept.getDeptId()); |
| | | unitId = projectEngineering.getUnit(); |
| | | } |
| | | SysDept dept = deptService.selectDeptById(unitId); |
| | | if (Objects.isNull(dept)) { |
| | | throw new RuntimeException("ä¸ä¸»åä½ä¸åå¨"); |
| | | } |
| | | String processInsId = this.startPro(form.getProjectId(), form.getProcessDefId(), dept.getDeptId()); |
| | | ProjectProcess entity = new ProjectProcess(); |
| | | entity.setProjectId(projectId); |
| | | entity.setProcessDefId(processDefId); |
| | | entity.setProjectId(form.getProjectId()); |
| | | entity.setProcessDefId(form.getProcessDefId()); |
| | | entity.setProcessInsId(processInsId); |
| | | entity.setDataLaunch(project.getProjectOwnerUnit()); |
| | | entity.setDataLaunch(unitId); |
| | | entity.setProjectType(form.getProjectType()); |
| | | baseMapper.insert(entity); |
| | | |
| | | return Result.ok("æµç¨å¯å¨æå"); |
| | |
| | | * @param processDefId |
| | | * @return |
| | | */ |
| | | private String startPro(Long projectId, String processDefId, Long createBy) { |
| | | private String startPro(String projectId, String processDefId, Long createBy) { |
| | | |
| | | |
| | | ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(processDefId) |
| | |
| | | /** |
| | | * è·åæµç¨è¯¦æ
|
| | | * |
| | | * @param projectId |
| | | * @param form |
| | | * @return |
| | | */ |
| | | @Override |
| | | public Result detail(Long projectId, String processDefId) { |
| | | // 项ç®ä¿¡æ¯ |
| | | ProjectInfo projectInfo = new LambdaQueryChainWrapper<>(projectInfoMapper) |
| | | .select(ProjectInfo::getId, ProjectInfo::getProjectName, ProjectInfo::getProjectCode) |
| | | .eq(ProjectInfo::getId, projectId) |
| | | .one(); |
| | | public Result detail(ProjectProcessForm form) { |
| | | |
| | | String projectName = ""; |
| | | String projectCode = ""; |
| | | if (ProjectProcessTypeEnum.PROJECT.equals(form.getProjectType())) { |
| | | ProjectInfo projectInfo = projectInfoMapper.selectById(form.getProjectId()); |
| | | if (Objects.isNull(projectInfo)) { |
| | | return Result.error("该项ç®ä¸åå¨"); |
| | | throw new RuntimeException("项ç®ä¸åå¨"); |
| | | } |
| | | projectName = projectInfo.getProjectName(); |
| | | projectCode = projectInfo.getProjectCode(); |
| | | } else if (ProjectProcessTypeEnum.ENGINEERING.equals(form.getProjectType())) { |
| | | ProjectEngineering projectEngineering = projectEngineeringMapper.selectById(form.getProjectId()); |
| | | if (Objects.isNull(projectEngineering)) { |
| | | throw new RuntimeException("å·¥ç¨ä¸åå¨"); |
| | | } |
| | | projectName = projectEngineering.getProjectName(); |
| | | } |
| | | |
| | | ProjectProcess projectProcess = new LambdaQueryChainWrapper<>(baseMapper) |
| | | .eq(ProjectProcess::getProjectId, projectId) |
| | | .eq(ProjectProcess::getProcessDefId, processDefId) |
| | | .eq(ProjectProcess::getProjectId, form.getProjectId()) |
| | | .eq(ProjectProcess::getProcessDefId, form.getProcessDefId()) |
| | | .eq(ProjectProcess::getProjectType, form.getProjectType()) |
| | | .one(); |
| | | if (Objects.isNull(projectProcess)) { |
| | | return Result.error("è¯¥é¡¹ç®æªè®¾ç½®æµç¨"); |
| | | return Result.error("æªè®¾ç½®æµç¨"); |
| | | } |
| | | |
| | | ProjectProcessDetailVO detail = new ProjectProcessDetailVO(); |
| | | detail.setProjectId(projectId); |
| | | detail.setProjectName(projectInfo.getProjectName()); |
| | | detail.setProjectCode(projectInfo.getProjectCode()); |
| | | detail.setProjectType(form.getProjectType().getValue()); |
| | | detail.setProjectId(form.getProjectId()); |
| | | |
| | | |
| | | detail.setProjectName(projectName); |
| | | detail.setProjectCode(projectCode); |
| | | |
| | | ProjectProcessDetailVO.TaskStatistics taskStatistics = new ProjectProcessDetailVO.TaskStatistics(); |
| | | // ç¶æç»è®¡ |
| | | taskStatistics.setTotalTaskNum(this.getTotalTaskNum(processDefId)); |
| | | taskStatistics.setTotalTaskNum(this.getTotalTaskNum(form.getProcessDefId())); |
| | | taskStatistics.setTodoTaskNum(this.getTodoTaskNum(projectProcess.getProcessInsId())); |
| | | taskStatistics.setRemainingTaskNum(this.getRemainingTaskNum(processDefId, projectProcess.getProcessInsId(), taskStatistics.getTotalTaskNum())); |
| | | taskStatistics.setRemainingTaskNum(this.getRemainingTaskNum(form.getProcessDefId(), projectProcess.getProcessInsId(), taskStatistics.getTotalTaskNum())); |
| | | taskStatistics.setTimelyFinishedTaskNum(this.getTimelyTaskNum(projectProcess.getProcessInsId())); |
| | | taskStatistics.setOvertimeTaskNum(this.getOvertimeTaskNum(projectProcess.getProcessInsId())); |
| | | taskStatistics.setWillOvertimeTaskNum(this.getWillOvertimeTaskNum(projectProcess.getProcessInsId())); |
| | |
| | | * @param pageNum |
| | | * @param result |
| | | */ |
| | | public void getTodoTaskList(Long projectId, String processInsId, String taskName, int pageSize, int pageNum, Result result) { |
| | | public void getTodoTaskList(String projectId, String processInsId, String taskName, int pageSize, int pageNum, Result result) { |
| | | TaskQuery taskQuery = taskService.createTaskQuery() |
| | | .active() |
| | | .processInstanceId(processInsId) |
| | |
| | | * @param result |
| | | * @return |
| | | */ |
| | | private List<CustomerTaskVO> getAllUserTask(Long projectId, String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) { |
| | | private List<CustomerTaskVO> getAllUserTask(String projectId, String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) { |
| | | int startNum = pageSize * (pageNum - 1); |
| | | int endNum = startNum + pageSize; |
| | | List<UserTask> allUserTaskElement = this.getAllUserTaskElement(processDefinitionId); |
| | |
| | | * @param processDefId æµç¨å®ä¹id |
| | | * @return |
| | | */ |
| | | private List<CustomerTaskVO> getFinishedProcessTaskInfo(List<UserTask> userTasks, Long projectId, String processInsId, String processDefId) { |
| | | private List<CustomerTaskVO> getFinishedProcessTaskInfo(List<UserTask> userTasks, String projectId, String processInsId, String processDefId) { |
| | | HistoricProcessInstance hisProcess = historyService.createHistoricProcessInstanceQuery().processInstanceId(processInsId).singleResult(); |
| | | if (Objects.isNull(hisProcess)) { |
| | | return new ArrayList<>(); |
| | |
| | | * @param taskVO ä»»å¡vo |
| | | * @param projectId 项ç®id |
| | | */ |
| | | private void setRuntimeTaskInfo(Task task, CustomerTaskVO taskVO, Long projectId) { |
| | | private void setRuntimeTaskInfo(Task task, CustomerTaskVO taskVO, String projectId) { |
| | | // å½åæµç¨ä¿¡æ¯ |
| | | taskVO.setTaskId(task.getId()); |
| | | taskVO.setCreateTime(task.getCreateTime()); |
| | |
| | | * @param result |
| | | * @return |
| | | */ |
| | | private List<CustomerTaskVO> getTimelyTask(Long projectId, String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) { |
| | | private List<CustomerTaskVO> getTimelyTask(String projectId, String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) { |
| | | int startNum = pageSize * (pageNum - 1); |
| | | int endNum = startNum + pageSize; |
| | | |
| | |
| | | * @param result |
| | | * @return |
| | | */ |
| | | private List<CustomerTaskVO> getOvertimeTask(Long projectId, String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) { |
| | | private List<CustomerTaskVO> getOvertimeTask(String projectId, String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) { |
| | | int startNum = pageSize * (pageNum - 1); |
| | | int endNum = startNum + pageSize; |
| | | |
| | |
| | | * @param result |
| | | * @return |
| | | */ |
| | | private List<CustomerTaskVO> getWillOvertimeTask(Long projectId, String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) { |
| | | private List<CustomerTaskVO> getWillOvertimeTask(String projectId, String processDefinitionId, String processInsId, String taskName, Integer pageNum, Integer pageSize, Result result) { |
| | | int startNum = pageSize * (pageNum - 1); |
| | | int endNum = startNum + pageSize; |
| | | |
| | |
| | | * @param result |
| | | * @return |
| | | */ |
| | | private List<CustomerTaskVO> getRemainingTask(Long projectId, |
| | | private List<CustomerTaskVO> getRemainingTask(String projectId, |
| | | String processDefinitionId, |
| | | String processInsId, |
| | | String taskName, |
| | |
| | | * @param setType 0 设置责任åä½ 1 设置åçåä½ |
| | | * @param vo |
| | | */ |
| | | private void varYzReview(CustomerTaskVO vo, Long projectId, String processInsId, HandlerTypeEnum type, Integer setType) { |
| | | private void varYzReview(CustomerTaskVO vo, String projectId, String processInsId, HandlerTypeEnum type, Integer setType) { |
| | | ProjectProcess projectProcess = new LambdaQueryChainWrapper<>(projectProcessMapper) |
| | | .eq(ProjectProcess::getProjectId, projectId) |
| | | .eq(ProjectProcess::getProcessInsId, processInsId) |
| | |
| | | * @param projectId |
| | | * @param processInsId |
| | | */ |
| | | private void setCandidateInfo(UserTask userTask, CustomerTaskVO vo, Long projectId, String processInsId) { |
| | | private void setCandidateInfo(UserTask userTask, CustomerTaskVO vo, String projectId, String processInsId) { |
| | | if (StringUtils.isNotBlank(userTask.getAssignee())) { |
| | | SysUser sysUser = sysUserService.selectUserById(Long.parseLong(userTask.getAssignee())); |
| | | if (Objects.nonNull(sysUser)) { |