diff --git a/develop/qinglong/task.go b/develop/qinglong/task.go index dfb098b..5bffa0a 100644 --- a/develop/qinglong/task.go +++ b/develop/qinglong/task.go @@ -2,6 +2,7 @@ package qinglong import ( "fmt" + "strings" "time" "github.com/cdle/sillyGirl/core" @@ -22,19 +23,13 @@ func init() { if err := Config.Req(CRONS, PUT, "/run", []byte(fmt.Sprintf(`["%s"]`, cron.Value))); err != nil { return err } - i := 0 for { - i++ - time.Sleep(time.Second) + time.Sleep(time.Microsecond * 300) data, _ := GetCronLog(cron.Value) - if data != "" { + if strings.Contains(data, "执行结束...") { s.Reply(data) break } - if i > 5 { - s.Reply("执行异常。") - break - } } if err := Config.Req(cron, CRONS, DELETE, []byte(`["`+cron.Value+`"]`)); err != nil { return err @@ -55,19 +50,13 @@ func init() { if err := Config.Req(CRONS, PUT, "/run", []byte(fmt.Sprintf(`["%s"]`, cron.Value))); err != nil { return err } - i := 0 for { - i++ - time.Sleep(time.Second) + time.Sleep(time.Microsecond * 300) data, _ := GetCronLog(cron.Value) - if data != "" { + if strings.Contains(data, "执行结束...") { s.Reply(data) break } - if i > 5 { - s.Reply("执行异常。") - break - } } if err := Config.Req(cron, CRONS, DELETE, []byte(`["`+cron.Value+`"]`)); err != nil { return err