|
@@ -1,6 +1,8 @@
|
|
|
package data_manage
|
|
|
|
|
|
import (
|
|
|
+ "eta/eta_hub/global"
|
|
|
+ "eta/eta_hub/utils"
|
|
|
"fmt"
|
|
|
"github.com/beego/beego/v2/client/orm"
|
|
|
"github.com/rdlucklib/rdluck_tools/paging"
|
|
@@ -86,54 +88,54 @@ type BaseFromTradeIneIndex struct {
|
|
|
|
|
|
type BaseFromTradeZhengzhouIndex struct {
|
|
|
BaseFromTradeZhengzhouIndexId int `orm:"column(base_from_trade_zhengzhou_index_id);pk"`
|
|
|
- Rank int
|
|
|
- DealShortName string
|
|
|
- DealName string
|
|
|
- DealCode string
|
|
|
- DealValue string
|
|
|
- DealChange string
|
|
|
- BuyShortName string
|
|
|
- BuyName string
|
|
|
- BuyCode string
|
|
|
- BuyValue string
|
|
|
- BuyChange string
|
|
|
- SoldShortName string
|
|
|
- SoldName string
|
|
|
- SoldCode string
|
|
|
- SoldValue string
|
|
|
- SoldChange string
|
|
|
- Frequency string
|
|
|
- ClassifyName string
|
|
|
- ClassifyType string
|
|
|
- CreateTime time.Time
|
|
|
- ModifyTime time.Time
|
|
|
- DataTime string
|
|
|
+ Rank int
|
|
|
+ DealShortName string
|
|
|
+ DealName string
|
|
|
+ DealCode string
|
|
|
+ DealValue string
|
|
|
+ DealChange string
|
|
|
+ BuyShortName string
|
|
|
+ BuyName string
|
|
|
+ BuyCode string
|
|
|
+ BuyValue string
|
|
|
+ BuyChange string
|
|
|
+ SoldShortName string
|
|
|
+ SoldName string
|
|
|
+ SoldCode string
|
|
|
+ SoldValue string
|
|
|
+ SoldChange string
|
|
|
+ Frequency string
|
|
|
+ ClassifyName string
|
|
|
+ ClassifyType string
|
|
|
+ CreateTime time.Time
|
|
|
+ ModifyTime time.Time
|
|
|
+ DataTime string
|
|
|
}
|
|
|
|
|
|
type BaseFromTradeDalianIndex struct {
|
|
|
BaseFromTradeDalianIndexId int `orm:"column(base_from_trade_dalian_index_id);pk"`
|
|
|
- Rank int
|
|
|
- DealShortName string
|
|
|
- DealName string
|
|
|
- DealCode string
|
|
|
- DealValue string
|
|
|
- DealChange string
|
|
|
- BuyShortName string
|
|
|
- BuyName string
|
|
|
- BuyCode string
|
|
|
- BuyValue string
|
|
|
- BuyChange string
|
|
|
- SoldShortName string
|
|
|
- SoldName string
|
|
|
- SoldCode string
|
|
|
- SoldValue string
|
|
|
- SoldChange string
|
|
|
- Frequency string
|
|
|
- ClassifyName string
|
|
|
- ClassifyType string
|
|
|
- CreateTime time.Time
|
|
|
- ModifyTime time.Time
|
|
|
- DataTime string
|
|
|
+ Rank int
|
|
|
+ DealShortName string
|
|
|
+ DealName string
|
|
|
+ DealCode string
|
|
|
+ DealValue string
|
|
|
+ DealChange string
|
|
|
+ BuyShortName string
|
|
|
+ BuyName string
|
|
|
+ BuyCode string
|
|
|
+ BuyValue string
|
|
|
+ BuyChange string
|
|
|
+ SoldShortName string
|
|
|
+ SoldName string
|
|
|
+ SoldCode string
|
|
|
+ SoldValue string
|
|
|
+ SoldChange string
|
|
|
+ Frequency string
|
|
|
+ ClassifyName string
|
|
|
+ ClassifyType string
|
|
|
+ CreateTime time.Time
|
|
|
+ ModifyTime time.Time
|
|
|
+ DataTime string
|
|
|
}
|
|
|
|
|
|
type BaseFromTradeEicIndex struct {
|
|
@@ -167,111 +169,112 @@ type BaseFromTradeEicIndex struct {
|
|
|
}
|
|
|
|
|
|
func GetBaseFromTradeIndexByParam(exchange, date, classifyName, classifyType string) (list []*BaseFromTradeShanghaiIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
if classifyName == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=?"
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&list).Error
|
|
|
return
|
|
|
} else if classifyType == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? ORDER BY classify_type,rank"
|
|
|
- _, err = o.Raw(sql, date, classifyName).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName).Find(&list).Error
|
|
|
return
|
|
|
} else {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? and classify_type=?"
|
|
|
- _, err = o.Raw(sql, date, classifyName, classifyType).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName, classifyType).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
func GetBaseFromTradeIneIndexByParam(exchange, date, classifyName, classifyType string) (list []*BaseFromTradeIneIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
if classifyName == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=?"
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&list).Error
|
|
|
return
|
|
|
} else if classifyType == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? ORDER BY classify_type,rank"
|
|
|
- _, err = o.Raw(sql, date, classifyName).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName).Find(&list).Error
|
|
|
return
|
|
|
} else {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? and classify_type=?"
|
|
|
- _, err = o.Raw(sql, date, classifyName, classifyType).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName, classifyType).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
func GetBaseFromTradeCffexIndexByParam(exchange, date, classifyName, classifyType string) (list []*BaseFromTradeCffexIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
if classifyName == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=?"
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&list).Error
|
|
|
return
|
|
|
} else if classifyType == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? ORDER BY classify_type,rank"
|
|
|
- _, err = o.Raw(sql, date, classifyName).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName).Find(&list).Error
|
|
|
return
|
|
|
} else {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? and classify_type=?"
|
|
|
- _, err = o.Raw(sql, date, classifyName, classifyType).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName, classifyType).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
func GetBaseFromTradeZhengzhouIndexByParam(exchange, date, classifyName, classifyType string) (list []*BaseFromTradeZhengzhouIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
if classifyName == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=?"
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&list).Error
|
|
|
return
|
|
|
} else if classifyType == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? ORDER BY classify_type,rank"
|
|
|
- _, err = o.Raw(sql, date, classifyName).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName).Find(&list).Error
|
|
|
return
|
|
|
} else {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? and classify_type=?"
|
|
|
- _, err = o.Raw(sql, date, classifyName, classifyType).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName, classifyType).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
func GetBaseFromTradeDalianIndexByParam(exchange, date, classifyName, classifyType string) (list []*BaseFromTradeDalianIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
if classifyName == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=?"
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&list).Error
|
|
|
return
|
|
|
} else if classifyType == "" {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? ORDER BY classify_type,rank"
|
|
|
- _, err = o.Raw(sql, date, classifyName).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName).Find(&list).Error
|
|
|
return
|
|
|
} else {
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where data_time=? and classify_name=? and classify_type=?"
|
|
|
- _, err = o.Raw(sql, date, classifyName, classifyType).QueryRows(&list)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date, classifyName, classifyType).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
|
|
|
func GetExchangeClassify(exchange, dataTime string) (classifyName []string, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT DISTINCT classify_name FROM base_from_trade_" + exchange + "_index where data_time=? ORDER BY CONVERT(classify_name using gbk) DESC"
|
|
|
- _, err = o.Raw(sql, dataTime).QueryRows(&classifyName)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, dataTime).Find(&classifyName).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetLatestDate(exchange string) (dataTime string, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT data_time FROM base_from_trade_" + exchange + "_index ORDER BY data_time desc limit 1"
|
|
|
- err = o.Raw(sql).QueryRow(&dataTime)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql).Scan(&dataTime).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetExchangeClassifyContract(exchange, Classify, dataTime string) (classifyName []*string, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT DISTINCT classify_type FROM base_from_trade_" + exchange + "_index where classify_name=? and data_time=?"
|
|
|
- _, err = o.Raw(sql, Classify, dataTime).QueryRows(&classifyName)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, Classify, dataTime).Find(&classifyName).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetContinentEicDate(date string) (data []*BaseFromTradeEicIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT * FROM base_from_trade_eic_index where gas_day_started_on=? and type='continent' "
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&data)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&data).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -381,7 +384,7 @@ type BaseFromCoalmineFirmIndex struct {
|
|
|
ModifyTime string `description:"修改时间"`
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineFirmIndex(dataTime string) (items []*BaseFromCoalmineFirmIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_firm_index WHERE data_time LIKE `
|
|
@@ -406,7 +409,7 @@ type BaseFromCoalmineCoastalIndex struct {
|
|
|
ModifyTime string `description:"修改时间"`
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineCoastalIndex(startDate, endDate string) (items []*BaseFromCoalmineCoastalIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_coastal_index WHERE data_time between ? and ? `
|
|
@@ -429,7 +432,7 @@ type BaseFromCoalmineInlandIndex struct {
|
|
|
ModifyTime string `description:"修改时间"`
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineInlandIndex(startDate, endDate string) (items []*BaseFromCoalmineInlandIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_inland_index WHERE data_time between ? and ? `
|
|
@@ -497,7 +500,7 @@ func GetFrequencyFromCoal(suffix string) (list *string, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询数据
|
|
|
+// 查询数据
|
|
|
func GetBaseFromCoalmineIndexByFrequency(frequency, groupName string) (items []*BaseFromCoalmineJsmIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_jsm_index WHERE frequency=? AND province=?`
|
|
@@ -505,7 +508,7 @@ func GetBaseFromCoalmineIndexByFrequency(frequency, groupName string) (items []*
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询数据
|
|
|
+// 查询数据
|
|
|
func GetGroupNameFromCoalmineIndex(suffix string) (items []*string, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT DISTINCT group_name FROM base_from_coalmine_%s `
|
|
@@ -514,7 +517,7 @@ func GetGroupNameFromCoalmineIndex(suffix string) (items []*string, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询数据
|
|
|
+// 查询数据
|
|
|
func GetProvinceFromCoalmineIndex(suffix string) (items []*string, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT DISTINCT province FROM base_from_coalmine_%s `
|
|
@@ -523,7 +526,7 @@ func GetProvinceFromCoalmineIndex(suffix string) (items []*string, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询数据
|
|
|
+// 查询数据
|
|
|
func GetClassifyCoalmineIndexByGroupName(groupName string) (items []*string, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT DISTINCT index_code FROM base_from_coalmine_jsm_index WHERE province=? `
|
|
@@ -531,7 +534,7 @@ func GetClassifyCoalmineIndexByGroupName(groupName string) (items []*string, err
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询数据
|
|
|
+// 查询数据
|
|
|
func GetPageFromCoalmineIndexByFrequency(frequency, classify string, startSize, pageSize int) (items []*BaseFromCoalmineJsmIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_jsm_index WHERE frequency=? AND index_code=? ORDER BY data_time DESC LIMIT ?,? `
|
|
@@ -539,7 +542,7 @@ func GetPageFromCoalmineIndexByFrequency(frequency, classify string, startSize,
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询数据
|
|
|
+// 查询数据
|
|
|
func GetCountFromJsm(indexCode string) (item int, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT COUNT(1) FROM base_from_coalmine_jsm_index WHERE index_code=? `
|
|
@@ -561,7 +564,7 @@ func GetClassifyJsmByGroupName(groupName string) (items []*string, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询公司指标
|
|
|
+// 查询公司指标
|
|
|
func GetPageFromCoalmineCompanyIndexByFrequency(frequency, classify string, startSize, pageSize int) (items []*BaseFromCoalmineCompanyIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_company_index WHERE frequency=? AND index_code=? ORDER BY data_time DESC LIMIT ?,? `
|
|
@@ -590,7 +593,7 @@ func GetClassifyFirmByGroupName(groupName string) (items []*string, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetPageFromCoalmineFirmIndexByFrequency(frequency, classify string, startSize, pageSize int) (items []*BaseFromCoalmineFirmIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_firm_index WHERE frequency=? AND index_code=? ORDER BY data_time DESC LIMIT ?,? `
|
|
@@ -612,7 +615,7 @@ func GetClassifyCoastalByGroupName(groupName string) (items []*string, err error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetPageFromCoalmineCoastalIndexByFrequency(frequency, classify string, startSize, pageSize int) (items []*BaseFromCoalmineCoastalIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_coastal_index WHERE frequency=? AND index_code=? ORDER BY data_time DESC LIMIT ?,? `
|
|
@@ -634,7 +637,7 @@ func GetClassifyInlandByGroupName(groupName string) (items []*string, err error)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetPageFromCoalmineInlandIndexByFrequency(frequency, classify string, startSize, pageSize int) (items []*BaseFromCoalmineInlandIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_inland_index WHERE frequency=? AND index_code=? ORDER BY data_time DESC LIMIT ?,? `
|
|
@@ -642,7 +645,7 @@ func GetPageFromCoalmineInlandIndexByFrequency(frequency, classify string, start
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询公司指标
|
|
|
+// 查询公司指标
|
|
|
func GetBaseFromCoalmineCompanyIndexByFrequency(frequency, groupName string) (items []*BaseFromCoalmineCompanyIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_company_index WHERE frequency=? AND group_name=? `
|
|
@@ -650,7 +653,7 @@ func GetBaseFromCoalmineCompanyIndexByFrequency(frequency, groupName string) (it
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineFirmIndexByFrequency(frequency, groupName string) (items []*BaseFromCoalmineFirmIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_firm_index WHERE frequency=? AND group_name=? `
|
|
@@ -658,7 +661,7 @@ func GetBaseFromCoalmineFirmIndexByFrequency(frequency, groupName string) (items
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineCoastalIndexByFrequency(frequency, groupName string) (items []*BaseFromCoalmineCoastalIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_coastal_index WHERE frequency=? AND group_name=? `
|
|
@@ -666,7 +669,7 @@ func GetBaseFromCoalmineCoastalIndexByFrequency(frequency, groupName string) (it
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineInlandIndexByFrequency(frequency, groupName string) (items []*BaseFromCoalmineInlandIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_inland_index WHERE frequency=? AND group_name=? `
|
|
@@ -674,7 +677,7 @@ func GetBaseFromCoalmineInlandIndexByFrequency(frequency, groupName string) (ite
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询数据
|
|
|
+// 查询数据
|
|
|
func GetBaseFromCoalmineIndexByCode(indexCode string) (items []*BaseFromCoalmineJsmIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_jsm_index WHERE index_code=?`
|
|
@@ -682,7 +685,7 @@ func GetBaseFromCoalmineIndexByCode(indexCode string) (items []*BaseFromCoalmine
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询公司指标
|
|
|
+// 查询公司指标
|
|
|
func GetBaseFromCoalmineCompanyIndexByCode(indexCode string) (items []*BaseFromCoalmineCompanyIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_company_index WHERE index_code=? `
|
|
@@ -690,7 +693,7 @@ func GetBaseFromCoalmineCompanyIndexByCode(indexCode string) (items []*BaseFromC
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineFirmIndexByCode(indexCode string) (items []*BaseFromCoalmineFirmIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_firm_index WHERE index_code=? `
|
|
@@ -698,7 +701,7 @@ func GetBaseFromCoalmineFirmIndexByCode(indexCode string) (items []*BaseFromCoal
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineCoastalIndexByCode(indexCode string) (items []*BaseFromCoalmineCoastalIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_coastal_index WHERE index_code=? `
|
|
@@ -706,7 +709,7 @@ func GetBaseFromCoalmineCoastalIndexByCode(indexCode string) (items []*BaseFromC
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//查询指标
|
|
|
+// 查询指标
|
|
|
func GetBaseFromCoalmineInlandIndexByCode(indexCode string) (items []*BaseFromCoalmineInlandIndex, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := `SELECT * FROM base_from_coalmine_inland_index WHERE index_code=? `
|
|
@@ -714,7 +717,6 @@ func GetBaseFromCoalmineInlandIndexByCode(indexCode string) (items []*BaseFromCo
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-
|
|
|
type BaseFromTradeEicIndexV2 struct {
|
|
|
BaseFromEicIndexId int `orm:"column(base_from_eic_index_id);pk"`
|
|
|
Type string
|
|
@@ -750,44 +752,44 @@ type BaseFromTradeEicIndexV2 struct {
|
|
|
}
|
|
|
|
|
|
func GetEicDateV2() (date []*BaseFromTradeEicIndexV2, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT * FROM base_from_trade_eic_index_v2 ORDER BY gas_day_start desc limit 1"
|
|
|
- _, err = o.Raw(sql).QueryRows(&date)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql).Find(&date).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetEicDataV2(date string) (data []*BaseFromTradeEicIndexV2, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT * FROM base_from_trade_eic_index_v2 where gas_day_start=? "
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&data)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&data).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetEicHistoryDateByDateV2(code, startDate, endDate string) (date []*BaseFromTradeEicIndexV2, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT * FROM base_from_trade_eic_index_v2 WHERE eic_code=? and gas_day_start between ? and ? ORDER BY gas_day_start desc"
|
|
|
- _, err = o.Raw(sql, code, startDate, endDate).QueryRows(&date)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, code, startDate, endDate).Find(&date).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetEicHistoryDateV2(code string) (date []*BaseFromTradeEicIndexV2, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT * FROM base_from_trade_eic_index_v2 WHERE eic_code=? ORDER BY gas_day_start desc limit 30"
|
|
|
- _, err = o.Raw(sql, code).QueryRows(&date)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, code).Find(&date).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetContinentAndCountryEicDateV2(date string) (data []*BaseFromTradeEicIndexV2, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT * FROM base_from_trade_eic_index_v2 where gas_day_start=? and (type='continent' OR type='country') "
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&data)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&data).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetSSOAndFacEicDateV2(date, name string) (data []*BaseFromTradeEicIndexV2, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
sql := "SELECT * FROM base_from_trade_eic_index_v2 where gas_day_start=? and (type='sso' OR type='fac') "
|
|
|
- _, err = o.Raw(sql, date).QueryRows(&data)
|
|
|
+ err = global.DbMap[utils.DbNameIndex].Raw(sql, date).Find(&data).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -803,4 +805,4 @@ func GetFirstBaseFromTradeIndexByDate(exchange string) (item *BaseFromTradeShang
|
|
|
sql := "SELECT * FROM base_from_trade_" + exchange + "_index where rank < 50 order by data_time asc"
|
|
|
err = o.Raw(sql).QueryRow(&item)
|
|
|
return
|
|
|
-}
|
|
|
+}
|