3bc61e0b6b2c885c0a2a348cea2f583b4bc2c361.svn-base 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205
  1. package routers
  2. import (
  3. "../comm"
  4. _ "../docs"
  5. "../middleware/jwt"
  6. "fmt"
  7. "github.com/gin-gonic/gin"
  8. // "../middleware/permission"
  9. "../pkg/setting"
  10. "../routers/api"
  11. "github.com/swaggo/gin-swagger"
  12. "github.com/swaggo/gin-swagger/swaggerFiles"
  13. "net/http"
  14. "strings"
  15. )
  16. func InitRouter() *gin.Engine {
  17. r := gin.New()
  18. // ginpprof.Wrap(r)
  19. r.Use(gin.LoggerWithFormatter(func(param gin.LogFormatterParams) string {
  20. // 你的自定义格式
  21. return fmt.Sprintf(" %+v \n",
  22. param.Keys,
  23. )
  24. }))
  25. r.Use(gin.Logger()) // 日志
  26. r.Use(Cors()) // 跨域请求rolemenus
  27. r.Use(gin.Recovery())
  28. gin.SetMode(setting.ServerSetting.RunMode)
  29. r.Static("/static", setting.CurrentPath + "/dist/static") // 添加资源路径
  30. r.StaticFile("/", setting.CurrentPath + "/dist/index.html") //前端接口
  31. r.StaticFile("/favicon.ico", setting.CurrentPath + "/dist/favicon.ico") //前端接口
  32. r.Static("/file", setting.CurrentPath + "/uploads/file")
  33. r.Static("/uploads", setting.CurrentPath + "/uploads")
  34. r.POST("/auth", api.Auth)// 获取登录token
  35. r.POST("/authlogin", api.AuthLogin)// 获取登录token
  36. r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler)) // API 注释
  37. if setting.CommSetting.PortName!="" {
  38. r.GET("/comm/:id/:x/:y/", comm.ProcessHttp)
  39. r.GET("/cps/:id/:limit", comm.ProcessHttpCPS)
  40. r.POST("/comm/:id/:x/:y/", comm.ProcessHttp)
  41. r.POST("/cps/:id/:limit", comm.ProcessHttpCPS)
  42. }
  43. eqm := r.Group("/manage/api")
  44. eqm.POST("/login", api.Auth)
  45. apiV1 := r.Group("/authdata")
  46. apiV1.Use(jwt.JWT()) // token 验证
  47. // apiV1.Use(permission.CasbinMiddleware()) // 权限 验证
  48. {
  49. apiV1.POST("/rolemenus", api.GetRecuDataByName)
  50. apiV1.GET("/userinfo", api.GetUserinfo)
  51. apiV1.POST("/logout", api.UserLogout)
  52. apiV1.POST("/GetRecuDataByName", api.GetRecuDataByName) ////
  53. apiV1.POST("/GetDataByName", api.GetDataByName)
  54. apiV1.POST("/GetDataBySqlIN", api.GetDataBySqlIN)
  55. apiV1.POST("/GetDataByNames", api.GetDataByNames)
  56. apiV1.POST("/PostDataByName", api.PostDataByName)
  57. apiV1.POST("/PostDataByNames", api.PostDataByNames)
  58. apiV1.POST("/UpdateDataRelation", api.UpdateDataRelation) //log.error
  59. apiV1.POST("/GetDataByNameForm", api.GetDataByNameForm)
  60. apiV1.POST("/PostDataByNameForm", api.PostDataByNameForm)
  61. apiV1.POST("/GetUpkeepPlan", api.GetUpkeepPlan)
  62. apiV1.POST("/GetReportform", api.GetReportform)
  63. apiV1.POST("/GetArrList", api.GetArrList)
  64. apiV1.POST("/GetAccount", api.GetAccount)
  65. apiV1.POST("/GETNurJudge", api.GETNurJudge)
  66. apiV1.POST("/GETNurJudgeRport", api.GETNurJudgeRport)
  67. apiV1.POST("/ExecDataByConfig", api.ExecDataByConfig)
  68. apiV1.POST("/ImportExcel", api.ImportExcel)
  69. apiV1.POST("/upload/:id/:name", api.UploadFile)
  70. apiV1.POST("/uploads", api.UploadFiles)
  71. apiV1.POST("/uploaderimage", api.UploaderImage)
  72. apiV1.POST("/uploaderTmrImage", api.UploaderTmrImage)
  73. apiV1.POST("/removeimage", api.RemovePicByName)
  74. apiV1.GET("/getthumbnailimage/:filename", api.GetThumbnailImage)
  75. apiV1.POST("/getoriginimage/:filename", api.GetOriginImage)
  76. apiV1.GET("/getfileraw/:filename", api.GetFileRaw)
  77. apiV1.GET("/downloadfile/:filename", api.DownloadFile)
  78. apiV1.POST("/removefile/:id", api.RemoveFileByName)
  79. apiV1.POST("/testdata", api.TestData)
  80. apiV1.POST("/Testpartitions", api.Testpartitions)
  81. //自定义报表
  82. apiV1.POST("/Createchart", api.Createchart)
  83. apiV1.POST("/Updatechart", api.Createchart)
  84. apiV1.POST("/exesql", api.ExecSQL)
  85. apiV1.POST("/Createdashboard", api.Updatedashboard)
  86. apiV1.POST("/Updatedashboard", api.Updatedashboard)
  87. apiV1.POST("/Dashboards", api.Dashboards)
  88. // 格润富德 API 数据获取
  89. apiV1.POST("/getDorm", api.GetDorm) // 牛舍信息
  90. apiV1.POST("/GetRJSBData", api.GetRJSBData)
  91. apiV1.POST("/PostRJSBData", api.PostRJSBData)
  92. apiV1.POST("/PostRJSBDatas", api.PostRJSBDatas)
  93. //apiV1.POST("/api/getMaterial", api.GetMaterial) // 饲料基本信息
  94. //apiV1.POST("/api/getMaterialCategory", api.GetMaterialCategory) // 饲料分类信息
  95. //apiV1.POST("/api/getCowCategory", api.GetCowCategory) // 畜牧类别
  96. //apiV1.POST("/api/getFormula", api.GetFormula) // 配方数据
  97. // 格润富德 API 数据上传
  98. //apiV1.POST("/api/addOtherDevice", api.AddOtherDevice) // 搅拌数据
  99. //apiV1.POST("/api/addOtherDeviceFeeding", api.AddOtherDeviceFeeding) // 撒料数据
  100. }
  101. if setting.ServerSetting.NoAuth > 0 {
  102. apiV2 := r.Group("/data") // restful 接口 tablename 是 表名字
  103. {
  104. apiV2.POST("/getdata", api.GetData)
  105. apiV2.POST("/GetDataByName", api.GetDataByName)
  106. apiV2.POST("/GetDataByNames", api.GetDataByNames)
  107. apiV2.POST("/PostDataByName", api.PostDataByName)
  108. apiV2.POST("/PostDataByNames", api.PostDataByNames)
  109. apiV2.POST("/ExecDataByConfig", api.ExecDataByConfig)
  110. apiV2.POST("/GetDataByNameForm", api.GetDataByNameForm)
  111. apiV2.POST("/PostDataByNameForm", api.PostDataByNameForm)
  112. apiV2.POST("/ImportExcel", api.ImportExcel)
  113. apiV2.POST("/upload", api.UploadFile)
  114. apiV2.POST("/uploads", api.UploadFiles)
  115. apiV2.POST("/uploaderimage", api.UploaderImage)
  116. apiV2.POST("/removeimage", api.RemovePicByName)
  117. apiV2.GET("/getthumbnailimage/:filename", api.GetThumbnailImage)
  118. apiV2.GET("/getoriginimage/:filename", api.GetOriginImage)
  119. apiV2.GET("/getfileraw/:filename", api.GetFileRaw)
  120. apiV2.GET("/downloadfile/:filename", api.DownloadFile)
  121. apiV2.POST("/removefile", api.RemoveFileByName)
  122. apiV2.POST("/testdata", api.TestData)
  123. }
  124. }
  125. r.POST("/getopenid/:code", api.GetOpenID)
  126. apiV3 := r.Group("/thi") // restful 接口 tablename 是 表名字
  127. {
  128. apiV3.POST("/GetDataByName", api.GetDataByName)
  129. apiV3.POST("/PostDataByName", api.PostDataByName)
  130. }
  131. apiV4 := r.Group("/customreport") // restful 接口 tablename 是 表名字
  132. {
  133. apiV4.POST("/createchart", api.Createchart)
  134. apiV4.POST("/PostDataByName", api.PostDataByName)
  135. }
  136. return r
  137. }
  138. // 跨域
  139. func Cors() gin.HandlerFunc {
  140. return func(c *gin.Context) {
  141. method := c.Request.Method //请求方法
  142. origin := c.Request.Header.Get("Origin") //请求头部
  143. var headerKeys []string // 声明请求头keys
  144. for k, _ := range c.Request.Header {
  145. headerKeys = append(headerKeys, k)
  146. }
  147. headerStr := strings.Join(headerKeys, ", ")
  148. if headerStr != "" {
  149. headerStr = fmt.Sprintf("access-control-allow-origin, access-control-allow-headers, %s", headerStr)
  150. } else {
  151. headerStr = "access-control-allow-origin, access-control-allow-headers"
  152. }
  153. if origin != "" {
  154. c.Writer.Header().Set("Access-Control-Allow-Origin", "*")
  155. c.Header("Access-Control-Allow-Origin", "*") // 这是允许访问所有域
  156. c.Header("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE, UPDATE") //服务器支持的所有跨域请求的方法,为了避免浏览次请求的多次'预检'请求
  157. // header的类型
  158. c.Header("Access-Control-Allow-Headers", "Authorization, Content-Length, X-CSRF-Token, id, Token, name, optname, thumbnail, session, X_Requested_With, Accept, Origin, Host, Connection, Accept-Encoding, Accept-Language,DNT, X-CustomHeader, Keep-Alive, User-Agent, X-Requested-With, If-Modified-Since, Cache-Control, Content-Type, Pragma")
  159. // 允许跨域设置 可以返回其他子段
  160. c.Header("Access-Control-Expose-Headers", "Content-Length, Access-Control-Allow-Origin, Access-Control-Allow-Headers, Cache-Control, Content-Language, Content-Type, Expires, Last-Modified, Pragma, FooBar") // 跨域关键设置 让浏览器可以解析
  161. c.Header("Access-Control-Max-Age", "172800") // 缓存请求信息 单位为秒
  162. c.Header("Access-Control-Allow-Credentials", "false") // 跨域请求是否需要带cookie信息 默认设置为true
  163. c.Set("content-type", "application/json") // 设置返回格式是json
  164. }
  165. //放行所有OPTIONS方法
  166. if method == "OPTIONS" {
  167. c.JSON(http.StatusOK, "Options Request!")
  168. }
  169. // 处理请求
  170. c.Next() // 处理请求
  171. }
  172. }