diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataOrgChangeEventListener.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataOrgChangeEventListener.java
index 7c0989aa64..928489f8b0 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataOrgChangeEventListener.java
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataOrgChangeEventListener.java
@@ -83,6 +83,7 @@ public class OpenDataOrgChangeEventListener implements MessageListenerConcurrent
             dto.setType(obj.getType());
             List<String> orgIdList = new ArrayList<>();
             orgIdList.add(obj.getOrgId());
+            dto.setOrgIdList(orgIdList);
             if ("agency".equals(obj.getOrgType())) {
                 SpringContextUtils.getBean(ExDeptService.class).getAgencyBaseInfo(dto);
             } else {
diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataStaffChangeEventListener.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataStaffChangeEventListener.java
index 96f0301bb7..ad7bd79b62 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataStaffChangeEventListener.java
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataStaffChangeEventListener.java
@@ -85,6 +85,7 @@ public class OpenDataStaffChangeEventListener implements MessageListenerConcurre
             dto.setType(obj.getType());
             List<String> staffIdList = new ArrayList<>();
             staffIdList.add(obj.getOrgId());
+            dto.setStaffIdList(staffIdList);
             SpringContextUtils.getBean(ExUserService.class).getStaffBaseInfo(dto);
         } catch (RenException e) {
             // 如果是我们手动抛出的异常，说明在业务可控范围内。目前不需要MQ重试