MTP20_IF/models/ermcp8.go

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
		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
	`
	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
}