12345678910111213141516171819202122232425262728293031323334353637383940 |
- // task定时执行项目索引
- package main
- import (
- "github.com/robfig/cron"
- util "utils"
- )
- func task_index() {
- c := cron.New()
- //c.AddFunc("20 30 5 * * *", func() { task_projects() })
- //c.AddFunc("0 30 * * * *", func() { task_biddingfile() }) //每30分钟执行一次
- //c.AddFunc("0 22 14 * * *", func() { task_qyxyindex() })
- _ = c.AddFunc("0 0 0 * * ?", func() { task_winneres() }) //每天凌晨执行一次winner生索引
- _ = c.AddFunc("0 0 1 * * ?", func() { task_buyeres() }) //每天1点执行一次buyer生索引
- //_ = c.AddFunc("0 0 2 * * ?", func() { task_biddingAll() }) //每天2点执行 前一天的所有招标数据
- c.Start()
- }
- func task_winneres() {
- util.Debug("定时任务,winneres")
- winnerEsTaskOnce()
- }
- func task_buyeres() {
- util.Debug("定时任务,buyeres")
- buyerEsTaskOnce()
- }
- //func task_biddingAll() {
- // qutil.Debug("定时任务,bidding_all")
- // t := time.Now()
- // currenttime := time.Date(t.Year(), t.Month(), t.Day(), 0, 0, 0, 0, t.Location())
- // endtime := time.Unix(currenttime.Unix(), 0).AddDate(0, 0, -1)
- //
- // sid := primitive.NewObjectIDFromTimestamp(endtime)
- // eid := primitive.NewObjectIDFromTimestamp(currenttime)
- //
- // //biddingDataTask(nil, map[string]interface{}{"gtid": mongodb.BsonIdToSId(sid), "lteid": mongodb.BsonIdToSId(eid)})
- //}
|