#[cfg(test)]
mod tests {
use std::collections::HashMap;
use dotenvy::dotenv;
use rpay::{
message::{message::{DataItem, MessageBuilder}, CustomerServiceBuilder, Link, Miniprogrampage, MsgType, Text}, pay::config::{WechatV3PayConfig, WechatV3PayConfigBuilder}, RPayError, RPayResult
};
fn get_oepn_id() -> String {
dotenv().ok();
let openid = std::env::var("WECHAT_OPEN_ID").expect("WECHAT_OPEN_ID not found");
return openid;
}
fn get_access_token() -> String {
dotenv().ok();
let openid = std::env::var("WECHAT_ACCESS_TOKEN").expect("WECHAT_ACCESS_TOKEN not found");
return openid;
}
#[tokio::test]
async fn test_kf_send_link_msg() -> RPayResult<()> {
let resp = CustomerServiceBuilder::default()
.access_token(get_access_token())
.touser(get_oepn_id())
.msg_type(MsgType::Link)
.link(Some(Link{
title: Some("新订单来了".to_string()),
description: Some("五香辣椒248g两包<br/>麻辣498一包".to_string()),
url: Some("https://www.baidu.com".to_string()),
thumb_url: Some("https://www.baidu.com".to_string()),
}))
.build()
.unwrap()
.send()
.await?;
println!("resp => {:?}", resp);
Ok(())
}
#[tokio::test]
async fn test_kf_card_send() -> RPayResult<()> {
let resp = CustomerServiceBuilder::default()
.access_token(get_access_token())
.touser(get_oepn_id())
.msg_type(MsgType::Miniprogrampage)
.miniprogrampage(Some(Miniprogrampage{
title: Some("测试玩一把".to_string()),
pagepath: Some("pages/index/index".to_string()),
thumb_media_id: None,
}))
.build()
.unwrap()
.send()
.await?;
println!("resp => {:?}", resp);
Ok(())
}
#[tokio::test]
async fn test_kf_text_send() -> RPayResult<()> {
let resp = CustomerServiceBuilder::default()
.access_token(get_access_token())
.touser(get_oepn_id())
.msg_type(MsgType::Text)
.text(Some(Text {
content: "我是后台接口主动发起的信息，王先生起来接单了，以后就用这个给你推送订单信息哈".to_string(),
}))
.build()
.unwrap()
.send()
.await?;
println!("resp => {:?}", resp);
Ok(())
}
#[allow(unused)]
fn get_sdk() -> RPayResult<WechatV3PayConfig> {
dotenv().ok();
let app_id = std::env::var("WECHAT_APP_ID").expect("WECHAT_APP_ID not found");
let mch_id = std::env::var("WECHAT_MCH_ID").expect("WECHAT_MCH_ID not found");
let secret = std::env::var("WECHAT_SECRET").expect("WECHAT_SECRET not found");
let private_key =
std::env::var("WECHAT_PRIVATE_KEY").expect("WECHAT_PRIVATE_KEY not found");
let serial_no = std::env::var("WECHAT_SERIAL_NO").expect("WECHAT_SERIAL_NO not found");
let v3_key = std::env::var("WECHAT_KEY_V3").expect("WECHAT_KEY_V3 not found");
let notify_url = std::env::var("WECHAT_NOTIFY_URL").expect("WECHAT_NOTIFY_URL not found");
let sdk = WechatV3PayConfigBuilder::default()
.app_id(app_id)
.secret(secret)
.api_key_v3(v3_key)
.serial_no(serial_no.to_string())
.mch_id(mch_id)
.private_key(private_key)
.notify_url(notify_url)
.build()?;
Ok(sdk)
}
#[tokio::test]
async fn test_message_send() -> RPayResult<()> {
let mut data = HashMap::new();
data.insert(
"character_string5".to_string(),
DataItem {
value: "快递单号".to_string(),
},
);
data.insert(
"character_string1".to_string(),
DataItem {
value: "订单编号".to_string(),
},
);
data.insert(
"thing20".to_string(),
DataItem {
value: "快递公司".to_string(),
},
);
data.insert(
"thing21".to_string(),
DataItem {
value: "物品名称".to_string(),
},
);
data.insert(
"thing25".to_string(),
DataItem {
value: "发货门店".to_string(),
},
);
let resp = MessageBuilder::default()
.access_token(get_access_token())
.touser(get_oepn_id())
.template_id("aZHCMNQEVOQjF5SSYuPI_eV0tuBj7R7-UQYuQ9FQWx4")
.data(data)
.build().map_err(|err|RPayError::ErrorWithMsg(err.to_string()))?
.send().await?;
println!("resp => {:?}", resp);
Ok(())
}
#[tokio::test]
async fn test_message_send_create_order() -> RPayResult<()> {
let mut data = HashMap::new();
data.insert(
"thing1".to_string(),
DataItem {
value: "大洋芋".to_string(), },
);
data.insert(
"amount2".to_string(),
DataItem {
value: "18.00".to_string(), },
);
data.insert(
"number3".to_string(),
DataItem {
value: "1".to_string(), },
);
data.insert(
"time4".to_string(),
DataItem {
value: "2024-06-21 14:16:33".to_string(), },
);
let resp = MessageBuilder::default()
.access_token(get_access_token())
.touser(get_oepn_id())
.template_id("rc-r-FZ6gwiq2tvkWwJeFckWRkU-RmReKyeFfkfFQLs")
.data(data)
.page("pages/order/index".to_string())
.build().map_err(|err|RPayError::ErrorWithMsg(err.to_string()))?
.send().await?;
println!("resp => {:?}", resp);
Ok(())
}
#[tokio::test]
async fn test_message_send_have_order() -> RPayResult<()> {
let mut data = HashMap::new();
data.insert(
"name7".to_string(),
DataItem {
value: "下单人".to_string(),
},
);
data.insert(
"thing9".to_string(),
DataItem {
value: "收货地址".to_string(),
},
);
data.insert(
"thing5".to_string(),
DataItem {
value: "备注信息".to_string(),
},
);
data.insert(
"thing6".to_string(),
DataItem {
value: "商品名称".to_string(),
},
);
data.insert(
"number12".to_string(),
DataItem {
value: "2".to_string(),
},
);
let resp = MessageBuilder::default()
.access_token(get_access_token())
.touser(get_oepn_id())
.template_id("rc-r-FZ6gwiq2tvkWwJeFckWRkU-RmReKyeFfkfFQLs")
.data(data)
.build()
.map_err(|err|RPayError::ErrorWithMsg(err.to_string()))?
.send().await?;
println!("resp => {:?}", resp);
Ok(())
}
}