"""
    The DD Dialysate Pumps ui loader
"""
# Python
import os

# Qt
from PySide2                import QtCore, QtWidgets
from PySide2.QtCore         import Slot

# parent
from engine.dynamicloader   import DynamicLoader

# dd Simulator
from leahi_dialin.ui.dd_messaging import DD_Messaging


class Loader(DynamicLoader):
    """
    The DD Dialysate Pumps ui loader
    """

    def __init__(self):
        self.dd_interface = DD_Messaging()
        super().__init__(os.path.dirname(__file__))


    def _init_loader(self):
        """
        finds and creates widgets
        :return: none
        """
        self.tbReset                    = self.find_widget(QtWidgets.QToolButton    , 'tbReset'                     )
        self.tbSend                     = self.find_widget(QtWidgets.QToolButton    , 'tbSend'                      )

        self.dsbD12targetRPM           = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD12targetRPM'              )
        self.dsbD12MeasuredSpeed       = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD12MeasuredSpeed'          )     
        self.dsbD12CurrentSpeed        = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD12CurrentSpeed'           )
        self.sbD12State                = self.find_widget(QtWidgets.QSpinBox       , 'sbD12State'                   )
        self.dsbD12TargetPressure      = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD12TargetPressure'         )
        self.dsbD12MeasuredPressure    = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD12MeasuredPressure'       )
        self.dsbD12MeasuredCurrent     = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD12MeasuredCurrent'        )         
        self.sbD12Control              = self.find_widget(QtWidgets.QSpinBox       , 'sbD12Control'                 )
        self.sbD12DirectionErrorCount  = self.find_widget(QtWidgets.QSpinBox       , 'sbD12DirectionErrorCount'     )
        self.sbD12MeasuredDirection    = self.find_widget(QtWidgets.QSpinBox       , 'sbD12MeasuredDirection'       )
        self.dsbD48targetRPM           = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD48targetRPM'              )
        self.dsbD48MeasuredSpeed       = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD48MeasuredSpeed'          )
        self.dsbD48CurrentSpeed        = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD48CurrentSpeed'           )
        self.sbD48State                = self.find_widget(QtWidgets.QSpinBox       , 'sbD48State'                   )
        self.dsbD48TargetPressure      = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD48TargetPressure'         )
        self.dsbD48MeasuredPressure    = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD48MeasuredPressure'       )
        self.dsbD48MeasuredCurrent     = self.find_widget(QtWidgets.QDoubleSpinBox , 'dsbD48MeasuredCurrent'        )
        self.sbD48Control              = self.find_widget(QtWidgets.QSpinBox       , 'sbD48Control'                 )
        self.sbD48DirectionErrorCount  = self.find_widget(QtWidgets.QSpinBox       , 'sbD48DirectionErrorCount'     )
        self.sbD48MeasuredDirection    = self.find_widget(QtWidgets.QSpinBox       , 'sbD48MeasuredDirection'       )

    def _init_connections(self):
        """
        initializes the widgets connections
        :return: none
        """
        self.tbReset.clicked.connect(self._init_widgets)
        self.tbSend.clicked.connect(self.do_dd_dialysate_pump)

    @Slot()
    def _init_widgets(self):
        """
        initializes the widgets' properties
        :return: none
        """
        self.dsbD12targetRPM          .setValue(0)
        self.dsbD12MeasuredSpeed      .setValue(0)
        self.dsbD12CurrentSpeed       .setValue(0)
        self.sbD12State               .setValue(0)
        self.dsbD12TargetPressure     .setValue(0)
        self.dsbD12MeasuredPressure   .setValue(0)
        self.dsbD12MeasuredCurrent    .setValue(0)
        self.sbD12Control             .setValue(0)
        self.sbD12DirectionErrorCount .setValue(0)
        self.sbD12MeasuredDirection   .setValue(0)
        self.dsbD48targetRPM          .setValue(0)
        self.dsbD48MeasuredSpeed      .setValue(0)
        self.dsbD48CurrentSpeed       .setValue(0)
        self.sbD48State               .setValue(0)
        self.dsbD48TargetPressure     .setValue(0)
        self.dsbD48MeasuredPressure   .setValue(0)
        self.dsbD48MeasuredCurrent    .setValue(0)
        self.sbD48Control             .setValue(0)
        self.sbD48DirectionErrorCount .setValue(0)
        self.sbD48MeasuredDirection   .setValue(0)

    @Slot()
    def do_dd_dialysate_pump(self):
        """
        the slot for dd Dialysate Pump change
        :return: none
        """
        
        d12PumpTargetRPM         = self.dsbD12targetRPM             .value()
        d48PumpTargetRPM         = self.dsbD48targetRPM             .value()
        d12PumpMeasuredSpeed     = self.dsbD12MeasuredSpeed         .value()
        d48PumpMeasuredSpeed     = self.dsbD48MeasuredSpeed         .value()
        d12PumpCurrentSpeed      = self.dsbD12CurrentSpeed          .value()
        d48PumpCurrentSpeed      = self.dsbD48CurrentSpeed          .value()
        d12PumpState             = self.sbD12State                  .value()
        d48PumpState             = self.sbD48State                  .value()
        d12PumpTargetPressure    = self.dsbD12TargetPressure        .value()
        d48PumpTargetPressure    = self.dsbD48TargetPressure        .value()
        d12PumpMeasuredPressure  = self.dsbD12MeasuredPressure      .value()
        d48PumpMeasuredPressure  = self.dsbD48MeasuredPressure      .value()
        d12PumpMeasuredCurrent   = self.dsbD12MeasuredCurrent       .value()
        d48PumpMeasuredCurrent   = self.dsbD48MeasuredCurrent       .value()
        d12PumpControl           = self.sbD12Control                .value()
        d48PumpControl           = self.sbD48Control                .value()
        d12PumpDirErrCnt         = self.sbD12DirectionErrorCount    .value()
        d48PumpDirErrCnt         = self.sbD48DirectionErrorCount    .value()
        d12PumpMeasuredDir       = self.sbD12MeasuredDirection      .value()
        d48PumpMeasuredDir       = self.sbD48MeasuredDirection      .value()

        self.dd_interface.dd_dialysate_pump(
            d12PumpTargetRPM        , 
            d48PumpTargetRPM        ,
            d12PumpMeasuredSpeed    ,
            d48PumpMeasuredSpeed    ,
            d12PumpCurrentSpeed     ,
            d48PumpCurrentSpeed     ,
            d12PumpState            ,
            d48PumpState            ,
            d12PumpTargetPressure   ,
            d48PumpTargetPressure   ,
            d12PumpMeasuredPressure ,
            d48PumpMeasuredPressure ,
            d12PumpMeasuredCurrent  ,
            d48PumpMeasuredCurrent  ,
            d12PumpControl          ,
            d48PumpControl          ,
            d12PumpDirErrCnt        ,
            d48PumpDirErrCnt        ,
            d12PumpMeasuredDir      ,
            d48PumpMeasuredDir                        
        )