jy-data-extract/udpcreateindex/src/task.go

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

import (
	"log"
	"mongodb"
	qutil "qfw/util"
	"time"

	"github.com/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.Start()
}
func task_winneres() {
	log.Println("定时任务，winneres")
	winnerEsTaskOnce()
}
func task_buyeres() {
	log.Println("定时任务，buyeres")
	buyerEsTaskOnce()
}

//招标附件、标的物,临时用
func task_biddingfile() {
	defer qutil.Catch()
	q := map[string]interface{}{
		"comeintime": map[string]interface{}{
			"$gte": time.Now().Unix() - 5400,
			"$lte": time.Now().Unix() - 3600,
		},
		"attach_text": map[string]interface{}{
			"$exists": true,
		},
	}
	biddingPurchaingTask(q)
}

//project2项目索引
func task_projects() {
	t := time.Now()
	pici := time.Date(t.Year(), t.Month(), t.Day(), 0, 0, 0, 0, time.Local).Unix()
	log.Println(pici)
	mapInfo := map[string]interface{}{
		"query": map[string]interface{}{
			"pici": map[string]interface{}{
				"$gte": pici - 86400,
				"$lte": pici,
			},
		},
	}
	projectTask([]byte{}, project2, mapInfo)
}

//企业信用信息
func task_qyxyindex() {
	defer qutil.Catch()
	q := map[string]interface{}{}
	qyxyTask(q)
}

//定时任务site：中国招标投标公共服务平台
func crontab() {
	defer qutil.Catch()
	q := map[string]interface{}{
		"_id": map[string]interface{}{
			"$gte": mongodb.StringTOBsonId("5e344f000000000000000000"), //2020-02-01 5e344f000000000000000000
			"$lte": mongodb.StringTOBsonId("5ea1bb800000000000000000"), //2020-04-23 5ea1bb800000000000000000
		},
	}
	site_attach_text(q)
}