router.go 8.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196
  1. package routers
  2. import (
  3. "fmt"
  4. "../comm"
  5. _ "../docs"
  6. "github.com/gin-gonic/gin"
  7. "github.com/kptyun/KPTCOMM/middleware/jwt"
  8. // "../middleware/permission"
  9. "net/http"
  10. "strings"
  11. "../pkg/setting"
  12. "../routers/api"
  13. ginSwagger "github.com/swaggo/gin-swagger"
  14. "github.com/swaggo/gin-swagger/swaggerFiles"
  15. )
  16. func InitRouter() *gin.Engine {
  17. r := gin.New()
  18. r.Use(gin.LoggerWithFormatter(func(param gin.LogFormatterParams) string {
  19. // 你的自定义格式
  20. return fmt.Sprintf(" %+v \n",
  21. param.Keys,
  22. )
  23. }))
  24. r.Use(gin.Logger()) // 日志
  25. r.Use(Cors()) // 跨域请求rolemenus
  26. r.Use(gin.Recovery())
  27. gin.SetMode(setting.ServerSetting.RunMode)
  28. r.Static("/static", setting.CurrentPath+"/dist/static") // 添加资源路径
  29. r.Static("/datas", setting.CurrentPath+"/dist/datas") // 添加资源路径
  30. r.StaticFile("/", setting.CurrentPath+"/dist/index.html") //前端接口
  31. r.StaticFile("/favicon.ico", setting.CurrentPath+"/dist/favicon.ico") //前端接口
  32. r.StaticFile("/myMap.json", setting.CurrentPath+"/data/myMap.json") //前端接口
  33. r.Static("/file", setting.CurrentPath+"/uploads/file")
  34. r.Static("/uploads", setting.CurrentPath+"/uploads")
  35. r.POST("/auth", api.Auth) // 获取登录token
  36. r.GET("/getAveragePrice/excel", api.GetAveragePriceExcel)
  37. r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler)) // API 注释
  38. if setting.CommSetting.PortName != "" {
  39. r.GET("/comm/:id/:x/:y/", comm.ProcessHttp)
  40. r.GET("/cps/:id/:limit", comm.ProcessHttpCPS)
  41. r.POST("/comm/:id/:x/:y/", comm.ProcessHttp)
  42. r.POST("/cps/:id/:limit", comm.ProcessHttpCPS)
  43. }
  44. eqm := r.Group("/manage/api")
  45. eqm.POST("/login", api.Auth)
  46. apiV1 := r.Group("/authdata")
  47. apiV1.Use(jwt.JWT()) // token 验证
  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("/GetDataByNames", api.GetDataByNames)
  55. apiV1.POST("/PostDataByName", api.PostDataByName)
  56. apiV1.POST("/PostThirdPartyData", api.PostThirdPartyData)
  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("/GetAccount", api.GetAccount)
  64. apiV1.POST("/ExecDataByConfig", api.ExecDataByConfig)
  65. apiV1.POST("/ImportExcel", api.ImportExcel)
  66. apiV1.POST("/upload/:id/:name", api.UploadFile)
  67. apiV1.POST("/uploads", api.UploadFiles)
  68. apiV1.POST("/uploaderimage", api.UploaderImage)
  69. apiV1.POST("/removeimage", api.RemovePicByName)
  70. apiV1.GET("/getthumbnailimage/:filename", api.GetThumbnailImage)
  71. apiV1.POST("/getoriginimage/:filename", api.GetOriginImage)
  72. apiV1.GET("/getfileraw/:filename", api.GetFileRaw)
  73. apiV1.GET("/downloadfile/:filename", api.DownloadFile)
  74. apiV1.POST("/downloadmailreport", api.DownloadMailReport)
  75. apiV1.POST("/removefile/:id", api.RemoveFileByName)
  76. apiV1.POST("/testdata", api.TestData)
  77. apiV1.POST("/Testpartitions", api.Testpartitions)
  78. //查看阳光餐饮产品地区信息
  79. apiV1.POST("/getproductareas", api.GetProductAreas)
  80. apiV1.POST("/productinfo", api.GetProductInfo)
  81. apiV1.POST("/getpublishprice", api.GetPublishPrice)
  82. apiV1.POST("/updatePublishPrice", api.UpdatePublishPrice)
  83. apiV1.POST("/getAveragePrice", api.GetAveragePrice)
  84. apiV1.POST("/getQuotationChart", api.GetQuotationChart)
  85. apiV1.POST("/attentionProduce", api.AttentionProduce)
  86. apiV1.POST("/getAveragePrice/excel", api.GetAveragePriceExcel)
  87. apiV1.POST("/areainfo", api.GetAreaInfo)
  88. // eas 对接
  89. apiV1.POST("/EasSync", api.EasSync)
  90. }
  91. if setting.ServerSetting.NoAuth > 0 {
  92. apiV2 := r.Group("/data") // restful 接口 tablename 是 表名字
  93. {
  94. apiV2.POST("/getdata", api.GetData)
  95. apiV2.POST("/GetDataByName", api.GetDataByName)
  96. apiV2.POST("/GetDataByNames", api.GetDataByNames)
  97. apiV2.POST("/PostDataByName", api.PostDataByName)
  98. apiV2.POST("/PostDataByNames", api.PostDataByNames)
  99. apiV2.POST("/ExecDataByConfig", api.ExecDataByConfig)
  100. apiV2.POST("/GetDataByNameForm", api.GetDataByNameForm)
  101. apiV2.POST("/PostDataByNameForm", api.PostDataByNameForm)
  102. apiV2.POST("/ImportExcel", api.ImportExcel)
  103. //调用资产标准管理
  104. apiV2.POST("/Equipment", api.Equipment)
  105. apiV2.POST("/PastureDepartment", api.PastureDepartment)
  106. //插入和修改标准管理
  107. apiV2.POST("/updateAndInster", api.UpdateAndInsert)
  108. // 标准库存管理
  109. apiV2.POST("/StandardPart", api.StandardPart)
  110. apiV2.POST("/upload", api.UploadFile)
  111. apiV2.POST("/uploads", api.UploadFiles)
  112. apiV2.POST("/uploaderimage", api.UploaderImage)
  113. apiV2.POST("/removeimage", api.RemovePicByName)
  114. apiV2.GET("/getthumbnailimage/:filename", api.GetThumbnailImage)
  115. apiV2.GET("/getoriginimage/:filename", api.GetOriginImage)
  116. apiV2.GET("/getfileraw/:filename", api.GetFileRaw)
  117. apiV2.GET("/downloadfile/:filename", api.DownloadFile)
  118. apiV2.POST("/removefile", api.RemoveFileByName)
  119. apiV2.POST("/testdata", api.TestData)
  120. //apiV2.POST("/DingShi",api.DingShi)
  121. //apiV2.POST("/Ceshi",api.Ceshi)
  122. }
  123. }
  124. r.POST("/getopenid/:code", api.GetOpenID)
  125. apiV3 := r.Group("/thi") // restful 接口 tablename 是 表名字
  126. {
  127. apiV3.POST("/GetDataByName", api.GetDataByName)
  128. apiV3.POST("/PostDataByName", api.PostDataByName)
  129. }
  130. apiV4 := r.Group("/openapi")
  131. //apiV4.Use(jwt.JWT())
  132. {
  133. apiV4.POST("/GetDataByName", api.GetDataByNameOPEN)
  134. apiV4.POST("/PostDataByName", api.PostDataByNameOPEN)
  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. }