Base/assembly/heartRate/repository/postgre/init.go

package postgre

import (
	"embed"
	"sportfitness/base/assembly/heartRate/repository"

	lib "git.beswell.com/gframe/application/repository"
)

//go:embed hrSql
var sqlDir embed.FS

//var SysToken string // 心率徐彤不需要与总后台对接，所以不需要传递SysToken，且心率库中未存储SysToken

func Init() {
	err := repository.Repository.InitGormByConfigCenter("DB_SportFitness_HrBase")
	if err != nil {
		panic(err)
	}

	err = getClient().AutoMigrateFunc(&sqlDir)
	if err != nil {
		panic(err)
	}
	// 需要从数据库取出sys_token用作系统验证，存全局变量，每次调用总后台接口需要传递sys_token
	//getClient().Raw("select sys_token from s_sys_config").Scan(&SysToken)  Hr子系统不需要与系统总后台对接
	//global.SysToken = SysToken

	go PGHr{}.workSaveHrSaveMap()
}
func getClient() *lib.DB {
	return repository.Repository.GetGormClient()
}