Alawn/udf
1
0
Fork 0
mirror of https://gitee.com/wangkang/udf.git synced 2026-11-03 11:17:22 +00:00
Code Issues Releases Wiki Activity

添加微信MP的集成

Browse Source
This commit is contained in:
udf_admin@163.com
2018-01-28 00:13:02 +08:00
parent b6b2e40ada
commit 6ec8b52510
2 changed files with 40 additions and 43 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
+36 -41
View File
@@ -72,54 +72,49 @@ public class WeixinMpCallbackService {
* @return String
* @throws Exception Exception
*/
public String callback(String businessCode, String signature, String timestamp, String nonce, String inputMessage) {
public String callback(String businessCode, String signature, String timestamp, String nonce, String inputMessage) throws Exception { //NOSONAR
//常量
final String defReturnMessage = "success";
final String eventMessageType = "event";
//开始处理
try {
//获得身份认证元数据
WeixinMpApiAuthMeta weixinMpApiAuthMeta = weixinMpApiProperties.getAuth().get(businessCode);
//验证签名
this.check(weixinMpApiAuthMeta.getToken(), signature, timestamp, nonce);
//获得身份认证元数据
WeixinMpApiAuthMeta weixinMpApiAuthMeta = weixinMpApiProperties.getAuth().get(businessCode);
//验证签名
this.check(businessCode, signature, timestamp, nonce);
//获得输入参数
String inputXmlMessage = inputMessage;
//判断是否需要解密
if (weixinMpApiAuthMeta.getSafeModel()) {
//实例化加密解密工具类
WXBizMsgCrypt pc = new WXBizMsgCrypt(weixinMpApiAuthMeta.getToken(), weixinMpApiAuthMeta.getEncodingAesKey(), weixinMpApiAuthMeta.getAppId());
//获得输入参数
String inputXmlMessage = inputMessage;
//判断是否需要解密
if (weixinMpApiAuthMeta.getSafeModel()) {
//解析密文输入参数
Element root = WeixinMpConsont.formatInputMessage(inputXmlMessage);
String msgSignature = WeixinMpConsont.getXmlNodeValue(root, "MsgSignature");
inputXmlMessage = pc.decryptMsg(msgSignature, timestamp, nonce, inputXmlMessage);
}
//解析明文输入参数
//解析密文输入参数
Element root = WeixinMpConsont.formatInputMessage(inputXmlMessage);
//获得消息类型
String msgType = WeixinMpConsont.getXmlNodeValue(root, "MsgType");
//定义MQ的交换机名称和路由键名称(默认是消息类型)
String exchange = WeixinMpApiConfig.EXCHANGE_WEIXIN_MP_MESSAGE;
String routingKey = msgType;
//判断处理
if (eventMessageType.equals(msgType)) { //事件
//更改为事件类型
exchange = WeixinMpApiConfig.EXCHANGE_WEIXIN_MP_EVENT;
routingKey = WeixinMpConsont.getXmlNodeValue(root, "Event");
}
//构造消息头
Map<String, String> header = new HashMap<>();
header.put("businessCode", businessCode);
//构造消息
RabbitmqMessage<String> message = new RabbitmqMessage<>(header, inputXmlMessage);
//发送消息
rabbitmq.convertAndSend(exchange, routingKey, message);
//日志输出
log.info("send weixin message ---> businessCode : {} , exchange : {} , routingKey : {} , body : {} ", businessCode, exchange, routingKey, inputXmlMessage);
//返回
return defReturnMessage;
} catch (Exception e) {
throw new WeixinMpException(e);
String msgSignature = WeixinMpConsont.getXmlNodeValue(root, "MsgSignature");
inputXmlMessage = pc.decryptMsg(msgSignature, timestamp, nonce, inputXmlMessage);
}
//解析明文输入参数
Element root = WeixinMpConsont.formatInputMessage(inputXmlMessage);
//获得消息类型
String msgType = WeixinMpConsont.getXmlNodeValue(root, "MsgType");
//定义MQ的交换机名称和路由键名称(默认是消息类型)
String exchange = WeixinMpApiConfig.EXCHANGE_WEIXIN_MP_MESSAGE;
String routingKey = msgType;
//判断处理
if (eventMessageType.equals(msgType)) { //事件
//更改为事件类型
exchange = WeixinMpApiConfig.EXCHANGE_WEIXIN_MP_EVENT;
routingKey = WeixinMpConsont.getXmlNodeValue(root, "Event");
}
//构造消息头
Map<String, String> header = new HashMap<>();
header.put("businessCode", businessCode);
//构造消息
RabbitmqMessage<String> message = new RabbitmqMessage<>(header, inputXmlMessage);
//发送消息
rabbitmq.convertAndSend(exchange, routingKey, message);
//日志输出
log.info("send weixin message ---> businessCode : {} , exchange : {} , routingKey : {} , body : {} ", businessCode, exchange, routingKey, inputXmlMessage);
//返回
return defReturnMessage;
}
}
udf-starter-weixin-mp/src/main/java/org/itkk/udf/weixin/mp/web/IWeixinMpCallbackController.java
+4 -2
View File
@@ -19,9 +19,10 @@ public interface IWeixinMpCallbackController {
* @param timestamp 时间戳
* @param nonce 随机数
* @param echostr 随机数
* @throws Exception Exception
*/
@GetMapping
void check(@PathVariable String businessCode, String signature, String timestamp, String nonce, String echostr);
void check(@PathVariable String businessCode, String signature, String timestamp, String nonce, String echostr) throws Exception; //NOSONAR
/**
* 微信消息推送(POST)
@@ -31,8 +32,9 @@ public interface IWeixinMpCallbackController {
* @param timestamp 时间戳
* @param nonce 随机数
* @param echostr 随机数
* @throws Exception Exception
*/
@PostMapping
void callback(@PathVariable String businessCode, String signature, String timestamp, String nonce, String echostr);
void callback(@PathVariable String businessCode, String signature, String timestamp, String nonce, String echostr) throws Exception; //NOSONAR
}