From 71f8f71a3b20589e3f6b9c426f7e9c966eaece66 Mon Sep 17 00:00:00 2001
From: zhongchao <zhongchao@zhidaoauto.com>
Date: Tue, 18 May 2021 16:30:34 +0800
Subject: [PATCH] wait to finish

---
 .../service/network/TimeDelayApiService.java  | 21 ++++++++++++++++
 .../MockDataDelayUploadHttpConstant.java      | 24 +++++++++++++++++++
 .../timedelay/TimeDelayUploadManager.java     | 17 ++++++++++++-
 3 files changed, 61 insertions(+), 1 deletion(-)
 create mode 100644 modules/mogo-module-service/src/main/java/com/mogo/module/service/network/TimeDelayApiService.java
 create mode 100644 modules/mogo-module-service/src/main/java/com/mogo/module/service/timedelay/MockDataDelayUploadHttpConstant.java

diff --git a/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/TimeDelayApiService.java b/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/TimeDelayApiService.java
new file mode 100644
index 0000000000..a07b6c58b8
--- /dev/null
+++ b/modules/mogo-module-service/src/main/java/com/mogo/module/service/network/TimeDelayApiService.java
@@ -0,0 +1,21 @@
+package com.mogo.module.service.network;
+
+import com.mogo.module.common.entity.MarkerResponse;
+
+import java.util.Map;
+
+import io.reactivex.Observable;
+import retrofit2.http.FieldMap;
+import retrofit2.http.FormUrlEncoded;
+import retrofit2.http.POST;
+
+public interface TimeDelayApiService {
+
+
+    /**
+     * 上报延时时间
+     */
+    @FormUrlEncoded
+    @POST("/yycp-computer-vision-service/mockEye/delayTimeCallBack")
+    Observable<Object> uploadDelayData(@FieldMap Map<String, Object> parameters);
+}
diff --git a/modules/mogo-module-service/src/main/java/com/mogo/module/service/timedelay/MockDataDelayUploadHttpConstant.java b/modules/mogo-module-service/src/main/java/com/mogo/module/service/timedelay/MockDataDelayUploadHttpConstant.java
new file mode 100644
index 0000000000..ae5f0c3170
--- /dev/null
+++ b/modules/mogo-module-service/src/main/java/com/mogo/module/service/timedelay/MockDataDelayUploadHttpConstant.java
@@ -0,0 +1,24 @@
+package com.mogo.module.service.timedelay;
+
+import com.mogo.commons.debug.DebugConfig;
+
+public class MockDataDelayUploadHttpConstant {
+
+    public static final String HOST_DEV = "http://dzt-test.zhidaozhixing.com";
+    public static final String HOST_TEST = "http://dzt-test.zhidaozhixing.com";
+    public static final String HOST_DEMO = "http://dzt-show.zhidaozhixing.com";
+    public static final String HOST_PRODUCT = "http://dzt.zhidaozhixing.com";
+
+    public static String getBaseUrl() {
+        switch (DebugConfig.getNetMode()) {
+            case DebugConfig.NET_MODE_DEV:
+                return HOST_DEV;
+            case DebugConfig.NET_MODE_QA:
+                return HOST_TEST;
+            case DebugConfig.NET_MODE_DEMO:
+                return HOST_DEMO;
+            default:
+                return HOST_PRODUCT;
+        }
+    }
+}
diff --git a/modules/mogo-module-service/src/main/java/com/mogo/module/service/timedelay/TimeDelayUploadManager.java b/modules/mogo-module-service/src/main/java/com/mogo/module/service/timedelay/TimeDelayUploadManager.java
index 1c66762326..67e952d195 100644
--- a/modules/mogo-module-service/src/main/java/com/mogo/module/service/timedelay/TimeDelayUploadManager.java
+++ b/modules/mogo-module-service/src/main/java/com/mogo/module/service/timedelay/TimeDelayUploadManager.java
@@ -7,6 +7,7 @@ import android.os.Message;
 import com.mogo.module.common.MogoApisHandler;
 import com.mogo.module.common.uploadintime.SnapshotLocationController;
 import com.mogo.module.service.MarkerServiceHandler;
+import com.mogo.module.service.network.TimeDelayApiService;
 import com.mogo.module.service.network.bean.MockSocketReceiverData;
 import com.mogo.realtime.api.MoGoAiCloudRealTime;
 import com.mogo.realtime.entity.MogoSnapshotSetData;
@@ -18,6 +19,9 @@ import com.mogo.utils.logger.Logger;
 import org.json.JSONException;
 import org.json.JSONObject;
 
+import io.reactivex.schedulers.Schedulers;
+import rx.android.schedulers.AndroidSchedulers;
+
 import static com.mogo.module.service.network.bean.MockSocketReceiverData.MOCK_RECEIVER_STATUS_START;
 
 /**
@@ -34,6 +38,8 @@ public class TimeDelayUploadManager implements IMogoOnMessageListener<MockSocket
     private MockSocketReceiverData mMockData;
     private long mRecordSatelliteTime; //todo 后续多点模拟用
 
+    private TimeDelayApiService timeDelayApiService;
+
     private TimeDelayUploadManager() {
 
     }
@@ -90,12 +96,15 @@ public class TimeDelayUploadManager implements IMogoOnMessageListener<MockSocket
     @Override
     public void onMsgReceived(MockSocketReceiverData mockData) {
         Logger.d(TAG, "onMsgReceived obj : " + mockData.toString());
-        if (mockData.getStatus() == MOCK_RECEIVER_STATUS_START) {
+        if (mockData.getStatus() == MOCK_RECEIVER_STATUS_START) { //todo 暂时以单条数据发送，后续多点实时发送Message
             isMockData = true;
             //开启定位模拟
             mMockData = mockData;
             mRecordSatelliteTime = mockData.getSatelliteTime();
             mockHandler.sendEmptyMessage(MOCK_MSG);
+            if (timeDelayApiService == null) {
+                timeDelayApiService = MogoApisHandler.getInstance().getApis().getNetworkApi().create(TimeDelayApiService.class, MockDataDelayUploadHttpConstant.getBaseUrl());
+            }
         } else {
             isMockData = false;
             //停止定位模拟
@@ -103,6 +112,7 @@ public class TimeDelayUploadManager implements IMogoOnMessageListener<MockSocket
                 mockHandler.removeMessages(MOCK_MSG);
                 mMockData = null;
                 mRecordSatelliteTime = 0;
+                timeDelayApiService = null;
             }
         }
     }
@@ -117,6 +127,11 @@ public class TimeDelayUploadManager implements IMogoOnMessageListener<MockSocket
     public void onMsgReceived(MogoSnapshotSetData mogoSnapshotSetData) {
         if (isMockData) {
             //接口数据上报
+
+//            timeDelayApiService.uploadDelayData()
+//                    .subscribeOn(Schedulers.io())
+//                    .observeOn(AndroidSchedulers.mainThread())
+//                    .subscribe()
         }
     }
 }