From c6fcb29206770bc699903cb3f8122f9d0a3e46ee Mon Sep 17 00:00:00 2001
From: yechenhao <yechenhao>
Date: Sat, 16 May 2020 02:50:04 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=A7=E5=B1=8F=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/kiisoo/ic/job/CustomerSyncJob.java     | 11 +++++++++++
 src/main/java/com/kiisoo/ic/job/DTOMessage.java     |  6 ++++++
 .../java/com/kiisoo/ic/job/DTOMessageHandler.java   | 13 +++----------
 3 files changed, 20 insertions(+), 10 deletions(-)

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 {