package main import ( "context" "lims_adapter/handler" "lims_adapter/handler/learning" "lims_adapter/service/timers" "net/http" "github.com/golang/glog" _ "lims_adapter/boot" _ "lims_adapter/valid" "dashoo.cn/micro_libary/micro_srv" "github.com/gogf/gf/frame/g" "github.com/robfig/cron" "github.com/smallnest/rpcx/protocol" ) func main() { go swaggerui() // 定时任务 c := cron.New() spec := "0 0 1 * * ?" // 每日1点执行 if err := c.AddJob(spec, timers.Timer{}); err != nil { glog.Error(err.Error()) } c.Start() srvAddr := g.Config().GetString("setting.bind-addr") basePath := g.Config().GetString("setting.srv-name") // 创建总服务包 s := micro_srv.CreateAndInitService(basePath) // 注册服务对象 s.RegisterName("Meeting", new(handler.Meeting), "") s.RegisterName("Reservation", new(handler.Reservation), "") s.RegisterName("Equipment", new(handler.Equipment), "") s.RegisterName("System", new(handler.System), "") s.RegisterName("Result", new(handler.Result), "") s.RegisterName("Account", new(handler.Account), "") s.RegisterName("SettleAccountBill", new(handler.SettleAccountBillController), "") s.RegisterName("SettleAccountMain", new(handler.SettleAccountMainController), "") s.RegisterName("SettleAccountDetail", new(handler.SettleAccountDetailController), "") s.RegisterName("InstrumentSurcharge", new(handler.InstrumentSurchargeController), "") s.RegisterName("Test", new((handler.TestController)), "") s.RegisterName("LearningSkill", new((learning.LearningSkill)), "") s.RegisterName("LearningMaterial", new((learning.LearningMaterial)), "") s.RegisterName("LearningQuestion", new((learning.LearningQuestion)), "") s.RegisterName("LearningExamRecord", new((learning.LearningExamRecord)), "") s.RegisterName("LearningLearningRecord", new((learning.LearningLearningRecord)), "") s.RegisterName("LearningTestpaper", new((learning.LearningTestpaper)), "") // 注册auth处理 s.AuthFunc = handleAuth // 运行服务 if err := s.Serve("tcp", srvAddr); err != nil { g.Log().Fatal(err) } } // AuthExcludePaths 设定不需要认证的路径 //var AuthExcludePaths = []string{} // 处理Auth func handleAuth(ctx context.Context, req *protocol.Message, token string) error { return micro_srv.HandleAuth(ctx, req, token, nil) } func swaggerui() { defer func() { if r := recover(); r != nil { glog.Error(r) } }() glog.Error(http.ListenAndServe(":8080", http.FileServer(http.Dir("./swaggerui/")))) }