// Package models 211.2风险管理系统2020_期现套利 package models import ( "fmt" "mtp2_if/db" "time" ) // Hedgeinnertradedetail 对冲内部成交单表 - 导历史 type Hedgeinnertradedetail struct { Tradeid int64 `json:"tradeid" xorm:"'TRADEID'" binding:"required"` // 成交单号(108+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx) Buyorsell int64 `json:"buyorsell" xorm:"'BUYORSELL'" binding:"required"` // 方向 - 0:买 1:卖 Orderid int64 `json:"orderid" xorm:"'ORDERID'"` // 委托单号 Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 交易日(yyyyMMdd) 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'"` // 成交数量 Tradeamount float64 `json:"tradeamount" xorm:"'TRADEAMOUNT'"` // 成交金额(账户) Closepl float64 `json:"closepl" xorm:"'CLOSEPL'"` // 平仓盈亏(账户) Opencharge float64 `json:"opencharge" xorm:"'OPENCHARGE'"` // 建仓手续费(账户) Closecharge float64 `json:"closecharge" xorm:"'CLOSECHARGE'"` // 平仓手续费(账户) Tradetype int64 `json:"tradetype" xorm:"'TRADETYPE'"` // 成交类别 - 1:正常委托成交 2:风控斩仓成交 3:修正持仓成交 4:管理端斩仓成交 Channelbuildtype int64 `json:"channelbuildtype" xorm:"'CHANNELBUILDTYPE'"` // 委托单据类型 0:无 1:建仓 2:平仓 Closetype int64 `json:"closetype" xorm:"'CLOSETYPE'"` // 平仓方式 - 0:无 1:平今 2:平昨 Hedgeflag int64 `json:"hedgeflag" xorm:"'HEDGEFLAG'"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利 Openqty int64 `json:"openqty" xorm:"'OPENQTY'"` // 开仓数量(先建后平操作 需要记录) Closeqty int64 `json:"closeqty" xorm:"'CLOSEQTY'"` // 平仓数量(先建后平操作 需要记录) Status int64 `json:"status" xorm:"'STATUS'"` // 处理状态 - 1:待处理 2:已处理 3:处理失败 Isreckoned int64 `json:"isreckoned" xorm:"'ISRECKONED'"` // 是否结算 - 0:未结算 1:已结算 Openfeealgorithm int64 `json:"openfeealgorithm" xorm:"'OPENFEEALGORITHM'"` // 建仓手续费收取方式 1：比率 2：固定 Openchargevalue float64 `json:"openchargevalue" xorm:"'OPENCHARGEVALUE'"` // 建仓手续费设置值 Closefeealgorithm int64 `json:"closefeealgorithm" xorm:"'CLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1：比率 2：固定 Closechargevalue float64 `json:"closechargevalue" xorm:"'CLOSECHARGEVALUE'"` // 平仓手续费设置值 Accountcurrencyid int64 `json:"accountcurrencyid" xorm:"'ACCOUNTCURRENCYID'"` // 账户币种ID Goodscurrencyid int64 `json:"goodscurrencyid" xorm:"'GOODSCURRENCYID'"` // 商品币种ID Curexchangerate float64 `json:"curexchangerate" xorm:"'CUREXCHANGERATE'"` // 当前汇率 Opencharge2 float64 `json:"opencharge2" xorm:"'OPENCHARGE2'"` // 建仓手续费(商品) Closecharge2 float64 `json:"closecharge2" xorm:"'CLOSECHARGE2'"` // 平仓手续费(商品) Closepl2 float64 `json:"closepl2" xorm:"'CLOSEPL2'"` // 平仓盈亏(商品) Closepl3 float64 `json:"closepl3" xorm:"'CLOSEPL3'"` // 平仓盈亏(账户)(逐笔) Closepl4 float64 `json:"closepl4" xorm:"'CLOSEPL4'"` // 平仓盈亏(商品)(逐笔) Extenalopenfeealgorithm int64 `json:"extenalopenfeealgorithm" xorm:"'EXTENALOPENFEEALGORITHM'"` // 建仓手续费收取方式(外部配置) 1：比率 2：固定 Extenalopenchargevalue float64 `json:"extenalopenchargevalue" xorm:"'EXTENALOPENCHARGEVALUE'"` // 建仓手续费设置值 Extenalclosefeealgorithm int64 `json:"extenalclosefeealgorithm" xorm:"'EXTENALCLOSEFEEALGORITHM'"` // 平仓手续费收取方式 1：比率 2：固定 Extenalclosechargevalue float64 `json:"extenalclosechargevalue" xorm:"'EXTENALCLOSECHARGEVALUE'"` // 平仓手续费设置值 Extenalopencharge float64 `json:"extenalopencharge" xorm:"'EXTENALOPENCHARGE'"` // 建仓手续费(商品)(外部) Extenalclosecharge float64 `json:"extenalclosecharge" xorm:"'EXTENALCLOSECHARGE'"` // 平仓手续费(商品)(外部) Parentaccountid int64 `json:"parentaccountid" xorm:"'PARENTACCOUNTID'"` // 所属母账户 Relatedouttradeid int64 `json:"relatedouttradeid" xorm:"'RELATEDOUTTRADEID'"` // 关联外部成交单ID } // TableName is HEDGE_INNERTRADEDETAIL func (Hedgeinnertradedetail) TableName() string { return "HEDGE_INNERTRADEDETAIL" } // Erms2astradedetails 期现套利期货成交单关联表 type Erms2astradedetails struct { Asapplyid int64 `json:"asapplyid" xorm:"'ASAPPLYID'" binding:"required"` // 策略申请ID Outtradeid int64 `json:"outtradeid" xorm:"'OUTTRADEID'" binding:"required"` // 外部成交单ID(114+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx) Biztype int64 `json:"biztype" xorm:"'BIZTYPE'"` // 策略业务类型 - 1:正向套利 2:反向套利 Detailtype int64 `json:"detailtype" xorm:"'DETAILTYPE'"` // 明细类型 - 1:套利对冲 2:期货换月 3:期货仓位调整 Spotcontractid int64 `json:"spotcontractid" xorm:"'SPOTCONTRACTID'"` // 现货合同ID [1:套利对冲 为合同ID，2:期货换月\3:期货仓位调整时为0] Contracttype int64 `json:"contracttype" xorm:"'CONTRACTTYPE'"` // 现货合同类型 - 1:采购合同 -1:销售合同 Hedgegoodsid int64 `json:"hedgegoodsid" xorm:"'HEDGEGOODSID'"` // 对冲合约ID Buyorsell int64 `json:"buyorsell" xorm:"'BUYORSELL'"` // 买卖方向 - 0:买 1:卖 [成交单方向] Buildtype int64 `json:"buildtype" xorm:"'BUILDTYPE'"` // 开平标志- 0:无 1:开仓 2:平仓 [根据成交单方向及策略业务类型确定]正向套利 成交单：卖 开 成交单：买 平反向套利 成交单：买 开 成交单：卖 平 Goodsgroupid int64 `json:"goodsgroupid" xorm:"'GOODSGROUPID'"` // 对冲品种ID[期货合约商品组ID] Tradedate string `json:"tradedate" xorm:"'TRADEDATE'"` // 成交交易日(yyyyMMdd) Tradeprice float64 `json:"tradeprice" xorm:"'TRADEPRICE'"` // 成交价 Tradelot float64 `json:"tradelot" xorm:"'TRADELOT'"` // 成交手数 Agreeunit float64 `json:"agreeunit" xorm:"'AGREEUNIT'"` // 合约单位 Tradeamount float64 `json:"tradeamount" xorm:"'TRADEAMOUNT'"` // 成交金额 = 成交价*成交手数*合约单位 Tradecharge float64 `json:"tradecharge" xorm:"'TRADECHARGE'"` // 交易手续费 Basisflag int64 `json:"basisflag" xorm:"'BASISFLAG'"` // 是否计入基差损益 - 0:不计入 1:计入 [明细类型：1\2为1，3:期货仓位调整是为0] Remark string `json:"remark" xorm:"'REMARK'"` // 备注 Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间 } // TableName is ERMS2_ASTRADEDETAILS func (Erms2astradedetails) TableName() string { return "ERMS2_ASTRADEDETAILS" } // Erms2Wrrcontract 仓单回购业务表 type Erms2Wrrcontract struct { Wrrcontractid string `json:"wrrcontractid" xorm:"WRRCONTRACTID"` // 回购业务ID(343+Unix秒时间戳(10位)+xxxxxx) Wrrcontractno string `json:"wrrcontractno" xorm:"WRRCONTRACTNO"` // 回购业务编号 Wrrcontractname string `json:"wrrcontractname" xorm:"WRRCONTRACTNAME"` // 回购名称 Areauserid int64 `json:"areauserid" xorm:"AREAUSERID"` // 所属机构 Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID Wrstandardid int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 仓单标准ID Wrfactortypeid int64 `json:"wrfactortypeid" xorm:"WRFACTORTYPEID"` // 仓单要素类型ID Accountid int64 `json:"accountid" xorm:"ACCOUNTID"` // 现货账户 Contractqtychar string `json:"contractqtychar" xorm:"CONTRACTQTYCHAR"` // 合同数量(显示) Contractqty float64 `json:"contractqty" xorm:"CONTRACTQTY"` // 合同数量 Contractprice float64 `json:"contractprice" xorm:"CONTRACTPRICE"` // 合同价格 Contractamount float64 `json:"contractamount" xorm:"CONTRACTAMOUNT"` // 合同金额 Interestratemode int32 `json:"interestratemode" xorm:"INTERESTRATEMODE"` // 利率方式 - 1:年利率 2:日利率 Interestrate float64 `json:"interestrate" xorm:"INTERESTRATE"` // 利率 Interestmindays int64 `json:"interestmindays" xorm:"INTERESTMINDAYS"` // 最小计息天数 Contractinterest float64 `json:"contractinterest" xorm:"CONTRACTINTEREST"` // 合同利息 Orimargin float64 `json:"orimargin" xorm:"ORIMARGIN"` // 初始保证金 Marginrate float64 `json:"marginrate" xorm:"MARGINRATE"` // 保证金率 Begindate time.Time `json:"begindate" xorm:"BEGINDATE"` // 开始日期 Enddate time.Time `json:"enddate" xorm:"ENDDATE"` // 结束日期 Warningline float64 `json:"warningline" xorm:"WARNINGLINE"` // 预警线 Closeline float64 `json:"closeline" xorm:"CLOSELINE"` // 强平线 Customeruserid int64 `json:"customeruserid" xorm:"CUSTOMERUSERID"` // 回购客户ID Customeraccountid int64 `json:"customeraccountid" xorm:"CUSTOMERACCOUNTID"` // 客户资金账户ID Curqty float64 `json:"curqty" xorm:"CURQTY"` // 当前数量 Curamount float64 `json:"curamount" xorm:"CURAMOUNT"` // 当前金额 Curinterest float64 `json:"curinterest" xorm:"CURINTEREST"` // 当前利息 Curmargin float64 `json:"curmargin" xorm:"CURMARGIN"` // 当前保证金 Addedmargin float64 `json:"addedmargin" xorm:"ADDEDMARGIN"` // 已追加保证金 Curenddate time.Time `json:"curenddate" xorm:"CURENDDATE"` // 最新结束日期(默认为结束日期) Remark string `json:"remark" xorm:"REMARK"` // 备注 Marketid int64 `json:"marketid" xorm:"MARKETID"` // 市场ID Tradedate string `json:"tradedate" xorm:"TRADEDATE"` // 交易日(yyyyMMdd) Updatetime time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间 Relatedspotcontractid int64 `json:"relatedspotcontractid" xorm:"RELATEDSPOTCONTRACTID"` // 关联销售合同ID Handlestatus int32 `json:"handlestatus" xorm:"HANDLESTATUS"` // 处理状态 Contractstatus int32 `json:"contractstatus" xorm:"CONTRACTSTATUS"` // 合同状态 - 0:未结束 1:已结束 Closetradedate string `json:"closetradedate" xorm:"CLOSETRADEDATE"` // 完结交易日(yyyyMMdd) } // TableName is ERMS2_WRRCONTRACT func (Erms2Wrrcontract) TableName() string { return "ERMS2_WRRCONTRACT" } // Erms2WrrcontractInfo 仓单回购业务详细信息. type Erms2WrrcontractInfo struct { Wrrcontractid string `json:"wrrcontractid" xorm:"WRRCONTRACTID"` // 回购业务ID(343+Unix秒时间戳(10位)+xxxxxx) Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID Contractqty float64 `json:"contractqty" xorm:"CONTRACTQTY"` // 合同数量 Contractstatus int32 `json:"contractstatus" xorm:"CONTRACTSTATUS"` // 合同状态 - 0:未结束 1:已结束 Buyqty float64 `json:"buyqty" xorm:"BUYQTY"` // 采购量. Buyamount float64 `json:"buyamount" xorm:"BUYAMOUNT"` // 采购额. Sellqty float64 `json:"sellqty" xorm:"SELLQTY"` // 销售量. Sellamount float64 `json:"sellamount" xorm:"SELLAMOUNT"` // 销售额. } // Erms2Spottradebiz 现货贸易业务表 type Erms2Spottradebiz struct { Spottradeid string `json:"spottradeid" xorm:"SPOTTRADEID"` // 业务ID(341+Unix秒时间戳(10位)+xxxxxx) Spottradeno string `json:"spottradeno" xorm:"SPOTTRADENO"` // 业务编号 Spottradename string `json:"spottradename" xorm:"SPOTTRADENAME"` // 业务名称 Areauserid int64 `json:"areauserid" xorm:"AREAUSERID"` // 所属机构 Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID Wrstandardid int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 仓单标准ID Goodsgroupid int64 `json:"goodsgroupid" xorm:"GOODSGROUPID"` // 期货品种 Spotaccountid int64 `json:"spotaccountid" xorm:"SPOTACCOUNTID"` // 现货资金账户 Futureaccountid int64 `json:"futureaccountid" xorm:"FUTUREACCOUNTID"` // 期货资金账户 Remark string `json:"remark" xorm:"REMARK"` // 备注 Marketid int64 `json:"marketid" xorm:"MARKETID"` // 市场ID Tradedate string `json:"tradedate" xorm:"TRADEDATE"` // 交易日(yyyyMMdd) Buyqty float64 `json:"buyqty" xorm:"BUYQTY"` // 采购总量 Buyamount float64 `json:"buyamount" xorm:"BUYAMOUNT"` // 采购总金额 Buydeliveryqty float64 `json:"buydeliveryqty" xorm:"BUYDELIVERYQTY"` // 采购已交收数量 Buydeliveryamount float64 `json:"buydeliveryamount" xorm:"BUYDELIVERYAMOUNT"` // 采购已交收金额 Sellqty float64 `json:"sellqty" xorm:"SELLQTY"` // 销售总量 Sellamount float64 `json:"sellamount" xorm:"SELLAMOUNT"` // 销售总金额 Selldeliveryqty float64 `json:"selldeliveryqty" xorm:"SELLDELIVERYQTY"` // 销售已交收数量 Selldeliveryamount float64 `json:"selldeliveryamount" xorm:"SELLDELIVERYAMOUNT"` // 销售已交收金额 Futurelot float64 `json:"futurelot" xorm:"FUTURELOT"` // 期货手数 Closestatus int32 `json:"closestatus" xorm:"CLOSESTATUS"` // 完结状态 - 0:未完结 1:已完结 Closetradedate string `json:"closetradedate" xorm:"CLOSETRADEDATE"` // 完结交易日(yyyyMMdd) } // TableName is ERMS2_SPOTTRADEBIZ func (Erms2Spottradebiz) TableName() string { return "ERMS2_SPOTTRADEBIZ" } // Erms2SpottradebizInfo 现货贸易详细信息. type Erms2SpottradebizInfo struct { Spottradeid string `json:"spottradeid" xorm:"SPOTTRADEID"` // 业务ID(341+Unix秒时间戳(10位)+xxxxxx) Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID Buyqty float64 `json:"buyqty" xorm:"BUYQTY"` // 采购总量 Sellqty float64 `json:"sellqty" xorm:"SELLQTY"` // 销售总量 Closestatus int32 `json:"closestatus" xorm:"CLOSESTATUS"` // 完结状态 - 0:未完结 1:已完结 TradeBuyqty float64 `json:"tradebuyqty" xorm:"TRADEBUYQTY"` // 采购量. TradeBuyamount float64 `json:"tradebuyamount" xorm:"TRADEBUYAMOUNT"` // 采购额. TradeSellqty float64 `json:"tradesellqty" xorm:"TRADESELLQTY"` // 销售量. TradeSellamount float64 `json:"tradesellamount" xorm:"TRADESELLAMOUNT"` // 销售额. } // Erms2Arbitragestrategy 期现套利业务表 type Erms2Arbitragestrategy struct { Asapplyid string `json:"asapplyid" xorm:"ASAPPLYID"` // 策略申请ID(342+Unix秒时间戳(10位)+xxxxxx) Asno string `json:"asno" xorm:"ASNO"` // 策略编号 Asname string `json:"asname" xorm:"ASNAME"` // 策略名称 Biztype int32 `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 int32 `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"` // 更新时间 } // TableName is ERMS2_ARBITRAGESTRATEGY func (Erms2Arbitragestrategy) TableName() string { return "ERMS2_ARBITRAGESTRATEGY" } // 期现套利详细信息. type Erms2AribitrageInfo struct { Asapplyid string `json:"asapplyid" xorm:"ASAPPLYID"` // 策略申请ID(342+Unix秒时间戳(10位)+xxxxxx) Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID Pricedspotqty float64 `json:"pricedspotqty" xorm:"PRICEDSPOTQTY"` // 已定价现货数量 Futureqty float64 `json:"futureqty" xorm:"FUTUREQTY"` // 期货持仓数量 Strategystatus int32 `json:"strategystatus" xorm:"STRATEGYSTATUS"` // 策略状态 - 0:未结束 1:已结束 Buyqty float64 `json:"buyqty" xorm:"BUYQTY"` // 采购量. Buyamount float64 `json:"buyamount" xorm:"BUYAMOUNT"` // 采购额. Sellqty float64 `json:"sellqty" xorm:"SELLQTY"` // 销售量. Sellamount float64 `json:"sellamount" xorm:"SELLAMOUNT"` // 销售额. } // Erms2spotcontract 现货合同表 type Erms2spotcontract struct { Spotcontractid int64 `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'"` // 终止日期 } // TableName is ERMS2_SPOTCONTRACT func (Erms2spotcontract) TableName() string { return "ERMS2_SPOTCONTRACT" } // Erms2asaccount 期现套利资金账户表 type Erms2asaccount struct { Asapplyid int64 `json:"asapplyid" xorm:"'ASAPPLYID'" binding:"required"` // 策略申请ID(702+Unix秒时间戳(10位)+xxxxxx) Accountid int64 `json:"accountid" xorm:"'ACCOUNTID'" binding:"required"` // 资金账户 Taaccounttype int64 `json:"taaccounttype" xorm:"'TAACCOUNTTYPE'"` // 账户类型 - 1:外部账号 2:内部账号 3:内部做市自营账号 4:内部做市接单账号 Taaccountbiztype int64 `json:"taaccountbiztype" xorm:"'TAACCOUNTBIZTYPE'"` // 账户业务类型 - 1:现货 2:期货 } // TableName is ERMS2_ASACCOUNT func (Erms2asaccount) TableName() string { return "ERMS2_ASACCOUNT" } // Erms2asspotdetail 期现套利现货明细表 - 导历史 type Erms2asspotdetail struct { Asapplyid int64 `json:"asapplyid" xorm:"'ASAPPLYID'" binding:"required"` // 策略申请ID Spotcontractid int64 `json:"spotcontractid" xorm:"'SPOTCONTRACTID'" binding:"required"` // 现货合同ID Contracttype int64 `json:"contracttype" xorm:"'CONTRACTTYPE'"` // 现货合同类型 - 1:采购合同 -1:销售合同 Pricedspotqty float64 `json:"pricedspotqty" xorm:"'PRICEDSPOTQTY'"` // 已定价数量(合同数量 * 合同类型) Pricedspotqtynotax float64 `json:"pricedspotqtynotax" xorm:"'PRICEDSPOTQTYNOTAX'"` // 已定价不含税数量( 已定价数量 /(1+对冲税率)) Vatrate float64 `json:"vatrate" xorm:"'VATRATE'"` // 税率 Spotprice float64 `json:"spotprice" xorm:"'SPOTPRICE'"` // 价格 Spotamount float64 `json:"spotamount" xorm:"'SPOTAMOUNT'"` // 收付款资金(合同金额 * 合同类型) Detailstatus int64 `json:"detailstatus" xorm:"'DETAILSTATUS'"` // 明细状态 - 0:未结束 1:已结束 Futureqty float64 `json:"futureqty" xorm:"'FUTUREQTY'"` // 期货已对冲数量 Futureamount float64 `json:"futureamount" xorm:"'FUTUREAMOUNT'"` // 期货成交金额 Closetradedate string `json:"closetradedate" xorm:"'CLOSETRADEDATE'"` // 完结交易日(yyyyMMdd) Remark string `json:"remark" xorm:"'REMARK'"` // 备注 Updatetime time.Time `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间 } // TableName is ERMS2_ASSPOTDETAIL func (Erms2asspotdetail) TableName() string { return "ERMS2_ASSPOTDETAIL" } // QueryASAccountInfoByAccountID 根据资金账号ID查询. func QueryASAccountInfoByAccountID(accountids []int64) ([]Erms2asaccount, error) { engine := db.GetEngine() data := make([]Erms2asaccount, 0) err := engine.In("ACCOUNTID", accountids).Find(&data) return data, err } // QueryASApplyIDSByAccountID 根据资金账号ID查询业务ID集合. func QueryASApplyIDSByAccountID(accountids []int64) ([]int64, error) { data, err := QueryASAccountInfoByAccountID(accountids) if err != nil { return nil, err } distinctID := make(map[int64]struct{}) applyids := make([]int64, 0, len(data)) for i := range data { if _, ok := distinctID[data[i].Asapplyid]; ok { continue } applyids = append(applyids, data[i].Asapplyid) distinctID[data[i].Asapplyid] = struct{}{} } return applyids, nil } // buildSQL 构建sql. func (asa Erms2Arbitragestrategy) buildSQL(accountids string, status int32) string { statement := `select to_char(asa.asapplyid) asapplyid, asa.deliverygoodsid, asa.pricedspotqty, asa.futureqty, asa.strategystatus, d.buyqty, d.buyamount, d.sellqty, d.sellamount from erms2_arbitragestrategy asa left join (select bt.relatedbizid, sum(case bt.contracttype when 1 then bt.relatedqty - bt.cancelledqty else 0 end) buyqty, sum(case bt.contracttype when 1 then bt.relatedamount - bt.cancelledamount else 0 end) buyamount, sum(case bt.contracttype when -1 then bt.relatedqty - bt.cancelledqty else 0 end) sellqty, sum(case bt.contracttype when -1 then bt.relatedamount - bt.cancelledamount else 0 end) sellamount from erms3_biztradedetail bt left join erms2_asaccount ea on bt.relatedbizid = ea.asapplyid where ea.accountid in (%v) group by bt.relatedbizid) d on asa.asapplyid = d.relatedbizid where asa.strategystatus = %v` return fmt.Sprintf(statement, accountids, status) } // GetByAccountIDSAndStatus 根据账号和状态获取期现套利详细信息. func (asa Erms2Arbitragestrategy) GetByAccountIDSAndStatus(accountids string, status int32) ([]Erms2AribitrageInfo, error) { engine := db.GetEngine() data := make([]Erms2AribitrageInfo, 0) err := engine.SQL(asa.buildSQL(accountids, status)).Find(&data) return data, err } func (Erms2Wrrcontract) buildSQL(accountids string, status int32) string { statement := `select to_char(wr.wrrcontractid) wrrcontractid, wr.deliverygoodsid, wr.contractqty, wr.contractstatus, sum(case bt.contracttype when 1 then bt.relatedqty - bt.cancelledqty else 0 end) buyqty, sum(case bt.contracttype when 1 then bt.relatedamount - bt.cancelledamount else 0 end) buyamount, sum(case bt.contracttype when -1 then bt.relatedqty - bt.cancelledqty else 0 end) sellqty, sum(case bt.contracttype when -1 then bt.relatedamount - bt.cancelledamount else 0 end) sellamount from erms3_biztradedetail bt left join erms2_wrrcontract wr on wr.wrrcontractid = bt.relatedbizid where wr.accountid in (%v) and wr.contractstatus = %v group by wr.wrrcontractid, wr.deliverygoodsid, wr.contractqty, wr.contractstatus` return fmt.Sprintf(statement, accountids, status) } // GetByAccountIDSAndStatus 根据账号和状态获取仓单回购业务. func (wr Erms2Wrrcontract) GetByAccountIDSAndStatus(accountids string, status int32) ([]Erms2WrrcontractInfo, error) { engine := db.GetEngine() data := make([]Erms2WrrcontractInfo, 0) err := engine.SQL(wr.buildSQL(accountids, status)).Find(&data) return data, err } // buildSQL 构建sql. func (Erms2Spottradebiz) buildSQL(accountids string, status int32) string { statement := `select to_char(sbt.spottradeid) spottradeid, sbt.deliverygoodsid, sbt.buyqty, sbt.sellqty, sbt.closestatus, sum(case bt.contracttype when 1 then bt.relatedqty - bt.cancelledqty else 0 end) tradebuyqty, sum(case bt.contracttype when 1 then bt.relatedamount - bt.cancelledamount else 0 end) tradebuyamount, sum(case bt.contracttype when -1 then bt.relatedqty - bt.cancelledqty else 0 end) tradesellqty, sum(case bt.contracttype when -1 then bt.relatedamount - bt.cancelledamount else 0 end) tradesellamount from erms3_biztradedetail bt left join erms2_spottradebiz sbt on sbt.spottradeid = bt.relatedbizid where sbt.spotaccountid in (%v) and sbt.closestatus = %v group by sbt.spottradeid, sbt.deliverygoodsid, sbt.buyqty, sbt.sellqty, sbt.closestatus` return fmt.Sprintf(statement, accountids, status) } // GetByAccountIDSAndStatus 根据账号和状态获取现货贸易业务. func (stb Erms2Spottradebiz) GetByAccountIDSAndStatus(accountids string, status int32) ([]Erms2SpottradebizInfo, error) { engine := db.GetEngine() data := make([]Erms2SpottradebizInfo, 0) err := engine.SQL(stb.buildSQL(accountids, status)).Find(&data) return data, err }