package com.igo.user

import android.app.Activity
import android.app.Application
import android.content.Intent
import android.os.Bundle
import android.util.Log
import androidx.core.os.bundleOf
import cn.sinata.rxnetty.NettyClient
import cn.sinata.xldutils.activity.BaseActivity
import cn.sinata.xldutils.application.BaseApplication
import cn.sinata.xldutils.utils.SPUtils
import cn.sinata.xldutils.utils.myToast
import com.amap.api.col.sln3.it
import com.google.android.gms.maps.MapsInitializer
import com.google.android.libraries.places.api.Places
import com.google.gson.Gson
import com.igo.user.dialog.TipDialog
import com.igo.user.interfaces.OrderStateChangeListener
import com.igo.user.network.Apis
import com.igo.user.network.HttpManager
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.sinata.download.DownloadLibrary
import com.umeng.commonsdk.UMConfigure
import com.umeng.socialize.PlatformConfig
import io.reactivex.Flowable
import io.reactivex.disposables.Disposable
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.launch
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
        // initializeRecaptchaClient()
        registerActivityLifecycleCallbacks(this)
        DownloadLibrary.init(
            this,
            resources.getIdentifier("ic_launcher", "mipmap", packageName),
            null,
            packageName
        )
        initNetty()
        UMConfigure.init(this, Const.UMENG_KEY, "", UMConfigure.DEVICE_TYPE_PHONE, "")
        PlatformConfig.setWeixin(Const.WX_APP_ID, Const.WX_SECRET)
        PlatformConfig.setWXFileProvider("com.igo.user.FileProvider")
        UMConfigure.setLogEnabled(true)
        Places.initialize(this, Const.google_key)
        MapsInitializer.initialize(
            this, MapsInitializer.Renderer.LATEST
        ) { renderer ->
            Log.e(Const.GoogleTag, "LATEST renderer:${renderer.name}")
//            initializeConsumerSdk()
        }
    }

    private fun initNetty() {
        NettyClient.getInstance().init(this, Apis.SOCKET_SERVER, Apis.SOCKET_PORT, true)
        NettyClient.getInstance().addOnMessageListener { message ->
            intervalCount = 0
            try {
                val json = JSONObject(message)
                val method = json.optString("method")
                val code = json.optString("code")
                if (code == "200") {
                    Log.e("物流需要补差价: ", "状态${method}")
                    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")
                            order?.let {
                                listeners.forEach {
                                    runOnUiThread {
                                        it.onStateChanged(
                                            order.optInt("orderId"),
                                            order.optInt("state")
                                        )
                                    }
                                }
                            }
                        }

                        Const.Method.DIFFERENCE -> {//物流需要补差价
                            Log.e("物流需要补差价: ", "物流需要补差价")
                            val order = json.optJSONObject("data")
                            val data = Gson().fromJson(order.toString(), TrippingInfo::class.java)
                            order?.let {
                                val topAct = activities[activities.lastIndex]
                                val tipDialog = TipDialog()
                                tipDialog.arguments = bundleOf(
                                    "msg" to topAct.getString(R.string.补差价提示)
                                        .format(data.orderId, data.money),
                                    "ok" to topAct.getString(R.string.同意),
                                    "cancel" to topAct.getString(R.string.不同意)
                                )
                                tipDialog.setCallback(object : TipDialog.OnClickCallback {
                                    override fun onOk() {
                                        HttpManager.confirmDifferencePrice(
                                            data.orderId,
                                            data.money,
                                            2
                                        ).request(topAct as BaseActivity) { _, _ ->
                                        }
                                    }

                                    override fun onCancel() {
                                        HttpManager.confirmDifferencePrice(
                                            data.orderId,
                                            data.money,
                                            3
                                        ).request(topAct as BaseActivity) { _, _ ->
                                        }
                                    }
                                })
                                tipDialog.show(
                                    (topAct as BaseActivity).supportFragmentManager,
                                    "diff"
                                )
                            }
                        }

                        Const.Method.REASSIGN -> {//订单改派
                            val order = json.optJSONObject("data")
                            order?.let {
                                listeners.forEach {
                                    runOnUiThread {
                                        it.onStateChanged(order.optInt("orderId"), 15)
                                    }
                                }
                            }
                        }

                        Const.Method.DRIVER_POSITION -> {//司机位置
                            val jb = json.optJSONObject("data")
                            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")
                            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")
                            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]
                            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(lat, lon, 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 -> {//强制下线
                            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 sendHeart() {
        val userId = SPUtils.instance().getInt(Const.User.USER_ID)
        val token = SPUtils.instance().getString(Const.User.TOKEN)
        if (userId != -1) {
            val language = SPUtils.instance().getString("language", "en")
            val l = when (language) {
                "ch" -> "1"
                "fr" -> "3"
                else -> "2"
            }
            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 {
                val mainActivity = it as MainActivity
                mainActivity.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 {
        var lat = 6.833333
        var lon = -5.25

        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 = ""

        //  var recaptchaClient: RecaptchaClient?=null
    }

    override fun onActivityPaused(p0: Activity) {

    }

    override fun onActivityStarted(p0: Activity) {
    }

    override fun onActivityDestroyed(p0: Activity) {
        activities.remove(p0)
    }

    override fun onActivitySaveInstanceState(p0: Activity, p1: Bundle) {
    }

    override fun onActivityStopped(p0: Activity) {
    }

    override fun onActivityCreated(p0: Activity, p1: Bundle?) {
        activities.add(p0)
    }

    override fun onActivityResumed(p0: Activity) {
    }
}