diff --git a/src/main/java/com/kiisoo/ic/job/DTOMessageGroup1Consumer.java b/src/main/java/com/kiisoo/ic/job/DTOMessageGroup1Consumer.java
index c2d2d07..1f0f8ff 100644
--- a/src/main/java/com/kiisoo/ic/job/DTOMessageGroup1Consumer.java
+++ b/src/main/java/com/kiisoo/ic/job/DTOMessageGroup1Consumer.java
@@ -38,7 +38,7 @@ public class DTOMessageGroup1Consumer implements WorkHandler<DTOMessage> {
         CustomerService customerService = dtoMessage.getCustomerService();
         PoiStoreStaffDOMapper poiStoreStaffDOMapper = dtoMessage.getPoiStoreStaffDOMapper();
         QWMailListManageService qwMailListManageService = dtoMessage.getQwMailListManageService();
-        PrivilageCpUserStoreDO cpUserStoreDO = dtoMessage.getPrivilageCpUserStoreDO();
+        Long storeId = dtoMessage.getStoreId();
         List<WxCpUserExternalContactInfo> customers = null;
         try {
             customers = qwMailListManageService.getCustomer(cpUserId);
@@ -70,7 +70,7 @@ public class DTOMessageGroup1Consumer implements WorkHandler<DTOMessage> {
                                 String groupName = tags[j].getGroupName();
                                 if ("导购".equals(groupName)) {
                                     String tagName = tags[j].getTagName();
-                                    String staffCode = poiStoreStaffDOMapper.selectStaffCodeByTagNew(cpUserStoreDO.getStoreId(), tagName);
+                                    String staffCode = poiStoreStaffDOMapper.selectStaffCodeByTagNew(storeId, tagName);
                                     if (StringUtils.isNotBlank(staffCode)) {
                                         turnBackDTO.setEaCode(staffCode);
                                     } else {