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

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

import (
	"log"
	"time"

	"github.com/cron"
)

func task_projects() {
	c := cron.New()
	_ = c.AddFunc("20 30 5 * * *", func() {
		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)
	})
	c.Start()
}