• 微信转账到零钱2种实现方式，SDK和API对接

    微信官方文档地址

    https://pay.weixin.qq.com/wiki/doc/apiv3/apis/chapter4_3_1.shtml#doc-main

    第一种：SDK方式

    首先引入微信官方的sdk包

    1.         <dependency>
    2.             <groupId>com.github.wechatpay-apiv3groupId>
    3.             <artifactId>wechatpay-javaartifactId>
    4.             <version>0.2.11version>
    5.         dependency>

    代码如下：

    1.  
    2. import cn.hutool.core.util.RandomUtil;
    3. import cn.hutool.core.util.StrUtil;
    4. import com.deliyun.transfer.util.UUIDUtil;
    5. import com.deliyun.transfer.util.WechatPayConstant;
    6. import com.wechat.pay.java.core.Config;
    7. import com.wechat.pay.java.core.RSAAutoCertificateConfig;
    8. import com.wechat.pay.java.service.transferbatch.TransferBatchService;
    9. import com.wechat.pay.java.service.transferbatch.model.InitiateBatchTransferRequest;
    10. import com.wechat.pay.java.service.transferbatch.model.InitiateBatchTransferResponse;
    11. import com.wechat.pay.java.service.transferbatch.model.TransferDetailInput;
    12.  
    13. import java.util.ArrayList;
    14. import java.util.List;
    15.  
    16. public class BatchTransfer {
    17.  
    18.     /**
    19.      * 商户号
    20.      */
    21.     public static String merchantId = "1********";
    22.     /**
    23.      * 商户API私钥路径
    24.      */
    25.     public static String privateKeyPath = "F:apiclient_key.pem";
    26.     /**
    27.      * 商户证书序列号
    28.      */
    29.     public static String merchantSerialNumber = "3860*********************E7447";
    30.     /**
    31.      * 商户APIV3密钥
    32.      */
    33.     public static String apiV3Key = "V**********************************V";
    34.     public static TransferBatchService service;
    35.  
    36.     public static void main(String[] args) {
    37.  
    38.         Config config = new RSAAutoCertificateConfig.Builder()
    39.                 .merchantId(merchantId)
    40.                 .privateKeyFromPath(privateKeyPath)
    41.                 .merchantSerialNumber(merchantSerialNumber)
    42.                 .apiV3Key(apiV3Key)
    43.                 .build();
    44.         service = new TransferBatchService.Builder().config(config).build();
    45.  
    46.         String out_batch_no = RandomUtil.randomNumbers(10);
    47.         out_batch_no = StrUtil.concat(true, "sc", out_batch_no);
    48.  
    49.         InitiateBatchTransferRequest initiateBatchTransferRequest = new InitiateBatchTransferRequest();
    50.         initiateBatchTransferRequest.setAppid(WechatPayConstant.APP_ID);
    51.         initiateBatchTransferRequest.setOutBatchNo(out_batch_no);
    52.         initiateBatchTransferRequest.setBatchName("2019年1月深圳分部报销单");
    53.         initiateBatchTransferRequest.setBatchRemark("2019年1月深圳分部报销单");
    54.         initiateBatchTransferRequest.setTotalAmount(100l);
    55.         initiateBatchTransferRequest.setTotalNum(1);
    56.  
    57.         List transferDetailListList = new ArrayList<>();
    58.         TransferDetailInput transferDetailInput = new TransferDetailInput();
    59.         transferDetailInput.setOutDetailNo(UUIDUtil.getUUID());
    60.         transferDetailInput.setTransferAmount(100l);
    61.         transferDetailInput.setTransferRemark("2020年4月报销");
    62.         transferDetailInput.setOpenid("o_***************************");
    63. //        transferDetailInput.setUserName(
    64. //                "757b340b45ebef5467rter35gf464344v3542sdf4t6re4tb4f54ty45t4yyry45");
    65.         transferDetailListList.add(transferDetailInput);
    66.         initiateBatchTransferRequest.setTransferDetailList(
    67.                 transferDetailListList);
    68.         initiateBatchTransferRequest.setTransferSceneId("1000");
    69.         InitiateBatchTransferResponse response =
    70.                 service.initiateBatchTransfer(initiateBatchTransferRequest);
    71.         System.out.println(response);
    72.     }
    73. }

    第二种：API方式

    协议对象

    1. public class Transfer {
    2.     private String appid; // 直连商户的appid
    3.  
    4.     private String out_batch_no; // 商家批次单号
    5.     private String batch_name = "分润红包"; // 该笔批量转账的名称：
    6.     private String batch_remark = "分润红包"; // 转账说明，UTF8编码，最多允许32个字符
    7.  
    8.     private int total_amount; // 转账总金额：分
    9.     private int total_num = 1; // 转账总笔数
    10.  
    11.     private List transfer_detail_list; // 发起批量转账的明细列表，最多三千笔
    12.  
    13.     public Transfer(String appid, String out_batch_no, int total_amount, List transfer_detail_list) {
    14.         this.appid = appid;
    15.         this.out_batch_no = out_batch_no;
    16.         this.total_amount = total_amount;
    17.         this.transfer_detail_list = transfer_detail_list;
    18.     }
    19.  
    20.     public String getAppid() {
    21.         return appid;
    22.     }
    23.  
    24.     public void setAppid(String appid) {
    25.         this.appid = appid;
    26.     }
    27.  
    28.     public String getOut_batch_no() {
    29.         return out_batch_no;
    30.     }
    31.  
    32.     public void setOut_batch_no(String out_batch_no) {
    33.         this.out_batch_no = out_batch_no;
    34.     }
    35.  
    36.     public String getBatch_name() {
    37.         return batch_name;
    38.     }
    39.  
    40.     public void setBatch_name(String batch_name) {
    41.         this.batch_name = batch_name;
    42.     }
    43.  
    44.     public String getBatch_remark() {
    45.         return batch_remark;
    46.     }
    47.  
    48.     public void setBatch_remark(String batch_remark) {
    49.         this.batch_remark = batch_remark;
    50.     }
    51.  
    52.     public int getTotal_amount() {
    53.         return total_amount;
    54.     }
    55.  
    56.     public void setTotal_amount(int total_amount) {
    57.         this.total_amount = total_amount;
    58.     }
    59.  
    60.     public int getTotal_num() {
    61.         return total_num;
    62.     }
    63.  
    64.     public void setTotal_num(int total_num) {
    65.         this.total_num = total_num;
    66.     }
    67.  
    68.     public List getTransfer_detail_list() {
    69.         return transfer_detail_list;
    70.     }
    71.  
    72.     public void setTransfer_detail_list(List transfer_detail_list) {
    73.         this.transfer_detail_list = transfer_detail_list;
    74.     }
    75.  
    76.     public static class TransferDetailList {
    77.  
    78.         private String out_detail_no = UUIDUtil.getUUID(); // 商户系统内部区分转账批次单下不同转账明细单的唯一标识，要求此参数只能由数字、大小写字母组成
    79.         private int transfer_amount; // 转账金额单位为分
    80.         private String transfer_remark = "分润红包"; //转账备注
    81.         private String openid; // 用户在直连商户应用下的用户标示
    82.  
    83.         public TransferDetailList( int transfer_amount, String openid) {
    84.             this.transfer_amount = transfer_amount;
    85.             this.openid = openid;
    86.         }
    87.  
    88.         public String getOut_detail_no() {
    89.             return out_detail_no;
    90.         }
    91.  
    92.         public void setOut_detail_no(String out_detail_no) {
    93.             this.out_detail_no = out_detail_no;
    94.         }
    95.  
    96.         public int getTransfer_amount() {
    97.             return transfer_amount;
    98.         }
    99.  
    100.         public void setTransfer_amount(int transfer_amount) {
    101.             this.transfer_amount = transfer_amount;
    102.         }
    103.  
    104.         public String getTransfer_remark() {
    105.             return transfer_remark;
    106.         }
    107.  
    108.         public void setTransfer_remark(String transfer_remark) {
    109.             this.transfer_remark = transfer_remark;
    110.         }
    111.  
    112.         public String getOpenid() {
    113.             return openid;
    114.         }
    115.  
    116.         public void setOpenid(String openid) {
    117.             this.openid = openid;
    118.         }
    119.     }
    120. }

    工具类 CertUtil.java

    1. public class CertUtil {
    2.  
    3.     public static String APICLIENT_KEY = "conf/cert/apiclient_key.pem";
    4.     public static String APICLIENT_CERT = "conf/cert/apiclient_cert.pem";
    5.  
    6.     /**
    7.      * 获取私钥。
    8.      *
    9.      * @return 私钥对象
    10.      */
    11.     public static PrivateKey getPrivateKey() throws IOException {
    12.         InputStream instream = CertUtil.class.getClassLoader().getResourceAsStream(APICLIENT_KEY);
    13.         String content = new String(ByteStreams.toByteArray(instream), StandardCharsets.UTF_8);
    14.  
    15. //		String content = new String(Files.readAllBytes(Paths.get(APICLIENT_KEY)), StandardCharsets.UTF_8);
    16.         try {
    17.             String privateKey = content.replace("-----BEGIN PRIVATE KEY-----", "").replace("-----END PRIVATE KEY-----", "").replaceAll("\\s+", "");
    18.             KeyFactory kf = KeyFactory.getInstance("RSA");
    19.             return kf.generatePrivate(new PKCS8EncodedKeySpec(Base64.decodeBase64(privateKey)));
    20.         } catch (NoSuchAlgorithmException e) {
    21.             throw new RuntimeException("当前Java环境不支持RSA", e);
    22.         } catch (InvalidKeySpecException e) {
    23.             throw new RuntimeException("无效的密钥格式");
    24.         }
    25.     }
    26.  
    27.     /**
    28.      * 获取商户证书。
    29.      *
    30.      * @return X509证书
    31.      */
    32.     public static X509Certificate getCertificate() throws IOException {
    33. //		InputStream fis = new FileInputStream(APICLIENT_CERT);
    34.         InputStream fis = CertUtil.class.getClassLoader().getResourceAsStream(APICLIENT_CERT);
    35.         ;
    36.         try (BufferedInputStream bis = new BufferedInputStream(fis)) {
    37.             CertificateFactory cf = CertificateFactory.getInstance("X509");
    38.             X509Certificate cert = (X509Certificate) cf.generateCertificate(bis);
    39.             cert.checkValidity();
    40.             return cert;
    41.         } catch (CertificateExpiredException e) {
    42.             throw new RuntimeException("证书已过期", e);
    43.         } catch (CertificateNotYetValidException e) {
    44.             throw new RuntimeException("证书尚未生效", e);
    45.         } catch (CertificateException e) {
    46.             throw new RuntimeException("无效的证书文件", e);
    47.         }
    48.     }
    49.  
    50.     /**
    51.      * 获取商户证书序列号
    52.      *
    53.      * @return
    54.      * @throws IOException
    55.      */
    56.     public static String getSerialNo() throws IOException {
    57.         X509Certificate certificate = getCertificate();
    58.         return certificate.getSerialNumber().toString(16).toUpperCase();
    59.     }
    60.  
    61.     public static void main(String[] args) {
    62.         try {
    63.             System.out.println(CertUtil.getCertificate());
    64.         } catch (Exception e) {
    65.             e.printStackTrace();
    66.         }
    67.     }
    68. }

    HttpUrl工具类

    1. public class HttpUrlUtil {
    2.  
    3.     public static String SCHEMA = "WECHATPAY2-SHA256-RSA2048";
    4.     public static String merchantId = WechatPayConstant.MCH_ID; // 服务商
    5.  
    6.     public static String POST = "POST";
    7.     public static String GET = "GET";
    8.  
    9.     public static String TRANSFER_URL = "https://api.mch.weixin.qq.com/v3/transfer/batches"; // 转账
    10.  
    11.     public static String postTransfer(String body) {
    12.         String authorization = getToken(POST, TRANSFER_URL, body);
    13.         String returnMsg = HttpRequest.post(TRANSFER_URL)
    14.                 .header("Authorization", authorization)
    15.                 .header("Wechatpay-Serial", WechatPayConstant.merchantSerialNumber)
    16.                 .body(body)
    17.                 .execute().body();
    18.         JSONObject returnTransferInfo = JSON.parseObject(returnMsg);
    19.         return returnTransferInfo.toJSONString();
    20.     }
    21.  
    22.     /**
    23.      * 获取加密串
    24.      *
    25.      * @param method
    26.      * @param url
    27.      * @param body
    28.      * @return
    29.      */
    30.     public static String getToken(String method, String url, String body) {
    31.         String nonceStr = UUIDUtil.getUUID();
    32.         long timestamp = System.currentTimeMillis() / 1000;
    33.         HttpUrl httpUrl = HttpUrl.parse(url);
    34.         String message = buildMessage(method, httpUrl, timestamp, nonceStr, body);
    35.         String signature = null;
    36.         String certificateSerialNo = null;
    37.         try {
    38.             signature = sign(message.getBytes("utf-8"));
    39.             certificateSerialNo = CertUtil.getSerialNo();
    40.         } catch (Exception e) {
    41.             e.printStackTrace();
    42.         }
    43.         return SCHEMA + " mchid=\"" + merchantId + "\"," + "nonce_str=\"" + nonceStr + "\"," + "timestamp=\"" + timestamp + "\"," + "serial_no=\""
    44.                 + certificateSerialNo + "\"," + "signature=\"" + signature + "\"";
    45.     }
    46.  
    47.     /**
    48.      * 得到签名字符串
    49.      */
    50.     public static String sign(byte[] message) throws Exception {
    51.         Signature sign = Signature.getInstance("SHA256withRSA");
    52.         PrivateKey privateKey = CertUtil.getPrivateKey();
    53.         sign.initSign(privateKey);
    54.         sign.update(message);
    55.         return Base64.getEncoder().encodeToString(sign.sign());
    56.     }
    57.  
    58.     public static String buildMessage(String method, HttpUrl url, long timestamp, String nonceStr, String body) {
    59.         String canonicalUrl = url.encodedPath();
    60.         if (url.encodedQuery() != null) {
    61.             canonicalUrl += "?" + url.encodedQuery();
    62.         }
    63.         return method + "\n" + canonicalUrl + "\n" + timestamp + "\n" + nonceStr + "\n" + body + "\n";
    64.     }

    UUID工具类

    1. public class UUIDUtil {
    2.  
    3.     public static String getUUID () {
    4.         return UUID.randomUUID().toString().replace("-", "");
    5.     }
    6.  
    7.     public static void main(String[] args) {
    8.         System.out.println(UUIDUtil.getUUID());
    9.     }
    10. }

    常量类 WechatPayConstant.java

    1. public class WechatPayConstant {
    2.  
    3.     /**
    4.      * appId
    5.      */
    6.     public static String APP_ID = "wx64************";
    7.  
    8.     /**
    9.      * 商户号
    10.      */
    11.     public static String MCH_ID = "1***********";
    12.  
    13.     /**
    14.      * API_V3密钥
    15.      */
    16.     public static String API_V3KEY = "V*****************************";
    17.  
    18.     /**
    19.      * 证书序列号
    20.      */
    21.     public static String merchantSerialNumber = "************************************";
    22. }

    转账业务类

    1. public class TransferService {
    2.  
    3.     public static void exe(String openId) {
    4.  
    5.         String out_batch_no = RandomUtil.randomNumbers(10);
    6.         out_batch_no = StrUtil.concat(true, "sc", out_batch_no);
    7.  
    8.  
    9.         int transfer_amount = 100;
    10.         Transfer.TransferDetailList transferDetailList = new Transfer.TransferDetailList(transfer_amount, openId);
    11.         List list = new ArrayList<>();
    12.         list.add(transferDetailList);
    13.         Transfer transfer = new Transfer(WechatPayConstant.APP_ID, out_batch_no, transfer_amount, list);
    14.         String str = HttpUrlUtil.postTransfer(JSONObject.toJSONString(transfer));
    15.         System.out.println("转账结果返回：" + str);
    16.     }
    17.  
    18.     public static void main(String[] args) {
    19.  
    20.         String openId = "o_F*******************************";
    21.         TransferService.exe(openId);
    22.     }
    23.  
    24. }

  • 相关阅读:
    CentOS Docker 安装 & 常用命令
    Java发展简史
    【数据结构】二叉树
    SpringBoot、MyBatis、PostgreSQL储存JSON、对象等自定义TypeHandler
    Vue工程化中创建全局组件、extend创建组件、extends配置组件、异步组件
    你的 Sleep 服务会梦到服务网格外的 bookinfo 吗
    Python学习一：基本内容
    基于ssm+vue员工工资管理系统
    jvm的jshell，学生的工具
    【C+】C++11 —— 线程库
  • 原文地址：https://blog.csdn.net/tm7796/article/details/132735094