package com.netsdk.demo.customize;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.enumeration.EM_REASON_TYPE;
|
import com.netsdk.lib.NativeString;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.callback.impl.DefaultDisconnectCallback;
|
import com.netsdk.lib.callback.impl.DefaultHaveReconnectCallBack;
|
import com.netsdk.lib.structure.NET_CFG_CAP_SPEAK;
|
import com.netsdk.lib.structure.NET_IN_PRE_UPLOAD_REMOTE_FILE;
|
import com.netsdk.lib.structure.NET_OUT_PRE_UPLOAD_REMOTE_FILE;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.Structure;
|
import com.sun.jna.ptr.IntByReference;
|
|
import java.io.File;
|
import java.nio.charset.Charset;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Scanner;
|
|
import static com.netsdk.lib.NetSDKLib.CtrlType.CTRLTYPE_CTRL_START_PLAYAUDIO;
|
|
/**
|
* @author 47081
|
* @version 1.0
|
* @description IPC声光警戒相机音频操作demo，
|
* 包括设备音频能力集的获取，音频文件预上传，上传，获取音频文件列表，播放音频，删除音频
|
* @date 2020/6/5
|
*/
|
public class AudioControlDemo {
|
private final String ip = "172.23.28.13";
|
private final int port = 37777;
|
private final String user = "admin";
|
private final String password = "admin123";
|
private final String srcFile = "alarm.wav";
|
|
private List<String> audioPaths;
|
private List<String> destPaths;
|
private List<String> audios;
|
public AudioControlDemo(){
|
audioPaths=new ArrayList<String>();
|
destPaths=new ArrayList<String>();
|
audios=new ArrayList<String>();
|
}
|
public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
|
public static final NetSDKLib configSdk=NetSDKLib.CONFIG_INSTANCE;
|
/**
|
* 登录句柄
|
*/
|
private NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0);
|
|
/**
|
*设备信息扩展
|
*/
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
|
public void initTest(){
|
// 初始化SDK库
|
netSdk.CLIENT_Init(DefaultDisconnectCallback.getINSTANCE(), null);
|
|
// 设置断线重连成功回调函数
|
netSdk.CLIENT_SetAutoReconnect(DefaultHaveReconnectCallBack.getINSTANCE(), null);
|
|
//打开日志，可选
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
String logPath = new File(".").getAbsoluteFile().getParent() + File.separator + "sdk_log" + File.separator + "sdk.log";
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
setLog.bSetPrintStrategy = 1;
|
setLog.nPrintStrategy = 0;
|
if (!netSdk.CLIENT_LogOpen(setLog)){
|
System.err.println("Open SDK Log Failed!!!");
|
}
|
login();
|
}
|
|
public void login(){
|
// 登陆设备
|
// TCP登入
|
int nSpecCap = NetSDKLib.EM_LOGIN_SPAC_CAP_TYPE.EM_LOGIN_SPEC_CAP_TCP;
|
IntByReference nError = new IntByReference(0);
|
loginHandle = netSdk.CLIENT_LoginEx2(ip, port, user,
|
password ,nSpecCap, null, deviceInfo, nError);
|
if(loginHandle.longValue() != 0) {
|
System.out.printf("Login Device[%s] Success!\n", ip);
|
}else {
|
System.err.printf("Login Device[%s] Fail.Error[%s]\n", ip, ToolKits.getErrorCode());
|
loginOut();
|
}
|
}
|
|
public void loginOut(){
|
System.out.println("End Test");
|
if( loginHandle.longValue() != 0)
|
{
|
netSdk.CLIENT_Logout(loginHandle);
|
}
|
System.out.println("See You...");
|
|
netSdk.CLIENT_Cleanup();
|
System.exit(0);
|
}
|
|
/**
|
* 获取设备音频能力:查看可上传路径，支持的音频格式
|
*/
|
public void getDeviceAudioCap(){
|
String audioCap=NetSDKLib.CFG_CAP_CMD_SPEAK;
|
NET_CFG_CAP_SPEAK speak=new NET_CFG_CAP_SPEAK();
|
if(getDevConfig(loginHandle,audioCap,speak,0)){
|
destPaths.clear();
|
System.out.println("播放路径个数: "+speak.nAudioPlayPathNum);
|
for (int i = 0; i < speak.nAudioPlayPathNum; i++) {
|
System.out.println("is support upload: "+speak.stuAudioPlayPath[i].bSupportUpload+",path: "+new String(speak.stuAudioPlayPath[i].szPath)+",max file upload number:"+speak.stuAudioPlayPath[i].nMaxFileUploadNum+",max file upload size(kb): "+speak.stuAudioPlayPath[i].nMaxUploadFileSize/1024.0);
|
if(speak.stuAudioPlayPath[i].bSupportUpload){
|
destPaths.add(new String(speak.stuAudioPlayPath[i].szPath,Charset.forName("GBK")).trim());
|
}
|
|
if(!"".equals(new String(speak.stuAudioPlayPath[i].szPath).trim())){
|
audioPaths.add(new String(speak.stuAudioPlayPath[i].szPath,Charset.forName("GBK")).trim());
|
}
|
}
|
}
|
}
|
|
/**
|
* 查询设备能力集
|
* @param loginHandle 登录句柄
|
* @param command 能力集命令
|
* @param structure 能力集的结构体
|
* @param channelID 通道号
|
* @return
|
*/
|
private boolean getDevConfig(NetSDKLib.LLong loginHandle, String command, Structure structure,int channelID){
|
boolean result=false;
|
int error[] = {0};
|
int nBufferLen = 100*1024;
|
byte[] strBuffer = new byte[nBufferLen];
|
result=netSdk.CLIENT_QueryNewSystemInfo(loginHandle,command,channelID,strBuffer,nBufferLen,new IntByReference(0),3000);
|
if(result){
|
structure.write();
|
if(configSdk.CLIENT_ParseData(command,strBuffer,structure.getPointer(),structure.size(),null)){
|
structure.read();
|
}else{
|
System.out.println("Parse " + command + " Config Failed!");
|
}
|
}else{
|
System.out.printf("Get %s Config Failed!Last Error = %s\n" , command , ToolKits.getErrorCode());
|
}
|
return result;
|
}
|
|
/**
|
* 音频文件预上传，校验该文件是否可以上传
|
*/
|
public void preAudioUpload(){
|
NET_IN_PRE_UPLOAD_REMOTE_FILE inparam=new NET_IN_PRE_UPLOAD_REMOTE_FILE();
|
inparam.pszFileSrc=new File(srcFile).getAbsolutePath();
|
Scanner scanner=new Scanner(System.in);
|
for (int i = 0; i < destPaths.size(); i++) {
|
System.out.println(i+" : "+destPaths.get(i));
|
}
|
System.out.println("please input the num to select the path to preupload: ");
|
String destPath=destPaths.get(scanner.nextInt());
|
//要上传的路径,上传文件夹+文件名
|
inparam.pszFileDst=destPath+new File(srcFile).getName();
|
NET_OUT_PRE_UPLOAD_REMOTE_FILE outparam=new NET_OUT_PRE_UPLOAD_REMOTE_FILE();
|
boolean preUpload=netSdk.CLIENT_PreUploadRemoteFile(loginHandle,inparam,outparam,3000);
|
if(preUpload){
|
System.out.println("can upload: "+outparam.bContinue2Upload+",reason:"+EM_REASON_TYPE.getReason(outparam.emType));
|
}else{
|
System.out.println("pre upload failed: "+ToolKits.getErrorCode());
|
}
|
}
|
/**
|
* 上传音频文件
|
*/
|
public void audioUpload(){
|
Scanner scanner=new Scanner(System.in);
|
for (int i = 0; i < destPaths.size(); i++) {
|
System.out.println(i+" : "+destPaths.get(i));
|
}
|
System.out.println("please input the num to select the path to upload: ");
|
String destPath=destPaths.get(scanner.nextInt());
|
//入参
|
NetSDKLib.NET_IN_UPLOAD_REMOTE_FILE uploadParam=new NetSDKLib.NET_IN_UPLOAD_REMOTE_FILE();
|
//要上传的文件
|
File file=new File(srcFile);
|
String filePath=file.getAbsolutePath();
|
String fileName=file.getName();
|
//源文件的路径
|
uploadParam.pszFileSrc=new NativeString(filePath).getPointer();
|
//目标文件名称
|
uploadParam.pszFileDst=new NativeString(fileName).getPointer();
|
// 接口参数上的注释:目标文件夹路径：可为NULL, NULL时设备使用默认路径
|
//注意:如果为null,会使用默认路径，但使用默认路径上传会失败,
|
// 需要先获取设备音频能力集，得到可上传的路径,并设置为目标文件夹路径
|
uploadParam.pszFolderDst=new NativeString(destPath).getPointer();
|
//文件分包大小(字节): 0表示不分包
|
uploadParam.nPacketLen=1024*2;
|
NetSDKLib.NET_OUT_UPLOAD_REMOTE_FILE uploadOutParam=new NetSDKLib.NET_OUT_UPLOAD_REMOTE_FILE();
|
uploadParam.write();
|
boolean isUpload=netSdk.CLIENT_UploadRemoteFile(loginHandle,uploadParam,uploadOutParam,3000);
|
uploadParam.read();
|
if(isUpload){
|
System.out.println("upload audio success!");
|
}else{
|
/**
|
* 如果上传失败,请检查上传的文件大小，上传路径,上传格式
|
*/
|
System.out.println("failed to upload audio.the error is "+ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 获取音频文件列表
|
*/
|
public void audioList(){
|
// 出参
|
NetSDKLib.NET_OUT_LIST_REMOTE_FILE stOut = new NetSDKLib.NET_OUT_LIST_REMOTE_FILE();
|
audios.clear();
|
for (String path:audioPaths) {
|
NetSDKLib.SDK_REMOTE_FILE_INFO[] remoteFile = ToolKits.ListAudioFile(loginHandle, path, stOut);
|
if(remoteFile != null) {
|
System.out.println("nRetFileCount : " + stOut.nRetFileCount);
|
for(int j = 0; j < stOut.nRetFileCount; j++) {
|
System.out.println("szPath : " + new String(remoteFile[j].szPath, Charset.forName("GBK")).trim());
|
audios.add(new String(remoteFile[j].szPath,Charset.forName("GBK")));
|
}
|
} else {
|
System.err.println("ListRemoteFile Failed!" + ToolKits.getErrorCode());
|
}
|
}
|
|
}
|
|
/**
|
* 播放音频文件
|
*/
|
public void audioPlay(){
|
|
for(int i=0;i<audios.size();i++){
|
System.out.println(i+" : "+audios.get(i));
|
}
|
System.out.println("Please choose the audio to play,input the num: ");
|
Scanner scanner=new Scanner(System.in);
|
String path=audios.get(scanner.nextInt());
|
NetSDKLib.NET_CTRL_START_PLAYAUDIO playParam=new NetSDKLib.NET_CTRL_START_PLAYAUDIO();
|
//字节数组赋值请使用System.arraycopy
|
byte[] pathArray=path.getBytes();
|
System.arraycopy(pathArray,0,playParam.szAudioPath,0,pathArray.length);
|
Pointer pointer=new Memory(playParam.size());
|
ToolKits.SetStructDataToPointer(playParam,pointer,0);
|
boolean isPlay=netSdk.CLIENT_ControlDevice(loginHandle,CTRLTYPE_CTRL_START_PLAYAUDIO,pointer,3000);
|
if(isPlay){
|
System.out.println("play audio success.");
|
}else{
|
System.out.println("failed to play audio.the error is "+ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 删除音频文件
|
*/
|
public void audioRemove(){
|
for(int i=0;i<audios.size();i++){
|
System.out.println(i+" : "+audios.get(i));
|
}
|
System.out.println("Please choose the audio to remove,input the num: ");
|
Scanner scanner=new Scanner(System.in);
|
int index=scanner.nextInt();
|
String path=audios.get(index);
|
if(ToolKits.RemoveAudioFiles(loginHandle, path)) {
|
System.out.println("RemoveRemoteFiles Succeed!");
|
audios.remove(index);
|
} else {
|
System.err.println("RemoveRemoteFiles Failed!" + ToolKits.getErrorCode());
|
}
|
|
}
|
|
public void run(){
|
CaseMenu menu=new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this,"获取设备音频能力","getDeviceAudioCap"));
|
menu.addItem(new CaseMenu.Item(this,"音频文件预上传(判断文件是否可以上传)","preAudioUpload"));
|
menu.addItem(new CaseMenu.Item(this,"上传音频文件","audioUpload"));
|
menu.addItem(new CaseMenu.Item(this,"获取音频列表","audioList"));
|
menu.addItem(new CaseMenu.Item(this,"播放音频","audioPlay"));
|
menu.addItem(new CaseMenu.Item(this,"删除音频文件","audioRemove"));
|
menu.run();
|
}
|
|
public static void main(String[] args) {
|
AudioControlDemo demo=new AudioControlDemo();
|
demo.initTest();
|
demo.run();
|
demo.loginOut();
|
}
|
}
|
