tinet 0.1.4

use serde::{de::Error, Deserialize, Deserializer, Serialize};

#[derive(Debug, Deserialize, Serialize, Default)]
pub struct Response<T> {
    #[serde(deserialize_with = "str_to_i64")]
    pub result: i64,
    pub description: String,
    #[serde(
        rename = "totalCount",
        deserialize_with = "str_to_opt_u64",
        skip_serializing_if = "Option::is_none",
        default
    )]
    pub total_count: Option<u64>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data: Option<Vec<T>>,
    // pub data: Vec<T>,
}

#[derive(Debug, Deserialize, Serialize, Default)]
pub struct RespCallDtailRecordOoutboundQuery {
    #[serde(deserialize_with = "str_to_u64")]
    pub id: u64,
    #[serde(rename = "callType")]
    pub call_type: String,
    pub status: String,
    #[serde(rename = "statusCode", deserialize_with = "str_to_u64")]
    pub status_code: u64,
    pub gno: String,
    #[serde(rename = "endReason")]
    pub end_reason: String,
    #[serde(rename = "recordFile")]
    pub record_file: Vec<RecordFile>,
    #[serde(rename = "uniqueId")]
    pub unique_id: String,
    #[serde(rename = "requestUniqueId")]
    pub request_unique_id: String,
    #[serde(rename = "customerNumber")]
    pub customer_number: String,
    #[serde(rename = "customerProvince")]
    pub customer_province: String,
    #[serde(rename = "customerCity")]
    pub customer_city: String,
    #[serde(rename = "agentName")]
    pub agent_name: String,
    pub cno: String,
    #[serde(rename = "agentNumber")]
    pub agent_number: String,
    #[serde(rename = "startTime", deserialize_with = "str_to_i64")]
    pub start_time: i64,
    #[serde(rename = "endTime", deserialize_with = "str_to_i64")]
    pub end_time: i64,
    #[serde(rename = "calleeRingingTime", deserialize_with = "str_to_i64")]
    pub callee_ringing_time: i64,
    #[serde(rename = "bridgeTime", deserialize_with = "str_to_i64")]
    pub bridge_time: i64,
    #[serde(rename = "waitDuration", deserialize_with = "str_to_i64")]
    pub wait_duration: i64,
    #[serde(rename = "vadIn", deserialize_with = "str_to_i64")]
    pub vad_in: i64,
    #[serde(rename = "vadOut", deserialize_with = "str_to_i64")]
    pub vad_out: i64,
    #[serde(rename = "bridgeDuration", deserialize_with = "str_to_i64")]
    pub bridge_duration: i64,
    #[serde(rename = "totalDuration", deserialize_with = "str_to_i64")]
    pub total_duration: i64,
    #[serde(rename = "sipCause")]
    pub sip_cause: String,
    #[serde(rename = "userField")]
    pub user_field: UserField,
    pub clid: String,
    #[serde(rename = "agentClid")]
    pub agent_clid: String,
    #[serde(rename = "xNumber")]
    pub x_number: String,
    #[serde(rename = "answerTime", deserialize_with = "str_to_i64")]
    pub answer_time: i64,
    #[serde(rename = "mainRingingTime", deserialize_with = "str_to_i64")]
    pub main_ringing_time: i64,
    #[serde(rename = "hangupReason")]
    pub hangup_reason: String,
    #[serde(rename = "taskId")]
    pub task_id: String,
}

#[derive(Debug, Deserialize, Serialize, Default)]
pub struct RecordFile {
    pub file: String,
    pub cdr_wav_transfer_format: String,
    pub index: String,
    #[serde(rename = "type")]
    pub kind: String,
    pub monitor_type: String,
}

#[derive(Debug, Deserialize, Serialize, Default)]
pub struct UserField {
    #[serde(default)]
    pub uid: String,
    #[serde(default)]
    pub phone: String,
    #[serde(rename = "rmsTag", default)]
    pub rms_tag: String,
    #[serde(rename = "sourcechannel")]
    pub source_channel: Option<String>,
    #[serde(default)]
    pub cdr_x1_number: String,
}

fn str_to_i64<'de, D>(deserializer: D) -> Result<i64, D::Error>
where
    D: Deserializer<'de>,
{
    let s: &str = Deserialize::deserialize(deserializer)?;
    Ok(s.parse().map_err(D::Error::custom)?)
}

fn str_to_opt_u64<'de, D>(deserializer: D) -> Result<Option<u64>, D::Error>
where
    D: Deserializer<'de>,
{
    let s: Option<&str> = Deserialize::deserialize(deserializer)?;
    if let Some(s) = s {
        return Ok(Some(s.parse().map_err(D::Error::custom)?));
    }
    Ok(None)
}

fn str_to_u64<'de, D>(deserializer: D) -> Result<u64, D::Error>
where
    D: Deserializer<'de>,
{
    let s: &str = Deserialize::deserialize(deserializer)?;
    Ok(s.parse().map_err(D::Error::custom)?)
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn deserial_from_str() {
        let json_str = r#"{
            "id": "6073544461",
            "callType": "预览外呼",
            "status": "座席未接听",
            "statusCode": "30",
            "gno": "",
            "endReason": "1000",
            "recordFile": [],
            "uniqueId": "sip-31-1661062084.60936",
            "requestUniqueId": "478aad828fb8a0659e9f462828698b77",
            "customerNumber": "13993122992",
            "customerProvince": "甘肃",
            "customerCity": "兰州",
            "agentName": "代立蒙",
            "cno": "18402",
            "agentNumber": "5892",
            "startTime": "1661062084",
            "endTime": "1661062116",
            "calleeRingingTime": "0",
            "bridgeTime": "0",
            "waitDuration": "0",
            "vadIn": "0",
            "vadOut": "0",
            "bridgeDuration": "0",
            "totalDuration": "0",
            "sipCause": "0",
            "userField": {},
            "clid": "01027251457",
            "agentClid": "01086487202",
            "xNumber": "",
            "answerTime": "0",
            "mainRingingTime": "0",
            "hangupReason": "0",
            "taskId": "0"
        }"#;

        match serde_json::from_str::<RespCallDtailRecordOoutboundQuery>(json_str) {
            Err(e) => println!("Error: {e:?}"),
            Ok(data) => println!("Ok: {data:?}"),
        }
    }

    #[test]
    fn deserial_from_str2() {
        let json_str = r#"{
            "id": "6073544461",
            "callType": "预览外呼",
            "status": "座席未接听",
            "statusCode": "30",
            "gno": "",
            "endReason": "1000",
            "recordFile": [],
            "uniqueId": "sip-31-1661062084.60936",
            "requestUniqueId": "478aad828fb8a0659e9f462828698b77",
            "customerNumber": "13993122992",
            "customerProvince": "甘肃",
            "customerCity": "兰州",
            "agentName": "代立蒙",
            "cno": "18402",
            "agentNumber": "5892",
            "startTime": "1661062084",
            "endTime": "1661062116",
            "calleeRingingTime": "0",
            "bridgeTime": "0",
            "waitDuration": "0",
            "vadIn": "0",
            "vadOut": "0",
            "bridgeDuration": "0",
            "totalDuration": "0",
            "sipCause": "0",
            "userField": {
                "uid": "111"
            },
            "clid": "01027251457",
            "agentClid": "01086487202",
            "xNumber": "",
            "answerTime": "0",
            "mainRingingTime": "0",
            "hangupReason": "0",
            "taskId": "0"
        }"#;

        match serde_json::from_str::<RespCallDtailRecordOoutboundQuery>(json_str) {
            Err(e) => println!("Error: {e:?}"),
            Ok(data) => println!("Ok: {data:?}"),
        }
    }
}