From 585f25a14f57d217a3ea924e1ce9deb1a16726b8 Mon Sep 17 00:00:00 2001
From: Sum1Dream <418471657@qq.com>
Date: Thu, 22 Sep 2022 16:52:05 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../java/com/v1/config/WeChatQrcodeUtils.java | 19 ++++++
.../com/v1/controller/WxMsgController.java | 62 ++++++++++++++-----
2 files changed, 65 insertions(+), 16 deletions(-)
diff --git a/v1/src/main/java/com/v1/config/WeChatQrcodeUtils.java b/v1/src/main/java/com/v1/config/WeChatQrcodeUtils.java
index 4851ede2..7dad0633 100644
--- a/v1/src/main/java/com/v1/config/WeChatQrcodeUtils.java
+++ b/v1/src/main/java/com/v1/config/WeChatQrcodeUtils.java
@@ -1,6 +1,7 @@
package com.v1.config;
+import com.alibaba.fastjson.JSONObject;
import com.hai.model.TextMessage;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.common.error.WxErrorException;
@@ -182,5 +183,23 @@ public class WeChatQrcodeUtils {
return xml;
}
+ /**
+ * @Author Sum1Dream
+ * @Name paramPars
+ * @Description // 微信二维码参数解析
+ * @Date 13:50 2022/9/22
+ * @Param [param]
+ * @Return com.alibaba.fastjson.JSONObject
+ */
+ public JSONObject paramPars(String param) {
+ String[] paramArray = param.split("&");
+ JSONObject object = new JSONObject();
+ for (String s : paramArray) {
+ String[] array = s.split("=");
+ object.put(array[0] , array[1]);
+ }
+ return object;
+ }
+
}
diff --git a/v1/src/main/java/com/v1/controller/WxMsgController.java b/v1/src/main/java/com/v1/controller/WxMsgController.java
index 18bd1f49..9f85c429 100644
--- a/v1/src/main/java/com/v1/controller/WxMsgController.java
+++ b/v1/src/main/java/com/v1/controller/WxMsgController.java
@@ -1,5 +1,6 @@
package com.v1.controller;
+import com.alibaba.druid.sql.visitor.functions.If;
import com.alibaba.fastjson.JSONObject;
import com.hai.common.exception.ErrorCode;
import com.hai.common.exception.ErrorHelp;
@@ -9,6 +10,7 @@ import com.hai.common.pay.util.XmlUtil;
import com.hai.common.utils.HttpsUtils;
import com.hai.common.utils.ResponseMsgUtil;
import com.hai.common.utils.WxUtils;
+import com.hai.config.CommonSysConst;
import com.hai.model.HighMerchantStoreModel;
import com.hai.model.ResponseData;
import com.hai.model.TextMessage;
@@ -42,6 +44,7 @@ import java.io.BufferedOutputStream;
import java.io.StringReader;
import java.util.HashMap;
import java.util.Map;
+import java.util.Objects;
import java.util.SortedMap;
/**
@@ -86,7 +89,25 @@ public class WxMsgController {
String event = map.get("Event");
// 区分消息类型
String msgType = map.get("MsgType");
+ // 二维码参数
+ String eventKey = map.get("EventKey");
+ String linkContent;
+ String content = null;
+ if (eventKey != null) {
+ JSONObject object = weChatQrcodeUtils.paramPars(eventKey);
+ // type = 1 推广扫码 type = 2
+ if (Objects.equals(object.getString("qrscene_type"), "1")) {
+ linkContent = "点击注册\n\n";
+ } else {
+ // 商户门店
+ HighMerchantStoreModel store = merchantStoreService.getMerchantStoreByKey(object.getString("code"));
+ linkContent = "欢迎来到" + store.getStoreName() + "[哇][哇][哇]\n\n点击这里一键加油\n\n";
+ }
+ } else {
+ linkContent = "点击注册\n\n";
+ }
+ log.info("二维码参数：" + eventKey);
// 普通消息
if ("text".equals(msgType)) {
// todo 处理文本消息
@@ -102,33 +123,42 @@ public class WxMsgController {
// 用户关注公众号
if ("subscribe".equals(event)) {
log.info("进入扫码关注流程：" + event);
- // 商户门店
- HighMerchantStoreModel store = merchantStoreService.getMerchantStoreByKey(map.get("EventKey"));
// todo 业务处理
- String content = "欢迎来到" + store.getStoreName() + "点击这里一键加油";
-
- map.put("content" , content);
- String mapToXml = weChatQrcodeUtils.handleEventSubscribe(map);
- response.setCharacterEncoding("UTF-8");
- response.getWriter().print(mapToXml);
+ content =
+ "终于等到你，还好我没放弃[玫瑰][玫瑰][玫瑰]\n\n" +
+ "您好，感谢关注嗨森逛商城！\n\n" +
+ linkContent +
+ "在线等你来撩~[哇][哇][哇]\n\n" +
+ "特意为您奉上" +
+ "5张优惠券" +
+ "，放在您的"+
+ "卡包"+
+ "里面，记得及时使用哦[爱心][爱心][爱心]\n\n" +
+ "【如遇任何问题请致电客服：400-678-0738】"
+ ;
// todo 业务处理
}
// 用户扫码进入公众号
else if ("SCAN".equals(event)) {
- // 商户门店
- HighMerchantStoreModel store = merchantStoreService.getMerchantStoreByKey(map.get("EventKey"));
// todo 业务处理
- String content = "欢迎来到" + store.getStoreName() + "点击这里一键加油";
+ content =
+ "油价很贵，诗和远方也很贵[可怜]\n\n" +
+ "“一键加油”有”油“惠[红包][红包][红包]\n\n" +
+ linkContent +
+ "多重好礼为您助力\n\n" +
+ "加油的时候少点心疼，踩油门的时候多点豪横！[得意][得意][得意]\n\n" +
+ "【如遇任何问题请致电客服：400-678-0738】"
+ ;
+
- map.put("content" , content);
- String mapToXml = weChatQrcodeUtils.handleEventSubscribe(map);
- response.setCharacterEncoding("UTF-8");
- response.getWriter().print(mapToXml);
}else if ("unsubscribe".equals(event)) {
// todo 取消关注 业务处理
}
-
+ map.put("content" , content);
+ String mapToXml = weChatQrcodeUtils.handleEventSubscribe(map);
+ response.setCharacterEncoding("UTF-8");
+ response.getWriter().print(mapToXml);
}
} catch (Exception e) {
// return null;