This commit is contained in:
Simon Ding
2025-11-12 14:53:36 +08:00
parent 0a48657999
commit d8944168d2

View File

@@ -37,15 +37,21 @@ func (c *Engine) checkDbScraps() error {
log.Debugf("get all episodes error: %v", err)
return err
}
count := 0
log.Infof("check db scraps, total episodes: %v, total media: %v", len(allEpisodes), len(validMediaIDs))
for _, ep := range allEpisodes {
if _, ok := validMediaIDs[ep.MediaID]; !ok {
log.Infof("remove scrap episode record: %v S%vE%v", ep.MediaID, ep.SeasonNumber, ep.EpisodeNumber)
//log.Infof("remove scrap episode record: %v S%vE%v", ep.MediaID, ep.SeasonNumber, ep.EpisodeNumber)
if err := c.db.DeleteEpisode(ep.ID); err != nil {
log.Errorf("delete scrap episode record error: %v", err)
}
count++
if count%100 == 0 {
log.Infof("%v scrap episode records removed...", count)
}
}
}
log.Infof("%v scrap episode records removed...", count)
return nil
}