|
@@ -9,9 +9,7 @@ import cn.cslg.pas.common.utils.LoginUtils;
|
|
|
import cn.cslg.pas.common.utils.StringUtils;
|
|
|
import cn.cslg.pas.common.vo.business.GetHandleResultFileVO;
|
|
|
import cn.cslg.pas.common.vo.business.HandleResultFileVO;
|
|
|
-import cn.cslg.pas.domain.business.AssoHandleResultFile;
|
|
|
-import cn.cslg.pas.domain.business.ProjectTask;
|
|
|
-import cn.cslg.pas.domain.business.TaskHandleResult;
|
|
|
+import cn.cslg.pas.domain.business.*;
|
|
|
import cn.cslg.pas.exception.UnLoginException;
|
|
|
import cn.cslg.pas.exception.XiaoShiException;
|
|
|
import cn.cslg.pas.mapper.TaskHandleResultMapper;
|
|
@@ -27,6 +25,7 @@ import org.springframework.stereotype.Service;
|
|
|
import java.io.IOException;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
+import java.util.Optional;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
@@ -53,6 +52,12 @@ public class TaskHandleResultService extends ServiceImpl<TaskHandleResultMapper,
|
|
|
@Autowired
|
|
|
private FileManagerService fileManagerService;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private ProjectService projectService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private ReportProjectService reportProjectService;
|
|
|
+
|
|
|
/**
|
|
|
* 添加任务处理结果
|
|
|
* @param taskHandleResultDTO
|
|
@@ -90,8 +95,9 @@ public class TaskHandleResultService extends ServiceImpl<TaskHandleResultMapper,
|
|
|
Integer currentTaskId = taskHandleResult.getTaskId();
|
|
|
//根据任务id查询任务类型
|
|
|
ProjectTask currentProjectTask = projectTaskService.getById(currentTaskId);
|
|
|
- //如果当前处理的是审核任务,进入以下流程
|
|
|
- if (currentProjectTask.getType() == 5) {
|
|
|
+ //如果当前处理的是审核任务或者项目开卷审核任务,进入以下流程
|
|
|
+ Integer taskType = currentProjectTask.getType();
|
|
|
+ if (taskType == 5 || taskType == 1) {
|
|
|
//判断下一个审核人
|
|
|
String nextAuditor = taskHandleResult.getNextAuditor();
|
|
|
if (StringUtils.isNotEmpty(nextAuditor)) {
|
|
@@ -105,7 +111,9 @@ public class TaskHandleResultService extends ServiceImpl<TaskHandleResultMapper,
|
|
|
//审核任务
|
|
|
projectTaskDTO.setType(5);
|
|
|
//所属流程
|
|
|
- projectTaskDTO.setProcessId(projectTask.getProcessId());
|
|
|
+ if (taskType == 5) {
|
|
|
+ projectTaskDTO.setProcessId(projectTask.getProcessId());
|
|
|
+ }
|
|
|
//审核人
|
|
|
projectTaskDTO.setHandler(taskHandleResult.getNextAuditor());
|
|
|
//是否内部人员
|
|
@@ -147,6 +155,41 @@ public class TaskHandleResultService extends ServiceImpl<TaskHandleResultMapper,
|
|
|
);
|
|
|
projectTaskService.updateBatchById(projectTasks);
|
|
|
}
|
|
|
+ //如果是 项目开卷审核任务 需要将项目的状态设置为完成
|
|
|
+ if (taskType == 1) {
|
|
|
+// ProjectTask projectTask1 = projectTaskService.getById(projectTask.getAssoTaskId());
|
|
|
+// if (projectTask1 != null) {
|
|
|
+// Integer projectId = projectTask1.getProjectId();
|
|
|
+// Project project = projectService.getById(projectId);
|
|
|
+// if (project != null) {
|
|
|
+// Integer projectType = project.getType();
|
|
|
+// if (projectType == 2) {
|
|
|
+// LambdaQueryWrapper<ReportProject> queryWrapper1 = new LambdaQueryWrapper<>();
|
|
|
+// queryWrapper1.eq(ReportProject::getProjectId, projectId);
|
|
|
+// ReportProject reportProject = reportProjectService.getOne(queryWrapper1, false);
|
|
|
+// if (reportProject != null) {
|
|
|
+// reportProject.setStatus(3);
|
|
|
+// reportProject.updateById();
|
|
|
+// }
|
|
|
+// }
|
|
|
+// }
|
|
|
+// }
|
|
|
+
|
|
|
+ Optional<ProjectTask> optionalProjectTask = projectTaskService.getByIdOpt(projectTask.getAssoTaskId());
|
|
|
+ optionalProjectTask.ifPresent(task -> {
|
|
|
+ Integer projectId = task.getProjectId();
|
|
|
+ projectService.getByIdOpt(projectId).ifPresent(project -> {
|
|
|
+ if (project.getType() == 2) {
|
|
|
+ reportProjectService.lambdaUpdate()
|
|
|
+ .set(ReportProject::getStatus, 3)
|
|
|
+ .eq(ReportProject::getProjectId, projectId)
|
|
|
+ .update();
|
|
|
+ }
|
|
|
+ });
|
|
|
+ });
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
} else {
|