refactor: 优化代码格式，调整函数参数和输出格式

Author: ExquisiteCore

examples/integration_test.rs

@@ -97,8 +97,10 @@ async fn main() {
     print!("[6/8] Get Material Count... ");
     match client.get_material_count().await {
         Ok(count) => {
-            println!("OK (image: {}, voice: {}, video: {}, news: {})",
-                count.image_count, count.voice_count, count.video_count, count.news_count);
+            println!(
+                "OK (image: {}, voice: {}, video: {}, news: {})",
+                count.image_count, count.voice_count, count.video_count, count.news_count
+            );
             passed += 1;
         }
         Err(e) => {

examples/message_handler.rs

@@ -7,7 +7,7 @@
 use wechat_oa_sdk::Config;
 use wechat_oa_sdk::WeChatClient;
 use wechat_oa_sdk::api::message::IncomingMessage;
-use wechat_oa_sdk::models::reply::{TextReply, NewsReply, NewsArticle, empty_reply};
+use wechat_oa_sdk::models::reply::{NewsArticle, NewsReply, TextReply, empty_reply};
 
 fn main() {
     // Create client with token for signature verification
@@ -76,14 +76,12 @@ fn handle_message(msg: IncomingMessage) -> String {
         }
         IncomingMessage::Image(img) => {
             // Reply with news article
-            let articles = vec![
-                NewsArticle {
-                    title: "Thanks for the image!".to_string(),
-                    description: "We received your image.".to_string(),
-                    pic_url: img.pic_url.clone(),
-                    url: "https://example.com".to_string(),
-                }
-            ];
+            let articles = vec![NewsArticle {
+                title: "Thanks for the image!".to_string(),
+                description: "We received your image.".to_string(),
+                pic_url: img.pic_url.clone(),
+                url: "https://example.com".to_string(),
+            }];
             let reply = NewsReply::new(&img.from_user_name, &img.to_user_name, articles);
             reply.to_xml()
         }

examples/publish_article.rs

@@ -8,9 +8,9 @@
 
 use std::env;
 use std::fs;
-use wechat_oa_sdk::{Config, WeChatClient};
 use wechat_oa_sdk::models::material::MaterialType;
 use wechat_oa_sdk::models::publish::Article;
+use wechat_oa_sdk::{Config, WeChatClient};
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {

src/api/customer_service.rs

@@ -108,7 +108,10 @@ struct SendResponse {
 
 impl WeChatClient {
     /// Send a customer service message.
-    pub async fn send_customer_service_message(&self, message: &CustomerServiceMessage) -> Result<()> {
+    pub async fn send_customer_service_message(
+        &self,
+        message: &CustomerServiceMessage,
+    ) -> Result<()> {
         let _: SendResponse = self.post_json("/message/custom/send", message).await?;
         Ok(())
     }

src/api/message.rs

@@ -3,8 +3,8 @@ use quick_xml::de::from_str;
 use crate::client::WeChatClient;
 use crate::crypto::check_signature;
 use crate::error::Result;
-use crate::models::message::*;
 use crate::models::event::*;
+use crate::models::message::*;
 
 /// Incoming message/event from WeChat.
 #[derive(Debug, Clone)]
@@ -71,7 +71,9 @@ impl WeChatClient {
             "LOCATION" => IncomingMessage::LocationEvent(from_str(xml_body)?),
             "CLICK" => IncomingMessage::MenuClickEvent(from_str(xml_body)?),
             "VIEW" => IncomingMessage::MenuViewEvent(from_str(xml_body)?),
-            "TEMPLATESENDJOBFINISH" => IncomingMessage::TemplateSendJobFinishEvent(from_str(xml_body)?),
+            "TEMPLATESENDJOBFINISH" => {
+                IncomingMessage::TemplateSendJobFinishEvent(from_str(xml_body)?)
+            }
             _ => IncomingMessage::Unknown(xml_body.to_string()),
         };
 

src/api/mod.rs

@@ -1,9 +1,9 @@
-pub mod message;
 pub mod customer_service;
-pub mod template;
 pub mod material;
-pub mod user;
 pub mod menu;
-pub mod stats;
+pub mod message;
 pub mod publish;
 pub mod qrcode;
+pub mod stats;
+pub mod template;
+pub mod user;

src/api/publish.rs

@@ -230,12 +230,13 @@ impl WeChatClient {
     /// Returns the URL of the uploaded image (can be used in article HTML).
     /// This is different from material upload - these images are specifically
     /// for embedding in article content.
-    pub async fn upload_article_image(&self, file_name: &str, file_data: Vec<u8>) -> Result<String> {
+    pub async fn upload_article_image(
+        &self,
+        file_name: &str,
+        file_data: Vec<u8>,
+    ) -> Result<String> {
         let token = self.access_token().await?;
-        let url = format!(
-            "{}/media/uploadimg?access_token={}",
-            WECHAT_API_BASE, token
-        );
+        let url = format!("{}/media/uploadimg?access_token={}", WECHAT_API_BASE, token);
 
         let part = Part::bytes(file_data).file_name(file_name.to_string());
         let form = Form::new().part("media", part);

src/api/stats.rs

@@ -172,8 +172,9 @@ impl WeChatClient {
 
     /// Get upstream message hour statistics (single day only).
     pub async fn get_upstream_msg_hour(&self, range: &DateRange) -> Result<Vec<UpstreamMsgItem>> {
-        let resp: ListResponse<UpstreamMsgItem> =
-            self.post_json("/datacube/getupstreammsghour", range).await?;
+        let resp: ListResponse<UpstreamMsgItem> = self
+            .post_json("/datacube/getupstreammsghour", range)
+            .await?;
         Ok(resp.list)
     }
 
@@ -184,8 +185,9 @@ impl WeChatClient {
         &self,
         range: &DateRange,
     ) -> Result<Vec<InterfaceSummaryItem>> {
-        let resp: ListResponse<InterfaceSummaryItem> =
-            self.post_json("/datacube/getinterfacesummary", range).await?;
+        let resp: ListResponse<InterfaceSummaryItem> = self
+            .post_json("/datacube/getinterfacesummary", range)
+            .await?;
         Ok(resp.list)
     }
 

src/api/template.rs

@@ -62,7 +62,9 @@ impl WeChatClient {
         let body = serde_json::json!({
             "template_id": template_id
         });
-        let _: DeleteResponse = self.post_json("/template/del_private_template", &body).await?;
+        let _: DeleteResponse = self
+            .post_json("/template/del_private_template", &body)
+            .await?;
         Ok(())
     }
 }

src/api/user.rs

@@ -131,7 +131,9 @@ impl WeChatClient {
             "openid_list": openids,
             "tagid": tag_id
         });
-        let _: ApiResponse = self.post_json("/tags/members/batchuntagging", &body).await?;
+        let _: ApiResponse = self
+            .post_json("/tags/members/batchuntagging", &body)
+            .await?;
         Ok(())
     }