diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/esRevision/service/impl/EsRevisionServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/esRevision/service/impl/EsRevisionServiceImpl.java
index 1cd91afa..29a8eaf8 100644
--- a/laws-modules/src/main/java/com/jero/modules/activiti/process/esRevision/service/impl/EsRevisionServiceImpl.java
+++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/esRevision/service/impl/EsRevisionServiceImpl.java
@@ -247,6 +247,8 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
                 }
                 break;
             case CONTACT_USER_COLLECT:
+                String contactUserLeader = (String) runtimeService.getVariable(executionId, executionId + "-ContactUserLeader");
+                data.setContactUserLeader(contactUserLeader);
             case CONTACT_USER_LEADER_APPROVAL:
                 advicesWrapper.eq(EsRevisionAdvice::getExecutionId, executionId);
                 adviceList = adviceService.list(advicesWrapper);
@@ -271,6 +273,7 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
             throw new JeroBootException("taskId为空或任务不存在");
         }
         String userId = actFlowCommonService.getOriginTaskAssignee(taskId);
+        String curUserId = UserUtils.getUserId();
         Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
         // 获取执行id
         String executionId = task.getExecutionId();
@@ -405,7 +408,9 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
             case CONTACT_USER_COLLECT:
                 data = revisionData.getData();
                 // 先删后增
-                runtimeService.setVariable(executionId, "contactUserLeader", data.getContactUserLeader());
+                String contactUserLeader = data.getContactUserLeader();
+                runtimeService.setVariable(executionId, "contactUserLeader", contactUserLeader);
+                runtimeService.setVariable(executionId, executionId + "-ContactUserLeader", contactUserLeader);
                 userMap.put("contactUserLeader", data.getContactUserLeader());
                 advices = data.getAdvices();
                 adviceWrapper.eq(EsRevisionAdvice::getExecutionId, executionId);
@@ -429,6 +434,11 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
                     adviceService.remove(adviceWrapper);
                     advices.forEach(advice -> advice.setProcessInstanceId(processInstanceId));
                     advices.forEach(advice -> advice.setExecutionId(executionId));
+                    advices.forEach(advice -> {
+                        if (StrUtil.isBlank(advice.getCreateUserId())) {
+                            advice.setCreateUserId(curUserId);
+                        }
+                    });
                     adviceService.saveBatch(advices);
                 }
                 break;