shayu/cai-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

123

Browse Source
This commit is contained in:
77
2024-04-17 23:28:20 +08:00
parent afa34b6c0c
commit 4fec751dd7
3 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ruoyi-cai/src/main/java/com/ruoyi/cai/dto/app/query/index/AnchorListQuery.java
View File

@@ -18,6 +18,9 @@ public class AnchorListQuery {
@Schema(description = "类型 0-默认 1-活跃 2-新人 3-同城")
private Integer type;
@Schema(hidden = true, description = "是否开启视频接听")
private Integer openVideoStatus;
@Schema(description = "城市（同城查询使用）")
private Integer cityId;

5
ruoyi-cai/src/main/java/com/ruoyi/cai/manager/HomeManager.java
View File

@@ -56,6 +56,7 @@ public class HomeManager {
// 0-默认查询 1-活跃查询 2-新人查询 3-同城查询
query.setType(0);
query.setOnlineStatus(1);
query.setOpenVideoStatus(1);
Page<AnchorListVo> app = anchorService.pageApp(pageQuery, query);
List<AnchorListVo> records = app.getRecords();
RBucket<List<AnchorListVo>> bucket = redissonClient.getBucket(RedisHttpConstant.HOME_RECOMMEND_REDIS);
@@ -69,6 +70,7 @@ public class HomeManager {
AnchorListQuery query = new AnchorListQuery();
// 0-默认查询 1-活跃查询 2-新人查询 3-同城查询
query.setType(1);
query.setOpenVideoStatus(1);
Page<AnchorListVo> app = anchorService.pageApp(pageQuery, query);
List<AnchorListVo> records = app.getRecords();
RBucket<List<AnchorListVo>> bucket = redissonClient.getBucket(RedisHttpConstant.HOME_NEW_REDIS);
@@ -82,6 +84,7 @@ public class HomeManager {
AnchorListQuery query = new AnchorListQuery();
// 0-默认查询 1-活跃查询 2-新人查询 3-同城查询
query.setType(2);
query.setOpenVideoStatus(1);
Page<AnchorListVo> app = anchorService.pageApp(pageQuery, query);
List<AnchorListVo> records = app.getRecords();
RBucket<List<AnchorListVo>> bucket = redissonClient.getBucket(RedisHttpConstant.HOME_ACTIVE_REDIS);
@@ -105,6 +108,8 @@ public class HomeManager {
if(query.getCityId() == null){
return Collections.emptyList();
}
query.setOnlineStatus(1);
query.setOpenVideoStatus(1);
return anchorService.pageApp(pageQuery, query).getRecords();
}
Collections.shuffle(vos);