From 0b1a81baf52cba4b977ec4dbc4657c726ec3305d Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 14 六月 2020 11:38:21 +0800
Subject: [PATCH] 优化 微信对接代码
---
service-front/src/main/java/com/java110/front/controller/WechatGatewayController.java | 172 ++++++++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 138 insertions(+), 34 deletions(-)
diff --git a/service-front/src/main/java/com/java110/front/controller/WechatGatewayController.java b/service-front/src/main/java/com/java110/front/controller/WechatGatewayController.java
index c1d9919..0acdcd6 100644
--- a/service-front/src/main/java/com/java110/front/controller/WechatGatewayController.java
+++ b/service-front/src/main/java/com/java110/front/controller/WechatGatewayController.java
@@ -5,6 +5,7 @@
import com.java110.core.factory.AuthenticationFactory;
import com.java110.core.factory.WechatFactory;
import com.java110.utils.constant.WechatConstant;
+import com.java110.utils.util.StringUtil;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
@@ -17,7 +18,11 @@
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
+import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
import java.util.Arrays;
/**
@@ -38,13 +43,10 @@
/**
* 寰俊鐧诲綍鎺ュ彛
*
- * @param param
* @param request
*/
- @RequestMapping(path = "/gateway", method = RequestMethod.POST)
- public ResponseEntity<String> gateway(@RequestBody String param, HttpServletRequest request) {
- logger.debug("寰俊浼犲叆淇℃伅" + param);
-
+ @RequestMapping(path = "/gateway", method = RequestMethod.GET)
+ public ResponseEntity<String> gateway(HttpServletRequest request) {
String token = WechatConstant.TOKEN;
String signature = request.getParameter("signature");
@@ -62,10 +64,90 @@
}
String signature1 = AuthenticationFactory.SHA1Encode(sourceString).toLowerCase();
logger.debug("sourceString = " + sourceString + "||||" + "signature1 = " + signature1);
- if (signature1.equals(signature)) {
- if (echostr == null) {
+ try {
+ if (signature1.equals(signature)) {
+ if (echostr == null) {
+ String postStr = this.readStreamParameter(request.getInputStream());
+ if (StringUtil.isEmpty(postStr)) {
+ responseStr = "鏈緭鍏ヤ换浣曞唴瀹�";
+ } else {
+ /*if (postStr.equals(new String(postStr.getBytes("ISO-8859-1"), "ISO-8859-1"))) {
+ logger.debug(" This type is iso-8859-1");
+ postStr = new String(postStr.getBytes("ISO-8859-1"), "UTF-8");
+
+ }
+ if (postStr.equals(new String(postStr.getBytes("GB2312"), "GB2312"))) {
+ logger.debug(" This type is GB2312" + postStr);
+ postStr = new String(postStr.getBytes("GB2312"), "UTF-8");
+ logger.debug(" change postStr to utf-8 " + postStr);
+ }
+ if (postStr.equals(new String(postStr.getBytes("GBK"), "GBK"))) {
+ logger.debug(" This type is GBK");
+ postStr = new String(postStr.getBytes("GBK"), "UTF-8");
+
+ }
+ postStr = new String(postStr.getBytes("GB2312"), "UTF-8");*/
+ Document document = DocumentHelper.parseText(postStr);
+ Element root = document.getRootElement();
+ String fromUserName = root.elementText("FromUserName");
+ String toUserName = root.elementText("ToUserName");
+ String keyword = root.elementTextTrim("Content");
+ String msgType = root.elementTextTrim("MsgType");
+ String event = root.elementText("Event");
+ String eventKey = root.elementText("EventKey");
+ if (WechatConstant.MSG_TYPE_TEXT.equals(msgType)) {
+ responseStr = textResponseHandler(fromUserName, toUserName, keyword);
+ } else if (WechatConstant.MSG_TYPE_EVENT.equals(msgType)) {
+ responseStr = eventResponseHandler(fromUserName, toUserName, keyword, event, eventKey);
+ } else {
+ responseStr = eventResponseHandler(fromUserName, toUserName, keyword, event, eventKey);
+ }
+
+ }
+ } else {
+ responseStr = echostr;
+ }
+ logger.debug(">>>>>>>>>>>>>..responseStr>>>>>>>>>>>>>>>" + responseStr);
+ } else {
+ responseStr = "浜诧紝闈炴硶璁块棶锛岀鍚嶅け璐�";
+ }
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ logger.error("澶勭悊澶辫触", e);
+ responseStr = "浜诧紝缃戠粶瓒呮椂锛岃绋嶅悗閲嶈瘯";
+ }
+
+ return new ResponseEntity<String>(responseStr, HttpStatus.OK);
+ }
+
+ /**
+ * 寰俊鐧诲綍鎺ュ彛
+ *
+ * @param request
+ */
+ @RequestMapping(path = "/gateway", method = RequestMethod.POST)
+ public ResponseEntity<String> gateway(@RequestBody String param, HttpServletRequest request) {
+
+ String token = WechatConstant.TOKEN;
+ String signature = request.getParameter("signature");
+ String timestamp = request.getParameter("timestamp");
+ String nonce = request.getParameter("nonce");
+ String openId = request.getParameter("openid");
+ String responseStr = "";
+ logger.debug("token = " + token + "||||" + "signature = " + signature + "|||" + "timestamp = "
+ + timestamp + "|||" + "nonce = " + nonce + "|||| param = " + param + "|||| openId= " + openId);
+ String sourceString = "";
+ String[] ss = new String[]{token, timestamp, nonce};
+ Arrays.sort(ss);
+ for (String s : ss) {
+ sourceString += s;
+ }
+ String signature1 = AuthenticationFactory.SHA1Encode(sourceString).toLowerCase();
+ logger.debug("sourceString = " + sourceString + "||||" + "signature1 = " + signature1);
+ try {
+ if (signature1.equals(signature)) {
String postStr = param;//this.readStreamParameter(request.getInputStream());
- if (postStr == null || postStr.length() == 0) {
+ if (StringUtil.isEmpty(postStr)) {
responseStr = "鏈緭鍏ヤ换浣曞唴瀹�";
} else {
/*if (postStr.equals(new String(postStr.getBytes("ISO-8859-1"), "ISO-8859-1"))) {
@@ -84,35 +166,32 @@
}
postStr = new String(postStr.getBytes("GB2312"), "UTF-8");*/
- Document document;
- try {
- document = DocumentHelper.parseText(postStr);
- Element root = document.getRootElement();
- String fromUserName = root.elementText("FromUserName");
- String toUserName = root.elementText("ToUserName");
- String keyword = root.elementTextTrim("Content");
- String msgType = root.elementTextTrim("MsgType");
- String event = root.elementText("Event");
- String eventKey = root.elementText("EventKey");
- if (WechatConstant.MSG_TYPE_TEXT.equals(msgType)) {
- responseStr = textResponseHandler(fromUserName, toUserName, keyword);
- } else if (WechatConstant.MSG_TYPE_EVENT.equals(msgType)) {
- responseStr = eventResponseHandler(fromUserName, toUserName, keyword, event, eventKey);
- } else {
- responseStr = eventResponseHandler(fromUserName, toUserName, keyword, event, eventKey);
- }
- } catch (Exception e) {
- // TODO Auto-generated catch block
- logger.error("澶勭悊澶辫触", e);
- responseStr = "浜诧紝缃戠粶瓒呮椂锛岃绋嶅悗閲嶈瘯";
+ Document document = DocumentHelper.parseText(postStr);
+ Element root = document.getRootElement();
+ String fromUserName = root.elementText("FromUserName");
+ String toUserName = root.elementText("ToUserName");
+ String keyword = root.elementTextTrim("Content");
+ String msgType = root.elementTextTrim("MsgType");
+ String event = root.elementText("Event");
+ String eventKey = root.elementText("EventKey");
+ if (WechatConstant.MSG_TYPE_TEXT.equals(msgType)) {
+ responseStr = textResponseHandler(fromUserName, toUserName, keyword);
+ } else if (WechatConstant.MSG_TYPE_EVENT.equals(msgType)) {
+ responseStr = eventResponseHandler(fromUserName, toUserName, keyword, event, eventKey);
+ } else {
+ responseStr = eventResponseHandler(fromUserName, toUserName, keyword, event, eventKey);
}
+
}
+
+ logger.debug(">>>>>>>>>>>>>..responseStr>>>>>>>>>>>>>>>" + responseStr);
} else {
- responseStr = echostr;
+ responseStr = "浜诧紝闈炴硶璁块棶锛岀鍚嶅け璐�";
}
- logger.debug(">>>>>>>>>>>>>..responseStr>>>>>>>>>>>>>>>" + responseStr);
- } else {
- responseStr = "浜诧紝闈炴硶璁块棶锛岀鍚嶅け璐�";
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ logger.error("澶勭悊澶辫触", e);
+ responseStr = "浜诧紝缃戠粶瓒呮椂锛岃绋嶅悗閲嶈瘯";
}
return new ResponseEntity<String>(responseStr, HttpStatus.OK);
@@ -161,7 +240,7 @@
public String eventResponseHandler(String fromUserName, String toUserName, String keyWords, String event,
String eventKey) throws Exception {
String resultStr = "";
- // 鐠併垽妲�
+ //
if (event.equals("subscribe")) {
resultStr = "HC灏忓尯鐗╀笟绠＄悊绯荤粺鏄敱java110鍥㈤槦浜�2017骞�4鏈堜唤鍙戣捣鐨勫墠鍚庣鍒嗙銆佸垎甯冨紡鏋舵瀯寮�婧愰」鐩紝鐩墠鎴戜滑鐨勪唬鐮佸紑婧愬湪github 鍜実itee涓婏紝寮�婧愰」鐩敱HC灏忓尯绠＄悊绯荤粺鍚庣锛孒C灏忓尯绠＄悊绯荤粺鍓嶇锛孒C灏忓尯绠＄悊绯荤粺涓氫富鎵嬫満鐗堝拰HC灏忓尯绠＄悊绯荤粺鐗╀笟鎵嬫満鐗堬紝涓氬姟鎶�鏈氦娴佺兢锛�827669685";
} else if (event.equals("unsubscribe")) {
@@ -174,4 +253,29 @@
}
return WechatFactory.formatText(toUserName, fromUserName, resultStr);
}
+
+ public String readStreamParameter(ServletInputStream in) {
+ StringBuilder buffer = new StringBuilder();
+ BufferedReader reader = null;
+ try {
+ reader = new BufferedReader(new InputStreamReader(in));
+ String line = null;
+ while ((line = reader.readLine()) != null) {
+ buffer.append(line);
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ if (null != reader) {
+ try {
+ reader.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ logger.debug("鍏紬鍙峰唴瀹�:" + buffer.toString());
+ return buffer.toString();
+ }
}
--
Gitblit v1.8.0