From cdb0aafaf39347fdb417c85b095803e10e4943d9 Mon Sep 17 00:00:00 2001
From: yangyakun <yangyakun@zhidaoauto.com>
Date: Mon, 5 Sep 2022 16:45:48 +0800
Subject: [PATCH] =?UTF-8?q?[fix]=20=E4=B9=98=E5=AE=A2=E7=AB=AF=204s?=
 =?UTF-8?q?=E6=9F=A5=E8=B7=AF=20=20=E8=8E=B7=E5=8F=96=E8=B7=AF=E7=82=B9?=
 =?UTF-8?q?=E5=A4=B1=E8=B4=A52s=E5=90=8E=E9=87=8D=E8=AF=95=20=20=E7=99=BB?=
 =?UTF-8?q?=E5=BD=95=E6=8F=90=E5=89=8D=E6=B8=85=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../passenger/model/TaxiPassengerModel.java     | 17 +++++++++++++++--
 .../TaxiPassengerServingOrderPresenter.java     | 14 +++++++++++---
 .../java/com/mogo/och/taxi/ui/TaxiFragment.java |  2 +-
 3 files changed, 27 insertions(+), 6 deletions(-)

diff --git a/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/model/TaxiPassengerModel.java b/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/model/TaxiPassengerModel.java
index 06ce8ec0f4..c3070eb0ba 100644
--- a/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/model/TaxiPassengerModel.java
+++ b/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/model/TaxiPassengerModel.java
@@ -67,7 +67,10 @@ import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.TimeUnit;
 
+import io.reactivex.Observable;
+import io.reactivex.disposables.Disposable;
 import io.reactivex.exceptions.UndeliverableException;
 import io.reactivex.functions.Consumer;
 import io.reactivex.plugins.RxJavaPlugins;
@@ -108,6 +111,9 @@ public class TaxiPassengerModel implements IOCHTaxiPassengerNaviChangedCallback
 
     private ITaxiPassengerVeloctityCallback mVeloctityCallback;//道路限速返回
 
+    private Disposable subscribe;
+    private int delayTime = 2;
+
     private double mLongitude, mLatitude;
 
     private List<LatLng> mLocationsModels = new ArrayList<>();
@@ -209,6 +215,9 @@ public class TaxiPassengerModel implements IOCHTaxiPassengerNaviChangedCallback
         startOrStopOrderLoop(false);
         startOrStopQueryOrderRemaining(false);
         releaseListeners();
+        if(subscribe!=null&&!subscribe.isDisposed()){
+            subscribe.dispose();
+        }
     }
 
     private void initListeners() {
@@ -720,13 +729,17 @@ public class TaxiPassengerModel implements IOCHTaxiPassengerNaviChangedCallback
                          startOrStopRouteAndWipe(true);
                      }
                  }else {
-                     queryOrderRouteList();
+                     subscribe = Observable.timer(delayTime, TimeUnit.SECONDS).subscribe(aLong -> {
+                         queryOrderRouteList();
+                     });
                  }
              }
 
              @Override
              public void onFail(int code, String msg) {
-                 queryOrderRouteList();
+                 subscribe = Observable.timer(delayTime, TimeUnit.SECONDS).subscribe(aLong -> {
+                     queryOrderRouteList();
+                 });
              }
          });
     }
diff --git a/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/presenter/TaxiPassengerServingOrderPresenter.java b/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/presenter/TaxiPassengerServingOrderPresenter.java
index 48cb45f36e..089dee2fc9 100644
--- a/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/presenter/TaxiPassengerServingOrderPresenter.java
+++ b/OCH/mogo-och-taxi-passenger/src/main/java/com/mogo/och/taxi/passenger/presenter/TaxiPassengerServingOrderPresenter.java
@@ -24,11 +24,8 @@ import com.mogo.och.taxi.passenger.model.TaxiPassengerGeocodeSearchModel;
 import com.mogo.och.taxi.passenger.model.TaxiPassengerModel;
 import com.mogo.och.taxi.passenger.ui.TaxiPassengerServingOrderFragment;
 
-import java.util.ArrayList;
 import java.util.List;
 
-import mogo.telematics.pad.MessagePad;
-
 import static com.mogo.eagle.core.utilcode.mogo.logger.scene.SceneConstant.M_TAXI_P;
 
 /**
@@ -54,9 +51,11 @@ public class TaxiPassengerServingOrderPresenter extends Presenter<TaxiPassengerS
     }
 
     private void initListener() {
+        // 设置起点和终点marker和实时车辆位置
         TaxiPassengerModel.getInstance().setMoGoAutopilotPlanningListener(this);
         TaxiPassengerModel.getInstance().setOrderStatusCallback("TaxiPassengerServingOrderPresenter",this);
         TaxiPassengerModel.getInstance().setControllerStatusCallback("TaxiPassengerServingOrderPresenter",this);
+        // 获取道路限速
         TaxiPassengerModel.getInstance().setVeloctityCallback(this);
     }
 
@@ -132,10 +131,19 @@ public class TaxiPassengerServingOrderPresenter extends Presenter<TaxiPassengerS
 
     }
 
+    private long startTime = 0;
+    private static final long TIMEINTERVAL = 4000;
+
     @Override
     public void onCarLocationChanged(Location location) {
         if (location != null){
             runOnUIThread(() -> mView.onCarLocationChanged(location));
+            long currentTimeMillis = System.currentTimeMillis();
+            if(currentTimeMillis-startTime<TIMEINTERVAL){
+                return;
+            }
+            CallerLogger.INSTANCE.d(M_TAXI_P + TAG,"onCarLocationChanged 获取当前路的信息");
+            startTime = currentTimeMillis;
             TaxiPassengerGeocodeSearchModel.getInstance(getContext()).searchLocationInfo(location.getLatitude(),location.getLongitude());
         }
     }
diff --git a/OCH/mogo-och-taxi/src/main/java/com/mogo/och/taxi/ui/TaxiFragment.java b/OCH/mogo-och-taxi/src/main/java/com/mogo/och/taxi/ui/TaxiFragment.java
index 319bcc9533..305a7372c8 100644
--- a/OCH/mogo-och-taxi/src/main/java/com/mogo/och/taxi/ui/TaxiFragment.java
+++ b/OCH/mogo-och-taxi/src/main/java/com/mogo/och/taxi/ui/TaxiFragment.java
@@ -396,8 +396,8 @@ public class TaxiFragment extends BaseTaxiTabFragment<TaxiFragment, TaxiPresente
             }
             taxiLoginDialog.show(getParentFragmentManager(), taxiLoginDialog.getTag());
             taxiLoginDialog.setOnDismissListener(dialog -> {
-                mPresenter.queryLoginStatus();
                 taxiLoginDialogFragment.clear();
+                mPresenter.queryLoginStatus();
             });
         }
     }