eta_task/services/task_gn.go

package services

import (
	"eta_gn/eta_task/services/eta_bridge"
	"eta_gn/eta_task/utils"
	"fmt"
	"github.com/beego/beego/v2/task"
)

func GnTask() {
	// 初始化一次
	//fmt.Println(eta_bridge.SyncGnIndex(nil))
	fmt.Println(eta_bridge.InitRefreshEdb(nil))

	// 指标相关

	// 每小时同步一次指标列表
	if utils.SyncIndexPath != `` {
		syncIndexTime := utils.SyncIndexTime
		if syncIndexTime == `` {
			syncIndexTime = "0 0 * * * *"
		}
		syncIndex := task.NewTask("syncIndex", syncIndexTime, eta_bridge.SyncGnIndex)
		task.AddTask("定时同步指标信息", syncIndex)
	}

	// 每小时同步一次OA用户信息
	syncOaUserTime := utils.SyncOaUserTime
	if syncOaUserTime == `` {
		syncOaUserTime = "0 0 * * * *"
	}
	syncOaUser := task.NewTask("syncGnUser", syncOaUserTime, eta_bridge.SyncGnUser)
	task.AddTask("定时同步OA用户信息", syncOaUser)
}