feat:[1004024] 微信群被封处理-转企业微信个人号流程

pcloud-facade-book/src/main/java/com/pcloud/book/group/dto/ReplyMsgDTO.java

+package com.pcloud.book.group.dto;
+
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+
+/**
+ * TODO
+ *
+ * @author guiq
+ * @version 1.0
+ * @since 2020/12/9
+ */
+@Getter
+@Setter
+@Builder
+@ToString
+@NoArgsConstructor
+@AllArgsConstructor
+public class ReplyMsgDTO {
+
+    @ApiModelProperty("1 文本 | 2 图片 | 3 链接")
+    private Integer msgType;
+
+    private String keyWord;
+
+    private String content;
+
+    private String imgUrl;
+
+    private String desc;
+
+    private String title;
+
+    private String url;
+
+}

pcloud-facade-book/src/main/java/com/pcloud/book/group/service/WxWorkKeyWordService.java

+package com.pcloud.book.group.service;
+
+import com.pcloud.book.group.dto.ReplyMsgDTO;
+import com.pcloud.common.dto.ResponseDto;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.cloud.netflix.feign.FeignClient;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.List;
+
+@FeignClient(value = "pcloud-service-book", qualifier = "wxWorkKeyWordServiceCloud", path = "book/v1.0/wxWorkKeyWordService")
+@Api(description = "关键词内部接口")
+public interface WxWorkKeyWordService {
+
+    @ApiOperation("根据群分类ID获取关键词回复")
+    @GetMapping("/getKeyWordsByClassify")
+    ResponseEntity<ResponseDto<List<ReplyMsgDTO>>> getKeyWordsByClassify(@RequestParam("classifyId") Long classifyId);
+
+}

pcloud-service-book/src/main/java/com/pcloud/book/group/biz/impl/BookGroupClassifyBizImpl.java

@@ -717,11 +717,13 @@ public class BookGroupClassifyBizImpl implements BookGroupClassifyBiz {
     @Override
     @ParamLog("客户端根据群分类获取二维码")
     public GroupQrcode4ClassifyVO getGroupQrcode4ClassifyWechat(Long classifyId, Long wechatUserId) {
+
         //获取分类基本信息
         ClassifyVO classify = bookGroupClassifyDao.getClassify(classifyId);
         if (classify == null) {
             throw new BookBizException(BookBizException.PARAM_IS_NULL, "社群码不存在，请刷新后重试");
         }
+
         if (new BigDecimal(0).compareTo(classify.getPrice()) < 0) {
             //校验用户是否正版授权
             Boolean isAuth = bookAuthUserBiz.checkIsHaveAuth(classify.getBookId(), classify.getChannelId(), classify.getCreateUser(), wechatUserId, 1);
@@ -734,6 +736,14 @@ public class BookGroupClassifyBizImpl implements BookGroupClassifyBiz {
             }
         }
 
+        // 临时替换为企业微信加好友流程
+        if (JedisClusterUtils.exists("WECHAT_GROUP_BAN_PROCESS")) {
+            GroupQrcode4ClassifyVO vo = new GroupQrcode4ClassifyVO();
+            vo.setQrcodeUrl(JedisClusterUtils.get("WECHAT_GROUP_BAN_PROCESS"));
+            vo.setGroupName(classify.getClassify());
+            return vo;
+        }
+
         //获取用户是否分配过二维码
         GroupQrcode4ClassifyVO groupQrcode4ClassifyVO = bookQrcodeUserDao.getUserQrcode(classifyId, wechatUserId);
         if (groupQrcode4ClassifyVO == null) {

pcloud-service-book/src/main/java/com/pcloud/book/group/service/impl/WxWorkKeyWordServiceImpl.java

+package com.pcloud.book.group.service.impl;
+
+import com.pcloud.book.group.dto.ReplyMsgDTO;
+import com.pcloud.book.group.service.WxWorkKeyWordService;
+import com.pcloud.book.keywords.biz.BookKeywordBiz;
+import com.pcloud.common.dto.ResponseDto;
+import com.pcloud.common.utils.ResponseHandleUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * TODO
+ *
+ * @author guiq
+ * @version 1.0
+ * @since 2020/12/9
+ */
+@RestController
+@RequestMapping("/wxWorkKeyWordService")
+public class WxWorkKeyWordServiceImpl implements WxWorkKeyWordService {
+
+    @Autowired
+    private BookKeywordBiz bookKeywordBiz;
+
+
+    @Override
+    @GetMapping("/getKeyWordsByClassify")
+    public ResponseEntity<ResponseDto<List<ReplyMsgDTO>>> getKeyWordsByClassify(@RequestParam("classifyId") Long classifyId) {
+        return ResponseHandleUtil.toResponse(bookKeywordBiz.getKeyWordsByClassify(classifyId));
+    }
+}

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

 package com.pcloud.book.keywords.biz;
 
 import com.pcloud.book.group.dto.GroupClassifyQrcodeDTO;
+import com.pcloud.book.group.dto.ReplyMsgDTO;
 import com.pcloud.book.keywords.dto.KeywordDTO;
 import com.pcloud.book.keywords.dto.KeywordStatisticsDTO;
 import com.pcloud.book.keywords.dto.ReplyKeywordDTO;
@@ -160,4 +161,6 @@ public interface BookKeywordBiz {
      * 自动唤醒处理
      */
     void robotWakeUp(String userWxId, String ip, Integer code, String robotId);
+
+    List<ReplyMsgDTO> getKeyWordsByClassify(Long classifyId);
 }

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

 package com.pcloud.book.keywords.biz.impl;
 
+import cn.hutool.core.collection.CollUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Lists;
@@ -33,7 +34,9 @@ import com.pcloud.book.group.dao.GroupQrcodeDao;
 import com.pcloud.book.group.dao.WxUserWechatRelevanceDao;
 import com.pcloud.book.group.dto.BookGroupDTO;
 import com.pcloud.book.group.dto.BookWxQrcodeDTO;
+import com.pcloud.book.group.dto.ClassifyDTO;
 import com.pcloud.book.group.dto.GroupClassifyQrcodeDTO;
+import com.pcloud.book.group.dto.ReplyMsgDTO;
 import com.pcloud.book.group.entity.AppTouchRecord;
 import com.pcloud.book.group.entity.BookGroup;
 import com.pcloud.book.group.entity.BookGroupCipherUser;
@@ -90,7 +93,6 @@ import com.pcloud.book.pcloudkeyword.enums.RelevanceTypeEnum;
 import com.pcloud.book.pcloudkeyword.set.PcloudRobotSet;
 import com.pcloud.book.personalstage.biz.PersonalStageBiz;
 import com.pcloud.book.personalstage.biz.PersonalStageJumpBiz;
-import com.pcloud.book.personalstage.enums.JumpTypeEnum;
 import com.pcloud.book.reading.biz.ReadingActivityBiz;
 import com.pcloud.book.skill.dto.AppOrProductReplyDTO;
 import com.pcloud.book.util.common.ThreadPoolUtils;
@@ -593,24 +595,24 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
         }
         //判断是否是平台端配置的小号,如果是，走平台端
         PcloudRobot pcloudRobot = pcloudRobotDao.getByWxId(sendTextDTO.getWxId());
-        if (pcloudRobot!=null){
+        if (pcloudRobot != null) {
             //如果是全局退订关键词
-            if(sendTextDTO.getTextContent().equals(pcloudRobotBiz.getTdKeyword())) {
+            if (sendTextDTO.getTextContent().equals(pcloudRobotBiz.getTdKeyword())) {
                 pcloudRobotBiz.handlePcloudTdReply(sendTextDTO);
                 return;
             }
             // 读者发送书名
             if (!StringUtil.isEmpty(sendTextDTO.getTextContent())
-                    &&sendTextDTO.getTextContent().length()>1
-                    &&sendTextDTO.getTextContent().startsWith("#")){
+                    && sendTextDTO.getTextContent().length() > 1
+                    && sendTextDTO.getTextContent().startsWith("#")) {
                 sendSearchBook(sendTextDTO);
                 return;
             }
-            if (personalStageBiz.isPersonalStageUser(sendTextDTO.getWxId())){
+            if (personalStageBiz.isPersonalStageUser(sendTextDTO.getWxId())) {
                 personalStageBiz.userSendPersonalStage(sendTextDTO.getWechatUserId(), sendTextDTO.getIp(), sendTextDTO.getCode(), sendTextDTO.getWxId(), sendTextDTO.getTextContent());
                 return;
             }
-            sendPcloudKeyword(sendTextDTO,pcloudRobot);
+            sendPcloudKeyword(sendTextDTO, pcloudRobot);
             return;
         }
         if (SendMessageTypeEnum.SELF.getCode().equals(sendTextDTO.getCode())) {
@@ -626,17 +628,17 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
 
     @ParamLog("发送搜索书籍")
     private void sendSearchBook(SendTextDTO sendTextDTO) {
-        String bookName=sendTextDTO.getTextContent().substring(1);
-        BookDto bookDto=bookDao.getAdviserBookByName(bookName);
+        String bookName = sendTextDTO.getTextContent().substring(1);
+        BookDto bookDto = bookDao.getAdviserBookByName(bookName);
         String userWxId = sendTextDTO.getWechatUserId();
         String ip = sendTextDTO.getIp();
         Integer code = sendTextDTO.getCode();
         String robotId = sendTextDTO.getWxId();
-        String uuid= UUID.randomUUID().toString();
-        RobotProcessTypeEnum robotProcessType=RobotProcessTypeEnum.USER_BOOK_SEARCH;
-        int counts=1;
-        int index=0;
-        if (bookDto==null){
+        String uuid = UUID.randomUUID().toString();
+        RobotProcessTypeEnum robotProcessType = RobotProcessTypeEnum.USER_BOOK_SEARCH;
+        int counts = 1;
+        int index = 0;
+        if (bookDto == null) {
             SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
             sendTextMessageVO.setContent("如果这里没有你需要的，小睿深表歉意，小睿还在不断丰富阅读内容，提升阅读体验，一旦发现好东西就会快马加鞭分享给你的！");
             sendTextMessageVO.setAltId(robotId);
@@ -648,36 +650,36 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
             sendTextMessageVO.setIndex(index);
             sendTextMessageVO.setCounts(counts);
             wechatGroupConsr.sendMessage(JSON.toJSONString(sendTextMessageVO));
-            String h5link = wechatGroupLinkPrefix +"/dialog/search?wxId=" + userWxId +"&robotWxId=" + robotId;
+            String h5link = wechatGroupLinkPrefix + "/dialog/search?wxId=" + userWxId + "&robotWxId=" + robotId;
             String linkUrl = UrlUtils.getShortUrl4Own(h5link);
             linkUrl = "★" + linkUrl + "★";
-            sendTextMessageVO.setContent("详情点击进入："+linkUrl);
+            sendTextMessageVO.setContent("详情点击进入：" + linkUrl);
             wechatGroupConsr.sendMessage(JSON.toJSONString(sendTextMessageVO));
-        }else {
+        } else {
             SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
             sendTextMessageVO.setAltId(robotId);
             sendTextMessageVO.setWxGroupId(userWxId);
             sendTextMessageVO.setIp(ip);
             sendTextMessageVO.setCode(code);
-            String h5link = wechatGroupLinkPrefix +"/dialog/resource?bookId="+bookDto.getBookId()+"&adviserId="+bookDto.getAdviserId()+"&channelId="+bookDto.getChannelId()+"&wxId=" + userWxId +"&robotWxId=" + robotId;
+            String h5link = wechatGroupLinkPrefix + "/dialog/resource?bookId=" + bookDto.getBookId() + "&adviserId=" + bookDto.getAdviserId() + "&channelId=" + bookDto.getChannelId() + "&wxId=" + userWxId + "&robotWxId=" + robotId;
             String linkUrl = UrlUtils.getShortUrl4Own(h5link);
             linkUrl = "★" + linkUrl + "★";
-            sendTextMessageVO.setContent("详情点击进入："+linkUrl);
+            sendTextMessageVO.setContent("详情点击进入：" + linkUrl);
             sendTextMessageVO.setMessageGroupId(uuid);
             sendTextMessageVO.setRobotProcessType(robotProcessType);
             sendTextMessageVO.setIndex(index);
             sendTextMessageVO.setCounts(counts);
             wechatGroupConsr.sendMessage(JSON.toJSONString(sendTextMessageVO));
             //插入触发记录
-            SearchRecord searchRecord=new SearchRecord();
+            SearchRecord searchRecord = new SearchRecord();
             searchRecord.setContent(bookName);
             searchRecord.setBookId(bookDto.getBookId());
             searchRecord.setWxId(userWxId);
-            Long agentId=adviserConsr.getAgentIdByAdviser(bookDto.getAdviserId());
+            Long agentId = adviserConsr.getAgentIdByAdviser(bookDto.getAdviserId());
             searchRecord.setAgentId(agentId);
-            if (searchRecord.getContent().length()>50){
-                log.error("长度大于50"+bookName);
-            }else {
+            if (searchRecord.getContent().length() > 50) {
+                log.error("长度大于50" + bookName);
+            } else {
                 searchRecordDao.insert(searchRecord);
                 searchBiz.createSearchRecordDis(searchRecord);
             }
@@ -688,7 +690,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
     private boolean replySelfKeywordTemplate(SendTextDTO sendTextDTO) {
         try {
             String content = sendTextDTO.getTextContent();
-            String redisKey = "replySelfKeywordTemplate:"+sendTextDTO.getWxId()+":"+sendTextDTO.getWechatUserId();
+            String redisKey = "replySelfKeywordTemplate:" + sendTextDTO.getWxId() + ":" + sendTextDTO.getWechatUserId();
             List<SelfRobotKeywordReplyTemplate> replyTemplateList = selfRobotKeywordReplyTemplateDao.getList();
             // 解析出《》的书名
             Pattern pattern = Pattern.compile("《(.*?)》");
@@ -698,19 +700,21 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                 // 解析出版社 出版社:
                 int index = content.indexOf("出版社：");
                 // 再匹配不到，直接返回，并走接下来的逻辑
-                if(index == -1) {
+                if (index == -1) {
                     index = content.indexOf("出版社:");
-                    if(index == -1)
+                    if (index == -1)
                         return true;
                 }
                 String agentName = content.substring(index + 4);
                 // 如果出版社名称为空，则直接return走非关键逻辑
-                if(StringUtil.isEmpty(agentName)){ return true; }
+                if (StringUtil.isEmpty(agentName)) {
+                    return true;
+                }
                 // 从redis取出书名
                 String bookName = JedisClusterUtils.get(redisKey);
                 // 删掉书名
                 JedisClusterUtils.del(redisKey);
-                if(StringUtil.isNotNull(bookName)){
+                if (StringUtil.isNotNull(bookName)) {
                     // 将书的信息录入
                     SelfRobotBookRecord selfRobotBookRecord = new SelfRobotBookRecord();
                     selfRobotBookRecord.setWxUserId(sendTextDTO.getWechatUserId());
@@ -728,18 +732,18 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
             String bookName = matcher.group(1).trim();
             // 根据书名查询到 bookIds
             List<Long> bookIds = bookDao.getBookIdsByBookName(bookName);
-            if(ListUtils.isEmpty(bookIds)){
+            if (ListUtils.isEmpty(bookIds)) {
                 // 将书名写入redis暂存
                 JedisClusterUtils.set(redisKey, bookName);
                 // 如果bookIds没有值，则回复模板状态3
                 // 呃，小睿刚才仔细的找了下，发现书刊的配套资源我这边还没有呢，要不等小睿看完整理好后再给你吧
                 Optional<SelfRobotKeywordReplyTemplate> replyTemplate = replyTemplateList.stream().filter(x -> x.getStatus().equals(3)).findFirst();
-                sendText(sendTextDTO, replyTemplate.get().getReplyContentTemplate().replace("${bookName}",bookName));
+                sendText(sendTextDTO, replyTemplate.get().getReplyContentTemplate().replace("${bookName}", bookName));
                 return false;
             } else {
                 // 根据bookIds查询资源数；
                 Integer totalCount = channelConsr.getMessageCountByBookIds(bookIds);
-                if(totalCount > 0){
+                if (totalCount > 0) {
                     // 信息录入
                     SelfRobotBookRecord selfRobotBookRecord = new SelfRobotBookRecord();
                     selfRobotBookRecord.setWxUserId(sendTextDTO.getWechatUserId());
@@ -748,13 +752,13 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                     selfRobotBookRecord.setStatus(3);
                     selfRobotBookRecordDao.insert(selfRobotBookRecord);
                     // 如果有书有资源，则转换链接，并推送链接给用户
-                    Map<String,String> paramMap = new HashMap<>();
-                    paramMap.put("wxId",sendTextDTO.getWechatUserId());
-                    paramMap.put("robotWxId",sendTextDTO.getWxId());
-                    paramMap.put("bookName",URLEncoder.encode(bookName));
+                    Map<String, String> paramMap = new HashMap<>();
+                    paramMap.put("wxId", sendTextDTO.getWechatUserId());
+                    paramMap.put("robotWxId", sendTextDTO.getWxId());
+                    paramMap.put("bookName", URLEncoder.encode(bookName));
                     Optional<SelfRobotKeywordReplyTemplate> replyTemplate = replyTemplateList.stream().filter(x -> x.getStatus().equals(4)).findFirst();
-                    sendText(sendTextDTO,appendUrlParams(replyTemplate.get().getReplyContentTemplate(),paramMap));
-                } else{
+                    sendText(sendTextDTO, appendUrlParams(replyTemplate.get().getReplyContentTemplate(), paramMap));
+                } else {
                     // 信息录入
                     SelfRobotBookRecord selfRobotBookRecord = new SelfRobotBookRecord();
                     selfRobotBookRecord.setWxUserId(sendTextDTO.getWechatUserId());
@@ -764,7 +768,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                     selfRobotBookRecordDao.insert(selfRobotBookRecord);
                     // 如果有书但没有资源，则回复模板状态1
                     Optional<SelfRobotKeywordReplyTemplate> replyTemplate = replyTemplateList.stream().filter(x -> x.getStatus().equals(1)).findFirst();
-                    sendText(sendTextDTO, replyTemplate.get().getReplyContentTemplate().replace("${bookName}",bookName));
+                    sendText(sendTextDTO, replyTemplate.get().getReplyContentTemplate().replace("${bookName}", bookName));
                 }
                 return false;
             }
@@ -775,36 +779,36 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
     }
 
     @ParamLog("发送平台端小号的")
-    private void sendPcloudKeyword(SendTextDTO sendTextDTO,PcloudRobot pcloudRobot) {
+    private void sendPcloudKeyword(SendTextDTO sendTextDTO, PcloudRobot pcloudRobot) {
         String userWxId = sendTextDTO.getWechatUserId();
         String ip = sendTextDTO.getIp();
         Integer code = sendTextDTO.getCode();
         String robotId = sendTextDTO.getWxId();
-        Long robotClassifyId=pcloudRobot.getRobotType().longValue();
+        Long robotClassifyId = pcloudRobot.getRobotType().longValue();
         //判断人工客服服务状态
         Integer serviceState = wechatGroupConsr.getServiceStateByRobotUser(robotId, userWxId);
-        if (serviceState == 1){
-            log.info("人工客服服务中，userWxId="+userWxId+"+robotId+"+robotId);
+        if (serviceState == 1) {
+            log.info("人工客服服务中，userWxId=" + userWxId + "+robotId+" + robotId);
             return;
         }
         PcloudRobotClassify robotClassify = pcloudRobotClassifyDao.getById(robotClassifyId);
-        if (robotClassify==null||robotClassify.getKeywordClassifyId()==null){
+        if (robotClassify == null || robotClassify.getKeywordClassifyId() == null) {
             return;
         }
-        Long pcloudClassifyId=robotClassify.getKeywordClassifyId();
+        Long pcloudClassifyId = robotClassify.getKeywordClassifyId();
         //查询该小号对应小号分类的关键词分类
         PcloudKeywordClassify pcloudKeywordClassify = pcloudKeywordClassifyDao.getById(pcloudClassifyId);
-        if (null == pcloudKeywordClassify || !pcloudKeywordClassify.getOpen()){//分类未启用
-            log.info("查询小号关键词分类为空或未启用sendTextDTO="+sendTextDTO.toString()+"pcloudRobot="+pcloudRobot.toString());
+        if (null == pcloudKeywordClassify || !pcloudKeywordClassify.getOpen()) {//分类未启用
+            log.info("查询小号关键词分类为空或未启用sendTextDTO=" + sendTextDTO.toString() + "pcloudRobot=" + pcloudRobot.toString());
             return;
         }
-        String content=sendTextDTO.getTextContent();
+        String content = sendTextDTO.getTextContent();
         //根据关键词分类和关键词查询关键词
         //精准
-        PcloudKeyword pcloudKeyword=pcloudKeywordDao.getByClassifyIdAndName(KeywordTypeEnum.ACCURATE.value,pcloudClassifyId,content);
-        if (pcloudKeyword==null){
+        PcloudKeyword pcloudKeyword = pcloudKeywordDao.getByClassifyIdAndName(KeywordTypeEnum.ACCURATE.value, pcloudClassifyId, content);
+        if (pcloudKeyword == null) {
             // 正向模糊
-            pcloudKeyword=pcloudKeywordDao.getByClassifyIdAndName(KeywordTypeEnum.LIKE.value,pcloudClassifyId,content);
+            pcloudKeyword = pcloudKeywordDao.getByClassifyIdAndName(KeywordTypeEnum.LIKE.value, pcloudClassifyId, content);
             // 反向模糊
             if (Objects.isNull(pcloudKeyword)) {
                 List<PcloudKeyword> pcloudKeywords = pcloudKeywordDao.listAllBlurryKeyword(pcloudClassifyId);
@@ -820,31 +824,31 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                 }
             }
         }
-        if (pcloudKeyword!=null){
+        if (pcloudKeyword != null) {
             //走关键词
-            log.info("查询平台端关键词"+pcloudKeyword.toString()+"id="+pcloudKeyword.getId());
+            log.info("查询平台端关键词" + pcloudKeyword.toString() + "id=" + pcloudKeyword.getId());
             //3min不回复同一关键词
-            String key ="BOOK:PCLOUD_KEYWORD:" + userWxId + "-" +robotId + "-" + pcloudKeyword.getId();
+            String key = "BOOK:PCLOUD_KEYWORD:" + userWxId + "-" + robotId + "-" + pcloudKeyword.getId();
             String redisContent = JedisClusterUtils.getJson(key, String.class);
-            if (!StringUtil.isEmpty(redisContent)){
+            if (!StringUtil.isEmpty(redisContent)) {
                 return;
-            }else {
-                JedisClusterUtils.setJson(key, userWxId, 3*60);
+            } else {
+                JedisClusterUtils.setJson(key, userWxId, 3 * 60);
             }
             List<PcloudKeywordReply> replies = pcloudKeywordReplyDao.getByRelevance(RelevanceTypeEnum.KEYWORD.value, pcloudKeyword.getId());
-            if (MethodEnum.RANDOM.value.equals(pcloudKeyword.getMethod())){
-                int a= (int) Math.floor(Math.random()*replies.size());
-                replies=Arrays.asList(replies.get(a));
+            if (MethodEnum.RANDOM.value.equals(pcloudKeyword.getMethod())) {
+                int a = (int) Math.floor(Math.random() * replies.size());
+                replies = Arrays.asList(replies.get(a));
             }
-            String uuid= UUID.randomUUID().toString();
-            RobotProcessTypeEnum robotProcessType=RobotProcessTypeEnum.PCLOUD_KEYWORD;
-            for (PcloudKeywordReply reply:replies){
-                sendPcloudKeywordReply(reply, robotId, userWxId, ip, code,uuid,robotProcessType,replies.indexOf(reply),replies.size());
+            String uuid = UUID.randomUUID().toString();
+            RobotProcessTypeEnum robotProcessType = RobotProcessTypeEnum.PCLOUD_KEYWORD;
+            for (PcloudKeywordReply reply : replies) {
+                sendPcloudKeywordReply(reply, robotId, userWxId, ip, code, uuid, robotProcessType, replies.indexOf(reply), replies.size());
             }
             //有关联技能,发送H5页面链接,取第一个技能
-            if (!StringUtil.isEmpty(pcloudKeyword.getSkillIds())){
+            if (!StringUtil.isEmpty(pcloudKeyword.getSkillIds())) {
                 List<Long> skillIds = pcloudKeyword.getSkillList(pcloudKeyword.getSkillIds());
-                String h5link = wechatGroupLinkPrefix +"/dialog?wxId=" + userWxId +"&robotWxId=" + robotId +"&skillId="+skillIds.get(0);
+                String h5link = wechatGroupLinkPrefix + "/dialog?wxId=" + userWxId + "&robotWxId=" + robotId + "&skillId=" + skillIds.get(0);
                 String linkUrl = UrlUtils.getShortUrl4Own(h5link);
                 linkUrl = "★" + linkUrl + "★";
                 SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
@@ -859,16 +863,16 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                 wechatGroupConsr.sendMessage(JSON.toJSONString(sendTextMessageVO));
             }
 
-        }else {
+        } else {
             //非关键词响应
-            sendPcloudNotKeyWord(userWxId,ip,code,robotId,pcloudClassifyId, MessageTypeEnum.TEXT.value);
+            sendPcloudNotKeyWord(userWxId, ip, code, robotId, pcloudClassifyId, MessageTypeEnum.TEXT.value);
         }
 
     }
 
 
     @ParamLog("平台端个人号关键词回复")
-    public void sendPcloudKeywordReply(PcloudKeywordReply reply, String robotId, String userWxId, String ip, Integer code, String uuid, RobotProcessTypeEnum robotProcessType, int index, int counts){
+    public void sendPcloudKeywordReply(PcloudKeywordReply reply, String robotId, String userWxId, String ip, Integer code, String uuid, RobotProcessTypeEnum robotProcessType, int index, int counts) {
         Integer type = reply.getType();
         if (ReplyTypeEnum.TEXT.value.equals(type)) {
             SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
@@ -897,7 +901,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
             wechatGroupConsr.sendMessage(JSON.toJSONString(sendPicMessageVO));
         }
         if (ReplyTypeEnum.APP.value.equals(type)) {
-            AppOrProductReplyDTO appOrProductReplyDTO=new AppOrProductReplyDTO();
+            AppOrProductReplyDTO appOrProductReplyDTO = new AppOrProductReplyDTO();
             appOrProductReplyDTO.setServeType(reply.getServeType());
             appOrProductReplyDTO.setServeId(reply.getServeId());
             appOrProductReplyDTO.setLinkUrl(reply.getLinkUrl());
@@ -919,11 +923,11 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                 sendFileVO.setFileUrl(resourceDTO.getFileUrl());
                 String fileName = resourceDTO.getResourceName();
                 String fileType = resourceDTO.getFileType();
-                log.info("fileName="+fileName+"+fileType+"+fileType);
-                if (fileName.contains(fileType)){//去掉后缀
-                    fileName = fileName.substring(0, fileName.indexOf(fileType)-1);
+                log.info("fileName=" + fileName + "+fileType+" + fileType);
+                if (fileName.contains(fileType)) {//去掉后缀
+                    fileName = fileName.substring(0, fileName.indexOf(fileType) - 1);
                 }
-                log.info("fileName="+fileName);
+                log.info("fileName=" + fileName);
                 sendFileVO.setFileName(fileName);
             }
             sendFileVO.setIp(ip);
@@ -982,23 +986,23 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
 
     @ParamLog("发送非关键词回复模板")
     private void sendNotKeywords(SendTextDTO sendTextDTO) {
-        NotKeywordTemplate template=notKeywordTemplateDao.getRandomTemplate();
-        if (template==null){
+        NotKeywordTemplate template = notKeywordTemplateDao.getRandomTemplate();
+        if (template == null) {
             return;
         }
         List<NotKeywordItem> list = notKeywordItemDao.getListByTemplateIds(Arrays.asList(template.getId()));
-        if (ListUtils.isEmpty(list)){
+        if (ListUtils.isEmpty(list)) {
             return;
         }
         String userWxId = sendTextDTO.getWechatUserId();
         String ip = sendTextDTO.getIp();
         Integer code = sendTextDTO.getCode();
         String robotId = sendTextDTO.getWxId();
-        String uuid= UUID.randomUUID().toString();
-        RobotProcessTypeEnum robotProcessType=RobotProcessTypeEnum.PCLOUD_NOT_KEYWORD;
-        int index=0;
-        int counts=1;
-        for (NotKeywordItem notKeywordItem:list){
+        String uuid = UUID.randomUUID().toString();
+        RobotProcessTypeEnum robotProcessType = RobotProcessTypeEnum.PCLOUD_NOT_KEYWORD;
+        int index = 0;
+        int counts = 1;
+        for (NotKeywordItem notKeywordItem : list) {
             Integer type = notKeywordItem.getType();
             if (ReplyTypeEnum.TEXT.value.equals(type)) {
                 SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
@@ -1021,11 +1025,11 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                     sendFileVO.setFileUrl(resourceDTO.getFileUrl());
                     String fileName = resourceDTO.getResourceName();
                     String fileType = resourceDTO.getFileType();
-                    log.info("fileName="+fileName+"+fileType+"+fileType);
-                    if (fileName.contains(fileType)){//去掉后缀
-                        fileName = fileName.substring(0, fileName.indexOf(fileType)-1);
+                    log.info("fileName=" + fileName + "+fileType+" + fileType);
+                    if (fileName.contains(fileType)) {//去掉后缀
+                        fileName = fileName.substring(0, fileName.indexOf(fileType) - 1);
                     }
-                    log.info("fileName="+fileName);
+                    log.info("fileName=" + fileName);
                     sendFileVO.setFileName(fileName);
                 }
                 sendFileVO.setIp(ip);
@@ -1047,21 +1051,21 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
         Integer code = sendTextDTO.getCode();
         String robotId = sendTextDTO.getWxId();
         List<SelfRobotKeywordReply> replyList = selfRobotKeywordReplyDao.getListByKeywordId(selfRobotKeyword.getId());
-        if (ListUtils.isEmpty(replyList)){
+        if (ListUtils.isEmpty(replyList)) {
             return;
         }
         RobotProcessTypeEnum robotProcessType = RobotProcessTypeEnum.PCLOUD_KEYWORD;
         String uuid = UUID.randomUUID().toString();
-        for (SelfRobotKeywordReply keywordReply : replyList){
+        for (SelfRobotKeywordReply keywordReply : replyList) {
             Integer type = keywordReply.getType();
             Integer index = replyList.indexOf(keywordReply);
             Integer counts = replyList.size();
             if (ReplyTypeEnum.TEXT.value.equals(type)) {
                 SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
-                Map<String,String> paramMap = new HashMap<>();
-                paramMap.put("wxId",userWxId);
-                paramMap.put("robotWxId",robotId);
-                sendTextMessageVO.setContent(appendUrlParams(keywordReply.getContent(),paramMap));
+                Map<String, String> paramMap = new HashMap<>();
+                paramMap.put("wxId", userWxId);
+                paramMap.put("robotWxId", robotId);
+                sendTextMessageVO.setContent(appendUrlParams(keywordReply.getContent(), paramMap));
                 sendTextMessageVO.setAltId(robotId);
                 sendTextMessageVO.setWxGroupId(userWxId);
                 sendTextMessageVO.setIp(ip);
@@ -1070,7 +1074,8 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                 sendTextMessageVO.setRobotProcessType(robotProcessType);
                 sendTextMessageVO.setIndex(index);
                 sendTextMessageVO.setCounts(counts);
-                wechatGroupConsr.sendMessage(JSON.toJSONString(sendTextMessageVO));;
+                wechatGroupConsr.sendMessage(JSON.toJSONString(sendTextMessageVO));
+                ;
             }
             if (ReplyTypeEnum.IMAGE.value.equals(type)) {
                 SendPicMessageVO sendPicMessageVO = new SendPicMessageVO();
@@ -1175,11 +1180,11 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                     sendFileVO.setFileUrl(resourceDTO.getFileUrl());
                     String fileName = resourceDTO.getResourceName();
                     String fileType = resourceDTO.getFileType();
-                    log.info("fileName="+fileName+"+fileType+"+fileType);
-                    if (fileName.contains(fileType)){//去掉后缀
-                        fileName = fileName.substring(0, fileName.indexOf(fileType)-1);
+                    log.info("fileName=" + fileName + "+fileType+" + fileType);
+                    if (fileName.contains(fileType)) {//去掉后缀
+                        fileName = fileName.substring(0, fileName.indexOf(fileType) - 1);
                     }
-                    log.info("fileName="+fileName);
+                    log.info("fileName=" + fileName);
                     sendFileVO.setFileName(fileName);
                 }
                 sendFileVO.setIp(ip);
@@ -1197,7 +1202,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
     /**
      * 关键词 补充wxid
      */
-    public String appendUrlParams(String content, Map<String,String> map) {
+    public String appendUrlParams(String content, Map<String, String> map) {
         String suffix = appendParams(map);
         Pattern pattern = Pattern.compile("(https?)://[-A-Za-z0-9+&@#/%?=~_|!:,.;]+[-A-Za-z0-9+&@#/%=~_|]");
         Matcher matcher = pattern.matcher(content);
@@ -1220,7 +1225,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
 
             if (group.contains("?")) {
                 content = content.replace(group, UrlUtils.getShortUrl(group + "&" + suffix));
-            }else {
+            } else {
                 content = content.replace(group, UrlUtils.getShortUrl(group + "?" + suffix));
             }
         }
@@ -1229,36 +1234,36 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
 
     @ParamLog("非关键词响应")
     @Override
-    public void sendPcloudNotKeyWord(String userWxId, String ip, Integer code, String robotId,Long pcloudClassifyId, Integer userMessageType) {
+    public void sendPcloudNotKeyWord(String userWxId, String ip, Integer code, String robotId, Long pcloudClassifyId, Integer userMessageType) {
         //判断人工客服服务状态
         Integer serviceState = wechatGroupConsr.getServiceStateByRobotUser(robotId, userWxId);
-        if (serviceState == 1){
-            log.info("人工客服服务中，userWxId="+userWxId+"+robotId+"+robotId);
+        if (serviceState == 1) {
+            log.info("人工客服服务中，userWxId=" + userWxId + "+robotId+" + robotId);
             return;
         }
         //1min不重复回复
-        String key ="BOOK:PCLOUD_NOT_KEYWORD:"+ userWxId +"-" + robotId +"-" + pcloudClassifyId;
+        String key = "BOOK:PCLOUD_NOT_KEYWORD:" + userWxId + "-" + robotId + "-" + pcloudClassifyId;
         String redisContent = JedisClusterUtils.getJson(key, String.class);
-        if (!StringUtil.isEmpty(redisContent)){
+        if (!StringUtil.isEmpty(redisContent)) {
             return;
-        }else {
+        } else {
             JedisClusterUtils.setJson(key, userWxId, 60);
         }
         //走非关键词
-        List<PcloudNotKeyword> notKeywords = pcloudNotKeywordDao.getPcloudNotKeywordListByMessageType(pcloudClassifyId,userMessageType);
-        if (!ListUtils.isEmpty(notKeywords)){
-            for (PcloudNotKeyword pcloudNotKeyword : notKeywords){
+        List<PcloudNotKeyword> notKeywords = pcloudNotKeywordDao.getPcloudNotKeywordListByMessageType(pcloudClassifyId, userMessageType);
+        if (!ListUtils.isEmpty(notKeywords)) {
+            for (PcloudNotKeyword pcloudNotKeyword : notKeywords) {
                 List<PcloudKeywordReply> replies = pcloudKeywordReplyDao.getByRelevance(RelevanceTypeEnum.NOT_KEYWORD.value, pcloudNotKeyword.getId());
-                if (ListUtils.isEmpty(replies)){
+                if (ListUtils.isEmpty(replies)) {
                     continue;
                 }
-                if (MethodEnum.RANDOM.value.equals(pcloudNotKeyword.getMethod())){
+                if (MethodEnum.RANDOM.value.equals(pcloudNotKeyword.getMethod())) {
                     replies = Arrays.asList(replies.get(new Random().nextInt(replies.size())));
                 }
-                String uuid= UUID.randomUUID().toString();
-                RobotProcessTypeEnum robotProcessType=RobotProcessTypeEnum.PCLOUD_NOT_KEYWORD;
-                for (PcloudKeywordReply reply:replies){
-                    sendPcloudKeywordReply(reply, robotId, userWxId, ip, code, uuid,robotProcessType,replies.indexOf(reply),replies.size());
+                String uuid = UUID.randomUUID().toString();
+                RobotProcessTypeEnum robotProcessType = RobotProcessTypeEnum.PCLOUD_NOT_KEYWORD;
+                for (PcloudKeywordReply reply : replies) {
+                    sendPcloudKeywordReply(reply, robotId, userWxId, ip, code, uuid, robotProcessType, replies.indexOf(reply), replies.size());
                 }
             }
         }
@@ -1316,7 +1321,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                 //最后一个
                 if (i + 1 == size) {
                     // 拼接反馈链接
-                    String feedbackUrl = "*common/C" + channelId + "/A0/feedback/suggest?bookGroupId="+bookGroupId+"&wxId=" + sendTextDTO.getWechatUserId();
+                    String feedbackUrl = "*common/C" + channelId + "/A0/feedback/suggest?bookGroupId=" + bookGroupId + "&wxId=" + sendTextDTO.getWechatUserId();
                     String url = SendWeixinRequestTools.splitUrl(accountSettingDto, feedbackUrl);
                     toAddIn = toAddIn + "回复对应数字序号给我，我将助你达成所愿，提高读书效率。\n如有其他问题反馈，请点击链接：\n"
                             + UrlUtils.getShortUrl4Own(url);
@@ -1345,7 +1350,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
         BookGroup bookGroup = bookGroupDao.getByBookGroupCipher(cipher);
         if (bookGroup != null) {
             try {
-                addBookGroupCipherUser(sendTextDTO, cipher,null, bookGroup.getId());
+                addBookGroupCipherUser(sendTextDTO, cipher, null, bookGroup.getId());
                 updateWxUserWechatRelevance(sendTextDTO);
                 dealByBookGroup(sendTextDTO, bookGroup.getId(), false);
             } catch (Exception e) {
@@ -1499,7 +1504,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
         if (StringUtil.isEmpty(weixinGroupId)) {
             throw new BookBizException(BookBizException.ID_NOT_EXIST, "群不存在classifyId=" + classifyId + ",changeNumber=" + changeNumber + ", wxId=" + sendTextDTO.getWxId());
         }
-        sendAndCheckInviteGroup(sendTextDTO,weixinGroupId);
+        sendAndCheckInviteGroup(sendTextDTO, weixinGroupId);
     }
 
     @ParamLog("判断冒泡和发送冒泡和发入群链接")
@@ -1535,7 +1540,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
     }
 
     @ParamLog("发送冒泡消息")
-    private void sendMaoPao(SendTextDTO sendTextDTO, String wxGroupId){
+    private void sendMaoPao(SendTextDTO sendTextDTO, String wxGroupId) {
         SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
         sendTextMessageVO.setContent("我来冒个泡");
         sendTextMessageVO.setAltId(sendTextDTO.getWxId());
@@ -1543,11 +1548,11 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
         sendTextMessageVO.setIp(findIp(wxGroupId));
         // TODO sdk.message
         wechatGroupConsr.sendMessage(JSON.toJSONString(sendTextMessageVO));
-        log.info("发送入群邀请链接之前发冒泡消息："+sendTextMessageVO.toString());
+        log.info("发送入群邀请链接之前发冒泡消息：" + sendTextMessageVO.toString());
     }
 
     @ParamLog("发送进群链接")
-    private void sendInviteToGroup(SendTextDTO sendTextDTO, String wxGroupId){
+    private void sendInviteToGroup(SendTextDTO sendTextDTO, String wxGroupId) {
         SendGroupInviteVO sendGroupInviteVO = new SendGroupInviteVO();
         sendGroupInviteVO.setAltId(sendTextDTO.getWxId());
         sendGroupInviteVO.setWxId(sendTextDTO.getWechatUserId());
@@ -1630,7 +1635,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
         }
         // 去除被发送内容完整包含的关键词
         List<ReplyKeywordDTO> collect = keywordDTOS.stream().filter(x -> content.contains(x.getKeywords())).collect(Collectors.toList());
-        if (ListUtils.isEmpty(collect)){
+        if (ListUtils.isEmpty(collect)) {
             log.info("[关键词消息回复] replyKeywordDTO is null");
             return;
         }
@@ -1672,12 +1677,12 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
         StringBuilder sb = new StringBuilder();
         //目标关键词回复+文案
         combineKeyWord(replyKeyWords, classifyQrcodeInfo, accountSettingDto, sb);
-        if (keywordsAll.size()>replyKeyWords.size()){
+        if (keywordsAll.size() > replyKeyWords.size()) {
             sb.append("--------------------------------\n为避免晚间群消息干扰，10分钟内只响应一次关键词，请直接点击下面的链接，获取本群其他资源服务：\n\n");
             //剩余关键词回复
             for (ReplyKeywordDTO replyKeywordDTO : keywordsAll) {
                 List<ReplyKeywordDTO> collect = replyKeyWords.stream().filter(x -> replyKeywordDTO.getKeywords().equals(x.getKeywords())).collect(Collectors.toList());
-                if (!ListUtils.isEmpty(collect)){
+                if (!ListUtils.isEmpty(collect)) {
                     continue;
                 }
                 List<ReplyKeywordDTO> addKeyWordList = new ArrayList<>();
@@ -1719,9 +1724,9 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
     }
 
     /**
-     *合并关键词回复
+     * 合并关键词回复
      */
-    private StringBuilder combineKeyWord(List<ReplyKeywordDTO> keywordsAll, GroupClassifyQrcodeDTO classifyQrcodeInfo, AccountSettingDto accountSettingDto,StringBuilder sb) {
+    private StringBuilder combineKeyWord(List<ReplyKeywordDTO> keywordsAll, GroupClassifyQrcodeDTO classifyQrcodeInfo, AccountSettingDto accountSettingDto, StringBuilder sb) {
         for (ReplyKeywordDTO keyword : keywordsAll) {
             if (ReplyTypeEnum.LINK.value.equals(keyword.getReplyType()) || ReplyTypeEnum.APP.value.equals(keyword.getReplyType())) {
                 String linkUrl = SendWeixinRequestTools.splitUrlNew(accountSettingDto, keyword.getLinkUrl(), classifyQrcodeInfo.getBookGroupId(), classifyQrcodeInfo.getClassifyId(), classifyQrcodeInfo.getGroupQrcodeId());
@@ -2094,7 +2099,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
         // 个人号消息 用户发送:wechatCreateUser!=wxId,小号发送wechatCreateUser=wxId
         if (SendMessageTypeEnum.SELF.getCode().equals(code) && !userWxId.equals(robotId)) {
             // 从缓存中获取缄默信息
-            if(JedisClusterUtils.hexists(robotId+PCLOUD_GUIDE_SUFFIX,userWxId)){
+            if (JedisClusterUtils.hexists(robotId + PCLOUD_GUIDE_SUFFIX, userWxId)) {
                 PcloudRobot pcloudRobot = pcloudRobotDao.getByWxId(robotId);
                 if (pcloudRobot == null) {
                     return;
@@ -2108,7 +2113,7 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
                 pcloudGuideDelayDto.setSendTime(new Date());
                 // duration
                 pcloudGuideDelayDto.setDuration(duration);
-                JedisClusterUtils.hset(robotId+PCLOUD_GUIDE_SUFFIX,userWxId,JSONObject.toJSONString(pcloudGuideDelayDto));
+                JedisClusterUtils.hset(robotId + PCLOUD_GUIDE_SUFFIX, userWxId, JSONObject.toJSONString(pcloudGuideDelayDto));
             }
         }
     }
@@ -2131,4 +2136,62 @@ public class BookKeywordBizImpl implements BookKeywordBiz {
             }
         }
     }
+
+    @Override
+    public List<ReplyMsgDTO> getKeyWordsByClassify(Long classifyId) {
+        ClassifyDTO classifyDTO = bookGroupClassifyDao.getById(classifyId);
+        if (Objects.isNull(classifyDTO) || Objects.isNull(classifyDTO.getBookGroupId())) {
+            return new ArrayList<>();
+        }
+        Long bookGroupId = classifyDTO.getBookGroupId();
+        // 获取所有的关键词
+        List<ReplyKeywordDTO> replyKeywordDTOS = bookKeywordDao.listAllKeywordByClassifyIdAndBookGroupId(classifyId, bookGroupId);
+        if (CollUtil.isEmpty(replyKeywordDTOS)) {
+            return new ArrayList<>();
+        }
+
+        List<ReplyMsgDTO> replyMsgDTOS = new ArrayList<>();
+
+        for (ReplyKeywordDTO replyKeywordDTO : replyKeywordDTOS) {
+            final boolean isApp = ReplyTypeEnum.APP.value.equals(replyKeywordDTO.getReplyType());
+            final boolean isLink = ReplyTypeEnum.LINK.value.equals(replyKeywordDTO.getReplyType());
+            if (isApp || isLink) {
+                AccountSettingDto accountSettingDto = qrcodeSceneConsr.getWechatInfo(classifyDTO.getChannelId());
+                String linkUrl = SendWeixinRequestTools.splitUrlNew(accountSettingDto, replyKeywordDTO.getLinkUrl(), bookGroupId, classifyId, 0L);
+                String shortUrl4Own = UrlUtils.getShortUrl4Own(linkUrl);
+                if (replyKeywordDTO.getLinkUrl().contains("live/C")) {
+                    // 获取直播课信息
+                    List<CourseListDto> list4BroadcastReminder = liveCons.getList4BroadcastReminder(replyKeywordDTO.getServeId(), replyKeywordDTO.getServeType());
+                    replyKeywordDTO.setReplyType(ReplyTypeEnum.TEXT.value);
+                    StringBuilder sb = new StringBuilder("【");
+                    sb.append(CollectionUtils.isEmpty(list4BroadcastReminder) ? replyKeywordDTO.getDescription() : list4BroadcastReminder.get(0).getTableTitle())
+                            .append("】近期将开播的课程\n");
+                    if (!CollectionUtils.isEmpty(list4BroadcastReminder)) {
+                        int i = 1;
+                        for (CourseListDto listDto : list4BroadcastReminder) {
+                            sb.append("第").append(i++).append("课：").append(listDto.getTitle()).append("\n");
+                        }
+                    }
+                    sb.append("查看更多课程表链接：").append(shortUrl4Own);
+                    replyKeywordDTO.setContent(sb.toString());
+                }
+                replyKeywordDTO.setLinkUrl(linkUrl);
+                replyKeywordDTO.setShortLinkUrl(shortUrl4Own);
+            }
+
+            if (ReplyTypeEnum.TEXT.value.equals(replyKeywordDTO.getReplyType())) {
+                replyMsgDTOS.add(ReplyMsgDTO.builder().msgType(1).keyWord(replyKeywordDTO.getKeywords()).content(replyKeywordDTO.getContent()).build());
+            } else if (ReplyTypeEnum.IMAGE.value.equals(replyKeywordDTO.getReplyType())) {
+                replyMsgDTOS.add(ReplyMsgDTO.builder().msgType(2).keyWord(replyKeywordDTO.getKeywords()).imgUrl(replyKeywordDTO.getPicUrl()).build());
+            } else if (ReplyTypeEnum.APP.value.equals(replyKeywordDTO.getReplyType()) || ReplyTypeEnum.LINK.value.equals(replyKeywordDTO.getReplyType())) {
+                replyMsgDTOS.add(ReplyMsgDTO.builder().msgType(3).keyWord(replyKeywordDTO.getKeywords())
+                        .desc(replyKeywordDTO.getDescription())
+                        .url(replyKeywordDTO.getLinkUrl())
+                        .title(replyKeywordDTO.getContent())
+                        .imgUrl(replyKeywordDTO.getPicUrl())
+                        .build());
+            }
+        }
+        return replyMsgDTOS;
+    }
 }