feat: 新增支付、退款、商家转账批次回调通知解析服务

service/src/example/java/com/wechat/pay/java/service/payments/PaymentNotificationParseServiceExample.java

@@ -0,0 +1,63 @@
+package com.wechat.pay.java.service.payments;
+
+import com.wechat.pay.java.core.RSAAutoCertificateConfig;
+import com.wechat.pay.java.core.exception.MalformedMessageException;
+import com.wechat.pay.java.core.exception.ValidationException;
+import com.wechat.pay.java.core.notification.NotificationConfig;
+import com.wechat.pay.java.core.notification.RequestParam;
+import com.wechat.pay.java.service.payments.model.Transaction;
+
+/** PaymentNotificationParseService使用示例 */
+public class PaymentNotificationParseServiceExample {
+
+  /** 商户号 */
+  public static String merchantId = "190000****";
+
+  /** 商户API私钥路径 */
+  public static String privateKeyPath = "/Users/yourname/your/path/apiclient_key.pem";
+
+  /** 商户证书序列号 */
+  public static String merchantSerialNumber = "5157F09EFDC096DE15EBE81A47057A72********";
+
+  /** 商户APIV3密钥 */
+  public static String apiV3Key = "...";
+
+  public static PaymentNotificationParseService service;
+
+  public static void main(String[] args) {
+    // 初始化商户配置
+    NotificationConfig config =
+        new RSAAutoCertificateConfig.Builder()
+            .merchantId(merchantId)
+            // 使用 com.wechat.pay.java.core.util 中的函数从本地文件中加载商户私钥，商户私钥会用来生成请求的签名
+            .privateKeyFromPath(privateKeyPath)
+            .merchantSerialNumber(merchantSerialNumber)
+            .apiV3Key(apiV3Key)
+            .build();
+
+    // 初始化服务
+    service = new PaymentNotificationParseService.Builder().config(config).build();
+    // ... 调用接口
+    try {
+      RequestParam requestParam =
+          new RequestParam.Builder()
+              .serialNumber("5157F09EFDC096DE15EBE81A47057A72********")
+              .signature("mm/2CMGxo5qDKNk1i7Szn0IiwAUPlfrp********")
+              .timestamp("1723789635")
+              .nonce("614275b63d789bd3a7a472c63d809552")
+              .body("")
+              .signType("WECHATPAY2-SHA256-RSA2048")
+              .build();
+      Transaction transaction = payment(requestParam);
+    } catch (MalformedMessageException e) { // 回调通知参数不正确、解析通知数据失败
+      // 调用e.getMessage()获取信息打印日志或上报监控，更多方法见MalformedMessageException定义
+    } catch (ValidationException e) { // 签名验证失败
+      // 调用e.getMessage()获取信息打印日志或上报监控，更多方法见ValidationException定义
+    }
+  }
+
+  /** 支付回调 */
+  public static Transaction payment(RequestParam requestParam) {
+    return service.payment(requestParam);
+  }
+}

service/src/example/java/com/wechat/pay/java/service/refund/RefundNotificationParseServiceExample.java

@@ -0,0 +1,63 @@
+package com.wechat.pay.java.service.refund;
+
+import com.wechat.pay.java.core.RSAAutoCertificateConfig;
+import com.wechat.pay.java.core.exception.MalformedMessageException;
+import com.wechat.pay.java.core.exception.ValidationException;
+import com.wechat.pay.java.core.notification.NotificationConfig;
+import com.wechat.pay.java.core.notification.RequestParam;
+import com.wechat.pay.java.service.refund.model.RefundNotification;
+
+/** RefundNotificationParseService使用示例 */
+public class RefundNotificationParseServiceExample {
+
+  /** 商户号 */
+  public static String merchantId = "190000****";
+
+  /** 商户API私钥路径 */
+  public static String privateKeyPath = "/Users/yourname/your/path/apiclient_key.pem";
+
+  /** 商户证书序列号 */
+  public static String merchantSerialNumber = "5157F09EFDC096DE15EBE81A47057A72********";
+
+  /** 商户APIV3密钥 */
+  public static String apiV3Key = "...";
+
+  public static RefundNotificationParseService service;
+
+  public static void main(String[] args) {
+    // 初始化商户配置
+    NotificationConfig config =
+        new RSAAutoCertificateConfig.Builder()
+            .merchantId(merchantId)
+            // 使用 com.wechat.pay.java.core.util 中的函数从本地文件中加载商户私钥，商户私钥会用来生成请求的签名
+            .privateKeyFromPath(privateKeyPath)
+            .merchantSerialNumber(merchantSerialNumber)
+            .apiV3Key(apiV3Key)
+            .build();
+
+    // 初始化服务
+    service = new RefundNotificationParseService.Builder().config(config).build();
+    // ... 调用接口
+    try {
+      RequestParam requestParam =
+          new RequestParam.Builder()
+              .serialNumber("5157F09EFDC096DE15EBE81A47057A72********")
+              .signature("mm/2CMGxo5qDKNk1i7Szn0IiwAUPlfrp********")
+              .timestamp("1723789635")
+              .nonce("614275b63d789bd3a7a472c63d809552")
+              .body("")
+              .signType("WECHATPAY2-SHA256-RSA2048")
+              .build();
+      RefundNotification refundNotification = refund(requestParam);
+    } catch (MalformedMessageException e) { // 回调通知参数不正确、解析通知数据失败
+      // 调用e.getMessage()获取信息打印日志或上报监控，更多方法见MalformedMessageException定义
+    } catch (ValidationException e) { // 签名验证失败
+      // 调用e.getMessage()获取信息打印日志或上报监控，更多方法见ValidationException定义
+    }
+  }
+
+  /** 退款回调 */
+  public static RefundNotification refund(RequestParam requestParam) {
+    return service.refund(requestParam);
+  }
+}

service/src/example/java/com/wechat/pay/java/service/transferbatch/TransferBatchNotificationParseServiceExample.java

@@ -0,0 +1,63 @@
+package com.wechat.pay.java.service.transferbatch;
+
+import com.wechat.pay.java.core.RSAAutoCertificateConfig;
+import com.wechat.pay.java.core.exception.MalformedMessageException;
+import com.wechat.pay.java.core.exception.ValidationException;
+import com.wechat.pay.java.core.notification.NotificationConfig;
+import com.wechat.pay.java.core.notification.RequestParam;
+import com.wechat.pay.java.service.transferbatch.model.TransferBatchNotification;
+
+/** TransferBatchNotificationParseService使用示例 */
+public class TransferBatchNotificationParseServiceExample {
+
+  /** 商户号 */
+  public static String merchantId = "190000****";
+
+  /** 商户API私钥路径 */
+  public static String privateKeyPath = "/Users/yourname/your/path/apiclient_key.pem";
+
+  /** 商户证书序列号 */
+  public static String merchantSerialNumber = "5157F09EFDC096DE15EBE81A47057A72********";
+
+  /** 商户APIV3密钥 */
+  public static String apiV3Key = "...";
+
+  public static TransferBatchNotificationParseService service;
+
+  public static void main(String[] args) {
+    // 初始化商户配置
+    NotificationConfig config =
+        new RSAAutoCertificateConfig.Builder()
+            .merchantId(merchantId)
+            // 使用 com.wechat.pay.java.core.util 中的函数从本地文件中加载商户私钥，商户私钥会用来生成请求的签名
+            .privateKeyFromPath(privateKeyPath)
+            .merchantSerialNumber(merchantSerialNumber)
+            .apiV3Key(apiV3Key)
+            .build();
+
+    // 初始化服务
+    service = new TransferBatchNotificationParseService.Builder().config(config).build();
+    // ... 调用接口
+    try {
+      RequestParam requestParam =
+          new RequestParam.Builder()
+              .serialNumber("5157F09EFDC096DE15EBE81A47057A72********")
+              .signature("mm/2CMGxo5qDKNk1i7Szn0IiwAUPlfrp********")
+              .timestamp("1723789635")
+              .nonce("614275b63d789bd3a7a472c63d809552")
+              .body("")
+              .signType("WECHATPAY2-SHA256-RSA2048")
+              .build();
+      TransferBatchNotification transferBatchNotification = transferBatch(requestParam);
+    } catch (MalformedMessageException e) { // 回调通知参数不正确、解析通知数据失败
+      // 调用e.getMessage()获取信息打印日志或上报监控，更多方法见MalformedMessageException定义
+    } catch (ValidationException e) { // 签名验证失败
+      // 调用e.getMessage()获取信息打印日志或上报监控，更多方法见ValidationException定义
+    }
+  }
+
+  /** 商家转账批次回调 */
+  public static TransferBatchNotification transferBatch(RequestParam requestParam) {
+    return service.transferBatch(requestParam);
+  }
+}

service/src/main/java/com/wechat/pay/java/service/payments/PaymentNotificationParseService.java

@@ -0,0 +1,59 @@
+package com.wechat.pay.java.service.payments;
+
+import static java.util.Objects.requireNonNull;
+
+import com.wechat.pay.java.core.exception.MalformedMessageException;
+import com.wechat.pay.java.core.exception.ValidationException;
+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.payments.model.Transaction;
+
+/**
+ * 支付回调通知解析服务
+ *
+ * <p>它用于对 支付回调 进行验签并解析回调报文。
+ */
+public class PaymentNotificationParseService {
+  private final NotificationParser parser;
+
+  private PaymentNotificationParseService(NotificationParser parser) {
+    this.parser = requireNonNull(parser);
+  }
+
+  /** PaymentNotificationParseService构造器 */
+  public static class Builder {
+
+    private NotificationConfig config;
+    private NotificationParser parser;
+
+    public PaymentNotificationParseService.Builder config(NotificationConfig config) {
+      this.config = config;
+      return this;
+    }
+
+    public PaymentNotificationParseService.Builder parser(NotificationParser parser) {
+      this.parser = parser;
+      return this;
+    }
+
+    public PaymentNotificationParseService build() {
+      if (parser == null && config != null) {
+        return new PaymentNotificationParseService(new NotificationParser(config));
+      }
+      return new PaymentNotificationParseService(parser);
+    }
+  }
+
+  /**
+   * 支付回调通知解析
+   *
+   * @param requestParam 解析通知所需要的请求参数
+   * @return 解析后的回调报文
+   * @throws MalformedMessageException 回调通知参数不正确、解析通知数据失败
+   * @throws ValidationException 签名验证失败
+   */
+  public Transaction payment(RequestParam requestParam) {
+    return parser.parse(requestParam, Transaction.class);
+  }
+}

service/src/main/java/com/wechat/pay/java/service/refund/RefundNotificationParseService.java

@@ -0,0 +1,59 @@
+package com.wechat.pay.java.service.refund;
+
+import static java.util.Objects.requireNonNull;
+
+import com.wechat.pay.java.core.exception.MalformedMessageException;
+import com.wechat.pay.java.core.exception.ValidationException;
+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.refund.model.RefundNotification;
+
+/**
+ * 退款回调通知解析服务
+ *
+ * <p>它用于对 退款回调 进行验签并解析回调报文。
+ */
+public class RefundNotificationParseService {
+  private final NotificationParser parser;
+
+  private RefundNotificationParseService(NotificationParser parser) {
+    this.parser = requireNonNull(parser);
+  }
+
+  /** RefundNotificationParseService构造器 */
+  public static class Builder {
+
+    private NotificationConfig config;
+    private NotificationParser parser;
+
+    public RefundNotificationParseService.Builder config(NotificationConfig config) {
+      this.config = config;
+      return this;
+    }
+
+    public RefundNotificationParseService.Builder parser(NotificationParser parser) {
+      this.parser = parser;
+      return this;
+    }
+
+    public RefundNotificationParseService build() {
+      if (parser == null && config != null) {
+        return new RefundNotificationParseService(new NotificationParser(config));
+      }
+      return new RefundNotificationParseService(parser);
+    }
+  }
+
+  /**
+   * 退款回调通知解析
+   *
+   * @param requestParam 解析通知所需要的请求参数
+   * @return 解析后的回调报文
+   * @throws MalformedMessageException 回调通知参数不正确、解析通知数据失败
+   * @throws ValidationException 签名验证失败
+   */
+  public RefundNotification refund(RequestParam requestParam) {
+    return parser.parse(requestParam, RefundNotification.class);
+  }
+}

service/src/main/java/com/wechat/pay/java/service/transferbatch/TransferBatchNotificationParseService.java

@@ -0,0 +1,59 @@
+package com.wechat.pay.java.service.transferbatch;
+
+import static java.util.Objects.requireNonNull;
+
+import com.wechat.pay.java.core.exception.MalformedMessageException;
+import com.wechat.pay.java.core.exception.ValidationException;
+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.transferbatch.model.TransferBatchNotification;
+
+/**
+ * 商家转账批次回调通知解析服务
+ *
+ * <p>它用于对 商家转账批次回调 进行验签并解析回调报文。
+ */
+public class TransferBatchNotificationParseService {
+  private final NotificationParser parser;
+
+  private TransferBatchNotificationParseService(NotificationParser parser) {
+    this.parser = requireNonNull(parser);
+  }
+
+  /** TransferBatchNotificationParseService构造器 */
+  public static class Builder {
+
+    private NotificationConfig config;
+    private NotificationParser parser;
+
+    public TransferBatchNotificationParseService.Builder config(NotificationConfig config) {
+      this.config = config;
+      return this;
+    }
+
+    public TransferBatchNotificationParseService.Builder parser(NotificationParser parser) {
+      this.parser = parser;
+      return this;
+    }
+
+    public TransferBatchNotificationParseService build() {
+      if (parser == null && config != null) {
+        return new TransferBatchNotificationParseService(new NotificationParser(config));
+      }
+      return new TransferBatchNotificationParseService(parser);
+    }
+  }
+
+  /**
+   * 商家转账批次回调通知解析
+   *
+   * @param requestParam 解析通知所需要的请求参数
+   * @return 解析后的回调报文
+   * @throws MalformedMessageException 回调通知参数不正确、解析通知数据失败
+   * @throws ValidationException 签名验证失败
+   */
+  public TransferBatchNotification transferBatch(RequestParam requestParam) {
+    return parser.parse(requestParam, TransferBatchNotification.class);
+  }
+}