[charter] 司机端到轮询

OCH/mogo-och-charter/src/driverm1/java/com/magic/mogo/och/charter/model/DriverM1LooperManager.kt

@@ -30,9 +30,10 @@ object DriverM1LooperManager {
         )
             .map { aLong: Long -> aLong + 1 }
             .subscribeOn(Schedulers.io())
-            .observeOn(AndroidSchedulers.mainThread())
-            .subscribe {
-                DriverM1Model.get().queryCurrentServiceStatus()
+            .subscribe { aLong: Long? ->
+                aLong?.let {
+                    DriverM1Model.get().queryCurrentServiceStatus()
+                }
             }
     }
 
@@ -55,9 +56,10 @@ object DriverM1LooperManager {
         )
             .map { aLong: Long -> aLong + 1 }
             .subscribeOn(Schedulers.io())
-            .observeOn(AndroidSchedulers.mainThread())
-            .subscribe {
-                DriverM1Model.get().checkOrderCountDown()
+            .subscribe {aLong: Long? ->
+                aLong?.let {
+                    DriverM1Model.get().checkOrderCountDown()
+                }
             }
     }
 

OCH/mogo-och-charter/src/driverm1/java/com/magic/mogo/och/charter/model/DriverM1Model.kt

@@ -377,6 +377,7 @@ class DriverM1Model {
     }
 
     private fun onArriveAt() {
+        isArrivedStation = true
        // todo 需要告诉前后外屏到站
     }
 
@@ -559,6 +560,7 @@ class DriverM1Model {
                     if (data == null || data.code != 0){
                         return
                     }
+                    stopQueryCurrentOrder()
                     d(SceneConstant.M_CHARTER_D + TAG, "queryCurrentServiceStatus success = "
                       + GsonUtils.toJson(data.data))
 

OCH/mogo-och-charter/src/driverm1/java/com/magic/mogo/och/charter/presenter/DriverM1Presenter.kt

@@ -68,12 +68,12 @@ class DriverM1Presenter(view: DriverM1Fragment?) :
             // 查询服务状态
             DriverM1Model.get().queryCurrentServiceStatus()
         } else {
-            DriverM1Model.get().stopQueryCurrentOrder()
+            DriverM1Model.get().startQueryCurrentOrder()
         }
     }
 
     override fun loginFail(isLogin: Boolean) {
-        DriverM1Model.get().stopQueryCurrentOrder()
+        DriverM1Model.get().startQueryCurrentOrder()
     }
 
     // 登出