// Package cptrade 产能预售 package cptrade import ( "fmt" "mtp2_if/db" "mtp2_if/global/app" "mtp2_if/global/e" "mtp2_if/logger" "net/http" "time" "github.com/gin-gonic/gin" ) // QueryPresaleApplyReq 产能预售申请表请求参数 type QueryPresaleApplyReq struct { UserID int `form:"userid" binding:"required"` ApplyID int `form:"applyid"` AccountID int `form:"accountid"` } // Cptradepresaleapply CPTRADE_PRESALEAPPLY 产能预售申请表 type Cptradepresaleapply struct { Applyid int64 `json:"applyid" xorm:"'APPLYID'" binding:"required"` // 申请ID(181+Unix秒时间戳(10位)+xxxxxx) Userid int64 `json:"userid" xorm:"'USERID'"` // 申请人ID Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 申请人账户ID Goodscode string `json:"goodscode" xorm:"'GOODSCODE'"` // 商品代码 Goodsname string `json:"goodsname" xorm:"'GOODSNAME'"` // 商品名称 Relatedgoodsid int64 `json:"relatedgoodsid" xorm:"'RELATEDGOODSID'"` // 关联交易合约ID Presaleqty int64 `json:"presaleqty" xorm:"'PRESALEQTY'"` // 预售数量 Starttime time.Time `json:"starttime" xorm:"'STARTTIME'"` // 预售开始时间 Endtime time.Time `json:"endtime" xorm:"'ENDTIME'"` // 预售结束时间 Attachmenturl string `json:"attachmenturl" xorm:"'ATTACHMENTURL'"` // 附件地址 Applystatus int64 `json:"applystatus" xorm:"'APPLYSTATUS'"` // 申请状态 - 1:已提交 2:初审通过 3:初审拒绝 4:初审失败 5复审通过 6:复审拒绝 7:复审失败 8:已撤销 Handlestatus int64 `json:"handlestatus" xorm:"'HANDLESTATUS'"` // 处理状态 Applytime time.Time `json:"applytime" xorm:"'APPLYTIME'"` // 申请时间 Marketid int64 `json:"marketid" xorm:"'MARKETID'"` // 预售市场ID Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd) Applyremark string `json:"applyremark" xorm:"'APPLYREMARK'"` // 申请备注 Relatedgoodscode string `json:"relatedgoodscode" xorm:"'RELATEDGOODSCODE'"` // 关联交易合约代码 Relatedgoodsname string `json:"relatedgoodsname" xorm:"'RELATEDGOODSNAME'"` // 关联交易合约名称 Marketname string `json:"marketname" xorm:"'MARKETNAME'"` // 预售市场名称 Trademode int64 `json:"trademode" xorm:"'TRADEMODE'"` // 交易模式 - 16:挂牌点选 21:大宗竞拍 Goodunit string `json:"goodunit" xorm:"'GOODUNIT'"` // 报价单位 Goodsid int64 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID } // QueryPreasleApply 查询产能预售申请信息 // @Summary 查询产能预售申请信息 // @Produce json // @Security ApiKeyAuth // @Param userid query int true "账户ID" // @Param applyid query int false "申请ID" // @Param accountid query int false "资金账户ID" // @Success 200 {object} Cptradepresaleapply // @Failure 500 {object} app.Response // @Router /CPTrade/QueryPreasleApply [get] // @Tags 产能预售 func QueryPreasleApply(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QueryPresaleApplyReq 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 } // 查询数据 engine := db.GetEngine() datas := make([]Cptradepresaleapply, 0) // s := engine.Where("userid=?", req.UserID) // if req.AccountID > 0 { // s = s.And("accountid=?", req.AccountID) // } // if req.ApplyID > 0 { // s = s.And("applyid=?", req.ApplyID) // } sql := fmt.Sprintf(`select t.ApplyID, t.UserID, t.AccountID, t.GoodsCode, t.GoodsName, t.RelatedGoodsID, t.PresaleQty, t.StartTime, t.EndTime, t.AttachmentUrl, t.ApplyStatus, t.HandleStatus, t.ApplyTime, t.CreatorID, t.CreateTime, t.MarketID, t.TradeDate, t.APPLYREMARK, g.goodscode RelatedGoodsCode, g.goodsname RelatedGoodsName, m.MarketName, m.TradeMode, e.enumdicname GoodUnit, g.GoodsID from CPTrade_PresaleApply t left join goods g on t.RelatedGoodsID = g.goodsid left join market m on t.MarketID = m.marketid left join enumdicitem e on g.goodunitid = e.enumitemname and e.enumdiccode = 'goodsunit' where t.UserID = %d`, req.UserID) if req.AccountID > 0 { sql += fmt.Sprintf(` and t.AccountID = %d`, req.AccountID) } if req.ApplyID > 0 { sql += fmt.Sprintf(` and t.ApplyID = %d`, req.ApplyID) } if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryPreasleApply failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryPreasleApply successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) } // QueryCPTradeUserGoodsDataReq 远期订单查询请求参数 type QueryCPTradeUserGoodsDataReq struct { AccountID int `form:"accountid" binding:"required"` } // Cptradeusergoodsdata 用户合约数据表 - 导历史 (远期订单数据) type Cptradeusergoodsdata struct { Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 账户ID Goodsid int64 `json:"goodsid" xorm:"'GOODSID'" binding:"required"` // 商品ID Wrstandardid int64 `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 仓单标准ID Userid int64 `json:"userid" xorm:"'USERID'"` // 用户ID Inqty int64 `json:"inqty" xorm:"'INQTY'"` // 转入量（总数量） Cancelqty int64 `json:"cancelqty" xorm:"'CANCELQTY'"` // 注销量 Deliveryqty int64 `json:"deliveryqty" xorm:"'DELIVERYQTY'"` // 交割量 Curpresaleqty int64 `json:"curpresaleqty" xorm:"'CURPRESALEQTY'"` // 当前预售量 Presaledqty int64 `json:"presaledqty" xorm:"'PRESALEDQTY'"` // 已预售量 Presaledamount int64 `json:"presaledamount" xorm:"'PRESALEDAMOUNT'"` // 已预售总金额 Marketid int64 `json:"marketid" xorm:"'MARKETID'"` // 市场ID Freezeamount float64 `json:"freezeamount" xorm:"'FREEZEAMOUNT'"` // 冻结金额 Hasspotfreeze int64 `json:"hasspotfreeze" xorm:"'HASSPOTFREEZE'"` // 是否有现货冻结 - 0:否 1:有 Goodscode string `json:"GoodsCode" xorm:"'GOODSCODE'"` // 订单商品代码 Goodsname string `json:"GoodsName" xorm:"'GOODSNAME'"` // 订单商品名称 Wrstandardcode string `json:"WRStandardCode" xorm:"'WRSTANDARDCODE'"` // 仓单标准代码 Wrstandardname string `json:"WRStandardName" xorm:"'WRSTANDARDNAME'"` // 仓单标准名称 Enabledqty int64 `json:"EnabledQty" xorm:"'ENABLEDQTY'"` // 可用量 Goodunit string `json:"goodunit" xorm:"'GOODUNIT'"` // 报价单位 } // TableName is CPTRADE_USERGOODSDATA // func (Cptradeusergoodsdata) TableName() string { // return "CPTRADE_USERGOODSDATA" // } // QueryUserGoodsData 查询远期订单信息 // @Summary 查询远期订单信息 // @Produce json // @Security ApiKeyAuth // @Param accountid query int true "资金账户ID" // @Success 200 {object} Cptradeusergoodsdata // @Failure 500 {object} app.Response // @Router /CPTrade/QueryUserGoodsData [get] // @Tags 产能预售 func QueryUserGoodsData(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QueryCPTradeUserGoodsDataReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryUserGoodsData failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 engine := db.GetEngine() datas := make([]Cptradeusergoodsdata, 0) if err := engine.SQL(`select t.AccountID, t.GoodsID, t.WRStandardID, t.UserID, t.InQty, t.CancelQty, t.DeliveryQty, t.CurPresaleQty, t.PresaledQty, t.PresaledAmount, t.FreezeAmount, t.MarketID, t.HasSpotFreeze, g.GoodsCode, g.GoodsName, ws.WRStandardCode, ws.WRStandardName, (t.InQty - t.CancelQty - t.DeliveryQty - t.CurPresaleQty) EnabledQty, e.enumdicname GoodUnit from CPTrade_UserGoodsData t left join goods g on t.goodsid = g.goodsid left join WRStandard ws on t.wrstandardid = ws.wrstandardid left join enumdicitem e on g.goodunitid = e.enumitemname and e.enumdiccode = 'goodsunit' where t.accountid = ?`, req.AccountID).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryUserGoodsData failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryUserGoodsData successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) } // QueryPositionCancelReq 查询远期订单注销申请请求参数 type QueryPositionCancelReq struct { UserID int `form:"userid" binding:"required"` AccountID int `form:"accountid"` CancelID int `form:"cancelid"` } // Cptradepositioncancel 远期订单注销申请表 type Cptradepositioncancel struct { Cancelid int64 `json:"cancelid" xorm:"'CANCELID'" binding:"required"` // 注销ID(SEQ_CPTRADE_POSITIONCANCEL) Userid int64 `json:"userid" xorm:"'USERID'"` // 申请人ID Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 申请人账户ID Goodsid int64 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID Cancelqty int64 `json:"cancelqty" xorm:"'CANCELQTY'"` // 注销数量 Applystatus int64 `json:"applystatus" xorm:"'APPLYSTATUS'"` // 申请状态 - 1:已提交 2:初审通过 3:初审拒绝 4:初审失败 5复审通过 6:复审拒绝 7:复审失败 8:已撤销 Handlestatus int64 `json:"handlestatus" xorm:"'HANDLESTATUS'"` // 处理状态 Applytime time.Time `json:"applytime" xorm:"'APPLYTIME'"` // 申请时间 Creatorid int64 `json:"creatorid" xorm:"'CREATORID'"` // 创建人ID Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间 Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd) Marketid int64 `json:"marketid" xorm:"'MARKETID'"` // 市场ID Goodscode string `json:"goodscode" xorm:"'GOODSCODE'"` // 订单商品代码 Goodsname string `json:"goodsname" xorm:"'GOODSNAME'"` // 订单商品名称 Marketname string `json:"marketname" xorm:"'GOODSNAME'"` // 市场名称 Goodunit string `json:"goodunit" xorm:"'GOODUNIT'"` // 报价单位 Creatorname string `json:"creatorname" xorm:"CREATORNAME"` // 创建人 } // QueryPositionCancel 查询远期订单注销申请信息 // @Summary 查询远期订单注销申请信息 // @Produce json // @Security ApiKeyAuth // @Param userid query int true "账户ID" // @Param cancelid query int false "注销ID" // @Param accountid query int false "资金账户ID" // @Success 200 {object} Cptradepositioncancel // @Failure 500 {object} app.Response // @Router /CPTrade/QueryPositionCancel [get] // @Tags 产能预售 func QueryPositionCancel(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QueryPositionCancelReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryPositionCancel failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 sql := fmt.Sprintf(`select t.CancelID, t.UserID, t.AccountID, t.GoodsID, t.CancelQty, t.ApplyStatus, t.HandleStatus, t.ApplyTime, t.CreatorID, t.CreateTime, t.TradeDate, t.MarketID, g.GoodsCode, g.GoodsName, m.MarketName, e.enumdicname GoodUnit, u.username CreatorName from CPTrade_PositionCancel t left join goods g on t.goodsid = g.goodsid left join market m on t.marketid = m.marketid left join enumdicitem e on g.goodunitid = e.enumitemname and e.enumdiccode = 'goodsunit' left join systemmanager u on t.creatorid = u.autoid where t.userid = %d`, req.UserID) if req.AccountID > 0 { sql += fmt.Sprintf(` and t.AccountID= %d`, req.AccountID) } if req.CancelID > 0 { sql += fmt.Sprintf(` and t.CancelID= %d`, req.CancelID) } engine := db.GetEngine() datas := make([]Cptradepositioncancel, 0) if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryPositionCancel failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryPositionCancel successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) } // QueryPresaleGoodsExReq 查询产能预售商品扩展请求参数 type QueryPresaleGoodsExReq struct { GoodsID int `form:"goodsid"` MarketID int `form:"marketid"` PresaleMode int `form:"presalemode"` GoodsIDs string `form:"goodsids"` GoodsCode string `form:"goodscode"` } // QueryPresaleGoodsExRsp 产能预售商品扩展表 type QueryPresaleGoodsExRsp struct { Goodsid int64 `json:"goodsid" xorm:"'GOODSID'" binding:"required"` // 商品ID（预售） Relatedgoodsid int64 `json:"relatedgoodsid" xorm:"'RELATEDGOODSID'"` // 关联交易合约ID Presaleqty int64 `json:"presaleqty" xorm:"'PRESALEQTY'"` // 预售数量 Starttime time.Time `json:"starttime" xorm:"'STARTTIME'"` // 预售开始时间 Endtime time.Time `json:"endtime" xorm:"'ENDTIME'"` // 预售结束时间 Attachmenturl string `json:"attachmenturl" xorm:"'ATTACHMENTURL'"` // 附件地址 Presalemode int64 `json:"presalemode" xorm:"'PRESALEMODE'"` // 预售模式 - 1:一口价 2:大宗式竞拍 Marketid int64 `json:"marketid" xorm:"'MARKETID'"` // 预售市场ID - 根据预售模式选择市场 Refprice float64 `json:"refprice" xorm:"'REFPRICE'"` // 参考价格[一口价] Startprice float64 `json:"startprice" xorm:"'STARTPRICE'"` // 起拍价[大宗式竞拍] Floorprice float64 `json:"floorprice" xorm:"'FLOORPRICE'"` // 底价[大宗式竞拍] Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间 Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd) Relatedmarketid int64 `json:"relatedmarketid" xorm:"'RELATEDMARKETID'"` // 关联交易合约市场ID Presaledqty int64 `json:"presaledqty" xorm:"'PRESALEDQTY'"` // 已预售量(预售结束时更新) Sellstatus int64 `json:"sellstatus" xorm:"'SELLSTATUS'"` // 卖方处理状态 - 1:卖方头寸未处理 2:卖方头寸已处理 Presaledamount float64 `json:"presaledamount" xorm:"'PRESALEDAMOUNT'"` // 已预售总金额(预售结束时更新) Goodsdetail string `json:"goodsdetail" xorm:"'GOODSDETAIL'"` // 详情[大宗] Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价[大宗] Goodunit string `json:"goodunit" xorm:"'GOODUNIT'"` // 报价单位 } // QueryPresaleGoodsEx 查询产能预售商品扩展信息 // @Summary 查询产能预售商品扩展信息 // @Produce json // @Security ApiKeyAuth // @Param goodsid query int false "预售商品ID" // @Param marketid query int false "预售市场ID" // @Param presalemode query int false "预售模式 - 1:一口价 2:大宗式竞拍" // @Param goodsids query string false "预售商品ID列表 - 格式：1,2,3" // @Param goodscode query string false "预售商品代码" // @Success 200 {object} QueryPresaleGoodsExRsp // @Failure 500 {object} app.Response // @Router /CPTrade/QueryPresaleGoodsEx [get] // @Tags 产能预售 func QueryPresaleGoodsEx(c *gin.Context) { appG := app.Gin{C: c} // FIXME: 由于数据中包括[]int类型，会造成校验报错，故暂时不使用 // 获取请求参数 var req QueryPresaleGoodsExReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryPresaleGoodsEx failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 engine := db.GetEngine() datas := make([]QueryPresaleGoodsExRsp, 0) sql := `select t.GoodsID, t.ApplyID, t.UserID, t.AccountID, t.RelatedGoodsID, t.PresaleQty, t.StartTime, t.EndTime, t.AttachmentUrl, t.PresaleMode, t.MarketID, t.RefPrice, t.StartPrice, t.FloorPrice, t.CreateTime, t.TradeDate, t.RelatedMarketID, t.PresaledQty, t.PresaledAmount, t.SellStatus, t.GoodsDetail, t.TradePrice, e.enumdicname GoodUnit from CPTrade_PresaleGoodsEx t left join goods g on t.GoodsID = g.goodsid left join enumdicitem e on g.goodunitid = e.enumitemname and e.enumdiccode = 'goodsunit' where 1=1 ` if req.GoodsID > 0 { sql += fmt.Sprintf(" and t.GoodsID = %d", req.GoodsID) } if req.MarketID > 0 { sql += fmt.Sprintf(" and t.MarketID = %d", req.MarketID) } if req.PresaleMode > 0 { sql += fmt.Sprintf(" and t.PresaleMode = %d", req.PresaleMode) } if len(req.GoodsIDs) > 0 { // s = s.And("GoodsID in (?)", req.GoodsIDs) sql += fmt.Sprintf(" and t.GoodsID in (%s)", req.GoodsIDs) } if len(req.GoodsCode) > 0 { sql += fmt.Sprintf(" and g.GoodsCode = '%s'", req.GoodsCode) } if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryPresaleGoodsEx failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryPresaleGoodsEx successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) } // QueryCPTradeMyBidReq 我的出价信息查询请求参数 type QueryCPTradeMyBidReq struct { AccountID int `form:"accountid" binding:"required"` GoodsID int `form:"goodsid"` MarketID int `form:"marketid"` } // QueryCPTradeMyBidRsp 我的出价信息查询 type QueryCPTradeMyBidRsp struct { Orderid int64 `json:"orderid" xorm:"'ORDERID'" binding:"required"` // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx) Marketid int64 `json:"marketid" xorm:"'MARKETID'" binding:"required"` // 市场ID Goodsid int64 `json:"goodsid" xorm:"'GOODSID'" binding:"required"` // 商品ID Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 账户ID[报价币种] Orderprice float64 `json:"orderprice" xorm:"'ORDERPRICE'"` // 委托价格 Orderqty int64 `json:"orderqty" xorm:"'ORDERQTY'" binding:"required"` // 委托数量 Ordertime time.Time `json:"ordertime" xorm:"'ORDERTIME'" binding:"required"` // 委托时间 Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'" binding:"required"` // 成交价格 Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'" binding:"required"` // 成交数量 Goodunit string `json:"goodunit" xorm:"'GOODUNIT'"` // 报价单位 OrderTotalPrice float64 `json:"ordertotalprice" xorm:"'ORDERTOTALPRICE'"` // 货款金额（委托总价格=委托价格*委托数量*合约单位） OrderTotalWeight int64 `json:"ordertotalweight" xorm:"'ORDERTOTALWEIGHT'"` // 竞拍总重量（委托总重量=委托数量*合约单位） TotalTotalPrice float64 `json:"totaltotalprice" xorm:"'TOTALTOTALPRICE'"` // 成交货款金额（成交总价格=成交价格*成交数量*合约单位） } // QueryCPTradeMyBidInfos 查询产能预售我的出价信息 // @Summary 查询产能预售我的出价信息 // @Produce json // @Security ApiKeyAuth // @Param accountid query int true "资金账户" // @Param marketid query int false "预售市场ID" // @Param goodsid query int false "预售商品ID" // @Success 200 {object} QueryCPTradeMyBidRsp // @Failure 500 {object} app.Response // @Router /CPTrade/QueryCPTradeMyBidInfos [get] // @Tags 产能预售 func QueryCPTradeMyBidInfos(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QueryCPTradeMyBidReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryCPTradeMyBidInfos failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 engine := db.GetEngine() datas := make([]QueryCPTradeMyBidRsp, 0) // 我的出价 -> 限价买建仓委托单 sql := fmt.Sprintf(`select t.OrderID, t.MarketID, t.GoodsID, t.AccountID, t.OrderPrice, t.OrderQty, t.OrderTime, td.TradePrice, td.TradeQty, e.enumdicname GoodUnit, (t.orderprice * t.orderqty * g.agreeunit) OrderTotalPrice, (t.orderqty * g.agreeunit) OrderTotalWeight, (td.tradeprice * td.tradeqty * g.agreeunit) TotalTotalPrice from Trade_OrderDetail t left join Trade_TradeDetail td on t.orderid = td.OrderID left join goods g on t.goodsid = g.goodsid left join enumdicitem e on g.goodunitid = e.enumitemname and e.enumdiccode = 'goodsunit' where t.BuyOrSell = 0 and t.BuildType = 1 and t.PriceMode = 2 and t.AccountID = %d`, req.AccountID) if req.GoodsID > 0 { sql += fmt.Sprintf(" and t.GoodsID = %d", req.GoodsID) } if req.MarketID > 0 { sql += fmt.Sprintf(" and t.MarketID = %d", req.MarketID) } else { // 如果没有传市场ID，则肯定查询预售一口价挂牌（40）和预售大宗竞拍（41）两个市场的数据 // FIXME: 目前暂时直接写死市场ID sql += fmt.Sprintf(" and t.MarketID in (%s)", "40201,41201") } if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryCPTradeMyBidInfos failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryCPTradeMyBidInfos successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) } // QueryMyCPTradeGoodsReq 查询我的预售信息请求参数 type QueryMyCPTradeGoodsReq struct { AccountID int `form:"accountid" binding:"required"` } // QueryMyCPTradeGoodsRsp 我的预售信息 type QueryMyCPTradeGoodsRsp struct { Goodsid int64 `json:"goodsid" xorm:"'GOODSID'" binding:"required"` // 商品ID(自增ID SEQ_GOODS) Goodscode string `json:"goodscode" xorm:"'GOODSCODE'" binding:"required"` // 商品代码(预售) Goodsname string `json:"goodsname" xorm:"'GOODSNAME'" binding:"required"` // 商品名称(预售) Marketid int64 `json:"marketid" xorm:"'MARKETID'" binding:"required"` // 所属市场ID Currencyid int64 `json:"currencyid" xorm:"'CURRENCYID'"` // 报价货币ID Goodunitid int64 `json:"goodunitid" xorm:"'GOODUNITID'"` // 报价单位ID Agreeunit float64 `json:"agreeunit" xorm:"'AGREEUNIT'"` // 合约单位 Decimalplace int64 `json:"decimalplace" xorm:"'DECIMALPLACE'"` // 报价小数位 Marketname string `json:"marketname" xorm:"'MARKETNAME'"` // 预售市场名称 Goodunit string `json:"goodunit" xorm:"'GOODUNIT'"` // 报价单位 Applyid int64 `json:"applyid" xorm:"'APPLYID'"` // 关联申请ID Userid int64 `json:"userid" xorm:"'USERID'"` // 卖方用户ID Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 卖方账户ID Relatedgoodsid int64 `json:"relatedgoodsid" xorm:"'RELATEDGOODSID'"` // 关联交易合约ID Presaleqty int64 `json:"presaleqty" xorm:"'PRESALEQTY'"` // 预售数量 Starttime time.Time `json:"starttime" xorm:"'STARTTIME'"` // 预售开始时间 Endtime time.Time `json:"endtime" xorm:"'ENDTIME'"` // 预售结束时间 Attachmenturl string `json:"attachmenturl" xorm:"'ATTACHMENTURL'"` // 附件地址 Presalemode int64 `json:"presalemode" xorm:"'PRESALEMODE'"` // 预售模式 - 1:一口价 2:大宗式竞拍 Refprice float64 `json:"refprice" xorm:"'REFPRICE'"` // 参考价格[一口价] Startprice float64 `json:"startprice" xorm:"'STARTPRICE'"` // 起拍价[大宗式竞拍] Floorprice float64 `json:"floorprice" xorm:"'FLOORPRICE'"` // 底价[大宗式竞拍] Createtime time.Time `json:"createtime" xorm:"'CREATETIME'"` // 创建时间 Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd) Relatedmarketid int64 `json:"relatedmarketid" xorm:"'RELATEDMARKETID'"` // 关联交易合约市场ID Presaledqty int64 `json:"presaledqty" xorm:"'PRESALEDQTY'"` // 已预售量(预售结束时更新) Sellstatus int64 `json:"sellstatus" xorm:"'SELLSTATUS'"` // 卖方处理状态 - 1:卖方头寸未处理 2:卖方头寸已处理 Presaledamount float64 `json:"presaledamount" xorm:"'PRESALEDAMOUNT'"` // 已预售总金额(预售结束时更新) Goodsdetail string `json:"goodsdetail" xorm:"'GOODSDETAIL'"` // 详情[大宗] Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价[大宗] Relatedgoodscode string `json:"relatedgoodscode" xorm:"'RELATEDGOODSCODE'" binding:"required"` // 商品代码(订单) Relatedgoodsname string `json:"relatedgoodsname" xorm:"'RELATEDGOODSNAME'" binding:"required"` // 商品名称(订单) } // QueryMyCPTradeGoods 查询我的预售信息 // @Summary 查询我的预售信息 // @Produce json // @Security ApiKeyAuth // @Param accountid query int true "资金账户" // @Success 200 {object} QueryMyCPTradeGoodsRsp // @Failure 500 {object} app.Response // @Router /CPTrade/QueryMyCPTradeGoods [get] // @Tags 产能预售 func QueryMyCPTradeGoods(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QueryMyCPTradeGoodsReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryMyCPTradeGoods failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 engine := db.GetEngine() datas := make([]QueryMyCPTradeGoodsRsp, 0) sql := fmt.Sprintf(`select t.Goodsid, t.Goodscode, t.Goodsname, t.Marketid, t.Currencyid, t.Goodunitid, t.Agreeunit, t.Decimalplace, m.Marketname, e.enumdicname GoodUnit, c.Applyid, c.Userid, c.Accountid, c.Relatedgoodsid, c.Presaleqty, c.Starttime, c.Endtime, c.Attachmenturl, c.Presalemode, c.Refprice, c.Startprice, c.Floorprice, c.Createtime, c.Tradedate, c.Relatedmarketid, c.Presaledqty, c.Sellstatus, c.Presaledamount, c.Goodsdetail, c.Tradeprice, g1.Goodscode RelatedGoodsCode, g1.GoodsName RelatedGoodsName from goods t left join market m on t.marketid = m.marketid left join enumdicitem e on t.goodunitid = e.enumitemname and e.enumdiccode = 'goodsunit' left join CPTRADE_PRESALEGOODSEX c on t.goodsid = c.goodsid left join goods g1 on c.Relatedgoodsid = g1.goodsid where m.trademode in (40,41) and c.Accountid = %d`, req.AccountID) if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryMyCPTradeGoods failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryMyCPTradeGoods successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) } // QueryCPTradeOrderDetailReq 查询产能预售委托单信息请求参数 type QueryCPTradeOrderDetailReq struct { GoodsID int `form:"goodsid"` GoodsIDs string `form:"goodsids"` MarketID int `form:"marketid"` } // QueryCPTradeOrderDetailRsq 产能预售委托单信息 type QueryCPTradeOrderDetailRsq struct { Strorderid string `json:"strorderid" xorm:"'STRORDERID'" binding:"required"` // 委托单号 Tradedate string `json:"tradedate" xorm:"'TRADEDATE'" binding:"required"` // 交易日(yyyyMMdd) Buildtype int64 `json:"buildtype" xorm:"'BUILDTYPE'" binding:"required"` // 委托单据类型 - 1:建仓 2:平仓 3:先平后建 Preorderid int64 `json:"preorderid" xorm:"'PREORDERID'"` // 关联预埋单号(止盈止损单时填写) Cancelorderid int64 `json:"cancelorderid" xorm:"'CANCELORDERID'"` // 撤单单号(撤单时填写) Relatedid int64 `json:"relatedid" xorm:"'RELATEDID'"` // 关联单号(交割单) Marketid int64 `json:"marketid" xorm:"'MARKETID'" binding:"required"` // 市场ID Goodsid int64 `json:"goodsid" xorm:"'GOODSID'" binding:"required"` // 商品ID Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 账户ID[报价币种] Memberuserid int64 `json:"memberuserid" xorm:"'MEMBERUSERID'" binding:"required"` // 所属会员UserID Buyorsell int64 `json:"buyorsell" xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖 Pricemode int64 `json:"pricemode" xorm:"'PRICEMODE'" binding:"required"` // 取价方式 - 1:市价 2: 限价 Orderprice float64 `json:"orderprice" xorm:"'ORDERPRICE'"` // 委托价格 Marketmaxsub float64 `json:"marketmaxsub" xorm:"'MARKETMAXSUB'"` // 市价最大偏移范围 Orderqty int64 `json:"orderqty" xorm:"'ORDERQTY'" binding:"required"` // 委托数量 Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量 Cancelqty int64 `json:"cancelqty" xorm:"'CANCELQTY'"` // 撤单数量 Openqty int64 `json:"openqty" xorm:"'OPENQTY'"` // 开仓数量(先建后平操作,需要记录) Closeqty int64 `json:"closeqty" xorm:"'CLOSEQTY'"` // 平仓数量(先建后平操作 需要记录) Opentradeqty int64 `json:"opentradeqty" xorm:"'OPENTRADEQTY'"` // 开仓成交数量(先建后平操作,需要记录) Closetradeqty int64 `json:"closetradeqty" xorm:"'CLOSETRADEQTY'"` // 平仓成交数量(先建后平操作,需要记录) Freezemargin float64 `json:"freezemargin" xorm:"'FREEZEMARGIN'"` // 冻结保证金(冻结交易金额) Unfreezemargin float64 `json:"unfreezemargin" xorm:"'UNFREEZEMARGIN'"` // 解冻保证金 Freezecharge float64 `json:"freezecharge" xorm:"'FREEZECHARGE'"` // 冻结手续费 Unfreezecharge float64 `json:"unfreezecharge" xorm:"'UNFREEZECHARGE'"` // 解冻手续费 Openfreezecharge float64 `json:"openfreezecharge" xorm:"'OPENFREEZECHARGE'"` // 开仓冻结手续费(先建后平操作,需要记录) Closefreezecharge float64 `json:"closefreezecharge" xorm:"'CLOSEFREEZECHARGE'"` // 平仓冻结手续费(先建后平操作,需要记录) Openunfreezecharge float64 `json:"openunfreezecharge" xorm:"'OPENUNFREEZECHARGE'"` // 开仓解冻手续费(先建后平操作,需要记录) Closeunfreezecharge float64 `json:"closeunfreezecharge" xorm:"'CLOSEUNFREEZECHARGE'"` // 平仓解冻手续费(先建后平操作,需要记录) Validtype int64 `json:"validtype" xorm:"'VALIDTYPE'" binding:"required"` // 有效类型 - 1当日有效 2本周有效 3指定日期有效 4一直有效 5指定时间有效 Validtime time.Time `json:"validtime" xorm:"'VALIDTIME'"` // 有效期限 Volumetype int64 `json:"volumetype" xorm:"'VOLUMETYPE'"` // 当时间有效类型为 “立即执行否则取消 IOC” 时，需要此项 - 0:任意量 1:最小量（暂时不支持） 2:全部量 Operatetype int64 `json:"operatetype" xorm:"'OPERATETYPE'" binding:"required"` // 操作类型 - 1:正常下单 2:斩仓 3:转单 4:结算撤单 5:系统卖出(适用于先平后建的卖出) 6:行情源报价 7:（结算)到期强平 8:（结算)协议转让 9:系统对冲单 10:（结算)到期无效 11:交割协议转让 12:交割协议平仓 13:交割成交(所有权) 14:管理端强行平仓 15:管理端协议转让 Ordertime time.Time `json:"ordertime" xorm:"'ORDERTIME'" binding:"required"` // 委托时间 Ordersrc int64 `json:"ordersrc" xorm:"'ORDERSRC'"` // 委托来源 - 1:客户端 2:管理端 3:风控服务 4:交割服务 5:交易服务 6:交易日结 7:商品强平 8:管理端商品退市强平 9:交易接口 10:交割服务商被动(受托竞价) 11:预埋触发 Orderstatus int64 `json:"orderstatus" xorm:"'ORDERSTATUS'"` // 委托状态 - 1： 委托请求 2：待冻结 3：委托成功 4： 委托失败 5：配对成功 6： 已撤销 7：部分成交 8：已成交 9：部成部撤 10：成交失败 11：已拒绝 12:经过摘牌(先摘后挂专用-先摘后挂已摘过) 13:冻结成功(通道交易专用) 14:通道已撤 15:通道部成部撤 16:成交失败违约(荷兰式竞拍专用) Operatorid int64 `json:"operatorid" xorm:"'OPERATORID'"` // 登录账号(LoginID) Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间 Clientordertime time.Time `json:"clientordertime" xorm:"'CLIENTORDERTIME'"` // 客户端委托时间 Clientticket string `json:"clientticket" xorm:"'CLIENTTICKET'"` // 客户端流水号 UUID string `json:"uuid" xorm:"'UUID'"` // 发起端唯一id Clienttype int64 `json:"clienttype" xorm:"'CLIENTTYPE'"` // 客户端类型 - 0:保留为未填终端类型 1:PC管理端 2:PC交易端 3:手机客户端_安卓 4:网页客户端 5:微信客户端 6:手机客户端_苹果 7:网上开户客户端 8:无效终端编号 9:报价终端(中江) Retcode int64 `json:"retcode" xorm:"'RETCODE'"` // 错误代码 Tradeproperty int64 `json:"tradeproperty" xorm:"'TRADEPROPERTY'"` // 交易属性 Listingselecttype int64 `json:"listingselecttype" xorm:"'LISTINGSELECTTYPE'"` // 挂牌点选类型 - 1:挂牌 2:摘牌 3:先摘后挂 Delistingtype int64 `json:"delistingtype" xorm:"'DELISTINGTYPE'"` // 摘牌类型 - 1:价格最优 2:点选成交 Marginalgorithm int64 `json:"marginalgorithm" xorm:"'MARGINALGORITHM'"` // 保证金收取方式 1：比率 2：固定 Marginvalue float64 `json:"marginvalue" xorm:"'MARGINVALUE'"` // 即市保证金设置值 Openfeealgorithm int64 `json:"openfeealgorithm" xorm:"'OPENFEEALGORITHM'"` // 建仓手续费收取方式 1：比率 2：固定 Openmemberchargevalue float64 `json:"openmemberchargevalue" xorm:"'OPENMEMBERCHARGEVALUE'"` // 建仓会员手续费设置值 Openexchagechargevalue float64 `json:"openexchagechargevalue" xorm:"'OPENEXCHAGECHARGEVALUE'"` // 建仓交易所手续费设置值 Closefeealgorithm int64 `json:"closefeealgorithm" xorm:"'CLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1：比率 2：固定 Closememberchargevalue float64 `json:"closememberchargevalue" xorm:"'CLOSEMEMBERCHARGEVALUE'"` // 平仓会员手续费设置值 Closeexchagechargevalue float64 `json:"closeexchagechargevalue" xorm:"'CLOSEEXCHAGECHARGEVALUE'"` // 平仓交易所手续费设置值 Optiontype int64 `json:"optiontype" xorm:"'OPTIONTYPE'"` // 期权类型 - 1:认购(看涨) 2:认沽(看跌) Premium float64 `json:"premium" xorm:"'PREMIUM'"` // 权利金 Ispreexercise int64 `json:"ispreexercise" xorm:"'ISPREEXERCISE'"` // 是否预申报- 0:否 1:是 Preexerciseprice float64 `json:"preexerciseprice" xorm:"'PREEXERCISEPRICE'"` // 预申报价格 Isconfirmexercise int64 `json:"isconfirmexercise" xorm:"'ISCONFIRMEXERCISE'"` // 是否确认行权- 0:否 1:是 Quoteid int64 `json:"quoteid" xorm:"'QUOTEID'"` // 报价单ID Gcaccountid int64 `json:"gcaccountid" xorm:"'GCACCOUNTID'"` // 账户ID[合约币种] Sessionid int64 `json:"sessionid" xorm:"'SESSIONID'"` // 会话ID } // QueryCPTradeOrderDetail 查询产能预售委托单信息 // @Summary 查询产能预售委托单信息 // @Produce json // @Security ApiKeyAuth // @Param goodsid query int false "预售商品ID" // @Param marketid query int false "预售市场ID" // @Param goodsids query string false "预售商品ID列表 - 格式：1,2,3" // @Success 200 {object} QueryCPTradeOrderDetailRsq // @Failure 500 {object} app.Response // @Router /CPTrade/QueryCPTradeOrderDetail [get] // @Tags 产能预售 func QueryCPTradeOrderDetail(c *gin.Context) { appG := app.Gin{C: c} // FIXME: 由于数据中包括[]int类型，会造成校验报错，故暂时不使用 // 获取请求参数 var req QueryCPTradeOrderDetailReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryCPTradeOrderDetail failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 engine := db.GetEngine() datas := make([]QueryCPTradeOrderDetailRsq, 0) sql := `select to_char(t.orderid) strOrderID, t.* from Trade_OrderDetail t where t.BuyOrSell = 1 and t.BuildType = 2 and t.MarketID in (40201,41201)` if req.GoodsID > 0 { sql += fmt.Sprintf(" and t.GoodsID = %d", req.GoodsID) } if req.MarketID > 0 { sql += fmt.Sprintf(" and t.MarketID = %d", req.MarketID) } if len(req.GoodsIDs) > 0 { // s = s.And("GoodsID in (?)", req.GoodsIDs) sql += fmt.Sprintf(" and t.GoodsID in (%s)", req.GoodsIDs) } if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryCPTradeOrderDetail failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryCPTradeOrderDetail successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) }