@@ -62,6 +62,10 @@ func GetEdbDataTableName(source int) (tableName string) {
tableName = "edb_data_calculate_ljztbpj"
case utils.DATA_SOURCE_LT:
tableName = "edb_data_lt"
+ case utils.DATA_SOURCE_COAL:
+ tableName = "edb_data_coal"
+ case utils.DATA_SOURCE_PYTHON:
+ tableName = "edb_data_python"
default:
tableName = ""
}
@@ -3722,6 +3722,8 @@ func RefreshEdbData(edbInfoId, source int, edbCode, startDate string) (resp *Ref
urlStr = "/gie/refresh"
urlStr = "/lt/refresh"
+ urlStr = "/coal/refresh"
if urlStr == "" {
err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口,请联系管理员"))
@@ -68,7 +68,8 @@ const (
DATA_SOURCE_CALCULATE_ZJPJ //直接拼接->23
DATA_SOURCE_CALCULATE_LJZTBPJ //累计值同比拼接->24
DATA_SOURCE_LT //路透->25
-
+ DATA_SOURCE_COAL //中国煤炭网->26
+ DATA_SOURCE_PYTHON //python代码->27
)
const (