queryOnLineCarWithRoute(@FieldMap Map< String, Object > parameters );
+
}
diff --git a/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshBody.java b/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshBody.java
index 281ecdef93..769aa2c6a1 100644
--- a/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshBody.java
+++ b/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshBody.java
@@ -16,6 +16,7 @@ public class RefreshBody {
public int radius = 2_000; // 地理围栏半径(米)
public LatLon location; // 坐标
+ public String sn;
public boolean onlyFocus; // 是否仅查询已关注的好友
public boolean onlySameCity; // 是否仅查询注册城市相同的同城用户
diff --git a/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshCallback.java b/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshCallback.java
index 64575bb66c..34a46cd615 100644
--- a/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshCallback.java
+++ b/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshCallback.java
@@ -6,9 +6,9 @@ package com.mogo.module.service.network;
*
* 刷新回调
*/
-public interface RefreshCallback {
+public interface RefreshCallback {
- void onSuccess();
+ void onSuccess(T o);
void onFail();
}
diff --git a/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshModel.java b/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshModel.java
index caffd2596e..528814792b 100644
--- a/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshModel.java
+++ b/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/RefreshModel.java
@@ -7,7 +7,9 @@ import com.mogo.commons.data.BaseData;
import com.mogo.commons.debug.DebugConfig;
import com.mogo.commons.network.ParamsProvider;
import com.mogo.commons.network.SubscribeImpl;
+import com.mogo.commons.network.Utils;
import com.mogo.map.MogoLatLng;
+import com.mogo.module.common.entity.MarkerResponse;
import com.mogo.module.service.ServiceConst;
import com.mogo.service.MogoServicePaths;
import com.mogo.service.network.IMogoNetwork;
@@ -73,7 +75,7 @@ public class RefreshModel {
public void onSuccess(BaseData o) {
super.onSuccess(o);
if (callback != null) {
- callback.onSuccess();
+ callback.onSuccess(o);
}
}
@@ -129,7 +131,7 @@ public class RefreshModel {
public void onSuccess(BaseData o) {
super.onSuccess(o);
if (callback != null) {
- callback.onSuccess();
+ callback.onSuccess(o);
}
}
@@ -143,4 +145,52 @@ public class RefreshModel {
});
}
}
+
+
+ /**
+ * 查询车辆 及路线
+ *
+ * @param latLng 经纬度
+ * @param onlyFocus 是否仅查询已关注的好友
+ * @param onlySameCity 是否仅查询注册城市相同的同城用户
+ * @param callback
+ */
+ public void queryOnLineCarWithRoute(MogoLatLng latLng,
+ boolean onlyFocus,
+ boolean onlySameCity,
+ final RefreshCallback callback){
+ if (mRefreshApiService != null) {
+ final Map query = new ParamsProvider.Builder(mContext).build();
+ final RefreshBody refreshBody = new RefreshBody();
+ refreshBody.sn = Utils.getSn();
+ refreshBody.location = new RefreshBody.LatLon(latLng.lat, latLng.lng);
+ refreshBody.onlyFocus = onlyFocus;
+ refreshBody.onlySameCity = onlySameCity;
+
+ query.put("data", GsonUtil.jsonFromObject(refreshBody));
+ mRefreshApiService.queryOnLineCarWithRoute(query)
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread())
+ .subscribe(new SubscribeImpl(RequestOptions.create(mContext)){
+ @Override
+ public void onSuccess(MarkerResponse o) {
+ super.onSuccess(o);
+ if (callback != null) {
+ callback.onSuccess(o);
+ }
+ }
+
+ @Override
+ public void onError(String message, int code) {
+ super.onError(message, code);
+ if (callback != null) {
+ callback.onFail();
+ }
+ }
+ });
+ }
+ }
+
+
+
}