~liusuyi/ruoyi-api.git

			@@ -10,8 +10,11 @@
			import com.ruoyi.device.camera.service.IArdCamerasService;
			import com.ruoyi.device.channel.domain.ArdChannel;
			import com.ruoyi.device.channel.service.IArdChannelService;
			import com.ruoyi.device.dhsdk.lib.LibraryLoad;
			import com.ruoyi.device.dhsdk.lib.NetSDKLib;
			import com.ruoyi.device.hiksdk.common.GlobalVariable;
			import com.ruoyi.device.camera.domain.ArdCameras;
			import com.ruoyi.device.hiksdk.sdk.ExceptionCallBack;
			import com.ruoyi.media.domain.Vtdu;
			import com.ruoyi.media.service.IVtduService;
			import com.ruoyi.utils.gis.GisUtil;
			@@ -25,7 +28,9 @@
			import com.sun.jna.Pointer;
			import com.sun.jna.ptr.IntByReference;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.scheduling.annotation.Async;
			import org.springframework.stereotype.Service;

			import java.util.Base64;
			import javax.annotation.Resource;
			import java.io.*;
			@@ -35,6 +40,7 @@
			import java.util.*;
			import java.util.concurrent.PriorityBlockingQueue;

			import static com.ruoyi.device.hiksdk.common.GlobalVariable.loginCameraMap;
			import static com.ruoyi.device.hiksdk.sdk.HCNetSDK.*;

			/**
			@@ -55,52 +61,10 @@
			@Resource
			private IVtduService vtduService;

			private static HCNetSDK hCNetSDK;
			public static HCNetSDK hCNetSDK = HCNetSDK.hCNetSDK;
			private static FExceptionCallBack fExceptionCallBack;//异常回调

			@Override
			public boolean init() {
			try {
			log.debug("开始加载sdk库文件路径");
			if (Platform.isWindows()) {
			String WIN_PATH = System.getProperty("user.dir") + File.separator + "lib\\hikDll\\HCNetSDK.dll";
			log.debug("当前Windows平台的sdk库路径：" + WIN_PATH);
			hCNetSDK = (HCNetSDK) Native.loadLibrary(WIN_PATH, HCNetSDK.class);
			} else {
			log.debug("Linux平台");
			String LINUX_PATH = System.getProperty("user.dir") + File.separator + "hiklib" + File.separator + "libhcnetsdk.so";
			log.debug("当前Linux平台的sdk库路径：" + LINUX_PATH);
			hCNetSDK = (HCNetSDK) Native.loadLibrary(LINUX_PATH, HCNetSDK.class);

			//设置HCNetSDKCom组件库所在路径
			//libhcnetsdk.so
			String strPathCom = "/home/hiklib";
			NET_DVR_LOCAL_SDK_PATH struComPath = new NET_DVR_LOCAL_SDK_PATH();
			System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());
			struComPath.write();
			hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());

			//设置libcrypto.so所在路径
			BYTE_ARRAY ptrByteArrayCrypto = new BYTE_ARRAY(256);
			String strPathCrypto = "/home/hiklib/libcrypto.so.1.1";
			System.arraycopy(strPathCrypto.getBytes(), 0, ptrByteArrayCrypto.byValue, 0, strPathCrypto.length());
			ptrByteArrayCrypto.write();
			hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArrayCrypto.getPointer());

			//设置libssl.so所在路径
			BYTE_ARRAY ptrByteArraySsl = new BYTE_ARRAY(256);
			String strPathSsl = "/home/hiklib/libssl.so.1.1";
			System.arraycopy(strPathSsl.getBytes(), 0, ptrByteArraySsl.byValue, 0, strPathSsl.length());
			ptrByteArraySsl.write();
			hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArraySsl.getPointer());
			}
			return true;
			} catch (Exception ex) {
			log.error("加载库文件异常：" + ex.getMessage());
			return false;
			}
			}

			@Override
			/**
			* @描述注册登录只支持同步登陆，且官方不建议直接在此接口下写耗时操作
			* @参数 [dvrLogin]
			@@ -109,98 +73,118 @@
			* @创建时间 2023/1/17 16:12
			* @修改人和其它信息
			*/
			public void syncLogin(ArdCameras camera) {
			// 初始化
			if (!hCNetSDK.NET_DVR_Init()) {
			log.error("SDK初始化失败");
			}
			//打印海康sdk日志
			if (Platform.isWindows()) {
			String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;
			hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true);
			} else {
			hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true);
			}
			String m_sDeviceIP = camera.getIp();
			String m_sUsername = camera.getUsername();
			String m_sPassword = camera.getPassword();
			short m_sPort = camera.getPort().shortValue();
			//设置连接时间与重连时间
			hCNetSDK.NET_DVR_SetConnectTime(2000, 1);
			hCNetSDK.NET_DVR_SetReconnect(100000, true);
			//设备信息, 输出参数
			HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();
			HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();

			// 注册设备-登录参数，包括设备地址、登录用户、密码等
			m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
			System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
			m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
			System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
			m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
			System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
			m_strLoginInfo.wPort = m_sPort;
			m_strLoginInfo.byVerifyMode = 0;
			m_strLoginInfo.byLoginMode = 0;
			//是否异步登录：0- 否，1- 是 windowsSDK里是true和false
			m_strLoginInfo.bUseAsynLogin = false;
			m_strLoginInfo.write();
			//同步登录
			int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
			if (lUserID < 0) {
			int errorCode = hCNetSDK.NET_DVR_GetLastError();
			log.error("登录异常：" + errorCode);

			log.debug(camera.getIp() + ":" + camera.getPort() + "登录失败");
			camera.setChanNum(0);
			camera.setLoginId(-1);
			camera.setState("0");
			} else {

			if (GlobalVariable.loginMap.containsKey(camera.getId())) {
			GlobalVariable.loginMap.remove(camera.getId());
			@Override
			public void login(ArdCameras camera) {
			try {
			// 初始化
			if (!hCNetSDK.NET_DVR_Init()) {
			log.error("SDK初始化失败");
			}
			//删除管理通道
			ardChannelService.deleteArdChannelByDeviceId(camera.getId());
			GlobalVariable.loginMap.put(camera.getId(), lUserID);
			log.debug(camera.getIp() + ":" + camera.getPort() + "登录成功");
			//打印海康sdk日志
			if (Platform.isWindows()) {
			String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator;
			hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true);
			} else {
			hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true);
			}
			String m_sDeviceIP = camera.getIp();
			String m_sUsername = camera.getUsername();
			String m_sPassword = camera.getPassword();
			short m_sPort = camera.getPort().shortValue();
			//设置连接时间与重连时间
			hCNetSDK.NET_DVR_SetConnectTime(2000, 1);
			hCNetSDK.NET_DVR_SetReconnect(5000, true);
			//设备信息, 输出参数
			HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();
			HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();

			camera.setLoginId(lUserID);
			camera.setState("1");
			camera.setChanNum((int) m_strDeviceInfo.struDeviceV30.byChanNum);
			camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan);
			//获取最新通道
			List<ArdChannel> cameraChannelList = getCameraChannelList(camera);
			if (cameraChannelList.size() > 0) {
			for (ArdChannel channel : cameraChannelList) {
			channel.setId(IdUtils.simpleUUID());
			ardChannelService.insertArdChannel(channel);
			// 注册设备-登录参数，包括设备地址、登录用户、密码等
			m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
			System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
			m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
			System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
			m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
			System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
			m_strLoginInfo.wPort = m_sPort;
			m_strLoginInfo.byVerifyMode = 0;
			m_strLoginInfo.byLoginMode = 0;
			//是否异步登录：0- 否，1- 是 windowsSDK里是true和false
			m_strLoginInfo.bUseAsynLogin = false;
			m_strLoginInfo.write();
			//同步登录
			int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
			if (lUserID < 0) {
			int errorCode = hCNetSDK.NET_DVR_GetLastError();
			log.debug(camera.getIp() + ":" + camera.getPort() + "登录失败,错误码：" + errorCode);
			camera.setChanNum(0);
			camera.setLoginId(-1);
			camera.setState("0");
			} else {
			if (fExceptionCallBack == null) {
			fExceptionCallBack = new ExceptionCallBack();//异常回调
			//设置异常回调函数(可在回调函数中获取设备上下线状态等)
			if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) {
			log.info("Set fExceptionCallBack function fail");
			return;
			} else {
			log.info("Set fExceptionCallBack function successfully!");
			}
			}
			//添加到流媒体
			for (ArdChannel channel : cameraChannelList) {
			String name = camera.getId() + "_" + channel.getChanNo();
			String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/h264/ch" + channel.getChanNo() + "/main/av_stream";
			Vtdu vtdu = vtduService.selectVtduByName(name);
			if (vtdu != null) {
			vtduService.deleteVtduByName(name);

			if (GlobalVariable.loginMap.containsKey(camera.getId())) {
			GlobalVariable.loginMap.remove(camera.getId());
			}
			//删除管理通道
			ardChannelService.deleteArdChannelByDeviceId(camera.getId());
			GlobalVariable.loginMap.put(camera.getId(), lUserID);
			GlobalVariable.loginCameraMap.put(lUserID, camera);

			log.debug("Login Success [ " + camera.getIp() + ":" + camera.getPort() + " ]");
			camera.setLoginId(lUserID);
			camera.setState("1");
			camera.setChanNum((int) m_strDeviceInfo.struDeviceV30.byChanNum);
			camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan);
			//获取最新通道
			List<ArdChannel> cameraChannelList = getCameraChannelList(camera);
			if (cameraChannelList.size() > 0) {
			for (ArdChannel channel : cameraChannelList) {
			channel.setId(IdUtils.simpleUUID());
			ardChannelService.insertArdChannel(channel);
			}
			//添加到流媒体
			vtdu = new Vtdu();
			vtdu.setRtspSource(rtspSource);
			vtdu.setName(camera.getId() + "_" + channel.getChanNo());
			vtdu.setIsCode("0");//默认不转码
			vtdu.setMode("1");//默认CPU软解码
			vtdu.setCameraId(camera.getId());
			vtduService.insertVtdu(vtdu);
			for (ArdChannel channel : cameraChannelList) {
			String name = camera.getId() + "_" + channel.getChanNo();
			String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/h264/ch" + channel.getChanNo() + "/main/av_stream";
			Vtdu vtdu = vtduService.selectVtduByName(name);
			if (vtdu != null) {
			vtduService.deleteVtduByName(name);
			}
			//添加到流媒体
			vtdu = new Vtdu();
			vtdu.setRtspSource(rtspSource);
			vtdu.setName(camera.getId() + "_" + channel.getChanNo());
			CameraCmd cmd = new CameraCmd(camera.getId(), channel.getChanNo());
			Map<String, Object> videoCompressionCfg = getVideoCompressionCfg(cmd);
			if (videoCompressionCfg.get("videoEncType").equals("标准h264")) {
			vtdu.setIsCode("0");//默认不转码
			} else {
			vtdu.setIsCode("1");//默认转码
			}
			vtdu.setMode("1");//默认CPU软解码
			vtdu.setCameraId(camera.getId());
			vtduService.insertVtdu(vtdu);
			}
			}
			//创建引导队列
			if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {
			Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();
			PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);
			GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);
			}
			ardCamerasService.updateArdCameras(camera);
			}
			//创建引导队列
			if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) {
			Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator();
			PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator);
			GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue);
			}
			ardCamerasService.updateArdCameras(camera);
			} catch (Exception ex) {
			log.error("注册设备异常", ex);
			}
			}

			@@ -270,14 +254,12 @@
			@Override
			public void loginAll() {
			try {
			log.debug("加载lib完成！");
			ArdCameras ardCamera = new ArdCameras();
			ardCamera.setFactory("1");
			List<ArdCameras> ardCameras = ardCamerasService.selectArdCamerasListNoDataScope(ardCamera);
			for (ArdCameras camera : ardCameras) {
			Thread.sleep(500);
			//异步登录
			syncLogin(camera);
			//登录
			login(camera);
			}
			} catch (Exception ex) {
			log.error("初始化登录相机异常：" + ex.getMessage());
			@@ -888,7 +870,6 @@
			log.error("控制失败,请稍后重试" + code);
			return new HashMap<>();
			}

			}

			/**