fix(稽查流程): 79726
This commit is contained in:
+5
@@ -304,6 +304,11 @@ public class EsInspectFlowServiceImpl implements IEsInspectFlowService {
|
|||||||
if (task!= null) {
|
if (task!= null) {
|
||||||
// 完成任务
|
// 完成任务
|
||||||
taskService.complete(task.getId(), map);
|
taskService.complete(task.getId(), map);
|
||||||
|
// 再次更新流程审批信息
|
||||||
|
processApprovalRecordService.update(new LambdaUpdateWrapper<ProcessApprovalRecord>()
|
||||||
|
.eq(ProcessApprovalRecord::getUserId, loginUser.getId())
|
||||||
|
.eq(ProcessApprovalRecord::getTaskId, processAll.getTaskId())
|
||||||
|
.set(ProcessApprovalRecord::getCommitFlag, processApprovalRecord.getCommitFlag()));
|
||||||
// 判断是否是最后一个节点
|
// 判断是否是最后一个节点
|
||||||
if (isLastNode(processAll.getProcessInstanceId())){
|
if (isLastNode(processAll.getProcessInstanceId())){
|
||||||
// 企标稽查计划 生成数据 保存企标库
|
// 企标稽查计划 生成数据 保存企标库
|
||||||
|
|||||||
+5
@@ -259,6 +259,11 @@ public class EsInspectDelayApplyFlowServiceImpl implements IEsInspectDelayApplyF
|
|||||||
if (task!= null) {
|
if (task!= null) {
|
||||||
// 完成任务
|
// 完成任务
|
||||||
taskService.complete(task.getId(), map);
|
taskService.complete(task.getId(), map);
|
||||||
|
// 再次更新流程审批信息
|
||||||
|
processApprovalRecordService.update(new LambdaUpdateWrapper<ProcessApprovalRecord>()
|
||||||
|
.eq(ProcessApprovalRecord::getUserId, loginUser.getId())
|
||||||
|
.eq(ProcessApprovalRecord::getTaskId, processAll.getTaskId())
|
||||||
|
.set(ProcessApprovalRecord::getCommitFlag, processApprovalRecord.getCommitFlag()));
|
||||||
// 判断是否是最后一个节点
|
// 判断是否是最后一个节点
|
||||||
if (isLastNode(processAll.getProcessInstanceId())){
|
if (isLastNode(processAll.getProcessInstanceId())){
|
||||||
// 稽查延期申请流程 生成数据 企业标准稽查延期
|
// 稽查延期申请流程 生成数据 企业标准稽查延期
|
||||||
|
|||||||
+7
-2
@@ -347,9 +347,14 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
|
|||||||
Task task = taskService.createTaskQuery().taskId(processAll.getTaskId()).singleResult();
|
Task task = taskService.createTaskQuery().taskId(processAll.getTaskId()).singleResult();
|
||||||
if (task != null) {
|
if (task != null) {
|
||||||
// 稽查联络人汇总节点保存会签信息
|
// 稽查联络人汇总节点保存会签信息
|
||||||
saveCountersign(esInspectPlanFlowVO, map, task);
|
saveCountersign(esInspectPlanFlowVO, map);
|
||||||
// 完成任务
|
// 完成任务
|
||||||
taskService.complete(task.getId(), map);
|
taskService.complete(task.getId(), map);
|
||||||
|
// 再次更新流程审批信息
|
||||||
|
processApprovalRecordService.update(new LambdaUpdateWrapper<ProcessApprovalRecord>()
|
||||||
|
.eq(ProcessApprovalRecord::getUserId, loginUser.getId())
|
||||||
|
.eq(ProcessApprovalRecord::getTaskId, processAll.getTaskId())
|
||||||
|
.set(ProcessApprovalRecord::getCommitFlag, processApprovalRecord.getCommitFlag()));
|
||||||
// 可跳过节点处理
|
// 可跳过节点处理
|
||||||
if (map.containsKey("pass") && (boolean) map.get("pass")){
|
if (map.containsKey("pass") && (boolean) map.get("pass")){
|
||||||
// 更新流程实例节点关联用户表
|
// 更新流程实例节点关联用户表
|
||||||
@@ -392,7 +397,7 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void saveCountersign(EsInspectPlanFlowVO esInspectPlanFlowVO, Map<String, Object> map, Task task) {
|
private static void saveCountersign(EsInspectPlanFlowVO esInspectPlanFlowVO, Map<String, Object> map) {
|
||||||
if (map.containsKey("pass") && (boolean) map.get("pass")){
|
if (map.containsKey("pass") && (boolean) map.get("pass")){
|
||||||
if (StringUtils.isNotBlank(esInspectPlanFlowVO.getCountersign())){
|
if (StringUtils.isNotBlank(esInspectPlanFlowVO.getCountersign())){
|
||||||
map.put(COUNTERSIGN, esInspectPlanFlowVO.getCountersign());
|
map.put(COUNTERSIGN, esInspectPlanFlowVO.getCountersign());
|
||||||
|
|||||||
+5
@@ -262,6 +262,11 @@ public class EsInspectRectifyFlowServiceImpl implements IEsInspectRectifyFlowSer
|
|||||||
if (task!= null) {
|
if (task!= null) {
|
||||||
// 完成任务
|
// 完成任务
|
||||||
taskService.complete(task.getId(), map);
|
taskService.complete(task.getId(), map);
|
||||||
|
// 再次更新流程审批信息
|
||||||
|
processApprovalRecordService.update(new LambdaUpdateWrapper<ProcessApprovalRecord>()
|
||||||
|
.eq(ProcessApprovalRecord::getUserId, loginUser.getId())
|
||||||
|
.eq(ProcessApprovalRecord::getTaskId, processAll.getTaskId())
|
||||||
|
.set(ProcessApprovalRecord::getCommitFlag, processApprovalRecord.getCommitFlag()));
|
||||||
// 判断是否是最后一个节点
|
// 判断是否是最后一个节点
|
||||||
if (isLastNode(processAll.getProcessInstanceId())){
|
if (isLastNode(processAll.getProcessInstanceId())){
|
||||||
ProcessEsInspectRectifyVO processEsInspectReportVO = processEsInspectRectifyService.queryByProjectId(processAll.getProjectId());
|
ProcessEsInspectRectifyVO processEsInspectReportVO = processEsInspectRectifyService.queryByProjectId(processAll.getProjectId());
|
||||||
|
|||||||
+5
@@ -263,6 +263,11 @@ public class EsPermissionApplyFlowServiceImpl implements EsPermissionApplyFlowSe
|
|||||||
if (task!= null) {
|
if (task!= null) {
|
||||||
// 完成任务
|
// 完成任务
|
||||||
taskService.complete(task.getId(), map);
|
taskService.complete(task.getId(), map);
|
||||||
|
// 再次更新流程审批信息
|
||||||
|
processApprovalRecordService.update(new LambdaUpdateWrapper<ProcessApprovalRecord>()
|
||||||
|
.eq(ProcessApprovalRecord::getUserId, loginUser.getId())
|
||||||
|
.eq(ProcessApprovalRecord::getTaskId, processAll.getTaskId())
|
||||||
|
.set(ProcessApprovalRecord::getCommitFlag, processApprovalRecord.getCommitFlag()));
|
||||||
// 判断是否是最后一个节点
|
// 判断是否是最后一个节点
|
||||||
if (isLastNode(processAll.getProcessInstanceId())
|
if (isLastNode(processAll.getProcessInstanceId())
|
||||||
&& map.containsKey("pass") && (boolean) map.get("pass")){
|
&& map.containsKey("pass") && (boolean) map.get("pass")){
|
||||||
|
|||||||
+5
-1
@@ -284,7 +284,11 @@ public class MeetingManageFlowServiceImpl implements IMeetingManageFlowService {
|
|||||||
if (task!= null) {
|
if (task!= null) {
|
||||||
// 完成任务
|
// 完成任务
|
||||||
taskService.complete(task.getId(), map);
|
taskService.complete(task.getId(), map);
|
||||||
|
// 再次更新流程审批信息
|
||||||
|
processApprovalRecordService.update(new LambdaUpdateWrapper<ProcessApprovalRecord>()
|
||||||
|
.eq(ProcessApprovalRecord::getUserId, loginUser.getId())
|
||||||
|
.eq(ProcessApprovalRecord::getTaskId, processAll.getTaskId())
|
||||||
|
.set(ProcessApprovalRecord::getCommitFlag, processApprovalRecord.getCommitFlag()));
|
||||||
// 查询业务表数据
|
// 查询业务表数据
|
||||||
ProcessMeetingManage processMeetingManage = processMeetingManageService.getOne(
|
ProcessMeetingManage processMeetingManage = processMeetingManageService.getOne(
|
||||||
new LambdaQueryWrapper<ProcessMeetingManage>()
|
new LambdaQueryWrapper<ProcessMeetingManage>()
|
||||||
|
|||||||
Reference in New Issue
Block a user