xiaoyong931011
2023-07-20 db0196ae6db238f8e387d24c9bbd4203ba834611
src/main/java/cc/mrbird/febs/pay/util/WechatEventUtil.java
@@ -1,6 +1,7 @@
package cc.mrbird.febs.pay.util;
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.util.StrUtil;
import org.dom4j.io.SAXReader;
import javax.servlet.http.HttpServletRequest;
@@ -77,7 +78,7 @@
        log.info("事件处理:event:{}、msgType:{}、toUserName:{}、fromUserName:{}", eventType, msgType, toUserName, fromUserName);
        if ("event".equals(msgType)) {
            if ("subscribe".equals(eventType)) {
                result = imgTextMsg(toUserName, fromUserName, "新用户注册", "欢迎光临【药王谷铺子】,点击总下角【药王谷铺子】-【商城】。", "图片地址", "点击后跳转的路径");
                result = imgTextMsg(toUserName, fromUserName, "欢迎光临", "欢迎光临【药王谷铺子】,点击左下角【药王谷铺子】-【商城】,进入商城。", "图片地址", "点击后跳转的路径");
                log.info("新增关注事件:toUserName{}、fromUserName{}", toUserName, fromUserName);
                StringBuffer stringBuffer = new StringBuffer();
                if(map.containsKey("EventKey")){
@@ -85,10 +86,12 @@
                     * 扫带参数二维码
                     */
                    String eventKey = map.get("EventKey");
                    stringBuffer.append(eventKey);
                    stringBuffer.append("-");
                    stringBuffer.append(fromUserName);
                    agentProducer.sendMemberSubScanMsg(stringBuffer.toString());
                    if(StrUtil.isNotEmpty(eventKey)){
                        stringBuffer.append(eventKey);
                        stringBuffer.append("-");
                        stringBuffer.append(fromUserName);
                        agentProducer.sendMemberSubScanMsg(stringBuffer.toString());
                    }
                }
                /**
                 * 普通关注事件