网约车 为解决工控机拿不到sn 临时方案

modules/mogo-module-adas/src/main/java/com/mogo/module/adas/AdasProvider.java

@@ -52,6 +52,7 @@ public class AdasProvider implements IProvider {
     }
 
     public void setBasicInfo(){
+        Logger.e("lianglihui","setBasicInfo");
         BasicInfo info = new BasicInfo();
         info.setSn(MoGoAiCloudClientConfig.getInstance().getSn());
         AdasManager.getInstance().setBasicInfo(info);

services/mogo-service/src/main/java/com/mogo/service/impl/adas/MogoADASController.java

@@ -67,8 +67,14 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.concurrent.TimeUnit;
 
+import io.reactivex.Observable;
+import io.reactivex.disposables.Disposable;
 import io.reactivex.schedulers.Schedulers;
+import rx.android.schedulers.AndroidSchedulers;
+
+import static rx.android.schedulers.AndroidSchedulers.mainThread;
 
 /**
  * @author congtaowang
@@ -347,6 +353,8 @@ public class MogoADASController implements IMogoADASController {
 
                 //测试网约车
                 //testOCH();
+                // TODO: 2021/6/30 临时解决方案
+                timeLoop();
             }
 
             @Override
@@ -749,6 +757,8 @@ public class MogoADASController implements IMogoADASController {
         adasProvider.removeAdasEventListener(mAdasDataListener);
         adasProvider.removeAdasStatusListener();
         //AutopilotServiceManage.getInstance().release();
+        //关闭定时任务
+        if (mDisposable != null) mDisposable.dispose();
     }
 
     @Override
@@ -935,4 +945,23 @@ public class MogoADASController implements IMogoADASController {
     public void mockAdasRecognized(String json) {
         mAdasDataListener.cameraEyeDetectResult(json);
     }
+
+
+    private static final int PERIOD = 5 * 1000;
+    private static final int DELAY = 10000;
+    private Disposable mDisposable;
+
+    /**
+     * 定时循环任务
+     */
+    private void timeLoop() {
+        mDisposable = Observable.interval(DELAY, PERIOD, TimeUnit.MILLISECONDS)
+                .map((aLong -> aLong + 1))
+                .subscribeOn(Schedulers.io())
+                .subscribe(aLong ->
+                        adasProvider.setBasicInfo()
+                );//getUnreadCount()执行的任务
+    }
 }
+
+