37 lines
1002 B
Go
37 lines
1002 B
Go
package task
|
|
|
|
import (
|
|
"pcgamedb/db"
|
|
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
func Clean(logger *zap.Logger) {
|
|
ids, err := db.DeduplicateGameItems()
|
|
if err != nil {
|
|
logger.Error("Failed to deduplicate games", zap.Error(err))
|
|
}
|
|
for _, id := range ids {
|
|
logger.Info("Deduplicated game", zap.Any("game_id", id))
|
|
}
|
|
idmap, err := db.CleanOrphanGamesInGameInfos()
|
|
if err != nil {
|
|
logger.Error("Failed to clean orphan games", zap.Error(err))
|
|
}
|
|
for _, id := range idmap {
|
|
logger.Info("Cleaned orphan game in game info", zap.Any("in", id), zap.Any("removed", idmap[id]))
|
|
}
|
|
ids, err = db.CleanGameInfoWithEmptyGameIDs()
|
|
if err != nil {
|
|
logger.Error("Failed to clean game info with empty game ids", zap.Error(err))
|
|
}
|
|
for _, id := range ids {
|
|
logger.Info("Cleaned game info with empty game ids", zap.Any("game_id", id))
|
|
}
|
|
err = db.MergeGameInfosWithSameIGDBID()
|
|
if err != nil {
|
|
logger.Error("Failed to merge game infos with same igdb id", zap.Error(err))
|
|
}
|
|
logger.Info("Cleaning task completed")
|
|
}
|