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

[dev_arch_opt_3.0] 添加设置obu发送频率控制

Browse Source
This commit is contained in:
lixiaopeng
2023-03-23 11:20:06 +08:00
parent 7b45dc91ad
commit 6b03ac3050
7 changed files with 73 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/obu/MoGoObuProvider.kt
View File

@@ -82,4 +82,8 @@ class MoGoObuProvider : IMoGoObuProvider {
override fun deleteObuFile() {
MogoPrivateObuNewManager.INSTANCE.deleteObuFile()
}
override fun setHvInfoSendCycle(time: Int) {
MogoPrivateObuNewManager.INSTANCE.setHvInfoSendCycle(time)
}
}

8
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/obu/MogoPrivateObuNewManager.kt
View File

@@ -1,6 +1,7 @@
package com.mogo.eagle.core.function.datacenter.obu
import android.content.Context
import android.util.Log
import com.mogo.eagle.core.data.config.FunctionBuildConfig
import com.mogo.eagle.core.data.config.HmiBuildConfig
import com.mogo.eagle.core.data.enums.*
@@ -74,6 +75,7 @@ class MogoPrivateObuNewManager private constructor() : OnUpgradeListener {
.registerTopic(MogoObuTopicId.RSI_WARNING)
.registerTopic(MogoObuTopicId.RSM_WARNING)
.registerTopic(MogoObuTopicId.MAP_MATCH)
.registerTopic(MogoObuTopicId.OBU_SYSTEM_STATUS)
.build()
//每次连接的时候如果连接连接了，先断开，防止ip改变等导致的连接失败
@@ -103,6 +105,11 @@ class MogoPrivateObuNewManager private constructor() : OnUpgradeListener {
}
}
fun setHvInfoSendCycle(time: Int) {
Log.d("liyz", "---setHvInfoSendCycle = time = $time")
// ObuManager.getInstance().setHvInfoPushCycle(time);
}
/**
* 当前的obu版本
*/
@@ -199,6 +206,7 @@ class MogoPrivateObuNewManager private constructor() : OnUpgradeListener {
* @param data 系统状态
*/
override fun onObuSystemStatus(data: MogoObuSystemStatusData?) {
Log.d("liyz", "data.toString() = ${data.toString()}" )
CallerObuInfoListenerManager.invokeGetObuInfo(data.toString())
}