alipay-rs 0.3.2

//! 对alipay api的简单封装
//!
//! # Usage:
//! ```toml
//! [dependencies]
//!
//! alipay-rs = "0.3"
//! # 如果不会修改公共参数，可以不添加以下依赖
//! alipay_params = "0.1"
//!
//! ```
//!
//! # Example:
//! ```rust
//! // 默认的公共参数只包含了最基础的，如果需要增加公共参数，可用通过set_public_params函数实现
//! // 默认的公共参数包含：app_id，charset，sign_type，format，version，method，timestamp，sign
//! // 通过set_public_params设置公共参数，如果参数值为None会自动过滤，重复的参数后面的值会覆盖前面的值
//! // 下面是单笔转账的几种示例
//! use serde::Serialize;
//! use chrono::{Local};
//! use alipay_rs::AlipayParam;
//!
//! // 单笔转账接口需要的参数
//! #[derive(Serialize, Debug)]
//! struct Transfer {
//!     out_biz_no: String,
//!     trans_amount: String,
//!     product_code: String,
//!     biz_scene: String,
//!     payee_info: PayeeInfo,
//! }
//! #[derive(Serialize, Debug)]
//! struct PayeeInfo {
//!     identity: String,
//!     identity_type: String,
//!     name: String,
//! }
//!
//! // 通过post方法访问单笔转账接口
//! async fn naive_fund_transfer() {
//!     let transfer = Transfer {
//!         out_biz_no: format!("{}", Local::now().timestamp()),
//!         trans_amount: String::from("0.1"),
//!         product_code: String::from("TRANS_ACCOUNT_NO_PWD"),
//!         biz_scene: String::from("DIRECT_TRANSFER"),
//!         payee_info: PayeeInfo {
//!             identity: String::from("343938938@qq.com"),
//!             identity_type: String::from("ALIPAY_LOGON_ID"),
//!             name: String::from("陈怀远"),
//!         },
//!     };
//!     let client = alipay_rs::Client::builder()
//!        .app_id("20210xxxxxxxxxxx")
//!        .public_key(include_str!("../公钥.txt"))
//!        .private_key(include_str!("../私钥.txt"))
//!        .app_cert_sn(include_str!("../appCertPublicKey_20210xxxxxxxxxxx.crt"))
//!        .alipay_root_cert_sn(include_str!("../alipayRootCert.crt"))
//!        .finish();
//!     let data:serde_json::Value = client
//!         .post("alipay.fund.trans.uni.transfer", transfer)
//!         .await.unwrap();
//!     println!("{:?}", data);
//! }
//!
//!
//! // 公共参数
//! #[derive(AlipayParam)]
//! struct PublicParams {
//!     app_id: String,
//!     method: Option<String>,
//!     charset: String,
//!     sign_type: String,
//!     sign: Option<String>,
//!     timestamp: Option<String>,
//!     version: String,
//! }
//! // 修改公共参数来访问单笔转账接口
//! async fn fund_transfer_from_public_params() {
//!     let transfer = Transfer {
//!         out_biz_no: format!("{}", Local::now().timestamp()),
//!         trans_amount: String::from("0.1"),
//!         product_code: String::from("TRANS_ACCOUNT_NO_PWD"),
//!         biz_scene: String::from("DIRECT_TRANSFER"),
//!         payee_info: PayeeInfo {
//!             identity: String::from("343938938@qq.com"),
//!             identity_type: String::from("ALIPAY_LOGON_ID"),
//!             name: String::from("陈怀远"),
//!         },
//!     };
//!     let client = alipay_rs::Client::builder()
//!        .app_id("20210xxxxxxxxxxx")
//!        .public_key(include_str!("../公钥.txt"))
//!        .private_key(include_str!("../私钥.txt"))
//!        .app_cert_sn(include_str!("../appCertPublicKey_20210xxxxxxxxxxx.crt"))
//!        .alipay_root_cert_sn(include_str!("../alipayRootCert.crt"))
//!        .finish();
//!     let public_params = PublicParams {
//!         app_id: "20210xxxxxxxxxxx".to_owned(),
//!         method: None,
//!         charset: "utf-8".to_owned(),
//!         sign_type: "RSA2".to_owned(),
//!         sign: None,
//!         timestamp: None,
//!         version: "1.0".to_owned(),
//!     };
//!     let mut client_with_params = client.set_public_params(public_params);
//!     let data:serde_json::Value = client_with_params
//!         .post("alipay.fund.trans.uni.transfer", transfer)
//!         .await.unwrap();
//!     println!("{:?}", data);
//! }
//!
//! // 上传图片文件
//! async fn image_upload() {
//! let file = std::fs::read("./test.png").unwrap();
//! let image = [("image_type", "png"), ("image_name", "test")];
//! let config = alipay_rs::Config::builder()
//!    .app_id("20210xxxxxxxxxxx")
//!    .public_key(include_str!("../公钥.txt"))
//!    .private_key(include_str!("../私钥.txt"))
//!    .app_cert_sn(include_str!("../appCertPublicKey_20210xxxxxxxxxxx.crt"))
//!    .alipay_root_cert_sn(include_str!("../alipayRootCert.crt"))
//!    .finish();
//! let client = config.get_client();
//! let mut client_with_params = client.set_public_params(image);
//!
//! let data:serde_json::Value = client_with_params.post_file("alipay.offline.material.image.upload", "image_content", "test.png", file.as_ref()).await.unwrap();
//! println!("{:?}", data);
//! }
//! #[tokio::main]
//! async fn main() {
//!     // naive_fund_transfer().await;
//!     // fund_transfer().await;
//!     fund_transfer_from_public_params().await;
//! }
//! ```
//! # Example2:
//! ```rust
//! use alipay_rs::AlipayParam;
//! use chrono::Local;
//! use serde::Serialize;
//! use std::collections::HashMap;
//!
//! #[derive(Serialize, Debug)]
//! struct Transfer {
//!     out_biz_no: String,
//!     trans_amount: String,
//!     product_code: String,
//!     biz_scene: String,
//!     payee_info: PayeeInfo,
//! }
//! #[derive(Serialize, Debug)]
//! struct PayeeInfo {
//!     identity: String,
//!     identity_type: String,
//!     name: String,
//! }
//!
//! #[derive(Debug, Serialize)]
//! struct QueryParam {
//!     operation: String,
//!     page_num: i32,
//!     page_size: i32,
//!     item_id_list: Option<String>
//! }
//!
//! async fn ref_query(client: &alipay_rs::Client) {
//!     let query = QueryParam {
//!         operation: "ITEM_PAGEQUERY".to_owned(),
//!         page_num: 1,
//!         page_size: 10,
//!         item_id_list: None,
//!     };
//!
//!     let data:serde_json::Value = client
//!         .post("alipay.open.mini.item.page.query", query)
//!         .await.unwrap();
//!     println!("{:?}", data);
//! }
//!
//! async fn ref_fund_transfer(client: &alipay_rs::Client) {
//!     let transfer = Transfer {
//!         out_biz_no: format!("{}", Local::now().timestamp()),
//!         trans_amount: String::from("0.1"),
//!         product_code: String::from("TRANS_ACCOUNT_NO_PWD"),
//!         biz_scene: String::from("DIRECT_TRANSFER"),
//!         payee_info: PayeeInfo {
//!             identity: String::from("343938938@qq.com"),
//!             identity_type: String::from("ALIPAY_LOGON_ID"),
//!             name: String::from("陈怀远"),
//!         },
//!     };
//!     let data:serde_json::Value = client
//!         .post("alipay.fund.trans.uni.transfer", transfer)
//!         .await.unwrap();
//!     println!("{:?}", data);
//! }
//! #[tokio::main]
//! async fn main() {
//!
//!     let client = alipay_rs::Client::builder()
//!        .app_id("20210xxxxxxxxxxx")
//!        .public_key(include_str!("../公钥.txt"))
//!        .private_key(include_str!("../私钥.txt"))
//!        .app_cert_sn(include_str!("../appCertPublicKey_20210xxxxxxxxxxx.crt"))
//!        .alipay_root_cert_sn(include_str!("../alipayRootCert.crt"))
//!        .finish();
//!
//!     ref_query(&client).await;
//!     ref_fund_transfer(&client).await;
//!
//!     // 多线程调用
//!     let cli = Arc::new(client);
//!     let cli_clone = cli.clone();
//!     tokio::spawn(async move {
//!         ref_query(&cli_clone).await;
//!     }).await.unwrap();
//!     tokio::spawn(async move {
//!         ref_fund_transfer(&cli.clone()).await;
//!     }).await.unwrap();
//! }
//! ```

mod app_cert_client;
mod client;
mod client_builder;
mod client_with_params;
mod config;
mod util;

pub use client_builder::ClientBuilder;
pub use client_with_params::ClientWithParams;
pub use config::Config;
pub use config::ConfigBuilder;
pub mod error;
pub use alipay_params::{AlipayParam, PublicParams};
pub use client::Client;
use error::AlipayResult;
use futures::future::BoxFuture;
use serde::{de::DeserializeOwned, Serialize};

pub trait Sign {
    fn sign(&self, params: &str) -> AlipayResult<String>;
    fn verify(&self, source: &str, signature: &str) -> AlipayResult<bool>;
}

pub trait Cli {
    fn post<'a, S, T, R>(&'a self, method: S, biz_content: T) -> BoxFuture<'a, AlipayResult<R>>
    where
        S: Into<String> + Send + 'a,
        T: Serialize + Send + 'a,
        R: DeserializeOwned + Send + 'a;

    fn no_param_post<'a, S, R>(&'a self, method: S) -> BoxFuture<'a, AlipayResult<R>>
    where
        S: Into<String> + Send + 'a,
        R: DeserializeOwned + Send + 'a;

    fn sync_post<'a, S, T, R>(&'a self, method: S, biz_content: T) -> AlipayResult<R>
    where
        S: Into<String> + Send + 'a,
        T: Serialize + Send + 'a,
        R: DeserializeOwned + Send + 'a;

    fn post_file<'a, S, D>(
        &'a self,
        method: S,
        key: &'a str,
        file_name: &'a str,
        file_content: &'a [u8],
    ) -> BoxFuture<'a, AlipayResult<D>>
    where
        S: Into<String> + Send + 'a,
        D: DeserializeOwned + Send + 'a;
}

pub trait MutCli {
    fn post<'a, S, T, R>(&'a mut self, method: S, biz_content: T) -> BoxFuture<'a, AlipayResult<R>>
    where
        S: Into<String> + Send + 'a,
        T: Serialize + Send + 'a,
        R: DeserializeOwned + Send + 'a;

    fn no_param_post<'a, S, R>(&'a mut self, method: S) -> BoxFuture<'a, AlipayResult<R>>
    where
        S: Into<String> + Send + 'a,
        R: DeserializeOwned + Send + 'a;

    fn sync_post<'a, S, T, R>(&'a mut self, method: S, biz_content: T) -> AlipayResult<R>
    where
        S: Into<String> + Send + 'a,
        T: Serialize + Send + 'a,
        R: DeserializeOwned + Send + 'a;

    fn post_file<'a, S, D>(
        &'a mut self,
        method: S,
        key: &'a str,
        file_name: &'a str,
        file_content: &'a [u8],
    ) -> BoxFuture<'a, AlipayResult<D>>
    where
        S: Into<String> + Send + 'a,
        D: DeserializeOwned + Send + 'a;
}