|
|
@@ -44,6 +44,8 @@ func AddEdbData(source int, edbCode string) (resp *models.BaseResponse, err erro
|
|
|
urlStr = "/gie/add"
|
|
|
case utils.DATA_SOURCE_LT:
|
|
|
urlStr = "/lt/add"
|
|
|
+ case utils.DATA_SOURCE_COAL:
|
|
|
+ urlStr = "/coal/add"
|
|
|
default:
|
|
|
}
|
|
|
if urlStr == "" {
|
|
|
@@ -90,6 +92,8 @@ func RefreshEdbData(edbInfoId, source int, edbCode, startDate string) (resp *mod
|
|
|
urlStr = "/gie/refresh"
|
|
|
case utils.DATA_SOURCE_LT:
|
|
|
urlStr = "/lt/refresh"
|
|
|
+ case utils.DATA_SOURCE_COAL:
|
|
|
+ urlStr = "/coal/refresh"
|
|
|
}
|
|
|
if urlStr == "" {
|
|
|
err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口，请联系管理员"))
|
