package com.netsdk.demo.customize.JordanPSD;

import com.netsdk.demo.customize.JordanPSD.module.LogonModule;
import com.netsdk.demo.customize.JordanPSD.module.RecordModule;
import com.netsdk.demo.customize.JordanPSD.module.SdkUtilModule;
import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.Utils;
import com.netsdk.lib.enumeration.EM_MOBILE_ENFORCE_FILE_TYPE;
import com.netsdk.lib.enumeration.EM_MOBILE_ENFORCE_FORMAT;
import com.netsdk.lib.enumeration.EM_MOBILE_ENFORCE_UPLOAD_FLAG;
import com.netsdk.lib.enumeration.ENUMERROR;
import com.netsdk.lib.structure.*;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.charset.Charset;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Scanner;
import java.util.concurrent.TimeUnit;

/**
 * @author 47040
 * @since Created at 2021/5/28 19:25
 */
public class Demo33C300 {

    static NetSDKLib NetSdk = NetSDKLib.NETSDK_INSTANCE;
    private final NetSDKLib.LLong m_hLoginHandle; // 登录句柄
    private final NetSDKLib.NET_DEVICEINFO_Ex m_hDeviceInfo; // 设备信息
    private final Charset encode = Charset.forName(Utils.getPlatformEncode()); // 跨平台编码
    private NetSDKLib.LLong m_hFindFileHandle = new NetSDKLib.LLong(0); // 文件查询句柄
    private NetSDKLib.LLong m_hDownLoadHandle = new NetSDKLib.LLong(0); // 下载句柄
    // 存储临时查询数据
    private ArrayList<NetOutMediaQueryFile> mediaRecords = new ArrayList<>();

    private class NetOutMediaQueryFile {

        public int nChannelID;
        public NetSDKLib.NET_TIME stuStartTime;
        public NetSDKLib.NET_TIME stuEndTime;
        public byte byFileType;
        public byte byPartition;
        public byte byVideoStream;
        public int nCluster;
        public byte[] szFilePath;
        public int nDriveNo;
        public long nFileSizeEx;
        public int nTotalFrame;
        public int emFileState;

    }

    public Demo33C300(DeviceInfo deviceInfo) {
        this.m_hLoginHandle = deviceInfo.m_hLoginHandle;
        this.m_hDeviceInfo = deviceInfo.m_stDeviceInfo;
    }

    public Demo33C300(NetSDKLib.LLong loginHandle, NetSDKLib.NET_DEVICEINFO_Ex deviceinfo) {
        this.m_hLoginHandle = loginHandle;
        this.m_hDeviceInfo = deviceinfo;
    }


    /**
     * 查询采集站和手持终端文件信息 Demo里的查询条件: 2021-06-02 12:00:00 至 2021-06-02 12:30:00 文件类型：未上传
     */
    public void findFileExQueryMobileEnforce() {
        if (m_hLoginHandle.longValue() == 0) {
            System.err.println("Please Login First");
            return;
        }

        ///////////////////////////// 开始查询 /////////////////////////////
        ///////////////////////////////////////////////////////////////////

        final int queryType = NetSDKLib.EM_FILE_QUERY_TYPE.NET_FILE_QUERY_MOBILE_ENFORCE;
        MEDIAFILE_MOBILE_ENFORCE_PARAM condition = new MEDIAFILE_MOBILE_ENFORCE_PARAM();

        condition.nChannelID = -1; // 采集站没有通道号概念  使用-1代表所有通道
        condition.stuBeginTime = new NET_TIME(2021, 7, 1, 2, 0, 0); // 设置 开始时间
        condition.stuEndTime = new NET_TIME(2021, 7, 2, 23, 30, 0); // 设置 结束时间
        condition.emUploadFlag =
                EM_MOBILE_ENFORCE_UPLOAD_FLAG.EM_MOBILE_ENFORCE_UPLOAD_FLAG_NOTUPLOAD.getValue(); // 未上传

        // 设置查询类型 获取查询句柄
        m_hFindFileHandle = RecordModule.FindFileEx(m_hLoginHandle, queryType, condition, 3000);
        if (m_hFindFileHandle.longValue() == 0) {
            System.err.println("查询采集站和手持终端文件信息失败:" + ENUMERROR.getErrorMessage());
            return;
        }
        System.out.println("查询采集站和手持终端文件信息成功");

        ///////////////////////////// 文件总数 /////////////////////////////
        ///////////////////////////////////////////////////////////////////

        // 获取违章总数
        int totalCount = RecordModule.GetTotalFileCount(m_hFindFileHandle, 3000);
        if (totalCount == -1) {
            System.err.println("获取查询总数失败:" + ENUMERROR.getErrorMessage());
            // 查询异常，直接退出查询
            RecordModule.FindCloseEx(m_hFindFileHandle);
            return;
        }

        ///////////////////////////// 获取查询结果 /////////////////////////////
        //////////////////////////////////////////////////////////////////////

        int queryCount = Math.min(10, totalCount); // 每次获取的违章数量
        MEDIAFILE_MOBILE_ENFORCE_INFO[] mediaFileInfos = new MEDIAFILE_MOBILE_ENFORCE_INFO[queryCount];
        for (int i = 0; i < mediaFileInfos.length; ++i) {
            mediaFileInfos[i] = new MEDIAFILE_MOBILE_ENFORCE_INFO();
        }

        final int memorySize = mediaFileInfos[0].size() * queryCount;
        Pointer mediaFileMemory = new Memory(memorySize);
        mediaFileMemory.clear(memorySize);

        // 循环查询
        int nCurrIndex = 0;
        do {
            // 查询
            int nRet =
                    RecordModule.FindNextFileEx(m_hFindFileHandle, mediaFileInfos, mediaFileMemory, 3000);
            if (nRet < 0) {
                System.err.println("获取查询信息失败:" + ENUMERROR.getErrorMessage());
                break;
            }

            // 打印一下获取到的信息内容
            StringBuilder printInfo = new StringBuilder();
            for (int j = 0; j < nRet; j++) {
                ++nCurrIndex;

                MEDIAFILE_MOBILE_ENFORCE_INFO info = mediaFileInfos[j];
                printInfo
                        .append("-------------------------")
                        .append(nCurrIndex)
                        .append("---------------------------\n")
                        .append("  开始时间: ")
                        .append(info.stuStartTime.toString())
                        .append("\n")
                        .append("  结束时间: ")
                        .append(info.stuEndTime.toString())
                        .append("\n")
                        .append("  文件路径: ")
                        .append(new String(info.szFilePath, encode))
                        .append("\n")
                        .append("  文件名称: ")
                        .append(new String(info.szFileName, encode))
                        .append("\n")
                        .append("  文件长度: ")
                        .append(info.nLength)
                        .append("\n")
                        .append("  文件标识: ")
                        .append(new String(info.szUniqueID, encode))
                        .append("\n")
                        .append("  文件序列: ")
                        .append(new String(info.szOriginalDeviceID, encode))
                        .append("\n")
                        .append("  文件类型: ")
                        .append(EM_MOBILE_ENFORCE_FORMAT.getEnum(info.emFormat).getNote())
                        .append("\n")
                        .append("  文件后缀: ")
                        .append(EM_MOBILE_ENFORCE_FILE_TYPE.getEnum(info.emFileType).getNote())
                        .append("\n");
            }
            System.out.println(printInfo.toString());
        } while ((totalCount -= queryCount) > 0);

        ///////////////////////////// 结束查询 /////////////////////////////
        ///////////////////////////////////////////////////////////////////

        RecordModule.FindCloseEx(m_hFindFileHandle);
    }

    /**
     * 通用录像文件下载 按文件信息筛选
     */
    public void DownloadRecordByFile() {

        if (m_hLoginHandle.longValue() == 0) {
            System.err.println("请先登录");
            return;
        }

        List<NetSDKLib.NET_RECORDFILE_INFO> files = QueryRecordFile();
        if (files.isEmpty()) {
            System.err.println("查询不到录像文件");
            return;
        }

        Scanner sc = new Scanner(System.in);
        System.out.println("请选择需要下载的文件序号");
        int idx = sc.nextInt();
        NetSDKLib.NET_RECORDFILE_INFO fileInfo = files.get(idx);

        // LPNET_RECORDFILE_INFO 和 NET_RECORDFILE_INFO 内部字段完全一样 可以互相替换 因此我加了个重载接口
        // 这里直接使用 fileInfo 作查询条件

        // 默认保存路径
        String savePath = new File(".").getAbsoluteFile().getParent() + "\\" + System.currentTimeMillis() + ".MP4";
        System.out.println("SavedFileName:" + savePath);
        NetSDKLib.fTimeDownLoadPosCallBack posCallBack = FileDownLoadPosCallBack.getInstance();   // 进度回调
        NetSDKLib.fDataCallBack dataCallBack = FileDownloadDataCallBack.getInstance();            // 下载数据回调

        m_hDownLoadHandle = RecordModule.DownloadRecordFileByFileEx(m_hLoginHandle, fileInfo, savePath, posCallBack, dataCallBack);
        if (m_hDownLoadHandle.longValue() == 0) {
            System.err.println("Start Download By File Failed :" + ENUMERROR.getErrorMessage());
        } else {
            System.out.println("Start Download By File Succeed");
        }
    }

    /**
     * 通用录像文件下载 FindFile 查询文件
     */
    public void DownloadRecordByFileAndFindFile() {

        if (m_hLoginHandle.longValue() == 0) {
            System.err.println("请先登录");
            return;
        }

        findFileExMediaRecord();
        if (mediaRecords.isEmpty()) {
            System.err.println("查询不到录像文件");
            return;
        }

        Scanner sc = new Scanner(System.in);
        System.out.println("请选择需要下载的文件序号");
        int idx = sc.nextInt();
        NetOutMediaQueryFile record = mediaRecords.get(idx);

        // 设置查询条件
        NetSDKLib.NET_RECORDFILE_INFO fileCondition = new NetSDKLib.NET_RECORDFILE_INFO();
        fileCondition.ch = record.nChannelID;
        fileCondition.bRecType = record.byVideoStream;
        // 两个 byte[] 长度并不相同 必须使用 arraycopy
        System.arraycopy(record.szFilePath, 0, fileCondition.filename, 0, fileCondition.filename.length);
        System.out.println("filePath:" + new String(fileCondition.filename, encode));
        fileCondition.size = (int) record.nFileSizeEx / 1024;
        fileCondition.framenum = record.nTotalFrame;
        fileCondition.driveno = record.nDriveNo;
        fileCondition.startcluster = record.nCluster;
        fileCondition.starttime = record.stuStartTime;
        fileCondition.endtime = record.stuEndTime;

        // 默认保存路径
        String savePath = new File(".").getAbsoluteFile().getParent() + "\\" + System.currentTimeMillis() + ".MP4";
        System.out.println("SavedFileName:" + savePath);
        NetSDKLib.fTimeDownLoadPosCallBack posCallBack = FileDownLoadPosCallBack.getInstance();   // 进度回调
        NetSDKLib.fDataCallBack dataCallBack = FileDownloadDataCallBack.getInstance();            // 下载数据回调

        m_hDownLoadHandle = RecordModule.DownloadRecordFileByFileEx(m_hLoginHandle, fileCondition, savePath, posCallBack, dataCallBack);
        if (m_hDownLoadHandle.longValue() == 0) {
            System.err.println("Start Download By File Failed :" + ENUMERROR.getErrorMessage());
        } else {
            System.out.println("Start Download By File Succeed");
        }
    }

    /**
     * 录像文件下载 CLIENT_DownloadByFileSelfAdapt自适应下载 + FindFile 查询文件
     */
    public void DownloadRecordWithSelfAdaptByFileAndFindFile() {

        FileDownLoadPosCallBack2.downloadPosQueue2.clear();
        FileDownloadDataCallBack2.downloadDataQueue2.clear();

        if (m_hLoginHandle.longValue() == 0) {
            System.err.println("请先登录");
            return;
        }

        findFileExMediaRecord();
        if (mediaRecords.isEmpty()) {
            System.err.println("查询不到录像文件");
            return;
        }

        Scanner sc = new Scanner(System.in);
        System.out.println("请选择需要下载的文件序号");
        int idx = sc.nextInt();
        NetOutMediaQueryFile record = mediaRecords.get(idx);

        // 设置查询条件
        NET_IN_DOWNLOAD_BYFILE_SELFADAPT stuParamIn = new NET_IN_DOWNLOAD_BYFILE_SELFADAPT();
        stuParamIn.nChannelID = record.nChannelID;
        stuParamIn.emRecordType = 0;
        // 两个 byte[] 长度并不相同 必须使用 arraycopy
        System.arraycopy(record.szFilePath, 0, stuParamIn.szFileName, 0, Math.min(record.szFilePath.length, stuParamIn.szFileName.length));
        stuParamIn.nFrameNum = record.nTotalFrame;
        stuParamIn.size = (int) record.nFileSizeEx / 1024;
        stuParamIn.stuStartTime = record.stuStartTime;
        stuParamIn.stuEndTime = record.stuEndTime;
        stuParamIn.nDriveno = record.nDriveNo;
        stuParamIn.nStartCluster = record.nCluster;

        stuParamIn.cbDownLoadPos = FileDownLoadPosCallBack2.getInstance();   // 进度回调  注意和 CLIENT_DownloadByRecordFileEx 的不一样 继承的接口不一样
        stuParamIn.dwDataUser = null;
        stuParamIn.fDownLoadDataCallBack = FileDownloadDataCallBack2.getInstance(); // 下载数据回调 注意 这个下载接口不能保存本地文件 所以数据只能从回调取
        stuParamIn.dwPosUser = null;

        NET_OUT_DOWNLOAD_BYFILE_SELFADAPT stuParamOut = new NET_OUT_DOWNLOAD_BYFILE_SELFADAPT();

        m_hDownLoadHandle = RecordModule.DownloadRecordFileWithSelfAdapt(m_hLoginHandle, stuParamIn, stuParamOut, 5000);

        if (m_hDownLoadHandle.longValue() == 0) {
            System.err.println("Start Download By File Failed :" + ENUMERROR.getErrorMessage());
        } else {
            System.out.println("Start Download By File Succeed");
        }

        // 起一个线程获取数据
        downloadTaskOpen = true;
        new Thread(this::downloadDataTask).start();
        new Thread(this::downloadPosTask).start();
    }


    /**
     * 33C300测试专用 用例
     * {
     * "CollectTime": "2021-07-05 10:30:07",
     * "DeviceID": "3G05E10YAJ2FED0",
     * "EndTime": "2021-07-05 10:19:12",
     * "FileName": "20210705101910.dav",
     * "FilePath": "/recno/463.dav",
     * "FileRemark": {
     * "CaseAddress": "",
     * "CaseID": "",
     * "CaseRemark": "",
     * "CaseType": 2,
     * "PicTurn": 0,
     * "UpLoadState": 1
     * },
     * "Format": 1,
     * "Length": 2983163,
     * "StartTime": "2021-07-05 10:19:10",
     * "Type": 1
     * }
     */
    public void DownloadRecord33C300SelfAdaptByFileAndFindFile() {

        FileDownLoadPosCallBack2.downloadPosQueue2.clear();
        FileDownloadDataCallBack2.downloadDataQueue2.clear();

        if (m_hLoginHandle.longValue() == 0) {
            System.err.println("请先登录");
            return;
        }

        // 设置查询条件
        NET_IN_DOWNLOAD_BYFILE_SELFADAPT stuParamIn = new NET_IN_DOWNLOAD_BYFILE_SELFADAPT();
        stuParamIn.emRecordType = 1;
        // 两个 byte[] 长度并不相同 必须使用 arraycopy
        System.arraycopy("/recno/463.dav".getBytes(), 0, stuParamIn.szFileName, 0, Math.min("/recno/463.dav".length(), stuParamIn.szFileName.length));
        stuParamIn.size = (int) 2983163 / 1024;
        stuParamIn.stuStartTime = new NetSDKLib.NET_TIME();
        stuParamIn.stuStartTime.setTime(2021,7,5,10,19,10);

        stuParamIn.stuEndTime = new NetSDKLib.NET_TIME();
        stuParamIn.stuEndTime.setTime(2021,7,5,10,19,12);

        stuParamIn.cbDownLoadPos = FileDownLoadPosCallBack2.getInstance();   // 进度回调  注意和 CLIENT_DownloadByRecordFileEx 的不一样 继承的接口不一样
        stuParamIn.dwDataUser = null;
        stuParamIn.fDownLoadDataCallBack = FileDownloadDataCallBack2.getInstance(); // 下载数据回调 注意 这个下载接口不能保存本地文件 所以数据只能从回调取
        stuParamIn.dwPosUser = null;

        NET_OUT_DOWNLOAD_BYFILE_SELFADAPT stuParamOut = new NET_OUT_DOWNLOAD_BYFILE_SELFADAPT();

        m_hDownLoadHandle = RecordModule.DownloadRecordFileWithSelfAdapt(m_hLoginHandle, stuParamIn, stuParamOut, 5000);

        if (m_hDownLoadHandle.longValue() == 0) {
            System.err.println("Start Download By File Failed :" + ENUMERROR.getErrorMessage());
        } else {
            System.out.println("Start Download By File Succeed");
        }

        // 起一个线程获取数据
        downloadTaskOpen = true;
        new Thread(this::downloadDataTask).start();
        new Thread(this::downloadPosTask).start();
    }

    private boolean downloadTaskOpen = false;

    // 获取监听回调数据并放入缓存
    public void downloadDataTask() {

        String savePath = new File(".").getAbsoluteFile().getParent() + "\\" + System.currentTimeMillis() + ".MP4";
        RandomAccessFile file = null;
        try {
            file = new RandomAccessFile(new File(savePath), "rw");
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
        int offset = 0;
        while (downloadTaskOpen || !FileDownloadDataCallBack2.downloadDataQueue2.isEmpty()) {
            try {
                // 阻塞获取数据
                byte[] data = FileDownloadDataCallBack2.downloadDataQueue2.poll(50, TimeUnit.MILLISECONDS);
                if (file == null || data == null) continue;
                // 数据存入文件
                file.seek(offset);
                file.write(data);
                offset += data.length;
            } catch (InterruptedException | IOException e) {
                e.printStackTrace();
                try {
                    if (file != null) file.close(); // 关闭文件
                    break;
                } catch (IOException ex) {
                    ex.printStackTrace();
                    break;
                }
            }
        }

        try {
            if (file != null) file.close(); // 关闭文件
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 获取监听回调进度
    public void downloadPosTask() {

        DecimalFormat df = new DecimalFormat("######0.00");

        while (downloadTaskOpen || !FileDownLoadPosCallBack2.downloadPosQueue2.isEmpty()) {
            try {
                // 判断下载进度
                DownloadPosInfo pos = FileDownLoadPosCallBack2.downloadPosQueue2.poll(50, TimeUnit.MILLISECONDS);
                if (pos != null) {
                    if (pos.downloadSize == -1) {
                        downloadTaskOpen = false;
                        System.out.println(String.format("download pos: %d%%  totalSize(kb): %d task completed",
                                100, pos.totalSize));
                    } else {
                        System.out.println(String.format("download pos: %2s%% downloadSize(kb): %d totalSize(kb): %d",
                                df.format(pos.downloadPos), pos.totalSize, pos.downloadSize));
                    }
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 停止下载录像
     */
    public void StopDownLoadRecordFile() {
        RecordModule.StopDownLoadRecordFile(m_hDownLoadHandle);
        downloadTaskOpen = false;
    }

    /**
     * 查找录像 需要指定查询录像的最大个数
     * 这个接口只是用于协助演示录像下载用的 比较简单 需要手动预填最大文件数量 实际开发请走 FindFile 接口
     */
    public List<NetSDKLib.NET_RECORDFILE_INFO> QueryRecordFile() {
        NetSDKLib.NET_TIME stTimeStart = new NetSDKLib.NET_TIME();
        stTimeStart.setTime(2021, 6, 8, 0, 0, 0);

        NetSDKLib.NET_TIME stTimeEnd = new NetSDKLib.NET_TIME();
        stTimeEnd.setTime(2021, 7, 2, 10, 15, 0);

        //////////// 按时间查找视频文件 //////////
        ////////////////////////////////////////

        int maxFileCount = 50; // 查询的最大文件个数
        NetSDKLib.NET_RECORDFILE_INFO[] fileInfos = new NetSDKLib.NET_RECORDFILE_INFO[maxFileCount];
        for (int i = 0; i < maxFileCount; i++) {
            fileInfos[i] = new NetSDKLib.NET_RECORDFILE_INFO();
        }
        int retCount = RecordModule.QueryRecordFileByTimeLimit(m_hLoginHandle, maxFileCount, fileInfos, stTimeStart, stTimeEnd);
        if (retCount == -1) {
            System.err.println("查询录像文件失败!" + ENUMERROR.getErrorMessage());
        }
        System.out.println("查询录像文件成功 共查询到录像数: " + retCount);

        // 打印看一下
        StringBuilder info = new StringBuilder()
                .append("QueryRecordFile  Succeed! \n" + "查询到的视频个数：")
                .append(retCount).append("\n")
                .append("码流类型：").append(fileInfos[0].bRecType).append("\n");
        for (int i = 0; i < retCount; i++) {
            info.append("【").append(i).append("】：").append("\n")
                    .append("文件名：").append(new String(fileInfos[i].filename, encode)).append("\n")
                    .append("文件长度：").append(fileInfos[i].size).append("\n")
                    .append("开始时间：").append(fileInfos[i].starttime).append("\n")
                    .append("结束时间：").append(fileInfos[i].endtime).append("\n")
                    .append("通道号：").append(fileInfos[i].ch).append("\n");
        }
        System.out.println(info.toString());

        return new ArrayList<>(Arrays.asList(fileInfos).subList(0, retCount));
    }

    /**
     * 查询 录像文件
     */
    public void findFileExMediaRecord() {

        if (m_hLoginHandle.longValue() == 0) {
            System.err.println("Please Login First");
            return;
        }
        mediaRecords.clear();

        ///////////////////////////// 开始查询 /////////////////////////////
        ///////////////////////////////////////////////////////////////////

        NetSDKLib.NET_TIME stTimeStart = new NetSDKLib.NET_TIME();
        stTimeStart.setTime(2021, 7, 1, 0, 0, 0);

        NetSDKLib.NET_TIME stTimeEnd = new NetSDKLib.NET_TIME();
        stTimeEnd.setTime(2021, 7, 20, 23, 15, 0);

        int type = NetSDKLib.EM_FILE_QUERY_TYPE.NET_FILE_QUERY_FILE;
        // 查询条件
        NetSDKLib.NET_IN_MEDIA_QUERY_FILE queryCondition = new NetSDKLib.NET_IN_MEDIA_QUERY_FILE();
        // 工作目录列表,一次可查询多个目录,为空表示查询所有目录。
        // 目录之间以分号分隔,如“/mnt/dvr/sda0;/mnt/dvr/sda1”,szDirs==null 或 "" 表示查询所有
        queryCondition.szDirs = null;         // 查询所有
        queryCondition.nMediaType = 2;      // 文件类型 1:查询jpg图片,2:查询dav
        queryCondition.nChannelID = -1;     // 通道号从0开始,-1表示查询所有通道
        queryCondition.stuStartTime = stTimeStart;    // 开始时间
        queryCondition.stuEndTime = stTimeEnd;        // 结束时间

        NetSDKLib.LLong m_lFindMediaHandle = RecordModule.FindFileEx(m_hLoginHandle, type, queryCondition, 5000);
        if (m_lFindMediaHandle.longValue() == 0) {
            System.err.println("FindFileEx Failed!" + ENUMERROR.getErrorMessage());
            return;
        }

        ///////////////////////////// 文件总数 /////////////////////////////
        ///////////////////////////////////////////////////////////////////

        // 获取违章总数
        int totalCount = RecordModule.GetTotalFileCount(m_lFindMediaHandle, 3000);
        if (totalCount == -1) {
            System.err.println("获取查询总数失败:" + ENUMERROR.getErrorMessage());
            // 查询异常，直接退出查询
            RecordModule.FindCloseEx(m_lFindMediaHandle);
            return;
        }

        if (totalCount == 0) {
            System.out.println("没有查询到任何录像数据");
            RecordModule.FindCloseEx(m_lFindMediaHandle);
            return;
        }

        ///////////////////////////// 获取查询结果 /////////////////////////////
        //////////////////////////////////////////////////////////////////////

        int queryCount = Math.min(10, totalCount); // 每次获取的违章数量
        NetSDKLib.NET_OUT_MEDIA_QUERY_FILE[] mediaFileInfos = new NetSDKLib.NET_OUT_MEDIA_QUERY_FILE[queryCount];
        for (int i = 0; i < mediaFileInfos.length; ++i) {
            mediaFileInfos[i] = new NetSDKLib.NET_OUT_MEDIA_QUERY_FILE();
        }

        final int memorySize = mediaFileInfos[0].size() * queryCount;
        Pointer mediaFileMemory = new Memory(memorySize);
        mediaFileMemory.clear(memorySize);

        // 循环查询
        int nCurrIndex = 0;
        do {
            // 查询
            // int nRet = RecordModule.FindNextFileEx(m_lFindMediaHandle, mediaFileInfos, mediaFileMemory, 5000);
            int nRet = RecordModule.FindNextMediaFileEx(m_lFindMediaHandle, mediaFileInfos, mediaFileMemory, 5000);
            if (nRet < 0) {
                System.err.println("获取查询信息失败:" + ENUMERROR.getErrorMessage());
                break;
            }

            // 打印一下获取到的信息内容
            StringBuilder printInfo = new StringBuilder();
            for (int j = 0; j < nRet; j++) {

                NetOutMediaQueryFile info = new NetOutMediaQueryFile();
                // 注意：循环中 mediaFileInfos 一直是同一组对象 所以获取数据必须使用深拷贝
                info.nChannelID = mediaFileInfos[j].nChannelID;
                info.stuStartTime = new NetSDKLib.NET_TIME(mediaFileInfos[j].stuStartTime);
                info.stuEndTime = new NetSDKLib.NET_TIME(mediaFileInfos[j].stuEndTime);
                info.byFileType = mediaFileInfos[j].byFileType;
                info.byPartition = mediaFileInfos[j].byPartition;
                info.byVideoStream = mediaFileInfos[j].byVideoStream;
                info.nCluster = mediaFileInfos[j].nCluster;
                info.szFilePath = new byte[mediaFileInfos[j].szFilePath.length];
                System.arraycopy(mediaFileInfos[j].szFilePath, 0, info.szFilePath, 0, mediaFileInfos[j].szFilePath.length);
                info.nDriveNo = mediaFileInfos[j].nDriveNo;
                info.nFileSizeEx = mediaFileInfos[j].nFileSizeEx;
                info.nTotalFrame = mediaFileInfos[j].nTotalFrame;
                info.emFileState = mediaFileInfos[j].emFileState;

                mediaRecords.add(info);
                printInfo
                        .append("-------------------------")
                        .append(nCurrIndex)
                        .append("---------------------------\n")
                        .append("  开始时间: ")
                        .append(info.stuStartTime.toString())
                        .append("\n")
                        .append("  结束时间: ")
                        .append(info.stuEndTime.toString())
                        .append("\n")
                        .append("  文件路径: ")
                        .append(new String(info.szFilePath, encode))
                        .append("\n")
                        .append("  文件类型: ")
                        .append(info.byFileType == 1 ? "jpg图片" : "dav文件")
                        .append("\n")
                        .append("  文件长度Ex: ")
                        .append(info.nFileSizeEx)
                        .append("\n");
                ++nCurrIndex;
            }
            System.out.println(printInfo.toString());
        } while ((totalCount -= queryCount) > 0);

        ///////////////////////////// 结束查询 /////////////////////////////
        ///////////////////////////////////////////////////////////////////

        RecordModule.FindCloseEx(m_lFindMediaHandle);
    }

    /////////////////////////////////////// 简易控制台 ///////////////////////////////////////
    /////////////////////////////////////////////////////////////////////////////////////////
    /////////////////////////////////////////////////////////////////////////////////////////

    /**
     * 初始化测试
     */
    public void InitTest() {
        SdkUtilModule.Init();  // 初始化SDK库
        NetSDKLib.LLong loginHandle = LogonModule.TcpLoginWithHighSecurity(m_ipAddr, m_nPort, m_username, m_password, m_hDeviceInfo);  // 高安全登录
        if (loginHandle.intValue() == 0) {
            SdkUtilModule.cleanup();
        }
        m_hLoginHandle.setValue(loginHandle.longValue());
    }

    public void RunTest() {
        CaseMenu menu = new CaseMenu();
        menu.addItem(new CaseMenu.Item(this, "查询采集站和手持终端文件信息", "findFileExQueryMobileEnforce"));
        menu.addItem(new CaseMenu.Item(this, "查询录像信息", "findFileExMediaRecord"));
        menu.addItem(new CaseMenu.Item(this, "下载录像", "DownloadRecordByFile"));
        menu.addItem(new CaseMenu.Item(this, "下载录像(FindFileEx)", "DownloadRecordByFileAndFindFile"));
        menu.addItem(new CaseMenu.Item(this, "下载录像sdk自适应(FindFileEx)", "DownloadRecordWithSelfAdaptByFileAndFindFile"));
        menu.addItem(new CaseMenu.Item(this, "下载录像33C300测试sdk自适应(FindFileEx)", "DownloadRecord33C300SelfAdaptByFileAndFindFile"));
        menu.addItem(new CaseMenu.Item(this, "停止下载录像", "StopDownLoadRecordFile"));
        menu.run();
        System.out.println("子测试已退出");
    }

    /**
     * 结束测试
     */
    public void EndTest() {
        System.out.println("End Test");
        LogonModule.logout(m_hLoginHandle);  // 登出
        System.out.println("See You...");
        SdkUtilModule.cleanup();             // 清理资源
        System.exit(0);
    }

    /////////////// 配置登陆地址，端口，用户名，密码  ////////////////////////
//    private String m_ipAddr = "172.8.2.99";  // MPT
    private String m_ipAddr = "172.11.2.20"; // 33C300
    private int m_nPort = 37777;
    private String m_username = "admin";
    //    private String m_password = "qqqqq1";   // MPT
    private String m_password = "admin123";   // 33C300
    //////////////////////////////////////////////////////////////////////

    public static void main(String[] args) {

        NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
        NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0);
        Demo33C300 demo = new Demo33C300(loginHandle, deviceInfo);
        if (args.length == 4) {
            demo.m_ipAddr = args[0];
            demo.m_nPort = Integer.parseInt(args[1]);
            demo.m_username = args[2];
            demo.m_password = args[3];
        }
        demo.InitTest();
        demo.RunTest();
        demo.EndTest();
    }
}