add xingyun obu

modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/V2XObuManager.java

@@ -8,6 +8,7 @@ import android.os.Handler;
 import android.os.Message;
 import android.os.SystemClock;
 import android.util.ArrayMap;
+import android.util.Log;
 
 import androidx.localbroadcastmanager.content.LocalBroadcastManager;
 
@@ -32,10 +33,15 @@ import com.zhidao.mogo.module.obu.obu.IObuCallback;
 import com.zhidao.mogo.module.obu.obu.bean.MogoObuEventInfo;
 import com.zhidao.mogo.module.obu.obu.bean.MogoObuLocationInfo;
 import com.zhidao.mogo.module.obu.obu.bean.MogoObuTrafficLightInfo;
+//import com.zhidao.support.nebulaobu.NebulaObuClient;
+//import com.zhidao.support.nebulaobu.OnObuListener;
+//import com.zhidao.support.nebulaobu.model.ActiveSafetyInfo;
+//import com.zhidao.support.nebulaobu.model.ObuInfo;
 
 import org.json.JSONArray;
 import org.json.JSONObject;
 
+import java.util.List;
 import java.util.Map;
 
 import static com.mogo.module.v2x.V2XConst.MODULE_NAME;
@@ -76,14 +82,59 @@ public class V2XObuManager implements IObuCallback, Handler.Callback {
 
     public void init(Context context) {
         Logger.d(MODULE_NAME, "obuManager初始化--");
+        //之前内部对接的obu
         obuManager = new ObuManager();
         obuManager.init(context);
         obuManager.registerObuDataChangedListener(this);
 
+        Logger.d("liyz", "obuManager初始化------> ");
+        //使用adas部门obu sdk (星云)
+//        NebulaObuClient.getInstance().init(context);
+//        NebulaObuClient.getInstance().registerObu(100);
+//        NebulaObuClient.getInstance().registerObuListener(listener);
+
         IntentFilter filter = new IntentFilter("com.mogo.launcher.v2x.action.EXCHANGE_OBU_TYPE");
         context.registerReceiver(obuTypeExchangeReceiver, filter);
     }
 
+
+//    public void release() {
+//        NebulaObuClient.getInstance().unregisterObu();
+//        NebulaObuClient.getInstance().unregisterObuListener();
+//    }
+
+
+    /**
+     * 星云obu数据监听
+     */
+//    private OnObuListener listener = new OnObuListener() {
+//        @Override
+//        public void onRegister() {
+//            Log.d("liyz", "onRegister ------> ");
+//        }
+//
+//        @Override
+//        public void onConnectFail(boolean isNeedReconnect) {
+//            Log.d("liyz", "onConnectFail ------> ");
+//        }
+//
+//        @Override
+//        public void onUnregister() {
+//            Log.d("liyz", "onUnregister ------> ");
+//        }
+//
+//        @Override
+//        public void onObuInfo(ObuInfo info) {
+//            Log.d("liyz", "onObuInfo ------> ");
+//        }
+//
+//        @Override
+//        public void onWarningInfo(List<ActiveSafetyInfo> infoList) {
+//            Log.d("liyz", "onWarningInfo ------> ");
+//        }
+//    };
+
+
     /**
      * 用来处理30秒内不重复播报的情况
      */