package com.xw.yunwei.ui.task

import android.app.Application
import android.view.View
import androidx.lifecycle.MutableLiveData
import com.amap.api.location.AMapLocation
import com.xw.common.base.BaseViewModel
import com.xw.common.utils.LogUtils
import com.xw.yunwei.R
import com.xw.yunwei.databinding.ItemArrow2TextBinding
import com.xw.yunwei.model.TaskStatisticInfo
import com.xw.yunwei.net.TaskRepository
import com.xw.yunwei.ui.task.list.TaskListFragment
import org.koin.core.component.inject

/**
 * 任务中心 ViewModel
 *
 * 管理任务筛选条件、任务列表 Fragment 实例、未读消息数量等业务数据，
 * 提供筛选参数转换及网络请求能力。
 *
 * @author zmc
 */
class TaskVM(myApplication: Application) : BaseViewModel(myApplication) {

    companion object {
        /** 全局标识：是否需要刷新消息红点 */
        val needRefresh = MutableLiveData(true)
    }

    /** 全部任务列表 Fragment */
    val allTaskFragment by lazy { TaskListFragment.newInstance(null) }

    /** 待到达任务列表 Fragment */
    val togoTaskFragment by lazy { TaskListFragment.newInstance(0) }

    /** 待处理任务列表 Fragment */
    val todoTaskFragment by lazy { TaskListFragment.newInstance(1) }

    /** 已处理任务列表 Fragment */
    val finishTaskFragment by lazy { TaskListFragment.newInstance(2) }
    val reassignmentTaskFragment by lazy { TaskListFragment.newInstance(4) }

    /** 任务数据仓库 */
    val taskRepository: TaskRepository by inject()

    //选中任务类型下标
    val selectTaskTypeIndex = MutableLiveData(0)

    //统计信息
    val taskStatistic = MutableLiveData<TaskStatisticInfo>()

    /** 当前定位信息 */
    var location: AMapLocation? = null

    /** 车牌号搜索关键字 */
    // 车牌号
    val plateNumber: MutableLiveData<String> = MutableLiveData("")

    /** 筛选开始时间（yyyy-MM-dd） */
    var startTime = ""

    /** 筛选结束时间（yyyy-MM-dd） */
    var endTime = ""

    /** 派发时间筛选项 */
    val filterTaskTime = listOf("今天", "昨天", "近一周", "近一月")

    /** 优先级筛选项 */
    val filterTaskLevel = listOf("全部", "一级", "二级", "三级")

    /** 任务类型筛选项 */
    val filterTaskType = listOf("全部", "事故", "常规")

    /** 排序优先筛选项 */
    val filterTaskSort = listOf("任务优先级", "车牌号", "任务时间")

    /** 当前选中的派发时间 */
    var selectTaskTime = filterTaskTime[2]

    /** 当前选中的优先级 */
    var selectTaskLevel = filterTaskLevel[0]

    /** 当前选中的任务类型 */
    var selectTaskType = filterTaskType[0]

    /** 当前选中的排序字段 */
    var selectTaskSort = filterTaskSort[0]

    /** 排序规则：1 正序，2 倒序 */
    var taskSort = 1

    /** 排序视图绑定列表，用于动态更新 UI 状态 */
    val sortViews = mutableListOf<ItemArrow2TextBinding>()

    //是否刷新列表
    val needRefreshList = MutableLiveData(false)

    //是否已经筛选
    fun hadFilter(): Boolean {
        return selectTaskTime != filterTaskTime[2] || selectTaskLevel != filterTaskLevel[0] ||
                selectTaskType != filterTaskType[0] || selectTaskSort != filterTaskSort[0] || taskSort != 1 ||
                startTime.isNotEmpty() || endTime.isNotEmpty()
    }

    /**
     * 获取派发类型对应的服务器参数
     *
     * 若用户自定义了时间范围则返回 5；否则根据快捷选项返回对应编码。
     *
     * @return 派发类型编码，null 表示未选择
     */
    fun getDistributeType(): Int? = when {
        startTime.isNotEmpty() || endTime.isNotEmpty() -> 5
        selectTaskTime == "今天" -> 1
        selectTaskTime == "昨天" -> 2
        selectTaskTime == "近一周" -> 3
        selectTaskTime == "近一月" -> 4
        else -> null
    }

    /**
     * 获取紧急程度对应的服务器参数
     *
     * @return 紧急程度编码，null 表示全部
     */
    fun getUrgencyLevel(): Int? = when (selectTaskLevel) {
        "一级" -> 0
        "二级" -> 1
        "三级" -> 2
        else -> null
    }

    /**
     * 获取任务类别对应的服务器参数
     *
     * @return 任务类别编码，null 表示全部
     */
    fun getTaskCategory(): Int? = when (selectTaskType) {
        "事故" -> 2
        "常规" -> 1
        else -> null
    }

    /**
     * 获取排序类型对应的服务器参数
     *
     * @return 排序类型编码，null 表示未选择
     */
    fun getSortType(): Int? = when (selectTaskSort) {
        "任务优先级" -> 1
        "车牌号" -> 2
        "任务时间" -> 3
        else -> null
    }

    /**
     * 获取未读消息数量
     *
     * @param block 请求结果回调，参数为未读数量字符串
     */
    fun getUnreadCount(block: (String) -> Unit) {
        launchRequest(showLoading = false) {
            taskRepository.getUnreadCount().let {
                runOnMainThread { block(it ?: "") }
            }
        }
    }

    //更改任务类型
    fun changeTaskType(index: Int) {
        selectTaskType = filterTaskType[index]
        selectTaskTypeIndex.postValue(index)
    }

    val onClick = View.OnClickListener {
        when (it.id) {
            R.id.back -> onBackPressed()

            R.id.rl_all -> {
                changeTaskType(0)
                statistic()
                needRefreshList.postValue(true)
            }

            R.id.rl_accident -> {
                changeTaskType(1)
                statistic()
                needRefreshList.postValue(true)
            }

            R.id.rl_normal -> {
                changeTaskType(2)
                statistic()
                needRefreshList.postValue(true)
            }
        }
    }

    //获取统计信息
    fun statistic() {
        launchRequest(error = { code, msg ->
            LogUtils.e(TAG, "launchRequest: code = $code msg = $msg")
        }) {
            taskRepository.statistic(
                getDistributeType()?.toString(),
                startTime,
                endTime,
                getTaskCategory()?.toString(),
                getUrgencyLevel()?.toString(),
                plateNumber.value
            )?.also {
                taskStatistic.postValue(it)
            }
        }
    }
}