open-lark 0.14.0

Enterprise-grade Lark/Feishu Open API SDK with comprehensive Chinese documentation and advanced error handling
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132

use reqwest::Method;
use serde::{Deserialize, Serialize};

use crate::{
    core::{
        api_req::ApiRequest,
        api_resp::{ApiResponseTrait, BaseResponse, ResponseFormat},
        config::Config,
        constants::AccessTokenType,
        endpoints::Endpoints,
        http::Transport,
        req_option::RequestOption,
        SDKResult,
    },
    service::apass::models::{
        PageResponse, SeatActivity, SeatActivityListRequest, SeatAssignment,
        SeatAssignmentListRequest,
    },
};

/// 席位管理服务
pub struct SeatService {
    pub config: Config,
}

/// 席位分配查询响应
#[derive(Debug, Serialize, Deserialize)]
pub struct SeatAssignmentListResponse {
    /// 分页响应数据
    #[serde(flatten)]
    pub page_response: PageResponse<SeatAssignment>,
}

impl ApiResponseTrait for SeatAssignmentListResponse {
    fn data_format() -> ResponseFormat {
        ResponseFormat::Data
    }
}

/// 席位活跃查询响应
#[derive(Debug, Serialize, Deserialize)]
pub struct SeatActivityListResponse {
    /// 分页响应数据
    #[serde(flatten)]
    pub page_response: PageResponse<SeatActivity>,
}

impl ApiResponseTrait for SeatActivityListResponse {
    fn data_format() -> ResponseFormat {
        ResponseFormat::Data
    }
}

impl SeatService {
    pub fn new(config: Config) -> Self {
        Self { config }
    }

    /// 查询席位分配详情
    ///
    /// 该接口用于查询低代码平台的席位分配详情信息。
    ///
    /// # 参数
    ///
    /// - `request`: 席位分配查询请求参数
    /// - `option`: 可选的请求配置
    pub async fn list_seat_assignment(
        &self,
        request: SeatAssignmentListRequest,
        option: Option<RequestOption>,
    ) -> SDKResult<BaseResponse<SeatAssignmentListResponse>> {
        let mut api_req = ApiRequest {
            http_method: Method::GET,
            api_path: Endpoints::APASS_V1_SEAT_ASSIGNMENT_LIST.to_string(),
            supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
            body: vec![],
            ..Default::default()
        };

        // 添加查询参数
        if let Some(page_size) = request.page_size {
            api_req
                .query_params
                .insert("page_size", page_size.to_string());
        }
        if let Some(page_token) = request.page_token {
            api_req.query_params.insert("page_token", page_token);
        }

        Transport::request(api_req, &self.config, option).await
    }

    /// 查询席位活跃详情
    ///
    /// 该接口用于查询低代码平台的席位活跃详情信息。
    ///
    /// # 参数
    ///
    /// - `request`: 席位活跃查询请求参数
    /// - `option`: 可选的请求配置
    pub async fn list_seat_activity(
        &self,
        request: SeatActivityListRequest,
        option: Option<RequestOption>,
    ) -> SDKResult<BaseResponse<SeatActivityListResponse>> {
        let mut api_req = ApiRequest {
            http_method: Method::GET,
            api_path: Endpoints::APASS_V1_SEAT_ACTIVITY_LIST.to_string(),
            supported_access_token_types: vec![AccessTokenType::Tenant, AccessTokenType::User],
            body: vec![],
            ..Default::default()
        };

        // 添加查询参数
        if let Some(page_size) = request.page_size {
            api_req
                .query_params
                .insert("page_size", page_size.to_string());
        }
        if let Some(page_token) = request.page_token {
            api_req.query_params.insert("page_token", page_token);
        }
        if let Some(start_time) = request.start_time {
            api_req.query_params.insert("start_time", start_time);
        }
        if let Some(end_time) = request.end_time {
            api_req.query_params.insert("end_time", end_time);
        }

        Transport::request(api_req, &self.config, option).await
    }
}