package com.netsdk.demo.intelligentTraffic;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.*;
import com.netsdk.lib.ToolKits;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

/**
 * 智能交通： 交通流量统计
 * @author 29779
 *
 */
public class TrafficFlowStatistic {
	
	static NetSDKLib netsdkApi = NetSDKLib.NETSDK_INSTANCE;
	static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;
	
	private NetSDKLib.NET_DEVICEINFO deviceInfo = new NetSDKLib.NET_DEVICEINFO();
	private LLong loginHandle = new LLong(0);

	String m_strIp 			= "192.168.1.53";
	int    m_nPort 			= 37777;
	String m_strUser 		= "admin";
	String m_strPassword 	= "admin123";
	
	
	public class fDisConnectCB implements NetSDKLib.fDisConnect{
		public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser){
			System.out.printf("Device[%s] Port[%d] Disconnect!\n" , pchDVRIP , nDVRPort);
		}	
    }
	
	public class fAnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack{
		public int invoke(LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize, Pointer dwUser, int nSequence, Pointer reserved){
			switch(dwAlarmType )
			{
				case NetSDKLib.EVENT_IVS_TRAFFIC_FLOWSTATE:
					NetSDKLib.DEV_EVENT_TRAFFIC_FLOW_STATE stFlowState = new NetSDKLib.DEV_EVENT_TRAFFIC_FLOW_STATE();
					ToolKits.GetPointerData(pAlarmInfo , stFlowState);
					for(int i =0 ; i< stFlowState.nStateNum ; i++)
		            {
		                System.out.printf("Lane[%d] Flow[%d] Period[%d]\n" , 
	                		stFlowState.stuStates[i].nLane , 
	                		stFlowState.stuStates[i].dwFlow , 
	                		stFlowState.stuStates[i].dwPeriod );
		            }
					System.out.printf("\n");
					break;
				default:
					System.out.printf("Get Event %x\n" , dwAlarmType);
					break;
			}
			return 0;
		}

	}

	private fDisConnectCB  	m_DisConnectCB   = new fDisConnectCB();
	private fAnalyzerDataCB m_AnalyzerDataCB = new fAnalyzerDataCB();
	
	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(m_DisConnectCB, null);
    	
    	// 向设备登入
    	int nSpecCap = 0;
    	IntByReference error = new IntByReference();
		loginHandle = netsdkApi.CLIENT_LoginEx(m_strIp, (short)m_nPort, m_strUser , 
				m_strPassword ,nSpecCap,null, deviceInfo,error);
		
		if(loginHandle.longValue() != 0)
		{
    		System.out.printf("Login Device[%s] Port[%d]Success!\n" , m_strIp , m_nPort);
    	}
    	else
    	{	
    		System.out.printf("Login Device[%s] Port[%d]Fail.Last Error[%x]\n" , m_strIp , m_nPort , netsdkApi.CLIENT_GetLastError());
    		EndTest();
    	}
	}
	
	public void attachEvent() {
		int bNeedPicture = 0;
		LLong hAttachHandle = new LLong(0);
		
		for( int i=0 ; i < deviceInfo.union.byChanNum ; i++)
		{
			hAttachHandle =  netsdkApi.CLIENT_RealLoadPictureEx(loginHandle, i ,  NetSDKLib.EVENT_IVS_ALL , bNeedPicture , m_AnalyzerDataCB , null , null);
			if( hAttachHandle.longValue() != 0  )
			{
				System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Success\n" , i);
			}
			else
			{
				System.out.printf("Ch[%d] CLIENT_RealLoadPictureEx Failed!LastError = %x\n" , i , netsdkApi.CLIENT_GetLastError() );
				return;
			}
		}
	}
		
	public void findTrafficFlowState() {
		// 设置查询条件
		FIND_RECORD_TRAFFICFLOW_CONDITION condition = new NetSDKLib.FIND_RECORD_TRAFFICFLOW_CONDITION();
		condition.bStartTime = 1; // 使能
		condition.bEndTime = 1; // 使能
		
		condition.stStartTime.setTime(2017, 12, 8, 18, 0, 0);
		condition.stEndTime.setTime(2017, 12, 8, 19, 0, 0);
		
		// CLIENT_FindRecord 入参
		NetSDKLib.NET_IN_FIND_RECORD_PARAM findRecordIn = new NetSDKLib.NET_IN_FIND_RECORD_PARAM();
		findRecordIn.emType = NetSDKLib.EM_NET_RECORD_TYPE.NET_RECORD_TRAFFICFLOW_STATE; 
		findRecordIn.pQueryCondition = condition.getPointer();
		
		// CLIENT_FindRecord 出参
		NetSDKLib.NET_OUT_FIND_RECORD_PARAM findRecordOut = new NetSDKLib.NET_OUT_FIND_RECORD_PARAM();
		
		condition.write(); 
		findRecordIn.write();
		findRecordOut.write();
		boolean bRet = netsdkApi.CLIENT_FindRecord(loginHandle, findRecordIn, findRecordOut, 3000);
		findRecordOut.read();
		findRecordIn.read();
		condition.read();		
		if(!bRet) {
			System.err.println("Can Not Find This Record" + Integer.toHexString(netsdkApi.CLIENT_GetLastError()));
			return;
		}
		int nRecordCount = 10;
		while(true) {			
			NetSDKLib.NET_IN_FIND_NEXT_RECORD_PARAM stuFindNextInParam = new NetSDKLib.NET_IN_FIND_NEXT_RECORD_PARAM();
			stuFindNextInParam.lFindeHandle = findRecordOut.lFindeHandle;
			stuFindNextInParam.nFileCount = nRecordCount;
			
			NetSDKLib.NET_OUT_FIND_NEXT_RECORD_PARAM stuFindNextOutParam = new NetSDKLib.NET_OUT_FIND_NEXT_RECORD_PARAM();
			stuFindNextOutParam.nMaxRecordNum = nRecordCount;
			NetSDKLib.NET_RECORD_TRAFFIC_FLOW_STATE pstRecordEx = new NetSDKLib.NET_RECORD_TRAFFIC_FLOW_STATE();
			stuFindNextOutParam.pRecordList = new Memory(pstRecordEx.dwSize * nRecordCount);   //分配(stRecordEx.dwSize * nRecordCount)个内存

			// 把内存里的dwSize赋值
			for (int i=0; i<stuFindNextOutParam.nMaxRecordNum; ++i)
			{
				ToolKits.SetStructDataToPointer(pstRecordEx, stuFindNextOutParam.pRecordList, i*pstRecordEx.dwSize);
			}
			
			pstRecordEx.write();
			boolean zRet = netsdkApi.CLIENT_FindNextRecord(stuFindNextInParam, stuFindNextOutParam, 3000);
			pstRecordEx.read();
			if (!zRet) {
				System.err.println("Can't FindNextRecord" + Integer.toHexString(netsdkApi.CLIENT_GetLastError()));
				break;
			}
			
			System.out.println("queryEx stuFindOutParam . dwSize " + findRecordOut.dwSize);
			System.out.println("queryEx stuFindOutParam . lFindHanlde " + findRecordOut.lFindeHandle);
			for(int i=0; i < stuFindNextOutParam.nRetRecordNum; i++) {
				ToolKits.GetPointerDataToStruct(stuFindNextOutParam.pRecordList, i*pstRecordEx.dwSize, pstRecordEx);
		        System.out.println("nRecordNum: " + pstRecordEx.nRecordNum 
		        			+ " nChannel: " + pstRecordEx.nChannel
		        			+ " nLane: " + pstRecordEx.nLane);
			}
			
			if (stuFindNextOutParam.nRetRecordNum < nRecordCount) {
				break;
			}
		}
		netsdkApi.CLIENT_FindRecordClose(findRecordOut.lFindeHandle);
	}
		
	public void RunTest()
	{
		System.out.println("Run Test");		
		CaseMenu menu = new CaseMenu();
		menu.addItem(new CaseMenu.Item(this, "findTrafficFlowState", "findTrafficFlowState"));
		menu.addItem(new CaseMenu.Item(this, "attachEvent", "attachEvent"));
		menu.run();
	}

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