panlinlin
2020-12-27 6968839f21fb05bf6e3204c2040ee47130006cd0
src/main/java/com/genersoft/iot/vmp/vmanager/playback/PlaybackController.java
@@ -27,6 +27,7 @@
import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
import org.springframework.web.context.request.async.DeferredResult;
import javax.sip.message.Response;
import java.util.UUID;
@CrossOrigin
@@ -72,12 +73,18 @@
      StreamInfo streamInfo = storager.queryPlaybackByDevice(deviceId, channelId);
      if (streamInfo != null) {
         // 停止之前的回放
         cmder.streamByeCmd(streamInfo.getSsrc());
         cmder.streamByeCmd(streamInfo.getStreamId());
      }
      resultHolder.put(DeferredResultHolder.CALLBACK_CMD_PlAY + uuid, result);
      cmder.playbackStreamCmd(device, channelId, startTime, endTime, (JSONObject response) -> {
         logger.info("收到订阅消息: " + response.toJSONString());
         playService.onPublishHandlerForPlayBack(response, deviceId, channelId, uuid.toString());
      }, event -> {
         Response response = event.getResponse();
         RequestMessage msg = new RequestMessage();
         msg.setId(DeferredResultHolder.CALLBACK_CMD_PlAY + uuid);
         msg.setData(String.format("回放失败, 错误码: %s, %s", response.getStatusCode(), response.getReasonPhrase()));
         resultHolder.invokeResult(msg);
      });
      return result;