---
url: "https://pay.weixin.qq.com/doc/v3/partner/4015949382.md"
title: "业务示例代码"
doc_id: 4015949382
---

>更新时间：2025.09.03

## 1、目标

通过本教程的学习，你应该可以：

- 设置商户违规处置通知的回调地址

- 处理商户平台处置记录回调通知


## 2、业务处理流程

### 2.1、管理回调地址

从业机构/服务商/渠道商需要先设置商户平台处置通知回调URL后，才可以接收对应的违规、拦截、申诉事件通知。

```
package com.java.violation_notification;

// 使用合作伙伴平台创建商户违规通知回调地址接口https://pay.weixin.qq.com/doc/v3/partner/4012471333
import com.java.demo.CreateViolationNotification;
import static com.java.demo.CreateViolationNotification.*;
// 使用合作伙伴平台修改商户违规通知回调地址接口https://pay.weixin.qq.com/doc/v3/partner/4012471330
import com.java.demo.UpdateViolationNotification;
import static com.java.demo.UpdateViolationNotification.*;
// 使用合作伙伴平台删除商户违规通知回调地址接口https://pay.weixin.qq.com/doc/v3/partner/4012471334
import com.java.demo.DeleteViolationNotification;
import static com.java.demo.DeleteViolationNotification.*;
// 使用合作伙伴平台查询商户违规通知回调地址接口https://pay.weixin.qq.com/doc/v3/partner/4012471327
import com.java.demo.GetViolationNotification;
import static com.java.demo.GetViolationNotification.*;

public class ViolationNotificationUrlDemo {
    // TODO: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/partner/4013080340
    // 商户号，是由微信支付系统生成并分配给每个商户的唯一标识符，商户号获取方式参考
    // https://pay.weixin.qq.com/doc/v3/partner/4013080340
    private static String mchid = "19xxxxxxxx";
    // 商户API证书序列号，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013058924
    private static String certificateSerialNo = "1DDE55AD98Exxxxxxxxxx";
    // 商户API证书私钥文件路径，本地文件路径
    private static String privateKeyFilePath = "/path/to/apiclient_key.pem";
    // 微信支付公钥ID，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013038589
    private static String wechatPayPublicKeyId = "PUB_KEY_ID_xxxxxxxxxxxxx";
    // 微信支付公钥文件路径，本地文件路径
    private static String wechatPayPublicKeyFilePath = "/path/to/wxp_pub.pem";

    public static void main(String[] args) {
        String notifyUrl = "https://www.example.com/notify";
        ViolationNotificationUrlDemo demo = new ViolationNotificationUrlDemo();

        // 1. 创建违约通知URL
        String createNotifyUrl = demo.createViolationNotificationUrl(notifyUrl);
        System.out.println("createNotifyUrl: " + createNotifyUrl);

        // 2. 更新违约通知URL
        // String updateNotifyUrl = demo.updateViolationNotificationUrl(notifyUrl);
        // System.out.println("updateNotifyUrl: " + updateNotifyUrl);

        // 3. 删除违约通知URL
        // demo.deleteViolationNotificationUrl();

        // 4. 查询违约通知URL
        String getNotifyUrl = demo.getViolationNotificationUrl();
        System.out.println("getNotifyUrl: " + getNotifyUrl);
    }

    private String createViolationNotificationUrl(String notifyUrl) {
        CreateViolationNotification client = new CreateViolationNotification(
                mchid,
                certificateSerialNo,
                privateKeyFilePath,
                wechatPayPublicKeyId,
                wechatPayPublicKeyFilePath);

        CreateViolationNotificationRequest request = new CreateViolationNotificationRequest();
        request.notifyUrl = notifyUrl;
        try {
            CreateViolationNotificationResponse response = client.run(request);
            System.out.println(response);
            return response.notifyUrl;
        } catch (WXPayUtility.ApiException e) {
            // 创建违约通知URL处理异常处理逻辑
            if (e.getErrorCode().equals("SYSTEM_ERROR")) {
                // 错误：系统错误
                // 解决方式：稍后重试
            } else if (e.getErrorCode().equals("FREQUENCY_LIMITED")) {
                // 错误：限频报错
                // 解决方式：稍后重试
            } else if (e.getErrorCode().equals("ALREADY_EXISTS")) {
                // 错误：用户账户异常
                // 解决方式：说明已经创建成功，可以通过查询接口确认是否符合预期
            } else if (e.getErrorCode().equals("SIGN_ERROR")) {
                // 错误：签名错误
                // 解决方式：检查平台商户证书序列号，证书私钥文件，公钥ID，公钥文件，同时确认下签名过程是不是按照微信支付的签名方式
                // 描述：签名报错，需要确认签名材料和签名流程是否正确
            } else if (e.getErrorCode().equals("PARAM_ERROR")) {
                // 错误：参数错误
                // 解决方式：按照报错返回的message，重新输入请求参数
                // 描述：参数的类型，长度，或者必填选项没有填写等
            } else if (e.getErrorCode().equals("INVALID_REQUEST")) {
                // 错误：请求非法，请求参数正确，但是不符合违约通知URL业务规则
                // 解决方式：根据具体message查看具体哪里不符合业务规则，如果可以修改参数达到符合业务规则的修改请求符合业务规则之后再重试
            } else {
                // 其他类型错误：稍等一会后重试
            }
        }
        return null; // 如果发生异常，返回null
    }

    private String updateViolationNotificationUrl(String notifyUrl) {
        UpdateViolationNotification client = new UpdateViolationNotification(
                mchid,
                certificateSerialNo,
                privateKeyFilePath,
                wechatPayPublicKeyId,
                wechatPayPublicKeyFilePath);

        UpdateViolationNotificationRequest request = new UpdateViolationNotificationRequest();
        request.notifyUrl = notifyUrl;
        try {
            UpdateViolationNotificationResponse response = client.run(request);
            System.out.println(response);
            return response.notifyUrl;
        } catch (WXPayUtility.ApiException e) {
            // 更新违约通知URL处理异常处理逻辑
            if (e.getErrorCode().equals("SYSTEM_ERROR")) {
                // 错误：系统错误
                // 解决方式：稍后重试
            } else if (e.getErrorCode().equals("FREQUENCY_LIMITED")) {
                // 错误：限频报错
                // 解决方式：稍后重试
            } else if (e.getErrorCode().equals("NOT_FOUND")) {
                // 错误：回调地址不存在
                // 解决方式：请检查是否已创建通知回调URL
            } else if (e.getErrorCode().equals("SIGN_ERROR")) {
                // 错误：签名错误
                // 解决方式：检查平台商户证书序列号，证书私钥文件，公钥ID，公钥文件，同时确认下签名过程是不是按照微信支付的签名方式
                // 描述：签名报错，需要确认签名材料和签名流程是否正确
            } else if (e.getErrorCode().equals("PARAM_ERROR")) {
                // 错误：参数错误
                // 解决方式：按照报错返回的message，重新输入请求参数
                // 描述：参数的类型，长度，或者必填选项没有填写等
            } else if (e.getErrorCode().equals("INVALID_REQUEST")) {
                // 错误：请求非法，请求参数正确，但是不符合违约通知URL业务规则
                // 解决方式：根据具体message查看具体哪里不符合业务规则，如果可以修改参数达到符合业务规则的修改请求符合业务规则之后再重试
            } else {
                // 其他类型错误：稍等一会后重试
            }
        }
        return null; // 如果发生异常，返回null
    }

    private void deleteViolationNotificationUrl() {
        DeleteViolationNotification client = new DeleteViolationNotification(
                mchid,
                certificateSerialNo,
                privateKeyFilePath,
                wechatPayPublicKeyId,
                wechatPayPublicKeyFilePath);

        try {
            client.run();
            System.out.println("删除成功");
        } catch (WXPayUtility.ApiException e) {
            // 删除违约通知URL处理异常处理逻辑
            if (e.getErrorCode().equals("SYSTEM_ERROR")) {
                // 错误：系统错误
                // 解决方式：稍后重试
            } else if (e.getErrorCode().equals("FREQUENCY_LIMITED")) {
                // 错误：限频报错
                // 解决方式：稍后重试
            } else if (e.getErrorCode().equals("NOT_FOUND")) {
                // 错误：回调地址不存在
                // 解决方式：请检查是否已创建通知回调URL
            } else if (e.getErrorCode().equals("SIGN_ERROR")) {
                // 错误：签名错误
                // 解决方式：检查平台商户证书序列号，证书私钥文件，公钥ID，公钥文件，同时确认下签名过程是不是按照微信支付的签名方式
                // 描述：签名报错，需要确认签名材料和签名流程是否正确
            } else if (e.getErrorCode().equals("PARAM_ERROR")) {
                // 错误：参数错误
                // 解决方式：按照报错返回的message，重新输入请求参数
                // 描述：参数的类型，长度，或者必填选项没有填写等
            } else if (e.getErrorCode().equals("INVALID_REQUEST")) {
                // 错误：请求非法，请求参数正确，但是不符合违约通知URL业务规则
                // 解决方式：根据具体message查看具体哪里不符合业务规则，如果可以修改参数达到符合业务规则的修改请求符合业务规则之后再重试
            } else {
                // 其他类型错误：稍等一会后重试
            }
        }
    }

    private String getViolationNotificationUrl() {
        GetViolationNotification client = new GetViolationNotification(
                mchid,
                certificateSerialNo,
                privateKeyFilePath,
                wechatPayPublicKeyId,
                wechatPayPublicKeyFilePath);

        try {
            GetViolationNotificationResponse response = client.run();
            System.out.println(response);
            return response.notifyUrl;
        } catch (WXPayUtility.ApiException e) {
            // 查询违约通知URL处理异常处理逻辑
            if (e.getErrorCode().equals("SYSTEM_ERROR")) {
                // 错误：系统错误
                // 解决方式：稍后重试
            } else if (e.getErrorCode().equals("FREQUENCY_LIMITED")) {
                // 错误：限频报错
                // 解决方式：稍后重试
            } else if (e.getErrorCode().equals("NOT_FOUND")) {
                // 错误：回调地址不存在
                // 解决方式：请检查是否已创建通知回调URL
            } else if (e.getErrorCode().equals("SIGN_ERROR")) {
                // 错误：签名错误
                // 解决方式：检查平台商户证书序列号，证书私钥文件，公钥ID，公钥文件，同时确认下签名过程是不是按照微信支付的签名方式
                // 描述：签名报错，需要确认签名材料和签名流程是否正确
            } else if (e.getErrorCode().equals("PARAM_ERROR")) {
                // 错误：参数错误
                // 解决方式：按照报错返回的message，重新输入请求参数
                // 描述：参数的类型，长度，或者必填选项没有填写等
            } else if (e.getErrorCode().equals("INVALID_REQUEST")) {
                // 错误：请求非法，请求参数正确，但是不符合违约通知URL业务规则
                // 解决方式：根据具体message查看具体哪里不符合业务规则，如果可以修改参数达到符合业务规则的修改请求符合业务规则之后再重试
            } else {
                // 其他类型错误：稍等一会后重试
            }
        }
        return null; // 如果发生异常，返回null
    }
}
```

### 2.2、处理商户平台处置记录回调通知

回调地址设置成功后，确保回调地址可以正常访问的情况下，子商户违规处理记录和交易拦截记录时，可以接收到对应的推送

```
import okhttp3.Headers;

// 商户APIv3密钥 https://pay.weixin.qq.com/doc/v3/partner/4013059095
String apiv3Key = "xxxxxxx";
// 微信支付公钥ID，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013038589
String wechatPayPublicKeyId = "PUB_KEY_ID_xxxxxxxxxxxxx";
// 微信支付公钥文件路径，本地文件路径
String wechatPayPublicKeyFilePath = "/path/to/wxp_pub.pem";
// 此处为代码示例，获取微信支付通知 Header 列表
Headers headers = getHeaders();
// 此处为代码示例，获取微信支付通知 Body
String body = getBody();

PublicKey wechatPayPublicKey WXPayUtility.loadPublicKeyFromPath(wechatPayPublicKeyFilePath);

Notification notification;
try {
  // 1. 解析微信支付回调包体，body为商户接收到微信回调的原始信息
  notification  = WXPayUtility.parseNotification(apiv3Key, wechatPayPublicKeyId, wechatPayPublicKey, headers, body);
  // 2. 解析完回调包体之后，可以先返回给微信支付200或者204，表示回调成功
  //    商户再异步处理包体逻辑，这样子能保证微信回调不会超时，微信支付超时多次之后不会再回调
  send2MQ(notification);
} catch (Exception e) {
  // 处理回调异常
}

```