fiee/micro-bundle
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

过滤重复的作品id

Browse Source
This commit is contained in:
lzh 2025-06-24 15:04:09 +08:00
parent 46a6c5723f
commit 0167e40f9e
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
internal/dao/bundleExtend.go
View File

@ -271,15 +271,22 @@ func GetVedioWorkDetail(req *bundle.GetVedioWorkDetailReq) (data model.CastWorkV
} }
func ToBeComfirmedWorks(req *bundle.ToBeComfirmedWorksReq) (data []model.CastWorkLog, total int64, unconfirmed int64, err error) { func ToBeComfirmedWorks(req *bundle.ToBeComfirmedWorksReq) (data []model.CastWorkLog, total int64, unconfirmed int64, err error) {
err = app.ModuleClients.BundleDB.Model(&model.CastWorkLog{}).Where(&model.CastWorkLog{ subQuery := app.ModuleClients.BundleDB.
ArtistUuid: req.ArtistUuid, Table("cast_work_log").
}).Where("confirmed_at = ?", 0).Count(&unconfirmed).Error Select("work_uuid, MAX(update_time) AS max_update_time").
Group("work_uuid")
err = app.ModuleClients.BundleDB.
Table("cast_work_log AS cwl").
Joins("INNER JOIN (?) AS t ON cwl.work_uuid = t.work_uuid AND cwl.update_time = t.max_update_time", subQuery).
Where("artist_uuid = ?", req.ArtistUuid).Where("confirmed_at = ?", 0).Count(&unconfirmed).Error
if err != nil { if err != nil {
return return
} }
session := app.ModuleClients.BundleDB.Model(&model.CastWorkLog{}).Where(&model.CastWorkLog{ session := app.ModuleClients.BundleDB.
ArtistUuid: req.ArtistUuid, Table("cast_work_log AS cwl").
}) Joins("INNER JOIN (?) AS t ON cwl.work_uuid = t.work_uuid AND cwl.update_time = t.max_update_time", subQuery).
Where("artist_uuid = ?", req.ArtistUuid)
err = session.Count(&total).Error err = session.Count(&total).Error
if err != nil { if err != nil {
return return