| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051 |
- package routers
- import (
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/engine"
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/entitys"
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/models"
- "github.com/gin-gonic/gin"
- "sync"
- )
- var (
- _registerHandlers []func(e *engine.ApiEngine) = nil
- _registerHandlerMutex sync.Mutex
- _router map[string][]gin.HandlerFunc
- )
- func addRegisterHandler(handler func(e *engine.ApiEngine)) {
- _registerHandlerMutex.Lock()
- defer _registerHandlerMutex.Unlock()
- if _registerHandlers == nil {
- _registerHandlers = make([]func(e *engine.ApiEngine), 0)
- }
- _registerHandlers = append(_registerHandlers, handler)
- }
- func UseMiddleware(name string, middle ...gin.HandlerFunc) {
- if _router == nil {
- _router = make(map[string][]gin.HandlerFunc)
- }
- _router[name] = append(_router[name], middle...)
- }
- func Register(e *engine.ApiEngine) {
- e.AddAppMoudleInitFunc("light-apiengine", DbInitFunc)
- _registerHandlerMutex.Lock()
- defer _registerHandlerMutex.Unlock()
- for i := range _registerHandlers {
- _registerHandlers[i](e)
- }
- }
- func DbInitFunc(domain string, e entitys.ApiEngineInterface) {
- if domain == "" {
- for _, db := range e.GetAllBusinessDb() {
- models.SyncDb(db)
- }
- } else {
- db := e.GetBusinessDb(domain)
- models.SyncDb(db)
- }
- }
|