|
@@ -256,7 +256,7 @@ func GetTradeZhengzhouDataByClassifyAndCompany(exchange string, contracts, compa
|
|
|
classify_name IN (%s) AND sold_short_name IN (%s)
|
|
|
)`
|
|
|
sql = fmt.Sprintf(sql, tableName, utils.GetOrmInReplace(len(contracts)), utils.GetOrmInReplace(len(companies)), tableName, utils.GetOrmInReplace(len(contracts)), utils.GetOrmInReplace(len(companies)))
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := orm.NewOrm()
|
|
|
_, err = o.Raw(sql, contracts, companies, contracts, companies).QueryRows(&items)
|
|
|
return
|
|
|
}
|
|
@@ -283,10 +283,10 @@ const (
|
|
|
WarehouseDefaultFrequency = "日度"
|
|
|
|
|
|
GuangZhouTopCompanyAliasName = "日成交持仓排名" // 广期所TOP20对应的公司名称
|
|
|
- GuangZhouSeatNameBuy = "持买单量" // 广期所指标名称中的多单名称
|
|
|
- GuangZhouSeatNameSold = "持卖单量" // 广期所指标名称中的空单名称
|
|
|
- GuangZhouTopSeatNameBuy = "持买单量总计" // 广期所指标名称中的TOP20多单名称
|
|
|
- GuangZhouTopSeatNameSold = "持卖单量总计" // 广期所指标名称中的TOP20空单名称
|
|
|
+ GuangZhouSeatNameBuy = "持买单量" // 广期所指标名称中的多单名称
|
|
|
+ GuangZhouSeatNameSold = "持卖单量" // 广期所指标名称中的空单名称
|
|
|
+ GuangZhouTopSeatNameBuy = "持买单量总计" // 广期所指标名称中的TOP20多单名称
|
|
|
+ GuangZhouTopSeatNameSold = "持卖单量总计" // 广期所指标名称中的TOP20空单名称
|
|
|
)
|
|
|
|
|
|
const (
|
|
@@ -453,7 +453,7 @@ func GetLastTradeZhengzhouDataByClassify(exchange string, contracts []string) (i
|
|
|
tpt.classify_name IN (%s)
|
|
|
)`
|
|
|
sql = fmt.Sprintf(sql, tableName, tableName, contractReplacer, contractReplacer, tableName, tableName, contractReplacer, contractReplacer)
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ o := orm.NewOrm()
|
|
|
_, err = o.Raw(sql, contracts, contracts, contracts, contracts).QueryRows(&items)
|
|
|
return
|
|
|
}
|