es_index_data/udpcreateindex/task.go

// task定时执行项目索引
package main

import (
	util "app.yhyue.com/data_processing/common_utils"
	"github.com/robfig/cron"
)

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)})
//}