package com.genersoft.iot.vmp.jt1078.proc.request;

import com.alibaba.fastjson2.JSON;
import com.genersoft.iot.vmp.jt1078.annotation.MsgId;
import com.genersoft.iot.vmp.jt1078.proc.Header;
import com.genersoft.iot.vmp.jt1078.proc.response.J8001;
import com.genersoft.iot.vmp.jt1078.proc.response.Rs;
import com.genersoft.iot.vmp.jt1078.session.Session;
import com.genersoft.iot.vmp.jt1078.session.SessionManager;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufUtil;

import java.util.ArrayList;
import java.util.List;

/**
 * 终端上传音视频资源列表
 *
 * @author QingtaiJiang
 * @date 2023/4/28 10:36
 * @email qingtaij@163.com
 */
@MsgId(id = "1205")
public class J1205 extends Re {
    Integer respNo;

    private List<JRecordItem> recordList = new ArrayList<JRecordItem>();

    @Override
    protected Rs decode0(ByteBuf buf, Header header, Session session) {
        respNo = buf.readUnsignedShort();
        long size = buf.readUnsignedInt();

        for (int i = 0; i < size; i++) {
            JRecordItem item = new JRecordItem();
            item.setChannelId(buf.readUnsignedByte());
            item.setStartTime(ByteBufUtil.hexDump(buf.readSlice(6)));
            item.setEndTime(ByteBufUtil.hexDump(buf.readSlice(6)));
            item.setWarn(buf.readLong());
            item.setMediaType(buf.readUnsignedByte());
            item.setStreamType(buf.readUnsignedByte());
            item.setStorageType(buf.readUnsignedByte());
            item.setSize(buf.readUnsignedInt());
            recordList.add(item);
        }

        return null;
    }

    @Override
    protected Rs handler(Header header, Session session) {
        SessionManager.INSTANCE.response(header.getDevId(), "1205", (long) respNo, JSON.toJSONString(this));

        J8001 j8001 = new J8001();
        j8001.setRespNo(header.getSn());
        j8001.setRespId(header.getMsgId());
        j8001.setResult(J8001.SUCCESS);
        return j8001;
    }


    public Integer getRespNo() {
        return respNo;
    }

    public void setRespNo(Integer respNo) {
        this.respNo = respNo;
    }

    public List<JRecordItem> getRecordList() {
        return recordList;
    }

    public void setRecordList(List<JRecordItem> recordList) {
        this.recordList = recordList;
    }

    public static class JRecordItem {

        // 逻辑通道号
        private int channelId;

        // 开始时间
        private String startTime;

        // 结束时间
        private String endTime;

        // 报警标志
        private long warn;

        // 音视频资源类型
        private int mediaType;

        // 码流类型
        private int streamType = 1;

        // 存储器类型
        private int storageType;

        // 文件大小
        private long size;

        public int getChannelId() {
            return channelId;
        }

        public void setChannelId(int channelId) {
            this.channelId = channelId;
        }

        public String getStartTime() {
            return startTime;
        }

        public void setStartTime(String startTime) {
            this.startTime = startTime;
        }

        public String getEndTime() {
            return endTime;
        }

        public void setEndTime(String endTime) {
            this.endTime = endTime;
        }

        public long getWarn() {
            return warn;
        }

        public void setWarn(long warn) {
            this.warn = warn;
        }

        public int getMediaType() {
            return mediaType;
        }

        public void setMediaType(int mediaType) {
            this.mediaType = mediaType;
        }

        public int getStreamType() {
            return streamType;
        }

        public void setStreamType(int streamType) {
            this.streamType = streamType;
        }

        public int getStorageType() {
            return storageType;
        }

        public void setStorageType(int storageType) {
            this.storageType = storageType;
        }

        public long getSize() {
            return size;
        }

        public void setSize(long size) {
            this.size = size;
        }

        @Override
        public String toString() {
            return "JRecordItem{" +
                    "channelId=" + channelId +
                    ", startTime='" + startTime + '\'' +
                    ", endTime='" + endTime + '\'' +
                    ", warn=" + warn +
                    ", mediaType=" + mediaType +
                    ", streamType=" + streamType +
                    ", storageType=" + storageType +
                    ", size=" + size +
                    '}';
        }
    }

    @Override
    public String toString() {
        return "J1205{" +
                "respNo=" + respNo +
                ", recordList=" + recordList +
                '}';
    }
}