|
@@ -11,6 +11,7 @@ import com.wechat.pay.contrib.apache.httpclient.auth.WechatPay2Validator;
|
|
|
import com.wechat.pay.contrib.apache.httpclient.cert.CertificatesManager;
|
|
|
import com.wechat.pay.contrib.apache.httpclient.util.PemUtil;
|
|
|
import com.yami.shop.bean.bo.PayInfoBo;
|
|
|
+import com.yami.shop.common.exception.GlobalException;
|
|
|
import com.yami.shop.wx.config.CombinePayUrlEnum;
|
|
|
import com.yami.shop.wx.config.WechatPayServiceConfig;
|
|
|
import com.yami.shop.wx.po.JsapiPayInfoPo;
|
|
@@ -398,11 +399,10 @@ public class WxProviderServiceImpl implements WxProviderService {
|
|
|
log.info("===========微信回调参数===========\n" + body);
|
|
|
log.info("微信回调参数:{}", body);
|
|
|
JSONObject jsonObject = JSONObject.parseObject(body);
|
|
|
- WechatPayValidator wechatPayValidator
|
|
|
- = new WechatPayValidator(getVerifier(), jsonObject.getString("id"), body);
|
|
|
+ WechatPayValidator wechatPayValidator = new WechatPayValidator(getVerifier(), jsonObject.getString("id"), body);
|
|
|
if (!wechatPayValidator.validate(request)) {
|
|
|
log.error("通知验签失败");
|
|
|
- return null;
|
|
|
+ throw new GlobalException("通知验签失败");
|
|
|
}
|
|
|
log.info("通知验签成功");
|
|
|
return jsonObject;
|