router.go 2.0 KB

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