配合修改收不到can数据问题

core/function-impl/mogo-core-function-main/build.gradle

@@ -60,6 +60,8 @@ dependencies {
     implementation rootProject.ext.dependencies.arouter
     kapt rootProject.ext.dependencies.aroutercompiler
 
+    implementation rootProject.ext.dependencies.mogoami
+
     if (Boolean.valueOf(USE_MAVEN_PACKAGE)) {
         implementation rootProject.ext.dependencies.mogoaicloudservicesdk
         implementation rootProject.ext.dependencies.mogocommons

core/function-impl/mogo-core-function-main/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java

@@ -17,6 +17,7 @@ import com.mogo.commons.AbsMogoApplication;
 import com.mogo.commons.constants.SharedPrefsConstants;
 import com.mogo.commons.debug.DebugConfig;
 import com.mogo.commons.network.Utils;
+import com.mogo.eagle.core.data.constants.MoGoConfig;
 import com.mogo.eagle.core.data.constants.MogoServicePaths;
 import com.mogo.eagle.core.data.map.MogoLocation;
 import com.mogo.map.MapApiPath;
@@ -38,6 +39,7 @@ import com.mogo.utils.ProcessUtils;
 import com.mogo.utils.logger.Logger;
 import com.mogo.utils.storage.SharedPrefsMgr;
 import com.zhidao.boot.persistent.lib.PersistentManager;
+import com.zhidao.support.obu.ami.AmiClientManager;
 
 /**
  * 默认初始化一些基础服务配置
@@ -160,7 +162,11 @@ public abstract class MainMoGoApplication extends AbsMogoApplication {
         clientConfig.setThirdPartyDeviceId(Utils.getDevicesId());
         // 设置循环检测间隔时间
         clientConfig.setLoopCheckDelay(5 * 1000);
+        //连接ami
+        connectAmiIp();
 
+//        todo 使用旧链路
+//        clientConfig.setUseOriginSocket(true);
 
         clientConfig.setIHttpDnsCurrentLocation(() -> {
             MogoLocation mogoLocation =
@@ -220,6 +226,15 @@ public abstract class MainMoGoApplication extends AbsMogoApplication {
         );
     }
 
+    /**
+     * 连接ami
+     */
+    private void connectAmiIp() {
+        String ipAddress = SharedPrefsMgr.getInstance(AbsMogoApplication.getApp().getBaseContext()).getString(MoGoConfig.OBU_IP, "192.168.1.199");
+        Logger.d("OnAdasListenerAdapter", "application --ipAddress = " + ipAddress);
+        AmiClientManager.getInstance().setObuIp(ipAddress);
+    }
+
     /**
      * 上传自车位置信息到云端
      */