From 2aff9cab16708c40236d5e35c667fd82251ec771 Mon Sep 17 00:00:00 2001
From: lixiaopeng <lixiaopeng@zhidaoauto.com>
Date: Thu, 24 Mar 2022 14:39:58 +0800
Subject: [PATCH] opt

---
 .../core/function/main/MainMoGoApplication.java  |  2 +-
 .../function/obu/mogo/MogoPrivateObuManager.kt   | 16 +++++++++++++++-
 2 files changed, 16 insertions(+), 2 deletions(-)

diff --git a/core/function-impl/mogo-core-function-main/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java b/core/function-impl/mogo-core-function-main/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java
index 1736c94d14..2c5518a4b8 100644
--- a/core/function-impl/mogo-core-function-main/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java
+++ b/core/function-impl/mogo-core-function-main/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java
@@ -341,7 +341,7 @@ public abstract class MainMoGoApplication extends AbsMogoApplication {
         // 调度
         MogoModulePaths.addBaseModule(new MogoModule(MogoServicePaths.PATH_AI_DISPATCH, "IDispatchProvider"));
         // V2X 模块
-        MogoModulePaths.addBaseModule(new MogoModule(MogoServicePaths.PATH_V2X_MODULE, "V2XProvider"));
+//        MogoModulePaths.addBaseModule(new MogoModule(MogoServicePaths.PATH_V2X_MODULE, "V2XProvider"));
         // 自动驾驶系统检测模块
         MogoModulePaths.addBaseModule(new MogoModule(MogoServicePaths.PATH_CHECK, "CheckProvider"));
         // 推送模块
diff --git a/core/function-impl/mogo-core-function-obu-mogo/src/main/java/com/mogo/eagle/core/function/obu/mogo/MogoPrivateObuManager.kt b/core/function-impl/mogo-core-function-obu-mogo/src/main/java/com/mogo/eagle/core/function/obu/mogo/MogoPrivateObuManager.kt
index befc31de96..c3538bfb40 100644
--- a/core/function-impl/mogo-core-function-obu-mogo/src/main/java/com/mogo/eagle/core/function/obu/mogo/MogoPrivateObuManager.kt
+++ b/core/function-impl/mogo-core-function-obu-mogo/src/main/java/com/mogo/eagle/core/function/obu/mogo/MogoPrivateObuManager.kt
@@ -2,6 +2,7 @@ package com.mogo.eagle.core.function.obu.mogo
 
 import android.content.Context
 import android.telecom.Call
+import android.util.Log
 import com.alibaba.android.arouter.launcher.ARouter
 import com.mogo.eagle.core.data.config.FunctionBuildConfig
 import com.mogo.eagle.core.data.constants.MogoServicePaths
@@ -394,6 +395,18 @@ class MogoPrivateObuManager private constructor() {
                 && info.ext_info.lights != null
                 && info.ext_info.lights.isNotEmpty()
             ) {
+                //v2i数据传输延迟
+                val hvTime = info.threat_info.hv_time.millisecond
+                val currentTime = TimeUtils.getNowMills()
+                val delayTime = currentTime - hvTime
+                //TODO
+                Log.e("liyz", "onCvxIvpThreatIndInfo hvTime--->  $hvTime --- currentTime =  $currentTime")
+                CallerObuListenerManager.invokeDelayTime(delayTime)
+                CallerLogger.e(
+                        "$M_OBU${MogoObuConst.TAG_MOGO_OBU}",
+                        "onCvxIvpThreatIndInfo red ---delayTime---> $delayTime"
+                )
+
                 handlerTrafficLight(
                         info.threat_info.app_id,
                         info.status,
@@ -405,6 +418,7 @@ class MogoPrivateObuManager private constructor() {
 
         // (2) 弱势交通参与者预警信息：CVX_PTC_THREAT_IND
         override fun onCvxPtcThreatIndInfo(info: CvxPtcThreatIndInfo?) {
+            Log.e("liyz", "onCvxPtcThreatIndInfo --->  $info")
             CallerLogger.d("$M_OBU${MogoObuConst.TAG_MOGO_OBU}", "onCvxPtcInfoIndInfo ------> $info")
             // 交通参与者类型 0x0:未知 UNKNOWN | 0x1:非机动车 NON_MOTOR | 0x2:行人 PEDESTRIAN 0x3:RSU
             if (info != null && (info.ptc_type == 1 || info.ptc_type == 2)) {
@@ -412,8 +426,8 @@ class MogoPrivateObuManager private constructor() {
                 val hvTime = info.threat_info.hv_time.millisecond
                 val currentTime = TimeUtils.getNowMills()
                 val delayTime = currentTime - hvTime
+                Log.e("liyz", "onCvxPtcThreatIndInfo hvTime--->  $hvTime --- currentTime =  $currentTime")
                 CallerObuListenerManager.invokeDelayTime(delayTime)
-
                 CallerLogger.d(
                         "$M_OBU${MogoObuConst.TAG_MOGO_OBU}",
                         "onCvxPtcInfoIndInfo ---delayTime---> $delayTime"