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

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

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

	"github.com/cron"
)

func task_index() {
	c := cron.New()
	c.AddFunc("20 30 5 * * *", func() { task_projects() })
	c.AddFunc("0 15 * * * *", func() { task_biddingfile() }) //每两小时执行一次
	//c.AddFunc("0 22 14 * * *", func() { task_qyxyindex() })
	c.Start()
}

//招标附件、标的物,临时用
func task_biddingfile() {
	defer qutil.Catch()
	q := map[string]interface{}{
		"extract_state": map[string]interface{}{
			"$eq": 3,
		},
	}
	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)
}