package com.netsdk.demo.customize;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.LastError;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.PlaySDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.utils.Initialization;
import com.sun.jna.Native;
import com.sun.jna.ptr.IntByReference;

import javax.swing.*;
import java.awt.*;
import java.io.ByteArrayOutputStream;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.Date;//导入Date类
import java.util.Timer;//Timer类
import java.util.TimerTask;//导入  TimerTask类

import static com.netsdk.demo.customize.PlayBackWithDataOnly.playsdk;

public class AutoPlayPushTestDemo extends Initialization {

    //智能报警句柄
    private NetSDKLib.LLong m_hPlayHandle = new NetSDKLib.LLong(0);

    private static int index = -1;

    JWindow wnd;


    private final NetSDKLib.NET_TIME m_startTime = new NetSDKLib.NET_TIME(); // 开始时间
    private final NetSDKLib.NET_TIME m_stopTime = new NetSDKLib.NET_TIME();  // 结束时间
    // The constant net sdk
    public static final NetSDKLib netsdk = NetSDKLib.NETSDK_INSTANCE;

    // The constant config sdk.
    public static NetSDKLib configsdk = NetSDKLib.CONFIG_INSTANCE;

    // The constant play sdk
    public static final PlaySDKLib playsdk = PlaySDKLib.PLAYSDK_INSTANCE;


    private static final PlayBackWithDataOnly.DownLoadPosCallBack m_PlayBackDownLoadPos = new PlayBackWithDataOnly.DownLoadPosCallBack(); // 回放数据下载进度

    private static final PlayBackWithDataOnly.DataCallBack m_dataCallBack = new PlayBackWithDataOnly.DataCallBack(); // 回放数据回调

    private static final PlayBackWithDataOnly.PlayDecCallBack m_playDecCallBack = new PlayBackWithDataOnly.PlayDecCallBack();  // Play SDK 回放

    private static final ExecutorService dataParseService = Executors.newFixedThreadPool(5);

    private static final int channel = 10;   // NetSDK 对应的 设备通道

    private static final int port = 10;     // PlaySDK 解码端口
    private static final LinkedBlockingDeque<ByteArrayOutputStream> queue = new LinkedBlockingDeque<>();

    public void PushTest(){

            wnd = new JWindow();
            Dimension screenSize = Toolkit.getDefaultToolkit().getScreenSize();
            screenSize.height /= 2;
            screenSize.width /= 2;
            wnd.setSize(screenSize);

            Dimension dim = Toolkit.getDefaultToolkit().getScreenSize();
            int w = wnd.getSize().width;
            int h = wnd.getSize().height;
            int x = (dim.width - w) / 2;
            int y = (dim.height - h) / 2;
            wnd.setLocation(x, y);

        Timer timer = new Timer();//创建Timer类对象
        Timer timer2 = new Timer();
        TimerTask playback = new TimerTask() {
            @Override
            public void run() {
                System.out.println("触发回放预览，时间为" + new Date());//输出当前的时间
                StartPlayBack();
            }
        };
        TimerTask stopplayback = new TimerTask() {
            @Override
            public void run() {
                System.out.println("触发停止回放预览，时间为" + new Date());//输出当前的时间
                StopPlayBack();
            }
        };
        TimerTask realplay = new TimerTask() {
            @Override
            public void run() {
                System.out.println("触发实时预览，时间为" + new Date());//输出当前的时间
                Realplay();
            }
        };
        TimerTask stoprealplay = new TimerTask() {
            @Override
            public void run() {
                System.out.println("触发停止实时预览，时间为" + new Date());//输出当前的时间
                StopRealPlay();
            }
        };
        timer.schedule(realplay, 0, 1000*600);
        timer.schedule(stoprealplay, 1000*150, 1000*600);
        timer.schedule(playback, 1000*300, 1000*600);
        timer.schedule(stopplayback, 1000*450, 1000*600);

    }

    public void SetStartTime(){
        Scanner sc = new Scanner(System.in);
        System.out.print("year:");
        String tmp = sc.nextLine();
        int year = Integer.parseInt(tmp);
        System.out.print("month:");
        tmp = sc.nextLine();
        int month = Integer.parseInt(tmp);
        System.out.print("day:");
        tmp = sc.nextLine();
        int day = Integer.parseInt(tmp);
        System.out.print("hour:");
        tmp = sc.nextLine();
        int hour = Integer.parseInt(tmp);
        System.out.print("minute:");
        tmp = sc.nextLine();
        int minute = Integer.parseInt(tmp);
        System.out.print("second:");
        tmp = sc.nextLine();
        int second = Integer.parseInt(tmp);
        m_startTime.setTime(year,month,day,hour,minute,second);
    }

    public void SetStopTime(){
        Scanner sc = new Scanner(System.in);
        System.out.print("year:");
        String tmp = sc.nextLine();
        int year = Integer.parseInt(tmp);
        System.out.print("month:");
        tmp = sc.nextLine();
        int month = Integer.parseInt(tmp);
        System.out.print("day:");
        tmp = sc.nextLine();
        int day = Integer.parseInt(tmp);
        System.out.print("hour:");
        tmp = sc.nextLine();
        int hour = Integer.parseInt(tmp);
        System.out.print("minute:");
        tmp = sc.nextLine();
        int minute = Integer.parseInt(tmp);
        System.out.print("second:");
        tmp = sc.nextLine();
        int second = Integer.parseInt(tmp);
        m_stopTime.setTime(year,month,day,hour,minute,second);
    }

    /**
     * 开启回放
     */
    public void StartPlayBack() {


        // 配置 PlaySDK
        playsdk.PLAY_OpenStream(port, null, 0, 4 * 1024 * 1024);
        playsdk.PLAY_SetDecCallBackEx(port, m_playDecCallBack, null);
        playsdk.PLAY_Play(port, null);

        // 设置回放时的码流类型
        IntByReference steamType = new IntByReference(0);           // 0-主辅码流,1-主码流,2-辅码流
        int emType = NetSDKLib.EM_USEDEV_MODE.NET_RECORD_STREAM_TYPE;

        boolean bret = netsdk.CLIENT_SetDeviceMode(loginHandle, emType, steamType.getPointer());
        if (!bret) {
            System.err.println("Set Stream Type Failed" + ToolKits.getErrorCode());
        }

        // 设置回放时的录像文件类型
        IntByReference emFileType = new IntByReference(0); // 所有录像 NET_RECORD_TYPE
        emType = NetSDKLib.EM_USEDEV_MODE.NET_RECORD_TYPE;
        bret = netsdk.CLIENT_SetDeviceMode(loginHandle, emType, emFileType.getPointer());
        if (!bret) {
            System.err.println("Set Record Type Failed " + ToolKits.getErrorCode());
        }

        m_hPlayHandle = netsdk.CLIENT_PlayBackByTimeEx(loginHandle, channel, m_startTime, m_stopTime,
                null, m_PlayBackDownLoadPos, null, m_dataCallBack, null);

        if (m_hPlayHandle.longValue() == 0) {
            int error = netsdk.CLIENT_GetLastError();
            System.err.println("PlayBackByTimeEx Failed " + ToolKits.getErrorCode());
            switch (error) {
                case LastError.NET_NO_RECORD_FOUND:
                    System.out.println("查找不到录像");
                    break;
                default:
                    System.out.println("开启失败");
                    break;
            }
        } else {
            System.out.println("PlayBackByTimeEx Succeed.");
        }

        // 启动新线程 顺序向PlaySDK写入数据 线程在句柄清空后关闭
        new Thread(new Runnable() {
            @Override
            public void run() {
                while (m_hPlayHandle.longValue() != 0) {
                    try {
                        ByteArrayOutputStream stream = queue.take();
                        final byte[] data = stream.toByteArray();
                        playsdk.PLAY_InputData(port, data, data.length);
                    } catch (InterruptedException e) {
                        System.err.println(e.getMessage());
                    }
                }
            }
        }).start();
    }

    /**
     * 停止回放
     */
    public void StopPlayBack() {
        if (m_hPlayHandle.longValue() == 0) {
            System.err.println("Please make sure the PlayBack Handle is valid");
            return;
        }

        if (!netsdk.CLIENT_StopPlayBack(m_hPlayHandle)) {
            System.err.println("StopPlayBack Failed");
            return;
        }

        // 关闭PlaySDK解码端口
        playsdk.PLAY_Stop(port);
        playsdk.PLAY_CloseStream(port);

        System.out.println("StopPlayBack Succeed.");

        m_hPlayHandle.setValue(0);
    }

    public void Realplay(){
        if (loginHandle.longValue() == 0) {
            System.err.println("Please login first");
        }
        wnd.setVisible(true);
        int channel = 0; // 预览通道号， 设备有多通道的情况，可手动更改
        int playType = NetSDKLib.NET_RealPlayType.NET_RType_Realplay; // 实时预览

        m_hPlayHandle = netSdk.CLIENT_RealPlayEx(loginHandle, channel, Native.getComponentPointer(wnd), playType);
        if (m_hPlayHandle.longValue() == 0) {
            int error = netSdk.CLIENT_GetLastError();
            System.err.println("开始实时预览失败，错误码：" + String.format("[0x%x]", error));
        }
        else {
            System.out.println("Success to start realplay");
            netSdk.CLIENT_SetRealDataCallBackEx(m_hPlayHandle, CommonWithCallBack.RealDataCallBack.getInstance(), null, 0);
        }
    }

    public void StopRealPlay(){
        wnd.setVisible(false);
        if(netSdk.CLIENT_StopRealPlayEx(m_hPlayHandle)){
            System.out.println("StopRealPlay success");
        }
    }

    public void RunTest()
    {
        System.out.println("Run Test");
        CaseMenu menu = new CaseMenu();;
        menu.addItem((new CaseMenu.Item(this , "PushTest" , "PushTest")));
        menu.addItem((new CaseMenu.Item(this , "SetStartTime" , "SetStartTime")));
        menu.addItem((new CaseMenu.Item(this , "SetStopTime" , "SetStopTime")));
//        menu.addItem((new CaseMenu.Item(this , "DetachEventRealLoadPic" , "DetachEventRealLoadPic")));

        menu.run();
    }
    public static void main(String[] args) {
        AutoPlayPushTestDemo AutoPlayPushTestDemo=new AutoPlayPushTestDemo();
        Scanner sc = new Scanner(System.in);
        System.out.print("ip:");
        String ip = sc.nextLine();
        System.out.print("port:");
        String tmp = sc.nextLine();
        int port = Integer.parseInt(tmp);
        System.out.print("username:");
        String username = sc.nextLine();
        System.out.print("password:");
        String pwd = sc.nextLine();
        InitTest(ip,port,username,pwd);
        AutoPlayPushTestDemo.RunTest();
        LoginOut();

    }
}