HyperNet/Interactive
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🐛 Fix wrongly count aggressive view counts

Browse Source
This commit is contained in:
LittleSheep 2025-03-01 18:25:01 +08:00
parent 4a7e41d4a9
commit dd5ce8074b
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/internal/services/post_views.go
View File

@ -35,22 +35,22 @@ func FlushPostViews() {
workingQueue := make([]models.PostView, len(postViewQueue)) workingQueue := make([]models.PostView, len(postViewQueue))
copy(workingQueue, postViewQueue) copy(workingQueue, postViewQueue)
clear(postViewQueue) clear(postViewQueue)
updateRequiredPost := make(map[uint]bool) updateRequiredPost := make(map[uint]int)
for _, item := range workingQueue { for _, item := range workingQueue {
updateRequiredPost[item.PostID] = true updateRequiredPost[item.PostID]++
} }
workingQueue = lo.UniqBy(workingQueue, func(item models.PostView) string { workingQueue = lo.UniqBy(workingQueue, func(item models.PostView) string {
return fmt.Sprintf("%d:%d", item.PostID, item.AccountID) return fmt.Sprintf("%d:%d", item.PostID, item.AccountID)
}) })
_ = database.C.Clauses(clause.OnConflict{DoNothing: true}).CreateInBatches(workingQueue, 1000).Error _ = database.C.Clauses(clause.OnConflict{DoNothing: true}).CreateInBatches(workingQueue, 1000).Error
for k := range updateRequiredPost { for k, v := range updateRequiredPost {
var count int64 var count int64
if err := database.C.Model(&models.PostView{}).Where("post_id = ?", k).Count(&count).Error; err != nil { if err := database.C.Model(&models.PostView{}).Where("post_id = ?", k).Count(&count).Error; err != nil {
continue continue
} }
database.C.Model(&models.Post{}).Where("id = ?", k).Updates(map[string]any{ database.C.Model(&models.Post{}).Where("id = ?", k).Updates(map[string]any{
"total_views": count, "total_views": count,
"total_aggressive_views": gorm.Expr("total_aggressive_views + ?", count), "total_aggressive_views": gorm.Expr("total_aggressive_views + ?", v),
}) })
} }
} }