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;