diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/esAnnualInit/service/impl/ProcessEsAnnualInitServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/esAnnualInit/service/impl/ProcessEsAnnualInitServiceImpl.java
index 80330243..10653464 100644
--- a/laws-modules/src/main/java/com/jero/modules/activiti/process/esAnnualInit/service/impl/ProcessEsAnnualInitServiceImpl.java
+++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/esAnnualInit/service/impl/ProcessEsAnnualInitServiceImpl.java
@@ -401,13 +401,18 @@ public class ProcessEsAnnualInitServiceImpl extends ServiceImpl<ProcessEsAnnualI
                 dataList = annualInitData.getDataList();
                 // 如果不驳回
                 if (pass) {
-                    dataList.forEach(d -> d.setRejectFlag(YesOrNoEnum.NO.getValue()));
+                    updateWrapper.eq(ProcessEsAnnualInit::getContactUser, contactUser);
+                    updateWrapper.eq(ProcessEsAnnualInit::getApprovalUser, approvalUser);
+                    updateWrapper.set(ProcessEsAnnualInit::getRejectFlag, YesOrNoEnum.NO.getValue());
+                    updateWrapper.set(ProcessEsAnnualInit::getExecutionId, executionId);
+                    update(updateWrapper);
                 } else {
-                    dataList.forEach(d -> d.setRejectFlag(YesOrNoEnum.YES.getValue()));
+                    updateWrapper.eq(ProcessEsAnnualInit::getContactUser, contactUser);
+                    updateWrapper.eq(ProcessEsAnnualInit::getApprovalUser, approvalUser);
+                    updateWrapper.set(ProcessEsAnnualInit::getRejectFlag, YesOrNoEnum.YES.getValue());
+                    updateWrapper.set(ProcessEsAnnualInit::getExecutionId, executionId);
+                    update(updateWrapper);
                 }
-                // 获取执行id
-                dataList.forEach(data -> data.setExecutionId(executionId));
-                saveOrUpdateBatch(dataList);
                 break;
             case STANDARD_ENGINEER_COLLECT:
                 // 根据流程ID删除所有数据后新增