| | |
|---|
| | | */
|
|---|
| | | @Override
|
|---|
| | | public void login(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(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();
|
|---|
| | |
|
|---|
| | | // 注册设备-登录参数，包括设备地址、登录用户、密码等
|
|---|
| | | 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!");
|
|---|
| | | }
|
|---|
| | | try {
|
|---|
| | | // 初始化
|
|---|
| | | if (!hCNetSDK.NET_DVR_Init()) {
|
|---|
| | | log.error("SDK初始化失败");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (GlobalVariable.loginMap.containsKey(camera.getId())) {
|
|---|
| | | GlobalVariable.loginMap.remove(camera.getId());
|
|---|
| | | //打印海康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);
|
|---|
| | | }
|
|---|
| | | //删除管理通道
|
|---|
| | | ardChannelService.deleteArdChannelByDeviceId(camera.getId());
|
|---|
| | | GlobalVariable.loginMap.put(camera.getId(), lUserID);
|
|---|
| | | GlobalVariable.loginCameraMap.put(lUserID,camera);
|
|---|
| | | 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();
|
|---|
| | |
|
|---|
| | | 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);
|
|---|
| | | // 注册设备-登录参数，包括设备地址、登录用户、密码等
|
|---|
| | | 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());
|
|---|
| | | 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");//默认转码
|
|---|
| | | 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);
|
|---|
| | | }
|
|---|
| | | 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);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
