mirror of
https://github.com/simon-ding/polaris.git
synced 2026-03-14 21:50:57 +08:00
fix
This commit is contained in:
12
db/db.go
12
db/db.go
@@ -126,8 +126,16 @@ type SeriesDetails struct {
|
||||
}
|
||||
|
||||
func (c *Client) GetSeriesDetails(id int) *SeriesDetails {
|
||||
se := c.ent.Series.Query().Where(series.ID(id)).FirstX(context.TODO())
|
||||
ep := se.QueryEpisodes().AllX(context.Background())
|
||||
se, err := c.ent.Series.Query().Where(series.ID(id)).First(context.TODO())
|
||||
if err != nil {
|
||||
log.Errorf("get series %d: %v", id, err)
|
||||
return nil
|
||||
}
|
||||
ep, err := se.QueryEpisodes().All(context.Background())
|
||||
if err != nil {
|
||||
log.Errorf("get episodes %d: %v", id, err)
|
||||
return nil
|
||||
}
|
||||
return &SeriesDetails{
|
||||
Series: se,
|
||||
Episodes: ep,
|
||||
|
||||
@@ -56,6 +56,9 @@ func (s *Server) moveCompletedTask(id int) error {
|
||||
r := s.db.GetHistory(id)
|
||||
|
||||
series := s.db.GetSeriesDetails(r.SeriesID)
|
||||
if series == nil {
|
||||
return nil
|
||||
}
|
||||
st := s.db.GetStorage(series.StorageID)
|
||||
log.Infof("move task files to target dir: %v", r.TargetDir)
|
||||
if st.Implementation == storage1.ImplementationWebdav {
|
||||
|
||||
Reference in New Issue
Block a user