package com.netsdk.demo.customize;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.enumeration.*;
import com.netsdk.lib.structure.*;
import com.netsdk.lib.utils.Initialization;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;

import java.io.File;
import java.io.UnsupportedEncodingException;
import java.util.Date;
import java.util.Objects;
import java.util.Scanner;

import static com.netsdk.lib.NetSDKLib.NET_MAX_DETECT_REGION_NUM;

public class VideoAnalyseAnalyseProcDemo extends Initialization {

	int channel = 0;

	public void setChannel(int channel) {
		this.channel = channel;
	}

	NetSDKLib.LLong attachHandle = new NetSDKLib.LLong(0);

	/**
	 * 订阅智能任务
	 */

	public NetSDKLib.LLong AttachVideoAnalyseAnalyseProc() {
		// 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
		if (attachHandle.longValue() != 0) {
			this.DetachVideoAnalyseAnalyseProc();
		}

		NET_IN_ATTACH_VIDEO_ANALYSE_ANALYSE_PROC stIn = new NET_IN_ATTACH_VIDEO_ANALYSE_ANALYSE_PROC();
		stIn.nChannelId = channel;
		NET_OUT_ATTACH_VIDEO_ANALYSE_ANALYSE_PROC stOut = new NET_OUT_ATTACH_VIDEO_ANALYSE_ANALYSE_PROC();
		stIn.cbVideoAnalyseAnalyseProc = new VideoAnalyseAnalyseCB();

		stIn.write();
		stOut.write();

		System.out.println("stIn.dwSize = " + stIn.dwSize);
		System.out.println("stOut.dwSize = " + stOut.dwSize);

		attachHandle = netSdk.CLIENT_AttachVideoAnalyseAnalyseProc(loginHandle, stIn.getPointer(), stOut.getPointer(),
				5000);
		if (attachHandle.longValue() != 0) {
			System.out.printf("Chn[%d] CLIENT_AttachVideoAnalyseAnalyseProc Success\n", channel);
		} else {
			System.out.printf("Chn[%d] CLIENT_AttachVideoAnalyseAnalyseProc Failed!LastError = %s\n", channel,
					ToolKits.getErrorCode());
		}

		return attachHandle;
	}

	/**
	 * 报警事件（智能）回调
	 */
	private static class VideoAnalyseAnalyseCB implements NetSDKLib.fVideoAnalyseAnalyseProc {
		private static VideoAnalyseAnalyseProcDemo.VideoAnalyseAnalyseCB instance;

		private VideoAnalyseAnalyseCB() {
		}

		public static VideoAnalyseAnalyseProcDemo.VideoAnalyseAnalyseCB getInstance() {
			if (instance == null) {
				synchronized (VideoAnalyseAnalyseProcDemo.VideoAnalyseAnalyseCB.class) {
					if (instance == null) {
						instance = new VideoAnalyseAnalyseProcDemo.VideoAnalyseAnalyseCB();
					}
				}
			}
			return instance;
		}

		@Override
		public void invoke(NetSDKLib.LLong lAttachHandle, Pointer pstuVideoAnalyseTrackProc, Pointer dwUser) {
			System.out.println("========================Enter invoke========================");
			NET_VIDEO_ANALYSE_ANALYSE_PROC msg = new NET_VIDEO_ANALYSE_ANALYSE_PROC();
			ToolKits.GetPointerData(pstuVideoAnalyseTrackProc, msg);
			System.out.println("msg.nChannelId = " + msg.nChannelId);
			System.out.println("msg.stuUTC = " + msg.stuUTC.toStringTime());

			System.out.println("msg.nObjectListNum = " + msg.nObjectListNum);
			NET_VEHICLE_FUSED_OBJECT[] tmpObjectList = new NET_VEHICLE_FUSED_OBJECT[msg.nObjectListNum];
			for (int i = 0; i < msg.nObjectListNum; i++) {
				tmpObjectList[i] = new NET_VEHICLE_FUSED_OBJECT();
			}
//            msg.pstuObjectList = new Memory(tmpObjectList[0].size() * msg.nObjectListNum);
			ToolKits.GetPointerDataToStructArr(msg.pstuObjectList, tmpObjectList);
			for (int i = 0; i < msg.nObjectListNum; i++) {
				System.out.println("ObjectList[" + i + "].nObjectID = " + tmpObjectList[i].nObjectID);
				System.out.println("ObjectList[" + i + "].emObjectType = " + tmpObjectList[i].emObjectType);
				System.out.println("ObjectList[" + i + "].fSpeed = " + tmpObjectList[i].fSpeed);
				System.out.println("ObjectList[" + i + "].fAcceleration = " + tmpObjectList[i].fAcceleration);
				System.out.println("ObjectList[" + i + "].nLaneID = " + tmpObjectList[i].nLaneID);
				System.out.println("ObjectList[" + i + "].nLocatedAreasNum = " + tmpObjectList[i].nLocatedAreasNum);
				for(int j = 0; j < tmpObjectList[i].nLocatedAreasNum; j ++){
					System.out.println("ObjectList[" + i + "].stuLocatedAreas["+j+"].nType = " + tmpObjectList[i].stuLocatedAreas[j].nType);
					System.out.println("ObjectList[" + i + "].stuLocatedAreas["+j+"].szIDStr = " + new String(tmpObjectList[i].stuLocatedAreas[j].szIDStr).trim());
				}
			}

			System.out.println("msg.nEventListCount = " + msg.nEventListCount);
			int[] dwEventCode = msg.dwEventCode;
			for (int i = 0; i < msg.nEventListCount; i++) {
				if (dwEventCode[i] != NetSDKLib.EVENT_IVS_COLLISION_CONFLICT) {
					return;
				}
				;
				NET_DEV_EVENT_COLLISION_CONFLICT_INFO tmpEvent = new NET_DEV_EVENT_COLLISION_CONFLICT_INFO();
				ToolKits.GetPointerDataToStruct(msg.pstuEventList[i], 0, tmpEvent);

				System.out.println("EventList[" + i + "].nChannelID = " + tmpEvent.nChannelID);
				System.out.println("EventList[" + i + "].nAction = " + tmpEvent.nAction);
				System.out.println("EventList[" + i + "].szName = " + new String(tmpEvent.szName).trim());
				System.out.println("EventList[" + i + "].nEventID = " + tmpEvent.nEventID);
				System.out.println("EventList[" + i + "].nType = " + tmpEvent.nType);
				System.out.println("EventList[" + i + "].nLeftTime = " + tmpEvent.nLeftTime);
				System.out.println("EventList[" + i + "].fConflictLevel = " + tmpEvent.fConflictLevel);
				System.out.println("EventList[" + i + "].fConfidence = " + tmpEvent.fConfidence);
				System.out.println("EventList[" + i + "].nObjectsCount = " + tmpEvent.nObjectsCount);
				for (int j = 0; j < tmpEvent.nObjectsCount; j++) {
					System.out.println("EventList[" + i + "].stuObjects[" + j + "].nObjectID = "+ tmpEvent.stuObjects[j].nObjectID);
					System.out.println("EventList[" + i + "].stuObjects[" + j + "].emObjectType = "+ tmpEvent.stuObjects[j].emObjectType);
					System.out.println("EventList[" + i + "].stuObjects[" + j + "].fSpeed = " + tmpEvent.stuObjects[j].fSpeed);
					System.out.println("EventList[" + i + "].stuObjects[" + j + "].fAcceleration = "+ tmpEvent.stuObjects[j].fAcceleration);
					System.out.println("EventList[" + i + "].stuObjects[" + j + "].nLaneID = " + tmpEvent.stuObjects[j].nLaneID);
				}
			}

		}
	}

	/**
	 * 停止侦听智能事件
	 */
	public void DetachVideoAnalyseAnalyseProc() {
		if (this.attachHandle.longValue() != 0) {
			netSdk.CLIENT_DetachVideoAnalyseAnalyseProc(this.attachHandle);
		}
	}

	public void RunTest() {
		System.out.println("Run Test");
		CaseMenu menu = new CaseMenu();
		;
		menu.addItem((new CaseMenu.Item(this, "AttachVideoAnalyseAnalyseProc", "AttachVideoAnalyseAnalyseProc")));
		menu.addItem((new CaseMenu.Item(this, "DetachVideoAnalyseAnalyseProc", "DetachVideoAnalyseAnalyseProc")));

		menu.run();
	}

	public static void main(String[] args) {
		VideoAnalyseAnalyseProcDemo RealLoadPicExDemo = new VideoAnalyseAnalyseProcDemo();
		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();
		String ip = "10.33.121.89";
		int port = 32200;
		String username = "admin";
		String pwd = "admin123";
		InitTest(ip, port, username, pwd);

//		System.out.print("channel:");
//        String tmp2 = sc.nextLine();
//        int channel = Integer.parseInt(tmp2);
		int channel = 0;
		RealLoadPicExDemo.setChannel(channel);

		RealLoadPicExDemo.RunTest();
		LoginOut();

	}
}