http.go 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
  1. package http
  2. import (
  3. "go-common/app/interface/main/feedback/conf"
  4. "go-common/app/interface/main/feedback/service"
  5. "go-common/library/log"
  6. bm "go-common/library/net/http/blademaster"
  7. "go-common/library/net/http/blademaster/middleware/auth"
  8. "go-common/library/net/http/blademaster/middleware/verify"
  9. )
  10. var (
  11. verifySvc *verify.Verify
  12. authSvc *auth.Auth
  13. feedbackSvr *service.Service
  14. )
  15. // Init init http
  16. func Init(c *conf.Config) error {
  17. initService(c)
  18. engineOut := bm.DefaultServer(c.BM.Outer)
  19. outerRouter(engineOut)
  20. internalRouter(engineOut)
  21. // init external server
  22. if err := engineOut.Start(); err != nil {
  23. log.Error("engineOut.Start() error(%v) | config(%v)", err, c)
  24. panic(err)
  25. }
  26. engineLocal := bm.DefaultServer(c.BM.Local)
  27. localRouter(engineLocal)
  28. // init local server
  29. if err := engineLocal.Start(); err != nil {
  30. log.Error("engineLocal.Start() error(%v) | config(%v)", err, c)
  31. panic(err)
  32. }
  33. return nil
  34. }
  35. // initService init services.
  36. func initService(c *conf.Config) {
  37. verifySvc = verify.New(nil)
  38. authSvc = auth.New(nil)
  39. feedbackSvr = service.New(c)
  40. }
  41. func outerRouter(e *bm.Engine) {
  42. e.Ping(ping)
  43. // init api
  44. feedback := e.Group("/x/feedback")
  45. feedback.POST("/add", addReply)
  46. feedback.GET("/reply", verifySvc.Verify, replys)
  47. feedback.GET("/tag", verifySvc.Verify, replyTag)
  48. feedback.POST("/upload", upload)
  49. feedback.POST("/uploadFile", uploadFile)
  50. feedback.POST("/playerCheck", playerCheck)
  51. feedback.GET("/h5/tag", replyTag)
  52. feedback.POST("/h5/add", addReplyH5)
  53. }
  54. func internalRouter(e *bm.Engine) {
  55. feedbackInner := e.Group("/x/internal/feedback")
  56. feedbackInner.POST("/ugc/add", addWebReply)
  57. feedbackInner.GET("/ugc/session", verifySvc.Verify, sessions)
  58. feedbackInner.POST("/ugc/session/close", verifySvc.Verify, sessionsClose)
  59. feedbackInner.GET("/ugc/tag", verifySvc.Verify, ugcTag)
  60. feedbackInner.GET("/ugc/reply", verifySvc.Verify, webReply)
  61. feedbackInner.POST("/upload", authSvc.User, upload)
  62. }
  63. func localRouter(e *bm.Engine) {
  64. }