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

Merge branch 'dev_robotaxi-d_241112_6.8.0' into dev_robotaxi-d_241202_6.8.2

Browse Source
This commit is contained in:
xyz
2024-12-04 14:13:34 +08:00
parent acd15af0fa cc422a1eb2
commit 5dfff8a249
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/autopilot/telematic/TeleMsgHandler.kt
View File

@@ -83,6 +83,7 @@ class TeleMsgHandler : IMsgHandler {
private var listener: EventListener? = null
@Volatile
private var lastTimeOnReceiveDriveVideo = 0L
override fun handleMsgFromServer(msg: MogoProtocolMsg?, channel: Channel?) {
@@ -205,7 +206,6 @@ class TeleMsgHandler : IMsgHandler {
it["open"] = true
it["playUrl"] = playUrl
})
CallerTelematicManager.sendMsgToServer(TelematicConstant.DRIVE_SEAT_VIDEO_STREAM_RSP, "11".toByteArray())
} else {
MogoAnalyticUtils.track("DriveSeatVideoStream", HashMap<String, Any>().also {
it["step"] = 2
@@ -223,6 +223,7 @@ class TeleMsgHandler : IMsgHandler {
Log.d(TAG, "--- poller -> $it")
if (!it) {
// 设备离线了，乘客屏的驾驶位视频控件要移除
lastTimeOnReceiveDriveVideo = 0L
CallerOchBizFunctionCall4EagleManager.setVideoView(null)
}
CallerTelematicManager.sendMsgToServer(TelematicConstant.DRIVE_SEAT_VIDEO_STREAM_RSP, if (it) "1".toByteArray() else "0".toByteArray())
@@ -230,6 +231,7 @@ class TeleMsgHandler : IMsgHandler {
CallerOchBizFunctionCall4EagleManager.setVideoView(target)
lastTimeOnReceiveDriveVideo = SystemClock.elapsedRealtime()
CallerTelematicManager.sendMsgToServer(TelematicConstant.DRIVE_SEAT_VIDEO_STREAM_RSP, "11".toByteArray())
}
} else {
MogoAnalyticUtils.track("DriveSeatVideoStream", HashMap<String, Any>().also {
@@ -241,6 +243,7 @@ class TeleMsgHandler : IMsgHandler {
}
} else {
//第1个0代表运营面板开关关闭，第2个1代表关闭成功，告之司机端; 相应的还有状态：00表示关闭失败
lastTimeOnReceiveDriveVideo = 0L
CallerTelematicManager.sendMsgToServer(TelematicConstant.DRIVE_SEAT_VIDEO_STREAM_RSP, "01".toByteArray())
CallerOchBizFunctionCall4EagleManager.setVideoView(null)
MogoAnalyticUtils.track("DriveSeatVideoStream", HashMap<String, Any>().also {