From b7062b3c0bb06a5f62e3723412211bfba3147132 Mon Sep 17 00:00:00 2001
From: liugl <liugl@sinata.cn>
Date: 星期一, 24 八月 2020 15:30:45 +0800
Subject: [PATCH] 8.24 资格证号错误
---
app/src/main/java/com/okgoincar/base/MyApplication.kt | 19 +++++++++++--------
1 files changed, 11 insertions(+), 8 deletions(-)
diff --git a/app/src/main/java/com/okgoincar/base/MyApplication.kt b/app/src/main/java/com/okgoincar/base/MyApplication.kt
index f1a0f7f..8209916 100644
--- a/app/src/main/java/com/okgoincar/base/MyApplication.kt
+++ b/app/src/main/java/com/okgoincar/base/MyApplication.kt
@@ -3,12 +3,12 @@
import android.app.Activity
import android.app.Application
import android.content.Context
-import android.content.Intent
import android.os.Bundle
import android.os.Handler
import android.os.Looper
import android.util.Log
import androidx.multidex.MultiDex
+import cn.sinata.rxnetty.Cache.CacheUtil
import cn.sinata.rxnetty.NettyClient
import cn.sinata.xldutils.BaseApplication
import cn.sinata.xldutils.utils.sysErr
@@ -27,7 +27,6 @@
import com.okgoincar.bean.websocket.HeartBean
import com.okgoincar.netUtls.Api
import com.okgoincar.netUtls.getUserId
-import com.okgoincar.netUtls.sendAudio
import com.okgoincar.slab.MySlabBaseActivity
import com.okgoincar.utils.Cache.CacheKey
import org.jetbrains.anko.toast
@@ -72,12 +71,11 @@
// LogUtils.OpenLog(true)
initUpPoint()
initSocket()
-
}
private fun initSocket() {
Handler(Looper.getMainLooper()).post {
- toast("websocket初始化")
+// toast("websocket初始化")
}
NettyClient.getInstance().init(this, Api.SOCKET_SERVER, Api.SOCKET_PORT, true)
NettyClient.getInstance()
@@ -89,7 +87,7 @@
val json = JSONObject(message)
val method = json.optString("method")
Handler(Looper.getMainLooper()).post {
- toast("收到websocket=$method")
+// toast("收到websocket=$method")
}
val data = json.optString("data")
val code = json.optInt("code", -1)
@@ -263,9 +261,9 @@
bean.data = dataBean
NettyClient.getInstance()
.sendMessage(Gson().toJson(bean))
-// Handler(Looper.getMainLooper()).post {
+ Handler(Looper.getMainLooper()).post {
// toast("发送location --> $dataBean")
-// }
+ }
sysErr(dataBean.toString())
}
}
@@ -286,8 +284,13 @@
if ((System.currentTimeMillis() - currentTime) / 1000 > 30) {
sysErr("sendHeart_websocket 重新连接")
currentTime = System.currentTimeMillis()
+// var s = CacheUtil.get().getAsString("reConnect")
+// s = "$s###初始化重连"
+// CacheUtil.get().put("reConnect", s)
// NettyClient.getInstance().checkNettyState()
- initSocket()
+ NettyClient.getInstance().checkNettyStateNull() //reconnect
+
+// initSocket()
heartHandler!!.postDelayed({ sendHeart() }, 5000)
} else {
sysErr("sendHeart_websocket 发送心跳")
--
Gitblit v1.7.1