fix 修改拉群规则

pcloud-facade-book/src/main/java/com/pcloud/book/book/constant/BookConstant.java

@@ -17,6 +17,11 @@ import java.util.Map;
 public class BookConstant {
 
     /**
+     * 微信小号每天拉人次数缓存前缀
+     */
+    public static final String WXGROUP_ADD_USER_NUM = CacheConstant.BOOK + "WXGROUP_ADD_USER_NUM:";
+
+    /**
      * 图书基础缓存前缀名称
      */
     public static final String BOOK_CACHE = CacheConstant.BOOK + "BOOK:";

pcloud-service-book/src/main/java/com/pcloud/book/keywords/biz/impl/BookGuideBizImpl.java

 package com.pcloud.book.keywords.biz.impl;
 
 import com.pcloud.book.base.exception.BookBizException;
+import com.pcloud.book.book.constant.BookConstant;
 import com.pcloud.book.clock.check.BookClockCheck;
 import com.pcloud.book.clock.dao.BookClockKeywordDao;
 import com.pcloud.book.clock.dto.BookClockKeywordDTO;
@@ -39,9 +40,11 @@ import com.pcloud.book.keywords.vo.UpdateGuideVO;
 import com.pcloud.channelcenter.wechat.dto.AccountSettingDto;
 import com.pcloud.common.core.aspect.ParamLog;
 import com.pcloud.common.utils.ListUtils;
+import com.pcloud.common.utils.cache.redis.JedisClusterUtils;
 import com.pcloud.common.utils.string.StringUtil;
 import com.pcloud.wechatgroup.message.dto.AgreeAddUserDTO;
 import com.sdk.wxgroup.AddToGroupVO;
+import com.sdk.wxgroup.SendGroupInviteVO;
 import com.sdk.wxgroup.SendMessageTypeEnum;
 import com.sdk.wxgroup.SendTextMessageVO;
 import com.sdk.wxgroup.WxGroupSDK;
@@ -124,10 +127,23 @@ public class BookGuideBizImpl implements BookGuideBiz {
         SendWeixinRequestTools.sendKeywordsInfo(keywords, agreeAddUserDTO.getRobotWxId(), agreeAddUserDTO.getUserWxId(), agreeAddUserDTO.getIp());
         // 拉群
         final String wxGroupId = bookGroupClassifyBiz.getWxGroupIdByClassifyIdAndWechatId(dto.getClassifyId(), dto.getWechatUserId());
+        final Integer peopleCounts = WxGroupSDK.getPeopleCounts(wxGroupId, agreeAddUserDTO.getRobotWxId(), agreeAddUserDTO.getIp());
+        // 邀请好友进群有次数限制，目前测试为每天只能拉30-40人就操作频繁，所以在此加判断，超过30人或者群人数超过30人就发送邀请链接
+        final String num = JedisClusterUtils.get(BookConstant.WXGROUP_ADD_USER_NUM + agreeAddUserDTO.getRobotWxId());
+        log.info("[同意加好友发送欢迎语] 拉群 agreeAddUserDTO:{}, wxGroupId:{}, peopleCounts:{}, num:{}", agreeAddUserDTO, wxGroupId, peopleCounts, num);
         if (StringUtil.isBlank(wxGroupId)) {
             log.info("[同意加好友发送欢迎语] 拉群 没有找到群 bookGroupClassifyBiz.getGroupQrcode4ClassifyWechat JoinGroupCipherDTO :{}", dto);
             return;
         }
+        if (!StringUtil.isBlank(num) && Integer.parseInt(num) <= 30 && peopleCounts <= 30) {
+            SendGroupInviteVO sendGroupInviteVO = new SendGroupInviteVO();
+            sendGroupInviteVO.setAltId(agreeAddUserDTO.getRobotWxId());
+            sendGroupInviteVO.setWxId(agreeAddUserDTO.getUserWxId());
+            sendGroupInviteVO.setWxGroupId(wxGroupId);
+            WxGroupSDK.sendGroupInvite(sendGroupInviteVO);
+            log.info("[同意加好友发送欢迎语] 发送进群链接 sendGroupInviteVO：{}", sendGroupInviteVO);
+            return;
+        }
         AddToGroupVO vo1 = new AddToGroupVO();
         vo1.setWxGroupId(wxGroupId);
         vo1.setWxId(agreeAddUserDTO.getUserWxId());
@@ -135,6 +151,12 @@ public class BookGuideBizImpl implements BookGuideBiz {
         vo1.setIp(agreeAddUserDTO.getIp());
         log.info("[同意加好友发送欢迎语 拉群] AddToGroupVO ：{}", vo1);
         WxGroupSDK.addToGroup(vo1);
+        // 拉一次+1
+        if (StringUtil.isBlank(num)) {
+            JedisClusterUtils.getSet(BookConstant.WXGROUP_ADD_USER_NUM + agreeAddUserDTO.getRobotWxId(), "1", 3600 * 24);
+        } else {
+            JedisClusterUtils.incr(BookConstant.WXGROUP_ADD_USER_NUM + agreeAddUserDTO.getRobotWxId());
+        }
     }
 
     @Override