merge code
This commit is contained in:
@@ -624,23 +624,25 @@ class ImportOMDBHelper @AssistedInject constructor(
|
|||||||
if(renderEntity.properties.containsKey("geometry")){
|
if(renderEntity.properties.containsKey("geometry")){
|
||||||
renderEntity.properties.remove("geometry")
|
renderEntity.properties.remove("geometry")
|
||||||
}
|
}
|
||||||
|
Log.d("ImportOMDBHelper", "解析===1insert")
|
||||||
Realm.getInstance(currentInstallTaskConfig).insert(renderEntity)
|
Realm.getInstance(currentInstallTaskConfig).insert(renderEntity)
|
||||||
|
Log.d("ImportOMDBHelper", "解析===2insert")
|
||||||
|
}
|
||||||
|
if (currentConfig.table == "OMDB_RD_LINK") {
|
||||||
|
listResult.add(renderEntity)
|
||||||
}
|
}
|
||||||
|
|
||||||
listResult.add(renderEntity)
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 如果当前解析的是OMDB_RD_LINK数据,将其缓存在预处理类中,以便后续处理其他要素时使用
|
// 如果当前解析的是OMDB_RD_LINK数据,将其缓存在预处理类中,以便后续处理其他要素时使用
|
||||||
if (currentConfig.table == "OMDB_RD_LINK") {
|
if (currentConfig.code == DataCodeEnum.OMDB_RD_LINK.code.toInt()) {
|
||||||
importConfig.preProcess.cacheRdLink =
|
importConfig.preProcess.cacheRdLink =
|
||||||
listResult.associateBy { it.properties["linkPid"] }
|
listResult.associateBy { it.properties["linkPid"] }
|
||||||
}
|
}
|
||||||
// 1个文件发送一次flow流
|
// 1个文件发送一次flow流
|
||||||
emit("${++processIndex}/${tableNum}")
|
emit("${++processIndex}/${tableNum}")
|
||||||
|
Log.d("ImportOMDBHelper", "表解析===2${currentConfig.table }")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Realm.getInstance (currentInstallTaskConfig).commitTransaction()
|
Realm.getInstance (currentInstallTaskConfig).commitTransaction()
|
||||||
|
|||||||
2
vtm
2
vtm
Submodule vtm updated: d1ac330cf7...3ea6a7c906
Reference in New Issue
Block a user