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" } // 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). 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 // 获取购买上限 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 - 已完成 } // 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`). 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.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 }