getLastADASRecognizedResult();
-}
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/connect/IMogoOnMessageListener.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/connect/IMogoOnMessageListener.java
new file mode 100644
index 0000000..136f8da
--- /dev/null
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/connect/IMogoOnMessageListener.java
@@ -0,0 +1,14 @@
+package com.mogo.realtime.connect;
+
+/**
+ * @author congtaowang
+ * @since 2019-12-31
+ *
+ * 消息回调
+ */
+public interface IMogoOnMessageListener< T > {
+
+ Class< T > target();
+
+ void onMsgReceived(T obj);
+}
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/connect/MsgBody.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/connect/MsgBody.java
new file mode 100644
index 0000000..e9f895d
--- /dev/null
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/connect/MsgBody.java
@@ -0,0 +1,71 @@
+package com.mogo.realtime.connect;
+
+/**
+ * @author congtaowang
+ * @since 2019-12-31
+ *
+ * 描述
+ */
+public class MsgBody {
+
+ /**
+ * 消息类型
+ */
+ private int mMsgType;
+
+// /**
+// * 服务端分发,业务线
+// */
+// private int mProductLine = MogoCommon.Product.mogoBussiness_VALUE;
+//
+// /**
+// *
+// */
+// private int mHeaderType = MogoConnsvr.MsgType.mogoMsgTypeDispatchSvrNoRspReq_VALUE;
+
+ /**
+ * 是否回执
+ */
+ private boolean mAck = false;
+
+ /**
+ * 消息ID
+ */
+ private final long mMsgId = System.currentTimeMillis();
+
+ /**
+ * 消息内容
+ */
+ private Object mContent;
+
+ public MsgBody msgType( int msgType ) {
+ this.mMsgType = msgType;
+ return this;
+ }
+
+ public MsgBody ack( boolean ack ) {
+ this.mAck = ack;
+ return this;
+ }
+
+ public MsgBody content( Object object ) {
+ this.mContent = object;
+ return this;
+ }
+
+ public int getMsgType() {
+ return mMsgType;
+ }
+
+ public boolean isAck() {
+ return mAck;
+ }
+
+ public long getMsgId() {
+ return mMsgId;
+ }
+
+ public Object getContent() {
+ return mContent;
+ }
+}
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/util/SimpleLocationCorrectStrategy.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/constant/SimpleLocationCorrectStrategy.java
similarity index 94%
rename from modules/mogo-realtime/src/main/java/com/mogo/realtime/util/SimpleLocationCorrectStrategy.java
rename to modules/mogo-realtime/src/main/java/com/mogo/realtime/constant/SimpleLocationCorrectStrategy.java
index d1d3795..426f119 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/util/SimpleLocationCorrectStrategy.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/constant/SimpleLocationCorrectStrategy.java
@@ -1,11 +1,10 @@
-package com.mogo.realtime.util;
+package com.mogo.realtime.constant;
import android.os.SystemClock;
-import com.mogo.map.MogoLatLng;
-import com.mogo.module.common.MogoApisHandler;
-import com.mogo.module.common.entity.CloudLocationInfo;
+import com.mogo.realtime.Interface.RealTimeApisHandler;
import com.mogo.realtime.entity.CloudLocationInfo;
+import com.mogo.realtime.util.MogoLatLng;
import com.mogo.utils.logger.Logger;
import java.util.ArrayList;
@@ -62,7 +61,7 @@ public class SimpleLocationCorrectStrategy {
try {
float targetDistance =
(float) (lastLocation.getSpeed() * (SystemClock.elapsedRealtime() - anchorTime) / 1000) + TARGET_DISTANCE_DEVIATION;
- float distance = MogoApisHandler.getInstance().getApis().getMapServiceApi().getMapUIController().calculateLineDistance(LocationParseUtil.cloudLocationToMogoLatLng(lastLocation), LocationParseUtil.cloudLocationToMogoLatLng(info));
+ float distance = RealTimeApisHandler.getInstance().getApis().getRecognizedResultManager().getDistanceBetweenTwoPoints();
Logger.d(TAG,
"准备计算{ lastInfo: " + lastLocation.print() + " info: " + info.print() + " targetDistance: " + targetDistance + " distance : " + distance + "}");
if (distance <= targetDistance) {
@@ -122,7 +121,7 @@ public class SimpleLocationCorrectStrategy {
try {
float targetDistance =
(float) (lastLocation.getSpeed() * (SystemClock.elapsedRealtime() - anchorTime) / 1000) + TARGET_DISTANCE_DEVIATION;
- float distance = MogoApisHandler.getInstance().getApis().getMapServiceApi().getMapUIController().calculateLineDistance(LocationParseUtil.cloudLocationToMogoLatLng(lastLocation), LocationParseUtil.cloudLocationToMogoLatLng(info));
+ float distance = RealTimeApisHandler.getInstance().getApis().getRecognizedResultManager().getDistanceBetweenTwoPoints();
Logger.d(TAG,
"异常定位点\n准备计算{ lastInfo: " + lastLocation.print() + " info: " + info.print() + " targetDistance: " + targetDistance + " distance : " + distance + "}");
// 按照上一个点的方向和速度,计算下一个点的位置,下一个点除坐标点外,其余数据与上一个点相同
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/constant/SnapshotUploadInTime.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/constant/SnapshotUploadInTime.java
index b2ea607..9eeaa58 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/constant/SnapshotUploadInTime.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/constant/SnapshotUploadInTime.java
@@ -4,18 +4,15 @@ import android.content.Context;
import android.util.Log;
import com.mogo.cloud.passport.MoGoAiCloudClient;
-import com.mogo.realtime.InterfaceManager.RealTimeApisHandler;
-import com.mogo.realtime.InterfaceManager.RealTimeServiceApis;
+import com.mogo.realtime.Interface.RealTimeApisHandler;
import com.mogo.realtime.entity.ADASRecognizedResult;
import com.mogo.realtime.entity.CloudLocationInfo;
import com.mogo.realtime.location.LocationResult;
import com.mogo.realtime.location.MogoRTKLocation;
import com.mogo.realtime.util.MortonCode;
-import com.mogo.realtime.util.SimpleLocationCorrectStrategy;
import com.mogo.realtime.websocket.OnePerSecondSendContent;
import java.util.List;
-import java.util.logging.Logger;
/**
* @author congtaowang
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/entity/CloudLocationInfo.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/entity/CloudLocationInfo.java
index ea09ba1..e9b665e 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/entity/CloudLocationInfo.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/entity/CloudLocationInfo.java
@@ -1,9 +1,11 @@
package com.mogo.realtime.entity;
+import android.os.Build;
import android.os.Parcel;
import android.os.Parcelable;
+import androidx.annotation.RequiresApi;
-import com.mogo.utils.CoordinateUtils;
+import com.mogo.cloud.commons.utils.CoordinateUtils;
import java.util.Objects;
@@ -167,6 +169,7 @@ public class CloudLocationInfo implements Parcelable {
Double.compare( that.lon, lon ) == 0;
}
+ @RequiresApi(api = Build.VERSION_CODES.KITKAT)
@Override
public int hashCode() {
return Objects.hash( lat, lon );
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/location/MogoRTKLocation.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/location/MogoRTKLocation.java
index 68bcf03..d515844 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/location/MogoRTKLocation.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/location/MogoRTKLocation.java
@@ -12,11 +12,13 @@ import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
+import com.mogo.cloud.passport.MoGoAiCloudClient;
import com.mogo.realtime.entity.CloudLocationInfo;
+import com.mogo.utils.WorkThreadHandler;
+import com.mogo.utils.logger.Logger;
import java.util.ArrayList;
import java.util.List;
-import java.util.logging.Logger;
public class MogoRTKLocation {
@@ -38,7 +40,7 @@ public class MogoRTKLocation {
}
private MogoRTKLocation() {
- mHandler = new Handler(WorkThreadHandler.newInstance( TAG ).getLooper() ) {
+ mHandler = new Handler(WorkThreadHandler.newInstance(TAG).getLooper()) {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
@@ -51,7 +53,7 @@ public class MogoRTKLocation {
}
};
mHandler.sendEmptyMessage(MSG_DATA_CHANGED);
- Logger.d(TAG,"构造方法开始发送消息");
+ Logger.d(TAG, "构造方法开始发送消息");
}
public interface RTKLocationListener {
@@ -73,12 +75,12 @@ public class MogoRTKLocation {
rtkLocationListener = locationListener;
}
- public void unregisterRTKLocationListener(){
+ public void unregisterRTKLocationListener() {
rtkLocationListener = null;
}
public void init() {
- locationManager = (LocationManager) AbsMogoApplication.getApp().getApplicationContext().getSystemService(Context.LOCATION_SERVICE);
+ locationManager = (LocationManager) MoGoAiCloudClient.getInstance().getContext().getSystemService(Context.LOCATION_SERVICE);
String provider = locationManager.getBestProvider(getCriteria(), true);
Logger.d(TAG, "init provider : " + provider);
if (locationManager.isProviderEnabled(LocationManager.GPS_PROVIDER)) {
@@ -96,9 +98,6 @@ public class MogoRTKLocation {
Logger.d(TAG, "RTK LocationManager Provider GPS_PROVIDER unable");
}
- // 注册修改上报间隔的广播, 临时使用,后面可直接干掉,发送广播的地方在EntranceFragment
- IntentFilter filter = new IntentFilter("com.mogo.launcher.action.FIX_UPLOAT_DELAY");
- AbsMogoApplication.getApp().registerReceiver(fixUploadDelayReceiver, filter);
}
private Criteria getCriteria() {
@@ -159,7 +158,7 @@ public class MogoRTKLocation {
private FixUploadDelayReceiver fixUploadDelayReceiver = new FixUploadDelayReceiver();
- private class FixUploadDelayReceiver extends BroadcastReceiver{
+ private class FixUploadDelayReceiver extends BroadcastReceiver {
@Override
public void onReceive(Context context, Intent intent) {
uploadDelay = intent.getIntExtra("fixTime", 0);
@@ -168,6 +167,7 @@ public class MogoRTKLocation {
/**
* 默认保持{@link #uploadDelay}间隔进行位置上报,如遇服务端控制,进行上报间隔修改
+ *
* @param delay 上报间隔
*/
public void resetUploadDelay(long delay) {
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/util/MogoLatLng.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/util/MogoLatLng.java
new file mode 100644
index 0000000..5b96069
--- /dev/null
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/util/MogoLatLng.java
@@ -0,0 +1,101 @@
+package com.mogo.realtime.util;
+
+import android.os.Build;
+import android.os.Parcel;
+import android.os.Parcelable;
+
+import androidx.annotation.RequiresApi;
+
+import java.util.Objects;
+
+/**
+ * @author congtaowang
+ * @since 2019-12-18
+ *
+ * 经纬度
+ */
+public class MogoLatLng implements Parcelable {
+
+ public final double lat;
+ @Deprecated
+ public final double lng;
+ public final double lon;
+
+ public MogoLatLng(double lat, double lon ) {
+ this.lat = lat;
+ this.lng = lon;
+ this.lon = lon;
+ }
+
+ public double getLat() {
+ return lat;
+ }
+
+ /**
+ * Deprecated, use {@link #getLon()} instead.
+ *
+ * @return
+ */
+ @Deprecated
+ public double getLng() {
+ return lng;
+ }
+
+ public double getLon() {
+ return lon;
+ }
+
+
+ @Override
+ public boolean equals( Object o ) {
+ if ( this == o ) return true;
+ if ( o == null || getClass() != o.getClass() ) return false;
+ MogoLatLng latLng = ( MogoLatLng ) o;
+ return Double.compare( latLng.lat, lat ) == 0 &&
+ Double.compare( latLng.lon, lon ) == 0;
+ }
+
+ @RequiresApi(api = Build.VERSION_CODES.KITKAT)
+ @Override
+ public int hashCode() {
+ return Objects.hash( lat, lng, lon );
+ }
+
+ @Override
+ public String toString() {
+ return "MogoLatLng{" +
+ "lat=" + lat +
+ ", lon=" + lon +
+ '}';
+ }
+
+ @Override
+ public int describeContents() {
+ return 0;
+ }
+
+ @Override
+ public void writeToParcel( Parcel dest, int flags ) {
+ dest.writeDouble( this.lat );
+ dest.writeDouble( this.lng );
+ dest.writeDouble( this.lon );
+ }
+
+ protected MogoLatLng(Parcel in ) {
+ this.lat = in.readDouble();
+ this.lng = in.readDouble();
+ this.lon = in.readDouble();
+ }
+
+ public static final Creator< MogoLatLng > CREATOR = new Creator< MogoLatLng >() {
+ @Override
+ public MogoLatLng createFromParcel( Parcel source ) {
+ return new MogoLatLng( source );
+ }
+
+ @Override
+ public MogoLatLng[] newArray( int size ) {
+ return new MogoLatLng[size];
+ }
+ };
+}
diff --git a/modules/mogo-tanlu/build.gradle b/modules/mogo-tanlu/build.gradle
index 0db5fac..9f280b6 100644
--- a/modules/mogo-tanlu/build.gradle
+++ b/modules/mogo-tanlu/build.gradle
@@ -1,14 +1,13 @@
-plugins {
- id 'com.android.library'
-}
+apply plugin: 'com.android.library'
+apply plugin: 'kotlin-android'
+apply plugin: 'kotlin-android-extensions'
android {
- compileSdkVersion 30
- buildToolsVersion "30.0.3"
+ compileSdkVersion rootProject.ext.android.compileSdkVersion
defaultConfig {
- minSdkVersion 26
- targetSdkVersion 30
+ minSdkVersion rootProject.ext.android.minSdkVersion
+ targetSdkVersion rootProject.ext.android.targetSdkVersion
versionCode 1
versionName "1.0"
@@ -29,21 +28,15 @@ android {
}
dependencies {
+ implementation fileTree(dir: "libs", include: ["*.jar"])
+ implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version"
+ implementation rootProject.ext.dependencies.androidxccorektx
- implementation 'androidx.appcompat:appcompat:1.2.0'
- implementation 'com.google.android.material:material:1.2.1'
- testImplementation 'junit:junit:4.+'
- androidTestImplementation 'androidx.test.ext:junit:1.1.2'
- androidTestImplementation 'androidx.test.espresso:espresso-core:3.3.0'
+ implementation rootProject.ext.dependencies.androidxappcompat
+ implementation rootProject.ext.dependencies.androidxconstraintlayout
- implementation rootProject.ext.dependencies.retrofit
- implementation rootProject.ext.dependencies.retrofitconvertergson
- implementation rootProject.ext.dependencies.gson
implementation rootProject.ext.dependencies.rxjava
-
- implementation 'com.elegant.spi:api:1.0.9'
- annotationProcessor 'com.elegant.spi:compiler:1.0.3'
-
- implementation project(path: ':foudations:mogo-passport')
+ implementation rootProject.ext.dependencies.rxandroid
implementation project(path: ':foudations:mogo-commons')
+
}
\ No newline at end of file
diff --git a/modules/mogo-tanlu/gradle.properties b/modules/mogo-tanlu/gradle.properties
new file mode 100644
index 0000000..7aa6551
--- /dev/null
+++ b/modules/mogo-tanlu/gradle.properties
@@ -0,0 +1,4 @@
+GROUP=com.mogo.cloud
+POM_ARTIFACT_ID=tanlu
+VERSION_CODE=1
+VERSION_NAME=1.0.0
\ No newline at end of file
diff --git a/modules/mogo-tanlu/src/androidTest/java/com/mogo/cloud/ExampleInstrumentedTest.java b/modules/mogo-tanlu/src/androidTest/java/com/mogo/cloud/ExampleInstrumentedTest.java
deleted file mode 100644
index 5643b64..0000000
--- a/modules/mogo-tanlu/src/androidTest/java/com/mogo/cloud/ExampleInstrumentedTest.java
+++ /dev/null
@@ -1,26 +0,0 @@
-package com.mogo.cloud;
-
-import android.content.Context;
-
-import androidx.test.platform.app.InstrumentationRegistry;
-import androidx.test.ext.junit.runners.AndroidJUnit4;
-
-import org.junit.Test;
-import org.junit.runner.RunWith;
-
-import static org.junit.Assert.*;
-
-/**
- * Instrumented test, which will execute on an Android device.
- *
- * @see Testing documentation
- */
-@RunWith(AndroidJUnit4.class)
-public class ExampleInstrumentedTest {
- @Test
- public void useAppContext() {
- // Context of the app under test.
- Context appContext = InstrumentationRegistry.getInstrumentation().getTargetContext();
- assertEquals("com.mogo.tanlu.test", appContext.getPackageName());
- }
-}
\ No newline at end of file
diff --git a/modules/mogo-tanlu/src/main/AndroidManifest.xml b/modules/mogo-tanlu/src/main/AndroidManifest.xml
index 0cca2d9..2c68fd6 100644
--- a/modules/mogo-tanlu/src/main/AndroidManifest.xml
+++ b/modules/mogo-tanlu/src/main/AndroidManifest.xml
@@ -1,5 +1,5 @@
+ package="com.mogo.cloud.tanlu">
\ No newline at end of file
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/UploadManager.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/UploadManager.java
deleted file mode 100644
index 093bfa6..0000000
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/UploadManager.java
+++ /dev/null
@@ -1,45 +0,0 @@
-package com.mogo.cloud;
-
-import android.content.Context;
-
-import com.mogo.cloud.api.ITanluUploadCallback;
-import com.mogo.cloud.bean.InformationBody;
-
-/**
- * @author lixiaopeng
- * @description
- * @since 2021/1/21
- */
-public class UploadManager {
- private static UploadManager sInstance;
- private Context mContext;
-
- private UploadManager (Context context) {
- mContext = context;
- }
-
- public static UploadManager getInstance(Context context) {
- if (sInstance == null) {
- synchronized (UploadManager.class) {
- sInstance = new UploadManager(context);
- }
- }
-
- return sInstance;
- }
-
- /**
- *
- * @param sn
- * @param informationBody
- * @param callback
- */
- public void loadUpload(String sn, InformationBody informationBody, ITanluUploadCallback callback) {
-
- }
-
-
-
-
-
-}
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/impl/LoadUploadImpl.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/impl/LoadUploadImpl.java
deleted file mode 100644
index 8e8fc6f..0000000
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/impl/LoadUploadImpl.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package com.mogo.cloud.impl;
-
-import com.mogo.cloud.api.ILoadUpload;
-import com.mogo.cloud.api.ITanluUploadCallback;
-import com.mogo.cloud.bean.InformationBody;
-
-/**
- * @author lixiaopeng
- * @description 请求上报
- * @since 2021/1/20
- */
-public class LoadUploadImpl {
-}
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/UploadManager.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/UploadManager.java
new file mode 100644
index 0000000..d76d728
--- /dev/null
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/UploadManager.java
@@ -0,0 +1,101 @@
+package com.mogo.cloud.tanlu;
+
+import android.content.Context;
+import android.util.Log;
+
+import com.google.gson.Gson;
+import com.mogo.cloud.commons.network.RetrofitFactory;
+import com.mogo.cloud.tanlu.api.ITanluUploadCallback;
+import com.mogo.cloud.tanlu.bean.InformationBody;
+import com.mogo.cloud.tanlu.bean.UploadResult;
+import com.mogo.cloud.tanlu.net.TanluApiService;
+import com.mogo.cloud.passport.MoGoAiCloudClient;
+
+
+import java.util.HashMap;
+import java.util.Map;
+
+import io.reactivex.Observer;
+import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.disposables.Disposable;
+import io.reactivex.schedulers.Schedulers;
+
+/**
+ * @author lixiaopeng
+ * @description
+ * @since 2021/1/21
+ */
+public class UploadManager {
+ private static final String TAG = "UploadManager";
+ private static UploadManager sInstance;
+ private Context mContext;
+ private TanluApiService apiService;
+
+
+ private UploadManager (Context context) {
+ mContext = context;
+ }
+
+ public static UploadManager getInstance(Context context) {
+ if (sInstance == null) {
+ synchronized (UploadManager.class) {
+ sInstance = new UploadManager(context);
+ }
+ }
+
+ return sInstance;
+ }
+
+ /**
+ *
+ * @param informationBody
+ * @param callback
+ *
+ */
+ public void loadUpload(InformationBody informationBody, ITanluUploadCallback callback) {
+ apiService = RetrofitFactory.INSTANCE.getInstance("http://dzt-test.zhidaozhixing.com")
+ .create(TanluApiService.class);
+
+ Gson gson = new Gson();
+ Map map = new HashMap<>();
+// map.put("sn", MoGoAiCloudClient.getInstance().getAiCloudClientConfig().getSn()); //TODO
+// map.put("data", gson.toJson(informationBody));
+
+ map.put("sn", "F803EB2046PZD00228");
+ map.put("data", "{\"addr\":\"北京市东城区小黄庄北街2号靠近中国银行(北京安贞桥支行)\",\"areaCode\":\"110101\",\"areaName\":\"东城区\",\"cityCode\":\"010\",\"cityName\":\"北京市\",\"data\":\"[{\\\"thumbnail\\\":\\\"http://petchfile-1255510688.cos.ap-beijing.myqcloud.com/CarPad/com.zhidao.roadcondition/F803EB2046PZD00228/F803EB2046PZD00228_20210121165329/Thumbnail1611219200669.jpg\\\",\\\"url\\\":\\\"http://petchfile-1255510688.cos.ap-beijing.myqcloud.com/CarPad/com.zhidao.roadcondition/F803EB2046PZD00228/F803EB2046PZD00228_20210121165329/compress_video_20210121165307.mp4\\\"}]\",\"direction\":0.0,\"fromType\":\"2\",\"generateTime\":1611219213616,\"infoTimeout\":240,\"infoType\":1,\"isShare\":false,\"lat\":39.968317,\"lon\":116.410892,\"mainInfoId\":0,\"poiType\":\"10008\",\"provinceName\":\"北京市\",\"sn\":\"F803EB2046PZD00228\",\"speed\":0.0,\"street\":\"小黄庄北街\",\"trafficInfoType\":\"\",\"type\":1,\"uid\":0}");
+
+ Log.d(TAG, "sn = " + MoGoAiCloudClient.getInstance().getAiCloudClientConfig().getSn());
+ apiService.uploadInformation(map)
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread())
+ .subscribe(new Observer() {
+ @Override
+ public void onSubscribe(Disposable d) {
+ Log.d(TAG, "onSubscribe -----> ");
+ }
+
+ @Override
+ public void onNext(UploadResult result) {
+ Log.d(TAG, "onNext -----> ");
+ callback.onSuccess(result);
+ }
+
+ @Override
+ public void onError(Throwable e) {
+ Log.e(TAG, "onError -----> e " + e);
+ callback.onError(e);
+ }
+
+ @Override
+ public void onComplete() {
+ Log.d(TAG, "onComplete -----> ");
+ }
+ });
+ }
+
+
+
+
+
+
+}
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/ILoadUpload.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/ILoadUpload.java
similarity index 70%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/ILoadUpload.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/ILoadUpload.java
index 8ce92d4..526a9f0 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/ILoadUpload.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/ILoadUpload.java
@@ -1,7 +1,7 @@
-package com.mogo.cloud.api;
+package com.mogo.cloud.tanlu.api;
-import com.mogo.cloud.bean.InformationBody;
+import com.mogo.cloud.tanlu.bean.InformationBody;
/**
* @author lixiaopeng
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/IRoadInfoSearchCallback.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/IRoadInfoSearchCallback.java
similarity index 62%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/IRoadInfoSearchCallback.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/IRoadInfoSearchCallback.java
index d07ec45..254d6f7 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/IRoadInfoSearchCallback.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/IRoadInfoSearchCallback.java
@@ -1,6 +1,6 @@
-package com.mogo.cloud.api;
+package com.mogo.cloud.tanlu.api;
-import com.mogo.cloud.bean.RoadInfos;
+import com.mogo.cloud.tanlu.bean.RoadInfos;
/**
* @author lixiaopeng
@@ -10,4 +10,5 @@ import com.mogo.cloud.bean.RoadInfos;
public interface IRoadInfoSearchCallback {
void onSuccess(RoadInfos result);
void onFailure(int code);
+ void onError(Throwable e);
}
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/ITanluUploadCallback.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/ITanluUploadCallback.java
similarity index 61%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/ITanluUploadCallback.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/ITanluUploadCallback.java
index 881a799..7bdd5e5 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/api/ITanluUploadCallback.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/api/ITanluUploadCallback.java
@@ -1,6 +1,6 @@
-package com.mogo.cloud.api;
+package com.mogo.cloud.tanlu.api;
-import com.mogo.cloud.bean.UploadResult;
+import com.mogo.cloud.tanlu.bean.UploadResult;
/**
* @author lixiaopeng
@@ -10,4 +10,5 @@ import com.mogo.cloud.bean.UploadResult;
public interface ITanluUploadCallback {
void onSuccess(UploadResult result);
void onFailure(int code);
+ void onError(Throwable e);
}
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/InformationBody.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/InformationBody.java
similarity index 99%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/InformationBody.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/InformationBody.java
index e34c349..d019f30 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/InformationBody.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/InformationBody.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.bean;
+package com.mogo.cloud.tanlu.bean;
import java.io.Serializable;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerExploreWay.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerExploreWay.java
similarity index 98%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerExploreWay.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerExploreWay.java
index 2a47056..3e8e523 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerExploreWay.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerExploreWay.java
@@ -1,8 +1,8 @@
-package com.mogo.cloud.bean;
+package com.mogo.cloud.tanlu.bean;
import android.text.TextUtils;
-import com.mogo.cloud.bean.location.MarkerLocation;
+import com.mogo.cloud.tanlu.bean.location.MarkerLocation;
import java.io.Serializable;
import java.util.List;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerExploreWayItem.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerExploreWayItem.java
similarity index 97%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerExploreWayItem.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerExploreWayItem.java
index c610527..237f43f 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerExploreWayItem.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerExploreWayItem.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.bean;
+package com.mogo.cloud.tanlu.bean;
import android.text.TextUtils;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerUserInfo.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerUserInfo.java
similarity index 99%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerUserInfo.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerUserInfo.java
index 24088fb..e5ad6df 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/MarkerUserInfo.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/MarkerUserInfo.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.bean;
+package com.mogo.cloud.tanlu.bean;
import android.text.TextUtils;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/RoadInfoRequest.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/RoadInfoRequest.java
similarity index 93%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/RoadInfoRequest.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/RoadInfoRequest.java
index 062f8e5..6f0955f 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/RoadInfoRequest.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/RoadInfoRequest.java
@@ -1,6 +1,6 @@
-package com.mogo.cloud.bean;
+package com.mogo.cloud.tanlu.bean;
-import com.mogo.cloud.bean.location.Location;
+import com.mogo.cloud.tanlu.bean.location.Location;
import java.util.ArrayList;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/RoadInfos.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/RoadInfos.java
similarity index 90%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/RoadInfos.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/RoadInfos.java
index 58922f9..9a5fe69 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/RoadInfos.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/RoadInfos.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.bean;
+package com.mogo.cloud.tanlu.bean;
import java.util.List;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/UploadResult.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/UploadResult.java
similarity index 92%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/UploadResult.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/UploadResult.java
index a66fe79..8734b5c 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/UploadResult.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/UploadResult.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.bean;
+package com.mogo.cloud.tanlu.bean;
import java.io.Serializable;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/Location.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/Location.java
similarity index 90%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/Location.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/Location.java
index 4bf7aa7..8e08139 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/Location.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/Location.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.bean.location;
+package com.mogo.cloud.tanlu.bean.location;
import java.io.Serializable;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/MarkerLocation.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/MarkerLocation.java
similarity index 96%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/MarkerLocation.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/MarkerLocation.java
index d7ceaa0..66b7d84 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/MarkerLocation.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/MarkerLocation.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.bean.location;
+package com.mogo.cloud.tanlu.bean.location;
import android.text.TextUtils;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/MogoLocation.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/MogoLocation.java
similarity index 99%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/MogoLocation.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/MogoLocation.java
index 69b26cb..5f5217a 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/bean/location/MogoLocation.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/bean/location/MogoLocation.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.bean.location;
+package com.mogo.cloud.tanlu.bean.location;
import android.os.Parcel;
import android.os.Parcelable;
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/constant/HttpConstant.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/constant/HttpConstant.java
similarity index 71%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/constant/HttpConstant.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/constant/HttpConstant.java
index ac934af..2662c9b 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/constant/HttpConstant.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/constant/HttpConstant.java
@@ -1,4 +1,4 @@
-package com.mogo.cloud.constant;
+package com.mogo.cloud.tanlu.constant;
/**
* @author lixiaopeng
diff --git a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/net/TanluApiService.java b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/net/TanluApiService.java
similarity index 88%
rename from modules/mogo-tanlu/src/main/java/com/mogo/cloud/net/TanluApiService.java
rename to modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/net/TanluApiService.java
index 5733af4..7fb5312 100644
--- a/modules/mogo-tanlu/src/main/java/com/mogo/cloud/net/TanluApiService.java
+++ b/modules/mogo-tanlu/src/main/java/com/mogo/cloud/tanlu/net/TanluApiService.java
@@ -1,7 +1,7 @@
-package com.mogo.cloud.net;
+package com.mogo.cloud.tanlu.net;
-import com.mogo.cloud.bean.RoadInfos;
-import com.mogo.cloud.bean.UploadResult;
+import com.mogo.cloud.tanlu.bean.RoadInfos;
+import com.mogo.cloud.tanlu.bean.UploadResult;
import java.util.Map;
diff --git a/modules/mogo-tanlu/src/test/java/com/mogo/cloud/ExampleUnitTest.java b/modules/mogo-tanlu/src/test/java/com/mogo/cloud/ExampleUnitTest.java
deleted file mode 100644
index 2802386..0000000
--- a/modules/mogo-tanlu/src/test/java/com/mogo/cloud/ExampleUnitTest.java
+++ /dev/null
@@ -1,17 +0,0 @@
-package com.mogo.cloud;
-
-import org.junit.Test;
-
-import static org.junit.Assert.*;
-
-/**
- * Example local unit test, which will execute on the development machine (host).
- *
- * @see Testing documentation
- */
-public class ExampleUnitTest {
- @Test
- public void addition_isCorrect() {
- assertEquals(4, 2 + 2);
- }
-}
\ No newline at end of file