@@ -57,37 +57,35 @@ async fn get_recent_messages(
5757 . await
5858 {
5959 Ok ( response) => {
60- if let Some ( data) = & response. data {
61- println ! ( "✅ 消息获取成功!" ) ;
62- println ! ( " 消息总数: {}" , data. items. len( ) ) ;
63- println ! ( " 是否有更多: {}" , data. has_more) ;
64-
65- if !data. items . is_empty ( ) {
66- println ! ( "\n 📝 消息列表:" ) ;
67- for ( index, message) in data. items . iter ( ) . enumerate ( ) {
68- println ! (
69- " {}. [{}] {} - {}" ,
70- index + 1 ,
71- format_timestamp( & message. create_time) ,
72- message. msg_type,
73- format_sender( & message. sender)
74- ) ;
75-
76- // 显示消息内容预览（前50个字符）
77- if let Some ( content) = extract_text_content ( & message. body . content ) {
78- let preview = if content. len ( ) > 50 {
79- format ! ( "{}..." , & content[ ..50 ] )
80- } else {
81- content
82- } ;
83- println ! ( " 内容: {}" , preview) ;
84- }
60+ println ! ( "✅ 消息获取成功!" ) ;
61+ println ! ( " 消息总数: {}" , response. items. len( ) ) ;
62+ println ! ( " 是否有更多: {}" , response. has_more) ;
63+
64+ if !response. items . is_empty ( ) {
65+ println ! ( "\n 📝 消息列表:" ) ;
66+ for ( index, message) in response. items . iter ( ) . enumerate ( ) {
67+ println ! (
68+ " {}. [{}] {} - {}" ,
69+ index + 1 ,
70+ format_timestamp( & message. create_time) ,
71+ message. msg_type,
72+ format_sender( & message. sender)
73+ ) ;
74+
75+ // 显示消息内容预览（前50个字符）
76+ if let Some ( content) = extract_text_content ( & message. body . content ) {
77+ let preview = if content. len ( ) > 50 {
78+ format ! ( "{}..." , & content[ ..50 ] )
79+ } else {
80+ content
81+ } ;
82+ println ! ( " 内容: {}" , preview) ;
8583 }
8684 }
8785
88- if data . has_more {
86+ if response . has_more {
8987 println ! ( "\n 💡 提示: 还有更多消息可以通过分页获取" ) ;
90- if let Some ( page_token) = & data . page_token {
88+ if let Some ( page_token) = & response . page_token {
9189 println ! ( " 下一页token: {}" , page_token) ;
9290 }
9391 }
@@ -131,37 +129,35 @@ async fn get_messages_by_timerange(
131129 . await
132130 {
133131 Ok ( response) => {
134- if let Some ( data) = & response. data {
135- println ! ( "✅ 时间段消息获取成功!" ) ;
136- println ! (
137- " 时间范围: {} - {}" ,
138- format_timestamp( & yesterday. to_string( ) ) ,
139- format_timestamp( & now. to_string( ) )
140- ) ;
141- println ! ( " 消息数量: {}" , data. items. len( ) ) ;
142-
143- if !data. items . is_empty ( ) {
144- // 按消息类型统计
145- let mut type_stats = std:: collections:: HashMap :: new ( ) ;
146- for message in & data. items {
147- * type_stats. entry ( & message. msg_type ) . or_insert ( 0 ) += 1 ;
148- }
132+ println ! ( "✅ 时间段消息获取成功!" ) ;
133+ println ! (
134+ " 时间范围: {} - {}" ,
135+ format_timestamp( & yesterday. to_string( ) ) ,
136+ format_timestamp( & now. to_string( ) )
137+ ) ;
138+ println ! ( " 消息数量: {}" , response. items. len( ) ) ;
139+
140+ if !response. items . is_empty ( ) {
141+ // 按消息类型统计
142+ let mut type_stats = std:: collections:: HashMap :: new ( ) ;
143+ for message in & response. items {
144+ * type_stats. entry ( & message. msg_type ) . or_insert ( 0 ) += 1 ;
145+ }
149146
150- println ! ( "\n 📊 消息类型统计:" ) ;
151- for ( msg_type, count) in type_stats {
152- println ! ( " {}: {} 条" , msg_type, count) ;
153- }
147+ println ! ( "\n 📊 消息类型统计:" ) ;
148+ for ( msg_type, count) in type_stats {
149+ println ! ( " {}: {} 条" , msg_type, count) ;
150+ }
154151
155- // 显示最近几条消息
156- println ! ( "\n 📝 最近的消息:" ) ;
157- for message in data. items . iter ( ) . take ( 5 ) {
158- println ! (
159- " [{}] {} - {}" ,
160- format_timestamp( & message. create_time) ,
161- message. msg_type,
162- format_sender( & message. sender)
163- ) ;
164- }
152+ // 显示最近几条消息
153+ println ! ( "\n 📝 最近的消息:" ) ;
154+ for message in response. items . iter ( ) . take ( 5 ) {
155+ println ! (
156+ " [{}] {} - {}" ,
157+ format_timestamp( & message. create_time) ,
158+ message. msg_type,
159+ format_sender( & message. sender)
160+ ) ;
165161 }
166162 } else {
167163 println ! ( "⚠️ 请求成功，但未返回消息数据" ) ;
0 commit comments