MTP20_IF/routers/router.go

package routers

import (
	"mtp2_if/controllers/cfg"
	"mtp2_if/controllers/common"
	"mtp2_if/controllers/cptrade"
	"mtp2_if/controllers/delivery"
	"mtp2_if/controllers/erms2"
	"mtp2_if/controllers/order"
	"mtp2_if/controllers/user"
	"mtp2_if/controllers/wrtrade"
	"mtp2_if/logger"
	"mtp2_if/token"
	"net/http"
	"time"

	"github.com/gin-gonic/gin"

	// Swagger生成的文档
	_ "mtp2_if/docs"

	ginSwagger "github.com/swaggo/gin-swagger"
	"github.com/swaggo/gin-swagger/swaggerFiles"
)

// InitRouter 初始化路由器的方法
func InitRouter() *gin.Engine {
	r := gin.New()
	// 设置日志中间件
	r.Use(ginLoggerMiddleware())
	// 设置奔溃中间件
	r.Use(ginRecoveryMiddleware())
	// 跨域
	r.Use(CORSMiddleware())
	// Swagger
	r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
	// 终端配置
	r.GET("/cfg", cfg.QueryCfg)

	// 主业务路由分组
	apiR := r.Group("/api")
	// apiR.Use(token.Auth())
	// ************************ 账户信息 ************************
	userR := apiR.Group("User")
	userR.Use()
	{
		// 获取登录ID
		userR.GET("/GetLoginID", user.GetLoginID)
	}
	// ************************ 通用服务 ************************
	commonR := apiR.Group("Common")
	commonR.Use()
	{
		// 查询交易端菜单
		commonR.GET("/QueryTraderMenu", common.QueryTraderMenu)
		// 查询交易端列表头信息
		commonR.GET("/QueryTableColumnConfig", common.QueryTableColumnConfig)
	}
	// ************************ 通用单据 ************************
	orderR := apiR.Group("Order")
	orderR.Use(token.Auth())
	{
		// 持仓汇总查询（合约市场）
		orderR.GET("/QueryTradePosition", order.QueryTradePosition)
	}
	// ************************ 仓单贸易 ************************
	wrTradeR := apiR.Group("WRTrade")
	wrTradeR.Use(token.Auth())
	{
		wrTradeR.GET("/GetAllDeliveryGoods", wrtrade.GetAllDeliveryGoods)
	}
	// ************************ 产能预售 ************************
	cpTradeR := apiR.Group("CPTrade")
	cpTradeR.Use(token.Auth())
	{
		// 查询产能预售申请表
		cpTradeR.GET("/QueryPreasleApply", cptrade.QueryPreasleApply)
		// 查询远期订单信息
		cpTradeR.GET("/QueryUserGoodsData", cptrade.QueryUserGoodsData)
		// 查询远期订单注销申请信息
		cpTradeR.GET("/QueryPositionCancel", cptrade.QueryPositionCancel)
		// 查询产能预售商品扩展信息
		cpTradeR.GET("/QueryPresaleGoodsEx", cptrade.QueryPresaleGoodsEx)
		// 查询产能预售我的出价信息
		cpTradeR.GET("/QueryCPTradeMyBidInfos", cptrade.QueryCPTradeMyBidInfos)
		// 查询我的预售信息
		cpTradeR.GET("/QueryMyCPTradeGoods", cptrade.QueryMyCPTradeGoods)
		// 查询产能预售委托单信息
		cpTradeR.GET("/QueryCPTradeOrderDetail", cptrade.QueryCPTradeOrderDetail)
	}
	// ************************ 交割服务 ************************
	deliveryR := apiR.Group("Delivery")
	deliveryR.Use(token.Auth())
	{
		// 查询商品交割关系表
		deliveryR.GET("/QueryDeliveryRelation", delivery.QueryDeliveryRelation)
	}
	// ************************ 风险管理 ************************
	erms2R := apiR.Group("Erms2")
	erms2R.Use(token.Auth())
	{
		// 查询内部成交单信息
		erms2R.GET("/QueryInnerTradeDetail", erms2.QueryInnerTradeDetail)
		// 查询期现套利策略表信息（指定资金账户、未结束的）
		erms2R.GET("/QueryArbitrageStrategy", erms2.QueryArbitrageStrategy)
		// 查询现货合同表信息（指定策略ID、未结束的）
		erms2R.GET("/QuerySpotContract", erms2.QuerySpotContract)
	}

	return r
}

func ginLoggerMiddleware() gin.HandlerFunc {
	return func(c *gin.Context) {
		start := time.Now()
		c.Next()
		end := time.Now()
		latency := end.Sub(start)
		path := c.Request.URL.RequestURI()
		clientip := c.ClientIP()
		method := c.Request.Method
		statuscode := c.Writer.Status()
		logger.GetLogger().Infof("|%3d|%13v|%15s|%s %s",
			statuscode,
			latency,
			clientip,
			method,
			path)
	}
}

func ginRecoveryMiddleware() gin.HandlerFunc {
	return gin.RecoveryWithWriter(logger.GetLogWriter())
}

// CORSMiddleware cors跨域.
func CORSMiddleware() gin.HandlerFunc {
	return func(c *gin.Context) {
		c.Writer.Header().Set("Access-Control-Allow-Origin", "*")
		c.Writer.Header().Set("Access-Control-Allow-Credentials", "true")
		c.Writer.Header().Set("Access-Control-Allow-Headers", "Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, Authorization, accept, origin, Cache-Control, X-Requested-With, X-session-Token")
		c.Writer.Header().Set("Access-Control-Allow-Methods", "POST, OPTIONS, GET, PUT")
		c.Writer.Header().Set("Access-Control-Expose-Headers", "Content-Length, Access-Control-Allow-Origin, Access-Control-Allow-Headers, Content-Type, X-session-Token")
		if c.Request.Method == "OPTIONS" {
			c.AbortWithStatus(http.StatusNoContent)
			return
		}

		c.Next()
	}
}