package common import ( "fmt" "mtp2_if/db" "mtp2_if/global/app" "mtp2_if/global/e" "mtp2_if/global/utils" "mtp2_if/logger" "mtp2_if/models" "net/http" "strconv" "strings" "github.com/gin-gonic/gin" ) // QueryTraderMenuReq 查询交易端菜单请求参数 type QueryTraderMenuReq struct { LoginID int `form:"loginid" binding:"required"` } // QuotePrimaryMenu 报价牌一级分类菜单 type QuotePrimaryMenu struct { Index int `json:"index"` // 序号 Key string `json:"key"` // 键名 Name string `json:"name"` // 菜单名称 SubTitleType int `json:"titletype"` // 子菜单标题模式:0-市场名称;1-外部交易所名称 TradeModes string `json:"trademodes"` // 包含市场交易类型 SubMenus []QuoteSecondaryMenu `json:"submenus"` // 子菜单 } // QuoteSecondaryMenu 报价牌二级分类菜单 type QuoteSecondaryMenu struct { Index int `json:"index"` // 序号 MarketID int `json:"marketid"` // 市场ID TradeMode int `json:"trademode"` // 交易模式 MenuTitle string `json:"menutitle"` // 菜单标题(市场名称或外部交易所名称) GoodsGroupID int `json:"goodsgroupid"` // 商品组ID ExExchangeCode string `json:"exexchangecode"` // 外部交易所代码 } // QueryTraderMenu 查询交易端菜单 // @Summary 查询交易端菜单 // @Produce json // @Security ApiKeyAuth // @Param loginid query int true "登录账号" // @Success 200 {object} app.Response // @Failure 500 {object} app.Response // @Router /Common/QueryTraderMenu [get] // @Tags 通用 func QueryTraderMenu(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QueryTraderMenuReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryPreasleApply failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } datas, _ := getMenu(req.LoginID) menuMap := make(map[string]interface{}) menuMap["menu"] = datas // 查询成功 logger.GetLogger().Infof("QueryPreasleApply successed: %v", menuMap) appG.Response(http.StatusOK, e.SUCCESS, menuMap) } func getMenu(loginID int) ([]QuotePrimaryMenu, error) { engine := db.GetEngine() rst := make([]QuotePrimaryMenu, 0) // ********************* 准备数据 ********************* var taAccounts []string // 账户下所有资金账户 var marketIDs []int // 资金账户下有权限的市场ID列表 // 先要获取当前登录账户对应的资金账户 if err := engine.SQL(fmt.Sprintf(`select to_char(AccountID) from LoginTAAccount where LoginID = %d`, loginID)).Find(&taAccounts); err != nil { return nil, err } // 如果一条记录都没有则直接通过资金账户表获取 if len(taAccounts) == 0 { sql := fmt.Sprintf(`select to_char(ta.accountid) from taaccount ta inner join loginaccount l on ta.userid = l.userid where l.loginid = %d`, loginID) if err := engine.SQL(sql).Find(&taAccounts); err != nil { return nil, err } } // 获取资金账户对应的市场权限(有权限的市场ID) if len(taAccounts) > 0 { taAccountStr := strings.Join(taAccounts, ",") if err := engine.SQL(fmt.Sprintf(`select MarketID from TAAccountMarket where AccountID in (%s)`, taAccountStr)).Find(&marketIDs); err != nil { return nil, err } } // ********************* 构建行情报价牌菜单 ********************* // 获取一级菜单列表 datas := make([]models.Tablecolumnconfig, 0) if err := engine.Where("TableKey = 'trader_master_menu' and IsShow = 1").Find(&datas); err != nil { return nil, err } // 构建一级菜单对象 for i, v := range datas { quotePrimaryMenu := QuotePrimaryMenu{ Index: i, Key: v.Columnfield, Name: v.Columntitle, } // 跳过自选 if v.Columnfield == "optional" { rst = append(rst, quotePrimaryMenu) continue } // FormatterString:模式,0-使用市场名称,1-使用外部交易所名称;Remark:包含市场交易模式 quotePrimaryMenu.SubTitleType, _ = strconv.Atoi(v.Formatterstring) quotePrimaryMenu.TradeModes = v.Remark // 构建二级子菜单对象 // 获取目标交易模式的市场信息 markets := make([]models.Market, 0) marketIDsStr := utils.JoinItoString(marketIDs, ",") if err := engine.Where(fmt.Sprintf(`TradeMode in (%s) and MarketID in (%s)`, quotePrimaryMenu.TradeModes, marketIDsStr)).Find(&markets); err != nil { return nil, err } if quotePrimaryMenu.SubTitleType == 0 { // 使用市场名称 for mi, mv := range markets { quoteSecondaryMenu := QuoteSecondaryMenu{ Index: mi, MarketID: int(mv.Marketid), TradeMode: int(mv.Trademode), MenuTitle: mv.Marketname, } quotePrimaryMenu.SubMenus = append(quotePrimaryMenu.SubMenus, quoteSecondaryMenu) } } else { // 使用外部交易所名称 } rst = append(rst, quotePrimaryMenu) } return rst, nil }