|
@@ -1,6 +1,7 @@
|
|
|
package com.ym.mec.biz.service.impl;
|
|
|
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import com.google.common.collect.Maps;
|
|
|
import com.ym.mec.biz.dal.dao.ImLiveRoomVideoDao;
|
|
|
import com.ym.mec.biz.dal.entity.ImLiveRoomVideo;
|
|
|
import com.ym.mec.biz.dal.vo.ImLiveRoomVideoVo;
|
|
@@ -11,6 +12,7 @@ import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
|
|
|
/**
|
|
|
* 直播视频记录(ImLiveRoomVideo)表服务实现类
|
|
@@ -32,5 +34,30 @@ public class ImLiveRoomVideoServiceImpl extends ServiceImpl<ImLiveRoomVideoDao,
|
|
|
return baseMapper.queryVideoList(roomUid);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 直播间的视频数
|
|
|
+ *
|
|
|
+ * @param roomIdList 直播间id
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Map<String, Integer> queryRoomUidCountMap(List<String> roomIdList) {
|
|
|
+ if (roomIdList == null || roomIdList.isEmpty()) {
|
|
|
+ return Maps.newHashMap();
|
|
|
+ }
|
|
|
+ List<ImLiveRoomVideo> list = this.lambdaQuery().in(ImLiveRoomVideo::getRoomUid, roomIdList).list();
|
|
|
+ Map<String, Integer> map = Maps.newHashMap();
|
|
|
+ for (ImLiveRoomVideo imLiveRoomVideo : list) {
|
|
|
+ String roomUid = imLiveRoomVideo.getRoomUid();
|
|
|
+ Integer count = map.get(roomUid);
|
|
|
+ if (count == null) {
|
|
|
+ count = 0;
|
|
|
+ }
|
|
|
+ map.put(roomUid, count + 1);
|
|
|
+ }
|
|
|
+ return map;
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
|