From 89c3ebb0ef855fba2788f9eb81262a3228ec3b6c Mon Sep 17 00:00:00 2001
From: yechenhao <yechenhao>
Date: Sun, 17 May 2020 23:27:45 +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

---
 .../service/StorePromotionDataService.java      | 17 +++++------------
 1 file changed, 5 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/kiisoo/ic/store/service/StorePromotionDataService.java b/src/main/java/com/kiisoo/ic/store/service/StorePromotionDataService.java
index 05a805e..ec27b18 100644
--- a/src/main/java/com/kiisoo/ic/store/service/StorePromotionDataService.java
+++ b/src/main/java/com/kiisoo/ic/store/service/StorePromotionDataService.java
@@ -351,25 +351,18 @@ public class StorePromotionDataService {
         //获取token
         String token = mainService.getAccessToken();
         WxCpExternalContactService externalContactService = mainService.getExternalContactService();
-        List<String> cpUserIds = externalContactService.listFollowUser();
-        cpUserIds.forEach(cpUserId -> {
+        List<PrivilageCpUserDO> privilageCpUserDOS = privilageCpUserDOMapper.selectList(null);
+        privilageCpUserDOS.forEach(privilageCpUserDO -> {
             // 返回
             try {
-                Long storeId = privilageCpUserStoreDOMapper.selectOneByCpUserId(cpUserId);
+                Long storeId = privilageCpUserStoreDOMapper.selectOneByCpUserId(privilageCpUserDO.getCpUserId());
                 Long regionId = null;
                 if (storeId == null){
-                    QueryWrapper<PrivilageCpUserDO> cpUserQw = new QueryWrapper<>();
-                    cpUserQw.eq("cpUserId",cpUserId).last("limit 1");
-                    PrivilageCpUserDO privilageCpUserDO = privilageCpUserDOMapper.selectOne(cpUserQw);
-                    if (privilageCpUserDO != null){
-                        regionId = privilageCpUserDO.getId();
-                    }else {
-                        return;
-                    }
+                    regionId = privilageCpUserDO.getId();
                 }
                 WxCusInfoReqDO wxCusInfoReqDO = new WxCusInfoReqDO();
                 wxCusInfoReqDO.setAccess_token(token);
-                wxCusInfoReqDO.setUserid(cpUserId);
+                wxCusInfoReqDO.setUserid(privilageCpUserDO.getCpUserId());
                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
                 //todo 分开写便于同步历史数据 最大跨度30天 最久当天往前180天 上线时改为System.currentTimeMillis()
                 wxCusInfoReqDO.setStart_time(startDate.getTime() / 1000);