package com.zhaoyang.driver.base
|
|
import android.app.Activity
|
import android.app.Application
|
import android.content.Intent
|
import android.os.*
|
import android.util.Log
|
import androidx.annotation.RequiresApi
|
import cn.jpush.android.api.JPushInterface
|
import cn.jpush.android.api.TagAliasCallback
|
import cn.sinata.rxnetty.NettyClient
|
import cn.sinata.xldutils.BaseApplication
|
import cn.sinata.xldutils.utils.sysErr
|
import com.amap.api.location.AMapLocation
|
import com.amap.api.track.AMapTrackClient
|
import com.amap.api.track.ErrorCode
|
import com.amap.api.track.OnTrackLifecycleListener
|
import com.amap.api.track.TrackParam
|
import com.amap.api.track.query.model.*
|
import com.zhaoyang.driver.base.gaode.gpsnav.util.TTSController
|
import com.zhaoyang.driver.base.local.OnTripTrackLifecycleListener
|
import com.zhaoyang.driver.base.local.OnTripTrackListener
|
import com.zhaoyang.driver.bean.CarLocationBean
|
import com.zhaoyang.driver.bean.OrderResData
|
import com.zhaoyang.driver.bean.OrderSimpleData
|
import com.zhaoyang.driver.bean.websocket.HeartBean
|
import com.zhaoyang.driver.netUtls.Api
|
import com.zhaoyang.driver.netUtls.getUserId
|
import com.zhaoyang.driver.ui.pub.LoginActivity
|
import com.zhaoyang.driver.ui.to_city.TripCityActivity
|
import com.zhaoyang.driver.utils.Cache.CacheKey
|
import com.zhaoyang.driver.utils.Cache.CacheUtil
|
import com.zhaoyang.driver.utils.LogUtils
|
import com.google.gson.Gson
|
import com.tencent.bugly.crashreport.CrashReport
|
import com.umeng.commonsdk.UMConfigure
|
import com.umeng.socialize.PlatformConfig
|
import com.xuexiang.xui.XUI
|
import org.greenrobot.eventbus.EventBus
|
import org.jetbrains.anko.toast
|
import org.json.JSONObject
|
import java.security.SecureRandom
|
import java.security.cert.X509Certificate
|
import java.util.*
|
import javax.net.ssl.HttpsURLConnection
|
import javax.net.ssl.SSLContext
|
import javax.net.ssl.TrustManager
|
import javax.net.ssl.X509TrustManager
|
|
/**
|
* Created by Administrator on 2018/1/17.
|
*/
|
class MyApplication : BaseApplication(), Application.ActivityLifecycleCallbacks, OnTrackListener,
|
OnTrackLifecycleListener {
|
//设置debug模式
|
var isDebug = false
|
var heartHandler: Handler? = null
|
var currentTime = System.currentTimeMillis()
|
|
override fun setSharedPreferencesName(): String {
|
return "MyApplication"
|
}
|
|
@RequiresApi(api = Build.VERSION_CODES.DONUT)
|
override fun onCreate() {
|
super.onCreate()
|
appContext = this
|
handleSSLHandshake()
|
//如果是主进程
|
XUI.init(this)
|
UMConfigure.init(
|
this,
|
"642298b0ba6a5259c428c920",
|
"gaode",
|
UMConfigure.DEVICE_TYPE_PHONE,
|
""
|
)
|
registerActivityLifecycleCallbacks(this)
|
PlatformConfig.setWeixin("wx6078319d54d38c66", "c3ef243fae93fb0fd093d457ada38b4c")
|
PlatformConfig.setQQZone("102047428", "qcBXgbJo6B2f5HF0") //qq互联
|
// CrashReport.initCrashReport(getApplicationContext(), "444bb776ed", false);
|
LogUtils.OpenLog(true)
|
// initUpPoint()
|
initSocket()
|
JPushInterface.setDebugMode(true)
|
JPushInterface.init(this)
|
setAlisa()
|
}
|
|
fun setAlisa() {
|
if (CacheKey.getUserId().isNotEmpty()) {
|
var alisa = "DRIVER" + CacheKey.getUserId()
|
sysErr(alisa)
|
mHandler.sendMessage(mHandler.obtainMessage(MSG_SET_ALIAS, alisa))
|
}
|
}
|
|
private val MSG_SET_ALIAS = 1001
|
private val mHandler: Handler = object : Handler() {
|
override fun handleMessage(msg: Message) {
|
super.handleMessage(msg)
|
when (msg.what) {
|
MSG_SET_ALIAS -> {
|
Log.d(TAG, "Set alias in handler.")
|
// 调用 JPush 接口来设置别名。
|
JPushInterface.setAliasAndTags(
|
applicationContext,
|
msg.obj as String,
|
null,
|
mAliasCallback
|
)
|
}
|
else -> Log.i(TAG, "Unhandled msg - " + msg.what)
|
}
|
}
|
}
|
|
private val mAliasCallback =
|
TagAliasCallback { code, alias, tags ->
|
val logs: String
|
when (code) {
|
0 -> {
|
logs = "Set tag and alias success"
|
Log.i("TAG", logs)
|
}
|
6002 -> {
|
logs = "Failed to set alias and tags due to timeout. Try again after 60s."
|
Log.i("TAG", logs)
|
// 延迟 60 秒来调用 Handler 设置别名
|
var alisa = "DRIVER" + CacheKey.getUserId()
|
Handler().postDelayed({
|
JPushInterface.setAliasAndTags(this, alisa, null, null)
|
}, 60 * 1000)
|
}
|
else -> {
|
logs = "Failed with errorCode = $code"
|
Log.e("TAG", logs)
|
}
|
}
|
}
|
|
private fun initSocket() {
|
NettyClient.getInstance().init(this, Api.SOCKET_SERVER, Api.SOCKET_PORT, true)
|
NettyClient.getInstance()
|
.addOnMessageListener { message: String? ->
|
try {
|
Log.e("socket_message_by", message)
|
// sysErr("收到websocket消息")
|
if (!isLogin) {
|
return@addOnMessageListener
|
}
|
currentTime = System.currentTimeMillis()
|
val json = JSONObject(message)
|
val method = json.optString("method")
|
Handler(Looper.getMainLooper()).post {
|
// ToastUtils.showShortToast(this, "收到websocket=$method")
|
}
|
val data = json.optString("data")
|
val code = json.optInt("code", -1)
|
if (code == 200) {
|
when (method) {
|
Const.SOCKET_METHOD.OK -> {
|
testReceiveNum++
|
}
|
Const.SOCKET_METHOD.OFFLINE -> {
|
CacheUtil.get().clear()
|
NettyClient.getInstance().stopService()
|
isLogin = false
|
var intent = Intent()
|
intent.setClass(this, LoginActivity::class.java)
|
intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK)
|
startActivity(intent)
|
toast("您的账号已在其他平台登录")
|
}
|
Const.SOCKET_METHOD.ORDER_STATUS -> {
|
val orderSimpleData =
|
Gson().fromJson(
|
data,
|
OrderSimpleData::class.java
|
)
|
for (view in orderStatueViews.asReversed().indices) {
|
orderStatueViews[view].orderInfo(orderSimpleData)
|
}
|
if (orderSimpleData.status == 1) {
|
val act = activities[activities.size - 1]
|
// MyApplication.getTTsManager().setVideoText("收到新的订单")
|
when (orderSimpleData.orderType) {
|
1,2 -> {
|
(act as MyBaseActivity).showOrder(
|
orderSimpleData.orderId.toString(),
|
orderSimpleData.orderType.toString(),
|
orderSimpleData.time,
|
1
|
)
|
}
|
4,5 -> {
|
(act as MyBaseActivity).showOrder(
|
orderSimpleData.orderId.toString(),
|
orderSimpleData.orderType.toString(),
|
orderSimpleData.time,
|
1
|
)
|
}
|
}
|
}
|
if (orderSimpleData.status == 2) {
|
val act = activities[activities.size - 1]
|
when (orderSimpleData.orderType) {
|
1, 2 -> {
|
(act as MyBaseActivity).toDorderAct(
|
orderSimpleData.orderId.toString(),
|
orderSimpleData.orderType.toString()
|
)
|
}
|
3 -> {
|
if (act is TripCityActivity) {
|
act.callOrder()
|
} else {
|
(act as MyBaseActivity).toDorderActCity(
|
orderSimpleData.orderId.toString(),
|
orderSimpleData.orderType.toString()
|
)
|
}
|
|
}
|
|
}
|
|
}
|
|
|
}
|
Const.SOCKET_METHOD.REASSIGN -> {
|
EventBus.getDefault().post(BaseEvent(BaseEvent.REFREASH_MAIN))
|
val orderSimpleData =
|
Gson().fromJson(
|
data,
|
OrderResData::class.java
|
)
|
val act = activities[activities.size - 1]
|
when (orderSimpleData.orderType) {
|
1, 2 -> {
|
(act as MyBaseActivity).showOrder(
|
orderSimpleData.orderId.toString(),
|
orderSimpleData.orderType.toString(),
|
30,
|
2
|
)
|
}
|
3 -> {
|
if (act is TripCityActivity) {
|
act.callOrder()
|
}
|
(act as MyBaseActivity).toDorderActCity(
|
orderSimpleData.orderId.toString(),
|
orderSimpleData.orderType.toString()
|
)
|
}
|
}
|
|
}
|
}
|
} else {
|
sysErr("socket return code ===$code")
|
}
|
} catch (e: Exception) {
|
e.printStackTrace()
|
}
|
}
|
NettyClient.getInstance()
|
.setOnConnectListener {
|
sendHeart()
|
}
|
}
|
|
|
fun initUpPoint() {
|
//猎鹰sdk上报
|
var serviceIdS = CacheKey.getServerId()
|
if (serviceIdS == "")
|
return
|
var serviceId = serviceIdS.toLong()
|
var terminalName = CacheKey.getTerminalName() // 唯一标识某个用户或某台设备的名称
|
aMapTrackClient = AMapTrackClient(applicationContext);
|
aMapTrackClient.setInterval(5, 30)
|
aMapTrackClient.queryTerminal(QueryTerminalRequest(serviceId, terminalName),
|
object : OnTripTrackListener() {
|
override fun onQueryTerminalCallback(p0: QueryTerminalResponse?) {
|
if (p0!!.isSuccess) {
|
if (p0.tid <= 0) {
|
aMapTrackClient.addTerminal(
|
AddTerminalRequest(terminalName, serviceId),
|
object :
|
OnTripTrackListener() {
|
override fun onQueryTerminalCallback(queryTerminalResponse: QueryTerminalResponse?) {
|
super.onQueryTerminalCallback(queryTerminalResponse)
|
if (p0.isSuccess) {
|
// 创建完成，开启猎鹰服务
|
sysErr("创建完成，开启猎鹰服务" + p0.errorMsg+",tid:${p0.tid}")
|
terminalId = queryTerminalResponse!!.tid
|
aMapTrackClient.startTrack(
|
TrackParam(
|
serviceId,
|
terminalId
|
), onTrackLifecycleListener
|
)
|
} else {
|
// 请求失败
|
sysErr("请求失败" + p0.getErrorMsg())
|
}
|
}
|
})
|
} else {
|
// terminal已经存在，直接开启猎鹰服务
|
terminalId = p0.tid
|
sysErr("terminal已经存在，直接开启猎鹰服务" + p0.errorMsg+",tid:${p0.tid}")
|
aMapTrackClient.startTrack(
|
TrackParam(serviceId, terminalId),
|
onTrackLifecycleListener
|
)
|
}
|
} else {
|
sysErr("请求失败" + p0.errorMsg)
|
}
|
}
|
})
|
}
|
|
// fun stopTrack(){
|
// var serviceIdS = CacheKey.getServerId()
|
// if (serviceIdS == "")
|
// return
|
// var serviceId = serviceIdS.toLong()
|
// var terminalName = CacheKey.getTerminalName() // 唯一标识某个用户或某台设备的名称
|
// aMapTrackClient.stopTrack(TrackParam(serviceId, terminalId),
|
// onTrackLifecycleListener)
|
// }
|
|
|
fun createTrack(){
|
val serviceIdS = CacheKey.getServerId()
|
if (serviceIdS == "")
|
return
|
aMapTrackClient.addTrack(AddTrackRequest(serviceIdS.toLong(), terminalId), this)//创建行程轨迹id
|
}
|
|
lateinit var aMapTrackClient: AMapTrackClient
|
private var terminalId = 0L
|
var onTrackLifecycleListener = object : OnTripTrackLifecycleListener() {
|
override fun onStartGatherCallback(p0: Int, p1: String?) {
|
if (p0 == ErrorCode.TrackListen.START_GATHER_SUCEE ||
|
p0 == ErrorCode.TrackListen.START_GATHER_ALREADY_STARTED
|
) {
|
sysErr("定位采集开启成功")
|
} else {
|
sysErr("定位采集启动异常=$p1")
|
}
|
}
|
|
override fun onStartTrackCallback(p0: Int, p1: String?) {
|
if (p0 == ErrorCode.TrackListen.START_TRACK_SUCEE ||
|
p0 == ErrorCode.TrackListen.START_TRACK_SUCEE_NO_NETWORK ||
|
p0 == ErrorCode.TrackListen.START_TRACK_ALREADY_STARTED
|
) {
|
// 服务启动成功，继续开启收集上报
|
aMapTrackClient.startGather(this);
|
} else {
|
sysErr("轨迹上报服务服务启动异常")
|
}
|
}
|
}
|
|
private fun sendLocation() {
|
if (getUserId() != -1 && aMapLocation != null) {
|
val bean = CarLocationBean()
|
val dataBean = CarLocationBean.DataBean(
|
getUserId(),
|
currentOrderId,
|
currentOrderType,
|
aMapLocation!!.longitude,
|
aMapLocation!!.latitude,
|
aMapLocation!!.bearing.toDouble(),
|
aMapLocation!!.altitude
|
)
|
bean.data = dataBean
|
NettyClient.getInstance()
|
.sendMessage(Gson().toJson(bean))
|
sysErr(dataBean.toString())
|
}
|
}
|
|
private fun sendHeart() {
|
if (getUserId() != -1) {
|
Log.i(TAG, "sendHeart: userId === " + getUserId())
|
val bean = HeartBean()
|
bean.data = HeartBean.DataBean()
|
NettyClient.getInstance()
|
.sendMessage(Gson().toJson(bean))
|
sendLocation()
|
if (heartHandler == null) {
|
heartHandler = Handler(mainLooper)
|
}
|
heartHandler!!.removeCallbacksAndMessages(null)
|
testHeartNunm++
|
if ((System.currentTimeMillis() - currentTime) / 1000 > 30) {
|
sysErr("sendHeart_websocket 重新连接")
|
currentTime = System.currentTimeMillis()
|
NettyClient.getInstance().checkNettyState()
|
} else {
|
sysErr("sendHeart_websocket 发送心跳")
|
}
|
}
|
heartHandler!!.postDelayed({ sendHeart() }, 5000)
|
}
|
|
interface OrderStatueView {
|
fun orderInfo(data: OrderSimpleData?)
|
}
|
|
|
companion object {
|
private const val TAG = "MyApplication"
|
public var appContext: MyApplication? = null
|
protected var mTtsManager: TTSController? = null
|
|
public var isLogin: Boolean = true
|
fun getInstance(): MyApplication? {
|
if (appContext == null) {
|
appContext = MyApplication()
|
}
|
return appContext
|
}
|
|
fun getTTsManager(): TTSController {
|
if (mTtsManager == null) {
|
mTtsManager = TTSController.getInstance(getInstance())
|
mTtsManager?.init()
|
}
|
return mTtsManager!!
|
}
|
|
fun getLocation(): AMapLocation {
|
if (aMapLocation == null) {
|
var map = AMapLocation("")
|
map.latitude = -1.0
|
map.longitude = -1.0
|
return map
|
} else {
|
return aMapLocation!!
|
}
|
}
|
|
var aMapLocation: AMapLocation? = null
|
var currentOrderId: String = ""
|
var currentOrderType: String = ""
|
var orderStatueViews: MutableList<OrderStatueView> =
|
mutableListOf()
|
var testHeartNunm = 0
|
var testReceiveNum = 0
|
fun handleSSLHandshake() {
|
try {
|
val trustAllCerts = arrayOf<TrustManager>(object : X509TrustManager {
|
override fun getAcceptedIssuers(): Array<X509Certificate?> {
|
return arrayOfNulls(0)
|
}
|
|
override fun checkClientTrusted(
|
certs: Array<X509Certificate>,
|
authType: String
|
) {
|
}
|
|
override fun checkServerTrusted(
|
certs: Array<X509Certificate>,
|
authType: String
|
) {
|
}
|
})
|
val sc = SSLContext.getInstance("TLS")
|
// trustAllCerts信任所有的证书
|
sc.init(null, trustAllCerts, SecureRandom())
|
HttpsURLConnection.setDefaultSSLSocketFactory(sc.socketFactory)
|
HttpsURLConnection.setDefaultHostnameVerifier { hostname, session -> true }
|
} catch (ignored: Exception) {
|
}
|
}
|
|
fun addOrderView(view: OrderStatueView) {
|
if (!orderStatueViews.contains(view)) {
|
orderStatueViews.add(view)
|
}
|
}
|
|
fun removeOrderView(view: OrderStatueView?) {
|
orderStatueViews.remove(view)
|
}
|
}
|
|
private val activities = ArrayList<Activity?>()
|
private var showNum = 0
|
|
override fun onActivityPaused(activity: Activity?) {
|
}
|
|
override fun onActivityResumed(activity: Activity?) {
|
}
|
|
override fun onActivityStarted(activity: Activity?) {
|
showNum++
|
}
|
|
override fun onActivityDestroyed(activity: Activity?) {
|
activities.remove(activity)
|
}
|
|
override fun onActivitySaveInstanceState(activity: Activity?, outState: Bundle?) {
|
}
|
|
override fun onActivityStopped(activity: Activity?) {
|
showNum--
|
Handler(Looper.getMainLooper()).postDelayed({
|
if (showNum == 0) {
|
getTTsManager().setVideoText("昭阳出行司机已置于后台，可能会导致听单异常，里程计费差异，请勿切换。")
|
}
|
}, 600)
|
|
}
|
|
override fun onActivityCreated(activity: Activity?, savedInstanceState: Bundle?) {
|
activities.add(activity)
|
}
|
|
override fun onQueryTerminalCallback(p0: QueryTerminalResponse?) {
|
}
|
|
override fun onCreateTerminalCallback(p0: AddTerminalResponse?) {
|
}
|
|
override fun onDistanceCallback(p0: DistanceResponse?) {
|
}
|
|
override fun onLatestPointCallback(p0: LatestPointResponse?) {
|
}
|
|
override fun onHistoryTrackCallback(p0: HistoryTrackResponse?) {
|
}
|
|
override fun onQueryTrackCallback(p0: QueryTrackResponse?) {
|
}
|
|
override fun onAddTrackCallback(p0: AddTrackResponse?) {
|
if (p0?.isSuccess == true) {
|
val trackId = p0.trid
|
sysErr("轨迹创建成功,轨迹Id:$trackId")
|
var serviceIdS = CacheKey.getServerId()
|
val trackParam = TrackParam(serviceIdS.toLong(), terminalId)
|
trackParam.trackId = trackId
|
aMapTrackClient.startTrack(trackParam, this) //开始采集位置
|
} else {
|
sysErr("轨迹创建失败")
|
}
|
}
|
|
override fun onParamErrorCallback(p0: ParamErrorResponse?) {
|
}
|
|
override fun onBindServiceCallback(p0: Int, p1: String?) {
|
sysErr("onBindServiceCallback")
|
}
|
|
override fun onStartGatherCallback(p0: Int, p1: String?) {
|
if (p0 == ErrorCode.TrackListen.START_GATHER_SUCEE ||
|
p0 == ErrorCode.TrackListen.START_GATHER_ALREADY_STARTED
|
) {
|
sysErr( "定位采集开启成功！")
|
} else {
|
sysErr( "定位采集启动异常！")
|
}
|
}
|
|
override fun onStartTrackCallback(p0: Int, p1: String?) {
|
if (p0 == ErrorCode.TrackListen.START_TRACK_SUCEE ||
|
p0 == ErrorCode.TrackListen.START_TRACK_SUCEE_NO_NETWORK ||
|
p0 == ErrorCode.TrackListen.START_TRACK_ALREADY_STARTED
|
) {
|
// 服务启动成功，继续开启收集上报
|
aMapTrackClient.startGather(this)
|
} else {
|
sysErr( "轨迹上报服务服务启动异常！")
|
}
|
}
|
|
override fun onStopGatherCallback(p0: Int, p1: String?) {
|
sysErr("onStopGatherCallback：关闭定位采集")
|
}
|
|
override fun onStopTrackCallback(p0: Int, p1: String?) {
|
sysErr("onStopTrackCallback")
|
}
|
|
|
}
|
