@@ -61,6 +61,8 @@ func GetEdbDataTableName(source int) (tableName string) {
tableName = "edb_data_coal"
case utils.DATA_SOURCE_PYTHON:
tableName = "edb_data_python"
+ case utils.DATA_SOURCE_GOOGLE_TRAVEL:
+ tableName = "edb_data_google_travel"
default:
tableName = ""
}
@@ -60,6 +60,8 @@ func GetEdbDataTableName(source int) (tableName string) {
@@ -98,6 +98,8 @@ func RefreshEdbData(edbInfoId, source int, edbCode, startDate string) (resp *mod
urlStr = "/lt/refresh"
case utils.DATA_SOURCE_COAL:
urlStr = "/coal/refresh"
+ urlStr = "google_travel/refresh"
if urlStr == "" {
err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口,请联系管理员"))
@@ -60,6 +60,7 @@ const (
DATA_SOURCE_COAL //煤炭网->26
DATA_SOURCE_PYTHON //python代码->27
DATA_SOURCE_PB_FINANCE //彭博财务数据->28
+ DATA_SOURCE_GOOGLE_TRAVEL //谷歌出行->29
)
//数据刷新频率