yangyakun921/MoGoEagleEye
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[6.7.2]

Browse Source 
[fea]
[线程检测]
This commit is contained in:
yangyakun
2024-10-25 18:30:46 +08:00
parent ec6ee7d45c
commit f280f1bda0
2 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/model/EventModel.kt
View File

@@ -48,7 +48,9 @@ object EventModel : EventDb.EventCallback {
}
private fun checkDbData() {
SiteDb.checkData()
BizLoopManager.runInIoThread{
SiteDb.checkData()
}
}

8
OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/repository/RepositoryManager.kt
View File

@@ -3,6 +3,7 @@ package com.mogo.och.weaknet.repository
import com.mogo.commons.env.ProjectUtils
import com.mogo.eagle.core.data.config.FunctionBuildConfig
import com.mogo.eagle.core.utilcode.mogo.AppIdentityModeUtils
import com.mogo.eagle.core.utilcode.mogo.logger.CallerLogger
import com.mogo.och.common.module.network.OchCommonServiceCallback
import com.mogo.och.weaknet.bean.response.CarExecutableTaskResponse
import com.mogo.och.weaknet.repository.db.bean.LineDataBean
@@ -16,21 +17,25 @@ import io.reactivex.Observable
object RepositoryManager {
private val TAG = "RepositoryManager"
private var repository: IRepository?=null
get() {
if(field==null){
if(ProjectUtils.isSaas()){
if(AppIdentityModeUtils.isShuttle(FunctionBuildConfig.appIdentityMode)) {
repository = ShuttleSaasRepository()
CallerLogger.d(TAG,"saas shuttle 支持db")
}else if(AppIdentityModeUtils.isBus(FunctionBuildConfig.appIdentityMode)) {
repository = BusSaasRepository()
CallerLogger.d(TAG,"saas bus 不支持db")
}
}else {
if(AppIdentityModeUtils.isShuttle(FunctionBuildConfig.appIdentityMode)) {
repository = ShuttleRepository()
CallerLogger.d(TAG,"非saas shuttle 不支持db")
}else if(AppIdentityModeUtils.isBus(FunctionBuildConfig.appIdentityMode)) {
repository = BusRepository()
CallerLogger.d(TAG,"非saas bus 不支持db")
}
}
}
@@ -38,6 +43,7 @@ object RepositoryManager {
}
fun release(){
CallerLogger.d(TAG,"重置 repository")
repository = null
}