紧急4

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

@@ -3,6 +3,7 @@ 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.consumer.channel.QrcodeSceneConsr;
+import com.pcloud.book.consumer.content.ResourceConsr;
 import com.pcloud.book.consumer.resource.ProductConsr;
 import com.pcloud.book.consumer.wechatgroup.WechatGroupConsr;
 import com.pcloud.book.group.biz.BookGroupAppBiz;
@@ -57,9 +58,12 @@ 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.contentcenter.resource.dto.ResourceDTO;
 import com.pcloud.wechatgroup.message.dto.AgreeAddUserDTO;
+import com.sdk.wxgroup.SendFileVO;
 import com.sdk.wxgroup.SendGroupInviteVO;
 import com.sdk.wxgroup.SendMessageTypeEnum;
+import com.sdk.wxgroup.SendPicMessageVO;
 import com.sdk.wxgroup.SendTextMessageVO;
 import com.sdk.wxgroup.WxGroupSDK;
 
@@ -71,6 +75,7 @@ import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -120,6 +125,8 @@ public class BookGuideBizImpl implements BookGuideBiz {
     private BookGroupCipherUserDao bookGroupCipherUserDao;
     @Autowired
     private SelfRobotKeywordDao selfRobotKeywordDao;
+    @Autowired
+    private ResourceConsr resourceConsr;
 
     @Value("${system.env}")
     private String envStr;
@@ -193,8 +200,31 @@ public class BookGuideBizImpl implements BookGuideBiz {
                                 vo.setWxGroupId(agreeAddUserDTO.getUserWxId());
                                 vo.setIp(agreeAddUserDTO.getIp());
                                 WxGroupSDK.sendTextMessage(vo);
+                                if ("学前".equals(selfRobotKeyword.getKeyword())){
+                                    SendPicMessageVO sendPicMessageVO = new SendPicMessageVO();
+                                    sendPicMessageVO.setWxGroupId(agreeAddUserDTO.getUserWxId());
+                                    sendPicMessageVO.setAltId(agreeAddUserDTO.getRobotWxId());
+                                    sendPicMessageVO.setPicUrl("https://oss.5rs.me/oss/uploadfe/jpg/ed67ad219eab128dcd404844ee966483.jpg");
+                                    sendPicMessageVO.setIp(agreeAddUserDTO.getIp());
+                                    sendPicMessageVO.setCode(SendMessageTypeEnum.SELF.getCode());
+                                    WxGroupSDK.sendPicMessage(sendPicMessageVO);
+                                    log.info("发送特殊名片"+sendPicMessageVO.toString());
+                                }
+                                if ("教辅书单".equals(selfRobotKeyword.getKeyword())){
+                                    SendFileVO sendFileVO = new SendFileVO();
+                                    Map<Long, ResourceDTO> map = resourceConsr.mapByIds(Arrays.asList(selfRobotKeyword.getResourceId()));
+                                    ResourceDTO resourceDTO = map.get(selfRobotKeyword.getResourceId());
+                                    if (resourceDTO != null) {
+                                        sendFileVO.setFileUrl(resourceDTO.getFileUrl());
+                                        sendFileVO.setFileName(resourceDTO.getResourceName());
+                                    }
+                                    sendFileVO.setIp(agreeAddUserDTO.getIp());
+                                    sendFileVO.setAltId(agreeAddUserDTO.getRobotWxId());
+                                    sendFileVO.setWxId(agreeAddUserDTO.getUserWxId());
+                                    WxGroupSDK.sendFile(sendFileVO);
+                                }
                                 log.info("临时demo发送个人号加好友信息"+vo.toString());
-                                Thread.sleep(1000*30);
+                                Thread.sleep(1000*60);
                             } catch (InterruptedException e) {
                                 log.error("发消息休眠5秒出错", e);
                             }