package com.igo.user
|
|
//import com.umeng.commonsdk.UMConfigure
|
//import com.umeng.socialize.PlatformConfig
|
import android.app.Activity
|
import android.app.Application
|
import android.content.Intent
|
import android.os.Bundle
|
import android.util.Log
|
import android.view.View
|
import androidx.appcompat.app.AppCompatActivity
|
import androidx.core.os.bundleOf
|
import androidx.fragment.app.Fragment
|
import androidx.fragment.app.FragmentManager
|
import androidx.lifecycle.lifecycleScope
|
import cn.sinata.rxnetty.LogHelper
|
import cn.sinata.rxnetty.NettyClient
|
import cn.sinata.xldutils.activity.BaseActivity
|
import cn.sinata.xldutils.application.BaseApplication
|
import cn.sinata.xldutils.utils.LanguageUtil
|
import cn.sinata.xldutils.utils.SPUtils
|
import cn.sinata.xldutils.utils.myToast
|
import com.google.android.gms.maps.MapsInitializer
|
import com.google.android.gms.maps.model.LatLng
|
import com.google.android.libraries.places.api.Places
|
import com.google.gson.Gson
|
import com.igo.user.dialog.ChooseCardDialog
|
import com.igo.user.dialog.PayDialog
|
import com.igo.user.dialog.TipDialog
|
import com.igo.user.interfaces.OrderStateChangeListener
|
import com.igo.user.interfaces.StringCallback
|
import com.igo.user.network.Apis
|
import com.igo.user.network.HttpManager
|
import com.igo.user.network.RRetrofit
|
import com.igo.user.network.entity.TrippingInfo
|
import com.igo.user.network.request
|
import com.igo.user.ui.MainActivity
|
import com.igo.user.ui.SplashActivity
|
import com.igo.user.ui.login.LoginActivity
|
import com.igo.user.ui.trip.TripActivity
|
import com.igo.user.utils.Const
|
import com.igo.user.utils.crash.CrashHandler
|
import com.sinata.download.DownloadLibrary
|
import io.reactivex.Flowable
|
import io.reactivex.disposables.Disposable
|
import org.jetbrains.anko.runOnUiThread
|
import org.jetbrains.anko.startActivity
|
import org.json.JSONObject
|
import java.util.concurrent.TimeUnit
|
|
class IGoApplication : BaseApplication(), Application.ActivityLifecycleCallbacks {
|
override fun getSPName() = "IgoSp"
|
private var heartSubscribe: Disposable? = null
|
private val listeners = ArrayList<OrderStateChangeListener>()
|
private val activities = ArrayList<Activity>()
|
|
|
override fun onCreate() {
|
super.onCreate()
|
appContext = this
|
registerActivityLifecycleCallbacks(this)
|
LanguageUtil.setDefaultLanguage(Const.Language.DEFAULT_LANGUAGE)
|
DownloadLibrary.init(
|
this,
|
resources.getIdentifier("ic_launcher", "mipmap", packageName),
|
null,
|
packageName
|
)
|
LogHelper.initLogs(this)
|
initNetty()
|
Places.initialize(this, Const.google_key)
|
MapsInitializer.initialize(
|
this, MapsInitializer.Renderer.LATEST
|
) { renderer ->
|
Log.e(Const.GoogleTag, "LATEST renderer:${renderer.name}")
|
}
|
CrashHandler.init(this)
|
}
|
|
private fun initNetty() {
|
NettyClient.getInstance().init(this, BuildConfig.SOCKET_SERVER, BuildConfig.SOCKET_PORT, true)
|
NettyClient.getInstance().addOnMessageListener { message ->
|
try {
|
val json = JSONObject(message)
|
val method = json.optString("method")
|
val code = json.optString("code")
|
if (method != "OK") {
|
Log.d("zmc-socket", message)
|
}
|
|
if (code == "200") {
|
when (method) {
|
|
Const.Method.PING_RECEIVE -> {//心跳
|
//延时发送心跳
|
if (heartSubscribe != null && !heartSubscribe?.isDisposed!!) {
|
heartSubscribe?.dispose()
|
}
|
heartSubscribe =
|
Flowable.just("").delay(5000, TimeUnit.MILLISECONDS).subscribe {
|
sendHeart()
|
}
|
}
|
|
Const.Method.ORDER_STATUS -> {//订单状态改变
|
val order = json.optJSONObject("data")
|
LogHelper.logRecord("socket==>订单状态改变:${order}")
|
order?.let {
|
listeners.forEach {
|
runOnUiThread {
|
it.onStateChanged(
|
order.optInt("orderId"),
|
order.optInt("orderType"),
|
order.optInt("state")
|
)
|
}
|
}
|
}
|
}
|
|
Const.Method.DIFFERENCE -> {//物流需要补差价
|
Log.e("zmc-socket", "物流需要补差价")
|
payTheDifference(json.optJSONObject("data"))
|
LogHelper.logRecord("socket==>物流需要补差价:${json.optJSONObject("data")}")
|
}
|
|
Const.Method.REASSIGN -> {//订单改派
|
val order = json.optJSONObject("data")
|
LogHelper.logRecord("socket==>订单改派:${order}")
|
order?.let {
|
listeners.forEach {
|
runOnUiThread {
|
it.onStateChanged(
|
order.optInt("orderId"),
|
order.optInt("orderType"),
|
15
|
)
|
}
|
}
|
}
|
}
|
|
Const.Method.DRIVER_POSITION -> {//司机位置
|
val jb = json.optJSONObject("data")
|
LogHelper.logRecord("socket==>司机位置:${jb}")
|
jb?.let {
|
val data = Gson().fromJson(jb.toString(), TrippingInfo::class.java)
|
listeners.forEach {
|
runOnUiThread {
|
it.onTrippingChanged(data)
|
}
|
}
|
}
|
}
|
|
Const.Method.MODIFY_ADDRESS -> {//司机操作目的地变更事件
|
val jb = json.optJSONObject("data")
|
LogHelper.logRecord("socket==>司机操作目的地变更事件:${jb}")
|
jb?.let {
|
val data = Gson().fromJson(jb.toString(), TrippingInfo::class.java)
|
listeners.forEach {
|
runOnUiThread {
|
it.onAddressChanged(data)
|
}
|
}
|
}
|
}
|
|
Const.Method.FERRY -> {//摆渡车被接单
|
val jb = json.optJSONObject("data")
|
LogHelper.logRecord("socket==>摆渡车被接单:${jb}")
|
jb?.let {
|
listeners.forEach {
|
runOnUiThread {
|
it.onShuttleConfirm(
|
jb.optInt("orderId"),
|
jb.optInt("orderType")
|
)
|
}
|
}
|
}
|
}
|
|
Const.Method.END_PUSH -> {//无司机接单
|
val jb = json.optJSONObject("data")
|
val id = jb?.optInt("orderId") ?: 0
|
val type = jb?.optInt("orderType") ?: 0
|
val topAct = activities[activities.lastIndex]
|
LogHelper.logRecord("socket==>无司机接单:${jb}")
|
if (topAct is TripActivity) {
|
topAct.noResponse(id)
|
} else {
|
val tipDialog = TipDialog()
|
tipDialog.arguments = bundleOf(
|
"msg" to topAct.getString(R.string.附近暂无司机接单),
|
"ok" to topAct.getString(R.string.继续等待),
|
"cancel" to topAct.getString(R.string.取消订单)
|
)
|
tipDialog.setCallback(object : TipDialog.OnClickCallback {
|
override fun onOk() {
|
|
}
|
|
override fun onCancel() {
|
HttpManager.cancelOrder(
|
_currentLatLng.latitude,
|
_currentLatLng.longitude,
|
id,
|
type
|
)
|
.request(topAct as BaseActivity) { _, _ ->
|
myToast(topAct.getString(R.string.取消成功))
|
if (activities[0] is MainActivity) {
|
(activities[0] as MainActivity).queryTripping()
|
}
|
}
|
}
|
})
|
tipDialog.setDismissCallback(object : TipDialog.OnDismiss {
|
override fun onDismiss() {
|
HttpManager.pushOrderTaxi(id, type)
|
.request(topAct as BaseActivity) { _, _ ->
|
}
|
}
|
})
|
tipDialog.show(
|
(topAct as BaseActivity).supportFragmentManager,
|
"noResponse"
|
)
|
}
|
}
|
|
Const.Method.OFFLINE -> {//强制下线
|
LogHelper.logRecord("socket==>强制下线")
|
val topAct = activities[activities.lastIndex]
|
SPUtils.instance().remove(Const.User.TOKEN).remove(Const.User.USER_ID)
|
.remove(Const.User.NO_PHONE).apply()
|
val tipDialog = TipDialog()
|
tipDialog.arguments = bundleOf(
|
"msg" to topAct.getString(R.string.您的账号已在其他地方登陆),
|
"isAlert" to true
|
)
|
tipDialog.setDismissCallback(object : TipDialog.OnDismiss {
|
override fun onDismiss() {
|
exit()
|
topAct.startActivity<LoginActivity>()
|
}
|
})
|
tipDialog.show(
|
(topAct as BaseActivity).supportFragmentManager,
|
"logout"
|
)
|
}
|
}
|
}
|
} catch (e: Exception) {
|
e.printStackTrace()
|
}
|
}
|
NettyClient.getInstance().setOnConnectListener {
|
//连接成功，发送一次心跳
|
sendHeart()
|
}
|
}
|
|
private fun payTheDifference(data: JSONObject?) {
|
data?.let { data ->
|
val topAct = activities[activities.lastIndex] as BaseActivity
|
topAct.lifecycleScope.launchWhenResumed {
|
val orderId = data.optInt("orderId")
|
val money = data.optDouble("money")
|
val tipDialog = TipDialog()
|
tipDialog.arguments = bundleOf(
|
"msg" to topAct.getString(R.string.补差价提示).format(orderId, money),
|
"ok" to topAct.getString(R.string.同意),
|
"cancel" to topAct.getString(R.string.不同意)
|
)
|
tipDialog.setCallback(object : TipDialog.OnClickCallback {
|
override fun onOk() {
|
confirmDifferencePrice(topAct, orderId, money, 2) {
|
getUserInfoWhenPay(topAct, orderId, money)
|
}
|
}
|
|
override fun onCancel() {
|
confirmDifferencePrice(topAct, orderId, money, 3)
|
}
|
})
|
tipDialog.show((topAct).supportFragmentManager, "diff")
|
}
|
}
|
}
|
|
private fun getUserInfoWhenPay(topAct: BaseActivity, orderId: Int, money: Double) {
|
HttpManager.queryUserInfo().request(topAct, showDialog = true) { _, data ->
|
data?.let {
|
val payDialog = PayDialog()
|
payDialog.arguments = bundleOf(
|
"money" to money,
|
"isLogistics" to true,
|
"balance" to it.balance
|
)
|
payDialog.setCallback(object : PayDialog.Callback {
|
override fun onOk(way: Int, couponId: Int, useRed: Boolean) {
|
if (way == 2) {
|
val dialog = ChooseCardDialog()
|
dialog.setCallback(object : StringCallback {
|
override fun onRlt(rlt: String) {
|
pay(topAct, orderId, way, money)
|
}
|
})
|
dialog.show(topAct.supportFragmentManager, "card")
|
} else {
|
pay(topAct, orderId, way, money)
|
}
|
payDialog.dismiss()
|
}
|
|
override fun onClose() {
|
confirmDifferencePrice(topAct, orderId, money, 3)
|
}
|
})
|
payDialog.show(topAct.supportFragmentManager, "pay")
|
}
|
}
|
|
}
|
|
private fun pay(act: BaseActivity, orderId: Int, way: Int, money: Double) {
|
HttpManager.payOrderLogisticsSpread(orderId, way)
|
.request(act, showDialog = true) { _, data ->
|
myToast(getString(R.string.支付成功))
|
}
|
}
|
|
private fun confirmDifferencePrice(
|
act: BaseActivity,
|
orderId: Int,
|
money: Double,
|
state: Int,
|
block: (() -> Unit)? = null
|
) {
|
HttpManager.confirmDifferencePrice(orderId, money, state)
|
.request(act, showDialog = true) { _, _ ->
|
block?.invoke()
|
}
|
}
|
|
private fun sendHeart() {
|
val userId = SPUtils.instance().getInt(Const.User.USER_ID)
|
val token = SPUtils.instance().getString(Const.User.TOKEN)
|
if (userId != -1) {
|
val language = LanguageUtil.getLanguage()
|
val l = RRetrofit.getLanguageType(language)
|
NettyClient.getInstance()
|
.sendMessage("{\"data\":{\"userId\":$userId,\"language\":$l,\"token\":\"$token\",\"type\":1},\"method\":\"PING\",\"code\":200,\"msg\":\"SUCCESS\"}")
|
}
|
}
|
|
fun addTripStateListener(changedListener: OrderStateChangeListener) {
|
listeners.add(changedListener)
|
}
|
|
fun removeTripStateListener(changedListener: OrderStateChangeListener) {
|
listeners.remove(changedListener)
|
}
|
|
fun exit() {
|
activities.forEach {
|
if (it !is MainActivity)
|
it.finish()
|
else {
|
it.resetLogin()
|
}
|
}
|
}
|
|
fun reLaunch() {
|
activities.forEach {
|
it.finish()
|
}
|
val intent = Intent(this, SplashActivity::class.java)
|
intent.flags = Intent.FLAG_ACTIVITY_NEW_TASK
|
startActivity(intent)
|
}
|
|
companion object {
|
private val defaultLocation = LatLng(6.833333, -5.25)
|
private var _hadInitLocation = false//是否初始化过定位
|
private var _currentLatLng: LatLng = defaultLocation // 实际定位
|
|
var cityCode = "" //定位城市编码
|
var address = "" //定位地址
|
var chooseCityName = "——" //选择城市
|
var chooseCityLat = 0.0 //选择城市精度
|
var chooseCityLon = 0.0 //选择城市维度
|
var chooseCountry = "" //选择国家代码
|
var intervalCount = 0 //计数器，收到消息时置零；在TripActivity中检测改值：如果6秒钟没收到socket 就调取接口查订单实时状态
|
var emergency = "" //紧急联系人
|
var phone = "" //我的手机号
|
var phoneOperator = "" //手机运营商
|
var phoneService = "" //客服电话号
|
var appContext: IGoApplication? = null
|
var isNotifyEmail = false
|
var hasAutoGoTripping = false //true 本次启动已经自动跳转过
|
var mainActivity: MainActivity? = null
|
var tripId = ""
|
|
//设置定位
|
fun setLocation(latLng: LatLng) {
|
setLocation(latLng.latitude, latLng.longitude)
|
}
|
|
//设置定位
|
fun setLocation(latitude: Double, longitude: Double) {
|
this._currentLatLng = LatLng(latitude, longitude)
|
this._hadInitLocation = true
|
}
|
|
//是否初始化过定位
|
fun hadInitLocation(): Boolean {
|
return _hadInitLocation
|
}
|
|
//获取实际定位
|
fun getCurrentLocation(): LatLng {
|
return _currentLatLng
|
}
|
// var recaptchaClient: RecaptchaClient?=null
|
}
|
|
override fun onActivityPaused(p0: Activity) {
|
}
|
|
override fun onActivityStarted(activity: Activity) {
|
}
|
|
override fun onActivityDestroyed(activity: Activity) {
|
activities.remove(activity)
|
LogHelper.logRecord("onActivityDestroyed: " + activity.javaClass.name)
|
}
|
|
override fun onActivitySaveInstanceState(p0: Activity, p1: Bundle) {
|
}
|
|
override fun onActivityStopped(activity: Activity) {
|
LogHelper.logRecord("onActivityStopped: " + activity.javaClass.name)
|
}
|
|
override fun onActivityCreated(activity: Activity, p1: Bundle?) {
|
activities.add(activity)
|
LogHelper.logRecord("onActivityCreated: " + activity.javaClass.name)
|
if (activity is AppCompatActivity) {
|
activity.supportFragmentManager.registerFragmentLifecycleCallbacks(object :
|
FragmentManager.FragmentLifecycleCallbacks() {
|
override fun onFragmentCreated(
|
fm: FragmentManager,
|
f: Fragment,
|
savedInstanceState: Bundle?
|
) {
|
super.onFragmentCreated(fm, f, savedInstanceState)
|
LogHelper.logRecord("onFragmentCreated: " + f.javaClass.name)
|
}
|
|
override fun onFragmentViewCreated(
|
fm: FragmentManager,
|
f: Fragment,
|
v: View,
|
savedInstanceState: Bundle?
|
) {
|
super.onFragmentViewCreated(fm, f, v, savedInstanceState)
|
LogHelper.logRecord("onFragmentViewCreated: " + f.javaClass.name)
|
}
|
|
override fun onFragmentViewDestroyed(fm: FragmentManager, f: Fragment) {
|
super.onFragmentViewDestroyed(fm, f)
|
LogHelper.logRecord("onFragmentViewDestroyed: " + f.javaClass.name)
|
}
|
|
override fun onFragmentDestroyed(fm: FragmentManager, f: Fragment) {
|
super.onFragmentDestroyed(fm, f)
|
LogHelper.logRecord("onFragmentDestroyed: " + f.javaClass.name)
|
}
|
}, true)
|
}
|
}
|
|
override fun onActivityResumed(activity: Activity) {
|
LogHelper.logRecord("onActivityResumed: " + activity.javaClass.name)
|
}
|
}
|
