jiazhizhong/polaris
1
0
Fork 0
mirror of https://github.com/simon-ding/polaris.git synced 2026-05-27 21:17:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: error

Browse Source
This commit is contained in:
Simon Ding
2024-07-20 13:47:54 +08:00
parent 45aff8e63b
commit af9e29b944
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server/scheduler.go
View File

@@ -48,7 +48,7 @@ func (s *Server) checkTasks() {
} }
} }
func (s *Server) moveCompletedTask(id int) (err error) { func (s *Server) moveCompletedTask(id int) (err1 error) {
torrent := s.tasks[id] torrent := s.tasks[id]
r := s.db.GetHistory(id) r := s.db.GetHistory(id)
if r.Status == history.StatusUploading { if r.Status == history.StatusUploading {
@@ -100,7 +100,8 @@ func (s *Server) moveCompletedTask(id int) (err error) {
} }
storageImpl, err := storage.NewWebdavStorage(ws.URL, ws.User, ws.Password, targetPath) storageImpl, err := storage.NewWebdavStorage(ws.URL, ws.User, ws.Password, targetPath)
if err != nil { if err != nil {
return errors.Wrap(err, "new webdav") err1 = errors.Wrap(err, "new webdav")
return
} }
stImpl = storageImpl stImpl = storageImpl
@@ -113,7 +114,8 @@ func (s *Server) moveCompletedTask(id int) (err error) {
storageImpl, err := storage.NewLocalStorage(targetPath) storageImpl, err := storage.NewLocalStorage(targetPath)
if err != nil { if err != nil {
return errors.Wrap(err, "new storage") err1 = errors.Wrap(err, "new storage")
return
} }
stImpl = storageImpl stImpl = storageImpl
@@ -121,12 +123,14 @@ func (s *Server) moveCompletedTask(id int) (err error) {
if r.EpisodeID == 0 { if r.EpisodeID == 0 {
//season package download //season package download
if err := stImpl.Move(filepath.Join(s.db.GetDownloadDir(), torrent.Name()), r.TargetDir); err != nil { if err := stImpl.Move(filepath.Join(s.db.GetDownloadDir(), torrent.Name()), r.TargetDir); err != nil {
return errors.Wrap(err, "move file") err1 = errors.Wrap(err, "move file")
return
} }
} else { } else {
if err := stImpl.Move(filepath.Join(s.db.GetDownloadDir(), torrent.Name()), filepath.Join(r.TargetDir, torrent.Name())); err != nil { if err := stImpl.Move(filepath.Join(s.db.GetDownloadDir(), torrent.Name()), filepath.Join(r.TargetDir, torrent.Name())); err != nil {
return errors.Wrap(err, "move file") err1 = errors.Wrap(err, "move file")
return
} }
} }