package erms2 import ( "fmt" "mtp2_if/db" "mtp2_if/global/app" "mtp2_if/global/e" "mtp2_if/logger" "net/http" "time" "github.com/gin-gonic/gin" ) // QueryInnerTradeDetailReq 查询内部成交单信息请求参数 type QueryInnerTradeDetailReq struct { AccountID int `form:"accountid" binding:"required"` } // QueryInnerTradeDetailRsp 内部成交单信息 type QueryInnerTradeDetailRsp struct { Tradeid string `json:"tradeid" xorm:"'TRADEID'" binding:"required"` // 成交单号(108+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx) Buyorsell int64 `json:"buyorsell" xorm:"'BUYORSELL'" binding:"required"` // 方向 - 0:买 1:卖 Orderid string `json:"orderid" xorm:"'ORDERID'"` // 委托单号 Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 账号ID Goodsid int64 `json:"goodsid" xorm:"'GOODSID'"` // 商品ID Marketid int64 `json:"marketid" xorm:"'MARKETID'"` // 市场ID Tradetime time.Time `json:"tradetime" xorm:"'TRADETIME'"` // 成交时间 Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价格 Tradeqty int64 `json:"tradeqty" xorm:"'TRADEQTY'"` // 成交数量 Channelbuildtype int64 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 委托单据类型 0:无 1:建仓 2:平仓 Closetype int64 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨 Relatedouttradeid string `json:"relatedouttradeid" xorm:"'RELATEDOUTTRADEID'"` // 关联外部成交单ID Asapplyid int64 `json:"asapplyid" xorm:"'ASAPPLYID'" binding:"required"` // 策略申请ID Detailtype int64 `json:"detailtype" xorm:"'DETAILTYPE'"` // 明细类型 - 1:套利对冲 2:期货换月 3:期货仓位调整 Spotcontractid int64 `json:"spotcontractid" xorm:"'SPOTCONTRACTID'"` // 现货合同ID [1:套利对冲 为合同ID，2:期货换月\3:期货仓位调整时为0] Asno string `json:"asno" xorm:"'ASNO'"` // 策略编号 Asname string `json:"asname" xorm:"'ASNAME'"` // 策略名称 Spotcontractno string `json:"spotcontractno" xorm:"'SPOTCONTRACTNO'"` // 现货合同编号 Remark string `json:"remark" xorm:"'REMARK'"` // 备注 Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间 Goodscode string `json:"goodscode" xorm:"'GOODSCODE'" binding:"required"` // 商品代码（合约） Goodsname string `json:"goodsname" xorm:"'GOODSNAME'" binding:"required"` // 商品名称（合约） Agreeunit float64 `json:"agreeunit" xorm:"'AGREEUNIT'"` // 合约单位 Goodunit string `json:"goodunit" xorm:"'GOODUNIT'"` // 报价单位 Exexchangecode string `json:"exexchangecode" xorm:"'EXEXCHANGECODE'"` // 外部交易所代码 Exexchangename string `json:"exexchangename" xorm:"'EXEXCHANGENAME'"` // 外部交易所名称 Outgoodscode string `json:"outgoodscode" xorm:"'OUTGOODSCODE'"` // 商品代码（外部） Decimalplace int64 `json:"decimalplace" xorm:"'DECIMALPLACE'"` // 报价小数位 Goodsgroupid int64 `json:"goodsgroupid" xorm:"'GOODSGROUPID'" binding:"required"` // 商品组ID（品种ID） Goodsgroupname string `json:"goodsgroupname" xorm:"'GOODSGROUPNAME'" binding:"required"` // 商品组名称（品种） } // QueryInnerTradeDetail 查询内部成交单信息 // @Summary 查询内部成交单信息 // @Produce json // @Security ApiKeyAuth // @Param accountid query int true "资金账户" // @Success 200 {object} QueryInnerTradeDetailRsp // @Failure 500 {object} app.Response // @Router /Erms2/QueryInnerTradeDetail [get] // @Tags 风险管理 func QueryInnerTradeDetail(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QueryInnerTradeDetailReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryInnerTradeDetail failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 engine := db.GetEngine() datas := make([]QueryInnerTradeDetailRsp, 0) sql := fmt.Sprintf(`select to_char(t.Tradeid) Tradeid, t.Buyorsell, to_char(t.Orderid) Orderid, t.Accountid, t.Goodsid, t.Marketid, t.Tradetime, t.Tradeprice, t.Tradeqty, t.Channelbuildtype, t.Closetype, to_char(t.Relatedouttradeid) Relatedouttradeid, ast.Asapplyid, ast.Detailtype, ast.Spotcontractid, ast.Remark, ast.Updatetime, asd.Asno, asd.ASName, sc.contractno Spotcontractno, g.Goodscode, g.Goodsname, g.Agreeunit, g.Outgoodscode, g.Decimalplace, e.enumdicname GoodUnit, ee.Exexchangecode, ee.Exexchangename, gg.Goodsgroupid, gg.Goodsgroupname from Hedge_InnerTradeDetail t left join ERMS2_ASTradeDetails ast on t.relatedouttradeid = OutTradeID left join ERMS2_ArbitrageStrategy asd on ast.asapplyid = asd.asapplyid left join ERMS3_SpotContract sc on ast.spotcontractid = sc.spotcontractid left join goods g on t.goodsid = g.goodsid left join enumdicitem e on g.goodunitid = e.enumitemname and e.enumdiccode = 'goodsunit' left join goodsgroup gg on g.goodsgroupid = gg.goodsgroupid left join ExternalExchange ee on gg.exexchangeid = ee.autoid where t.Accountid = %d`, req.AccountID) if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryInnerTradeDetail failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryInnerTradeDetail successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) } // QueryArbitrageStrategyReq 查询期现套利策略表信息请求参数 type QueryArbitrageStrategyReq struct { // AccountID int `form:"accountid" binding:"required"` UserID int `form:"userid" binding:"required"` GoodsGroupID int `form:"goodsgroupid"` } // QueryArbitrageStrategyRsp 期现套利策略表信息 type QueryArbitrageStrategyRsp struct { Asapplyid string `json:"asapplyid" xorm:"'ASAPPLYID'" binding:"required"` // 策略申请ID(702+Unix秒时间戳(10位)+xxxxxx) Asno string `json:"asno" xorm:"'ASNO'"` // 策略编号 Biztype int64 `json:"biztype" xorm:"'BIZTYPE'"` // 业务类型 - 1:正向套利 -1:反向套利 Userid int64 `json:"userid" xorm:"'USERID'"` // 所属机构 Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 现货品种ID Goodsgroupid int64 `json:"goodsgroupid" xorm:"'GOODSGROUPID'"` // 期货品种ID Spotquota float64 `json:"spotquota" xorm:"'SPOTQUOTA'"` // 现货额度 Futurequote float64 `json:"futurequote" xorm:"'FUTUREQUOTE'"` // 期货额度 Applybasis float64 `json:"applybasis" xorm:"'APPLYBASIS'"` // 申请基差 Strategystatus int64 `json:"strategystatus" xorm:"'STRATEGYSTATUS'"` // 策略状态 - 0:未结束 1:已结束 Remark string `json:"remark" xorm:"'REMARK'"` // 备注 Marketid int64 `json:"marketid" xorm:"'MARKETID'"` // 市场ID Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd) Closetradedate string `json:"closetradedate" xorm:"'CLOSETRADEDATE'"` // 完结交易日(yyyyMMdd) Usedquota float64 `json:"usedquota" xorm:"'USEDQUOTA'"` // 已占用资金 Futureqty float64 `json:"futureqty" xorm:"'FUTUREQTY'"` // 期货持仓数量 Futureavgprice float64 `json:"futureavgprice" xorm:"'FUTUREAVGPRICE'"` // 期货建仓均价 Futurepl float64 `json:"futurepl" xorm:"'FUTUREPL'"` // 期货总盈亏[结算更新] Pricedspotqty float64 `json:"pricedspotqty" xorm:"'PRICEDSPOTQTY'"` // 已定价现货数量 Pricedspotqtynotax float64 `json:"pricedspotqtynotax" xorm:"'PRICEDSPOTQTYNOTAX'"` // 已定价现货不含税数量 Spotavgprice float64 `json:"spotavgprice" xorm:"'SPOTAVGPRICE'"` // 现货均价 Spotpl float64 `json:"spotpl" xorm:"'SPOTPL'"` // 现货总盈亏[结算更新] Netexposure float64 `json:"netexposure" xorm:"'NETEXPOSURE'"` // 单笔业务头寸净敞口 = 期货持仓数量 + 已定价现货不含税数量 Netexposurerate float64 `json:"netexposurerate" xorm:"'NETEXPOSURERATE'"` // 净敞口比例 - 0:未结束 = (NetExposure/PriceSpotQtyNoTax) ； 已结束为0 Totalpl float64 `json:"totalpl" xorm:"'TOTALPL'"` // 业务合计损益 = FuturePL + SpotPL [结算更新] Openbasis float64 `json:"openbasis" xorm:"'OPENBASIS'"` // 建仓基差 Curbasis float64 `json:"curbasis" xorm:"'CURBASIS'"` // 当前基差[结算更新] Basischangepl float64 `json:"basischangepl" xorm:"'BASISCHANGEPL'"` // 基差变动损益[结算更新] Netexposurepl float64 `json:"netexposurepl" xorm:"'NETEXPOSUREPL'"` // 净敞口损益 = TotalPL - BasisChangePL[结算更新] Spotusedquota float64 `json:"spotusedquota" xorm:"'SPOTUSEDQUOTA'"` // 现货占用资金 Futureopenqty float64 `json:"futureopenqty" xorm:"'FUTUREOPENQTY'"` // 期货开仓数量 Futureopenamount float64 `json:"futureopenamount" xorm:"'FUTUREOPENAMOUNT'"` // 期货开仓金额 Futurecloseqty float64 `json:"futurecloseqty" xorm:"'FUTURECLOSEQTY'"` // 期货平仓数量 Futurecloseamount float64 `json:"futurecloseamount" xorm:"'FUTURECLOSEAMOUNT'"` // 期货平仓金额 Spotbuyamount float64 `json:"spotbuyamount" xorm:"'SPOTBUYAMOUNT'"` // 现货采购金额 Spotbuyqty float64 `json:"spotbuyqty" xorm:"'SPOTBUYQTY'"` // 现货采购数量 Spotsellamount float64 `json:"spotsellamount" xorm:"'SPOTSELLAMOUNT'"` // 现货销售金额 Spotsellqty float64 `json:"spotsellqty" xorm:"'SPOTSELLQTY'"` // 现货销售数量 Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间 Asname string `json:"asname" xorm:"'ASNAME'"` // 策略名称 } // QueryArbitrageStrategy 查询期现套利策略表信息（指定资金账户、未结束的） // @Summary 查询期现套利策略表信息（指定资金账户、未结束的） // @Produce json // @Security ApiKeyAuth // @Param userid query int true "账户ID" // @Param goodsgroupid query string false "商品组ID（品种ID）" // @Success 200 {object} QueryArbitrageStrategyRsp // @Failure 500 {object} app.Response // @Router /Erms2/QueryArbitrageStrategy [get] // @Tags 风险管理 func QueryArbitrageStrategy(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QueryArbitrageStrategyReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QueryArbitrageStrategy failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 engine := db.GetEngine() datas := make([]QueryArbitrageStrategyRsp, 0) sql := fmt.Sprintf(`select to_char(t.ASApplyID) ASApplyID, t.ASNo, t.ASName, t.BizType, t.UserID, t.DeliveryGoodsID, t.GoodsGroupID, t.SpotQuota, t.FutureQuote, t.ApplyBasis, t.StrategyStatus, t.Remark, t.MarketID, t.TradeDate, t.CloseTradeDate, t.UsedQuota, t.FutureQty, t.FutureAvgPrice, t.FuturePL, t.PricedSpotQty, t.PricedSpotQtyNoTax, t.SpotAvgPrice, t.SpotPL, t.NetExposure, t.NetExposureRate, t.TotalPL, t.OpenBasis, t.CurBasis, t.BasisChangePL, t.NetExposurePL, t.SpotUsedQuota, t.FutureOpenQty, t.FutureOpenAmount, t.FutureCloseQty, t.FutureCloseAmount, t.SpotBuyAmount, t.SpotBuyQty, t.SpotSellAmount, t.SpotSellQty, t.UpdateTime from ERMS2_ArbitrageStrategy t left join ERMS2_ASAccount a on t.asapplyid = a.asapplyid and a.taaccounttype = 1 where t.StrategyStatus = 0 and t.userid = %d`, req.UserID) if req.GoodsGroupID > 0 { sql += fmt.Sprintf(" and t.GoodsGroupID = %d", req.GoodsGroupID) } if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QueryArbitrageStrategy failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QueryArbitrageStrategy successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) } // QuerySpotContractReq 查询现货合同表信息请求参数 type QuerySpotContractReq struct { AsApplyID uint64 `form:"asapplyid" binding:"required"` SpotContractID uint64 `form:"spotcontractid"` } // QuerySpotContractRsp 现货合同表 type QuerySpotContractRsp struct { Spotcontractid string `json:"spotcontractid" xorm:"'SPOTCONTRACTID'" binding:"required"` // 现货合同ID(701+Unix秒时间戳(10位)+xxxxxx) Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd) Contractno string `json:"contractno" xorm:"'CONTRACTNO'"` // 现货合同编号 Contracttype int64 `json:"contracttype" xorm:"'CONTRACTTYPE'"` // 现货合同类型 - 1:采购合同 -1:销售合同 Areauserid int64 `json:"areauserid" xorm:"'AREAUSERID'"` // 所属机构 Userid int64 `json:"userid" xorm:"'USERID'"` // 业务员用户ID Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'"` // 资金账户ID Customeruserid int64 `json:"customeruserid" xorm:"'CUSTOMERUSERID'"` // 客户ID Customeraccountid int64 `json:"customeraccountid" xorm:"'CUSTOMERACCOUNTID'"` // 客户资金账户ID Signdate time.Time `json:"signdate" xorm:"'SIGNDATE'"` // 签订日期 Lastdate time.Time `json:"lastdate" xorm:"'LASTDATE'"` // 交货时间 Contractattachment string `json:"contractattachment" xorm:"'CONTRACTATTACHMENT'"` // 合同附件 Producttype int64 `json:"producttype" xorm:"'PRODUCTTYPE'"` // 产品类型 - 1:标准仓单 2:等标 3:非标 Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 现货品种ID Deliverygoodsdesc string `json:"deliverygoodsdesc" xorm:"'DELIVERYGOODSDESC'"` // 品种说明 Warehouseid int64 `json:"warehouseid" xorm:"'WAREHOUSEID'"` // 仓库ID Wrfactortypeid int64 `json:"wrfactortypeid" xorm:"'WRFACTORTYPEID'"` // 仓单要素类型ID Contractqtychar string `json:"contractqtychar" xorm:"'CONTRACTQTYCHAR'"` // 合同数量\已订价数量 (用于显示) Spotprice float64 `json:"spotprice" xorm:"'SPOTPRICE'"` // 价格 Contractamount float64 `json:"contractamount" xorm:"'CONTRACTAMOUNT'"` // 合同金额 Marketid int64 `json:"marketid" xorm:"'MARKETID'"` // 市场ID Remark string `json:"remark" xorm:"'REMARK'"` // 备注 Handlestatus int64 `json:"handlestatus" xorm:"'HANDLESTATUS'"` // 处理状态 Contractqty float64 `json:"contractqty" xorm:"'CONTRACTQTY'"` // 合同数量(数值) (用于计算) Positionqty int64 `json:"positionqty" xorm:"'POSITIONQTY'"` // 头寸数量 - 合同数量去小数部分 Paystatus int64 `json:"paystatus" xorm:"'PAYSTATUS'"` // 收付款状态 - 0:未支付 1:已收款 2:已付款 Payremark string `json:"payremark" xorm:"'PAYREMARK'"` // 收付款备注 Paydatetime time.Time `json:"paydatetime" xorm:"'PAYDATETIME'"` // 收付款更新时间 Invoicestatus int64 `json:"invoicestatus" xorm:"'INVOICESTATUS'"` // 开收票状态 - 0:未开票 1:已开票 Invoiceremark string `json:"invoiceremark" xorm:"'INVOICEREMARK'"` // 发票备注 Invoiceatt string `json:"invoiceatt" xorm:"'INVOICEATT'"` // 发票附件 Invoicedatetime time.Time `json:"invoicedatetime" xorm:"'INVOICEDATETIME'"` // 开收票更新时间 Spotstatus int64 `json:"spotstatus" xorm:"'SPOTSTATUS'"` // 收发货状态 - 0:未交收 1:已发货 2:已发货 Spotremark string `json:"spotremark" xorm:"'SPOTREMARK'"` // 收发货备注 Spotdatetime time.Time `json:"spotdatetime" xorm:"'SPOTDATETIME'"` // 收发货更新时间 Relatedqty float64 `json:"relatedqty" xorm:"'RELATEDQTY'"` // 已关联数量 Contractstatus int64 `json:"contractstatus" xorm:"'CONTRACTSTATUS'"` // 合同状态 - 0:未结束 1:已结束 Closeremark string `json:"closeremark" xorm:"'CLOSEREMARK'"` // 结束备注 Closetradedate string `json:"closetradedate" xorm:"'CLOSETRADEDATE'"` // 完结交易日(yyyyMMdd) Relatedstatus int64 `json:"relatedstatus" xorm:"'RELATEDSTATUS'"` // 关联完结状态 - 0:未结束 1:已结束 Wrstandardid int64 `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 仓单标准ID(SEQ_WRSTANDARD) Invoiceopentime time.Time `json:"invoiceopentime" xorm:"'INVOICEOPENTIME'"` // 开票时间 Closetype int64 `json:"closetype" xorm:"'CLOSETYPE'"` // 终止类型 - 1:违约 2:提前终止 Closedate time.Time `json:"closedate" xorm:"'CLOSEDATE'"` // 终止日期 } // QuerySpotContract 查询现货合同表信息（指定策略ID、未结束的） // @Summary 查询现货合同表信息（指定策略ID、未结束的） // @Produce json // @Security ApiKeyAuth // @Param asapplyid query uint64 true "策略申请ID" // @Param spotcontractid query uint64 false "现货合同ID" // @Success 200 {object} QuerySpotContractRsp // @Failure 500 {object} app.Response // @Router /Erms2/QuerySpotContract [get] // @Tags 风险管理 func QuerySpotContract(c *gin.Context) { appG := app.Gin{C: c} // 获取请求参数 var req QuerySpotContractReq if err := appG.C.ShouldBindQuery(&req); err != nil { logger.GetLogger().Errorf("QuerySpotContract failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil) return } // 查询数据 engine := db.GetEngine() datas := make([]QuerySpotContractRsp, 0) sql := fmt.Sprintf(`select to_char(t.SpotContractID) SpotContractID, t.TradeDate, t.ContractNo, t.ContractType, t.AreaUserID, t.UserID, t.AccountID, t.CustomerUserID, t.CustomerAccountID, t.SignDate, t.LastDate, t.ContractAttachment, t.ProductType, t.DeliveryGoodsID, t.DeliveryGoodsDesc, t.WarehouseID, t.WRStandardID, t.WRFactorTypeID, t.ContractQtyChar, t.SpotPrice, t.ContractAmount, t.MarketID, t.Remark, t.HandleStatus, t.ContractQty, t.PositionQty, t.PayStatus, t.PayRemark, t.PayDateTime, t.InvoiceStatus, t.InvoiceRemark, t.InvoiceAtt, t.InvoiceOpenTime, t.InvoiceDateTime, t.SpotStatus, t.SpotRemark, t.SpotDateTime, t.RelatedQty, t.ContractStatus, t.CloseType, t.CloseDate, t.CloseRemark, t.CloseTradeDate, t.RelatedStatus from ERMS2_SpotContract t left join ERMS2_ASSpotDetail a on t.spotcontractid = a.spotcontractid where t.ContractStatus = 0 and not exists ( select 1 from ERMS2_ASTradeDetails e where e.spotcontractid=t.spotcontractid ) and a.asapplyid = %d`, req.AsApplyID) if req.SpotContractID > 0 { sql += fmt.Sprintf(" and a.spotcontractid = %d", req.SpotContractID) } if err := engine.SQL(sql).Find(&datas); err != nil { // 查询失败 logger.GetLogger().Errorf("QuerySpotContract failed: %s", err.Error()) appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil) return } // 查询成功 logger.GetLogger().Debugln("QuerySpotContract successed: %v", datas) appG.Response(http.StatusOK, e.SUCCESS, datas) }