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 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.initLogs
import cn.sinata.rxnetty.LogHelper.logRecord
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.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 {
    private val TAG = "IGoApplication"
    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)
        LanguageUtil.setDefaultLanguage(Const.Language.DEFAULT_LANGUAGE)
        DownloadLibrary.init(
            this,
            resources.getIdentifier("ic_launcher", "mipmap", packageName),
            null,
            packageName
        )
        initLogs()
        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 (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")
                            order?.let {
                                listeners.forEach {
                                    runOnUiThread {
                                        it.onStateChanged(
                                            order.optInt("orderId"),
                                            order.optInt("state")
                                        )
                                    }
                                }
                            }
                        }

                        Const.Method.DIFFERENCE -> {//物流需要补差价
                            Log.e("zmc-socket", "物流需要补差价")
                            payTheDifference(json.optJSONObject("data"))
//                            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 -> {//司机位置
                            logRecord(
                                TAG,
                                "received DRIVER_POSITION message $json, listeners size ${listeners.size}"
                            )
                            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 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 {
                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 currentLatLng: LatLng = LatLng(lat, lon) // 实际定位 永远不变 上那个会被修改

        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(activity: Activity) {
        Log.d("zmc-pageA", "onActivityStarted: " + activity.javaClass.name)
    }

    override fun onActivityDestroyed(activity: Activity) {
        activities.remove(activity)
        Log.d("zmc-pageA", "onActivityDestroyed: " + activity.javaClass.name)
    }

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

    override fun onActivityStopped(activity: Activity) {
        Log.e("zmc-pageA", "onActivityStopped: " + activity.javaClass.name)
    }

    override fun onActivityCreated(activity: Activity, p1: Bundle?) {
        activities.add(activity)
        Log.i("zmc-pageA", "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)
                    Log.i("zmc-pageF", "onFragmentCreated: " + f.javaClass.name)
                }

                override fun onFragmentDestroyed(fm: FragmentManager, f: Fragment) {
                    super.onFragmentDestroyed(fm, f)
                    Log.e("zmc-pageF", "onFragmentDestroyed: " + f.javaClass.name)
                }
            }, true)
        }
    }

    override fun onActivityResumed(p0: Activity) {
    }
}