package models import ( "mtp2_if/db" "mtp2_if/utils" "time" ) // Ermcp2hedgeditem 被套期项目表 type Ermcp2hedgeditem struct { Hedgeditemid string `json:"hedgeditemid" xorm:"HEDGEDITEMID"` // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx) Hedgeditemnum string `json:"hedgeditemnum" xorm:"HEDGEDITEMNUM"` // 项目编号 Hedgeditemname string `json:"hedgeditemname" xorm:"HEDGEDITEMNAME"` // 项目名称 Hedgedtype int32 `json:"hedgedtype" xorm:"HEDGEDTYPE" form:"hedgedtype"` // 套期类型 - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目 Planstartdate time.Time `json:"planstartdate" xorm:"PLANSTARTDATE"` // 计划开始日期 Planenddate time.Time `json:"planenddate" xorm:"PLANENDDATE"` // 计划结束日期 Hedgerate float64 `json:"hedgerate" xorm:"HEDGERATE"` // 套保比率 Tradeuserid int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID Areauserid int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID Hedgeditemstatus int32 `json:"hedgeditemstatus" xorm:"HEDGEDITEMSTATUS" form:"hedgeditemstatus"` // 项目状态 - 0:未提交 1:待审核 2:执行中 3:正常完结 4:审核拒绝 5:异常完结 6:已撤回 Applysrc int32 `json:"applysrc" xorm:"APPLYSRC"` // 申请来源 - 1:管理端 2:终端 Applyid int64 `json:"applyid" xorm:"APPLYID"` // 申请人 Remark string `json:"remark" xorm:"REMARK"` // 备注 Createtime time.Time `json:"createtime" xorm:"CREATETIME"` // 申请时间 Audittradedate string `json:"audittradedate" xorm:"AUDITTRADEDATE"` // 审核交易日(yyyyMMdd) Auditid int64 `json:"auditid" xorm:"AUDITID"` // 审核人 Auditsrc int32 `json:"auditsrc" xorm:"AUDITSRC"` // 审核来源 - 1:管理端 2:终端 Audittime time.Time `json:"audittime" xorm:"AUDITTIME"` // 审核时间 Auditremark string `json:"auditremark" xorm:"AUDITREMARK"` // 审核备注 Deliverygoodsid int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID Wrstandardid int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID Vatrate float64 `json:"vatrate" xorm:"VATRATE"` // 增值税 Hedgeqty float64 `json:"hedgeqty" xorm:"HEDGEQTY"` // 套期现货量 Hedgeamount float64 `json:"hedgeamount" xorm:"HEDGEAMOUNT"` // 套期市价总额 Hedgerestamount float64 `json:"hedgerestamount" xorm:"HEDGERESTAMOUNT"` // 套期剩余市价总额【现货贸易】 Hedgecontractamount float64 `json:"hedgecontractamount" xorm:"HEDGECONTRACTAMOUNT"` // 套期定价总额 【定价采购合同】【现货贸易】 Oriavgprice float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场均价 = 套期市价总额 / 套期现货量 Exeqty float64 `json:"exeqty" xorm:"EXEQTY"` // 执行现货量 Exeamount float64 `json:"exeamount" xorm:"EXEAMOUNT"` // 执行市价总额 Exerestamount float64 `json:"exerestamount" xorm:"EXERESTAMOUNT"` // 执行剩余市价总额【现货贸易】 Exeavgprice float64 `json:"exeavgprice" xorm:"EXEAVGPRICE"` // 执行市场均价= 执行市价总额 / 执行现货量 Execontractamount float64 `json:"execontractamount" xorm:"EXECONTRACTAMOUNT"` // 执行定价总额 Curprice float64 `json:"curprice" xorm:"CURPRICE"` // 当前市场价 Unexeqty float64 `json:"unexeqty" xorm:"UNEXEQTY"` // 未执行现货量 = 套期现货量 - 执行现货量 Spothedgepl float64 `json:"spothedgepl" xorm:"SPOTHEDGEPL"` // 现货套期损益 =(执行市场均价-期初市场均价)*执行现货量 * 方向(销售计划 为 -1, 其它为1) Spotpl float64 `json:"spotpl" xorm:"SPOTPL"` // 现货套期损益 = 现货实际损益 + 现货浮动损益 Futurehedgepl float64 `json:"futurehedgepl" xorm:"FUTUREHEDGEPL"` // 期货实际损益 Futurepl float64 `json:"futurepl" xorm:"FUTUREPL"` // 期货套期损益 Hedgesumpl float64 `json:"hedgesumpl" xorm:"HEDGESUMPL"` // 套期汇总损益 = 期货汇总损益 + 现货汇总损益 Spottradepl float64 `json:"spottradepl" xorm:"SPOTTRADEPL"` // 现货贸易损益【现货贸易】= 执行合同定价总额 - 套期合同定价总额 Vatpl float64 `json:"vatpl" xorm:"VATPL"` // 增值税损益【现货贸易】= 现货贸易损益 * （增值税率 /（1+增值税率）） Sumobspl float64 `json:"sumobspl" xorm:"SUMOBSPL"` // 汇总绝对损益【现货贸易】=现货贸易损益+增值税损益+期货套期损益 Spotbookamount float64 `json:"spotbookamount" xorm:"SPOTBOOKAMOUNT"` // 现货账面总额 Curstock float64 `json:"curstock" xorm:"CURSTOCK"` // 期末库存量 = 采购总量 - 销售总量 Enddate time.Time `json:"enddate" xorm:"ENDDATE"` // 完成日期 Endtradedate string `json:"endtradedate" xorm:"ENDTRADEDATE"` // 完成交易日 Updatetime time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间 Orispothedgepl float64 `json:"orispothedgepl" xorm:"ORISPOTHEDGEPL"` // 期初现货实际损益 Orifuturehedgepl float64 `json:"orifuturehedgepl" xorm:"ORIFUTUREHEDGEPL"` // 期初期货实际损益 Orispotpl float64 `json:"orispotpl" xorm:"ORISPOTPL"` // 期初现货套期损益 Orifuturepl float64 `json:"orifuturepl" xorm:"ORIFUTUREPL"` // 期初期货套期损益 Spotfloatpl float64 `json:"spotfloatpl" xorm:"SPOTFLOATPL"` // 现货浮动损益 =(当前市场价 - 期初市场价)*未执行现货量 * 方向(销售计划 为 -1, 其它为1) Futurefloatpl float64 `json:"futurefloatpl" xorm:"FUTUREFLOATPL"` // 期货浮动损益 SpotHedgePLChange float64 `json:"spothedgeplchange" xorm:"SPOTHEDGEPLCHANGE"` // 现货实际损益变动 SpotPLChange float64 `json:"spotplchange" xorm:"SPOTPLCHANGE"` // 现货套期损益变动 FutureHedgePLChange float64 `json:"futurehedgeplchange" xorm:"FUTUREHEDGEPLCHANGE"` // 期货实际损益变动 FuturePLChange float64 `json:"futureplchange" xorm:"FUTUREPLCHANGE"` // 期货套期损益变动 Wrstandardname string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 商品名称 EnumdicName string `json:"enumdicname" xorm:"'ENUMDICNAME'"` // 单位 AccountName string `json:"accountName" xorm:"ACCOUNTNAME"` // 套期主体 MiddleGoodsList []Ermcp2himiddlegoods `json:"middlegoodslist"` // 套期商品列表 USERID int64 `json:"-" form:"userid" binding:"required"` // 用户id, 用于过滤 } // TableName is ERMCP2_HEDGEDITEM func (r *Ermcp2hedgeditem) TableName() string { return "ERMCP2_HEDGEDITEM" } func (r *Ermcp2hedgeditem) calc() { } func (r *Ermcp2hedgeditem) buildSql() string { var sqlId utils.SQLVal = ` SELECT to_char(t.HEDGEDITEMID) HEDGEDITEMID, t.HEDGEDITEMNUM , t.HEDGEDITEMNAME , t.HEDGEDTYPE , t.PLANSTARTDATE , t.PLANENDDATE , t.HEDGERATE , t.TRADEUSERID , t.AREAUSERID , t.HEDGEDITEMSTATUS , t.APPLYSRC , t.APPLYID , t.REMARK , t.CREATETIME , t.AUDITTRADEDATE , t.AUDITID , t.AUDITSRC , t.AUDITTIME , t.AUDITREMARK , t.DELIVERYGOODSID , t.WRSTANDARDID , t.VATRATE , t.HEDGEQTY , t.HEDGEAMOUNT , t.HEDGERESTAMOUNT , t.HEDGECONTRACTAMOUNT, t.ORIAVGPRICE , t.EXEQTY , t.EXEAMOUNT , t.EXERESTAMOUNT , t.EXEAVGPRICE , t.EXECONTRACTAMOUNT , t.CURPRICE , t.UNEXEQTY , t.SPOTHEDGEPL , t.SPOTPL , t.FUTUREHEDGEPL , t.FUTUREPL , t.HEDGESUMPL , t.SPOTTRADEPL , t.VATPL , t.SUMOBSPL , t.SPOTBOOKAMOUNT , t.CURSTOCK , t.ENDDATE , t.ENDTRADEDATE , t.UPDATETIME , t.ORISPOTHEDGEPL , t.ORIFUTUREHEDGEPL , t.ORISPOTPL , t.ORIFUTUREPL , t.SPOTFLOATPL , t.FUTUREFLOATPL , (t.SpotHedgePL - t.OriSpotHedgePL) SPOTHEDGEPLCHANGE, (t.SpotPL - t.OriSpotPL) SPOTPLCHANGE, (t.FutureHedgePL - t.OriFutureHedgePL) FUTUREHEDGEPLCHANGE, (t.FuturePL - t.OriFuturePL) FUTUREPLCHANGE, wr.WRSTANDARDNAME, e.ENUMDICNAME, u.ACCOUNTNAME FROM ERMCP2_HedgedItem t LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit' LEFT JOIN useraccount u ON u.userid = t.tradeuserid WHERE 1 = 1 AND %v in (t.AreaUserID, t.TradeUserID) ` sqlId.FormatParam(r.USERID) sqlId.AndEx("t.Hedgedtype", r.Hedgedtype, r.Hedgedtype > 0) sqlId.AndEx("t.hedgeditemstatus", r.Hedgeditemstatus, r.Hedgeditemstatus > 0) return sqlId.String() } // GetDataEx 从数据库中查询数据 func (r *Ermcp2hedgeditem) GetDataEx() (interface{}, error) { e := db.GetEngine() s := e.SQL(r.buildSql()) sData := make([]Ermcp2hedgeditem, 0) if err := s.Find(&sData); err != nil { return nil, err } for i := range sData { sData[i].calc() } if len(sData) > 0 { // 获取关联期货品种 m1 := Ermcp2himiddlegoods{} if d1, err := m1.GetDataEx(); err == nil { gpLst := d1.([]Ermcp2himiddlegoods) for i := range sData { sData[i].MiddleGoodsList = append(sData[i].MiddleGoodsList, gpLst...) } } } return sData, nil } // Ermcp2himiddlegoods 项目套保品种明细 type Ermcp2himiddlegoods struct { HEDGEDITEMID int64 `json:"hedgeditemid" xorm:"HEDGEDITEMID" binding:"required"` // 被套期项目ID(624+Unix秒时间戳(10位)+xxxxxx) MIDDLEGOODSID int64 `json:"middlegoodsid" xorm:"MIDDLEGOODSID" binding:"required"` // 套保品种ID DELIVERYGOODSID int64 `json:"-" xorm:"DELIVERYGOODSID"` // 现货品种ID WRSTANDARDID int64 `json:"-" xorm:"WRSTANDARDID"` // 现货商品ID VATRATE float64 `json:"-" xorm:"VATRATE"` // 增值税 SPOTCONVERTRATIO float64 `json:"-" xorm:"SPOTCONVERTRATIO"` // 折算系数 [现货] UNEXESPOTQTY float64 `json:"-" xorm:"UNEXESPOTQTY"` // 未执行现货量 UNEXEHEDGEQTY float64 `json:"unexehedgeqty" xorm:"UNEXEHEDGEQTY"` // 未执行套期量 = 未执行现货量*折算系数* (1/(1+增值税)) * 套期比例(项目上) FUTUREHEDGEQTY float64 `json:"futurehedgeqty" xorm:"FUTUREHEDGEQTY"` // 期货持仓套期量 HIEXPSOURE float64 `json:"hiexpsoure" xorm:"HIEXPSOURE"` // 期现敞口量 = 未执行套期量 + 期货持仓套期量 TRADEUSERID int64 `json:"-" xorm:"TRADEUSERID"` // 交易用户ID AREAUSERID int64 `json:"-" xorm:"AREAUSERID"` // 企业ID CREATETIME time.Time `json:"-" xorm:"CREATETIME"` // 创建时间 UPDATETIME time.Time `json:"-" xorm:"UPDATETIME"` // 更新时间 Middlegoodsname string `json:"middlegoodsname" xorm:"'MIDDLEGOODSNAME'"` // 套保商品名称 Middlegoodscode string `json:"middlegoodscode" xorm:"'MIDDLEGOODSCODE'"` // 套保商品代码 } // TableName is ERMCP2_HIMIDDLEGOODS func (r *Ermcp2himiddlegoods) TableName() string { return "ERMCP2_HIMIDDLEGOODS" } func (r *Ermcp2himiddlegoods) calc() { } func (r *Ermcp2himiddlegoods) buildSql() string { var sqlId utils.SQLVal = ` SELECT t.MIDDLEGOODSID, t.UNEXEHEDGEQTY, t.FUTUREHEDGEQTY, t.HIEXPSOURE, m.MIDDLEGOODSNAME, m.MIDDLEGOODSCODE FROM ERMCP2_HIMIDDLEGOODS t LEFT JOIN erms_middlegoods m ON m.middlegoodsid = t.middlegoodsid WHERE t.HEDGEDITEMID = %v ` sqlId.FormatParam(r.HEDGEDITEMID) return sqlId.String() } // GetDataEx 从数据库中查询数据 func (r *Ermcp2himiddlegoods) GetDataEx() (interface{}, error) { e := db.GetEngine() s := e.SQL(r.buildSql()) sData := make([]Ermcp2himiddlegoods, 0) if err := s.Find(&sData); err != nil { return nil, err } for i := range sData { sData[i].calc() } return sData, nil } // Ermcpjrlinkpos 项目期货关联头寸 type Ermcpjrlinkpos struct { SPOTCONTRACTID string `json:"spotcontractid" xorm:"SPOTCONTRACTID" form:"hedgeditemid" binding:"required"` // 现货ID [套期项目ID - 金瑞:合同\虚拟合同ID GOODSID int32 `json:"goodsid" xorm:"GOODSID"` // 期货合约 ORDERTYPE int32 `json:"ordertype" xorm:"ORDERTYPE"` // 单据类型[套期工具] - 1:期货单 2:看涨期权单 3:看跌期权单 EXECUTEPRICE int64 `json:"executeprice" xorm:"EXECUTEPRICE"` // 执行价 - 1:期货单 为 0 OPTIONCODE string `json:"optioncode" xorm:"OPTIONCODE"` // 期权代码 AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 所属企业 TOTALBUYAMOUNT float64 `json:"totalbuyamount" xorm:"TOTALBUYAMOUNT"` // 买金额 [期货] TOTALBUYQTY float64 `json:"totalbuyqty" xorm:"TOTALBUYQTY"` // 买数量 TOTALSELLAMOUNT float64 `json:"totalsellamount" xorm:"TOTALSELLAMOUNT"` // 卖金额 [期货] TOTALSELLQTY float64 `json:"totalsellqty" xorm:"TOTALSELLQTY"` // 卖数量 NETQTY float64 `json:"netqty" xorm:"NETQTY"` // 净头寸 TOTALCHARGE float64 `json:"totalcharge" xorm:"TOTALCHARGE"` // 手续费 TOTALPREMIUM float64 `json:"totalpremium" xorm:"TOTALPREMIUM"` // 权利金 [期权] CLOSEPL float64 `json:"closepl" xorm:"CLOSEPL"` // 总平仓盈亏 [期货损益] UPDATETIME time.Time `json:"updatetime" xorm:"UPDATETIME"` // 更新时间 TOTALBUYHOLDAMOUNT float64 `json:"totalbuyholdamount" xorm:"TOTALBUYHOLDAMOUNT"` // 买持仓总金额[期货] TOTALSELLHOLDAMOUNT float64 `json:"totalsellholdamount" xorm:"TOTALSELLHOLDAMOUNT"` // 卖持仓总金额[期货] TODAYFUTURECLOSEPL float64 `json:"todayfutureclosepl" xorm:"TODAYFUTURECLOSEPL"` // 今日平仓盈亏 RECKONPL float64 `json:"reckonpl" xorm:"RECKONPL"` // 总盈亏(平仓盈亏 + 结算盈亏 - 手续费) Middlegoodsname string `json:"middlegoodsname" xorm:"'MIDDLEGOODSNAME'"` // 套保商品名称 Middlegoodscode string `json:"middlegoodscode" xorm:"'MIDDLEGOODSCODE'"` // 套保商品代码 FUTUREHEDGEQTY float64 `json:"futurehedgeqty" xorm:"FUTUREHEDGEQTY"` // 期货套期量 AVERAGEPRICE float64 `json:"averageprice" xorm:"AVERAGEPRICE"` // 持仓均价 (TotalBuyHoldAmount - TotalSellHoldAmount) / NetQty } // TableName is ERMCP_JR_LINKPOS func (r *Ermcpjrlinkpos) TableName() string { return "ERMCP_JR_LINKPOS" } func (r *Ermcpjrlinkpos) calc() { } func (r *Ermcpjrlinkpos) buildSql() string { var sqlId utils.SQLVal = ` SELECT to_char(t.SPOTCONTRACTID) SPOTCONTRACTID, t.ORDERTYPE, t.OPTIONCODE, t.CLOSEPL, t.NETQTY, ((t.TotalBuyHoldAmount - t.TotalSellHoldAmount) / NetQty) AVERAGEPRICE, mg.middlegoodsname, mg.middlegoodscode FROM ERMCP_JR_LinkPos t LEFT JOIN Goods g ON g.goodsid = t.goodsid LEFT JOIN ERMCP_GGConvertConfig gc on gc.srcgoodsgroupid = g.goodsgroupid LEFT JOIN ERMS_MiddleGoods mg ON mg.goodsgroupid = gc.destgoodsgroupid WHERE mg.areauserid = t.areauserid AND t.SPOTCONTRACTID = %v ORDER BY t.OPTIONCODE ` // 只有期货合约ID(GoodsID)的情况下获取套保商品名称，需要以上的关联 sqlId.FormatParam(r.SPOTCONTRACTID) return sqlId.String() } // GetDataEx 从数据库中查询数据 func (r *Ermcpjrlinkpos) GetDataEx() (interface{}, error) { e := db.GetEngine() s := e.SQL(r.buildSql()) sData := make([]Ermcpjrlinkpos, 0) if err := s.Find(&sData); err != nil { return nil, err } for i := range sData { sData[i].calc() } return sData, nil } // Ermcp2hedgeditemspot 项目现货明细 type Ermcp2hedgeditemspot struct { HEDGEDITEMSPOTID string `json:"hedgeditemspotid" xorm:"HEDGEDITEMSPOTID"` // 现货明细ID(625+Unix秒时间戳(10位)+xxxxxx) HEDGEDITEMID string `json:"hedgeditemid" xorm:"HEDGEDITEMID" form:"hedgeditemid" binding:"required"` // 被套期项目ID HEDGEDTYPE int32 `json:"hedgedtype" xorm:"HEDGEDTYPE"` // 套期类型[计划类型] - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目 SPOTTYPE int32 `json:"spottype" xorm:"SPOTTYPE"` // 现货类型 - 1:采购计划 2:销售计划 3:采购合同 4:销售合同 5:库存存货 RELATEDTYPE int32 `json:"relatedtype" xorm:"RELATEDTYPE"` // 关联类型 - 1:套期关联 2:执行关联 RELATEDHEDGEPLANID int64 `json:"relatedhedgeplanid" xorm:"RELATEDHEDGEPLANID"` // 关联计划ID 【1:采购计划 2:销售计划】 RELATEDSPOTCONTRACTID int64 `json:"relatedspotcontractid" xorm:"RELATEDSPOTCONTRACTID"` // 关联合同ID 【3:采购合同 4:销售合同】 CUSTOMERUSERID int64 `json:"customeruserid" xorm:"CUSTOMERUSERID"` // 对手方 【3:采购合同 4:销售合同】 DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"SPOTGOODSBRANDID"` // 现货品牌ID - 存“DGFactoryItem”表"DGFactoryItemID" = 2 RELATEDQTY float64 `json:"relatedqty" xorm:"RELATEDQTY"` // 关联数量[数量] ORIAVGPRICE float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场价[当初市场价] RELATEDAMOUNT float64 `json:"relatedamount" xorm:"RELATEDAMOUNT"` // 市价总额 = 关联数量 * 期初市场价 SPOTPRICEDAMOUNT float64 `json:"spotpricedamount" xorm:"SPOTPRICEDAMOUNT"` // 定价总额 SPOTPRICEDAVGPRICE float64 `json:"spotpricedavgprice" xorm:"SPOTPRICEDAVGPRICE"` // 现货均价 = 定价总额 / 关联数量 CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间 TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID Wrstandardname string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品 EnumdicName string `json:"enumdicname" xorm:"'ENUMDICNAME'"` // 单位 Hedgeplanno string `json:"hedgeplanno" xorm:"'HEDGEPLANNO'"` // 计划编号 } // TableName is ERMCP2_HEDGEDITEMSPOT func (r *Ermcp2hedgeditemspot) TableName() string { return "ERMCP2_HEDGEDITEMSPOT" } func (r *Ermcp2hedgeditemspot) calc() { } func (r *Ermcp2hedgeditemspot) buildSql() string { var sqlId utils.SQLVal = ` SELECT to_char(t.hedgeditemspotid) HEDGEDITEMSPOTID, to_char(t.hedgeditemid) HEDGEDITEMID, t.HEDGEDTYPE, wr.WRSTANDARDNAME, e.ENUMDICNAME, t.RELATEDQTY, t.ORIAVGPRICE, s.HEDGEPLANNO FROM ERMCP2_HEDGEDITEMSPOT t LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit' LEFT JOIN ermcp_hedgeplan s ON s.HedgePlanID = t.RELATEDHEDGEPLANID WHERE t.HedgedType IN (1,2) AND t.hedgeditemid = %v ORDER BY t.createtime ` sqlId.FormatParam(r.HEDGEDITEMID) return sqlId.String() } // GetDataEx 从数据库中查询数据 func (r *Ermcp2hedgeditemspot) GetDataEx() (interface{}, error) { e := db.GetEngine() s := e.SQL(r.buildSql()) sData := make([]Ermcp2hedgeditemspot, 0) if err := s.Find(&sData); err != nil { return nil, err } for i := range sData { sData[i].calc() } return sData, nil } // Ermcp2hedgeditemspotDetail 现货成交明细 type Ermcp2hedgeditemspotDetail struct { HEDGEDITEMSPOTID string `json:"hedgeditemspotid" xorm:"HEDGEDITEMSPOTID"` // 现货明细ID(625+Unix秒时间戳(10位)+xxxxxx) HEDGEDITEMID string `json:"hedgeditemid" xorm:"HEDGEDITEMID" form:"hedgeditemid" binding:"required"` // 被套期项目ID HEDGEDTYPE int32 `json:"hedgedtype" xorm:"HEDGEDTYPE"` // 套期类型[计划类型] - 1:采购计划项目 2:销售计划项目 3:现货贸易项目 4:库存存货项目 5:定价采购合同项目 SPOTTYPE int32 `json:"spottype" xorm:"SPOTTYPE"` // 现货类型[合同类型] - 1:采购计划 2:销售计划 3:采购合同 4:销售合同 5:库存存货 RELATEDTYPE int32 `json:"relatedtype" xorm:"RELATEDTYPE"` // 关联类型 - 1:套期关联 2:执行关联 RELATEDHEDGEPLANID int64 `json:"relatedhedgeplanid" xorm:"RELATEDHEDGEPLANID"` // 关联计划ID 【1:采购计划 2:销售计划】 RELATEDSPOTCONTRACTID int64 `json:"relatedspotcontractid" xorm:"RELATEDSPOTCONTRACTID"` // 关联合同ID 【3:采购合同 4:销售合同】 CUSTOMERUSERID int64 `json:"customeruserid" xorm:"CUSTOMERUSERID"` // 对手方 【3:采购合同 4:销售合同】 DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"DELIVERYGOODSID"` // 现货品种ID WRSTANDARDID int64 `json:"wrstandardid" xorm:"WRSTANDARDID"` // 现货商品ID SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"SPOTGOODSBRANDID"` // 现货品牌ID - 存“DGFactoryItem”表"DGFactoryItemID" = 2 RELATEDQTY float64 `json:"relatedqty" xorm:"RELATEDQTY"` // 关联数量[数量] ORIAVGPRICE float64 `json:"oriavgprice" xorm:"ORIAVGPRICE"` // 期初市场价[当初市场价] RELATEDAMOUNT float64 `json:"relatedamount" xorm:"RELATEDAMOUNT"` // 市价总额 = 关联数量 * 期初市场价 SPOTPRICEDAMOUNT float64 `json:"spotpricedamount" xorm:"SPOTPRICEDAMOUNT"` // 定价总额[金额] SPOTPRICEDAVGPRICE float64 `json:"spotpricedavgprice" xorm:"SPOTPRICEDAVGPRICE"` // 现货均价 = 定价总额 / 关联数量 CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间 TRADEUSERID int64 `json:"tradeuserid" xorm:"TRADEUSERID"` // 交易用户ID AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 企业ID Wrstandardname string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品 EnumdicName string `json:"enumdicname" xorm:"'ENUMDICNAME'"` // 单位 AccountName string `json:"accountName" xorm:"ACCOUNTNAME"` // 对手方 BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌 CONTRACTNO string `json:"contractno" xorm:"'CONTRACTNO'"` // 合同编号 } func (r *Ermcp2hedgeditemspotDetail) calc() { } func (r *Ermcp2hedgeditemspotDetail) buildSql() string { var sqlId utils.SQLVal = ` SELECT to_char(t.hedgeditemspotid) HEDGEDITEMSPOTID, to_char(t.hedgeditemid) HEDGEDITEMID, t.CREATETIME, t.SPOTTYPE, u.ACCOUNTNAME, wr.WRSTANDARDNAME, e.ENUMDICNAME, gb.dgfactoryitemvalue BRANDNAME, t.RELATEDQTY, t.SPOTPRICEDAVGPRICE, t.SPOTPRICEDAMOUNT, t.ORIAVGPRICE, s.CONTRACTNO FROM ERMCP2_HEDGEDITEMSPOT t LEFT JOIN useraccount u ON u.userid = t.CUSTOMERUSERID LEFT JOIN WRStandard wr ON wr.wrstandardid = t.wrstandardid LEFT JOIN enumdicitem e on wr.unitid=e.enumitemname and e.enumdiccode='goodsunit' LEFT JOIN dgfactoryitem gb ON gb.dgfactoryitemid = t.SPOTGOODSBRANDID LEFT JOIN ermcp_spotcontract s on s.spotcontractid = t.RELATEDSPOTCONTRACTID WHERE t.HedgedType IN (3,4,5) AND t.hedgeditemid = %v ORDER BY t.createtime ` sqlId.FormatParam(r.HEDGEDITEMID) return sqlId.String() } // GetDataEx 从数据库中查询数据 func (r *Ermcp2hedgeditemspotDetail) GetDataEx() (interface{}, error) { e := db.GetEngine() s := e.SQL(r.buildSql()) sData := make([]Ermcp2hedgeditemspotDetail, 0) if err := s.Find(&sData); err != nil { return nil, err } for i := range sData { sData[i].calc() } return sData, nil } // Ermcppatradelinkdetail 期货成交单关联明细表 type Ermcppatradelinkdetail struct { LINKDETAILID string `json:"linkdetailid" xorm:"LINKDETAILID"` // 期货明细ID(614+Unix秒时间戳(10位)+xxxxxx) TRADEID string `json:"tradeid" xorm:"TRADEID"` // [成交单号]内部成交单ID BUYORSELL int32 `json:"buyorsell" xorm:"BUYORSELL"` // 方向 - 0:买 1:卖 HEDGEFLAG int32 `json:"hedgeflag" xorm:"HEDGEFLAG"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利 4:套期保值(平安\合同) 5:单边(平安) 6:移仓(平安) 7:错单处理(平安) 8:跨期套利(平安) 9:套期保值(计划) 10:套利(合同) 11:换月(合同) 12:交割(金瑞) 13:被套期项目 SPOTCONTRACTID int64 `json:"hedgeditemid" xorm:"SPOTCONTRACTID" form:"hedgeditemid" binding:"required"` // 现货ID[套期项目ID] [13 - 被套期项目ID] [4,10,11 - 现货合同ID] [9 - 套保计划ID] RELATEDLOT float64 `json:"relatedlot" xorm:"RELATEDLOT"` // [数量]关联手数 GOODSID int32 `json:"goodsid" xorm:"GOODSID"` // 商品ID GOODSGROUPID int32 `json:"goodsgroupid" xorm:"GOODSGROUPID"` // 对冲品种ID[期货合约商品组ID] MIDDLEGOODSID int64 `json:"middlegoodsid" xorm:"MIDDLEGOODSID"` // 套保品种ID RELATEDQTY float64 `json:"relatedqty" xorm:"RELATEDQTY"` // 关联数量 = RelatedLot * AgreeUnit * ConvertRatio TRADEDATE string `json:"tradedate" xorm:"TRADEDATE"` // 关联交易日(yyyyMMdd) RELATEDMODE int32 `json:"relatedmode" xorm:"RELATEDMODE"` // 关联方式 - 1:自动关联 2:手动关联 3:解绑关联 TRADETRADEDATE string `json:"tradetradedate" xorm:"TRADETRADEDATE"` // 成交交易日(yyyyMMdd) TRADEPRICE float64 `json:"tradeprice" xorm:"TRADEPRICE"` // [价格]成交价格 TRADELOT int64 `json:"tradelot" xorm:"TRADELOT"` // 成交手数 SALEUSERID int64 `json:"saleuserid" xorm:"SALEUSERID"` // 业务员ID BIZSUBJECTID int64 `json:"bizsubjectid" xorm:"BIZSUBJECTID"` // 归属业务部门ID - SubjectID AGREEUNIT float64 `json:"agreeunit" xorm:"AGREEUNIT"` // 合约乘数 CONVERTRATIO float64 `json:"convertratio" xorm:"CONVERTRATIO"` // 品种系数 AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 所属机构 CREATORSRC int32 `json:"creatorsrc" xorm:"CREATORSRC"` // 创建人来源 - 1:管理端 2:终端 3:交易 CREATORID int64 `json:"creatorid" xorm:"CREATORID"` // 创建人ID CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间 LINKSTATUS int32 `json:"linkstatus" xorm:"LINKSTATUS"` // 关联状态 - 1:成功 2:失败 3:解绑 RETCODE int32 `json:"retcode" xorm:"RETCODE"` // 返回码 TRADETIME time.Time `json:"tradetime" xorm:"TRADETIME"` // 日期时间 ORDERTYPE int32 `json:"ordertype" xorm:"ORDERTYPE"` // 单据类型[套期工具] - 1:期货单 2:看涨期权单 3:看跌期权单 OPTIONCODE string `json:"optioncode" xorm:"OPTIONCODE"` // [期货合约]期权代码 [期权] AMOUNT float64 `json:"amount" xorm:"AMOUNT"` // 金额 = RelatedLot * TradePrice * AgreeUnit NAME string `json:"name" xorm:"NAME"` // 账户名/子账户 } func (r *Ermcppatradelinkdetail) calc() { } func (r *Ermcppatradelinkdetail) buildSql() string { var sqlId utils.SQLVal = ` SELECT p.TRADETIME, p.ORDERTYPE, p.OPTIONCODE, t.BUYORSELL, t.TRADEPRICE, t.RELATEDLOT, (t.RelatedLot * t.TradePrice * t.AgreeUnit) AMOUNT, to_char(t.TRADEID) TRADEID, (u.ACCOUNTNAME || '/' || to_char(t.ACCOUNTID)) NAME FROM ERMCP_PA_TradeLinkDetail t LEFT JOIN ERMCP_PA_TradeLink p ON p.TradeID = t.TradeID AND p.BuyorSell = t.BuyorSell LEFT JOIN TAACCOUNT ta ON ta.ACCOUNTID = t.ACCOUNTID LEFT JOIN USERACCOUNT u on u.userid = ta.relateduserid WHERE t.HedgeFlag = 13 AND t.SpotContractID = %v ORDER BY p.TradeTime ` sqlId.FormatParam(r.SPOTCONTRACTID) return sqlId.String() } // GetDataEx 从数据库中查询数据 func (r *Ermcppatradelinkdetail) GetDataEx() (interface{}, error) { e := db.GetEngine() s := e.SQL(r.buildSql()) sData := make([]Ermcppatradelinkdetail, 0) if err := s.Find(&sData); err != nil { return nil, err } for i := range sData { sData[i].calc() } return sData, nil } // InternalUncorrelatedTradeDetail 内部未关联成交单 type InternalUncorrelatedTradeDetail struct { LINKDETAILID string `json:"linkdetailid" xorm:"LINKDETAILID"` // 期货明细ID(614+Unix秒时间戳(10位)+xxxxxx) TRADEID string `json:"tradeid" xorm:"TRADEID" form:"tradeid"` // 成交单号 BUYORSELL int32 `json:"buyorsell" xorm:"BUYORSELL" form:"buyorsell"` // 方向 - 0:买 1:卖 HEDGEFLAG int32 `json:"hedgeflag" xorm:"HEDGEFLAG"` // 投机套保标志 - 0:无 1:投机 2:套保 3:套利 4:套期保值(平安\合同) 5:单边(平安) 6:移仓(平安) 7:错单处理(平安) 8:跨期套利(平安) 9:套期保值(计划) 10:套利(合同) 11:换月(合同) 12:交割(金瑞) 13:被套期项目 SPOTCONTRACTID int64 `json:"hedgeditemid" xorm:"SPOTCONTRACTID"` // 现货ID[套期项目ID] [13 - 被套期项目ID] [4,10,11 - 现货合同ID] [9 - 套保计划ID] RELATEDLOT float64 `json:"relatedlot" xorm:"RELATEDLOT"` // [数量]关联手数 GOODSID int32 `json:"goodsid" xorm:"GOODSID"` // 商品ID GOODSGROUPID int32 `json:"goodsgroupid" xorm:"GOODSGROUPID"` // 对冲品种ID[期货合约商品组ID] MIDDLEGOODSID int64 `json:"middlegoodsid" xorm:"MIDDLEGOODSID"` // 套保品种ID RELATEDQTY float64 `json:"relatedqty" xorm:"RELATEDQTY"` // [套期商品数量]关联数量 = RelatedLot * AgreeUnit * ConvertRatio TRADEDATE string `json:"tradedate" xorm:"TRADEDATE"` // 关联交易日(yyyyMMdd) RELATEDMODE int32 `json:"relatedmode" xorm:"RELATEDMODE"` // 关联方式 - 1:自动关联 2:手动关联 3:解绑关联 TRADETRADEDATE string `json:"tradetradedate" xorm:"TRADETRADEDATE"` // 成交交易日(yyyyMMdd) TRADEPRICE float64 `json:"tradeprice" xorm:"TRADEPRICE"` // 成交价 TRADELOT int64 `json:"tradelot" xorm:"TRADELOT"` // 成交手数 SALEUSERID int64 `json:"saleuserid" xorm:"SALEUSERID"` // 业务员ID BIZSUBJECTID int64 `json:"bizsubjectid" xorm:"BIZSUBJECTID"` // 归属业务部门ID - SubjectID AGREEUNIT float64 `json:"agreeunit" xorm:"AGREEUNIT"` // 合约乘数 CONVERTRATIO float64 `json:"convertratio" xorm:"CONVERTRATIO"` // 品种系数 AREAUSERID int64 `json:"areauserid" xorm:"AREAUSERID"` // 所属机构 CREATORSRC int32 `json:"creatorsrc" xorm:"CREATORSRC"` // 创建人来源 - 1:管理端 2:终端 3:交易 CREATORID int64 `json:"creatorid" xorm:"CREATORID"` // 创建人ID CREATETIME time.Time `json:"createtime" xorm:"CREATETIME"` // 创建时间 LINKSTATUS int32 `json:"linkstatus" xorm:"LINKSTATUS"` // 关联状态 - 1:成功 2:失败 3:解绑 RETCODE int32 `json:"retcode" xorm:"RETCODE"` // 返回码 TRADETIME string `json:"tradetime" xorm:"TRADETIME"` // 成交时间 ACCOUNTNAME string `json:"accountname" xorm:"ACCOUNTNAME" form:"accountname"` // 套期主体 ENABLEQTY float64 `json:"enableqty" xorm:"ENABLEQTY"` // 项目可关联手数 = 成交手数 - 关联数量 USERID int64 `json:"-" form:"userid" binding:"required"` // 用户编号 BEGINDATE string `json:"-" form:"begindate"` // 起始日期, 格式：yyyymmdd ENDDATE string `json:"-" form:"enddate"` // 终止日期, 格式：yyyymmdd GOODSCODE string `json:"goodscode" xorm:"GOODSCODE" form:"goodscode"` // 合约代码 GOODSNAME string `json:"goodsname" xorm:"GOODSNAME" form:"goodsname"` // 合约名称 } func (r *InternalUncorrelatedTradeDetail) calc() { } func (r *InternalUncorrelatedTradeDetail) buildSql() string { var sqlId utils.SQLVal = ` SELECT to_char(ept.TRADETIME, 'yyyy-mm-dd hh24:mi:ss') TRADETIME, ept.GOODSID, g.GOODSCODE, g.GOODSNAME, ept.BUYORSELL, ept.TRADEPRICE, ept.TRADELOT, ept.RELATEDQTY, ept.RELATEDLOT, ept.MIDDLEGOODSQTY, e.ENUMDICNAME, to_char(ept.TRADEID) TRADEID, ua.ACCOUNTNAME, ta.accountname TAACCOUNTNAME, ept.ACCOUNTID, (ept.TRADELOT - ept.RELATEDQTY) ENABLEQTY FROM ERMCP_PA_TRADELINK ept LEFT JOIN goods g ON ept.goodsid = g.goodsid LEFT JOIN taaccount ta ON ta.accountid = ept.accountid LEFT JOIN useraccount ua ON ta.userid = ua.userid LEFT JOIN enumdicitem e ON e.enumitemname = g.goodunitid AND e.enumdiccode = 'goodsunit' WHERE ept.tradelot > ept.relatedlot and ept.areauserid in (select u1.userid FROM useraccount u1 start with u1.userid = %v connect by prior u1.userid = u1.parentuserid) ` sqlId.FormatParam(r.USERID) if r.BEGINDATE != "" { sqlId.JoinFormat(" and to_char(ept.tradetime, 'yyyymmdd') >= '%v'", r.BEGINDATE) } if r.ENDDATE != "" { sqlId.JoinFormat(" and to_char(ept.tradetime, 'yyyymmdd') <= '%v'", r.ENDDATE) } sqlId.AndLike("g.goodscode", r.GOODSCODE) sqlId.AndLike("g.goodsname", r.GOODSNAME) sqlId.AndEx("ept.TRADEID", r.TRADEID, r.TRADEID != "") sqlId.AndEx("ept.BUYORSELL", r.BUYORSELL, r.BUYORSELL != -1) sqlId.AndLikes2("ta.accountname", "ta.accountid", r.ACCOUNTNAME) sqlId.OrderByDesc("ept.tradetime") return sqlId.String() } // GetDataEx 从数据库中查询数据 func (r *InternalUncorrelatedTradeDetail) GetDataEx() (interface{}, error) { e := db.GetEngine() s := e.SQL(r.buildSql()) sData := make([]InternalUncorrelatedTradeDetail, 0) if err := s.Find(&sData); err != nil { return nil, err } for i := range sData { sData[i].calc() } return sData, nil }