| | |
| | | import com.ard.utils.hiksdk.domain.ExternalAlarmEventInfo; |
| | | import com.ard.utils.hiksdk.util.hikSdkUtil.HCNetSDK; |
| | | import com.ard.utils.other.DateUtils; |
| | | import com.ard.utils.mqtt.MqttConsumer; |
| | | import com.ard.utils.mqtt.MqttProducer; |
| | | import com.ard.utils.spring.SpringUtils; |
| | | import com.ard.utils.uuid.IdUtils; |
| | | import com.sun.jna.Pointer; |
| | |
| | | @Override |
| | | public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) { |
| | | SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP);//设备IP地址 |
| | | String sDeviceIP = ByteUtils.bytesToStringZh(pAlarmer.sDeviceIP).trim();//设备IP地址 |
| | | Integer wLinkPort = Integer.valueOf(pAlarmer.wLinkPort);//设备通讯端口 |
| | | CameraEventInfo info; |
| | | String sTime;//事件时间 |
| | |
| | | */ |
| | | private void publishMqtt(CameraEventInfo info) { |
| | | printLog(info); |
| | | MqttConsumer.publish(2, false, "camera", JSON.toJSONString(info)); |
| | | MqttProducer.publish(2, false, "camera", JSON.toJSONString(info)); |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | private void publishMqtt(ExternalAlarmEventInfo info) { |
| | | printLog(info); |
| | | MqttConsumer.publish(2, false, "external", JSON.toJSONString(info)); |
| | | MqttProducer.publish(2, false, "external", JSON.toJSONString(info)); |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | private void publishMqtt(AccessControlHostEventInfo info) { |
| | | printLog(info); |
| | | MqttConsumer.publish(2, false, "accessControl", JSON.toJSONString(info)); |
| | | MqttProducer.publish(2, false, "accessControl", JSON.toJSONString(info)); |
| | | } |
| | | |
| | | /** |