huanghaosheng/VLoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor：修改了过去likecount的方式

Browse Source
This commit is contained in:
Leon
2025-12-23 02:22:06 +08:00
parent 88d2cabaac
commit 326782240f
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
internal/feed/repo.go
View File

@@ -30,13 +30,19 @@ func (repo *FeedRepository) ListLatest(ctx context.Context, limit int, latestBef
return videos, nil return videos, nil
} }
func (repo *FeedRepository) ListLikesCount(ctx context.Context, limit int, likesCountBefore int64) ([]video.Video, error) { func (repo *FeedRepository) ListLikesCountWithCursor(ctx context.Context, limit int, cursor *LikesCountCursor) ([]video.Video, error) {
var videos []video.Video var videos []video.Video
query := repo.db.WithContext(ctx).Model(&video.Video{}). query := repo.db.WithContext(ctx).Model(&video.Video{}).
Order("likes_count DESC") Order("likes_count DESC, id DESC")
if likesCountBefore > 0 {
query = query.Where("likes_count < ?", likesCountBefore) if cursor != nil {
query = query.Where(
"(likes_count < ?) OR (likes_count = ? AND id < ?)",
cursor.LikesCount,
cursor.LikesCount, cursor.ID,
)
} }
if err := query.Limit(limit).Find(&videos).Error; err != nil { if err := query.Limit(limit).Find(&videos).Error; err != nil {
return nil, err return nil, err
} }