diff --git a/handler/cid.go b/handler/cid.go index afd4137..53e6e7d 100644 --- a/handler/cid.go +++ b/handler/cid.go @@ -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