Browse Source

部门联审

master
PoffyZhang 1 year ago
parent
commit
afe86cdfb7
2 changed files with 3 additions and 3 deletions
  1. +2
    -2
      pmapi/src/main/java/com/ningdatech/pmapi/projectdeclared/manage/ReviewByDeptJointManage.java
  2. +1
    -1
      pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/ProjectStatusFlowTask.java

+ 2
- 2
pmapi/src/main/java/com/ningdatech/pmapi/projectdeclared/manage/ReviewByDeptJointManage.java View File

@@ -63,8 +63,8 @@ public class ReviewByDeptJointManage {
*/ */
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public Boolean startTheProcess(Project project) { public Boolean startTheProcess(Project project) {
Long userId = LoginUserUtil.getUserId();
VUtils.isTrue(Objects.isNull(userId)).throwMessage("获取登录用户失败!");
//这里是任务发起的 所以用项目发起人
Long userId = project.getSponsor();


VUtils.isTrue(Objects.isNull(project.getId())).throwMessage("提交失败 缺少项目ID!"); VUtils.isTrue(Objects.isNull(project.getId())).throwMessage("提交失败 缺少项目ID!");
Project projectInfo = projectService.getById(project.getId()); Project projectInfo = projectService.getById(project.getId());


+ 1
- 1
pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/ProjectStatusFlowTask.java View File

@@ -82,7 +82,7 @@ public class ProjectStatusFlowTask {
projectStagingService.removeById(projectStaging); projectStagingService.removeById(projectStaging);
} }
}catch (Exception e){ }catch (Exception e){
log.error("项目流转 异常 projectId:【" + projectStaging.getProjectId() + "】 异常内容:" + e);
log.error("项目流转 异常 projectId:【" + projectStaging.getProjectId() + "】 异常内容:" + e.getMessage());
}finally { }finally {
//增加重试的次数 和下次扫描时间 //增加重试的次数 和下次扫描时间
projectStagingService.addRetryTimes(projectStaging); projectStagingService.addRetryTimes(projectStaging);


Loading…
Cancel
Save