diff --git a/src/main/java/com/kiisoo/ic/job/CustomerSyncJob.java b/src/main/java/com/kiisoo/ic/job/CustomerSyncJob.java
index b91c78d..ac6dc48 100644
--- a/src/main/java/com/kiisoo/ic/job/CustomerSyncJob.java
+++ b/src/main/java/com/kiisoo/ic/job/CustomerSyncJob.java
@@ -1,6 +1,8 @@
 package com.kiisoo.ic.job;
 
+import com.kiisoo.ic.customer.CustomerService;
 import com.kiisoo.ic.store.entity.PrivilageCpUserStoreDO;
+import com.kiisoo.ic.store.mapper.PoiStoreStaffDOMapper;
 import com.kiisoo.ic.store.mapper.PrivilageCpUserStoreDOMapper;
 import com.kiisoo.ic.wx.service.QWMailListManageService;
 import com.lmax.disruptor.*;
@@ -23,6 +25,12 @@ public class CustomerSyncJob {
     @Autowired
     private QWMailListManageService qwMailListManageService;
 
+    @Autowired
+    private PoiStoreStaffDOMapper poiStoreStaffDOMapper;
+
+    @Autowired
+    private CustomerService customerService;
+
     public void syncCustomer() throws ExecutionException, InterruptedException {
         long beginTime=System.currentTimeMillis();
 
@@ -69,6 +77,9 @@ public class CustomerSyncJob {
                     //给这个区块放入 数据  如果此处不理解，想想RingBuffer的结构图
                     ringBuffer.get(seq).setCpUserId(cpUserId);
                     ringBuffer.get(seq).setPrivilageCpUserStoreDO(privilageCpUserStoreDO);
+                    ringBuffer.get(seq).setQwMailListManageService(qwMailListManageService);
+                    ringBuffer.get(seq).setCustomerService(customerService);
+                    ringBuffer.get(seq).setPoiStoreStaffDOMapper(poiStoreStaffDOMapper);
 //                    ringBuffer.get(seq).setCustomers(customers);
                     ringBuffer.publish(seq);//发布这个区块的数据使handler(consumer)可见
 
diff --git a/src/main/java/com/kiisoo/ic/job/DTOMessage.java b/src/main/java/com/kiisoo/ic/job/DTOMessage.java
index 09d1b31..c516db3 100644
--- a/src/main/java/com/kiisoo/ic/job/DTOMessage.java
+++ b/src/main/java/com/kiisoo/ic/job/DTOMessage.java
@@ -1,6 +1,9 @@
 package com.kiisoo.ic.job;
 
+import com.kiisoo.ic.customer.CustomerService;
 import com.kiisoo.ic.store.entity.PrivilageCpUserStoreDO;
+import com.kiisoo.ic.store.mapper.PoiStoreStaffDOMapper;
+import com.kiisoo.ic.wx.service.QWMailListManageService;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
@@ -18,6 +21,9 @@ public class DTOMessage {
     private String id;
     private String cpUserId;
     private PrivilageCpUserStoreDO privilageCpUserStoreDO;
+    private QWMailListManageService qwMailListManageService;
+    private CustomerService customerService;
+    private PoiStoreStaffDOMapper poiStoreStaffDOMapper;
     private List<WxCpUserExternalContactInfo> customers;
 
 }
diff --git a/src/main/java/com/kiisoo/ic/job/DTOMessageHandler.java b/src/main/java/com/kiisoo/ic/job/DTOMessageHandler.java
index 4859e4e..4f06de3 100644
--- a/src/main/java/com/kiisoo/ic/job/DTOMessageHandler.java
+++ b/src/main/java/com/kiisoo/ic/job/DTOMessageHandler.java
@@ -20,19 +20,9 @@ import java.util.List;
 import java.util.UUID;
 
 @Slf4j
-@Service
 public class DTOMessageHandler implements EventHandler<DTOMessage> {
 
 
-    @Autowired
-    private PoiStoreStaffDOMapper poiStoreStaffDOMapper;
-
-    @Autowired
-    private CustomerService customerService;
-
-    @Autowired
-    private QWMailListManageService qwMailListManageService;
-
     /**
      * 处理事件， 如入库操作
      * @param dtoMessage
@@ -45,6 +35,9 @@ public class DTOMessageHandler implements EventHandler<DTOMessage> {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         dtoMessage.setId(UUID.randomUUID().toString());
         String cpUserId = dtoMessage.getCpUserId();
+        CustomerService customerService = dtoMessage.getCustomerService();
+        PoiStoreStaffDOMapper poiStoreStaffDOMapper = dtoMessage.getPoiStoreStaffDOMapper();
+        QWMailListManageService qwMailListManageService = dtoMessage.getQwMailListManageService();
         PrivilageCpUserStoreDO cpUserStoreDO = dtoMessage.getPrivilageCpUserStoreDO();
         List<WxCpUserExternalContactInfo> customers = null;
         try {