package models import ( "errors" "eta/eta_data_init/utils" "fmt" "github.com/beego/beego/v2/client/orm" "strings" "time" ) type EdbClassifyItem struct { ClassifyID int64 `orm:"column(classify_id);pk"` ClassifyType uint32 ClassifyName string ParentID int64 HasData int32 CreateTime time.Time ModifyTime time.Time SysUserID int64 SysUserRealName string Level int64 UniqueCode string Sort uint32 RootID int64 LastModifyUserID uint32 LastModifyUserName string } // GetAllEdbClassifyListByCondition // @Description: 获取分类列表 // @author: Roc // @datetime 2024-02-29 10:55:38 // @param condition string // @param pars []interface{} // @return item []*EdbInfoUpdateLog // @return err error func GetAllEdbClassifyListByCondition(condition string, pars []interface{}) (item []*EdbClassifyItem, err error) { o := orm.NewOrmUsingDB("data") sql := ` SELECT * FROM edb_classify WHERE 1=1 ` if condition != "" { sql += condition } sql += ` ORDER BY classify_id ASC ` _, err = o.Raw(sql, pars).QueryRows(&item) return } type EdbInfoItem struct { CalculateFormula string `json:"calculate_formula"` Calendar string `json:"calendar"` ChartImage string `json:"chart_image"` ClassifyId int `json:"classify_id"` CreateTime string `json:"create_time"` DataDateType string `json:"data_date_type"` DataUpdateTime string `json:"data_update_time"` EdbCode string `json:"edb_code"` EdbInfoId int `json:"edb_info_id"` EdbInfoType int `json:"edb_info_type"` EdbName string `json:"edb_name"` EdbNameEn string `json:"edb_name_en"` EdbNameSource string `json:"edb_name_source"` EdbType int `json:"edb_type"` EmptyType int `json:"empty_type"` EndDate string `json:"end_date"` EndValue float64 `json:"end_value"` ErDataUpdateDate string `json:"er_data_update_date"` Extra string `json:"extra"` Frequency string `json:"frequency"` IndicatorCode string `json:"indicator_code"` IsUpdate int `json:"is_update"` LatestDate string `json:"latest_date"` LatestValue float64 `json:"latest_value"` ManualSave int `json:"manual_save"` MaxEmptyType int `json:"max_empty_type"` MaxValue float64 `json:"max_value"` MinValue float64 `json:"min_value"` ModifyTime string `json:"modify_time"` MoveFrequency string `json:"move_frequency"` MoveType int `json:"move_type"` NoUpdate int `json:"no_update"` ServerUrl string `json:"server_url"` Sort int `json:"sort"` Source int `json:"source"` SourceIndexName string `json:"source_index_name"` SourceName string `json:"source_name"` StartDate string `json:"start_date"` StockCode string `json:"stock_code"` SubSource int `json:"sub_source"` SubSourceName string `json:"sub_source_name"` SysUserId int `json:"sys_user_id"` SysUserRealName string `json:"sys_user_real_name"` TerminalCode string `json:"terminal_code"` UniqueCode string `json:"unique_code"` Unit string `json:"unit"` UnitEn string `json:"unit_en"` } // GetAllEdbInfoListByCondition // @Description: 获取所有的指标 // @author: Roc // @datetime 2024-02-29 10:55:38 // @param condition string // @param pars []interface{} // @return item []*EdbInfoUpdateLog // @return err error func GetAllEdbInfoListByCondition(condition string, pars []interface{}) (item []*EdbInfoItem, err error) { o := orm.NewOrmUsingDB("data") sql := ` SELECT * FROM edb_info WHERE 1=1 ` if condition != "" { sql += condition } sql += ` ORDER BY edb_info_id ASC ` _, err = o.Raw(sql, pars).QueryRows(&item) return } type EdbData struct { EdbDataId int32 `orm:"column(edb_data_id);pk" json:"edb_data_id"` EdbInfoId int32 `json:"edb_info_id"` // 指标id EdbCode string `json:"edb_code"` // 指标编码 //DataTime time.Time `json:"data_time"` // 数据日期 DataTime string `json:"data_time"` // 数据日期 Value float64 `json:"value"` // 数据值 //CreateTime time.Time `json:"create_time"` // 创建时间 //ModifyTime time.Time `json:"modify_time"` // 修改时间 CreateTime string `json:"create_time"` // 创建时间 ModifyTime string `json:"modify_time"` // 修改时间 DataTimestamp int64 `json:"data_timestamp"` // 数据日期时间戳 } // GetAllEdbDataListByCondition // @Description: 根据指标id和表名获取指标数据 // @author: Roc // @datetime 2024-03-14 13:22:01 // @param tableName string // @param edbInfoId int // @return item []*EdbData // @return err error func GetAllEdbDataListByCondition(tableName string, edbInfoId int) (item []*EdbData, err error) { if tableName == `` { err = errors.New("错误的表名") return } o := orm.NewOrmUsingDB("data") sql := fmt.Sprintf(` SELECT * FROM %s WHERE 1=1 and edb_info_id = ? `, tableName) sql += ` ORDER BY edb_data_id ASC ` _, err = o.Raw(sql, edbInfoId).QueryRows(&item) return } type BaseFromMysteelChemicalIndexItem struct { BaseFromMysteelChemicalIndexId int32 `json:"base_from_mysteel_chemical_index_id"` BaseFromMysteelChemicalClassifyId int32 `json:"base_from_mysteel_chemical_classify_id"` // 钢联化工指标分类id IndexCode string `json:"index_code"` // 指标编码 IndexName string `json:"index_name"` // 指标名称 Unit string `json:"unit"` // 单位 Source string `json:"source"` // 数据来源 Frequency string `json:"frequency"` // 频度 StartDate string `json:"start_date"` // 开始日期 EndDate string `json:"end_date"` // 结束日期 Describe string `json:"describe"` // 指标描述 UpdateWeek string `json:"update_week"` // 更新周期 UpdateTime string `json:"update_time"` // 更新时间，多个时间点用英文,隔开 UpdateTime2 string `json:"update_time2"` // 更新时间2 SysUserId int32 `json:"sys_user_id"` // 创建人id SysUserRealName string `json:"sys_user_real_name"` // 创建人姓名 CreateTime string `json:"create_time"` // 创建时间 ModifyTime string `json:"modify_time"` // 修改时间 FilePath string `json:"file_path"` // 文件存储路径 Sort int32 `json:"sort"` // 排序 MergeFilePath string `json:"merge_file_path"` FileIndex int32 `json:"file_index"` MergeUpdateWeek string `json:"merge_update_week"` // 合并文件的更新周 MergeFilePathWeek string `json:"merge_file_path_week"` // 更新文件 UpdateDate string `json:"update_date"` // 更新日期 IsRefresh int32 `json:"is_refresh"` // 0:不需要及时刷新,1:需要及时刷新 IsStop int32 `json:"is_stop"` // 是否停更:1:停更,0:未停更 TerminalCode string `json:"terminal_code"` // 所属终端编码 EndValue float64 `json:"end_value"` // 指标的最新值 } // GetBaseFromMysteelChemicalIndexItemByCode // @Description: 根据指标编码获取钢联指标详情 // @author: Roc // @datetime 2024-03-11 16:42:56 // @param edbCode string // @return item *BaseFromMysteelChemicalIndexItem // @return err error func GetBaseFromMysteelChemicalIndexItemByCode(edbCode string) (item *BaseFromMysteelChemicalIndexItem, err error) { o := orm.NewOrmUsingDB("data") sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE index_code = ?` err = o.Raw(sql, edbCode).QueryRow(&item) return } type BaseFromSmmIndexItem struct { BaseFromSmmIndexId int32 `json:"base_from_smm_index_id"` ClassifyId int32 `json:"classify_id"` // Smm原始数据指标分类id Interface string `json:"interface"` Name string `json:"name"` IndexCode string `json:"index_code"` // 指标编码 IndexName string `json:"index_name"` // 指标名称 Type1 string `json:"type_1"` // 类型1 Type2 string `json:"type_2"` // 类型2 Type3 string `json:"type_3"` // 类型3 Frequency string `json:"frequency"` // 频度 Unit string `json:"unit"` // 单位 ApiStartTime string `json:"api_start_time"` // 接口开始日期 ApiUpdateTime string `json:"api_update_time"` // 接口更新日期 StartTime string `json:"start_time"` // 开始日期 FinishTime string `json:"finish_time"` // 完成日期 CreateTime string `json:"create_time"` ModifyTime string `json:"modify_time"` StartDate string `json:"start_date"` EndDate string `json:"end_date"` IsGet int32 `json:"is_get"` // 0:未获取数据,1:已获取数据 Sort int32 `json:"sort"` // 排序 BaseFileName string `json:"base_file_name"` // 文件目录 RenameFileName string `json:"rename_file_name"` // 重命名文件目录 TerminalCode string `json:"terminal_code"` // 所属终端编码 DataState string `json:"data_state"` // 指标数据状态 normal/空白-正常更新 ceased-已停更irregular-更新依赖外部会有不定期延迟 ReleaseTime string `json:"release_time"` // 预计发布时间 IsStop int32 `json:"is_stop"` // 是否停更:1:停更,0:未停更 EndValue float64 `json:"end_value"` // 指标的最新值 } // GetBaseFromSmmIndexItemItemByCode // @Description: 根据指标编码获取指标信息 // @author: Roc // @datetime 2024-03-11 16:41:02 // @param source int // @param edbCode string // @return item *BaseFromSmmIndexItem // @return err error func GetBaseFromSmmIndexItemItemByCode(edbCode string) (item *BaseFromSmmIndexItem, err error) { o := orm.NewOrmUsingDB("data") sql := ` SELECT * FROM base_from_smm_index WHERE index_code=? ` err = o.Raw(sql, edbCode).QueryRow(&item) return } // GetEdbDataTableName 指标数据->存储表 func GetEdbDataTableName(source, subSource int) (tableName string) { switch source { case utils.DATA_SOURCE_THS: tableName = "edb_data_ths" if subSource == utils.DATA_SUB_SOURCE_DATE { tableName = "edb_data_ths_ds" } else { tableName = "edb_data_ths" } case utils.DATA_SOURCE_WIND: if subSource == utils.DATA_SUB_SOURCE_DATE { tableName = "edb_data_wind_wsd" } else { tableName = "edb_data_wind" } case utils.DATA_SOURCE_PB, utils.DATA_SOURCE_PB_FINANCE: //彭博经济数据、彭博财务数据 tableName = "edb_data_pb" case utils.DATA_SOURCE_CALCULATE: tableName = "edb_data_calculate" case utils.DATA_SOURCE_CALCULATE_LJZZY: tableName = "edb_data_calculate_ljzzy" case utils.DATA_SOURCE_CALCULATE_TBZ: tableName = "edb_data_calculate_tbz" case utils.DATA_SOURCE_CALCULATE_TCZ: tableName = "edb_data_calculate_tcz" case utils.DATA_SOURCE_CALCULATE_NSZYDPJJS: tableName = "edb_data_calculate_nszydpjjs" case utils.DATA_SOURCE_MANUAL: tableName = "edb_data_manual" case utils.DATA_SOURCE_LZ: tableName = "edb_data_lz" case utils.DATA_SOURCE_YS: tableName = "edb_data_ys" case utils.DATA_SOURCE_CALCULATE_HBZ: tableName = "edb_data_calculate_hbz" case utils.DATA_SOURCE_CALCULATE_HCZ: tableName = "edb_data_calculate_hcz" case utils.DATA_SOURCE_CALCULATE_BP: tableName = "edb_data_calculate_bp" case utils.DATA_SOURCE_GL: tableName = "edb_data_gl" case utils.DATA_SOURCE_ZZ: tableName = "edb_data_zz" case utils.DATA_SOURCE_DL: tableName = "edb_data_dl" case utils.DATA_SOURCE_SH: tableName = "edb_data_sh" case utils.DATA_SOURCE_CFFEX: tableName = "edb_data_cffex" case utils.DATA_SOURCE_SHFE: tableName = "edb_data_ine" case utils.DATA_SOURCE_GIE: tableName = "edb_data_gie" case utils.DATA_SOURCE_CALCULATE_ZJPJ: tableName = "edb_data_calculate_zjpj" case utils.DATA_SOURCE_CALCULATE_TIME_SHIFT: tableName = "edb_data_calculate_time_shift" case utils.DATA_SOURCE_CALCULATE_LJZTBPJ: 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" case utils.DATA_SOURCE_GOOGLE_TRAVEL: tableName = "edb_data_google_travel" case utils.DATA_SOURCE_PREDICT_CALCULATE: tableName = "edb_data_predict_calculate" case utils.DATA_SOURCE_PREDICT_CALCULATE_TBZ: tableName = "edb_data_predict_calculate_tbz" case utils.DATA_SOURCE_PREDICT_CALCULATE_TCZ: tableName = "edb_data_predict_calculate_tcz" case utils.DATA_SOURCE_MYSTEEL_CHEMICAL: tableName = "edb_data_mysteel_chemical" case utils.DATA_SOURCE_CALCULATE_CJJX: tableName = "edb_data_calculate_cjjx" case utils.DATA_SOURCE_EIA_STEO: tableName = "edb_data_eia_steo" case utils.DATA_SOURCE_CALCULATE_NHCC: tableName = "edb_data_calculate_nhcc" case utils.DATA_SOURCE_COM_TRADE: tableName = "edb_data_com_trade" case utils.DATA_SOURCE_PREDICT_CALCULATE_NSZYDPJJS: tableName = "edb_data_predict_calculate_nszydpjjs" case utils.DATA_SOURCE_CALCULATE_ADJUST: tableName = "edb_data_calculate_adjust" case utils.DATA_SOURCE_SCI: tableName = "edb_data_sci" case utils.DATA_SOURCE_PREDICT_CALCULATE_LJZZY: tableName = "edb_data_predict_calculate_ljzzy" case utils.DATA_SOURCE_PREDICT_CALCULATE_TIME_SHIFT: tableName = "edb_data_predict_calculate_time_shift" case utils.DATA_SOURCE_PREDICT_CALCULATE_ZJPJ: tableName = "edb_data_predict_calculate_zjpj" case utils.DATA_SOURCE_PREDICT_CALCULATE_LJZTBPJ: tableName = "edb_data_predict_calculate_ljztbpj" case utils.DATA_SOURCE_PREDICT_CALCULATE_NHCC: tableName = "edb_data_predict_calculate_nhcc" case utils.DATA_SOURCE_PREDICT_CALCULATE_CJJX: tableName = "edb_data_predict_calculate_cjjx" case utils.DATA_SOURCE_PREDICT_CALCULATE_HBZ: tableName = "edb_data_predict_calculate_hbz" case utils.DATA_SOURCE_PREDICT_CALCULATE_HCZ: tableName = "edb_data_predict_calculate_hcz" case utils.DATA_SOURCE_PREDICT_CALCULATE_BP: tableName = "edb_data_predict_calculate_bp" case utils.DATA_SOURCE_CALCULATE_JP: tableName = "edb_data_calculate_jp" case utils.DATA_SOURCE_CALCULATE_NH: tableName = "edb_data_calculate_nh" case utils.DATA_SOURCE_CALCULATE_KSZS: tableName = "edb_data_calculate_kszs" case utils.DATA_SOURCE_PREDICT_CALCULATE_JP: tableName = "edb_data_predict_calculate_jp" case utils.DATA_SOURCE_PREDICT_CALCULATE_NH: tableName = "edb_data_predict_calculate_nh" case utils.DATA_SOURCE_PREDICT_CALCULATE_KSZS: tableName = "edb_data_predict_calculate_kszs" case utils.DATA_SOURCE_BAIINFO: tableName = "edb_data_baiinfo" case utils.DATA_SOURCE_STOCK_PLANT: tableName = "edb_data_stock_plant" case utils.DATA_SOURCE_CALCULATE_CORRELATION: tableName = "edb_data_calculate_correlation" case utils.DATA_SOURCE_NATIONAL_STATISTICS: tableName = "edb_data_national_statistics" case utils.DATA_SOURCE_CALCULATE_LJZZJ: //累计值转季 -> 61 tableName = "edb_data_calculate_ljzzj" case utils.DATA_SOURCE_CALCULATE_LJZ: //累计值 -> 62 tableName = "edb_data_calculate_ljz" case utils.DATA_SOURCE_CALCULATE_LJZNCZJ: //累计值(年初至今） -> 63 tableName = "edb_data_calculate_ljznczj" case utils.DATA_SOURCE_PREDICT_CALCULATE_LJZZJ: // 预测指标 - 累计值 -> 65 tableName = "edb_data_predict_calculate_ljzzj" case utils.DATA_SOURCE_PREDICT_CALCULATE_LJZ: //预测指标 - 累计值转季->64 tableName = "edb_data_predict_calculate_ljz" case utils.DATA_SOURCE_PREDICT_CALCULATE_LJZNCZJ: //预测指标 - 累计值(年初至今） -> 66 tableName = "edb_data_predict_calculate_ljznczj" case utils.DATA_SOURCE_CALCULATE_STANDARD_DEVIATION: //标准差->67 tableName = "edb_data_calculate_standard_deviation" case utils.DATA_SOURCE_CALCULATE_PERCENTILE: //百分位->68 tableName = "edb_data_calculate_percentile" case utils.DATA_SOURCE_PREDICT_CALCULATE_STANDARD_DEVIATION: //预测标准差->69 tableName = "edb_data_predict_ccalculate_standard_deviation" case utils.DATA_SOURCE_PREDICT_CALCULATE_PERCENTILE: //预测百分位->70 tableName = "edb_data_predict_ccalculate_percentile" case utils.DATA_SOURCE_FUBAO: //富宝-71 tableName = "edb_data_fubao" case utils.DATA_SOURCE_CALCULATE_ZSXY: tableName = "edb_data_calculate_zsxy" // 指数修匀->72 case utils.DATA_SOURCE_PREDICT_CALCULATE_ZSXY: tableName = "edb_data_predict_calculate_zsxy" // 预测指数修匀->73 case utils.DATA_SOURCE_CALCULATE_ZDYFX: tableName = "edb_data_calculate_zdyfx" // 自定义分析->74 case utils.DATA_SOURCE_CALCULATE_RJZ: //日均值->75 tableName = "edb_data_calculate_rjz" case utils.DATA_SOURCE_GFEX: //广州期货交易所->78 tableName = "edb_data_gz" case utils.DATA_SOURCE_ICPI: //ICPI消费价格指数->79 tableName = "edb_data_icpi" default: edbSource := EdbSourceIdMap[source] if edbSource != nil { tableName = edbSource.TableName } } return } // GetSourceAndSubSourceTableName 存储表->指标数据 func GetSourceAndSubSourceTableName(tableName, edbCode string) (source, subSource int) { switch tableName { case "edb_data_ths": source = utils.DATA_SOURCE_THS case "edb_data_ths_ds": source = utils.DATA_SOURCE_THS subSource = utils.DATA_SUB_SOURCE_DATE case "edb_data_wind": source = utils.DATA_SOURCE_WIND case "edb_data_wind_wsd": source = utils.DATA_SOURCE_WIND subSource = utils.DATA_SUB_SOURCE_DATE case "edb_data_pb": source = utils.DATA_SOURCE_PB // 彭博财务 if strings.Contains(edbCode, "&&") { source = utils.DATA_SOURCE_PB_FINANCE } case "edb_data_calculate": source = utils.DATA_SOURCE_CALCULATE case "edb_data_calculate_ljzzy": source = utils.DATA_SOURCE_CALCULATE_LJZZY case "edb_data_calculate_tbz": source = utils.DATA_SOURCE_CALCULATE_TBZ case "edb_data_calculate_tcz": source = utils.DATA_SOURCE_CALCULATE_TCZ case "edb_data_calculate_nszydpjjs": source = utils.DATA_SOURCE_CALCULATE_NSZYDPJJS case "edb_data_manual": source = utils.DATA_SOURCE_MANUAL case "edb_data_lz": source = utils.DATA_SOURCE_LZ case "edb_data_ys": source = utils.DATA_SOURCE_YS case "edb_data_calculate_hbz": source = utils.DATA_SOURCE_CALCULATE_HBZ case "edb_data_calculate_hcz": source = utils.DATA_SOURCE_CALCULATE_HCZ case "edb_data_calculate_bp": source = utils.DATA_SOURCE_CALCULATE_BP case "edb_data_gl": source = utils.DATA_SOURCE_GL case "edb_data_zz": source = utils.DATA_SOURCE_ZZ case "edb_data_dl": source = utils.DATA_SOURCE_DL case "edb_data_sh": source = utils.DATA_SOURCE_SH case "edb_data_cffex": source = utils.DATA_SOURCE_CFFEX case "edb_data_ine": source = utils.DATA_SOURCE_SHFE case "edb_data_gie": source = utils.DATA_SOURCE_GIE case "edb_data_calculate_zjpj": source = utils.DATA_SOURCE_CALCULATE_ZJPJ case "edb_data_calculate_time_shift": source = utils.DATA_SOURCE_CALCULATE_TIME_SHIFT case "edb_data_calculate_ljztbpj": source = utils.DATA_SOURCE_CALCULATE_LJZTBPJ case "edb_data_lt": source = utils.DATA_SOURCE_LT case "edb_data_coal": source = utils.DATA_SOURCE_COAL case "edb_data_python": source = utils.DATA_SOURCE_PYTHON case "edb_data_google_travel": source = utils.DATA_SOURCE_GOOGLE_TRAVEL case "edb_data_predict_calculate": source = utils.DATA_SOURCE_PREDICT_CALCULATE case "edb_data_predict_calculate_tbz": source = utils.DATA_SOURCE_PREDICT_CALCULATE_TBZ case "edb_data_predict_calculate_tcz": source = utils.DATA_SOURCE_PREDICT_CALCULATE_TCZ case "edb_data_mysteel_chemical": source = utils.DATA_SOURCE_MYSTEEL_CHEMICAL case "edb_data_calculate_cjjx": source = utils.DATA_SOURCE_CALCULATE_CJJX case "edb_data_eia_steo": source = utils.DATA_SOURCE_EIA_STEO case "edb_data_calculate_nhcc": source = utils.DATA_SOURCE_CALCULATE_NHCC case "edb_data_com_trade": source = utils.DATA_SOURCE_COM_TRADE case "edb_data_predict_calculate_nszydpjjs": source = utils.DATA_SOURCE_PREDICT_CALCULATE_NSZYDPJJS case "edb_data_calculate_adjust": source = utils.DATA_SOURCE_CALCULATE_ADJUST case "edb_data_sci": source = utils.DATA_SOURCE_SCI case "edb_data_predict_calculate_ljzzy": source = utils.DATA_SOURCE_PREDICT_CALCULATE_LJZZY case "edb_data_predict_calculate_time_shift": source = utils.DATA_SOURCE_PREDICT_CALCULATE_TIME_SHIFT case "edb_data_predict_calculate_zjpj": source = utils.DATA_SOURCE_PREDICT_CALCULATE_ZJPJ case "edb_data_predict_calculate_ljztbpj": source = utils.DATA_SOURCE_PREDICT_CALCULATE_LJZTBPJ case "edb_data_predict_calculate_nhcc": source = utils.DATA_SOURCE_PREDICT_CALCULATE_NHCC case "edb_data_predict_calculate_cjjx": source = utils.DATA_SOURCE_PREDICT_CALCULATE_CJJX case "edb_data_predict_calculate_hbz": source = utils.DATA_SOURCE_PREDICT_CALCULATE_HBZ case "edb_data_predict_calculate_hcz": source = utils.DATA_SOURCE_PREDICT_CALCULATE_HCZ case "edb_data_predict_calculate_bp": source = utils.DATA_SOURCE_PREDICT_CALCULATE_BP case "edb_data_calculate_jp": source = utils.DATA_SOURCE_CALCULATE_JP case "edb_data_calculate_nh": source = utils.DATA_SOURCE_CALCULATE_NH case "edb_data_calculate_kszs": source = utils.DATA_SOURCE_CALCULATE_KSZS case "edb_data_predict_calculate_jp": source = utils.DATA_SOURCE_PREDICT_CALCULATE_JP case "edb_data_predict_calculate_nh": source = utils.DATA_SOURCE_PREDICT_CALCULATE_NH case "edb_data_predict_calculate_kszs": source = utils.DATA_SOURCE_PREDICT_CALCULATE_KSZS case "edb_data_baiinfo": source = utils.DATA_SOURCE_BAIINFO case "edb_data_stock_plant": source = utils.DATA_SOURCE_STOCK_PLANT case "edb_data_calculate_correlation": source = utils.DATA_SOURCE_CALCULATE_CORRELATION case "edb_data_national_statistics": source = utils.DATA_SOURCE_NATIONAL_STATISTICS case "edb_data_calculate_ljzzj": //累计值转季 -> 61 source = utils.DATA_SOURCE_CALCULATE_LJZZJ case "edb_data_calculate_ljz": //累计值 -> 62 source = utils.DATA_SOURCE_CALCULATE_LJZ case "edb_data_calculate_ljznczj": //累计值(年初至今） -> 63 source = utils.DATA_SOURCE_CALCULATE_LJZNCZJ case "edb_data_predict_calculate_ljzzj": // 预测指标 - 累计值 -> 65 source = utils.DATA_SOURCE_PREDICT_CALCULATE_LJZZJ case "edb_data_predict_calculate_ljz": //预测指标 - 累计值转季->64 source = utils.DATA_SOURCE_PREDICT_CALCULATE_LJZ case "edb_data_predict_calculate_ljznczj": //预测指标 - 累计值(年初至今） -> 66 source = utils.DATA_SOURCE_PREDICT_CALCULATE_LJZNCZJ case "edb_data_calculate_standard_deviation": //标准差->67 source = utils.DATA_SOURCE_CALCULATE_STANDARD_DEVIATION case "edb_data_calculate_percentile": //百分位->68 source = utils.DATA_SOURCE_CALCULATE_PERCENTILE case "edb_data_predict_ccalculate_standard_deviation": //预测标准差->69 source = utils.DATA_SOURCE_PREDICT_CALCULATE_STANDARD_DEVIATION case "edb_data_predict_ccalculate_percentile": //预测百分位->70 source = utils.DATA_SOURCE_PREDICT_CALCULATE_PERCENTILE case "edb_data_fubao": source = utils.DATA_SOURCE_FUBAO case "edb_data_calculate_zsxy": source = utils.DATA_SOURCE_CALCULATE_ZSXY // 指数修匀->72 case "edb_data_predict_calculate_zsxy": source = utils.DATA_SOURCE_PREDICT_CALCULATE_ZSXY // 预测指数修匀->73 case "edb_data_calculate_zdyfx": source = utils.DATA_SOURCE_CALCULATE_ZDYFX // 自定义分析->74 case "edb_data_calculate_rjz": //日均值75 source = utils.DATA_SOURCE_CALCULATE_RJZ default: edbSource := EdbTableNameSourceMap[tableName] if edbSource != nil { source = edbSource.EdbSourceId } } return }