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

fix: get episode

Browse Source
This commit is contained in:
Simon Ding
2025-04-23 11:07:24 +08:00
parent 98823e251b
commit 2641a5fccd
2 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
engine/integration.go
View File

@@ -260,8 +260,9 @@ func (c *Engine) findEpisodeFilesPreMoving(historyId int) error {
return err return err
} }
for _, id := range episodeIds { for _, id := range episodeIds {
ep, err := c.db.GetEpisode(his.MediaID, his.SeasonNum, id) ep, err := c.db.GetEpisodeByID(id)
if err != nil { if err != nil {
log.Warnf("query episode error (%d): %v", id, err)
continue continue
} }
task.WalkFunc()(func(path string, info fs.FileInfo) error { task.WalkFunc()(func(path string, info fs.FileInfo) error {

10
server/activity.go
View File

@@ -106,9 +106,9 @@ func (s *Server) RemoveActivity(c *gin.Context) (interface{}, error) {
episodeIds := s.core.GetEpisodeIds(his) episodeIds := s.core.GetEpisodeIds(his)
for _, id := range episodeIds { for _, id := range episodeIds {
ep, err := s.db.GetEpisode(his.MediaID, his.SeasonNum, id) ep, err := s.db.GetEpisodeByID(id)
if err != nil { if err != nil {
log.Warnf("get episode error: %v", err) log.Warnf("get episode (%d) error: %v", id, err)
continue continue
} }
if !s.db.IsEpisodeDownloadingOrDownloaded(id) && ep.Status != episode.StatusDownloaded { if !s.db.IsEpisodeDownloadingOrDownloaded(id) && ep.Status != episode.StatusDownloaded {
@@ -127,7 +127,7 @@ func (s *Server) addTorrent2Blacklist(h *ent.History) error {
func (s *Server) GetAllBlacklistItems(c *gin.Context) (interface{}, error) { func (s *Server) GetAllBlacklistItems(c *gin.Context) (interface{}, error) {
list, err := s.db.GetTorrentBlacklist() list, err := s.db.GetTorrentBlacklist()
if err!= nil { if err != nil {
return nil, errors.Wrap(err, "db") return nil, errors.Wrap(err, "db")
} }
return list, nil return list, nil
@@ -138,10 +138,10 @@ func (s *Server) RemoveBlacklistItem(c *gin.Context) (interface{}, error) {
return nil, fmt.Errorf("id is empty") return nil, fmt.Errorf("id is empty")
} }
idInt, err := strconv.Atoi(id) idInt, err := strconv.Atoi(id)
if err!= nil { if err != nil {
return nil, fmt.Errorf("id is not int: %v", id) return nil, fmt.Errorf("id is not int: %v", id)
} }
if err := s.db.DeleteTorrentBlacklist(idInt); err!= nil { if err := s.db.DeleteTorrentBlacklist(idInt); err != nil {
return nil, errors.Wrap(err, "db") return nil, errors.Wrap(err, "db")
} }
return nil, nil return nil, nil