@@ -263,9 +263,9 @@ func GetEdbDataTableNameAndSubSource(source, subSource int) (tableName string) {
}
case utils.DATA_SOURCE_THS:
if subSource == utils.DATA_SUB_SOURCE_EDB {
- tableName = "edb_data_ths"
- } else {
tableName = "edb_data_ths_ds"
+ } else {
+ tableName = "edb_data_ths"
default:
edbSource := EdbSourceIdMap[source]
@@ -193,6 +193,8 @@ func DeleteEdbInfoAndData(edbInfoId, source, subSource int) (err error) {
} else {
if source == utils.DATA_SOURCE_WIND {
tableName = "edb_data_wind_wsd"
+ } else if source == utils.DATA_SOURCE_THS {
+ tableName = "edb_data_ths_ds"