Alawn/udf
1
0
Fork 0
mirror of https://gitee.com/wangkang/udf.git synced 2026-10-28 15:23:46 +00:00
Code Issues Releases Wiki Activity

添加微信MP的集成

Browse Source
This commit is contained in:
udf_admin@163.com
2018-01-30 20:57:24 +08:00
parent 9957cd70a4
commit dbe511a5de
2 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
udf-starter-weixin-mp/src/main/java/org/itkk/udf/weixin/mp/service/WeixinMpCallbackService.java
+3 -9
View File
@@ -4,11 +4,7 @@ import com.qq.weixin.mp.aes.WXBizMsgCrypt;
import lombok.extern.slf4j.Slf4j;
import org.itkk.udf.amqp.rabbitmq.Rabbitmq;
import org.itkk.udf.amqp.rabbitmq.RabbitmqMessage;
import org.itkk.udf.weixin.mp.api.WeixinMpConsont;
import org.itkk.udf.weixin.mp.api.WeixinMpException;
import org.itkk.udf.weixin.mp.api.ShaOne;
import org.itkk.udf.weixin.mp.api.WeixinMpApiConfig;
import org.itkk.udf.weixin.mp.api.WeixinMpApiProperties;
import org.itkk.udf.weixin.mp.api.*;
import org.itkk.udf.weixin.mp.api.meta.WeixinMpApiAuthMeta;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
@@ -72,11 +68,12 @@ public class WeixinMpCallbackService {
* @param signature signature
* @param timestamp timestamp
* @param nonce nonce
* @param msgSignature msgSignature
* @param inputMessage inputMessage
* @throws Exception Exception
*/
@Async
public void callback(String businessCode, String signature, String timestamp, String nonce, String inputMessage) throws Exception { //NOSONAR
public void callback(String businessCode, String signature, String timestamp, String nonce, String msgSignature, String inputMessage) throws Exception { //NOSONAR
//常量
final String eventMessageType = "event";
//获得身份认证元数据
@@ -93,9 +90,6 @@ public class WeixinMpCallbackService {
if (weixinMpApiAuthMeta.getSafeModel()) {
//实例化加密解密工具类
WXBizMsgCrypt pc = new WXBizMsgCrypt(weixinMpApiAuthMeta.getToken(), weixinMpApiAuthMeta.getEncodingAesKey(), weixinMpApiAuthMeta.getAppId());
//解析密文输入参数
Element root = WeixinMpConsont.formatInputMessage(inputXmlMessage);
String msgSignature = WeixinMpConsont.getXmlNodeValue(root, "MsgSignature");
inputXmlMessage = pc.decryptMsg(msgSignature, timestamp, nonce, inputXmlMessage);
}
//解析明文输入参数
udf-starter-weixin-mp/src/main/java/org/itkk/udf/weixin/mp/web/IWeixinMpCallbackController.java
+3 -1
View File
@@ -3,6 +3,7 @@ package org.itkk.udf.weixin.mp.web;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import springfox.documentation.annotations.ApiIgnore;
/**
@@ -32,9 +33,10 @@ public interface IWeixinMpCallbackController {
* @param timestamp 时间戳
* @param nonce 随机数
* @param echostr 随机数
* @param msgSignature 随机数
* @throws Exception Exception
*/
@PostMapping
void callback(@PathVariable String businessCode, String signature, String timestamp, String nonce, String echostr) throws Exception; //NOSONAR
void callback(@PathVariable String businessCode, String signature, String timestamp, String nonce, String echostr, @RequestParam("msg_signature") String msgSignature) throws Exception; //NOSONAR
}