router.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. package router
  2. import (
  3. "dsbqj-admin/app/api/hotupdate"
  4. v1 "dsbqj-admin/app/api/v1"
  5. "dsbqj-admin/middleware"
  6. "os"
  7. "github.com/gin-gonic/gin"
  8. )
  9. // NewRouter 路由配置
  10. func NewRouter() *gin.Engine {
  11. r := gin.New()
  12. // 中间件, 顺序不能改
  13. r.Use(middleware.Session(os.Getenv("SESSION_SECRET")))
  14. r.Use(middleware.Cors())
  15. r.Use(gin.Recovery())
  16. // 路由
  17. apiv1 := r.Group("/api/v1")
  18. {
  19. //apiv1.POST("upload/data", v1.UploadReport)
  20. apiv1.POST("version/check", v1.CheckVersion)
  21. apiv1.POST("version/server", v1.ServerVersion)
  22. apiv1.GET("channel/all", v1.ChannelAll)
  23. }
  24. webv1 := r.Group("/web/v1")
  25. {
  26. webv1.POST("auth/login", v1.AdminLogin)
  27. authed := webv1.Group("")
  28. authed.Use(middleware.AdminAccountRequired())
  29. {
  30. authed.PUT("auth/password", v1.AdminChangePassword)
  31. authed.GET("versions", v1.ShowVersions)
  32. authed.POST("version", v1.VersionCreate)
  33. authed.PUT("version", v1.VersionEdit)
  34. authed.DELETE("version/:key", v1.VersionDelete)
  35. authed.POST("version/reload", v1.ReloadVersion)
  36. authed.GET("channel/list", v1.ChannelList)
  37. authed.POST("channel", v1.ChannelCreate)
  38. authed.PUT("channel", v1.ChannelUpdate)
  39. authed.POST("channel/delete", v1.ChannelDelete)
  40. }
  41. }
  42. pointv1 := r.Group("/point/v1")
  43. {
  44. pointv1.POST("thinkingdata", v1.ThinkingData)
  45. }
  46. subscribev1 := r.Group("/subscribe/v1")
  47. {
  48. subscribev1.POST("/open", v1.Open) // 标记开启订阅
  49. subscribev1.POST("/close", v1.Close) // 标记关闭订阅
  50. subscribev1.POST("/check", v1.Check) // 检查用户当前订阅
  51. subscribev1.POST("/send", v1.Send) // 触发订阅直接发送
  52. subscribev1.POST("/task", v1.Task) // 触发订阅任务发送
  53. }
  54. hotupdateR := r.Group("/hotupdate")
  55. {
  56. hotupdateR.GET("/getversion", hotupdate.GetVersion)
  57. }
  58. // TODO 内网请求,需要添加ip白名单等
  59. internalR := r.Group("/internal")
  60. internalR.Use(middleware.AdminAccountRequired())
  61. {
  62. internalR.POST("/addversion", hotupdate.AddVersion)
  63. internalR.GET("/getmaxverinfo", hotupdate.GetMaxVerInfo)
  64. internalR.GET("/getversionlist", hotupdate.GetVersionList)
  65. internalR.PUT("/changestatus", hotupdate.ChangeStatus)
  66. }
  67. //webv1.Use(middleware.BodyHandler())
  68. //{
  69. //
  70. // // 需要登录保护的
  71. // authed := webv1.Group("/")
  72. //authed.Use(middleware.AdminRequired())
  73. // {
  74. //
  75. // }
  76. //
  77. return r
  78. }