opt traffic light panel

modules/mogo-module-extensions/src/main/java/com/mogo/module/extensions/net/DelayCheckApiServices.java

@@ -0,0 +1,26 @@
+package com.mogo.module.extensions.net;
+
+import com.mogo.commons.data.BaseData;
+
+import java.util.Map;
+
+import io.reactivex.Observable;
+import retrofit2.http.FieldMap;
+import retrofit2.http.FormUrlEncoded;
+import retrofit2.http.GET;
+import retrofit2.http.POST;
+
+/**
+ * 时延验证相关接口
+ *
+ * @author tongchenfei
+ */
+public interface DelayCheckApiServices {
+
+    @GET("/")
+    Observable<BaseData> emptyInterface();
+
+    @POST("/")
+    @FormUrlEncoded
+    Observable<BaseData> uploadDelayCheckData(@FieldMap Map<String, String> params);
+}

modules/mogo-module-extensions/src/main/java/com/mogo/module/extensions/utils/DelayCheckUtil.java

@@ -0,0 +1,121 @@
+package com.mogo.module.extensions.utils;
+
+import android.content.Context;
+import android.os.Handler;
+import android.os.Message;
+import android.os.SystemClock;
+
+import com.mogo.commons.data.BaseData;
+import com.mogo.commons.network.SubscribeImpl;
+import com.mogo.module.common.MogoApisHandler;
+import com.mogo.module.extensions.net.DelayCheckApiServices;
+import com.mogo.module.extensions.net.DztHttpConstant;
+import com.mogo.utils.NetworkUtils;
+import com.mogo.utils.network.RequestOptions;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import io.reactivex.schedulers.Schedulers;
+
+/**
+ * 延时验证工具类
+ *
+ * @author tongchenfei
+ */
+public class DelayCheckUtil implements Handler.Callback {
+
+    private final Handler handler = new Handler(this);
+
+    private static final int MSG_CHECK_NET_CONNECT_STATUS = 1001;
+    private static final long CHECK_NET_CONNECT_STATUS_DELAY = 5000L;
+
+    private static final int MSG_START_DELAY_CHECK = 1002;
+    private static final long DELAY_CHECK_DELAY = 10 * 60 * 1000;
+
+    private Context context;
+
+    public DelayCheckUtil(Context context) {
+        this.context = context;
+    }
+
+    /**
+     * 每5s检查一下网络状态，网络状态为连接状态时，开始空接口请求以及后续的参数上报
+     */
+    public void waitingForCheck() {
+        handler.sendEmptyMessageDelayed(MSG_CHECK_NET_CONNECT_STATUS, CHECK_NET_CONNECT_STATUS_DELAY);
+    }
+
+    private long requestTime, netDelay;
+
+    @Override
+    public boolean handleMessage(Message msg) {
+        switch (msg.what) {
+            case MSG_CHECK_NET_CONNECT_STATUS:
+                if (NetworkUtils.isConnected(context)) {
+                    handler.sendEmptyMessage(MSG_START_DELAY_CHECK);
+                } else {
+                    handler.sendEmptyMessageDelayed(MSG_CHECK_NET_CONNECT_STATUS, CHECK_NET_CONNECT_STATUS_DELAY);
+                }
+                return true;
+            case MSG_START_DELAY_CHECK:
+                // 请求空接口
+                startEmptyRequest();
+                return true;
+            default:
+                return false;
+        }
+    }
+
+    private void startEmptyRequest() {
+        requestTime = SystemClock.elapsedRealtime();
+        MogoApisHandler.getInstance().getApis().getNetworkApi()
+                .create(DelayCheckApiServices.class, DztHttpConstant.getBaseUrl())
+                .emptyInterface().subscribeOn(Schedulers.io()).observeOn(Schedulers.io())
+                .subscribe(new SubscribeImpl<BaseData>(RequestOptions.create(context)) {
+                    @Override
+                    public void onSuccess(BaseData o) {
+                        super.onSuccess(o);
+                        netDelay = SystemClock.elapsedRealtime() - requestTime;
+
+                        startUpload();
+
+                    }
+
+                    @Override
+                    public void onError(Throwable e) {
+                        super.onError(e);
+                    }
+
+                    @Override
+                    public void onError(String message, int code) {
+                        super.onError(message, code);
+                    }
+                });
+    }
+
+    private void startUpload(){
+        Map<String, String> params = new HashMap<>();
+        MogoApisHandler.getInstance().getApis().getNetworkApi()
+                .create(DelayCheckApiServices.class, DztHttpConstant.getBaseUrl())
+                .uploadDelayCheckData(params).observeOn(Schedulers.io()).subscribeOn(Schedulers.io())
+                .subscribe(new SubscribeImpl<BaseData>(RequestOptions.create(context)) {
+                    @Override
+                    public void onSuccess(BaseData o) {
+                        super.onSuccess(o);
+
+                        handler.sendEmptyMessageDelayed(MSG_START_DELAY_CHECK, DELAY_CHECK_DELAY);
+                    }
+
+                    @Override
+                    public void onError(String message, int code) {
+                        super.onError(message, code);
+                    }
+
+                    @Override
+                    public void onError(Throwable e) {
+                        super.onError(e);
+                    }
+                });
+    }
+}