package com.netsdk.module;
|
|
import com.netsdk.lib.NativeString;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.Utils;
|
import com.netsdk.lib.enumeration.ENUMERROR;
|
import com.netsdk.lib.structure.NET_IN_PRE_UPLOAD_REMOTE_FILE;
|
import com.netsdk.lib.structure.NET_OUT_PRE_UPLOAD_REMOTE_FILE;
|
import com.netsdk.module.entity.DeliveryFileInfo;
|
import com.netsdk.module.entity.FilePreUploadResult;
|
|
import java.nio.charset.Charset;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
import static com.netsdk.lib.NetSDKLib.MAX_DELIVERY_FILE_NUM;
|
|
|
/**
|
* @author 47081
|
* @version 1.0
|
* @description 操作文件的二次封装类
|
* @date 2020/9/14
|
*/
|
public class FileModule extends BaseModule {
|
|
public FileModule(NetSDKLib netSdkApi) {
|
super(netSdkApi);
|
}
|
|
private FileModule() {
|
this(NetSDKLib.NETSDK_INSTANCE);
|
}
|
|
/**
|
* 检测文件是否可以上传
|
*
|
* @param loginHandler 登录句柄
|
* @param srcPath 源文件路径
|
* @param destPath 上传到设备的路径
|
* @return null:预上传接口调用失败,FilePreUploadResult: canUpload:true，可以上传,false:不可上传,emType:不可上传的原因
|
*/
|
public FilePreUploadResult canUpload(long loginHandler, String srcPath, String destPath) {
|
NET_IN_PRE_UPLOAD_REMOTE_FILE inParam = new NET_IN_PRE_UPLOAD_REMOTE_FILE();
|
inParam.pszFileSrc = srcPath;
|
inParam.pszFileDst = destPath;
|
NET_OUT_PRE_UPLOAD_REMOTE_FILE outParam = new NET_OUT_PRE_UPLOAD_REMOTE_FILE();
|
boolean result = getNetsdkApi().CLIENT_PreUploadRemoteFile(new NetSDKLib.LLong(loginHandler), inParam, outParam, 5000);
|
if (!result) {
|
System.out.println("pre upload failed." + ENUMERROR.getErrorMessage());
|
return null;
|
}
|
return new FilePreUploadResult(outParam.bContinue2Upload, outParam.emType);
|
}
|
|
/**
|
* 上传文件
|
*
|
* @param srcPath 源文件路径,绝对路径
|
* @param destPath 上传到设备的目录
|
* @param fileName 上传后的文件的文件名
|
* @return
|
*/
|
public boolean uploadFile(long loginHandle, String srcPath, String destPath, String fileName) {
|
NetSDKLib.NET_IN_UPLOAD_REMOTE_FILE uploadParam = new NetSDKLib.NET_IN_UPLOAD_REMOTE_FILE();
|
uploadParam.pszFileSrc = new NativeString(srcPath).getPointer();
|
if (destPath != null && !destPath.trim().equals("")) {
|
uploadParam.pszFolderDst = new NativeString(destPath).getPointer();
|
}
|
uploadParam.pszFileDst = new NativeString(fileName).getPointer();
|
//文件分包大小(字节): 0表示不分包
|
//大文件要分包,特别是dav视频,建议512kb
|
uploadParam.nPacketLen = 1024 * 512;
|
NetSDKLib.NET_OUT_UPLOAD_REMOTE_FILE uploadOutParam = new NetSDKLib.NET_OUT_UPLOAD_REMOTE_FILE();
|
uploadParam.write();
|
boolean isUpload = getNetsdkApi().CLIENT_UploadRemoteFile(new NetSDKLib.LLong(loginHandle), uploadParam, uploadOutParam, 3000);
|
uploadParam.read();
|
if (!isUpload) {
|
/**
|
* 如果上传失败,请检查上传的文件大小，上传路径,上传格式
|
*/
|
System.out.println(ENUMERROR.getErrorMessage());
|
return false;
|
}
|
return true;
|
}
|
|
/**
|
* 向视频输出口投放视频和图片文件
|
*
|
* @param loginHandle 登录句柄
|
* @param port 要投放文件的端口
|
* @param emPlayMode 播放类型 0:未知,1:播放一次,2:循环播放
|
* @param startTime 开始时间
|
* @param endTime 结束时间,当emPlayMode为2时有效
|
* @param infos 文件信息列表
|
* @return 是否投放成功
|
*/
|
public boolean deliveryFileToDevice(long loginHandle, int port, int emPlayMode, Date startTime, Date endTime, List<DeliveryFileInfo> infos) {
|
NetSDKLib.NET_CTRL_DELIVERY_FILE stuInfo = new NetSDKLib.NET_CTRL_DELIVERY_FILE();
|
stuInfo.nPort = port;
|
stuInfo.emPlayMode = emPlayMode;
|
if (startTime == null) {
|
System.out.println("startTime is null");
|
return false;
|
}
|
if (infos.size() > MAX_DELIVERY_FILE_NUM) {
|
System.out.println("out of delivery file num");
|
return false;
|
}
|
//时间赋值
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(startTime);
|
stuInfo.stuStartPlayTime.dwYear = calendar.get(Calendar.YEAR);
|
stuInfo.stuStartPlayTime.dwMonth = calendar.get(Calendar.MONTH);
|
stuInfo.stuStartPlayTime.dwDay = calendar.get(Calendar.DATE);
|
//24小时制
|
stuInfo.stuStartPlayTime.dwHour = calendar.get(Calendar.HOUR_OF_DAY);
|
stuInfo.stuStartPlayTime.dwMinute = calendar.get(Calendar.MINUTE);
|
stuInfo.stuStartPlayTime.dwSecond = calendar.get(Calendar.SECOND);
|
if (emPlayMode == 2) {
|
calendar.setTime(endTime);
|
stuInfo.stuStopPlayTime.dwYear = calendar.get(Calendar.YEAR);
|
stuInfo.stuStopPlayTime.dwMonth = calendar.get(Calendar.MONTH);
|
stuInfo.stuStopPlayTime.dwDay = calendar.get(Calendar.DATE);
|
//24小时制
|
stuInfo.stuStopPlayTime.dwHour = calendar.get(Calendar.HOUR_OF_DAY);
|
stuInfo.stuStopPlayTime.dwMinute = calendar.get(Calendar.MINUTE);
|
stuInfo.stuStopPlayTime.dwSecond = calendar.get(Calendar.SECOND);
|
}
|
|
//文件赋值
|
stuInfo.nFileCount = infos.size();
|
DeliveryFileInfo info = null;
|
for (int i = 0; i < infos.size(); i++) {
|
info = infos.get(i);
|
stuInfo.stuFileInfo[i].emFileType = info.getEmFileType().getType();
|
stuInfo.stuFileInfo[i].nImageSustain = info.getnImageSustain();
|
System.arraycopy(info.getSzFileUrl().getBytes(Charset.forName(Utils.getPlatformEncode())), 0, stuInfo.stuFileInfo[i].szFileURL, 0,
|
info.getSzFileUrl().getBytes(Charset.forName(Utils.getPlatformEncode())).length);
|
}
|
stuInfo.write();
|
|
int emType = NetSDKLib.CtrlType.CTRLTYPE_CTRL_DELIVERY_FILE;
|
boolean bRet = getNetsdkApi().CLIENT_ControlDevice(new NetSDKLib.LLong(loginHandle), emType,
|
stuInfo.getPointer(), 3000);
|
stuInfo.read();
|
if (!bRet) {
|
System.out.println("deliveryFile failed." + ENUMERROR.getErrorMessage());
|
}
|
System.out.println("deliveryFile success");
|
return bRet;
|
}
|
|
}
|
