jiazhizhong/polaris
1
0
Fork 0
mirror of https://github.com/simon-ding/polaris.git synced 2026-03-03 16:10:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: remove history

Browse Source
This commit is contained in:
Simon Ding
2025-04-23 11:32:42 +08:00
parent 62fd7e2c18
commit 78573b71a9
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
db/db.go
View File

@@ -507,7 +507,7 @@ func (c *client) GetHistory(id int) *ent.History {
}
func (c *client) DeleteHistory(id int) error {
err := c.ent.History.Update().Where(history.ID(id)).SetStatus(history.StatusRemoved).Exec(context.Background())
err := c.ent.History.Update().Where(history.ID(id)).SetStatus(history.StatusRemoved).Exec(context.Background())
return err
}
@@ -534,7 +534,7 @@ func (c *client) SetEpisodeStatus(id int, status episode.Status) error {
func (c *client) IsEpisodeDownloadingOrDownloaded(id int) bool {
ep, _ := c.GetEpisodeByID(id)
his := c.ent.History.Query().Where(history.MediaID(ep.MediaID),history.SeasonNum(ep.SeasonNumber), history.StatusEQ(history.StatusRemoved), history.StatusNEQ(history.StatusFail)).AllX(context.Background())
his := c.ent.History.Query().Where(history.MediaID(ep.MediaID), history.SeasonNum(ep.SeasonNumber), history.StatusNEQ(history.StatusRemoved), history.StatusNEQ(history.StatusFail)).AllX(context.Background())
for _, h := range his {
if len(h.EpisodeNums) == 0 { //season pack download
return true
@@ -751,8 +751,7 @@ func (c *client) GetTmdbApiKey() string {
return k
}
func (c *client) AddTorrent2Blacklist(hash, name string, mediaId int) error {
func (c *client) AddTorrent2Blacklist(hash, name string, mediaId int) error {
count := c.ent.Blacklist.Query().Where(blacklist.TorrentHash(hash), blacklist.MediaID(mediaId)).CountX(context.TODO())
if count > 0 { //already exist
log.Infof("torrent %s already in blacklist", hash)
@@ -766,4 +765,4 @@ func (c *client) GetTorrentBlacklist() (ent.Blacklists, error) {
}
func (c *client) DeleteTorrentBlacklist(id int) error {
return c.ent.Blacklist.DeleteOneID(id).Exec(context.Background())
}
}

1
server/activity.go
View File

@@ -113,6 +113,7 @@ func (s *Server) RemoveActivity(c *gin.Context) (interface{}, error) {
}
if !s.db.IsEpisodeDownloadingOrDownloaded(id) && ep.Status != episode.StatusDownloaded {
//没有正在下载中或者下载完成的任务，并且episode状态不是已经下载完成
log.Debugf("set episode (%d) status to missing", id)
s.db.SetEpisodeStatus(id, episode.StatusMissing)
}
}