test

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatPlanServiceImpl.java

@@ -31,7 +31,6 @@ import com.gic.dubbo.entity.ProviderLocalTag;
 import com.gic.enterprise.api.dto.StoreDTO;
 import com.gic.enterprise.api.service.StoreService;
 import com.gic.haoban.common.utils.DingUtils;
-import com.gic.haoban.manage.api.constants.Manage3Constants;
 import com.gic.haoban.manage.api.dto.WxEnterpriseQwDTO;
 import com.gic.haoban.manage.api.dto.chat.GroupChatPlanDTO;
 import com.gic.haoban.manage.api.dto.chat.GroupChatPlanLogDTO;
@@ -99,6 +98,9 @@ public class GroupChatPlanServiceImpl implements GroupChatPlanService {
 
     private static GicMQClient mqClient = GICMQClientUtil.getClientInstance();
 
+    // 每次成员数
+    private int pageSize = 1;
+
     // 发送队列
     private void putMQForSend(Long id) {
         try {
@@ -197,7 +199,6 @@ public class GroupChatPlanServiceImpl implements GroupChatPlanService {
             madidList.add(json.getString("relation_id"));
         }
         int pageNum = 0;
-        int pageSize = Manage3Constants.CHAT_PLAN_PAGE_SIZE;
         List<TabGroupChatPlanOwnerLog> ownerList = null;
         while (true) {
             ownerList = this.groupChatPlanOwnerLogMapper.listForDoPlan(planId, pageNum * pageSize, pageSize);