|
|
@@ -528,16 +528,16 @@ func QueryCPTradeMyBidInfos(c *gin.Context) {
|
|
|
appG.Response(http.StatusOK, e.SUCCESS, datas)
|
|
|
}
|
|
|
|
|
|
-// QueryMyCPTradeGoodsReq 查询我的产能预售信息请求参数
|
|
|
+// QueryMyCPTradeGoodsReq 查询我的预售信息请求参数
|
|
|
type QueryMyCPTradeGoodsReq struct {
|
|
|
AccountID int `form:"accountid" binding:"required"`
|
|
|
}
|
|
|
|
|
|
-// QueryMyCPTradeGoodsRsp 我的产能预售信息
|
|
|
+// 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"` // 商品名称
|
|
|
+ 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
|
|
|
@@ -568,6 +568,9 @@ type QueryMyCPTradeGoodsRsp struct {
|
|
|
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 查询我的预售信息
|
|
|
@@ -623,11 +626,14 @@ func QueryMyCPTradeGoods(c *gin.Context) {
|
|
|
c.Sellstatus,
|
|
|
c.Presaledamount,
|
|
|
c.Goodsdetail,
|
|
|
- c.Tradeprice
|
|
|
+ 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 {
|
|
|
// 查询失败
|
|
|
@@ -640,3 +646,128 @@ func QueryMyCPTradeGoods(c *gin.Context) {
|
|
|
logger.GetLogger().Infof("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 {
|
|
|
+ Orderid int64 `json:"orderid" xorm:"'ORDERID'" binding:"required"` // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
|
|
|
+ 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
|
|
|
+ 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().Infof("QueryCPTradeOrderDetail successed: %v", datas)
|
|
|
+ appG.Response(http.StatusOK, e.SUCCESS, datas)
|
|
|
+}
|
Simon Zhou