Browse Source

fix:预警结束失败

master
buaixuexideshitongxue 3 weeks ago
parent
commit
bd6e30dc88
  1. 6
      src/main/java/com/biutag/supervision/pojo/request/warning/WarningEndRequest.java
  2. 7
      src/main/java/com/biutag/supervision/service/Report/ReportFlowService.java

6
src/main/java/com/biutag/supervision/pojo/request/warning/WarningEndRequest.java

@ -36,8 +36,8 @@ public class WarningEndRequest implements ParamChecked {
throw new IllegalArgumentException("项目id不能为空"); throw new IllegalArgumentException("项目id不能为空");
} }
if (StrUtil.isBlank(flowId)){ // if (StrUtil.isBlank(flowId)){
throw new IllegalArgumentException("flowid不能为空"); // throw new IllegalArgumentException("flowid不能为空");
} // }
} }
} }

7
src/main/java/com/biutag/supervision/service/Report/ReportFlowService.java

@ -490,6 +490,7 @@ public class ReportFlowService extends ServiceImpl<ReportFlowMapper,ReportFlow>
UserAuth currentUser = UserContextHolder.getCurrentUser(); UserAuth currentUser = UserContextHolder.getCurrentUser();
if (StrUtil.isNotBlank(queryParam.getFlowId())){
LambdaUpdateWrapper<ReportFlow> reportFlowLambdaQueryWrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<ReportFlow> reportFlowLambdaQueryWrapper = new LambdaUpdateWrapper<>();
reportFlowLambdaQueryWrapper.eq(ReportFlow::getId,queryParam.getFlowId()); reportFlowLambdaQueryWrapper.eq(ReportFlow::getId,queryParam.getFlowId());
reportFlowLambdaQueryWrapper.set(ReportFlow::getApproverState, "end"); reportFlowLambdaQueryWrapper.set(ReportFlow::getApproverState, "end");
@ -497,6 +498,10 @@ public class ReportFlowService extends ServiceImpl<ReportFlowMapper,ReportFlow>
reportFlowLambdaQueryWrapper.set(ReportFlow::getApproverUnit, currentUser.getDepartName()); reportFlowLambdaQueryWrapper.set(ReportFlow::getApproverUnit, currentUser.getDepartName());
reportFlowLambdaQueryWrapper.set(ReportFlow::getApproverUnitId, currentUser.getDepartId()); reportFlowLambdaQueryWrapper.set(ReportFlow::getApproverUnitId, currentUser.getDepartId());
int update = baseMapper.update(reportFlowLambdaQueryWrapper); int update = baseMapper.update(reportFlowLambdaQueryWrapper);
if (update > 1) {
throw new RuntimeException("多条流程记录被找到,请联系后台人员");
}
}
// 留痕:写一条结束记录 // 留痕:写一条结束记录
ReportFlow endFlow = new ReportFlow(); ReportFlow endFlow = new ReportFlow();
@ -516,6 +521,6 @@ public class ReportFlowService extends ServiceImpl<ReportFlowMapper,ReportFlow>
// //
endFlow.setType("end"); endFlow.setType("end");
boolean ok2 = baseMapper.insert(endFlow) > 0; boolean ok2 = baseMapper.insert(endFlow) > 0;
return Result.success(ok1 && ok2 && update==1); return Result.success(ok1 && ok2);
} }
} }

Loading…
Cancel
Save