package com.doumee.api.business; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.doumee.config.wx.TransferDetailEntityNew; import com.doumee.config.wx.WxMiniConfig; import com.doumee.core.constants.Constants; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.model.ApiResponse; import com.doumee.service.business.OrdersService; import com.doumee.service.business.WithdrawalOrdersService; import com.wechat.pay.java.core.Config; import com.wechat.pay.java.core.RSAAutoCertificateConfig; import com.wechat.pay.java.core.RSAPublicKeyConfig; import com.wechat.pay.java.core.notification.NotificationConfig; import com.wechat.pay.java.core.notification.NotificationParser; import com.wechat.pay.java.core.notification.RequestParam; import com.wechat.pay.java.service.partnerpayments.jsapi.model.Transaction; import com.wechat.pay.java.service.refund.model.RefundNotification; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.apache.shiro.mgt.DefaultSecurityManager; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.CrossOrigin; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RestController; import javax.servlet.ServletInputStream; import javax.servlet.http.HttpServletRequest; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.util.HashMap; import java.util.Map; /** * Created by IntelliJ IDEA. * 支付回调 * @Author : Rk * @create 2023/2/23 13:49 */ @Slf4j @RestController @CrossOrigin public class PaymentCallback { @Autowired private OrdersService ordersService; @Autowired private WithdrawalOrdersService withdrawalOrdersService; /** * 【微信支付】异步通知 * * @return */ @PostMapping("/web/wxPayNotify") public ApiResponse wxPay_notify(HttpServletRequest request) { log.error("微信支付回调结果开始===========" ); try { ServletInputStream inputStream = request.getInputStream(); StringBuffer stringBuffer = new StringBuffer(); BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream)); String s; //读取回调请求体 while ((s = bufferedReader.readLine()) != null) { stringBuffer.append(s); } String body = stringBuffer.toString(); String timestamp = request.getHeader("Wechatpay-Timestamp"); String nonce = request.getHeader("Wechatpay-Nonce"); String signType = request.getHeader("Wechatpay-Signature-Type"); String serialNo = request.getHeader("wechatpay-Serial"); String signature = request.getHeader("Wechatpay-Signature"); RequestParam requestParam = new RequestParam.Builder() .serialNumber(serialNo) .nonce(nonce) .signType(signType) .signature(signature) .timestamp(String.valueOf(timestamp)) .body(body) .build(); NotificationConfig config = new RSAPublicKeyConfig.Builder() .merchantId(WxMiniConfig.wxProperties.getMchId()) .privateKeyFromPath(WxMiniConfig.wxProperties.getPrivateKeyPath()) .publicKeyFromPath(WxMiniConfig.wxProperties.getPubKeyPath()) .publicKeyId(WxMiniConfig.wxProperties.getPayPublicKeyId()) .merchantSerialNumber(WxMiniConfig.wxProperties.getSerialNumer()) .apiV3Key(WxMiniConfig.wxProperties.getApiV3Key()) .build(); NotificationParser parser = new NotificationParser(config); Transaction result = parser.parse(requestParam, Transaction.class); log.error("支付回调信息：{}"+ JSONObject.toJSONString(result)); //自定义订单号 String outTradeNo = result.getOutTradeNo(); //微信订单号 String paymentNo = result.getTransactionId(); if ("SUCCESS".equals(result.getTradeState().name())) { // 支付成功ge switch (result.getAttach()) { //支付订单回调 case "createOrder": { ordersService.payNotify(outTradeNo,paymentNo); break; } } } else { // 支付失败 switch (result.getAttach()) { case "createOrder": { break; } } } log.error("微信支付回调结果结束===========" ); return ApiResponse.success("处理成功!"); } catch (Exception e) { e.printStackTrace(); log.error("微信回调结果异常,异常原因{}", e.getLocalizedMessage()); return ApiResponse.failed(""); } } @PostMapping("/web/wxRefundNotify") public ApiResponse wxRefundNotify(HttpServletRequest request) { log.error("微信退款回调结果开始===========" ); try { DefaultSecurityManager securityManager = new DefaultSecurityManager(); SecurityUtils.setSecurityManager(securityManager); ServletInputStream inputStream = request.getInputStream(); StringBuffer stringBuffer = new StringBuffer(); BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream)); String s; //读取回调请求体 while ((s = bufferedReader.readLine()) != null) { stringBuffer.append(s); } String body = stringBuffer.toString(); String timestamp = request.getHeader("Wechatpay-Timestamp"); String nonce = request.getHeader("Wechatpay-Nonce"); String signType = request.getHeader("Wechatpay-Signature-Type"); String serialNo = request.getHeader("wechatpay-Serial"); String signature = request.getHeader("Wechatpay-Signature"); RequestParam requestParam = new RequestParam.Builder() .serialNumber(serialNo) .nonce(nonce) .signType(signType) .signature(signature) .timestamp(String.valueOf(timestamp)) .body(body) .build(); NotificationConfig config = /*new RSAAutoCertificateConfig.Builder() .merchantId(WxMiniConfig.wxProperties.getMchId()) .privateKeyFromPath(WxMiniConfig.wxProperties.getPrivateKeyPath()) .merchantSerialNumber(WxMiniConfig.wxProperties.getSerialNumer()) .apiV3Key(WxMiniConfig.wxProperties.getApiV3Key()) .build();*/ new RSAPublicKeyConfig.Builder() .merchantId(WxMiniConfig.wxProperties.getMchId()) .privateKeyFromPath(WxMiniConfig.wxProperties.getPrivateKeyPath()) .publicKeyFromPath(WxMiniConfig.wxProperties.getPubKeyPath()) .publicKeyId(WxMiniConfig.wxProperties.getPayPublicKeyId()) .merchantSerialNumber(WxMiniConfig.wxProperties.getSerialNumer()) .apiV3Key(WxMiniConfig.wxProperties.getApiV3Key()) .build(); NotificationParser parser = new NotificationParser(config); RefundNotification result = parser.parse(requestParam, RefundNotification.class); // if ("SUCCESS".equals(result.getRefundStatus().name())) { // 支付成功ge ordersService.refundCallback(result); // } return ApiResponse.success("处理成功"); } catch (Exception e) { e.printStackTrace(); log.error("微信回调结果异常,异常原因{}", e.getLocalizedMessage()); return ApiResponse.failed(""); } } /** * 微信商户零线转账 - 回调通知 * @Context注解 把HTTP请求上下文对象注入进来，HttpServletRequest、HttpServletResponse、UriInfo 等 * @return */ @PostMapping(value = "/web/wechat/transferNotify") public ApiResponse transferNotify( HttpServletRequest request) { Map errMap = new HashMap<>(); try { log.error("微信商户零线转账 - 回调通知 /wxpay/callback"); Config config = new RSAPublicKeyConfig.Builder() .merchantId(WxMiniConfig.wxProperties.getSubMchId()) //微信支付的商户号 .privateKeyFromPath(WxMiniConfig.wxProperties.getWechatPrivateKeyPath()) // 商户API证书私钥的存放路径 .publicKeyFromPath(WxMiniConfig.wxProperties.getWechatPubKeyPath()) //微信支付公钥的存放路径 .publicKeyId(WxMiniConfig.wxProperties.getWechatPayPublicKeyId()) //微信支付公钥ID .merchantSerialNumber(WxMiniConfig.wxProperties.getWechatSerialNumer()) //商户API证书序列号 .apiV3Key(WxMiniConfig.wxProperties.getWechatApiV3Key()) //APIv3密钥 .build(); TransferDetailEntityNew entity = wxSuccessCallback(request,config); log.error("transfer ok.{}",entity); //回调成功后处理自己的业务 if(entity != null){ if((entity.getState().equals(Constants.SUCCESS) || entity.getState().equals(Constants.CANCELLED) || entity.getState().equals(Constants.FAIL)) && StringUtils.isNotBlank(entity.getOutBillNo())){ withdrawalOrdersService.transferSuccess(entity.getOutBillNo(),entity.getState().equals(Constants.SUCCESS)?true:false); } } return ApiResponse.success("处理成功"); } catch (Exception e) { log.error("微信商户零线转账 - 回调通知 /wxpay/callback：异常！", e); errMap.put("code", "FAIL"); errMap.put("message", "服务器内部错误"); return ApiResponse.failed("处理失败"); } } public TransferDetailEntityNew wxSuccessCallback(HttpServletRequest request,Config config) throws IOException { String requestBody = getBodyString(request, "UTF-8"); //证书序列号（微信平台） 验签的“微信支付平台证书”所对应的平台证书序列号 String wechatPaySerial = request.getHeader("Wechatpay-Serial"); //微信传递过来的签名 验签的签名值 String wechatSignature = request.getHeader("Wechatpay-Signature"); //验签的时间戳 String wechatTimestamp = request.getHeader("Wechatpay-Timestamp"); //验签的随机字符串 String wechatpayNonce = request.getHeader("Wechatpay-Nonce"); // 1. 构造 RequestParam RequestParam requestParam = new RequestParam.Builder() .serialNumber(wechatPaySerial) .nonce(wechatpayNonce) .signature(wechatSignature) .timestamp(wechatTimestamp) .body(requestBody) .build(); // 2. 构建Config RSAPublicKeyConfig // Config config = new RSAPublicKeyConfig.Builder() // .merchantId(WxMiniConfig.wxProperties.getMchId()) //微信支付的商户号 // .privateKeyFromPath(WxMiniConfig.wxProperties.getPrivateKeyPath()) // 商户API证书私钥的存放路径 // .publicKeyFromPath(WxMiniConfig.wxProperties.getWechatPubKeyPath()) //微信支付公钥的存放路径 // .publicKeyId(WxMiniConfig.wxProperties.getWechatPayPublicKeyId()) //微信支付公钥ID // .merchantSerialNumber(WxMiniConfig.wxProperties.getSerialNumer()) //商户API证书序列号 // .apiV3Key("") //APIv3密钥 // .build(); log.info("WxPayService.wxPaySuccessCallback request : wechatPaySerial is [{}] , wechatSignature is [{}] , wechatTimestamp is [{}] , wechatpayNonce is [{}] , requestBody is [{}]",wechatPaySerial,wechatSignature,wechatTimestamp,wechatpayNonce,requestBody); // 3. 初始化 NotificationParser NotificationParser parser = new NotificationParser((NotificationConfig) config); try { TransferDetailEntityNew entity = parser.parse(requestParam, TransferDetailEntityNew.class); log.info("WxPayService.wxPaySuccessCallback responseBody: {}", entity != null ? JSON.toJSONString(entity) : null); return entity; } catch (Exception e) { log.error("Exception occurred while processing", e); throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"系统内部错误"); } } /** * 获取post请求中的Body * * @param request httpRequest * @return body字符串 */ public static String getBodyString(HttpServletRequest request, String charSet) throws IOException { StringBuilder sb = new StringBuilder(); InputStream inputStream = null; BufferedReader reader = null; try { inputStream = request.getInputStream(); //读取流并将流写出去,避免数据流中断; reader = new BufferedReader(new InputStreamReader(inputStream, charSet)); String line; while ((line = reader.readLine()) != null) { sb.append(line); } } catch (IOException e) { log.error("获取requestBody异常", e); } finally { inputStream.close(); reader.close(); } return sb.toString(); } }