|
@@ -340,6 +340,15 @@ public class LiveRoomServiceImpl implements LiveRoomService {
|
|
|
imLiveRoomVideo.setUrl(event.getVideoUrl());
|
|
|
imLiveRoomVideo.setType(2);
|
|
|
|
|
|
- imLiveRoomVideoService.save(imLiveRoomVideo);
|
|
|
+ // 回放记录已存在,直接忽略
|
|
|
+ ImLiveRoomVideo video = imLiveRoomVideoService.lambdaQuery()
|
|
|
+ .eq(ImLiveRoomVideo::getRoomUid, imLiveRoomVideo.getRoomUid())
|
|
|
+ .eq(ImLiveRoomVideo::getRecordId, imLiveRoomVideo.getRecordId())
|
|
|
+ .last("LIMIT 1")
|
|
|
+ .one();
|
|
|
+ if (Objects.isNull(video)) {
|
|
|
+ imLiveRoomVideoService.save(imLiveRoomVideo);
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
}
|