panlinlin
2021-04-26 b92027f31ef24583e8b9d4c2dc44c7e9262a2023
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/RegisterRequestProcessor.java
@@ -116,9 +116,12 @@
            AddressImpl address = (AddressImpl) fromHeader.getAddress();
            SipUri uri = (SipUri) address.getURI();
            String deviceId = uri.getUser();
            device = new Device();
            device.setStreamMode("UDP");
            device.setDeviceId(deviceId);
            device = storager.queryVideoDevice(deviceId);
            if (device == null) {
               device = new Device();
               device.setStreamMode("UDP");
               device.setDeviceId(deviceId);
            }
            device.setIp(received);
            device.setPort(rPort);
            device.setHostAddress(received.concat(":").concat(String.valueOf(rPort)));
@@ -145,7 +148,7 @@
         // 下发catelog查询目录
         if (registerFlag == 1 && device != null) {
            logger.info("注册成功! deviceId:" + device.getDeviceId());
            boolean exists = storager.exists(device.getDeviceId());
            // boolean exists = storager.exists(device.getDeviceId());
            device.setRegisterTimeMillis(System.currentTimeMillis());
            storager.updateDevice(device);
            publisher.onlineEventPublish(device.getDeviceId(), VideoManagerConstants.EVENT_ONLINE_REGISTER);