fix: ignore episode record exists

bangumi · Oct 10, 2024 · 2d534b5 · 2d534b5
1 parent cf9d301
commit 2d534b5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/collections/infra/mysql_repo.go b/internal/collections/infra/mysql_repo.go
@@ -880,7 +880,8 @@ func (r mysqlRepo) createEpisodeCollection(
 	}
 
 	table := r.q.EpCollection
-	err = table.WithContext(ctx).Where(table.UserID.Eq(userID), table.SubjectID.Eq(subjectID)).Create(&dao.EpCollection{
+	err = table.WithContext(ctx).Clauses(clause.OnConflict{DoNothing: true}).
+		Where(table.UserID.Eq(userID), table.SubjectID.Eq(subjectID)).Create(&dao.EpCollection{
 		UserID:      userID,
 		SubjectID:   subjectID,
 		Status:      bytes,