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 9a8c8199..d445ac36 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
@@ -419,13 +419,12 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
                 break;
             case CONTACT_USER_DISTRIBUTE:
                 data = revisionData.getData();
-                flowUser = revisionData.getFlowUser();
-                String adviceUsers = (String) flowUser.get("adviceUserList");
-                List<String> adviceUserList = Arrays.asList(adviceUsers.split(","));
+                String workGroup = data.getWorkGroup();
+                List<String> adviceUserList = Arrays.asList(workGroup.split(","));
                 runtimeService.setVariable(executionId, "adviceUserList", adviceUserList);
                 runtimeService.setVariable(executionId, executionId + "-adviceDeadline", data.getAdviceDeadline());
                 runtimeService.setVariable(executionId, contactUser + "-ExecutionId", executionId);
-                userMap.put("adviceUserList", adviceUsers);
+                userMap.put("adviceUserList", workGroup);
                 processNodeLinkService.incrementSaveNodeUserLink(processDefinitionId, processInstanceId, userMap);
                 // 设置截止时间
                 saveOrUpdate(data);