package com.netsdk.demo.intelligentTraffic;

import static com.netsdk.lib.Utils.getOsPrefix;

import com.netsdk.demo.customize.PrintStruct;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.CFG_TIME_SCHEDULE;
import com.netsdk.lib.NetSDKLib.CFG_TIME_SECTION;
import com.netsdk.lib.NetSDKLib.LLong;
import com.netsdk.lib.NetSDKLib.NET_CFG_TIME_SCHEDULE;
import com.netsdk.lib.NetSDKLib.NET_CFG_TRAFFICSTROBE_INFO;
import com.netsdk.lib.NetSDKLib.NET_EM_CFG_TRAFFICSTROBE_CTRTYPE;
import com.netsdk.lib.NetSDKLib.NET_POINT;
import com.netsdk.lib.NetSDKLib.NET_TSECT;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.enumeration.EM_RELAY_STATE_TYPE;
import com.netsdk.lib.enumeration.EM_TRAFFICSTROBE_STATUS;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_DEVICE_WORK_STATE;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_GROUND_SENSE_IN_STATE_TYPE;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_RADAR_COIL_MATCH_STATE;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_RADAR_DETECT_CAR_STATE;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_STROBE_ACTION_REASON_TYPE;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_STROBE_FAULT_CODE_TYPE;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_STROBE_IN_STATE_TYPE;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_STROBE_RAIL_STATE_TYPE;
import com.netsdk.lib.enumeration.EM_TRAFFIC_SNAP_STROBE_RUN_STATE;
import com.netsdk.lib.enumeration.ENUMERROR;
import com.netsdk.lib.enumeration.NET_EM_CFG_OPERATE_TYPE;
import com.netsdk.lib.structure.ALARM_TRAFFICSTROBESTATE_INFO;
import com.netsdk.lib.structure.NET_IN_TRAFFIC_SNAP_RADAR_INFO;
import com.netsdk.lib.structure.NET_IN_TRAFFIC_SNAP_STROBE_INFO;
import com.netsdk.lib.structure.NET_OUT_TRAFFIC_SNAP_RADAR_INFO;
import com.netsdk.lib.structure.NET_OUT_TRAFFIC_SNAP_STROBE_INFO;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

/**
 * @author 251823
 * @description 智能交通:道闸 雷达
 * @date 2020/12/14
 */
public class TrafficStrobeDemo {
	static NetSDKLib netsdkApi = NetSDKLib.NETSDK_INSTANCE;
	static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;

	private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
	private static LLong loginHandle = new LLong(0);

	private static class DisconnectCallback implements NetSDKLib.fDisConnect {
		private static DisconnectCallback instance = new DisconnectCallback();

		private DisconnectCallback() {
		}

		public static DisconnectCallback getInstance() {
			return instance;
		}

		public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
			System.out.printf("Device[%s:%d] Disconnect!\n", pchDVRIP, nDVRPort);
		}
	}

	private static class HaveReconnectCallback implements NetSDKLib.fHaveReConnect {
		private static HaveReconnectCallback instance = new HaveReconnectCallback();

		private HaveReconnectCallback() {
		}

		public static HaveReconnectCallback getInstance() {
			return instance;
		}

		public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
			System.out.printf("Device[%s:%d] HaveReconnected!\n", pchDVRIP, nDVRPort);
		}
	}

	public void EndTest() {
		System.out.println("End Test");
		if (loginHandle.longValue() != 0) {
			netsdkApi.CLIENT_Logout(loginHandle);
		}
		System.out.println("See You...");

		netsdkApi.CLIENT_Cleanup();
		System.exit(0);
	}

	public void InitTest() {
		// 初始化SDK库
		netsdkApi.CLIENT_Init(DisconnectCallback.getInstance(), null);

		// 设置断线自动重练功能
		netsdkApi.CLIENT_SetAutoReconnect(HaveReconnectCallback.getInstance(), null);

		// 向设备登入
		int nSpecCap = 0;
		IntByReference nError = new IntByReference(0);
		loginHandle = netsdkApi.CLIENT_LoginEx2(address, port, username, password, nSpecCap, null, deviceInfo, nError);

		if (loginHandle.longValue() == 0) {
			System.err.printf("Login Device [%s:%d] Failed ! Last Error[%x]\n", address, port,
					netsdkApi.CLIENT_GetLastError());
			EndTest();
			return;
		}

		System.out.printf("Login Device [%s:%d] Success. \n", address, port);
	}

	// 编码格式
	public static String encode;

	static {
		String osPrefix = getOsPrefix();
		if (osPrefix.toLowerCase().startsWith("win32-amd64")) {
			encode = "GBK";
		} else if (osPrefix.toLowerCase().startsWith("linux-amd64")) {
			encode = "UTF-8";
		}
	}

	/**
	 * 订阅报警信息
	 * 
	 */
	public void startListen() {
		// 设置报警回调函数
		netsdkApi.CLIENT_SetDVRMessCallBack(fAlarmAccessDataCB.getInstance(), null);

		// 订阅报警
		boolean bRet = netsdkApi.CLIENT_StartListenEx(loginHandle);
		if (!bRet) {
			System.err.println("订阅报警失败! LastError = 0x%x\n" + netsdkApi.CLIENT_GetLastError());
		} else {
			System.out.println("订阅报警成功.");
		}
	}

	/**
	 * 报警事件回调
	 */
	private static class fAlarmAccessDataCB implements NetSDKLib.fMessCallBack {
		private fAlarmAccessDataCB() {
		}

		private static class fAlarmDataCBHolder {
			private static fAlarmAccessDataCB instance = new fAlarmAccessDataCB();
		}

		public static fAlarmAccessDataCB getInstance() {
			return fAlarmDataCBHolder.instance;
		}

		public boolean invoke(int lCommand, LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP,
				NativeLong nDevicePort, Pointer dwUser) {
			switch (lCommand) {
			case NetSDKLib.NET_ALARM_TRAFFICSTROBESTATE: // 道闸栏状态事件(对应结构体 ALARM_TRAFFICSTROBESTATE_INFO)
			{
				ALARM_TRAFFICSTROBESTATE_INFO msg = new ALARM_TRAFFICSTROBESTATE_INFO();
				ToolKits.GetPointerData(pStuEvent, msg);
				System.out.println("事件动作:" + msg.bEventAction);
				System.out.println("事件发生时间:" + msg.stuTime.toString());
				System.out.println("视频通道号:" + msg.nChannelID);
				System.out.println("道闸栏状态:" + EM_TRAFFICSTROBE_STATUS.getNoteByValue(msg.emStatus));
				System.out.println("道闸开关闸原因:"
						+ EM_TRAFFIC_SNAP_STROBE_ACTION_REASON_TYPE.getNoteByValue(msg.emStrobeActionReason));
				break;
			}
			}
			return true;
		}
	}

	/**
	 * 取消订阅报警信息
	 * 
	 * @return
	 */
	public void stopListen() {
		// 停止订阅报警
		boolean bRet = netsdkApi.CLIENT_StopListen(loginHandle);
		if (bRet) {
			System.out.println("取消订阅报警信息.");
		}
	}

	/**
	 * 获取智能交通雷达信息
	 */
	public void queryTrafficSnapRadarInfo() {
		// 入参
		NET_IN_TRAFFIC_SNAP_RADAR_INFO pInBuf = new NET_IN_TRAFFIC_SNAP_RADAR_INFO();
		pInBuf.nChannel = 0;
		pInBuf.write();

		// 出参
		NET_OUT_TRAFFIC_SNAP_RADAR_INFO pOutBuf = new NET_OUT_TRAFFIC_SNAP_RADAR_INFO();
		pOutBuf.write();

		boolean flg = netsdkApi.CLIENT_QueryDevInfo(loginHandle, NetSDKLib.NET_QUERY_TRAFFIC_SNAP_RADAR,
				pInBuf.getPointer(), pOutBuf.getPointer(), null, 3000);
		if (flg) {
			pOutBuf.read();
			System.out.println("设备编号:" + new String(pOutBuf.szSerialNo));
			System.out.println("生产商:" + new String(pOutBuf.szVendor));
			System.out.println("设备型号:" + new String(pOutBuf.szDevType));
			System.out.println("工作状态:" + EM_TRAFFIC_SNAP_DEVICE_WORK_STATE.getNoteByValue(pOutBuf.emWorkState));
			System.out.println("线圈匹配状态:" + EM_TRAFFIC_SNAP_RADAR_COIL_MATCH_STATE.getNoteByValue(pOutBuf.emCoilMatch));
			System.out.println("实际返回虚警点个数:" + pOutBuf.nRetFakeAlarmPointNum);
			// 虚警坐标点信息
			NET_POINT[] stuFakeAlarmPointInfo = pOutBuf.stuFakeAlarmPointInfo;
			System.out.println("虚警坐标点信息:---------开始---------");
			for (int i = 0; i < pOutBuf.nRetFakeAlarmPointNum; i++) {
				System.out.println("坐标点" + i + ":" + stuFakeAlarmPointInfo[i].toString());
			}
			System.out.println("虚警坐标点信息:---------结束---------");
			System.out.println("实际返回虚警点个数:" + pOutBuf.nRelayWorkCount);
			System.out.println(
					"检测汽车状态:" + EM_TRAFFIC_SNAP_RADAR_DETECT_CAR_STATE.getNoteByValue(pOutBuf.emDetectCarState));
			System.out.println("串口号（连接相机的端口号）:" + pOutBuf.nCommPort);
		} else {
			System.out.println("获取智能交通雷达信息失敗:" + ENUMERROR.getErrorMessage());
		}

	}

	/**
	 * 获取智能交通道闸信息
	 */
	public void queryTrafficSnapStrobeInfo() {
		// 入参
		NET_IN_TRAFFIC_SNAP_STROBE_INFO pInBuf = new NET_IN_TRAFFIC_SNAP_STROBE_INFO();
		pInBuf.nChannel = 0;
		pInBuf.write();

		// 出参
		NET_OUT_TRAFFIC_SNAP_STROBE_INFO pOutBuf = new NET_OUT_TRAFFIC_SNAP_STROBE_INFO();
		pOutBuf.write();

		boolean flg = netsdkApi.CLIENT_QueryDevInfo(loginHandle, NetSDKLib.NET_QUERY_TRAFFIC_SNAP_STROBE,
				pInBuf.getPointer(), pOutBuf.getPointer(), null, 3000);
		if (flg) {
			pOutBuf.read();
			System.out.println("设备编号:" + new String(pOutBuf.szSerialNo));
			System.out.println("生产商:" + new String(pOutBuf.szVendor));
			System.out.println("设备型号:" + new String(pOutBuf.szDevType));
			System.out.println("工作状态:" + EM_TRAFFIC_SNAP_DEVICE_WORK_STATE.getNoteByValue(pOutBuf.emWorkState));
			System.out.println("故障代码:" + EM_TRAFFIC_SNAP_STROBE_FAULT_CODE_TYPE.getNoteByValue(pOutBuf.emFaultCode));
			System.out.println("出厂后开闸运行次数:" + pOutBuf.nOpenStrobeCount);
			System.out.println("运行状态:" + EM_TRAFFIC_SNAP_STROBE_RUN_STATE.getNoteByValue(pOutBuf.emRunState));
			System.out.println("道闸开关闸原因:"
					+ EM_TRAFFIC_SNAP_STROBE_ACTION_REASON_TYPE.getNoteByValue(pOutBuf.emStrobeActionReason));
			System.out.println("强继电器状态:" + EM_RELAY_STATE_TYPE.getNoteByValue(pOutBuf.emHeavyCurrentRelayState));
			System.out.println("信号继电器1:" + EM_RELAY_STATE_TYPE.getNoteByValue(pOutBuf.emSignalRelay1State));
			System.out.println("信号继电器2:" + EM_RELAY_STATE_TYPE.getNoteByValue(pOutBuf.emSignalRelay2State));
			System.out.println("地感输入信号:"
					+ EM_TRAFFIC_SNAP_GROUND_SENSE_IN_STATE_TYPE.getNoteByValue(pOutBuf.emGroundSenseInState));
			System.out.println(
					"开闸输入状态:" + EM_TRAFFIC_SNAP_STROBE_IN_STATE_TYPE.getNoteByValue(pOutBuf.emStrobeInPutState));
			System.out.println("栏杆状态:" + EM_TRAFFIC_SNAP_STROBE_RAIL_STATE_TYPE.getNoteByValue(pOutBuf.emRailState));
			System.out.println("串口号（连接相机的端口号）:" + pOutBuf.nCommPort);
		} else {
			System.out.println("获取智能交通道闸信息失败:" + ENUMERROR.getErrorMessage());
		}
	}

	/**
	 * 设置道闸配置
	 */
	public void setTrafficStrobeInfo() {
		// 入参
		NET_CFG_TRAFFICSTROBE_INFO trafficStrobeInfo = new NET_CFG_TRAFFICSTROBE_INFO();
		int emCfgOpType = NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_TRAFFICSTROBE;
		int nChannelID = 0;
		trafficStrobeInfo.bEnable = 1;
		trafficStrobeInfo.nCtrlTypeCount = 2;
		trafficStrobeInfo.emCtrlType[0] = NET_EM_CFG_TRAFFICSTROBE_CTRTYPE.NET_EM_CFG_CTRTYPE_TRAFFICTRUSTLIST;
		trafficStrobeInfo.emCtrlType[1] = NET_EM_CFG_TRAFFICSTROBE_CTRTYPE.NET_EM_CFG_CTRTYPE_ALLSNAPCAR;
		trafficStrobeInfo.stuStationaryOpen.bEnable = 1;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.bEnableHoliday = 1;

		CFG_TIME_SECTION[] stuTimeSection = trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay;

		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[0].dwRecordMask = 1;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[0].nBeginHour = 6;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[0].nBeginMin = 30;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[0].nBeginSec = 0;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[0].nEndHour = 23;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[0].nEndMin = 0;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[0].nEndSec = 0;
		
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[1].dwRecordMask = 1;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[1].nBeginHour = 5;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[1].nBeginMin = 30;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[1].nBeginSec = 0;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[1].nEndHour = 23;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[1].nEndMin = 0;
		trafficStrobeInfo.stuStationaryOpen.stTimeShecule.stuTimeSectionWeekDay[1].nEndSec = 4;


		trafficStrobeInfo.write();

		if (netsdkApi.CLIENT_SetConfig(loginHandle, emCfgOpType, nChannelID, trafficStrobeInfo.getPointer(),
				trafficStrobeInfo.size(), 4000, null, null)) {
			System.out.println("SetConfig Succeed!");
		} else {
			System.err.println("SetConfig Failed!" + ToolKits.getErrorCode() + "|" + ENUMERROR.getErrorMessage());
		}
	}

	/**
	 * 获取道闸配置
	 */
	public void getTrafficStrobeInfo() {
		// 入参
		NET_CFG_TRAFFICSTROBE_INFO trafficStrobeInfo = new NET_CFG_TRAFFICSTROBE_INFO();
		int emCfgOpType = NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_TRAFFICSTROBE;
		int nChannelID = 0;
		trafficStrobeInfo.write();
		if (netsdkApi.CLIENT_GetConfig(loginHandle, emCfgOpType, nChannelID, trafficStrobeInfo.getPointer(),
				trafficStrobeInfo.size(), 4000, null)) {
			trafficStrobeInfo.read();
			System.out.println("使能:" + trafficStrobeInfo.bEnable);
			System.out.println("道闸控制方式个数:" + trafficStrobeInfo.nCtrlTypeCount);
			for (int i = 0; i < trafficStrobeInfo.nCtrlTypeCount; i++) {
				System.out.println("道闸控制方式" + i + ":" + trafficStrobeInfo.emCtrlType[i]);
			}
			System.out.println("所有车开闸种类个数:" + trafficStrobeInfo.nAllSnapCarCount);
			for (int i = 0; i < trafficStrobeInfo.nAllSnapCarCount; i++) {
				System.out.println("所有车开闸种类" + i + ":" + trafficStrobeInfo.emAllSnapCar[i]);
			}
			System.out.println("负责命令开闸的平台IP:" + new String(trafficStrobeInfo.szOrderIP));
			System.out.println("平台IP与设备断开连接后，设备采用的开闸方式:" + trafficStrobeInfo.emCtrlTypeOnDisconnect);

			// 道闸常开配置
			System.out.println("道闸常开配置-使能：" + trafficStrobeInfo.stuStationaryOpen.bEnable);
			// 常开模式执行时间段
			CFG_TIME_SCHEDULE stTimeShecule = trafficStrobeInfo.stuStationaryOpen.stTimeShecule;			
			System.out.println("是否支持节假日配置，默认为不支持：" + stTimeShecule.bEnableHoliday);
			CFG_TIME_SECTION[] times = stTimeShecule.stuTimeSectionWeekDay;
			for (int i = 0; i < times.length; i++) {
				System.out.println("时间段" + i + "：" + times[i].startTime() + "--" + times[i].endTime());
			}

		} else {
			System.err.println("GetConfig Failed!" + ToolKits.getErrorCode() + "|" + ENUMERROR.getErrorMessage());
		}
	}

	/******************************** 测试控制台 ***************************************/

	// 配置登陆地址，端口，用户名，密码
	String address = "172.24.31.180"; // 172.24.1.229  172.24.31.180
	int port = 37777;
	String username = "admin";
	String password = "admin123";

	public static void main(String[] args) {
		TrafficStrobeDemo demo = new TrafficStrobeDemo();
		demo.InitTest();
		demo.RunTest();
		demo.EndTest();

	}

	/**
	 * 加载测试内容
	 */
	public void RunTest() {
		CaseMenu menu = new CaseMenu();
		menu.addItem(new CaseMenu.Item(this, "获取智能交通雷达信息", "queryTrafficSnapRadarInfo"));
		menu.addItem(new CaseMenu.Item(this, "获取智能交通道闸信息", "queryTrafficSnapStrobeInfo"));
		menu.addItem(new CaseMenu.Item(this, "设置道闸配置", "setTrafficStrobeInfo"));
		menu.addItem(new CaseMenu.Item(this, "获取道闸配置", "getTrafficStrobeInfo"));
		menu.addItem(new CaseMenu.Item(this, "订阅报警信息", "startListen"));
		menu.addItem(new CaseMenu.Item(this, "取消订阅报警信息", "stopListen"));
		menu.run();
	}

	/******************************** 结束 ***************************************/
}