MTP20_IF/models/hsby.go

package models

import (
	"fmt"
	"math"
	"mtp2_if/db"
	"mtp2_if/utils"
	"strconv"
	"time"
)

// Hsbygoodsex 商品扩展表
type Hsbygoodsex struct {
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'" binding:"required"` // 商 品ID
	Hotindex       int32     `json:"hotindex"  xorm:"'HOTINDEX'"`                  // 景点热度
	Descprovinceid int64     `json:"descprovinceid"  xorm:"'DESCPROVINCEID'"`      // 目的地(省)
	Desccityid     int64     `json:"desccityid"  xorm:"'DESCCITYID'"`              // 目的地(市)
	Vendorid       int32     `json:"vendorid"  xorm:"'VENDORID'"`                  // 供应商ID
	Goodsdesc      string    `json:"goodsdesc"  xorm:"'GOODSDESC'"`                // 商品详情
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`              // 创建时间
	Creatorid      int64     `json:"creatorid"  xorm:"'CREATORID'"`                // 创建人
	Modifierid     int64     `json:"modifierid"  xorm:"'MODIFIERID'"`              // 修改人
	Modifytime     time.Time `json:"modifytime"  xorm:"'MODIFYTIME'"`              // 修改时间
	Memberratio    float64   `json:"memberratio"  xorm:"'MEMBERRATIO'"`            // 会员货款比例 [71]
	Videourls      string    `json:"videourls"  xorm:"'VIDEOURLS'"`                // 介绍视频[多张用逗号分隔]
	Picurls        string    `json:"picurls"  xorm:"'PICURLS'"`                    // 介绍图片[多张用逗号分隔]
}

// TableName is HSBY_GOODSEX
func (Hsbygoodsex) TableName() string {
	return "HSBY_GOODSEX"
}

// Hsbysupplierinfo 供应商表
type Hsbysupplierinfo struct {
	Vendorid    int32     `json:"vendorid"  xorm:"'VENDORID'" binding:"required"` // 供应商ID(SEQ_HSBY_SUPPLIERINFO)
	Vendorname  string    `json:"vendorname"  xorm:"'VENDORNAME'"`                // 名称描述客服电话名称
	Vendordesc  string    `json:"vendordesc"  xorm:"'VENDORDESC'"`                // 描述
	Vendorphone string    `json:"vendorphone"  xorm:"'VENDORPHONE'"`              // 客服电话
	Vendorattr  string    `json:"vendorattr"  xorm:"'VENDORATTR'"`                // 附件(多张，逗号分隔)
	Createtime  time.Time `json:"createtime"  xorm:"'CREATETIME'"`                // 创建时间
	Creatorid   int64     `json:"creatorid"  xorm:"'CREATORID'"`                  // 创建人
	Modifierid  int64     `json:"modifierid"  xorm:"'MODIFIERID'"`                // 修改人
	Modifytime  time.Time `json:"modifytime"  xorm:"'MODIFYTIME'"`                // 修改时间
}

// TableName is HSBY_SUPPLIERINFO
func (Hsbysupplierinfo) TableName() string {
	return "HSBY_SUPPLIERINFO"
}

// HsbyTopGoods 热卖商品（二级市场挂牌点选）
type HsbyTopGoods struct {
	Goodsid      int64  `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID(自增ID SEQ_GOODS)
	Goodscode    string `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64  `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Marketid     int64  `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Quoteminunit int64  `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]

	Hotindex  int32  `json:"hotindex"  xorm:"'HOTINDEX'"`   // 景点热度
	Videourls string `json:"videourls"  xorm:"'VIDEOURLS'"` // 介绍视频[多张用逗号分隔]
	Picurls   string `json:"picurls"  xorm:"'PICURLS'"`     // 介绍图片[多张用逗号分隔]

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Last    float64 `json:"last" xorm:"-"`    // 现价
	LotSize float64 `json:"lotsize" xorm:"-"` // 最小变动单位
}

// GetHsbyTopGoodses 获取热门商品列表
// 参数 marketIDs string 所属市场ID列表, 格式 1,2,3
// 参数 descProvinceID int 目标省ID
// 参数 descCityID int 目标城市ID
// 返回 []TopGoods 热门商品列表
// 返回 error error
func GetHsbyTopGoodses(marketIDs string, descProvinceID, descCityID int) ([]HsbyTopGoods, error) {
	// 热门商品为二级市场（挂牌点选）下的商品信息

	engine := db.GetEngine()

	topGoodses := make([]HsbyTopGoods, 0)
	// 获取挂牌商品信息，以及扩展表信息
	session := engine.Table("GOODS").
		Select(`GOODS.*, 
				HSBY_GOODSEX.HOTINDEX, HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS, 
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN`).
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Where(fmt.Sprintf("GOODS.GOODSSTATUS = 3 and GOODS.MARKETID in (%s)", marketIDs)) // 二级市场只获取 3:上市 状态的商品
	if descProvinceID > 0 {
		session = session.And("HSBY_GOODSEX.DESCPROVINCEID = ?", descProvinceID)
	}
	if descCityID > 0 {
		session = session.And("HSBY_GOODSEX.DESCCITYID = ?", descCityID)
	}
	if err := session.Find(&topGoodses); err != nil {
		return nil, err
	}
	if len(topGoodses) == 0 {
		// 无数据
		return topGoodses, nil
	}
	// 获取商品ID列表
	goodsCodes := ""
	for _, v := range topGoodses {
		if len(goodsCodes) == 0 {
			goodsCodes = v.Goodscode
		} else {
			goodsCodes += "," + v.Goodscode
		}
	}

	// 获取商品现价
	quoteDays, err := GetQuoteDays(goodsCodes)
	if err != nil {
		return nil, err
	}
	for i, g := range topGoodses {
		topGoods := &topGoodses[i]
		// FIXME: - 这里应该使用 Duck Typing，后期再处理
		// 计算最小变动单位
		lotSize := float64(topGoods.Quoteminunit) * math.Pow(0.1, float64(topGoods.Decimalplace))
		topGoods.LotSize, _ = strconv.ParseFloat(utils.FormatFloat(lotSize, int(topGoods.Decimalplace)), 64)

		for _, q := range quoteDays {
			if g.Goodscode == q.Goodscode {
				if q.Last != 0 {
					topGoods.Last = utils.IntToFloat64(int(q.Last), int(g.Decimalplace))
				}

				continue
			}
		}
	}

	return topGoodses, nil
}

// HsbyListingGoodsDetail 二级市场（挂牌点选）商品信息详情
type HsbyListingGoodsDetail struct {
	Goodsid      int64  `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID(自增ID SEQ_GOODS)
	Goodscode    string `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64  `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Marketid     int64  `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Quoteminunit int64  `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]

	Hotindex       int32  `json:"hotindex"  xorm:"'HOTINDEX'"`             // 景点热度
	Videourls      string `json:"videourls"  xorm:"'VIDEOURLS'"`           // 介绍视频[多张用逗号分隔]
	Picurls        string `json:"picurls"  xorm:"'PICURLS'"`               // 介绍图片[多张用逗号分隔]
	Descprovinceid int64  `json:"descprovinceid"  xorm:"'DESCPROVINCEID'"` // 目的地(省)ID
	Desccityid     int64  `json:"desccityid"  xorm:"'DESCCITYID'"`         // 目的地(市)ID
	Goodsdesc      string `json:"goodsdesc"  xorm:"'GOODSDESC'"`           // 商品详情

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Vendorname  string `json:"vendorname"  xorm:"'VENDORNAME'"`   // 供应商名称
	Vendorphone string `json:"vendorphone"  xorm:"'VENDORPHONE'"` // 供应商客服电话
	Vendorattr  string `json:"vendorattr"  xorm:"'VENDORATTR'"`   // 供应商附件(多张，逗号分隔)

	Last      float64 `json:"last" xorm:"-"`      // 现价
	Limitup   float64 `json:"limitup" xorm:"-"`   // 涨停价
	Limitdown float64 `json:"limitdown" xorm:"-"` // 跌停价
	LotSize   float64 `json:"lotsize" xorm:"-"`   // 最小变动单位
}

// GetHsbyListingGoodsDetail 获取二级市场（挂牌点选）商品信息详情
// 参数 goodsID int 目标商品ID
// 返回 *HsbyListingGoodsDetail 二级市场（挂牌点选）商品信息详情，查询无结果返回nil
// 返回 error error
func GetHsbyListingGoodsDetail(goodsID int) (*HsbyListingGoodsDetail, error) {
	engine := db.GetEngine()

	details := make([]HsbyListingGoodsDetail, 0)
	// 获取挂牌商品信息，以及扩展表信息
	// FIXME: - 这里使用Get方法，会造成SQL语句的嵌套出错，后期再研究
	session := engine.Table("GOODS").
		Select(`GOODS.GOODSID, GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.MARKETID, GOODS.QUOTEMINUNIT, 
				HSBY_GOODSEX.HOTINDEX, HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS, HSBY_GOODSEX.DESCPROVINCEID, HSBY_GOODSEX.Desccityid, HSBY_GOODSEX.Goodsdesc,
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME, HSBY_SUPPLIERINFO.VENDORPHONE, HSBY_SUPPLIERINFO.VENDORATTR`).
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Where("GOODS.GOODSID = ?", goodsID)
	if err := session.Find(&details); err != nil {
		return nil, err
	}
	// 无目标商品
	if len(details) == 0 {
		return nil, nil
	}
	hsbyListingGoodsDetail := details[0]

	// 获取商品现价和涨跌停价
	quoteDays, err := GetQuoteDays(hsbyListingGoodsDetail.Goodscode)
	if err != nil {
		return nil, err
	}
	if len(quoteDays) > 0 {
		if quoteDays[0].Last != 0 {
			hsbyListingGoodsDetail.Last = utils.IntToFloat64(int(quoteDays[0].Last), int(hsbyListingGoodsDetail.Decimalplace))
		}
		if quoteDays[0].Limitup != 0 {
			hsbyListingGoodsDetail.Limitup = utils.IntToFloat64(int(quoteDays[0].Limitup), int(hsbyListingGoodsDetail.Decimalplace))
		}
		if quoteDays[0].Limitdown != 0 {
			hsbyListingGoodsDetail.Limitdown = utils.IntToFloat64(int(quoteDays[0].Limitdown), int(hsbyListingGoodsDetail.Decimalplace))
		}
	}

	// FIXME: - 这里应该使用 Duck Typing，后期再处理
	// 计算最小变动单位
	lotSize := float64(hsbyListingGoodsDetail.Quoteminunit) * math.Pow(0.1, float64(hsbyListingGoodsDetail.Decimalplace))
	hsbyListingGoodsDetail.LotSize, _ = strconv.ParseFloat(utils.FormatFloat(lotSize, int(hsbyListingGoodsDetail.Decimalplace)), 64)

	return &hsbyListingGoodsDetail, nil
}

// HsbyGoodsOrderDetail 二级市场挂牌商品当前可摘委托单信息
type HsbyGoodsOrderDetail struct {
	Orderid    string    `json:"orderid"  xorm:"'ORDERID'" binding:"required"`     // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Buyorsell  int32     `json:"buyorsell"  xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖
	Ordertime  time.Time `json:"ordertime"  xorm:"'ORDERTIME'" binding:"required"` // 委托时间
	Orderprice float64   `json:"orderprice"  xorm:"'ORDERPRICE'"`                  // 委托价格
	Enableqty  int64     `json:"enableqty" xorm:"ENABLEQTY"`                       // 可用数量

	Customername string `json:"customername"  xorm:"'CUSTOMERNAME'"` // 客户名称(企业名称)，已脱敏

	Currencysign string `json:"currencysign" xorm:"-"` // 货币符号
	Goodunit     string `json:"goodunit"  xorm:"-"`    // 报价单位
}

// GetHsbyGoodsOrderDetails 获取二级市场（挂牌点选）商品对应的挂牌委托单信息
// 输入 goodsID int 商品ID
// 输入 buyOrSell int 委托单方向，0：买 1：卖
// 输入 price float64 参考价格。买方向委托单则价格大于等于（站在摘牌人的角度）；卖方向委托单则价格小于等于
// 输出 []HsbyGoodsOrderDetail 商品对应的挂牌委托单信息
// 输出 error error
func GetHsbyGoodsOrderDetails(goodsID, buyOrSell int, price float64) ([]HsbyGoodsOrderDetail, error) {
	engine := db.GetEngine()

	// 获取与目标商品相关的挂牌委托单信息（ListingSelectType = 1 or 3; OrderStatus =3 or 7）
	hsbyGoodsOrderDetails := make([]HsbyGoodsOrderDetail, 0)
	session := engine.Table("TRADE_ORDERDETAIL").
		Select(`to_char(TRADE_ORDERDETAIL.ORDERID) ORDERID, TRADE_ORDERDETAIL.BUYORSELL, TRADE_ORDERDETAIL.ORDERTIME, TRADE_ORDERDETAIL.ORDERPRICE, (TRADE_ORDERDETAIL.ORDERQTY - TRADE_ORDERDETAIL.TRADEQTY - TRADE_ORDERDETAIL.CANCELQTY) ENABLEQTY,
				substr(USERINFO.CUSTOMERNAME,0,1)||'****' as CUSTOMERNAME`).
		Join("LEFT", "TAACCOUNT", "TAACCOUNT.ACCOUNTID = TRADE_ORDERDETAIL.ACCOUNTID").
		Join("LEFT", "USERINFO", "USERINFO.USERID = TAACCOUNT.RELATEDUSERID").
		Where("(TRADE_ORDERDETAIL.LISTINGSELECTTYPE = 1 or TRADE_ORDERDETAIL.LISTINGSELECTTYPE = 3) and (TRADE_ORDERDETAIL.ORDERSTATUS = 3 or TRADE_ORDERDETAIL.ORDERSTATUS = 7)").
		And("TRADE_ORDERDETAIL.GOODSID = ?", goodsID).
		And("TRADE_ORDERDETAIL.BUYORSELL = ?", buyOrSell)
	if price > 0 {
		if buyOrSell == 0 {
			// 买方向委托单则价格大于等于（站在摘牌人的角度）
			session = session.And("TRADE_ORDERDETAIL.ORDERPRICE >= ?", price)
		} else {
			// 卖方向委托单则价格小于等于
			session = session.And("TRADE_ORDERDETAIL.ORDERPRICE <= ?", price)
		}
	}
	if err := session.Find(&hsbyGoodsOrderDetails); err != nil {
		return nil, err
	}

	// 获取商品货币符号和报价单位
	goods, err := GetGoods(goodsID)
	if err != nil {
		return nil, err
	}
	currencyEnums, err := GetEnumDicItem("currency", int(goods.Currencyid))
	if err != nil {
		return nil, err
	}
	currencysign := ""
	if len(currencyEnums) > 0 {
		currencysign = currencyEnums[0].Param2
	}
	goodsUnitEnums, err := GetEnumDicItem("goodsunit", int(goods.Goodunitid))
	if err != nil {
		return nil, err
	}
	goodsUnit := ""
	if len(goodsUnitEnums) > 0 {
		goodsUnit = goodsUnitEnums[0].Enumdicname
	}

	for i := range hsbyGoodsOrderDetails {
		orderDetail := &hsbyGoodsOrderDetails[i]

		// 设置货币符号和报价单位
		orderDetail.Currencysign = currencysign
		orderDetail.Goodunit = goodsUnit
	}

	return hsbyGoodsOrderDetails, nil
}

// HybsMyBuyOrderDetail 我的订单（一二级市场的买方向委托单）
type HybsMyBuyOrderDetail struct {
	Orderid           string    `json:"orderid"  xorm:"'ORDERID'" binding:"required"`     // 委托单号(100+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Marketid          int32     `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 市场ID
	Goodsid           int32     `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID
	Accountid         int64     `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"` // 账户ID[报价币种]
	Buyorsell         int32     `json:"buyorsell"  xorm:"'BUYORSELL'" binding:"required"` // 买卖 - 0:买 1:卖
	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'"`                    // 撤单数量
	Ordertime         time.Time `json:"ordertime"  xorm:"'ORDERTIME'" binding:"required"` // 委托时间
	Listingselecttype int32     `json:"listingselecttype"  xorm:"'LISTINGSELECTTYPE'"`    // 挂牌点选类型 - 1:挂牌 2:摘牌 3:先摘后挂
	Orderstatus       int32     `json:"orderstatus"  xorm:"'ORDERSTATUS'"`                // 委托状态 - 1： 委托请求 2：待冻结 3：委托成功 4： 委托失败 5：配对成功 6： 已撤销 7：部分成交 8：已成交 9：部成部撤 10：成交失败 11：已拒绝 12:经过摘牌(先摘后挂专用-先摘后挂已摘过) 13:冻结成功(通道交易专用) 14:通道已撤 15:通道部成部撤 16:成交失败违约(荷兰式竞拍专用)

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Picurls string `json:"picurls"  xorm:"'PICURLS'"` // 介绍图片[多张用逗号分隔]

	Trademode uint32 `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Vendorname string `json:"vendorname"  xorm:"'VENDORNAME'"` // 供应商名称

	MyBuyStatus int     `json:"mybuystatus" xorm:"-"` // "我的订单"显示状态- 1：抢购中 2：求购中 3：已完成 4：已撤消 5：委托失败
	Orderamount float64 `json:"" xorm:"-"`            // 委托金额
}

// GetHsbyBuyMyOrderDetails 获取“我的订单”数据（包括一二级市场）
// 输入 accountIDs string 资金账户列表
// 输入 myBuyStatus int "我的订单"状态, 1：抢购中 2：求购中 3：已完成
// 输出 []HybsMyBuyOrderDetail “我的订单”数据
// 输出 error error
func GetHsbyBuyMyOrderDetails(accountIDs string, myBuyStatus int) ([]HybsMyBuyOrderDetail, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	// 委托状态
	orderStatus := "0" // 单据状态，为0的时候查询全部
	marketID := 0      // 我的订单包括一二级市场的单据，目前暂时由服务直接报相关类型的第一个市场
	switch myBuyStatus {
	case 1: // 抢购中 (一级市场)
		// 获取市场ID
		for _, v := range markets {
			if v.Trademode == 71 { // 预售挂牌
				marketID = int(v.Marketid)
				break
			}
		}
		orderStatus = "3,7"
	case 2: // 求购中（二级市场）
		// 获取市场ID
		for _, v := range markets {
			if v.Trademode == 16 { // 挂牌点选
				marketID = int(v.Marketid)
				break
			}
		}
		orderStatus = "3,7"
	case 3: // 已完成
		orderStatus = "8,9"
	}

	hybsMyBuyOrderDetails := make([]HybsMyBuyOrderDetail, 0)
	session := engine.Table("TRADE_ORDERDETAIL").
		Select(`to_char(TRADE_ORDERDETAIL.ORDERID) ORDERID, TRADE_ORDERDETAIL.*, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN,
				HSBY_SUPPLIERINFO.VENDORNAME`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_ORDERDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TRADE_ORDERDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Where(fmt.Sprintf("TRADE_ORDERDETAIL.ACCOUNTID in (%s)", accountIDs))
	// 是否过滤市场（抢购中、求购中）
	if marketID > 0 {
		session = session.And("TRADE_ORDERDETAIL.MARKETID = ?", marketID)
	}
	// 是否过滤状态（抢购中、求购中、已完成）
	if orderStatus != "0" {
		session = session.And(fmt.Sprintf("TRADE_ORDERDETAIL.ORDERSTATUS in (%s)", orderStatus))
	}
	if err := session.Find(&hybsMyBuyOrderDetails); err != nil {
		return nil, err
	}

	// 设置“我的订单”显示状态
	for i := range hybsMyBuyOrderDetails {
		detail := &hybsMyBuyOrderDetails[i]

		// 委托金额 = 委托价格 * 委托数量 * 合约单位
		detail.Orderamount = detail.Orderprice * float64(detail.Orderqty) * float64(detail.Agreeunit)

		if detail.Trademode == 71 && (detail.Orderstatus == 3 || detail.Orderstatus == 7) {
			// 抢购中
			detail.MyBuyStatus = 1
		} else if detail.Trademode == 16 && (detail.Orderstatus == 3 || detail.Orderstatus == 7) {
			// 求购中
			detail.MyBuyStatus = 2
		} else if detail.Orderstatus == 8 || detail.Orderstatus == 9 {
			// 已完成
			detail.MyBuyStatus = 3
		} else if detail.Orderstatus == 6 {
			// 已撤销
			detail.MyBuyStatus = 4
		} else if detail.Orderstatus == 4 {
			// 委托失败
			detail.MyBuyStatus = 5
		}
	}

	return hybsMyBuyOrderDetails, nil
}

// HsbyMyGoods 我的商品（买方向持仓）
type HsbyMyGoods struct {
	Accountid          int64   `json:"accountid"  xorm:"'ACCOUNTID'" binding:"required"` // 账号Id
	Goodsid            int32   `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品Id
	Buycurpositionqty  int64   `json:"buycurpositionqty"  xorm:"'BUYCURPOSITIONQTY'"`    // 买当前持仓总数量
	Buycurholderamount float64 `json:"buycurholderamount"  xorm:"'BUYCURHOLDERAMOUNT'"`  // 买当前持仓总金额[商品币种]

	Goodscode    string  `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string  `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64   `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	Picurls string `json:"picurls"  xorm:"'PICURLS'"` // 介绍图片[多张用逗号分隔]

	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Buyaverageprice float64 `json:"buyaverageprice" xorm:"-"` // 持仓均价
}

// GetHsbyMyGoods 获取“我的商品”信息
// 输入 accountIDs string 资金账户列表，格式 1,2,3
// 输出 []HsbyMyGoods “我的商品”信息
// 输入 error error
func GetHsbyMyGoods(accountIDs string) ([]HsbyMyGoods, error) {
	engine := db.GetEngine()

	hsbyMyGoodses := make([]HsbyMyGoods, 0)
	// 此定制版本，只查询出当前手数（期末）大于0的数据 （TRADEPOSITION.BUYCURPOSITIONQTY > 0）
	if err := engine.Table("TRADEPOSITION").
		Select(`TRADEPOSITION.*, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADEPOSITION.GOODSID").
		Join("INNER", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Where(fmt.Sprintf("TRADEPOSITION.BUYCURPOSITIONQTY > 0 and TRADEPOSITION.ACCOUNTID in (%s)", accountIDs)).Find(&hsbyMyGoodses); err != nil {
		return nil, err
	}

	// 计算持仓均价
	for i := range hsbyMyGoodses {
		myGoods := &hsbyMyGoodses[i]

		averagePrice := myGoods.Buycurholderamount / float64(myGoods.Buycurpositionqty) / myGoods.Agreeunit
		myGoods.Buyaverageprice, _ = strconv.ParseFloat(utils.FormatFloat(averagePrice, int(myGoods.Decimalplace)), 64)
	}

	return hsbyMyGoodses, nil
}

// HsbyPreGoods 新品上市商品（一级市场产能预售）
type HsbyPreGoods struct {
	Goodsid      int64  `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID(自增ID SEQ_GOODS)
	Goodscode    string `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64  `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Marketid     int64  `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Goodsstatus  int64  `json:"goodsstatus"  xorm:"'GOODSSTATUS'"`                // 商品状态- 2:未上市 3:上市
	Quoteminunit int64  `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]

	Relatedgoodsid int64     `json:"relatedgoodsid"  xorm:"'RELATEDGOODSID'"` // 关联交易合约ID
	Presaleqty     int64     `json:"presaleqty"  xorm:"'PRESALEQTY'"`         // 预售数量
	Starttime      time.Time `json:"starttime"  xorm:"'STARTTIME'"`           // 预售开始时间
	Endtime        time.Time `json:"endtime"  xorm:"'ENDTIME'"`               // 预售结束时间
	Refprice       float64   `json:"refprice"  xorm:"'REFPRICE'"`             // 参考价格[一口价]

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号

	Videourls string `json:"videourls"  xorm:"'VIDEOURLS'"` // 介绍视频[多张用逗号分隔]
	Picurls   string `json:"picurls"  xorm:"'PICURLS'"`     // 介绍图片[多张用逗号分隔]

	LotSize float64 `json:"lotsize" xorm:"-"` // 最小变动单位
}

// GetHsbyPreGoodses 获取“新品上市”商品列表（一级市场产能预售）
// 输入 marketIDs string 市场ID列表，格式 1,2,3
// 输入 descProvinceID int 省ID
// 输入 descCityID int 市ID
// 输出 []HsbyPreGoods “新品上市”商品列表
// 输出 error error
func GetHsbyPreGoodses(marketIDs string, descProvinceID, descCityID int) ([]HsbyPreGoods, error) {
	engine := db.GetEngine()

	// 注意：一级产能预售市场使用的商品实际上是和二级市场有关系的，所以要使用 CPTRADE_PRESALEGOODSEX.RELATEDGOODSID 进行关联
	preGoodses := make([]HsbyPreGoods, 0)
	session := engine.Table("GOODS").
		Select(`GOODS.*, 
				CPTRADE_PRESALEGOODSEX.RELATEDGOODSID, CPTRADE_PRESALEGOODSEX.PRESALEQTY, 
				CPTRADE_PRESALEGOODSEX.STARTTIME, CPTRADE_PRESALEGOODSEX.ENDTIME, CPTRADE_PRESALEGOODSEX.REFPRICE, 
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS`).
		Join("INNER", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Where(fmt.Sprintf("GOODS.GOODSSTATUS in (2,3) and GOODS.MARKETID in (%s)", marketIDs)) // 一级市场获取 2:未上市 3:上市 状态的商品
	if descProvinceID > 0 {
		session = session.And("HSBY_GOODSEX.DESCPROVINCEID = ?", descProvinceID)
	}
	if descCityID > 0 {
		session = session.And("HSBY_GOODSEX.DESCCITYID = ?", descCityID)
	}
	if err := session.Find(&preGoodses); err != nil {
		return nil, err
	}

	for i := range preGoodses {
		preGoods := &preGoodses[i]

		// FIXME: - 这里应该使用 Duck Typing，后期再处理
		// 计算最小变动单位
		lotSize := float64(preGoods.Quoteminunit) * math.Pow(0.1, float64(preGoods.Decimalplace))
		preGoods.LotSize, _ = strconv.ParseFloat(utils.FormatFloat(lotSize, int(preGoods.Decimalplace)), 64)
	}

	return preGoodses, nil
}

// HsbyPreGoodsDetail 一级市场（产能预售）商品信息详情
type HsbyPreGoodsDetail struct {
	Goodsid      int64  `json:"goodsid"  xorm:"'GOODSID'" binding:"required"`     // 商品ID(自增ID SEQ_GOODS)
	Goodscode    string `json:"goodscode"  xorm:"'GOODSCODE'" binding:"required"` // 商品代码(内部)
	Goodsname    string `json:"goodsname"  xorm:"'GOODSNAME'" binding:"required"` // 商品名称
	Decimalplace int64  `json:"decimalplace"  xorm:"'DECIMALPLACE'"`              // 报价小数位
	Marketid     int64  `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 所属市场ID
	Goodsstatus  int64  `json:"goodsstatus"  xorm:"'GOODSSTATUS'"`                // 商品状态- 2:未上市 3:上市
	Quoteminunit int64  `json:"quoteminunit"  xorm:"'QUOTEMINUNIT'"`              // 行情最小变动单位 [整数，报价小数位一起使用]

	Relatedgoodsid int64     `json:"relatedgoodsid"  xorm:"'RELATEDGOODSID'"` // 关联交易合约ID
	Presaleqty     int64     `json:"presaleqty"  xorm:"'PRESALEQTY'"`         // 预售数量
	Starttime      time.Time `json:"starttime"  xorm:"'STARTTIME'"`           // 预售开始时间
	Endtime        time.Time `json:"endtime"  xorm:"'ENDTIME'"`               // 预售结束时间
	Refprice       float64   `json:"refprice"  xorm:"'REFPRICE'"`             // 参考价格[一口价]

	Videourls      string `json:"videourls"  xorm:"'VIDEOURLS'"`           // 介绍视频[多张用逗号分隔]
	Picurls        string `json:"picurls"  xorm:"'PICURLS'"`               // 介绍图片[多张用逗号分隔]
	Descprovinceid int64  `json:"descprovinceid"  xorm:"'DESCPROVINCEID'"` // 目的地(省)ID
	Desccityid     int64  `json:"desccityid"  xorm:"'DESCCITYID'"`         // 目的地(市)ID
	Goodsdesc      string `json:"goodsdesc"  xorm:"'GOODSDESC'"`           // 商品详情

	Currency     string `json:"currency" xorm:"'CURRENCY'"`         // 货币
	Currencysign string `json:"currencysign" xorm:"'CURRENCYSIGN'"` // 货币符号
	Goodunit     string `json:"goodunit"  xorm:"GOODUNIT"`          // 报价单位

	Vendorname  string `json:"vendorname"  xorm:"'VENDORNAME'"`   // 供应商名称
	Vendorphone string `json:"vendorphone"  xorm:"'VENDORPHONE'"` // 供应商客服电话
	Vendorattr  string `json:"vendorattr"  xorm:"'VENDORATTR'"`   // 供应商附件(多张，逗号分隔)

	LotSize float64 `json:"lotsize" xorm:"-"` // 最小变动单位
}

// GetHsbyPreGoodsDetail 获取一级市场（产能预售）商品信息详情
// 参数 goodsID int 目标商品ID
// 返回 *HsbyListingGoodsDetail 二级市场（挂牌点选）商品信息详情，查询无结果返回nil
// 返回 error error
func GetHsbyPreGoodsDetail(goodsID int) (*HsbyPreGoodsDetail, error) {
	engine := db.GetEngine()

	details := make([]HsbyPreGoodsDetail, 0)
	// 获取挂牌商品信息，以及扩展表信息
	// FIXME: - 这里使用Get方法，会造成SQL语句的嵌套出错，后期再研究
	session := engine.Table("GOODS").
		Select(`GOODS.*, 
				CPTRADE_PRESALEGOODSEX.RELATEDGOODSID, CPTRADE_PRESALEGOODSEX.PRESALEQTY, 
				CPTRADE_PRESALEGOODSEX.STARTTIME, CPTRADE_PRESALEGOODSEX.ENDTIME, CPTRADE_PRESALEGOODSEX.REFPRICE, 
				HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS, HSBY_GOODSEX.DESCPROVINCEID, HSBY_GOODSEX.Desccityid, HSBY_GOODSEX.Goodsdesc,
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				E1.ENUMDICNAME GOODUNIT, 
				HSBY_SUPPLIERINFO.VENDORNAME, HSBY_SUPPLIERINFO.VENDORPHONE, HSBY_SUPPLIERINFO.VENDORATTR`).
		Join("INNER", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "ENUMDICITEM E1", "E1.ENUMITEMNAME = GOODS.GOODUNITID and E1.ENUMDICCODE = 'goodsunit'").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Where("GOODS.GOODSID = ?", goodsID)
	if err := session.Find(&details); err != nil {
		return nil, err
	}
	// 无目标商品
	if len(details) == 0 {
		return nil, nil
	}
	preGoodsDetail := details[0]

	// FIXME: - 这里应该使用 Duck Typing，后期再处理
	// 计算最小变动单位
	lotSize := float64(preGoodsDetail.Quoteminunit) * math.Pow(0.1, float64(preGoodsDetail.Decimalplace))
	preGoodsDetail.LotSize, _ = strconv.ParseFloat(utils.FormatFloat(lotSize, int(preGoodsDetail.Decimalplace)), 64)

	return &preGoodsDetail, nil
}