| | |
|---|
| | | public ResponseEntity<WVPResult<String>> updateDevice(Device device){ |
|---|
| | | |
|---|
| | | if (device != null && device.getDeviceId() != null) { |
|---|
| | | |
|---|
| | | |
|---|
| | | // TODO 报警订阅相关的信息 |
|---|
| | | |
|---|
| | | deviceService.updateDevice(device); |
|---|
| | | // cmder.deviceInfoQuery(device); |
|---|
| | | } |
|---|
| | | WVPResult<String> result = new WVPResult<>(); |
|---|
| | | result.setCode(0); |
|---|
| | |
|---|
| | | Device device = storager.queryVideoDevice(deviceId); |
|---|
| | | String uuid = UUID.randomUUID().toString(); |
|---|
| | | String key = DeferredResultHolder.CALLBACK_CMD_DEVICESTATUS + deviceId; |
|---|
| | | DeferredResult<ResponseEntity<String>> result = new DeferredResult<ResponseEntity<String>>(2*1000L); |
|---|
| | | if(device == null) { |
|---|
| | | result.setResult(new ResponseEntity(String.format("设备%s不存在", deviceId),HttpStatus.OK)); |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | cmder.deviceStatusQuery(device, event -> { |
|---|
| | | RequestMessage msg = new RequestMessage(); |
|---|
| | | msg.setId(uuid); |
|---|
| | |
|---|
| | | msg.setData(String.format("获取设备状态失败，错误码： %s, %s", event.statusCode, event.msg)); |
|---|
| | | resultHolder.invokeResult(msg); |
|---|
| | | }); |
|---|
| | | DeferredResult<ResponseEntity<String>> result = new DeferredResult<ResponseEntity<String>>(2*1000L); |
|---|
| | | result.onTimeout(()->{ |
|---|
| | | logger.warn(String.format("获取设备状态超时")); |
|---|
| | | // 释放rtpserver |
|---|
