MTP20_IF/models/hsby.go

package models

import (
	"encoding/hex"
	"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"
}

// Tradepayorder 交易待付款表
type Tradepayorder struct {
	Tradeid        int64     `json:"tradeid"  xorm:"'TRADEID'" binding:"required"` // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Tradedate      string    `json:"tradedate"  xorm:"'TRADEDATE'"`                // 交易日(yyyyMMdd)
	Marketid       int32     `json:"marketid"  xorm:"'MARKETID'"`                  // 市场ID
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'"`                    // 商品ID
	Buyorderid     int64     `json:"buyorderid"  xorm:"'BUYORDERID'"`              // 买方委托单号
	Buyaccountid   int64     `json:"buyaccountid"  xorm:"'BUYACCOUNTID'"`          // 买方账号ID[报价币种]
	Sellorderid    int64     `json:"sellorderid"  xorm:"'SELLORDERID'"`            // 卖方委托单号
	Sellaccountid  int64     `json:"sellaccountid"  xorm:"'SELLACCOUNTID'"`        // 卖方账号ID[报价币种]
	Tradeamount    float64   `json:"tradeamount"  xorm:"'TRADEAMOUNT'"`            // 成交金额
	Tradecharge    float64   `json:"tradecharge"  xorm:"'TRADECHARGE'"`            // 成交手续费(买方)
	Payflag        int32     `json:"payflag"  xorm:"'PAYFLAG'"`                    // 付款标识 - 1:未支付 2:已支付 3:已过期 4:已撤销 5:结算过期 6:预售终止
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`              // 创建时间
	Paytime        time.Time `json:"paytime"  xorm:"'PAYTIME'"`                    // 付款时间
	Paylimitedtime time.Time `json:"paylimitedtime"  xorm:"'PAYLIMITEDTIME'"`      // 支付期限
	Offamount      float64   `json:"offamount"  xorm:"'OFFAMOUNT'"`                // 优惠金额
	Tradeprice     float64   `json:"tradeprice"  xorm:"'TRADEPRICE'"`              // 成交价格
	Tradeqty       int64     `json:"tradeqty"  xorm:"'TRADEQTY'"`                  // 成交数量
	Payamount      float64   `json:"payamount"  xorm:"'PAYAMOUNT'"`                // 支付金额 = TradeAmount + TradeCharge - OffAmount
}

// TableName is TRADE_PAYORDER
func (Tradepayorder) TableName() string {
	return "TRADE_PAYORDER"
}

// 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'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	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'"` // 货币符号

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

	Last float64 `json:"last" 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, 
				MARKET.TRADEMODE`).
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMNAME = GOODS.CURRENCYID and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = GOODS.MARKETID").
		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))
				}
				// 没有现价则尝试用昨结
				if topGoods.Last == 0 && q.Presettle != 0 {
					topGoods.Last = utils.IntToFloat64(int(q.Presettle), 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'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit    float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位

	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'"`   // 供应商附件(多张，逗号分隔)

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

	Last      float64 `json:"last" xorm:"-"`      // 现价
	Limitup   float64 `json:"limitup" xorm:"-"`   // 涨停价
	Limitdown float64 `json:"limitdown" xorm:"-"` // 跌停价
	StepValue float64 `json:"stepvalue" xorm:"-"` // 价格最小变动单位
	LotSize   int     `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, GOODS.AGREEUNIT, 
				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, 
				MARKET.TRADEMODE`).
		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").
		Join("LEFT", "MARKET", "MARKET.MARKETID = GOODS.MARKETID").
		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 hsbyListingGoodsDetail.Last == 0 && quoteDays[0].Presettle != 0 {
			hsbyListingGoodsDetail.Last = utils.IntToFloat64(int(quoteDays[0].Presettle), 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))
		}
	}

	// 计算价格最小变动单位
	stepValue := float64(hsbyListingGoodsDetail.Quoteminunit) * math.Pow(0.1, float64(hsbyListingGoodsDetail.Decimalplace))
	hsbyListingGoodsDetail.StepValue, _ = strconv.ParseFloat(utils.FormatFloat(stepValue, int(hsbyListingGoodsDetail.Decimalplace)), 64)

	// 计算手数最小变动单位
	hsbyListingGoodsDetail.LotSize = 1

	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, accountIDs string) ([]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 len(accountIDs) > 0 {
		session = session.And(fmt.Sprintf("TRADE_ORDERDETAIL.ACCOUNTID not in (%s)", accountIDs))
	}
	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'"`                    // 合约单位

	Picurls1 string `json:"picurls1"  xorm:"'PICURLS1'"` // 预售商品介绍图片[多张用逗号分隔]
	Picurls2 string `json:"picurls2"  xorm:"'PICURLS2'"` // 挂牌商品介绍图片[多张用逗号分隔]

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

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

	Vendorname1 string `json:"vendorname1"  xorm:"'VENDORNAME1'"` // 预售商品供应商名称
	Vendorname2 string `json:"vendorname2"  xorm:"'VENDORNAME2'"` // 挂牌商品供应商名称

	MyBuyStatus int     `json:"mybuystatus" xorm:"-"` // "我的订单"显示状态- 1：抢购中 2：求购中 3：已完成 4：已撤消 5：委托失败
	Orderamount float64 `json:"orderamount" 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的时候查询全部
	marketIDs := ""    // 我的订单包括一二级市场的单据
	switch myBuyStatus {
	case 1: // 抢购中 (一级市场)
		// 获取市场ID
		for _, v := range markets {
			if v.Trademode == 71 { // 预售挂牌
				if len(marketIDs) == 0 {
					marketIDs = strconv.Itoa(int(v.Marketid))
				} else {
					marketIDs += "," + strconv.Itoa(int(v.Marketid))
				}
			}
		}
		orderStatus = "3,7"
	case 2: // 求购中（二级市场）
		// 获取市场ID
		for _, v := range markets {
			if v.Trademode == 16 { // 挂牌点选
				if len(marketIDs) == 0 {
					marketIDs = strconv.Itoa(int(v.Marketid))
				} else {
					marketIDs += "," + strconv.Itoa(int(v.Marketid))
				}
			}
		}
		orderStatus = "3,7"
	case 3: // 已完成
		orderStatus = "8,9"
	}
	// 默认取 TradeMode = 16 or 71 的市场
	if len(marketIDs) == 0 {
		for _, v := range markets {
			if v.Trademode == 16 || v.Trademode == 71 {
				if len(marketIDs) == 0 {
					marketIDs = strconv.Itoa(int(v.Marketid))
				} else {
					marketIDs += "," + strconv.Itoa(int(v.Marketid))
				}
			}
		}
	}

	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, 
				HG1.PICURLS PICURLS1, 
				HG2.PICURLS PICURLS2, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN,
				HS1.VENDORNAME VENDORNAME1, 
				HS2.VENDORNAME VENDORNAME2`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_ORDERDETAIL.GOODSID").
		Join("LEFT", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = TRADE_ORDERDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG1", "HG1.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "HSBY_GOODSEX HG2", "HG2.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 HS1", "HS1.VENDORID = HG1.VENDORID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS2", "HS2.VENDORID = HG2.VENDORID").
		Where(fmt.Sprintf("TRADE_ORDERDETAIL.BUYORSELL = 0 and TRADE_ORDERDETAIL.ACCOUNTID in (%s)", accountIDs)).
		And(fmt.Sprintf("TRADE_ORDERDETAIL.MARKETID in (%s)", marketIDs))
	// 是否过滤状态（抢购中、求购中、已完成）
	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'"`  // 买当前持仓总金额[商品币种]
	EnableQty          int64   `json:"enableqty" xorm:"'ENABLEQTY'"`                     // 可用数量

	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'"`                    // 合约单位
	Goodsstatus  int64   `json:"goodsstatus"  xorm:"'GOODSSTATUS'"`                // 商品状态- 1:待审核 2:未上市 3:上市 4:已注销 5:审核拒绝 6:退市 7:待退市

	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.*, (TRADEPOSITION.BUYCURPOSITIONQTY - TRADEPOSITION.BUYFROZENQTY - TRADEPOSITION.BUYOTHERFROZENQTY) ENABLEQTY, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, GOODS.GOODSSTATUS, 
				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'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit     float64   `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位
	Listingdate   time.Time `json:"listingdate"  xorm:"'LISTINGDATE'"`                // 交易开始日期
	Lasttradedate time.Time `json:"lasttradedate"  xorm:"'LASTTRADEDATE'"`            // 最后交易日期(状态：待退市)

	Relatedgoodsid int64   `json:"relatedgoodsid"  xorm:"'RELATEDGOODSID'"` // 关联交易合约ID
	Presaleqty     int64   `json:"presaleqty"  xorm:"'PRESALEQTY'"`         // 预售数量
	Refprice       float64 `json:"refprice"  xorm:"'REFPRICE'"`             // 参考价格[一口价]
	Presaledqty    int64   `json:"presaledqty"  xorm:"'PRESALEDQTY'"`       // 已预售量(预售结束时更新)
	EnableQty      int64   `json:"enableqty" xorm:"ENABLEQTY"`              // 剩余数量

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

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

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

// 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 进行关联
	// 注意：CPTRADE_PRESALEGOODSEX 表的开始与结束时间是给大宗用的
	preGoodses := make([]HsbyPreGoods, 0)
	session := engine.Table("GOODS").
		Select(`GOODS.*, 
				CPTRADE_PRESALEGOODSEX.RELATEDGOODSID, CPTRADE_PRESALEGOODSEX.PRESALEQTY, CPTRADE_PRESALEGOODSEX.REFPRICE, 
				CPTRADE_PRESALEGOODSEX.PRESALEDQTY, (CPTRADE_PRESALEGOODSEX.PRESALEQTY - CPTRADE_PRESALEGOODSEX.PRESALEDQTY) ENABLEQTY, 
				ENUMDICITEM.ENUMDICNAME CURRENCY, ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_GOODSEX.VIDEOURLS, HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE`).
		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").
		Join("LEFT", "MARKET", "MARKET.MARKETID = GOODS.MARKETID").
		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'"`              // 行情最小变动单位 [整数，报价小数位一起使用]
	Agreeunit     float64   `json:"agreeunit"  xorm:"'AGREEUNIT'"`                    // 合约单位
	Listingdate   time.Time `json:"listingdate"  xorm:"'LISTINGDATE'"`                // 交易开始日期
	Lasttradedate time.Time `json:"lasttradedate"  xorm:"'LASTTRADEDATE'"`            // 最后交易日期(状态：待退市)

	Relatedgoodsid int64   `json:"relatedgoodsid"  xorm:"'RELATEDGOODSID'"` // 关联交易合约ID
	Presaleqty     int64   `json:"presaleqty"  xorm:"'PRESALEQTY'"`         // 预售数量
	Refprice       float64 `json:"refprice"  xorm:"'REFPRICE'"`             // 参考价格[一口价]
	Presaledqty    int64   `json:"presaledqty"  xorm:"'PRESALEDQTY'"`       // 已预售量(预售结束时更新)
	EnableQty      int64   `json:"enableqty" xorm:"ENABLEQTY"`              // 剩余数量

	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'"`   // 供应商附件(多张，逗号分隔)

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

	Customername string `json:"customername" xorm:"'CUSTOMERNAME'"` // 发行单位

	StepValue float64 `json:"stepvalue" xorm:"-"`    // 价格最小变动单位
	LotSize   int     `json:"lotsize" xorm:"-"`      // 手数最小变动单位
	Buymaxqty int     `json:"buymaxqty"  xorm:"'-'"` // 购买上限 [71] - 0为不限
}

// GetHsbyPreGoodsDetail 获取一级市场（产能预售）商品信息详情
// 参数 goodsID int 目标商品ID
// 返回 *HsbyListingGoodsDetail 二级市场（挂牌点选）商品信息详情，查询无结果返回nil
// 返回 error error
func GetHsbyPreGoodsDetail(goodsID, accountID 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.REFPRICE, 
				CPTRADE_PRESALEGOODSEX.PRESALEDQTY, (CPTRADE_PRESALEGOODSEX.PRESALEQTY - CPTRADE_PRESALEGOODSEX.PRESALEDQTY) ENABLEQTY, 
				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, 
				MARKET.TRADEMODE, 
				USERINFO.CUSTOMERNAME`).
		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").
		Join("LEFT", "MARKET", "MARKET.MARKETID = GOODS.MARKETID").
		Join("LEFT", "USERINFO", "USERINFO.USERID = CPTRADE_PRESALEGOODSEX.USERID").
		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，后期再处理
	// 计算价格最小变动单位
	stepValue := float64(preGoodsDetail.Quoteminunit) * math.Pow(0.1, float64(preGoodsDetail.Decimalplace))
	preGoodsDetail.StepValue, _ = strconv.ParseFloat(utils.FormatFloat(stepValue, int(preGoodsDetail.Decimalplace)), 64)

	// 计算手数最小变动单位，一级市场固定为1
	preGoodsDetail.LotSize = 1

	// 获取购买上限
	if accountID != 0 {
		buyMaxQty, err := GetCPTradeBuyLimit(goodsID, accountID)
		if err != nil {
			return nil, err
		}
		preGoodsDetail.Buymaxqty = buyMaxQty
	}

	return &preGoodsDetail, nil
}

// HsbySellMyDetail "我的闲置"单据信息（发布中 - 二级市场卖挂，3：委托成功、7：部分成交; 已完成 - 二级市场成交单，包括历史数据）
type HsbySellMyDetail struct {
	Orderid   string    `json:"orderid"  xorm:"'ORDERID'" binding:"required"`     // 单号（发布中 - 委托单号；已完成 - 成交单号）
	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:卖
	Price     float64   `json:"price"  xorm:"'PRICE'"`                            // 价格
	Qty       int64     `json:"qty"  xorm:"'QTY'" binding:"required"`             // 数量
	Time      time.Time `json:"time"  xorm:"'TIME'" binding:"required"`           // 时间
	Amount    float64   `json:"amount" xorm:"'AMOUNT'"`                           // 金额 = 价格 * 数量 * 合约单位

	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'"` // 供应商名称

	OrderType int32 `json:"ordertype" xorm:"'ORDERTYPE'"` // 单据类型：0 - 发布中, 1 - 已完成

	PayedCount int `json:"payedcount" xorm:"PAYEDCOUNT"` // 已付款数量
	UnPayCount int `json:"unPayCount" xorm:"UNPAYCOUNT"` // 待付款数量
}

// GetHsbySellMyOrderDetails 获取"我的闲置 - 发布中"单据信息
// 输入 accountIDs string 资金账户列表
// 输出 []HsbySellMyDetail "我的闲置 - 发布中"单据信息
// 输出 error error
func GetHsbySellMyOrderDetails(accountIDs string) ([]HsbySellMyDetail, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := "" // 我的闲置-发布中： 二级市场卖挂牌
	// 默认取 TradeMode = 16
	for _, v := range markets {
		if v.Trademode == 16 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orderDetails := make([]HsbySellMyDetail, 0)
	// “我的闲置 - 发布中”都是卖挂委托
	session := engine.Table("TRADE_ORDERDETAIL").
		Select(`to_char(TRADE_ORDERDETAIL.ORDERID) ORDERID, 
				TRADE_ORDERDETAIL.MARKETID, TRADE_ORDERDETAIL.GOODSID, TRADE_ORDERDETAIL.ACCOUNTID, TRADE_ORDERDETAIL.BUYORSELL,
				TRADE_ORDERDETAIL.ORDERPRICE PRICE, TRADE_ORDERDETAIL.ORDERQTY QTY, TRADE_ORDERDETAIL.ORDERTIME TIME, 
				(TRADE_ORDERDETAIL.ORDERPRICE * TRADE_ORDERDETAIL.ORDERQTY * GOODS.AGREEUNIT) AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME, 
				0 ORDERTYPE, 
				(select count(TR1.TRADEID) from TRADE_PAYORDER TR1 where TR1.PAYFLAG = 2 and TR1.TRADEID = TD.TRADEID) PAYEDCOUNT, 
				(select count(TR2.TRADEID) from TRADE_PAYORDER TR2 where TR2.PAYFLAG = 1 and TR2.TRADEID = TD.TRADEID) UNPAYCOUNT`).
		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").
		Join("LEFT", "TRADE_TRADEDETAIL TD", "TD.ORDERID = TRADE_ORDERDETAIL.ORDERID").
		Where(fmt.Sprintf(`TRADE_ORDERDETAIL.BUYORSELL = 1 and TRADE_ORDERDETAIL.LISTINGSELECTTYPE = 1 and (TRADE_ORDERDETAIL.ORDERSTATUS = 3 or TRADE_ORDERDETAIL.ORDERSTATUS = 7) 
						   and TRADE_ORDERDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TRADE_ORDERDETAIL.MARKETID in (%s)", marketIDs))
	if err := session.Find(&orderDetails); err != nil {
		return nil, err
	}

	return orderDetails, nil
}

// GetHsbySellMyTradeDetails 获取"我的闲置 - 已完成"单据信息
// 输入 accountIDs string 资金账户列表
// 输出 []HsbySellMyDetail "我的闲置 - 已完成"单据信息
// 输出 error error
func GetHsbySellMyTradeDetails(accountIDs string) ([]HsbySellMyDetail, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := "" // 我的闲置-发布中： 二级市场卖方向成交单（包括历史成交单）
	// 默认取 TradeMode = 16
	for _, v := range markets {
		if v.Trademode == 16 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orders := make([]HsbySellMyDetail, 0)

	// 当前成交单
	curOrders := make([]HsbySellMyDetail, 0)
	if err := engine.Table("TRADE_TRADEDETAIL").
		Select(`to_char(TRADE_TRADEDETAIL.TRADEID) ORDERID, 
				TRADE_TRADEDETAIL.MARKETID, TRADE_TRADEDETAIL.GOODSID, TRADE_TRADEDETAIL.ACCOUNTID, TRADE_TRADEDETAIL.BUYORSELL,
				TRADE_TRADEDETAIL.TRADEPRICE PRICE, TRADE_TRADEDETAIL.TRADEQTY QTY, TRADE_TRADEDETAIL.TRADETIME TIME, TRADE_TRADEDETAIL.TRADEAMOUNT AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME, 
				1 ORDERTYPE`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_TRADEDETAIL.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_TRADEDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Where(fmt.Sprintf(`TRADE_TRADEDETAIL.BUYORSELL = 1 
						   and TRADE_TRADEDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TRADE_TRADEDETAIL.MARKETID in (%s)", marketIDs)).Find(&curOrders); err != nil {
		return nil, err
	}
	if len(curOrders) > 0 {
		orders = append(orders, curOrders...)
	}

	// 历史成交单
	hisOrders := make([]HsbySellMyDetail, 0)
	if err := engine.Table("HIS_TRADE_TRADEDETAIL").
		Select(`to_char(HIS_TRADE_TRADEDETAIL.TRADEID) ORDERID, 
				HIS_TRADE_TRADEDETAIL.MARKETID, HIS_TRADE_TRADEDETAIL.GOODSID, HIS_TRADE_TRADEDETAIL.ACCOUNTID, HIS_TRADE_TRADEDETAIL.BUYORSELL,
				HIS_TRADE_TRADEDETAIL.TRADEPRICE PRICE, HIS_TRADE_TRADEDETAIL.TRADEQTY QTY, HIS_TRADE_TRADEDETAIL.TRADETIME TIME, HIS_TRADE_TRADEDETAIL.TRADEAMOUNT AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME, 
				1 ORDERTYPE`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = HIS_TRADE_TRADEDETAIL.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 = HIS_TRADE_TRADEDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Where(fmt.Sprintf(`HIS_TRADE_TRADEDETAIL.BUYORSELL = 1 and HIS_TRADE_TRADEDETAIL.ISVALIDDATA = 1 
						   and HIS_TRADE_TRADEDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("HIS_TRADE_TRADEDETAIL.MARKETID in (%s)", marketIDs)).Find(&hisOrders); err != nil {
		return nil, err
	}
	if len(hisOrders) > 0 {
		orders = append(orders, hisOrders...)
	}

	return orders, nil
}

// HsbyMyPackage 我的包裹信息
type HsbyMyPackage struct {
	Takeorderid     string    `json:"takeorderid"  xorm:"'TAKEORDERID'" binding:"required"` // 提货单号(905+Unix秒时间戳(10位)+xxxxxx)
	Accountid       int64     `json:"accountid"  xorm:"'ACCOUNTID'"`                        // 账户ID
	Goodsid         int64     `json:"goodsid"  xorm:"'GOODSID'"`                            // 商品ID
	Userid          int64     `json:"userid"  xorm:"'USERID'"`                              // 用户ID
	Qty             float64   `json:"qty"  xorm:"'QTY'"`                                    // 提货数量
	Reqtime         time.Time `json:"reqtime"  xorm:"'REQTIME'"`                            // 更新时间
	Recivername     string    `json:"recivername"  xorm:"'RECIVERNAME'"`                    // 提货人姓名
	Cardtypeid      int32     `json:"cardtypeid"  xorm:"'CARDTYPEID'"`                      // 提货人证件类型
	Cardnum         string    `json:"cardnum"  xorm:"'CARDNUM'"`                            // 提货人证件号码
	Phonenum        string    `json:"phonenum"  xorm:"'PHONENUM'"`                          // 提货人联系方式
	Takemode        int32     `json:"takemode"  xorm:"'TAKEMODE'"`                          // 提货方式 - 2:自提 3:配送
	Address         string    `json:"address"  xorm:"'ADDRESS'"`                            // 提货人详细地址
	Takeremark      string    `json:"takeremark"  xorm:"'TAKEREMARK'"`                      // 提货备注
	Takeorderstatus int32     `json:"takeorderstatus"  xorm:"'TAKEORDERSTATUS'"`            // 提货状态 - 1:待发货 2:已发货 3:已收货
	Auditer         int32     `json:"auditer"  xorm:"'AUDITER'"`                            // 审核人
	Audittime       time.Time `json:"audittime"  xorm:"'AUDITTIME'"`                        // 审核时间
	Checkremark     string    `json:"checkremark"  xorm:"'CHECKREMARK'"`                    // 审核备注
	Tradedate       string    `json:"tradedate"  xorm:"'TRADEDATE'"`                        // 交易日(yyyyMMdd)
	Marketid        int32     `json:"marketid"  xorm:"'MARKETID'"`                          // 市场ID
	Handlestatus    int32     `json:"handlestatus"  xorm:"'HANDLESTATUS'"`                  // 处理状态
	Amount          float64   `json:"amount"  xorm:"'AMOUNT'"`                              // 提货金额
	Averageprice    float64   `json:"averageprice" xorm:"'AVERAGEPRICE'"`                   // 均价

	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'"` // 货币符号

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

// GetHsbyMyPackages 获取我的包裹信息
// 输入 accountIDs string 资金账户列表
// 输入 takeOrderStatus int 提货状态 - 1:待发货 2:已发货 3:已收货
// 输出 []HsbyMyPackage 我的包裹信息
// 输出 error error
func GetHsbyMyPackages(accountIDs string, takeOrderStatus int) ([]HsbyMyPackage, error) {
	engine := db.GetEngine()

	myPackages := make([]HsbyMyPackage, 0)
	session := engine.Table("TRADE_GOODSPICKUP").
		Select(`to_char(TRADE_GOODSPICKUP.TAKEORDERID) TAKEORDERID, (DIVISION.PATHNAME || TRADE_GOODSPICKUP.ADDRESS) ADDRESS, TRADE_GOODSPICKUP.*, 
				(TRADE_GOODSPICKUP.AMOUNT/TRADE_GOODSPICKUP.QTY/GOODS.AGREEUNIT) AVERAGEPRICE, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HSBY_GOODSEX.PICURLS, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HSBY_SUPPLIERINFO.VENDORNAME`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_GOODSPICKUP.GOODSID").
		Join("LEFT", "HSBY_GOODSEX", "HSBY_GOODSEX.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "HSBY_SUPPLIERINFO", "HSBY_SUPPLIERINFO.VENDORID = HSBY_GOODSEX.VENDORID").
		Join("LEFT", "DIVISION", "DIVISION.AUTOID = TRADE_GOODSPICKUP.DISTRICTID").
		Where(fmt.Sprintf("TRADE_GOODSPICKUP.ACCOUNTID in (%s)", accountIDs))
	if takeOrderStatus > 0 {
		session = session.And("TAKEORDERSTATUS = ?", takeOrderStatus)
	}
	if err := session.Find(&myPackages); err != nil {
		return nil, err
	}

	// FIXME：- 目前暂时在服务端对手机号码进行解密
	key, _ := hex.DecodeString(utils.AESSecretKey)
	for i := range myPackages {
		myPackage := &myPackages[i]

		// 解密手机号码
		if phonenum, err := hex.DecodeString(myPackage.Phonenum); err == nil { // hex -> []byte
			if mobile, err := utils.AESDecrypt(phonenum, key); err == nil {
				myPackage.Phonenum = string(mobile)
			}
		}
	}

	return myPackages, nil
}

// SetHsbyMyPackagesStatus 设置我的包裹提货状态
func SetHsbyMyPackagesStatus(takeOrderID string, accountID, status int) error {
	engine := db.GetEngine()

	sql := fmt.Sprintf("update TRADE_GOODSPICKUP set TAKEORDERSTATUS = %d where TAKEORDERID = %s and ACCOUNTID = %d", status, takeOrderID, accountID)
	_, err := engine.Exec(sql)

	return err
}

// GetHsbyProvincesAndCities 获取省市信息数组
// 参数 provinceID int 省ID，选填
// 返回 []Division 枚举信息数组
// 返回 error error
func GetHsbyProvincesAndCities(provinceID int) ([]Division, error) {
	engine := db.GetEngine()

	divisions := make([]Division, 0)
	session := engine.Where("DIVISIONLEVEL = 'province' or DIVISIONLEVEL = 'city'").
		And(`AUTOID in (
				(select DESCPROVINCEID AUTOID from HSBY_GOODSEX inner join GOODS on GOODS.GOODSID = HSBY_GOODSEX.GOODSID and GOODS.GOODSSTATUS in (2,3))
				union all
				(select DESCCITYID AUTOID from HSBY_GOODSEX inner join GOODS on GOODS.GOODSID = HSBY_GOODSEX.GOODSID and GOODS.GOODSSTATUS in (2,3))
						)`)
	if provinceID > 0 {
		session = session.And("AUTOID = ?", provinceID)
	}
	if err := session.Find(&divisions); err != nil {
		return nil, err
	}

	return divisions, nil
}

// HsbyBuyMyTradeDetail "我的订单 - 已完成"单据信息（一二级市场成交单，包括历史数据）
type HsbyBuyMyTradeDetail struct {
	Orderid   string    `json:"orderid"  xorm:"'ORDERID'" binding:"required"`     // 单号（成交单号）
	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:卖
	Price     float64   `json:"price"  xorm:"'PRICE'"`                            // 价格
	Qty       int64     `json:"qty"  xorm:"'QTY'" binding:"required"`             // 数量
	Time      time.Time `json:"time"  xorm:"'TIME'" binding:"required"`           // 时间
	Amount    float64   `json:"amount" xorm:"'AMOUNT'"`                           // 金额 = 价格 * 数量 * 合约单位

	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'"`                    // 合约单位

	Picurls1 string `json:"picurls1"  xorm:"'PICURLS1'"` // 预售商品介绍图片[多张用逗号分隔]
	Picurls2 string `json:"picurls2"  xorm:"'PICURLS2'"` // 挂牌商品介绍图片[多张用逗号分隔]

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

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

	Vendorname1 string `json:"vendorname1"  xorm:"'VENDORNAME1'"` // 预售商品供应商名称
	Vendorname2 string `json:"vendorname2"  xorm:"'VENDORNAME2'"` // 挂牌商品供应商名称
}

// GetHsbyBuyMyTradeDetails 获取"我的订单 - 已完成"单据信息（一二级市场成交单，包括历史数据）
// 输入 accountIDs string 资金账户列表
// 输出 []HsbyBuyMyTradeDetail "我的订单 - 已完成"单据信息
// 输出 error error
func GetHsbyBuyMyTradeDetails(accountIDs string) ([]HsbyBuyMyTradeDetail, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := "" // 我的订单包括一二级市场卖方向成交单（包括历史成交单）
	// 默认取 TradeMode = 16
	for _, v := range markets {
		if v.Trademode == 16 || v.Trademode == 71 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orders := make([]HsbyBuyMyTradeDetail, 0)

	// 当前成交单
	curOrders := make([]HsbyBuyMyTradeDetail, 0)
	if err := engine.Table("TRADE_TRADEDETAIL").
		Select(`to_char(TRADE_TRADEDETAIL.TRADEID) ORDERID, 
				TRADE_TRADEDETAIL.MARKETID, TRADE_TRADEDETAIL.GOODSID, TRADE_TRADEDETAIL.ACCOUNTID, TRADE_TRADEDETAIL.BUYORSELL,
				TRADE_TRADEDETAIL.TRADEPRICE PRICE, TRADE_TRADEDETAIL.TRADEQTY QTY, TRADE_TRADEDETAIL.TRADETIME TIME, TRADE_TRADEDETAIL.TRADEAMOUNT AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HG1.PICURLS PICURLS1, HG2.PICURLS PICURLS2, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HS1.VENDORNAME VENDORNAME1, HS2.VENDORNAME VENDORNAME2`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG1", "HG1.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "HSBY_GOODSEX HG2", "HG2.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TRADE_TRADEDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS1", "HS1.VENDORID = HG1.VENDORID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS2", "HS2.VENDORID = HG2.VENDORID").
		Where(fmt.Sprintf(`TRADE_TRADEDETAIL.BUYORSELL = 0 
						   and TRADE_TRADEDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TRADE_TRADEDETAIL.MARKETID in (%s)", marketIDs)).Find(&curOrders); err != nil {
		return nil, err
	}
	if len(curOrders) > 0 {
		orders = append(orders, curOrders...)
	}

	// 历史成交单
	hisOrders := make([]HsbyBuyMyTradeDetail, 0)
	if err := engine.Table("HIS_TRADE_TRADEDETAIL").
		Select(`to_char(HIS_TRADE_TRADEDETAIL.TRADEID) ORDERID, 
				HIS_TRADE_TRADEDETAIL.MARKETID, HIS_TRADE_TRADEDETAIL.GOODSID, HIS_TRADE_TRADEDETAIL.ACCOUNTID, HIS_TRADE_TRADEDETAIL.BUYORSELL,
				HIS_TRADE_TRADEDETAIL.TRADEPRICE PRICE, HIS_TRADE_TRADEDETAIL.TRADEQTY QTY, HIS_TRADE_TRADEDETAIL.TRADETIME TIME, HIS_TRADE_TRADEDETAIL.TRADEAMOUNT AMOUNT, 
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HG1.PICURLS PICURLS1, HG2.PICURLS PICURLS2, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HS1.VENDORNAME VENDORNAME1, HS2.VENDORNAME VENDORNAME2`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = HIS_TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "CPTRADE_PRESALEGOODSEX", "CPTRADE_PRESALEGOODSEX.GOODSID = HIS_TRADE_TRADEDETAIL.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG1", "HG1.GOODSID = CPTRADE_PRESALEGOODSEX.RELATEDGOODSID").
		Join("LEFT", "HSBY_GOODSEX HG2", "HG2.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = HIS_TRADE_TRADEDETAIL.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS1", "HS1.VENDORID = HG1.VENDORID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS2", "HS2.VENDORID = HG2.VENDORID").
		Where(fmt.Sprintf(`HIS_TRADE_TRADEDETAIL.BUYORSELL = 0 and HIS_TRADE_TRADEDETAIL.ISVALIDDATA = 1 
						   and HIS_TRADE_TRADEDETAIL.ACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("HIS_TRADE_TRADEDETAIL.MARKETID in (%s)", marketIDs)).Find(&hisOrders); err != nil {
		return nil, err
	}
	if len(hisOrders) > 0 {
		orders = append(orders, hisOrders...)
	}

	return orders, nil
}

// HsbyBuyMyPayOrder "我的订单 - 待付款"单据信息（一二级市场成交单和待付款信息）
type HsbyBuyMyPayOrder struct {
	Tradeid        string    `json:"tradeid"  xorm:"'TRADEIDSTR'" binding:"required"` // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Tradedate      string    `json:"tradedate"  xorm:"'TRADEDATE'"`                   // 交易日(yyyyMMdd)
	Marketid       int32     `json:"marketid"  xorm:"'MARKETID'"`                     // 市场ID
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'"`                       // 商品ID
	Buyorderid     string    `json:"buyorderid"  xorm:"'BUYORDERIDSTR'"`              // 买方委托单号
	Buyaccountid   int64     `json:"buyaccountid"  xorm:"'BUYACCOUNTID'"`             // 买方账号ID[报价币种]
	Sellorderid    string    `json:"sellorderid"  xorm:"'SELLORDERIDSTR'"`            // 卖方委托单号
	Sellaccountid  int64     `json:"sellaccountid"  xorm:"'SELLACCOUNTID'"`           // 卖方账号ID[报价币种]
	Tradeamount    float64   `json:"tradeamount"  xorm:"'TRADEAMOUNT'"`               // 成交金额
	Tradecharge    float64   `json:"tradecharge"  xorm:"'TRADECHARGE'"`               // 成交手续费(买方)
	Payflag        int32     `json:"payflag"  xorm:"'PAYFLAG'"`                       // 付款标识 - 1:未支付 2:已支付 3:已过期 4:已撤销 5:结算过期 6:预售终止
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`                 // 创建时间
	Paytime        time.Time `json:"paytime"  xorm:"'PAYTIME'"`                       // 付款时间
	Paylimitedtime time.Time `json:"paylimitedtime"  xorm:"'PAYLIMITEDTIME'"`         // 支付期限
	Offamount      float64   `json:"offamount"  xorm:"'OFFAMOUNT'"`                   // 优惠金额
	Tradeprice     float64   `json:"tradeprice"  xorm:"'TRADEPRICE'"`                 // 成交价格
	Tradeqty       int64     `json:"tradeqty"  xorm:"'TRADEQTY'"`                     // 成交数量
	Payamount      float64   `json:"payamount"  xorm:"'PAYAMOUNT'"`                   // 支付金额 = TradeAmount + TradeCharge - OffAmount

	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'"`                    // 合约单位

	Picurls1 string `json:"picurls1"  xorm:"'PICURLS1'"` // 预售商品介绍图片[多张用逗号分隔]
	Picurls2 string `json:"picurls2"  xorm:"'PICURLS2'"` // 挂牌商品介绍图片[多张用逗号分隔]

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

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

	Vendorname1 string `json:"vendorname1"  xorm:"'VENDORNAME1'"` // 预售商品供应商名称
	Vendorname2 string `json:"vendorname2"  xorm:"'VENDORNAME2'"` // 挂牌商品供应商名称
}

// GetHsbyBuyMyPayOrders 获取待付款信息
func GetHsbyBuyMyPayOrders(accountIDs string, buyOrderID, sellOrderID int) ([]HsbyBuyMyPayOrder, error) {
	// 获取市场信息
	markets, err := GetMarkets()
	if err != nil {
		return nil, err
	}

	engine := db.GetEngine()
	marketIDs := "" // 我的订单包括一二级市场卖方向成交单
	// 默认取 TradeMode = 16
	for _, v := range markets {
		if v.Trademode == 16 || v.Trademode == 71 {
			if len(marketIDs) == 0 {
				marketIDs = strconv.Itoa(int(v.Marketid))
			} else {
				marketIDs += "," + strconv.Itoa(int(v.Marketid))
			}
		}
	}

	orders := make([]HsbyBuyMyPayOrder, 0)
	session := engine.Table("TRADE_PAYORDER TP").
		Select(`to_char(TP.TRADEID) TRADEIDSTR, to_char(TP.BUYORDERID) BUYORDERIDSTR, to_char(TP.SELLORDERID) SELLORDERIDSTR, TP.*,
				GOODS.GOODSCODE, GOODS.GOODSNAME, GOODS.DECIMALPLACE, GOODS.AGREEUNIT, 
				HG1.PICURLS PICURLS1, HG2.PICURLS PICURLS2, 
				MARKET.TRADEMODE, 
				ENUMDICITEM.PARAM2 CURRENCYSIGN, 
				HS1.VENDORNAME VENDORNAME1, HS2.VENDORNAME VENDORNAME2`).
		Join("LEFT", "GOODS", "GOODS.GOODSID = TP.GOODSID").
		Join("LEFT", "CPTRADE_PRESALEGOODSEX CP", "CP.GOODSID = TP.GOODSID").
		Join("LEFT", "HSBY_GOODSEX HG1", "HG1.GOODSID = CP.RELATEDGOODSID").
		Join("LEFT", "HSBY_GOODSEX HG2", "HG2.GOODSID = GOODS.GOODSID").
		Join("LEFT", "ENUMDICITEM", "GOODS.CURRENCYID = ENUMDICITEM.ENUMITEMNAME and ENUMDICITEM.ENUMDICCODE = 'currency'").
		Join("LEFT", "MARKET", "MARKET.MARKETID = TP.MARKETID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS1", "HS1.VENDORID = HG1.VENDORID").
		Join("LEFT", "HSBY_SUPPLIERINFO HS2", "HS2.VENDORID = HG2.VENDORID").
		Where(fmt.Sprintf(`TP.PAYFLAG = 1 and TP.BUYACCOUNTID in (%s)`, accountIDs)).
		And(fmt.Sprintf("TP.MARKETID in (%s)", marketIDs))
	if buyOrderID != 0 {
		session = session.And("TP.BUYORDERID = ?", buyOrderID)
	}
	if sellOrderID != 0 {
		session = session.And("TP.SELLORDERID = ?", sellOrderID)
	}
	if err := session.Find(&orders); err != nil {
		return nil, err
	}

	return orders, nil
}

// HsbyMarketInfo 海商报业相关市场信息
type HsbyMarketInfo struct {
	Marketid   int32  `json:"marketid"  xorm:"'MARKETID'" binding:"required"`   // 市场ID正常5位，前三位固定：两位表示交易模式， 一位表示交易属性(1:收益权，2：所有权) 其它特殊市场：0-系统 1-交割服务 2-账户服务3-履约服务 4-仓单服务 5-积分服务 6-银行服务
	Marketname string `json:"marketname"  xorm:"'MARKETNAME'"`                  // 市场名称
	Trademode  int32  `json:"trademode"  xorm:"'TRADEMODE'" binding:"required"` // 交易模式 - 10:做市 13:竞价 15:通道交易 16:挂牌点选 17:仓单贸易 18:期权 19:竞拍-降价式 20:竞拍-竞价式 21:竞拍-大宗式 22:受托竞价
}

// GetHsbyMarketInfos 获取海商报业相关市场信息
func GetHsbyMarketInfos() ([]HsbyMarketInfo, error) {
	engine := db.GetEngine()

	markets := make([]HsbyMarketInfo, 0)
	if err := engine.Table("MARKET").Where("TRADEMODE in (71,16,70)").Find(&markets); err != nil {
		return nil, err
	}

	return markets, nil
}

// HsbySellCollectionOrder 我的闲置中收款信息
type HsbySellCollectionOrder struct {
	Tradeid        string    `json:"tradeid"  xorm:"'TRADEIDSTR'" binding:"required"` // 成交单号(101+Unix秒时间戳(10位)+2位(MarketServiceID)+xxxx)
	Tradedate      string    `json:"tradedate"  xorm:"'TRADEDATE'"`                   // 交易日(yyyyMMdd)
	Marketid       int32     `json:"marketid"  xorm:"'MARKETID'"`                     // 市场ID
	Goodsid        int32     `json:"goodsid"  xorm:"'GOODSID'"`                       // 商品ID
	Buyorderid     string    `json:"buyorderid"  xorm:"'BUYORDERIDSTR'"`              // 买方委托单号
	Buyaccountid   int64     `json:"buyaccountid"  xorm:"'BUYACCOUNTID'"`             // 买方账号ID[报价币种]
	Sellorderid    string    `json:"sellorderid"  xorm:"'SELLORDERIDSTR'"`            // 卖方委托单号
	Sellaccountid  int64     `json:"sellaccountid"  xorm:"'SELLACCOUNTID'"`           // 卖方账号ID[报价币种]
	Tradeamount    float64   `json:"tradeamount"  xorm:"'TRADEAMOUNT'"`               // 成交金额
	Tradecharge    float64   `json:"tradecharge"  xorm:"'TRADECHARGE'"`               // 成交手续费(买方)
	Payflag        int32     `json:"payflag"  xorm:"'PAYFLAG'"`                       // 付款标识 - 1:未支付 2:已支付 3:已过期 4:已撤销 5:结算过期 6:预售终止
	Createtime     time.Time `json:"createtime"  xorm:"'CREATETIME'"`                 // 创建时间
	Paytime        time.Time `json:"paytime"  xorm:"'PAYTIME'"`                       // 付款时间
	Paylimitedtime time.Time `json:"paylimitedtime"  xorm:"'PAYLIMITEDTIME'"`         // 支付期限
	Offamount      float64   `json:"offamount"  xorm:"'OFFAMOUNT'"`                   // 优惠金额
	Tradeprice     float64   `json:"tradeprice"  xorm:"'TRADEPRICE'"`                 // 成交价格
	Tradeqty       int64     `json:"tradeqty"  xorm:"'TRADEQTY'"`                     // 成交数量
	Payamount      float64   `json:"payamount"  xorm:"'PAYAMOUNT'"`                   // 支付金额 = TradeAmount + TradeCharge - OffAmount

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

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

	Agreeunit float64 `json:"agreeunit"  xorm:"'AGREEUNIT'"` // 合约单位
}

// GetHsbySellCollectionOrders 获取我的闲置中收款信息
func GetHsbySellCollectionOrders(sellOrderID, sellAccountID int) ([]HsbySellCollectionOrder, error) {
	engine := db.GetEngine()

	orders := make([]HsbySellCollectionOrder, 0)
	if err := engine.Table("TRADE_PAYORDER TP").
		Select(`to_char(TP.TRADEID) TRADEIDSTR, to_char(TP.BUYORDERID) BUYORDERIDSTR, to_char(TP.SELLORDERID) SELLORDERIDSTR, TP.*,
				substr(U.CUSTOMERNAME,0,1)||'****' as CUSTOMERNAME,
				E1.PARAM2 CURRENCYSIGN,
				E1.ENUMDICNAME GOODUNIT,
				G.AGREEUNIT`).
		Join("LEFT", "TAACCOUNT TA", "TA.ACCOUNTID = TP.SELLACCOUNTID").
		Join("LEFT", "USERINFO U", "U.USERID = TA.RELATEDUSERID").
		Join("LEFT", "GOODS G", "G.GOODSID = TP.GOODSID").
		Join("LEFT", "ENUMDICITEM E1", "E1.ENUMITEMNAME = G.CURRENCYID and E1.ENUMDICCODE = 'currency'").
		Join("LEFT", "ENUMDICITEM E2", "E2.ENUMITEMNAME = G.GOODUNITID and E2.ENUMDICCODE = 'goodsunit'").
		Where("TP.PAYFLAG in (1,2) and TP.SELLORDERID = ?", sellOrderID).
		And("TP.SELLACCOUNTID = ?", sellAccountID).
		Find(&orders); err != nil {
		return nil, err
	}

	return orders, nil
}