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

[8.1.0]多链路数据控制

Browse Source
This commit is contained in:
xuxinchao
2025-06-07 15:17:13 +08:00
parent 9943888855
commit 6a2c64289b
14 changed files with 597 additions and 264 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/autopilot/MoGoAutopilotControlProvider.kt
View File

@@ -1616,4 +1616,53 @@ class MoGoAutopilotControlProvider :
return AdasManager.getInstance().sendCloudConfigRequest() > -1
}
/**
* NDE下行感知进PNC开关
* @param enable 0: 不发给PnC 1:发给Pnc
*/
override fun sendNdeDownPerceptionToPnc(enable: Int): Boolean {
return AdasManager.getInstance().sendNdeDownPerceptionToPnc(enable) > -1
}
/**
* NDE下行事件进PNC开关
* @param enable 0: 不发给PnC 1:发给Pnc
*/
override fun sendNdeDownEventToPnc(enable: Int): Boolean {
return AdasManager.getInstance().sendNdeDownEventToPnc(enable) > -1
}
/**
* V2I下行感知进PNC开关
* @param enable 0: 不发给PnC 1:发给Pnc
*/
override fun sendV2iDownPerceptionToPnc(enable: Int): Boolean {
return AdasManager.getInstance().sendV2iDownPerceptionToPnc(enable) > -1
}
/**
* 云端配置控制
* @param type 0:蘑菇云 1:NDE云 2:基础平台云
* @param direction 0:上行和下行 1:上行 2:下行 当 type == 0 或 1 时 此值只能是 0（蘑菇云和NDE云只能上下行同时控制；当 type == 2 时 此值不能是 0（基础平台云只能上下行分开控制）；
* @param enable 连接使能开关, true:开 false:关闭
*/
override fun sendForceStopOrStartCloudReq(type: Int, direction: Int, enable: Boolean): Boolean {
return AdasManager.getInstance().sendForceStopOrStartCloudReq(type, direction, enable) > -1
}
/**
* 域控上报OBU开关控制
* @param enable 0:关 1:开
*/
override fun sendSetObuUploadReq(enable: Int): Boolean {
return AdasManager.getInstance().sendSetObuUploadReq(enable) > -1
}
/**
* 域控上报OBU开关状态查询
*/
override fun sendObuUploadStatusQuery(): Boolean {
return AdasManager.getInstance().sendObuUploadStatusQuery() > -1
}
}

7
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/autopilot/adapter/MoGoAdasListenerImpl.kt
View File

@@ -88,7 +88,7 @@ import com.mogo.eagle.core.function.call.autopilot.CallerV2XListenerManager
import com.mogo.eagle.core.function.call.autopilot.CallerV2nNioEventListenerManager
import com.mogo.eagle.core.function.call.devatools.CallerCaptureImgManager
import com.mogo.eagle.core.function.call.devatools.CallerDiskCopyManager
import com.mogo.eagle.core.function.call.devatools.CallerImgUploadCloudManager
import com.mogo.eagle.core.function.call.devatools.CallerV2XManager
import com.mogo.eagle.core.function.call.devatools.CallerOTAManager
import com.mogo.eagle.core.function.call.msgbox.CallerMsgBoxManager
import com.mogo.eagle.core.function.call.obu.CallerObuMapMathListenerManager
@@ -1308,6 +1308,7 @@ class MoGoAdasListenerImpl : OnAdasListener {
) {
FunctionBuildConfig.fusionMode = adasParam.fusionMode
CallerAutopilotGetParamResponseDispatcher.dispatchResponse(header, getParamResp, adasParam)
CallerV2XManager.invokeGetParamResp(getParamResp, adasParam)
}
/**
@@ -1485,13 +1486,14 @@ class MoGoAdasListenerImpl : OnAdasListener {
override fun onCloudConfig(header: MessagePad.Header, config: MessagePad.CloudConfig) {
CallerCloudConfigListenerManager.invokeCloudConfig(config)
CallerV2XManager.invokeCloudConfig(config)
}
override fun onImgUploadCloudStatusResp(
header: MessagePad.Header,
resp: MessagePad.ImgUploadCloudStatusResp
) {
CallerImgUploadCloudManager.invokeImgUploadCloudStatusResp(resp)
CallerV2XManager.invokeImgUploadCloudStatusResp(resp)
}
/**
@@ -1594,6 +1596,7 @@ class MoGoAdasListenerImpl : OnAdasListener {
* @param enable 数据
*/
override fun onObuUploadStatus(header: MessagePad.Header, enable: MessagePad.SetEnableReq) {
CallerV2XManager.invokeObuUploadStatus(enable)
}
/**