From 561ae5f9b26a0c247d3994084a5246595c96de8e Mon Sep 17 00:00:00 2001
From: LegnaYet <1023868505@qq.com>
Date: Thu, 21 May 2020 15:23:46 +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

---
 .../kiisoo/ic/job/behavior/CustomerBehaviorJob.java  | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java b/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java
index dd4eb22..4a78d47 100644
--- a/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java
+++ b/src/main/java/com/kiisoo/ic/job/behavior/CustomerBehaviorJob.java
@@ -1,6 +1,6 @@
 package com.kiisoo.ic.job.behavior;
 
-import com.kiisoo.ic.employee.entity.PrivilageCpUserDO;
+import com.kiisoo.ic.config.WxCpConfiguration;
 import com.kiisoo.ic.employee.mapper.PrivilageCpUserDOMapper;
 import com.kiisoo.ic.generalize.mapper.PoiCustomerContactDataStatMapper;
 import com.kiisoo.ic.store.mapper.PrivilageCpUserStoreDOMapper;
@@ -14,6 +14,8 @@ import com.lmax.disruptor.dsl.Disruptor;
 import com.lmax.disruptor.dsl.ProducerType;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.cp.api.WxCpExternalContactService;
+import me.chanjar.weixin.cp.api.WxCpService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -22,8 +24,8 @@ import java.util.Date;
 import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.stream.Collectors;
 
+import static com.kiisoo.ic.config.WxCpConfiguration.APPLICATIONID;
 import static com.kiisoo.ic.system.constant.SysTaskConstant.TASK_STATUS_FINISHED;
 
 /**
@@ -74,8 +76,10 @@ public class CustomerBehaviorJob {
         BehaviorDTOMessageEventProducer producer = new BehaviorDTOMessageEventProducer(ringBuffer, privilageCpUserStoreDOMapper,poiCustomerContactDataStatMapper,storePromotionDataDOMapper,privilageCpUserDOMapper);
 
 
-        List<PrivilageCpUserDO> privilageCpUserDOS = privilageCpUserDOMapper.selectList(null);
-        List<String> cpUserIds = privilageCpUserDOS.stream().map(privilageCpUserDO -> privilageCpUserDO.getCpUserId()).collect(Collectors.toList());
+        WxCpService wxCpService = WxCpConfiguration.getCpService(APPLICATIONID);
+        WxCpExternalContactService externalContactService = wxCpService.getExternalContactService();
+        //查询企业微信已配置联系我的用户
+        List<String> cpUserIds = externalContactService.listFollowUser();
 
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
         int index =0;