MTP20_IF/controllers/order/order.go

package order

import (
	"encoding/json"
	"fmt"
	"mtp2_if/db"
	"mtp2_if/global/app"
	"mtp2_if/global/e"
	"mtp2_if/logger"
	"mtp2_if/models"
	"net/http"
	"time"

	"github.com/gin-gonic/gin"
)

// QueryTradePositionReq 持仓汇总查询请求参数（合约市场）
type QueryTradePositionReq struct {
	AccountID string `form:"accountID" binding:"required"`
	TradeMode string `form:"tradeMode"`
}

// QueryTradePositionRsp 持仓汇总查询返回模型（合约市场）
type QueryTradePositionRsp struct {
	AccountID       uint64  `json:"accountid"  xorm:"'ACCOUNTID'"`             // 资金账户
	BuyOrSell       int64   `json:"buyorsell"  xorm:"'BUYORSELL'" `            // 方向 - 0:买 1:卖
	GoodsCode       string  `json:"goodscode" xorm:"GOODSCODE"`                // 商品代码
	GoodsName       string  `json:"goodsname" xorm:"GOODSNAME"`                // 商品名称
	AgreeUnit       float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`             // 合约单位
	CurrencyID      int64   `json:"currencyid"  xorm:"'CURRENCYID'"`           // 报价货币ID
	GoodUnitID      int64   `json:"goodunitid"  xorm:"'GOODUNITID'"`           // 报价单位ID
	Goodunit        string  `json:"goodunit" xorm:"'GOODUNIT'"`                // 报价单位
	DecimalPlace    int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`       // 报价小数位
	MarketID        int64   `json:"marketid"  xorm:"'MARKETID'"`               // 所属市场ID
	TradeMode       uint32  `json:"trademode"  xorm:"'TRADEMODE'"`             // 交易模式
	PositionQTY     uint64  `json:"positionqty"  xorm:"'POSITIONQTY'"`         // 期初持仓数量
	HolderAmount    float64 `json:"holderamount"  xorm:"'HOLDERAMOUNT'"`       // 期初持仓总金额[商品币种]
	CurPositionQTY  uint64  `json:"curpositionqty"  xorm:"'CURPOSITIONQTY'"`   // 当前持仓总数量
	CurHolderAmount float64 `json:"curholderamount"  xorm:"'CURHOLDERAMOUNT'"` // 当前持仓总金额[商品币种]
	FrozenQTY       uint64  `json:"frozenqty"  xorm:"'FROZENQTY'"`             // 持仓冻结数量
	OtherFrozenQTY  uint64  `json:"otherfrozenqty"  xorm:"'OTHERFROZENQTY'"`   // 持仓其他冻结数量(交割冻结)
	OpenReqQTY      uint64  `json:"openreqqty"  xorm:"'OPENREQQTY'"`           // 开仓申请数量(用于比较最大持仓数量)
	OpenTotalQTY    uint64  `json:"opentotalqty"  xorm:"'OPENTOTALQTY'"`       // 开仓总数量
	CloseTotalQTY   uint64  `json:"closetotalqty"  xorm:"'CLOSETOTALQTY'"`     // 平仓总数量
	TNQTY           uint64  `json:"tnqty"  xorm:"'TNQTY'"`                     // T+N冻结总量
	TNUsedQTY       uint64  `json:"tnusedqty"  xorm:"'TNUSEDQTY'"`             // T+N使用量(可以使用T+N的冻结数量)
	CurTDPosition   uint64  `json:"curtdposition"  xorm:"'CURTDPOSITION'"`     // 期末今日头寸
	FreTDPosition   uint64  `json:"fretdposition"  xorm:"'FRETDPOSITION'"`     // 冻结今日头寸
	EnableQTY       uint64  `json:"enableqty"  xorm:"'ENABLEQTY'"`             // 可用量
}

// QueryTradePosition 持仓汇总查询（合约市场）
// @Summary 持仓汇总查询（合约市场）
// @Produce json
// @Security ApiKeyAuth
// @Param accountID query string true "资金账户 - 格式：1,2,3"
// @Param tradeMode query string false "交易模式 - 格式：1,2,3"
// @Success 200 {object} QueryTradePositionRsp
// @Failure 500 {object} app.Response
// @Router /Order/QueryTradePosition [get]
// @Tags 通用单据
// 参考通用查询：SearchTradePositionDetail
func QueryTradePosition(c *gin.Context) {
	appG := app.Gin{C: c}

	// 获取请求参数
	var req QueryTradePositionReq
	if err := appG.C.ShouldBindQuery(&req); err != nil {
		logger.GetLogger().Errorf("QueryTradePosition failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
		return
	}

	// 查询数据
	type tradePosition struct {
		models.Tradeposition `xorm:"extends"`
		Goodscode            string  `json:"goodscode"  xorm:"'GOODSCODE'"`       // 商品代码(内部)
		Goodsname            string  `json:"goodsname"  xorm:"'GOODSNAME'"`       // 商品名称
		Currencyid           int64   `json:"currencyid"  xorm:"'CURRENCYID'"`     // 报价货币ID
		Goodunitid           int64   `json:"goodunitid"  xorm:"'GOODUNITID'"`     // 报价单位ID
		Goodunit             string  `json:"goodunit" xorm:"'GOODUNIT'"`          // 报价单位
		Agreeunit            float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`       // 合约单位
		Decimalplace         int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"` // 报价小数位
		Marketid             uint32  `json:"marketid"  xorm:"'MARKETID'"`         // 市场ID
		Trademode            uint32  `json:"trademode"  xorm:"'TRADEMODE'"`       // 交易模式
	}
	datas := make([]tradePosition, 0)
	engine := db.GetEngine()
	// ORACLE好像在JOIN里不支持别名功能（在XORM中）
	s := engine.Table("TRADEPOSITION").
		Join("LEFT", "GOODS", "TRADEPOSITION.GOODSID = GOODS.GOODSID").
		Join("LEFT", "MARKET", "GOODS.MARKETID = MARKET.MARKETID").
		Join("LEFT", "ENUMDICITEM", "GOODS.GOODUNITID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'goodsunit'").
		Select("TRADEPOSITION.*, GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.CURRENCYID, GOODS.GOODUNITID, ENUMDICITEM.ENUMDICNAME as GOODUNIT, GOODS.AGREEUNIT, GOODS.DECIMALPLACE, MARKET.MARKETID, MARKET.TRADEMODE").
		Where(fmt.Sprintf(`TRADEPOSITION.ACCOUNTID in (%s)`, req.AccountID))
	if len(req.TradeMode) > 0 {
		s = s.And(fmt.Sprintf(`MARKET.TRADEMODE in (%s)`, req.TradeMode))
	}
	if err := s.Find(&datas); err != nil {
		// 查询失败
		logger.GetLogger().Errorf("QueryTradePosition failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
		return
	}
	// 构建返回数据
	rst := make([]QueryTradePositionRsp, 0)
	for _, v := range datas {
		// 构建买方向持仓汇总
		if v.Buycurpositionqty > 0 {
			var tradePosition QueryTradePositionRsp
			// 反射数据
			// struct -> json
			if jsonBytes, err := json.Marshal(v); err == nil {
				// json -> struct
				json.Unmarshal(jsonBytes, &tradePosition)
				tradePosition.BuyOrSell = 0
				tradePosition.PositionQTY = v.Buypositionqty
				tradePosition.HolderAmount = v.Buyholderamount
				tradePosition.CurPositionQTY = v.Buycurpositionqty
				tradePosition.CurHolderAmount = v.Buycurholderamount
				tradePosition.FrozenQTY = v.Buyfrozenqty
				tradePosition.OtherFrozenQTY = v.Buyotherfrozenqty
				tradePosition.OpenReqQTY = v.Buyopenreqqty
				tradePosition.OpenTotalQTY = v.Buyopentotalqty
				tradePosition.CloseTotalQTY = v.Buyclosetotalqty
				tradePosition.TNQTY = v.Buytnqty
				tradePosition.TNUsedQTY = v.Buytnusedqty
				tradePosition.CurTDPosition = v.Buycurtdposition
				tradePosition.FreTDPosition = v.Buyfretdposition
				tradePosition.EnableQTY = v.Buycurpositionqty - v.Buyfrozenqty - v.Buyotherfrozenqty

				rst = append(rst, tradePosition)
			}
		}

		// 构建卖方向持仓汇总
		if v.Tradeproperty != 2 && v.Sellcurpositionqty > 0 {
			var tradePosition QueryTradePositionRsp
			// 反射数据
			// struct -> json
			if jsonBytes, err := json.Marshal(v); err == nil {
				// json -> struct
				json.Unmarshal(jsonBytes, &tradePosition)
				tradePosition.BuyOrSell = 1
				tradePosition.PositionQTY = v.Sellpositionqty
				tradePosition.HolderAmount = v.Sellholderamount
				tradePosition.CurPositionQTY = v.Sellcurpositionqty
				tradePosition.CurHolderAmount = v.Sellcurholderamount
				tradePosition.FrozenQTY = v.Sellfrozenqty
				tradePosition.OtherFrozenQTY = v.Sellotherfrozenqty
				tradePosition.OpenReqQTY = v.Sellopenreqqty
				tradePosition.OpenTotalQTY = v.Sellopentotalqty
				tradePosition.CloseTotalQTY = v.Sellclosetotalqty
				tradePosition.TNQTY = v.Selltnqty
				tradePosition.TNUsedQTY = v.Selltnusedqty
				tradePosition.CurTDPosition = v.Sellcurtdposition
				tradePosition.FreTDPosition = v.Sellfretdposition
				tradePosition.EnableQTY = v.Sellcurpositionqty - v.Sellfrozenqty - v.Sellotherfrozenqty

				rst = append(rst, tradePosition)
			}
		}
	}

	// 查询成功
	logger.GetLogger().Infof("QueryTradePosition successed: %v", rst)
	appG.Response(http.StatusOK, e.SUCCESS, rst)
}

// QueryTradeOrderDetailReq 委托单查询请求参数（合约市场）
type QueryTradeOrderDetailReq struct {
	AccountID   string `form:"accountID" binding:"required"`
	OrderStatus string `form:"orderStatus"`
	TradeMode   string `form:"tradeMode"`
	OrderID     int    `form:"orderID"`
}

// QueryTradeOrderDetailRsp 委托单查询返回模型（合约市场）
type QueryTradeOrderDetailRsp 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[报价币种]
	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'"`                      // 委托价格
	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"`     // 委托时间
	Orderstatus         int64     `json:"orderstatus"  xorm:"'ORDERSTATUS'"`                    // 委托状态 - 1： 委托请求 2：待冻结 3：委托成功 4： 委托失败 5：配对成功 6： 已撤销 7：部分成交 8：已成交 9：部成部撤 10：成交失败 11：已拒绝 12:经过摘牌(先摘后挂专用-先摘后挂已摘过) 13:冻结成功(通道交易专用) 14:通道已撤 15:通道部成部撤 16:成交失败违约(荷兰式竞拍专用)
	Listingselecttype   int64     `json:"listingselecttype"  xorm:"'LISTINGSELECTTYPE'"`        // 挂牌点选类型 - 1:挂牌 2:摘牌 3:先摘后挂
	Delistingtype       int64     `json:"delistingtype"  xorm:"'DELISTINGTYPE'"`                // 摘牌类型 - 1:价格最优 2:点选成交

	// 关联字段
	GoodsCode  string `json:"goodscode" xorm:"GOODSCODE"`      // 商品代码
	GoodsName  string `json:"goodsname" xorm:"GOODSNAME"`      // 商品名称
	Marketname string `json:"marketname"  xorm:"'MARKETNAME'"` // 市场名称
	TradeMode  uint32 `json:"trademode"  xorm:"'TRADEMODE'"`   // 交易模式

	// 计算字段
	Enableqty int64 `json:"enableqty" xorm:"ENABLEQTY"` // 可用数量, 委托数量 - 成交数量 - 撤单数量
}

// QueryTradeOrderDetail 委托单查询请求（合约市场）
// @Summary 委托单查询请求（合约市场）
// @Produce json
// @Security ApiKeyAuth
// @Param accountID query string true "资金账户 - 格式：1,2,3"
// @Param tradeMode query string false "交易模式 - 格式：1,2,3"
// @Param orderStatus query string false "委托状态 - 格式：1,2,3"
// @Param orderID query int false "委托单号"
// @Success 200 {object} QueryTradeOrderDetailRsp
// @Failure 500 {object} app.Response
// @Router /Order/QueryTradeOrderDetail [get]
// @Tags 通用单据
// 参考通用查询：SearchTradeOrderDetail
func QueryTradeOrderDetail(c *gin.Context) {
	appG := app.Gin{C: c}

	// 获取请求参数
	var req QueryTradeOrderDetailReq
	if err := appG.C.ShouldBindQuery(&req); err != nil {
		logger.GetLogger().Errorf("QueryTradeOrderDetail failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
		return
	}

	datas := make([]QueryTradeOrderDetailRsp, 0)
	engine := db.GetEngine()
	s := engine.Table("TRADE_ORDERDETAIL").
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_ORDERDETAIL.GOODSID").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TRADE_ORDERDETAIL.MARKETID").
		Select(`TRADE_ORDERDETAIL.*, TRADE_ORDERDETAIL.ORDERPRICE - TRADE_ORDERDETAIL.TRADEQTY - TRADE_ORDERDETAIL.CANCELQTY as ENABLEQTY, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, MARKET.MARKETNAME, MARKET.TRADEMODE`).
		Where(fmt.Sprintf(`TRADE_ORDERDETAIL.ORDERSRC != 10 and TRADE_ORDERDETAIL.ACCOUNTID in (%s)`, req.AccountID)).
		Desc("TRADE_ORDERDETAIL.ORDERTIME")
	if len(req.OrderStatus) > 0 {
		s = s.And(fmt.Sprintf(`TRADE_ORDERDETAIL.ORDERSTATUS in (%s)`, req.OrderStatus))
	}
	if len(req.TradeMode) > 0 {
		s = s.And(fmt.Sprintf(`TRADE_ORDERDETAIL.TRADEMODE in (%s)`, req.TradeMode))
	}
	if req.OrderID > 0 {
		s = s.And("TRADE_ORDERDETAIL.ORDERID = ?", req.OrderID)
	}
	if err := s.Find(&datas); err != nil {
		// 查询失败
		logger.GetLogger().Errorf("QueryTradeOrderDetail failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
		return
	}

	// 查询成功
	logger.GetLogger().Infof("QueryTradeOrderDetail successed: %v", datas)
	appG.Response(http.StatusOK, e.SUCCESS, datas)
}