648540858
2021-10-18 61a8113c39007105fb20e5c997d69f1586c86149
src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java
@@ -101,7 +101,7 @@
   @GetMapping("/stop/{deviceId}/{channelId}")
   public DeferredResult<ResponseEntity<String>> playStop(@PathVariable String deviceId, @PathVariable String channelId) {
      logger.debug(String.format("设备预览/回放停止API调用,streamId:%s/$s", deviceId, channelId ));
      logger.debug(String.format("设备预览/回放停止API调用,streamId:%s_%s", deviceId, channelId ));
      UUID uuid = UUID.randomUUID();
      DeferredResult<ResponseEntity<String>> result = new DeferredResult<ResponseEntity<String>>();
@@ -134,20 +134,20 @@
         json.put("deviceId", deviceId);
         json.put("channelId", channelId);
         RequestMessage msg = new RequestMessage();
         msg.setId(DeferredResultHolder.CALLBACK_CMD_PlAY + uuid);
         msg.setId(DeferredResultHolder.CALLBACK_CMD_PLAY + uuid);
         msg.setData(json.toString());
         resultHolder.invokeResult(msg);
      } else {
         logger.warn("设备预览/回放停止API调用失败!");
         RequestMessage msg = new RequestMessage();
         msg.setId(DeferredResultHolder.CALLBACK_CMD_PlAY + uuid);
         msg.setId(DeferredResultHolder.CALLBACK_CMD_PLAY + uuid);
         msg.setData("streamId null");
         resultHolder.invokeResult(msg);
      }
      // 超时处理
      result.onTimeout(()->{
         logger.warn(String.format("设备预览/回放停止超时,deviceId/channelId:%s/$s ", deviceId, channelId));
         logger.warn(String.format("设备预览/回放停止超时,deviceId/channelId:%s_%s ", deviceId, channelId));
         RequestMessage msg = new RequestMessage();
         msg.setId(DeferredResultHolder.CALLBACK_CMD_STOP + uuid);
         msg.setData("Timeout");