forked from uav/ard-uav-server
ard-sample/src/main/java/com/ard/sample/manage/service/impl/LiveStreamServiceImpl.java
@@ -1,5 +1,6 @@ package com.ard.sample.manage.service.impl; import com.ard.sample.common.error.CommonErrorEnum; import com.ard.sample.common.error.LiveErrorEnum; import com.ard.sample.common.model.ResponseResult; import com.ard.sample.component.mqtt.model.CommonTopicResponse; @@ -20,8 +21,8 @@ import com.ard.sample.manage.service.ILiveStreamService; import com.ard.vtdu.config.MediamtxConfig; import com.ard.vtdu.domain.ArdVtdu; import com.ard.vtdu.service.IArdMediaService; import com.ard.vtdu.service.IArdVtduService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -40,6 +41,7 @@ * @version 0.1 * @date 2021/11/22 */ @Slf4j @Service @Transactional public class LiveStreamServiceImpl implements ILiveStreamService { @@ -116,7 +118,8 @@ ServiceReply receiveReply = this.publishLiveStart(respTopic, liveParam); if (ResponseResult.CODE_SUCCESS != receiveReply.getResult()) { return ResponseResult.error(LiveErrorEnum.find(receiveReply.getResult())); log.info("机场直播开启失败，错误码：{},错误描述：{}", receiveReply.getResult(), LiveErrorEnum.find(receiveReply.getResult()).getErrorMsg()); return ResponseResult.error(receiveReply.getResult(), LiveErrorEnum.find(receiveReply.getResult()).getErrorMsg()); } LiveUrlTypeEnum urlType = LiveUrlTypeEnum.find(liveParam.getUrlType()); @@ -145,8 +148,10 @@ // 查询是否已经存在该记录 ArdVtdu ardVtdu = ardVtduService.selectArdVtduByName(vtdu.getName()); int i = 0; log.info("机场视频插入前vtdu:{}",vtdu); if(ardVtdu == null){ i = ardVtduService.insertArdVtdu(vtdu); // 保存到媒体表 log.info("机场视频插入后 i:{}",i); if (i > 0) { live.setRtmpUrl(rtmpUrl); live.setRtspUrl(rtspUrl); @@ -154,9 +159,13 @@ } } else{ live.setRtmpUrl(rtmpUrl); live.setRtspUrl(rtspUrl); live.setWebrtcUrl(webrtcUrl); i = ardVtduService.updateArdVtdu(vtdu); log.info("机场视频更新后 i:{}",i); if (i > 0) { live.setRtmpUrl(rtmpUrl); live.setRtspUrl(rtspUrl); live.setWebrtcUrl(webrtcUrl); } } //int i = ardVtduService.insertArdVtdu(vtdu); // 保存到媒体表 // if (i > 0) { @@ -174,6 +183,11 @@ return ResponseResult.error(LiveErrorEnum.URL_TYPE_NOT_SUPPORTED); } // 开始直播时发送机场相机摄像头默认信息（舱外）到所有在线用户,只取机场sn，发机场的摄像头信息 if(data.getChildDeviceSn()!=null) { String sn = data.getDeviceSn(); deviceService.setRedisCameraPosition(sn, 1); } return ResponseResult.success(live); } @@ -188,6 +202,7 @@ ServiceReply receiveReply = this.publishLiveStop(respTopic, videoId); if (receiveReply.getResult() != 0) { log.info("videoId:{},直播停止失败，错误码：{},错误描述：{}", videoId, receiveReply.getResult(), LiveErrorEnum.find(receiveReply.getResult()).getErrorMsg()); return ResponseResult.error(LiveErrorEnum.find(receiveReply.getResult())); } //注释掉删除流媒体管理库中的信息 @@ -220,6 +235,7 @@ @Override public ResponseResult liveLensChange(LiveTypeDTO liveParam) { log.info("切换镜头参数：{}", liveParam); ResponseResult<DeviceDTO> responseResult = this.checkBeforeLive(liveParam.getVideoId()); if (ResponseResult.CODE_SUCCESS != responseResult.getCode()) { return responseResult; @@ -233,10 +249,53 @@ ServiceReply receiveReply = this.publishLiveLensChange(respTopic, liveParam); if (ResponseResult.CODE_SUCCESS != receiveReply.getResult()) { Integer code = receiveReply.getResult(); if(code == 325003) { // 指令响应失败，请重试. 经查询官网，机场3为低配，飞行器不支持红外 return ResponseResult.error(325003000,LiveErrorEnum.COMMAND_FAILED.getErrorMsg()+"请确认无人机是否支持此功能！"); } return ResponseResult.error(LiveErrorEnum.find(receiveReply.getResult())); } return ResponseResult.success(); } @Override public ResponseResult<List<String>> getLiveLens(String sn) { List<String> videoTypes = new ArrayList<>(); // 检查设备是否在线 if (!deviceService.checkDeviceOnline(sn)) { log.info("SN: {}-设备不在线，请检查网络连接！", sn); // 抛弃出异常，给调用者处理 //throw new Exception("设备不在线，请检查网络连接！"); return ResponseResult.error(CommonErrorEnum.DEVICE_OFFLINE.getErrorCode(),CommonErrorEnum.DEVICE_OFFLINE.getErrorMsg()); } // 读取直播能力拼接参数 List<CapacityDeviceDTO> devicesList = getLiveCapacity(); if (devicesList == null || devicesList.isEmpty()) { log.info("SN: {}-未获得设备直播能力！", sn); // 抛弃出异常，给调用者处理 //throw new Exception("未获得设备直播能力！"); return ResponseResult.error(22222200,"未获得设备直播能力！"); } for (CapacityDeviceDTO device : devicesList) { if (!device.getSn().equals(sn)) { continue; } List<CapacityCameraDTO> camerasList = device.getCamerasList(); for (CapacityCameraDTO camera : camerasList) { // 机场3中飞行器，没有name，需要其他条件确定主摄像头参数 for (CapacityVideoDTO video : camera.getVideosList()) { if (video.getSwitchVideoTypes().size() == 1 && camera.getName() == null) { continue; } videoTypes = video.getSwitchVideoTypes(); } } } return ResponseResult.success(videoTypes); } @Override @@ -260,6 +319,10 @@ if (ResponseResult.CODE_SUCCESS != receiveReply.getResult()) { return ResponseResult.error(LiveErrorEnum.find(receiveReply.getResult())); } // 将切换相机摄像头信息到redis Integer camera_position = liveParam.getCameraPosition(); String sn = responseResult.getData().getDeviceSn(); deviceService.setRedisCameraPosition(sn, camera_position); return ResponseResult.success(); }
