package routers import ( "fmt" "kpt.xdmy/middleware/jwt" "github.com/gin-gonic/gin" "kpt.xdmy/middleware/comm" // "kpt.xdmy/middleware/permission" "net/http" "strings" swaggerFiles "github.com/swaggo/files" ginSwagger "github.com/swaggo/gin-swagger" // "github.com/swaggo/gin-swagger/swaggerFiles" "kpt.xdmy/apiserver/routers/api" "kpt.xdmy/pkg/setting" ) func InitRouter() *gin.Engine { r := gin.New() r.Use(gin.LoggerWithFormatter(func(param gin.LogFormatterParams) string { // 你的自定义格式 return fmt.Sprintf(" %+v \n", param.Keys, ) })) r.Use(gin.Logger()) // 日志 // r.Use(gzip.Gzip(gzip.DefaultCompression)) r.Use(Cors()) // 跨域请求rolemenus r.Use(gin.Recovery()) gin.SetMode(setting.ServerSetting.RunMode) r.MaxMultipartMemory = 1 r.Static("/static", setting.CurrentPath+"/dist/static") // 添加资源路径 r.Static("/datas", setting.CurrentPath+"/dist/datas") // 添加资源路径 r.StaticFile("/", setting.CurrentPath+"/dist/index.html") //前端接口 r.StaticFile("/favicon.ico", setting.CurrentPath+"/dist/favicon.ico") //前端接口 r.StaticFile("/myMap.json", setting.CurrentPath+"/data/myMap.json") //前端接口 r.Static("/file", setting.CurrentPath+"/uploads/file") r.Static("/uploads", setting.CurrentPath+"/uploads") r.POST("/auth", api.Auth) // 获取登录token r.POST("/authdata/test", Exec) r.POST("/authdata/department", DepartmentExec) r.POST("/authdata/provider", ProviderExec) r.POST("/authdata/equipmentExecAdd", EquipmentExecAdd) r.POST("/authdata/contractExec", ContractExec) r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler)) // API 注释 if setting.CommSetting.PortName != "" { r.GET("/comm/:id/:x/:y/", comm.ProcessHttp) r.GET("/cps/:id/:limit", comm.ProcessHttpCPS) r.POST("/comm/:id/:x/:y/", comm.ProcessHttp) r.POST("/cps/:id/:limit", comm.ProcessHttpCPS) } r.POST("/quickResponse", QuickResponse) r.POST("/test", Test) //r.POST("/dingding", Dingding) eqm := r.Group("/manage/api") eqm.POST("/login", api.Auth) apiV1 := r.Group("/authdata") apiV1.Use(jwt.JWT()) // token 验证 { //查询报表管理，启停记录 apiV1.POST("/startStopRecord", StartStopRecord) //查看督办信息 apiV1.POST("/oversee", GetOversee) apiV1.POST("/maintain/pasture", MaintainListPid) apiV1.POST("/maintain", MaintainList) apiV1.POST("/maintain/equipment", MaintainListEquipment) apiV1.POST("/equipment", EquipmentExec) //srm手动推送 apiV1.POST("srm/order/send", ManaulSrmOrderJob) //sap手动推送 apiV1.POST("sap/order/send", ManaulSapOrder) //手动入库 apiV1.POST("sap/laidproof/send", LaidProof) //手动出库 apiV1.POST("sap/useproof/send", UseProof) //手动退货 apiV1.POST("sap/refundproof/send", RefundProof) //手动退库 apiV1.POST("sap/quitproof/send", QuitProof) //sap手动调拨 apiV1.POST("sap/transfer/send", ManualTransfer) apiV1.POST("part/eas/batch", EasBatch) apiV1.POST("/sap/proof/off/list", ProofOffList) apiV1.POST("/sap/proof/off", ProofOff) apiV1.POST("/sap/proof/detail", ProofList) apiV1.GET("/mcs/accounts", McsAccounts) apiV1.POST("/mcs/record", McsControl) apiV1.POST("/rolemenus", api.GetRecuDataByName) apiV1.GET("/userinfo", api.GetUserinfo) apiV1.POST("/logout", api.UserLogout) apiV1.POST("/GetRecuDataByName", api.GetRecuDataByName) //// apiV1.POST("/GetDataByName", api.GetDataByName) apiV1.POST("/GetDataByNames", api.GetDataByNames) apiV1.POST("/PostDataByName", api.PostDataByName) apiV1.POST("/PostThirdPartyData", api.PostThirdPartyData) apiV1.POST("/PostDataByNames", api.PostDataByNames) apiV1.POST("/UpdateDataRelation", api.UpdateDataRelation) //log.error apiV1.POST("/GetDataByNameForm", api.GetDataByNameForm) apiV1.POST("/PostDataByNameForm", api.PostDataByNameForm) apiV1.POST("/GetUpkeepPlan", api.GetUpkeepPlan) apiV1.POST("/GetReportform", api.GetReportform) apiV1.POST("/GetAccount", api.GetAccount) apiV1.POST("/ExecDataByConfig", api.ExecDataByConfig) apiV1.POST("/ImportExcel", api.ImportExcel) apiV1.POST("/upload/:id/:name", api.UploadFile) apiV1.POST("/uploads", api.UploadFiles) apiV1.POST("/uploaderimage", api.UploaderImage) apiV1.POST("/removeimage", api.RemovePicByName) apiV1.GET("/getthumbnailimage/:filename", api.GetThumbnailImage) apiV1.POST("/getoriginimage/:filename", api.GetOriginImage) apiV1.GET("/getfileraw/:filename", api.GetFileRaw) apiV1.GET("/downloadfile/:filename", api.DownloadFile) apiV1.POST("/downloadmailreport", api.DownloadMailReport) apiV1.POST("/removefile/:id", api.RemoveFileByName) apiV1.POST("/testdata", api.TestData) apiV1.POST("/Testpartitions", api.Testpartitions) // eas 对接 apiV1.POST("/EasSync", api.EasSync) apiV1.POST("/partslistSGv2", api.GetPartsListSGv2) apiV1.POST("/waterandelectricity", api.GetWaterAndElectricity) // 备件申购-特殊申购 apiV1.POST("/spare/parts/requisitions", api.SparePartsRequisitions) apiV1.GET("/diesel/type/list", api.GetDieselTypeList) apiV1.POST("/diese/add", InsertDieselData) apiV1.POST("/diese/import/excel", InsertDieselImportExcel) apiV1.POST("/diese/off", DieselOff) apiV1.GET("/centra/index", CentralIndex) //各中心总指标 apiV1.GET("/overall/index", OverallIndex) //集团分项指标 apiV1.GET("/expense", GetExpense) //费用统计 apiV1.GET("/pasture/index", GetPastureIndex) //牧场指标 //apiV1.GET("/vehicleL/list", GetVehicleList) apiV1.POST("/contract/push", PostPushContractDataToSAP) apiV1.GET("/equipment/index", GetEquipmentIndex) apiV1.GET("/choosemonthwx/index", GetChooseMonthWXByDepartment) apiV1.POST("/stock/import", StockExcel) apiV1.GET("/stock/list", GetStockList) apiV1.POST("/stock/del", DelStockList) //各牧场年度用水量对比 apiV1.GET("/water/nowwater", GetWaterYieldByPasture) //单头牛水量 apiV1.GET("/water/singlecow", GetWaterSingleCowByPasture) //单头牛水费 apiV1.GET("/water/waterrate", GetWaterRateByPasture) //水费完成率 apiV1.GET("/water/ratecomplete", GetWaterRateCompleteByPasture) //每月单头牛用水量对比 apiV1.GET("/water/perhead", GetWaterPerHeadByPasture) //各牧场年度用电量对比 apiV1.GET("/electricity/nowelectricity", GetElectricityYieldByPasture) //单头牛电量 apiV1.GET("/electricity/singlecow", GetElectricitySingleCowByPasture) //单头牛电费 apiV1.GET("/electricity/electricityrate", GetElectricityRateByPasture) //电费完成率 apiV1.GET("/electricity/ratecomplete", GetElectricityRateCompleteByPasture) //每月单头牛用电量对比 apiV1.GET("/electricity/perhead", GetElectricityPerHeadByPasture) //各牧场年度维修对比 apiV1.GET("/repair/nowelectricity", GetWxYieldByPasture) //单头牛维修 apiV1.GET("/repair/singlecow", GetWxSingleCowByPasture) //每月单头牛维修对比 apiV1.GET("/repair/perhead", GetWxPerHeadByPasture) //各牧场年度燃动费对比 apiV1.GET("/ignition/nowwater", GetIgnitionYieldByPasture) //各牧场年度柴油费对比 apiV1.GET("/diesel/nowwater", GetDieselYieldByPasture) //单头牛柴油 apiV1.GET("/diesel/rate", GetDieselRateByPasture) //单头牛燃动费 apiV1.GET("/ignition/rate", GetIgnitionRateByPasture) //单头牛燃动费 apiV1.GET("/diesel/perhead", GetDieselPerHeadByPasture) apiV1.GET("/vehicle/list", GetVehicle) // 申购备件修改 apiV1.POST("/partpurchase/edit", EditPartpurchase) //工作分类下拉，目前写死 apiV1.GET("/work/class", GetWorkClass) apiV1.GET("/ensiling", GetEnsiling) //车辆运转率明细 apiV1.GET("/running/rate/detail", GetRunningRateDetail) } if setting.ServerSetting.NoAuth > 0 { apiV2 := r.Group("/data") // restful 接口 tablename 是 表名字 { apiV2.POST("sap/transfer/send", ManualTransfer) apiV2.POST("/getdata", api.GetData) apiV2.POST("/GetDataByName", api.GetDataByName) apiV2.POST("/GetDataByNames", api.GetDataByNames) apiV2.POST("/PostDataByName", api.PostDataByName) apiV2.POST("/PostDataByNames", api.PostDataByNames) apiV2.POST("/ExecDataByConfig", api.ExecDataByConfig) apiV2.POST("/GetDataByNameForm", api.GetDataByNameForm) apiV2.POST("/PostDataByNameForm", api.PostDataByNameForm) apiV2.POST("/ImportExcel", api.ImportExcel) //调用资产标准管理 apiV2.POST("/Equipment", api.Equipment) apiV2.POST("/PastureDepartment", api.PastureDepartment) //插入和修改标准管理 apiV2.POST("/updateAndInster", api.UpdateAndInsert) // 标准库存管理 apiV2.POST("/StandardPart", api.StandardPart) apiV2.POST("/upload", api.UploadFile) apiV2.POST("/uploads", api.UploadFiles) apiV2.POST("/uploaderimage", api.UploaderImage) apiV2.POST("/removeimage", api.RemovePicByName) apiV2.GET("/getthumbnailimage/:filename", api.GetThumbnailImage) apiV2.GET("/getoriginimage/:filename", api.GetOriginImage) apiV2.GET("/getfileraw/:filename", api.GetFileRaw) apiV2.GET("/downloadfile/:filename", api.DownloadFile) apiV2.POST("/removefile", api.RemoveFileByName) apiV2.POST("/testdata", api.TestData) //apiV2.POST("/DingShi",api.DingShi) //apiV2.POST("/Ceshi",api.Ceshi) } } r.POST("/getopenid/:code", api.GetOpenID) apiV3 := r.Group("/thi") // restful 接口 tablename 是 表名字 { apiV3.POST("/GetDataByName", api.GetDataByName) apiV3.POST("/PostDataByName", api.PostDataByName) apiV3.POST("/vehicle/edit", EditVehicle) } apiV4 := r.Group("/openapi") //apiV4.Use(jwt.JWT()) { apiV4.POST("/GetDataByName", api.GetDataByNameOPEN) apiV4.POST("/PostDataByName", api.PostDataByNameOPEN) } apiV5 := r.Group("/api/v1") { apiV5.GET("/oauth2/token", OAuth2Token) apiV5.GET("/logout", OAuth2Logout) apiV5.POST("/user/add", OAuth2AddUser) } return r } // 跨域 //func Cors() gin.HandlerFunc { // return func(c *gin.Context) { // //method := c.Request.Method //请求方法 // //origin := c.Request.Header.Get("Origin") //请求头部 // var headerKeys []string // 声明请求头keys // for k := range c.Request.Header { // headerKeys = append(headerKeys, k) // } // headerStr := strings.Join(headerKeys, ", ") // if headerStr != "" { // headerStr = fmt.Sprintf("access-control-allow-origin, access-control-allow-headers, %s", headerStr) // } else { // headerStr = "access-control-allow-origin, access-control-allow-headers" // } // //if origin != "" { // c.Writer.Header().Set("Access-Control-Allow-Origin", "*") // c.Header("Access-Control-Allow-Origin", "*") // 这是允许访问所有域 // c.Header("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE, UPDATE") //服务器支持的所有跨域请求的方法,为了避免浏览次请求的多次'预检'请求 // // header的类型 // 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") // // 允许跨域设置 可以返回其他子段 // 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") // 跨域关键设置 让浏览器可以解析 // c.Header("Access-Control-Max-Age", "172800") // 缓存请求信息 单位为秒 // c.Header("Access-Control-Allow-Credentials", "false") // 跨域请求是否需要带cookie信息 默认设置为true // c.Set("content-type", "application/json") // 设置返回格式是json // //} // // //放行所有OPTIONS方法 // //if method == "OPTIONS" { // c.JSON(http.StatusOK, "Options Request!") // //} // // 处理请求 // c.Next() // 处理请求 // } //} // Cors 开放所有接口的OPTIONS方法 func Cors() gin.HandlerFunc { return func(c *gin.Context) { method := c.Request.Method //请求方法 //origin := c.Request.Header.Get("Origin") //请求头部 var headerKeys []string // 声明请求头keys for k, _ := range c.Request.Header { headerKeys = append(headerKeys, k) } headerStr := strings.Join(headerKeys, ", ") if headerStr != "" { headerStr = fmt.Sprintf("access-control-allow-origin, access-control-allow-headers, %s", headerStr) } else { headerStr = "access-control-allow-origin, access-control-allow-headers" } //if origin != "" { // origin := c.Request.Header.Get("Origin") c.Header("Access-Control-Allow-Origin", "*") // 这是允许访问所有域 c.Header("Access-Control-Allow-Methods", "*") //服务器支持的所有跨域请求的方法,为了避免浏览次请求的多次'预检'请求 // header的类型 c.Header("Access-Control-Allow-Headers", "Authorization, Content-Length, X-CSRF-Token, Token,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") // 允许跨域设置 可以返回其他子段 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") // 跨域关键设置 让浏览器可以解析 c.Header("Access-Control-Max-Age", "172800") // 缓存请求信息 单位为秒 c.Header("Access-Control-Allow-Credentials", "false") // 跨域请求是否需要带cookie信息 默认设置为true c.Set("content-type", "application/json") // 设置返回格式是json //} //放行所有OPTIONS方法 if method == "OPTIONS" { c.JSON(http.StatusOK, "Options Request!") } // 处理请求 c.Next() // 处理请求 } }