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

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

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

	"github.com/cron"
)

func task_standarData() {
	mgofromdb := qu.ObjToString(sysconfig["mgofromdb"])
	c := cron.New()
	_ = c.AddFunc("0 30 4 * * *", func() {
		t := time.Now()
		pici := time.Date(t.Year(), t.Month(), t.Day(), 0, 0, 0, 0, time.Local).Unix()
		query := map[string]interface{}{
			"comeintime": map[string]interface{}{
				"$gt":  pici - 86400,
				"$lte": pici,
			},
		}
		log.Println(mgofromdb, query)
		go winnerStandarData(mgofromdb, query)
		time.Sleep(1 * time.Minute)
		go buyerStandarData(mgofromdb, query)
		time.Sleep(1 * time.Minute)
		go agencyStandarData(mgofromdb, query)
	})
	c.Start()
}