修复定时任务功能
This commit is contained in:
parent
66ec0ff947
commit
69f04c09a6
|
|
@ -255,15 +255,17 @@ func RunCron() {
|
|||
if err != nil {
|
||||
fmt.Println("json unmarshal failed")
|
||||
}
|
||||
for _, v := range cid_workers {
|
||||
fmt.Println("cid_workers:", cid_workers)
|
||||
for i, v := range cid_workers {
|
||||
//查找定时任务
|
||||
if v.Curr-10 <= 0 {
|
||||
cid := dao.FindCIDByCID(v.CID)
|
||||
if cid.ID != 0 {
|
||||
go RunShell("cron", cid.Url, cid.Script, int(cid.ID), cid.Auth_id)
|
||||
}
|
||||
cid_workers[i].Curr = v.Every
|
||||
} else {
|
||||
v.Curr = v.Curr - 10
|
||||
cid_workers[i].Curr = v.Curr - 10
|
||||
}
|
||||
}
|
||||
//将定时任务加入redis
|
||||
|
|
|
|||
Loading…
Reference in New Issue