jt1078 0.1.0

use jt808::models::{Jt808, Jt808BodySerialize, Jt808BodyTrans, Ver808};
use jt_util::{bytes::{IBuffRead, IBuffWrite}, timer_helper::TimeHelper};
use chrono::{Local, TimeZone};


#[derive(Debug, Default)]
pub struct Jt0x9205 {
    /// 逻辑通道号
    pub channel: u8,
    /// 开始时间（时间戳 单位秒，0表示无起始时间条件）
    pub starttime: i64,
    /// 结束时间（时间戳 单位秒，0表示无终止时间条件）
    pub endtime: i64,
    /// 报警标志（bit0~bit31见JT/T 808-2011表18报警标志位定义；bit32~bit64见表13；全0表示无报警类型条件）
    pub alarm: u64,
    /// 音视频资源类型（0：音视频，1：音频，2：视频，3：视频或音视频）
    pub media_type: u8,
    /// 码流类型（0：所有码流，1：主码流，2：子码流）
    pub stream_type: u8,
    /// 存储器类型（0：所有存储器，1：主存储器，2：灾备存储器）
    pub storage_type: u8,
}

impl Jt808BodySerialize for Jt0x9205 {
    fn write(&mut self, _ver: &Ver808, buf: &mut dyn IBuffWrite) {
        buf.put_u8(self.channel);
        if self.starttime == 0 {
            buf.put_slice(&[0; 6]);
        } else {
            buf.put_slice(&TimeHelper::datetime_to_bcd6(&Local.timestamp(self.starttime, 0)));
        }
        if self.endtime == 0 {
            buf.put_slice(&[0; 6]);
        } else {
            buf.put_slice(&TimeHelper::datetime_to_bcd6(&Local.timestamp(self.endtime, 0)));
        }
        buf.put_u64(self.alarm);
        buf.put_u8(self.media_type);
        buf.put_u8(self.stream_type);
        buf.put_u8(self.storage_type);
    }

    fn len(&self, _ver: &Ver808) -> usize {
        24
    }
}


impl Jt808BodyTrans for Jt0x9205 {
    fn fill_new<T>(buf: &mut T, _jt808: &Jt808) -> Self
    where
        T: IBuffRead,
    {
        Self {
            channel: buf.get_u8(),
            starttime: buf.get_dt_bcd6_timestamp(),
            endtime: buf.get_dt_bcd6_timestamp(),
            alarm: buf.get_u64(),
            media_type: buf.get_u8(),
            stream_type: buf.get_u8(),
            storage_type: buf.get_u8(),
        }
    }
}