package application.controller

import application.model.*
import javafx.collections.FXCollections
import javafx.collections.ObservableList
import javafx.fxml.FXML
import javafx.fxml.Initializable
import javafx.scene.control.ListCell
import javafx.scene.control.ListView
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import org.charts.dataviewer.api.config.DataViewerConfiguration
import org.charts.dataviewer.api.data.PlotData
import org.charts.dataviewer.api.trace.ScatterTrace
import org.charts.dataviewer.javafx.JavaFxDataViewer
import org.charts.dataviewer.utils.TraceColour
import org.charts.dataviewer.utils.TraceVisibility
import java.net.URL
import java.util.*


class DataPanelController : Initializable, SelectedVesselListener {
    private var dataList: ObservableList<Pair<String, ArrayList<MessageData?>>> = FXCollections.observableArrayList()
    private lateinit var timeData: ArrayList<MessageData?>

    private val latitude: ArrayList<MessageData?> = arrayListOf()
    private val longitude: ArrayList<MessageData?> = arrayListOf()
    private val speedOverGround: ArrayList<MessageData?> = arrayListOf()
    private val courseOverGround: ArrayList<MessageData?> = arrayListOf()
    private val heading: ArrayList<MessageData?> = arrayListOf()
    private val vesselName: ArrayList<MessageData?> = arrayListOf()
    private val imo: ArrayList<MessageData?> = arrayListOf()
    private val callSign: ArrayList<MessageData?> = arrayListOf()
    private val vesselType: ArrayList<MessageData?> = arrayListOf()
    private val status: ArrayList<MessageData?> = arrayListOf()
    private val length: ArrayList<MessageData?> = arrayListOf()
    private val width: ArrayList<MessageData?> = arrayListOf()
    private val draft: ArrayList<MessageData?> = arrayListOf()
    private val cargo: ArrayList<MessageData?> = arrayListOf()

    private var selectedItem: Pair<String, ArrayList<MessageData?>>? = null

    @FXML
    var dataListView = ListView<Pair<String, ArrayList<MessageData?>>>()

    @FXML
    var dataViewer = JavaFxDataViewer()

    private val plotData = PlotData()
    private val config = DataViewerConfiguration()

    override fun initialize(location: URL?, resources: ResourceBundle?) {
        setObservableSelectedVesselListener()
        dataListView.items = dataList



        config.showLegend(true)
        config.setLegendInsidePlot(false)

        setObservableCurrentTimeListener()

        dataListView.setCellFactory {
            object : ListCell<Pair<String, ArrayList<MessageData?>>?>() {
                override fun updateItem(item: Pair<String, ArrayList<MessageData?>>?, empty: Boolean) {
                    super.updateItem(item, empty)
                    text = if (empty) {
                        null
                    } else {
                        item?.first
                    }
                }
            }
        }

        dataListView.selectionModel.selectedItemProperty().addListener { _, _, newValue ->
            selectedItem = newValue
            plot(newValue)
        }

        plotData.allTraces.clear()
        config.setxAxisTitle("")
        config.setyAxisTitle("")
        config.plotTitle = ""
        dataViewer.updateConfiguration(config)
        dataViewer.updatePlot(plotData)
        initDataList()


    }

    private fun plot() {
        if (selectedItem != null) {
            GlobalScope.launch {
                plot(selectedItem)
            }
        }
    }

    private fun plot(data: Pair<String, ArrayList<MessageData?>>?) {
        if (data == null) {
            plotData.allTraces.clear()
            config.setxAxisTitle("")
            config.setyAxisTitle("")
            dataViewer.updateConfiguration(config)

            dataViewer.resetPlot()

            return
        }

        val getValueVisitorX = GetValueVisitor()
        val getValueVisitorY = GetValueVisitor()

        val arrayListStringX = arrayListOf<String>()
//        val arrayListDoubleX = arrayListOf<Double>()
        val arrayListStringY = arrayListOf<String>()
        val arrayListDoubleY = arrayListOf<Double>()

        for (x in 0 until timeData.size) {
            timeData[x]?.accept(getValueVisitorX)
            data.second[x]?.accept(getValueVisitorY)

            if (getValueVisitorY.value.toDoubleOrNull() == null) {
                arrayListStringX.add(getValueVisitorX.value)
                arrayListStringY.add(getValueVisitorY.value)
            } else {
                arrayListStringX.add(getValueVisitorX.value)
                arrayListDoubleY.add(getValueVisitorY.value.toDouble())
            }
        }

        val scatterTrace = ScatterTrace<Any>()
        scatterTrace.traceColour = TraceColour.RED
        scatterTrace.traceVisibility = TraceVisibility.TRUE

        val serieStringX: Array<String> = arrayListStringX.toTypedArray()
//            val serieDoubleX: Array<Double> = arrayListDoubleX.toTypedArray()
        val serieStringY: Array<String> = arrayListStringY.toTypedArray()
        val serieDoubleY: Array<Double> = arrayListDoubleY.toTypedArray()

        if (getValueVisitorY.value.toDoubleOrNull() == null) {
            scatterTrace.setxArray(serieStringX)
            scatterTrace.setyArray(serieStringY)
        } else {
            scatterTrace.setxArray(serieStringX)
            scatterTrace.setyArray(serieDoubleY)
        }

        config.plotTitle = ""
        config.setxAxisTitle("Time (s)")
        config.setyAxisTitle(data.first)
        dataViewer.resetPlot()
        plotData.allTraces.clear()
        plotData.addTrace(scatterTrace)
        dataViewer.updateConfiguration(config)
        dataViewer.updatePlot(plotData)

    }


    private fun setObservableSelectedVesselListener() {
        observableSelectedVessel.listeners.add(this)
    }

    private fun populateTime(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllTimeBeforeSelectedTime()
        } else {
            vessel.getAllTime()
        }
    }


    private fun populateLatitude(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllLatitudeBeforeSelectedTime()
        } else {
            vessel.getAllLatitude()
        }
    }

    private fun populateLongitude(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllLongitudeBeforeSelectedTime()
        } else {
            vessel.getAllLongitude()
        }
    }

    private fun populateSpeedOverGround(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllSpeedOverGroundBeforeSelectedTime()
        } else {
            vessel.getAllSpeedOverGround()
        }
    }

    private fun populateCourseOverGround(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllCourseOverGroundBeforeSelectedTime()
        } else {
            vessel.getAllCourseOverGround()
        }
    }

    private fun populateHeading(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllHeadingBeforeSelectedTime()
        } else {
            vessel.getAllHeading()
        }
    }

    private fun populateVesselName(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllVesselNameBeforeSelectedTime()
        } else {
            vessel.getAllVesselName()
        }
    }

    private fun populateIMO(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllIMOBeforeSelectedTime()
        } else {
            vessel.getAllIMO()
        }
    }

    private fun populateCallSign(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllCallSignBeforeSelectedTime()
        } else {
            vessel.getAllCallSign()
        }
    }

    private fun populateVesselType(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllVesselTypeBeforeSelectedTime()
        } else {
            vessel.getAllVesselType()
        }
    }

    private fun populateStatus(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllStatusBeforeSelectedTime()
        } else {
            vessel.getAllStatus()
        }
    }

    private fun populateLength(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllLengthBeforeSelectedTime()
        } else {
            vessel.getAllLength()
        }
    }

    private fun populateWidth(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllWidthBeforeSelectedTime()
        } else {
            vessel.getAllWidth()
        }
    }

    private fun populateDraft(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllDraftBeforeSelectedTime()
        } else {
            vessel.getAllDraft()
        }
    }

    private fun populateCargo(vessel: Vessel): ArrayList<MessageData?> {
        return if (observableIsReplayState.value) {
            vessel.getAllCargoBeforeSelectedTime()
        } else {
            vessel.getAllCargo()
        }
    }

    private fun initDataList() {
        val data = arrayListOf<Pair<String, ArrayList<MessageData?>>>()

        data.add(Pair("Latitude", latitude))
        data.add(Pair("Longitude", longitude))
        data.add(Pair("Speed Over Ground", speedOverGround))
        data.add(Pair("Course Over Ground", courseOverGround))
        data.add(Pair("Heading", heading))
        data.add(Pair("Vessel Name", vesselName))
        data.add(Pair("IMO", imo))
        data.add(Pair("Call Sign", callSign))
        data.add(Pair("Vessel Type", vesselType))
        data.add(Pair("Status", status))
        data.add(Pair("Length", length))
        data.add(Pair("Width", width))
        data.add(Pair("Draft", draft))
        data.add(Pair("Cargo", cargo))

        dataList.addAll(data)
    }

    private fun updateDataList(vessel: Vessel) {
        timeData = populateTime(vessel)

        latitude.clear()
        latitude.addAll(populateLatitude(vessel))

        longitude.clear()
        longitude.addAll(populateLongitude(vessel))

        speedOverGround.clear()
        speedOverGround.addAll(populateSpeedOverGround(vessel))

        courseOverGround.clear()
        courseOverGround.addAll(populateCourseOverGround(vessel))

        heading.clear()
        heading.addAll(populateHeading(vessel))

        vesselName.clear()
        vesselName.addAll(populateVesselName(vessel))

        imo.clear()
        imo.addAll(populateIMO(vessel))

        callSign.clear()
        callSign.addAll(populateCallSign(vessel))

        vesselType.clear()
        vesselType.addAll(populateVesselType(vessel))

        status.clear()
        status.addAll(populateStatus(vessel))

        length.clear()
        length.addAll(populateLength(vessel))

        width.clear()
        width.addAll(populateWidth(vessel))

        draft.clear()
        draft.addAll(populateDraft(vessel))

        cargo.clear()
        cargo.addAll(populateCargo(vessel))

    }

    private fun setObservableCurrentTimeListener() {
        observableCurrentTime.listeners.add(object : CurrentTime {
            override fun onValueChanged(newValue: Int) {
                updateDataList(observableSelectedVessel.value)
                plot()
            }
        })
    }

    override fun onValueChanged(newValue: Vessel) {
        updateDataList(newValue)
        plot()
    }

}