pay/jeepay
1
0
Fork 0
mirror of https://github.com/jeequan/jeepay synced 2024-11-17 14:58:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

#I9UT23 解决商户通知转义问题。

Browse Source
This commit is contained in:
terrfly 2024-06-12 12:03:35 +08:00
parent f471f67cd1
commit dbf4d9c6e0
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
jeepay-payment/src/main/java/com/jeequan/jeepay/pay/mq/PayOrderMchNotifyMQReceiver.java
View File

@ -16,6 +16,7 @@
package com.jeequan.jeepay.pay.mq;
import cn.hutool.core.net.url.UrlBuilder;
import cn.hutool.core.util.CharsetUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpUtil;
import com.jeequan.jeepay.components.mq.model.PayOrderMchNotifyMQ;
@ -28,6 +29,8 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Map;
/**
* 接收MQ消息
* 业务： 支付订单商户通知
@ -71,13 +74,10 @@ public class PayOrderMchNotifyMQReceiver implements PayOrderMchNotifyMQ.IMQRecei
try {
// res = HttpUtil.createPost(notifyUrl).timeout(20000).execute().body();
int pathEndPos = notifyUrl.indexOf('?');
if (pathEndPos <= -1) {
log.error("通知地址错误，参数为空，notifyUrl：{}", notifyUrl);
throw new BizException("通知地址错误");
}
String host = notifyUrl.split("\\?")[0];
Map bodyMap = HttpUtil.decodeParamMap(notifyUrl, CharsetUtil.CHARSET_UTF_8);
res = HttpUtil.post(host, bodyMap, 20000);
res = HttpUtil.post(StrUtil.subPre(notifyUrl, pathEndPos), StrUtil.subSuf(notifyUrl, pathEndPos + 1), 20000);
} catch (Exception e) {
log.error("http error", e);
res = "连接["+ UrlBuilder.of(notifyUrl).getHost() +"]异常:【" + e.getMessage() + "】";