From bbc5401e317a863afda6cc9552a53ce694fb7914 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=99=AF=E9=98=B3?= <1656488874@qq.com>
Date: Fri, 27 Sep 2019 14:16:41 +0800
Subject: [PATCH] =?UTF-8?q?=E6=89=93=E5=8D=B0=E4=B8=80=E4=BA=9B=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF=E7=9A=84=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/model/schedule.go    |  3 ++-
 backend/services/schedule.go | 14 ++++++++++++++
 2 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/backend/model/schedule.go b/backend/model/schedule.go
index 1c8db0bd..6415e22b 100644
--- a/backend/model/schedule.go
+++ b/backend/model/schedule.go
@@ -65,7 +65,8 @@ func GetScheduleList(filter interface{}) ([]Schedule, error) {
 		// 获取爬虫名称
 		spider, err := GetSpider(schedule.SpiderId)
 		if err != nil {
-			log.Errorf(err.Error())
+			log.Errorf("get spider by id: %s, error: %s", schedule.SpiderId.Hex(), err.Error())
+			debug.PrintStack()
 			continue
 		}
 		schedules[i].SpiderName = spider.Name
diff --git a/backend/services/schedule.go b/backend/services/schedule.go
index 1c08e0fd..c35c6a58 100644
--- a/backend/services/schedule.go
+++ b/backend/services/schedule.go
@@ -62,12 +62,16 @@ func (s *Scheduler) Start() error {
 
 	// 更新任务列表
 	if err := s.Update(); err != nil {
+		log.Errorf("update scheduler error: %s", err.Error())
+		debug.PrintStack()
 		return err
 	}
 
 	// 每30秒更新一次任务列表
 	spec := "*/30 * * * * *"
 	if _, err := exec.AddFunc(spec, UpdateSchedules); err != nil {
+		log.Errorf("add func update schedulers error: %s", err.Error())
+		debug.PrintStack()
 		return err
 	}
 
@@ -80,12 +84,16 @@ func (s *Scheduler) AddJob(job model.Schedule) error {
 	// 添加任务
 	eid, err := s.cron.AddFunc(spec, AddTask(job))
 	if err != nil {
+		log.Errorf("add func task error: %s", err.Error())
+		debug.PrintStack()
 		return err
 	}
 
 	// 更新EntryID
 	job.EntryId = eid
 	if err := job.Save(); err != nil {
+		log.Errorf("job save error: %s", err.Error())
+		debug.PrintStack()
 		return err
 	}
 
@@ -106,6 +114,8 @@ func (s *Scheduler) Update() error {
 	// 获取所有定时任务
 	sList, err := model.GetScheduleList(nil)
 	if err != nil {
+		log.Errorf("get scheduler list error: %s", err.Error())
+		debug.PrintStack()
 		return err
 	}
 
@@ -116,6 +126,8 @@ func (s *Scheduler) Update() error {
 
 		// 添加到定时任务
 		if err := s.AddJob(job); err != nil {
+			log.Errorf("add job error: %s", err.Error())
+			debug.PrintStack()
 			return err
 		}
 	}
@@ -128,6 +140,8 @@ func InitScheduler() error {
 		cron: cron.New(cron.WithSeconds()),
 	}
 	if err := Sched.Start(); err != nil {
+		log.Errorf("start scheduler error: %s", err.Error())
+		debug.PrintStack()
 		return err
 	}
 	return nil