From a6ca278347bf909f03f3f65f6f9a4b1ff3e23c83 Mon Sep 17 00:00:00 2001
From: LegnaYet <1023868505@qq.com>
Date: Mon, 18 May 2020 02:06:31 +0800
Subject: [PATCH] =?UTF-8?q?=E9=97=A8=E5=BA=97=E5=8F=B7=E7=AE=A1=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/kiisoo/ic/job/count/CountDTOMessageEventProducer.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageEventProducer.java b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageEventProducer.java
index 8a0d8b3..f2959bd 100644
--- a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageEventProducer.java
+++ b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageEventProducer.java
@@ -23,6 +23,7 @@ public class CountDTOMessageEventProducer {
             //给这个区块放入 数据  如果此处不理解，想想RingBuffer的结构图
             ringBuffer.get(seq).setIndex(index);
             ringBuffer.get(seq).setCpUserId(cpUserId);
+            ringBuffer.get(seq).setPrivilageCpUserDOMapper(privilageCpUserDOMapper);
         } finally {
             // 发布Event，激活观察者去消费， 将sequence传递给该消费者
             // 注意，最后的 ringBuffer.publish() 方法必须包含在 finally 中以确保必须得到调用；如果某个请求的 sequence 未被提交，将会堵塞后续的发布操作或者其它的 producer。