tmrgo/routers/router.go

package routers

import (
	"context"
	"fmt"

	"../comm"
	_ "../docs"
	"../middleware/jwt"

	"net/http"
	"strings"

	"../pkg/setting"
	"../routers/api"

	"../routers/api/sap"
	"../routers/api/zc"
	"github.com/gin-contrib/gzip"
	"github.com/gin-gonic/gin"
	ginSwagger "github.com/swaggo/gin-swagger"
	"github.com/swaggo/gin-swagger/swaggerFiles"
)

func InitRouter() *gin.Engine {
	r := gin.New()
	// api.InitMqttClient()
	go api.CronScheduled(context.TODO())
	// go sap.XdmySapSync()
	//正诚配方生产计划同步
	// go zc.SyncZC()

	r.Use(func(c *gin.Context) {
		fmt.Println(c.Request.URL)
	})
	r.Use(gzip.Gzip(gzip.DefaultCompression))
	//	ginpprof.Wrap(r)
	r.Use(gin.LoggerWithFormatter(func(param gin.LogFormatterParams) string {
		// 你的自定义格式
		return fmt.Sprintf("   %+v \n",
			param.Keys,
		)
	}))
	r.Use(gin.Logger()) // 日志

	r.Use(Cors()) // 跨域请求rolemenus
	r.Use(gin.Recovery())
	gin.SetMode(setting.ServerSetting.RunMode)

	r.Static("/static", setting.CurrentPath+"/dist/static")               // 添加资源路径
	r.StaticFile("/", setting.CurrentPath+"/dist/index.html")             //前端接口
	r.StaticFile("/favicon.ico", setting.CurrentPath+"/dist/favicon.ico") //前端接口

	r.Static("/file", setting.CurrentPath+"/uploads/file")
	r.Static("/uploads", setting.CurrentPath+"/uploads")
	r.POST("/auth", api.Auth)           // 获取登录token
	r.POST("/authlogin", api.AuthLogin) // 获取登录token

	r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler)) // API 注释

	// r.GET("/sync", api.Sync)
	// r.GET("/UDFeedtempletinfo", api.UDFeedtempletinfo)
	// r.GET("/UDUploadadddata", api.UDUploadadddata)
	// r.GET("/UDUploaddiliverdata", api.UDUploaddiliverdata)
	// r.GET("/UDUploadoverplusdata", api.UDUploadoverplusdata)

	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)
	}
	eqm := r.Group("/manage/api")
	eqm.POST("/login", api.Auth)
	eqm.POST("/login/imei", api.AuthImei)

	r.GET("/getData", api.GetWxCode)

	r.POST("/userwxopenid/binding", api.UserWXOpenIDBinding)

	apiV1 := r.Group("/authdata")
	apiV1.Use(jwt.JWT()) // token 验证
	{
		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("/GetDataBySqlIN", api.GetDataBySqlIN)
		apiV1.POST("/GetDataByNames", api.GetDataByNames)
		apiV1.POST("/PostDataByName", api.PostDataByName)
		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("/GetArrList", api.GetArrList)
		apiV1.POST("/GETNurJudge", api.GETNurJudge)
		apiV1.POST("/GETNurJudgeRport", api.GETNurJudgeRport)

		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("/uploaderTmrImage", api.UploaderTmrImage)
		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("/removefile/:id", api.RemoveFileByName)

		apiV1.POST("/testdata", api.TestData)
		apiV1.POST("/Testpartitions", api.Testpartitions)

		//自定义报表
		apiV1.POST("/Createchart", api.Createchart)
		apiV1.POST("/Updatechart", api.Createchart)
		apiV1.POST("/exesql", api.ExecSQL)
		apiV1.POST("/Createdashboard", api.Updatedashboard)
		apiV1.POST("/Updatedashboard", api.Updatedashboard)
		apiV1.POST("/Dashboards", api.Dashboards)

		// 格润富德 API 数据获取
		apiV1.POST("/getDorm", api.GetDorm) // 牛舍信息
		apiV1.POST("/GetRJSBData", api.GetRJSBData)
		apiV1.POST("/PostRJSBData", api.PostRJSBData)
		apiV1.POST("/PostRJSBDatas", api.PostRJSBDatas)

		apiV1.POST("/autogeneration", api.Autogeneration)
		apiV1.POST("/spillage", api.GetSpillage)
		apiV1.POST("/trains", api.UpdateTrains)
		apiV1.POST("/lpplan/edit", api.UpdateLpplan)
		apiV1.POST("/lpplan/add", api.AddLpplan)
		apiV1.POST("/lpplandtl", api.GetLpplandtl)
		apiV1.POST("/lpplandtl/restore", api.RestoreLpplandtl)
		apiV1.POST("/lpplandtl/del", api.DelLpplandtl)

		apiV1.POST("/spillage/day", api.GetSpillageDay)
		apiV1.POST("/trains/day", api.UpdateTrainsDay)
		apiV1.POST("/lpplandtl/restore/day", api.RestoreLpplandtlDay)
		apiV1.POST("/lpplandtl/del/day", api.DelLpplandtlDay)
		apiV1.POST("/lpplandtl/add/day", api.AddLpplanDay)
		apiV1.POST("/lpplandtl/day", api.GetLpplandtlDay)

		apiV1.POST("/chart/feedEffMR", api.GetFeedEffMR)
		apiV1.POST("/chart/feedEffSL", api.GetFeedEffSL)
		apiV1.POST("/chart/feedEffHL", api.GetFeedEffHL)
		apiV1.POST("/chart/feedEffZH", api.GetFeedEffZH)
		apiV1.POST("/chart/feedEffCBFT", api.GetFeedEffCBFT)

		apiV1.POST("/chart/accuracyAllFT", api.GetAccuracyAllFT)
		apiV1.POST("/chart/accuracyAllJH", api.GetAccuracyAllJH)
		apiV1.POST("/chart/accuracyAllNQ", api.GetAccuracyAllNQ)
		apiV1.POST("/chart/accuracyAllCC", api.GetAccuracyAllCC)
		apiV1.POST("/chart/accuracyAllHL", api.GetAccuracyAllHL)
		apiV1.POST("/chart/accuracyAllLS", api.GetAccuracyAllLS)
		apiV1.POST("/chart/accuracyAllQX", api.GetAccuracyAllQX)

		apiV1.POST("/summary", api.GetSummary)

		apiV1.POST("/ftdetail/edit", api.UpdateFTdetail)
		apiV1.POST("/fpdetail/edit", api.UpdateFpdetailBar)
		apiV1.POST("/ftdetai/del", api.DeleteFTdetail)
		apiV1.POST("/lpplandtl/add", api.AddLpplandtl)
		apiV1.POST("/lpplandtl/edit/sort", api.UpdateLpplandtlSort)
		apiV1.POST("/lpplandtl/date/add", api.AddLpplandtlDate)
		apiV1.POST("/lpplandtl/edit/date/sort", api.UpdateLpplandtlDateSort)
		apiV1.POST("/processAnalysist", api.GetProcessAnalysis)

		apiV1.POST("/feedp/undistribute", api.GetFeedpUndistributed)

		apiV1.POST("/feedtemplet/enable", api.UpdateFeedtempletStatus)

		apiV1.POST("/ftdry/add", api.AddFtdry)
		apiV1.POST("/checkDates", api.CheckDates)
		//编辑数据同步勾选状态
		apiV1.POST("/scheduled/status/edit", api.UpdateScheduledStatus)
		//	立即同步
		apiV1.POST("/synchronizeNow", api.SynchronizeNow)

		apiV1.POST("/fpdimportexcel", api.FpdImportExcel)

		apiV1.POST("/barfeedremain/excel", api.GetBarfeedremainExcel)

		//删除当前班次撒料时记录
		apiV1.POST("/spillageall/del", api.DeleteSpillageAll)

		apiV1.POST("/feedp/history", api.GetFeedpHistory)
		//查看撒料修改记录
		apiV1.POST("/spillageall/history", api.GetSpillageallHistory)
		//查看撒料设备
		apiV1.POST("/tmrListEnableTypeAll", api.GetTMRListEnableTypeAll)
		//查看提醒设置
		apiV1.POST("/remind/list", api.GetRemind)
		apiV1.POST("/remind/edit", api.UpdateRemind)
		//配方模板修改记录
		apiV1.POST("/recipetemplate/history", api.GetRecipeTemplateRecordHistory)
		//配方模板修改记录
		apiV1.POST("/feedtemplet/history", api.GetFeedtempletHistory)

		//app取料接口
		apiV1.POST("/downloadedplan", api.GetDownloadedplanMaterial1)
		apiV1.POST("/downloadedplan/list", api.GetDownloadedplanMaterialList)
		apiV1.POST("/subplan", api.GetSubPlan)
		apiV1.POST("/completeplan", api.CompletePlan)
		apiV1.POST("/realtimeweight", api.AddRealTimeWeight)

		//修改撒料计划tmr编号
		apiV1.POST("/materialtmr/edit", api.UpdateMaterialTMR)
		apiV1.POST("/materialtmr/date/edit", api.UpdateMaterialTMRDate)

		//集团端配方下发
		apiV1.POST("/formulaissued", api.AddFormulaIssued)
		//盘点单添加
		apiV1.POST("/biginventory", api.AddBigInventory)
		//sap原料上传
		apiV1.POST("/material/sap/upload", sap.MaterialOutbound)

		apiV1.POST("/downloadplandtl1/image/upload", api.UploadFile1)

		apiV1.POST("/syncSCJH", zc.SyncSCJH)

		//修改日执行计划
		apiV1.POST("/dailydata/edit", api.UpdateDailyData)
		apiV1.POST("/formulastatistics", api.GetFormulaStatistics)

		apiV1.POST("/sap/feed", sap.SyncSapFeed)

		apiV1.POST("/sap/bar", sap.SyncSapBar)

		apiV1.POST("/sap/material", sap.MaterialOutbound)

		apiV1.POST("/feedbackup/check", api.CheckFeedTrgaddress)

		// apiV1.POST("/ud/feedp/sync", api.UdFeedpSync)

	}

	//不需要登录验证的接口
	r.POST("/getopenid/:code", api.GetOpenID)
	apiV3 := r.Group("/thi") // restful  接口 tablename 是 表名字
	{
		apiV3.POST("/GetDataByName", api.ThiGetDataByName)
		apiV3.POST("/PostDataByName", api.PostDataByName)

		// apiV3.POST("/getDorm", api.GetDorm) // 牛舍信息
		// RJSBData
		apiV3.POST("/plandata", api.GetPlanData)
		// PostRJSBData
		apiV3.POST("/plandata/edit", api.PostPlanData)
		// apiV3.POST("/PostRJSBDatas", api.PostRJSBDatas)
	}

	apiV4 := r.Group("/customreport") // restful  接口 tablename 是 表名字
	{
		apiV4.POST("/createchart", api.Createchart)
		apiV4.POST("/PostDataByName", api.PostDataByName)
	}
	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() //  处理请求
	}
}