wx_pay 0.3.0

微信支付 api
Documentation

注:当前为测试版

微信支付,rust api

目前版本 apiv3 jsapi

let wx_pay = WxPay {
    appid: WECHAT_MINI_APP_ID,
    mchid: WECHAT_PAY_MCH_ID,
    private_key: WECHAT_PRIVATE_KEY,
    serial_no: WECHAT_PAY_SERIAL,
    apiv3_private_key: WECHAT_PAY_APIV3,
    notify_url: WECHAT_PAY_NOTIFY_URL,
};

jsapi 支付,返回客户端的支付参数信息

    wx_pay.jsapi

微信支付订单号查询订单

    wx_pay.get_transactions_by_id

商户订单号查询订单

    wx_pay.get_transactions_by_out_trade_no

关闭订单

    wx_pay.close

退款申请

    wx_pay.refund

查寻单笔退款

    wx_pay.get_refund

后台接口,以actix-web为例

use wx_pay::{decode_wx_pay, Amount, Jsapi, Payer, WxPayData, WxPay, WxPayNotify};
use wx_pay::TradeState;
use wx_pay::decode::{WxPayNotify, decode_wx_pay};
use wx_pay::verification::WxPayVerification;

#[post("/pay/wx/v3/test")]
pub async fn pay_wx_v3_test() -> Result<impl Responder> {
    let wxpay = WxPay {
        appid: WECHAT_MINI_APP_ID,
        mchid: WECHAT_PAY_MCH_ID,
        private_key: WECHAT_PRIVATE_KEY,
        serial_no: WECHAT_PAY_SERIAL,
        apiv3_private_key: WECHAT_PAY_APIV3,
        notify_url: WECHAT_PAY_NOTIFY_URL,
    };
    let data: WxPayData = wxpay
        .jsapi(&Jsapi {
            description: "测试122".to_string(),
            out_trade_no: rand_string(16),
            amount: Amount {
                total: 1,
                ..Default::default()
            },
            payer: Payer { openid },
            ..Default::default()
        })
        .await
        .unwrap();
    return Ok(web::Json(data));
}

/// 微信支付 回调
#[post("/pay/notify_url/action")]
pub async fn pay_notify_url_action(body: web::Bytes, req: actix_web::HttpRequest) -> Result<impl Responder> {
    // 1. 用原始 body 进行验签
    let body_str = std::str::from_utf8(&body)?;
    // WECHAT_PAY_PUBKEY 为 微信支付公钥
    let verification = WxPayVerification::new(WECHAT_PAY_PUBKEY.to_string());
    // 获取验签所需的 HTTP 头信息
    let timestamp = req
        .headers()
        .get("Wechatpay-Timestamp")
        .and_then(|v| v.to_str().ok())
        .unwrap_or("");
    let nonce = req
        .headers()
        .get("Wechatpay-Nonce")
        .and_then(|v| v.to_str().ok())
        .unwrap_or("");
    let signature = req
        .headers()
        .get("Wechatpay-Signature")
        .and_then(|v| v.to_str().ok())
        .unwrap_or("");
    if WxPayVerification::is_test_signature(signature) {
        return Err(error::ErrorNotAcceptable("测试签名"));
    }
    let is_verifi_ok = verification
        .verify_response(timestamp, nonce, body_str, signature)
        .map_err(|e| error::ErrorInternalServerError(e))?;
    if !is_verifi_ok {
        return Err(error::ErrorNotAcceptable("签名验证失败"));
    }

    // 2. 验签成功后再解析 JSON
    let params: WxPayNotify = serde_json::from_slice(&body)?;
    if params.event_type != "TRANSACTION.SUCCESS".to_string() {
        // 没返回成功
        return Err(error::ErrorMethodNotAllowed("失败"));
    }
    let data =
        decode_wx_pay(WECHAT_PAY_APIV3, params).map_err(|e| error::ErrorInternalServerError(e))?;
    if data.trade_state != TradeState::SUCCESS {
        // 没返回成功
        return Err(error::ErrorMethodNotAllowed("失败"));
    }
    println!("回调解密数据: {:#?}", data);

    // ----- 你的业务逻辑 -----

    Ok(web::Json(()))
}

公众号/小程序端:

let res = await post("/pay/wx/v3/test");
wx.requestPayment({
  timeStamp: res.data.time_stamp,
  nonceStr: res.data.nonce_str,
  package: res.data.package,
  signType: res.data.sign_type,
  paySign: res.data.pay_sign,
  success(res2) {
    console.log("支付返回", res2);
  },
});