eta_bridge/init_serve/task.go

package init_serve

import (
	"eta/eta_bridge/global"
	"eta/eta_bridge/logic/xiangyu"
	"eta/eta_bridge/services"
	"github.com/robfig/cron/v3"
)

func InitTask() {
	// 角色-用户-部门-分组同步
	go services.ListenSyncRole()
	go services.ListenSyncAdmin()
	go services.ListenSyncDepartment()
	go services.ListenSyncGroup()

	go services.ListenSyncUserEnRole()

	// 开始定时任务
	c := cron.New(cron.WithSeconds())

	//每1小时检测一次，增量用户生成
	if global.CONFIG.Xiangyu.UserSyncHost != `` {
		_, err := c.AddFunc("0 0 * * * *", xiangyu.TaskPullUser)
		if err != nil {
			global.LOG.Error("CheckIndexCreateMerge err" + err.Error())
		}
	}

	c.Start()
}