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 | 83 ++++++++++++++++++++++++++++++++++++++++-
1 files changed, 81 insertions(+), 2 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 ff02266..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
@@ -13,7 +13,9 @@
import org.slf4j.LoggerFactory;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.ServletInputStream;
@@ -43,7 +45,7 @@
*
* @param request
*/
- @RequestMapping(path = "/gateway")
+ @RequestMapping(path = "/gateway", method = RequestMethod.GET)
public ResponseEntity<String> gateway(HttpServletRequest request) {
String token = WechatConstant.TOKEN;
@@ -119,6 +121,83 @@
}
/**
+ * 寰俊鐧诲綍鎺ュ彛
+ *
+ * @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 (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);
+ }
+
+ }
+
+ 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 fromUserName
@@ -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")) {
--
Gitblit v1.8.0