src/main/java/com/ard/alarm/camera/service/impl/ArdCamerasServiceImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/ard/utils/tcp/ClientHandler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/ard/utils/tcp/ClientInitialize.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/ard/alarm/camera/service/impl/ArdCamerasServiceImpl.java
@@ -33,7 +33,7 @@ private ArdEquipExternalMapper ardEquipExternalMapper; @Override public void run(ApplicationArguments args) throws Exception { public void run(ApplicationArguments args) { //加载sdk库 HikClientUtil.loadHCNetSDKLib(); //获取全部海康光电尝试登录 src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
@@ -49,7 +49,7 @@ String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP); Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort); CameraEventInfo info; String sTime;//事件时间 String url = "";//事件图片 //lCommand是传的报警类型 @@ -61,7 +61,7 @@ ardCameras.setPort(wLinkPort); IArdCamerasService ardCamerasService = SpringTool.getApplicationContext().getBean(IArdCamerasService.class); ArdCameras ardcamere = ardCamerasService.selectArdCamerasList(ardCameras).get(0); log.info("报警事件类型:lCommand:" + Integer.toHexString(lCommand)); log.debug("报警事件类型:lCommand:" + Integer.toHexString(lCommand)); HCNetSDK.NET_VCA_RULE_ALARM strVcaAlarm = new HCNetSDK.NET_VCA_RULE_ALARM(); strVcaAlarm.write(); Pointer pVCAInfo = strVcaAlarm.getPointer(); @@ -71,7 +71,7 @@ sTime = DateUtils.parseTime(strVcaAlarm.dwAbsTime);//事件时间 String ipaddr = new String(strVcaAlarm.struDevInfo.struDevIP.sIpV4).trim();//设备ip Integer channel = Integer.valueOf(strVcaAlarm.struDevInfo.byChannel);//通道 CameraEventInfo info = new CameraEventInfo(); info = new CameraEventInfo(); info.setAlarmName("人员行为分析"); info.setAlarmTime(sTime); info.setCameraName(ardcamere.getName()); src/main/java/com/ard/utils/tcp/ClientHandler.java
@@ -172,9 +172,9 @@ //region crc校验-目前仅用于显示校验结果 Boolean crc32Check = MessageParsing.CRC32Check(data); if (!crc32Check) { log.info("CRC32校验不通过"); log.debug("CRC32校验不通过"); } else { log.info("CRC32校验通过"); log.debug("CRC32校验通过"); } //endregion //log.info("原始数据:" + DatatypeConverter.printHexBinary(data)); src/main/java/com/ard/utils/tcp/ClientInitialize.java
@@ -104,14 +104,14 @@ // 异步连接tcp服务端 bootstrap.remoteAddress(host, port).connect().addListener((ChannelFuture futureListener) -> { if (!futureListener.isSuccess()) { log.error("雷达【" + host + ":" + port + "】连接失败"); log.debug("雷达【" + host + ":" + port + "】连接失败"); futureListener.channel().close(); // 连接失败信息插入Set falseConnectSet.add(ardEquipRadar); // 连接失败信息从map移除 tureConnectMap.remove(futureListener.channel().id()); } else { log.info("雷达【" + host + ":" + port + "】连接成功"); log.debug("雷达【" + host + ":" + port + "】连接成功"); // 连接成功信息从Set拔除 falseConnectSet.remove(ardEquipRadar); // 连接成功信息写入map