|
@@ -7,7 +7,6 @@ import com.framework.app.base.IRepository
|
|
|
import com.framework.mvvm.model.data.Data
|
|
|
import com.framework.mvvm.model.data.dataSource
|
|
|
import com.framework.mvvm.model.data.request
|
|
|
-import com.framework.mvvm.model.data.toDb
|
|
|
import com.framework.mvvm.model.db.AdmDatabase
|
|
|
import com.framework.mvvm.model.db.entity.*
|
|
|
import com.framework.mvvm.model.vo.AdmRequest
|
|
@@ -78,8 +77,34 @@ class AdmRepository(
|
|
|
return db.infosConfigDao().getConfigByObjType(type)
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 请求框架数据
|
|
|
+ */
|
|
|
+ suspend fun requestFrame(request: AdmRequest) {
|
|
|
+ request(
|
|
|
+ from = { api.getFrame(request) },
|
|
|
+ to = { frame ->
|
|
|
+ println("frame: $frame")
|
|
|
+ val projects = frame.projects
|
|
|
+ val objects = frame.buildingsAndFloors
|
|
|
+ try {
|
|
|
+ db.projectDao().insProject(projects)
|
|
|
+ db.objectDao().insObjects(objects)
|
|
|
+ } catch (e: Exception) {
|
|
|
+ Log.d("IRepository:${AdmRepository::class.simpleName}", e.message!!)
|
|
|
+ }
|
|
|
+ },
|
|
|
+ error = {
|
|
|
+ Log.d("requestFrame error: ", it)
|
|
|
+ }
|
|
|
+ )
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 请求字典数据
|
|
|
+ */
|
|
|
suspend fun requestDict(request: AdmRequest) {
|
|
|
- toDb(
|
|
|
+ request(
|
|
|
from = { api.getDict(request) },
|
|
|
to = { define ->
|
|
|
|
|
@@ -95,7 +120,7 @@ class AdmRepository(
|
|
|
|
|
|
try {
|
|
|
db.pipeConfigDao().insConfigs(pipeConfig)
|
|
|
- db.infosConfigDao().insConfigs(infosConfig) // wu
|
|
|
+ db.infosConfigDao().insConfigs(infosConfig)
|
|
|
db.configDao().insConfigs(config)
|
|
|
db.m2dEquipDao().insM2ds(m2dTypes)
|
|
|
db.relConfigDao().insConfigs(relConfig)
|
|
@@ -110,9 +135,11 @@ class AdmRepository(
|
|
|
)
|
|
|
}
|
|
|
|
|
|
-
|
|
|
+ /**
|
|
|
+ * 请求建筑数据
|
|
|
+ */
|
|
|
suspend fun requestBuilding(request: AdmRequest) {
|
|
|
- toDb(
|
|
|
+ request(
|
|
|
from = { api.getBuilding(request) },
|
|
|
to = { building ->
|
|
|
val file = building.file
|