router.go 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  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.GET("versions", v1.ShowVersions)
  27. webv1.POST("version", v1.VersionCreate)
  28. webv1.PUT("version", v1.VersionEdit)
  29. webv1.DELETE("version/:key", v1.VersionDelete)
  30. webv1.POST("version/reload", v1.ReloadVersion)
  31. // 渠道管理
  32. webv1.GET("channel/list", v1.ChannelList)
  33. webv1.POST("channel", v1.ChannelCreate)
  34. webv1.PUT("channel", v1.ChannelUpdate)
  35. webv1.POST("channel/delete", v1.ChannelDelete)
  36. }
  37. pointv1 := r.Group("/point/v1")
  38. {
  39. pointv1.POST("thinkingdata", v1.ThinkingData)
  40. }
  41. subscribev1 := r.Group("/subscribe/v1")
  42. {
  43. subscribev1.POST("/open", v1.Open) // 标记开启订阅
  44. subscribev1.POST("/close", v1.Close) // 标记关闭订阅
  45. subscribev1.POST("/check", v1.Check) // 检查用户当前订阅
  46. subscribev1.POST("/send", v1.Send) // 触发订阅直接发送
  47. subscribev1.POST("/task", v1.Task) // 触发订阅任务发送
  48. }
  49. hotupdateR := r.Group("/hotupdate")
  50. {
  51. hotupdateR.GET("/getversion", hotupdate.GetVersion)
  52. }
  53. // TODO 内网请求,需要添加ip白名单等
  54. internalR := r.Group("/internal")
  55. {
  56. internalR.POST("/addversion", hotupdate.AddVersion)
  57. internalR.GET("/getmaxverinfo", hotupdate.GetMaxVerInfo)
  58. internalR.GET("/getversionlist", hotupdate.GetVersionList)
  59. internalR.PUT("/changestatus", hotupdate.ChangeStatus)
  60. }
  61. //webv1.Use(middleware.BodyHandler())
  62. //{
  63. //
  64. // // 需要登录保护的
  65. // authed := webv1.Group("/")
  66. //authed.Use(middleware.AdminRequired())
  67. // {
  68. //
  69. // }
  70. //
  71. return r
  72. }