package com.netsdk.demo.units;

import java.io.File;

import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.NetSDKLib.LLong;
import com.netsdk.lib.NetSDKLib.LOG_SET_PRINT_INFO;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

public class AudioUnit {
		//实体化 SDK 调用对象
		static NetSDKLib netsdkApi 	= NetSDKLib.NETSDK_INSTANCE;
		static NetSDKLib configApi 	= NetSDKLib.CONFIG_INSTANCE;

		//Begin:设备登入信息------------
		private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
		private static LLong loginHandle = new LLong(0);
		
		String address 			= "10.35.83.104"; 	// IP
		int    port 			= 37777;			// 端口
		String username 		= "admin";			// 登入用户名
		String password 		= "123456";			// 登入密码
		//Finish:设备登入信息------------

		//Begin:回调事件设置------------
		//断线回调
		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 Disconnect [%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);
			}
		}

		//Finish:回调事件设置------------

		//开启设备
		public void BeginTest()
		{		
			// SDK资源初始化
			netsdkApi.CLIENT_Init(DisconnectCallback.getInstance(), null);
			// 设置断线重连回调，当设备断线后会自动重连并在重连后自动调用HaveReConnect(可选)
			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());
	    		FinishTest();
	    		return;
	    	}

	    	System.out.printf("Login Device [%s:%d] Success. \n", address, port);	
	
	    	
	    	// 设置语音对讲编码格式
	    	//初始化对讲中的音频编码接口，告诉SDK内部要编码的源音频数据的音频格式，对不支持的音频格式初始化会失败
    		NetSDKLib.NET_AUDIO_FORMAT aFormat =new NetSDKLib.NET_AUDIO_FORMAT();
    		aFormat.byFormatTag = 0;                   // 编码类型,如0：PCM 注意只支持PCM 格式的音频文件
    		aFormat.nChannels = 1;                     // 声道数
    		aFormat.wBitsPerSample = 16;                // 采样深度            
    		aFormat.nSamplesPerSec = 8000;                // 采样率
    		if(netsdkApi.CLIENT_InitAudioEncode(aFormat) == 0) {
    			System.out.println("InitAudioEncode Succeed!");
    		} else {
    			System.err.println("InitAudioEncode Failed!");
    		}	
			// 打开SDK日志（可选）
			LOG_SET_PRINT_INFO setLog = new LOG_SET_PRINT_INFO();
	        String logPath = new File(".").getAbsoluteFile().getParent() + File.separator + "sdk_log" + File.separator + "sdk.log";
	        System.err.println("log=>" +logPath);
	        
			setLog.bSetFilePath = 1;
			System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
			setLog.bSetPrintStrategy = 1;
			setLog.nPrintStrategy = 0;
			if (!netsdkApi.CLIENT_LogOpen(setLog)) {
				System.err.println("Failed to open NetSDK log !!!");
			}

			
		}
		
		
		public void ARun()
		{
			Memory lpInBuf = new Memory(ToolKits.GetFileSize("D:/test.pcm"));
			if(ToolKits.ReadAllFileToMemory("D:/test.pcm", lpInBuf))
			{
				System.out.printf("读取文件成功！！\n");
			}
			else
			{
				System.err.printf("读取文件失败！！\n");
			}
			IntByReference lpInLen=new IntByReference(9000);
           		
			Pointer lpOutBuf = new Memory(9000);
			IntByReference lpOutLen = new IntByReference(9000);
			
            //进行音频的数据二次编码，从标准音频格式转换成设备支持的格式
			int a = netsdkApi.CLIENT_AudioEncode(loginHandle, lpInBuf,lpInLen, lpOutBuf, lpOutLen);
			if(a == 0)
			{
				System.out.println("CLIENT_AudioEncode ==> True");
				if(0 == netsdkApi.CLIENT_ReleaseAudioEncode())
				{
					System.out.println("CLIENT_ReleaseAudioEncode ==> True");
				}else
				{
					System.out.println("CLIENT_ReleaseAudioEncode ==> False");
				}
				
			}else
			{
				System.err.println("CLIENT_AudioEncode ==> False");
				netsdkApi.CLIENT_ReleaseAudioEncode();
			}
		}
		
		
		//关闭设备
		public void FinishTest() {
			
			// 停止订阅报警
			if (netsdkApi.CLIENT_StopListen(loginHandle)) {
				System.out.println("取消订阅报警信息.");
			}
		   	
			System.out.println("Finish Test");
			if( loginHandle.longValue() != 0)
			{
				netsdkApi.CLIENT_Logout(loginHandle);
			}
			System.out.println("See You...");

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

		public static void main(String[]args) {
			AudioUnit demo = new AudioUnit();
			demo.BeginTest();
			demo.ARun();
			demo.FinishTest();
		}
}