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 527f9af1..f4d18996 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
@@ -218,6 +218,7 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
         advicesWrapper.eq(EsRevisionAdvice::getProcessInstanceId, processInstanceId);
         wrapper.eq(ProcessEsRevision::getProcessInstanceId, processInstanceId);
         ProcessEsRevision data = getOne(wrapper);
+        List<EsRevisionAdvice> adviceList = new ArrayList<>();
         List<OtherDraftUserVO> otherDraftUserVOS = data.parseOtherDraftUserVOS();
         List<InspectContentVO> inspectContentVOS = data.parseInspectContents();
         String xmlNodeId = record.getNodeId();
@@ -240,9 +241,12 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
             case CONTACT_USER_COLLECT:
             case CONTACT_USER_LEADER_APPROVAL:
                 advicesWrapper.eq(EsRevisionAdvice::getExecutionId, executionId);
+                adviceList = adviceService.list(advicesWrapper);
+                break;
+            case MAIN_DRAFT_USER_COLLECT_FIRST:
+                adviceList = adviceService.list(advicesWrapper);
                 break;
         }
-        List<EsRevisionAdvice> adviceList = adviceService.list(advicesWrapper);
         data.setAdvices(adviceList);
         data.setOtherDraftUserVOS(otherDraftUserVOS);
         data.setInspectContents(inspectContentVOS);
@@ -414,8 +418,8 @@ public class EsRevisionServiceImpl extends ServiceImpl<EsRevisionMapper, Process
                         .eq(EsRevisionAdvice::getProcessInstanceId, processInstanceId)
                         .eq(EsRevisionAdvice::getExecutionId, executionId));
                 advices = data.getAdvices();
-                advices.forEach(advice -> advice.setProcessInstanceId(processInstanceId));
-                advices.forEach(advice -> advice.setExecutionId(executionId));
+                adviceWrapper.eq(EsRevisionAdvice::getExecutionId, executionId);
+                adviceService.remove(adviceWrapper);
                 adviceService.saveBatch(advices);
                 break;
             case MAIN_DRAFT_USER_COLLECT_SECOND: