|
@@ -4,32 +4,6 @@ import (
|
|
|
"eta/eta_chart_lib/utils"
|
|
|
)
|
|
|
|
|
|
-var (
|
|
|
- EdbDataTableNameMap map[int]string // 指标来源对应数据表名
|
|
|
- EdbDataAddMethodMap map[int]string // 指标来源对应的新增指标方法
|
|
|
- EdbDataRefreshMethodMap map[int]string // 指标来源对应的刷新指标方法
|
|
|
- EdbSourceNameMap map[int]string // 指标来源名称
|
|
|
-)
|
|
|
-
|
|
|
-// InitEdbSourceVar 初始化时加载指标来源对应信息, 避免循环中查库, 注意edb_source表修改table_name的话需要重启服务
|
|
|
-func InitEdbSourceVar() {
|
|
|
- EdbDataTableNameMap = make(map[int]string)
|
|
|
- EdbDataAddMethodMap = make(map[int]string)
|
|
|
- EdbDataRefreshMethodMap = make(map[int]string)
|
|
|
- EdbSourceNameMap = make(map[int]string)
|
|
|
- sources, e := GetEdbSourceItemsByCondition(``, make([]interface{}, 0), []string{}, "")
|
|
|
- if e != nil {
|
|
|
- utils.FileLog.Info("init source table err: %s", e.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- for _, v := range sources {
|
|
|
- EdbDataTableNameMap[v.EdbSourceId] = v.TableName
|
|
|
- EdbDataAddMethodMap[v.EdbSourceId] = v.EdbAddMethod
|
|
|
- EdbDataRefreshMethodMap[v.EdbSourceId] = v.EdbRefreshMethod
|
|
|
- EdbSourceNameMap[v.EdbSourceId] = v.SourceName
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
// GetEdbDataTableName 指标数据->存储表
|
|
|
func GetEdbDataTableName(source int) (tableName string) {
|
|
|
switch source {
|
|
@@ -180,7 +154,10 @@ func GetEdbDataTableName(source int) (tableName string) {
|
|
|
case utils.DATA_SOURCE_CALCULATE_RJZ: //日均值->75
|
|
|
tableName = "edb_data_calculate_rjz"
|
|
|
default:
|
|
|
- tableName = EdbDataTableNameMap[source] // 没有对应的从edb_source中取
|
|
|
+ edbSource := EdbSourceIdMap[source]
|
|
|
+ if edbSource != nil {
|
|
|
+ tableName = edbSource.TableName
|
|
|
+ }
|
|
|
}
|
|
|
return
|
|
|
}
|