wechat-minapp

A rust sdk for wechat miniprogram server api

基于 open-wechat 修改

首先感谢 headironc 的项目，之所以重新发一包，而不是 pr 是因为我改了很多结构，现在 wechat-minapp 的调用方式出现了很大的不同。

actix web + 小程序端 完整示例

功能

• 获取访问令牌
• 用户登录凭证校验
• 解析用户信息
• 获取用户手机号
• 生成小程序码
• 内容安全检测
• 生成小程序链接

用法

获取 access token

use  wechat_minapp::client::{WechatMinapp, 
NormalToken, MemoryTokenStorage, ReqwestHttpClient};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let app_id = "your app id";
    let app_secret = "your app secret";
    let http_client = Arc::new(ReqwestHttpClient::new());
    let token_type = Arc::new(NormalToken::new(
        &app_id,
        &secret,
        http_client.clone(),
    ));
    let token_storage = Arc::new(MemoryTokenStorage::new(token_type));
    let client =  WechatMinapp::custom(http_client, token_storage)

    let access_token = client.token().await?;

    Ok(())
}

获取 stable access token

use wechat_minapp::client::WechatMinapp;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let app_id = "your app id";
    let app_secret = "your app secret";

    let client = WechatMinapp::new(app_id, app_secret);
    let access_token = client.token().await?;

    Ok(())
}

登录

use wechat_minapp::client::WechatMinapp;
use wechat_minapp::user::{User, Contact};
use serde::Deserialize;

use crate::{Error, state::AppState};
use actix_web::{Responder, web};

#[derive(Deserialize, Default)]
#[serde(default)]
pub struct Logger {
   pub code: String,
}

pub async fn login(
    state: web::Data<AppState>,
    logger: web::Json<Logger>,
) -> Result<impl Responder, Error> {
    let user = User::new(state.client);
    let credential = user.login(&logger.code).await?;

    Ok(())
}

解码用户信息

use wechat_minapp::client::WechatMinapp;
use wechat_minapp::user::{User, Contact};
use serde::Deserialize;

use crate::{Error, state::AppState};
use actix_web::{Responder, web};

#[derive(Deserialize, Default)]
pub struct EncryptedPayload {
   pub code: String,
   pub encrypted_data: String,
   pub iv: String,
}

pub async fn user_info(
    state: web::Data<AppState>,
    payload: web::Json<EncryptedPayload>,
) -> Result<impl Responder, Error> {
    let client = state.wechat_minapp.client();
    let user = User::new(client);
    let credential = user.login(&payload.code).await?;
    let user_info = credential.decrypt(&payload.encrypted_data, &payload.iv)?;

    Ok(web::Json(user_info))
}

获取用户手机号

use wechat_minapp::client::WechatMinapp;
use wechat_minapp::user::User;
use serde::Deserialize;

use crate::{Error, state::AppState};
use actix_web::{Responder, web};

#[derive(Deserialize, Default)]
pub struct PhonePayload {
   pub code: String,
   pub openid: Option<String>,
}

pub async fn get_phone_num(
    state: web::Data<AppState>,
    payload: web::Json<PhonePayload>,
) -> Result<impl Responder, Error> {
     let user = User::new(state.client);
     let phone = user.get_contact(&payload.code,&payload.openid).await?;

    Ok(web::Json(phone))
}

生成小程序码

use use wechat_minapp::client::WechatMinapp;
use wechat_minapp::qr::{QrCodeArgs,Qr, MinappEnvVersion};
use serde::Deserialize;

use crate::{Error, state::AppState};
use actix_web::{Responder, web};


pub async fn get_user_qr(
    user: AuthenticatedUser,
    state: web::Data<AppState>,
) -> Result<impl Responder, Error> {

    let page:&str = "/index";
    let qr_args = QrCodeArgs::builder().path(&page).build()?;
    let qr = Qr::new(state.client);
    let buffer = qr.qr_code(qr_args).await?;

    Ok(buffer)
}

检查文本内容安全

use wechat_minapp::minapp_security::{Args, Scene,MinappSecurity};
use wechat_minapp::client::WechatMinapp;
use crate::{Error, state::AppState};
use actix_web::{Responder, web};
use serde::{Deserialize,Serialize};

#[derive(Deserialize,Serialize)]
pub struct ContentCheck {
   pub content: String,
   pub scene: Scene,
}

pub async fn get_user_qr(
    user: AuthenticatedUser,
    state: web::Data<AppState>,
    date:web::Json<ContentCheck>
) -> Result<impl Responder, Error> {

let args = Args::builder()
        .content(&data.content)
        .scene(data.scene)
        .openid(user.openid)
        .build()?;
    let security = MinappSecurity::new(state.client);
    let result = security.msg_sec_check(args).await?;
    
    if result.is_pass() {
        println!("内容安全，可以发布");
    } else if result.needs_review() {
        println!("内容需要人工审核");
    } else {
        println!("内容有风险，建议修改");
    }
    
    Ok(web::Json(result))
}

生成电商短链接

use wechat_minapp::link::{Link, ShortLinkArgs};
use wechat_minapp::client::WechatMinapp;
use crate::{Error, state::AppState};
use actix_web::{Responder, web};
use serde::{Deserialize,Serialize};

#[derive(Deserialize,Serialize)]
pub struct ShortLinkDto {
   pub page_url: String,
   pub page_title: Option<String>,
   pub is_permanent:Option<bool>
}

pub async fn get_user_qr(
    state: web::Data<AppState>,
    date:web::Json<ShortLinkDto>
) -> Result<impl Responder, Error> {

    let mut args = ShortLinkArgs::builder().path(date.page_url);
    
    if let Some(page_title)=data.page_title{
      args = args.page_title(page_title);
    }
    
    if let Some(is_permanent)=data.is_permanent{
      args = args.with_permanent(is_permanent);
    }
   
    
    let args = args.build()?;

    let link = Link::new(state.client);
    let result = lik.short_link(args).await?;
    
    Ok(web::Json(result))
}