Index: leahi_dialin/ui/td_messaging.py =================================================================== diff -u -r690b21a94bd10378e12ee9a7493f9a18602ce311 -ra88c5fc804a98a253822d607557501b27bc53d5b --- leahi_dialin/ui/td_messaging.py (.../td_messaging.py) (revision 690b21a94bd10378e12ee9a7493f9a18602ce311) +++ leahi_dialin/ui/td_messaging.py (.../td_messaging.py) (revision a88c5fc804a98a253822d607557501b27bc53d5b) @@ -118,13 +118,16 @@ self.can_interface.send(message, 0) def td_air_trap(self, - H17_state : int, - H16_state : int, - H17_raw_state : int, - H16_raw_state : int, - H13_state : int, - H20_State : int, - controlling : int): + H17State : int, + H16State : int, + H17RawState : int, + H16RawState : int, + H13State : int, + H20State : int, + IsAutoControlling : int, + AirTrapState : int, + AirPumpLowerPowerLevel : int, + AirPumpRaisePowerLevel : int): """ Broadcasts the current TD air trap data(Msg ID: 0x2A, 42) Args: @@ -141,13 +144,16 @@ raise ValueError("CAN Interface is not enabled") - payload = conversions.unsigned_integer_to_bytearray(H17_state ) - payload += conversions.unsigned_integer_to_bytearray(H16_state ) - payload += conversions.unsigned_integer_to_bytearray(H17_raw_state ) - payload += conversions.unsigned_integer_to_bytearray(H16_raw_state ) - payload += conversions.unsigned_integer_to_bytearray(H13_state ) - payload += conversions.unsigned_integer_to_bytearray(H20_State ) - payload += conversions.unsigned_integer_to_bytearray(controlling ) + payload = conversions.unsigned_integer_to_bytearray(H17State ) + payload += conversions.unsigned_integer_to_bytearray(H16State ) + payload += conversions.unsigned_integer_to_bytearray(H17RawState ) + payload += conversions.unsigned_integer_to_bytearray(H16RawState ) + payload += conversions.unsigned_integer_to_bytearray(H13State ) + payload += conversions.unsigned_integer_to_bytearray(H20State ) + payload += conversions.unsigned_integer_to_bytearray(IsAutoControlling ) + payload += conversions.unsigned_integer_to_bytearray(AirTrapState ) + payload += conversions.unsigned_integer_to_bytearray(AirPumpLowerPowerLevel ) + payload += conversions.unsigned_integer_to_bytearray(AirPumpRaisePowerLevel ) message = CAN.CanMessage.build_message( channel_id=CAN.CanChannels.td_sync_broadcast_ch_id, @@ -179,8 +185,11 @@ self.can_interface.send(message, 0) - def td_air_pump(self, H12_state : int, - H12_power : int): + def td_air_pump(self, H12_state : int, + H12_rpm : int, + H12_power : float, + H12_fpga_rpm : int, + H12_scalar_power : int): """ Broadcasts the current TD Air Pump data (Msg ID: 0x20, 32) Args: @@ -192,8 +201,11 @@ raise ValueError("CAN Interface is not enabled") - payload = conversions.unsigned_integer_to_bytearray(H12_state) - payload += conversions.unsigned_integer_to_bytearray(H12_power) + payload = conversions.unsigned_integer_to_bytearray(H12_state ) + payload += conversions.unsigned_integer_to_bytearray(H12_rpm ) + payload += conversions.float_to_bytearray (H12_power ) + payload += conversions.unsigned_integer_to_bytearray(H12_fpga_rpm ) + payload += conversions.unsigned_integer_to_bytearray(H12_scalar_power ) message = CAN.CanMessage.build_message( channel_id=CAN.CanChannels.td_sync_broadcast_ch_id, @@ -202,7 +214,10 @@ self.can_interface.send(message, 0) - def td_ejector(self, H5_state: int, H5_set_speed: float): + def td_ejector(self, H5_state: int, + H5_set_speed: float, + Retract_Opt_sensor: int, + Engage_Opt_sensor: int): """ Broadcasts the current TD Ejector data (Msg ID: 0x4E, 78) Args: @@ -213,10 +228,11 @@ if not self.can_enabled: raise ValueError("CAN Interface is not enabled") + payload = conversions.unsigned_integer_to_bytearray (H5_state ) + payload += conversions.float_to_bytearray (H5_set_speed ) + payload += conversions.unsigned_integer_to_bytearray (Retract_Opt_sensor ) + payload += conversions.unsigned_integer_to_bytearray (Engage_Opt_sensor ) - payload = conversions.unsigned_integer_to_bytearray(H5_state ) - payload += conversions.float_to_bytearray (H5_set_speed) - message = CAN.CanMessage.build_message( channel_id=CAN.CanChannels.td_sync_broadcast_ch_id, message_id=msg_ids.MsgIds.MSG_ID_TD_EJECTOR_DATA.value, @@ -267,7 +283,16 @@ self.can_interface.send(message, 0) - def td_valves(self, valve_id: int, state: int, pos_name: int, pos_count: int, next_pos: int): + def td_valves(self, valve_id : int, + state : int, + currPosID : int, + currPos : int, + cmdPos : int, + posA : int, + posB : int, + posC : int, + posD : int, + maxHomingPos: int): """ Broadcasts the current TD Valves Data (Msg ID: 0x2B, 43) Args: @@ -285,9 +310,14 @@ payload = conversions.unsigned_integer_to_bytearray(valve_id ) payload += conversions.unsigned_integer_to_bytearray(state ) - payload += conversions.unsigned_integer_to_bytearray(pos_name ) - payload += conversions.short_to_bytearray (pos_count ) - payload += conversions.short_to_bytearray (next_pos ) + payload += conversions.unsigned_integer_to_bytearray(currPosID ) + payload += conversions.short_to_bytearray (currPos ) + payload += conversions.short_to_bytearray (cmdPos ) + payload += conversions.short_to_bytearray (posA ) + payload += conversions.short_to_bytearray (posB ) + payload += conversions.short_to_bytearray (posC ) + payload += conversions.short_to_bytearray (posD ) + payload += conversions.short_to_bytearray (maxHomingPos) message = CAN.CanMessage.build_message( channel_id=CAN.CanChannels.td_sync_broadcast_ch_id, @@ -296,21 +326,22 @@ self.can_interface.send(message, 0) - def td_voltage(self, line_1_2v: float, line_3_3v: float, line_logic_5v: float, - line_sensors_5v: float, line_24v: float, line_regen_24v: float, - fpga_adc_ref: float, res_ref: float, fpga_vcc: float, - fpga_vaux: float, fpga_vpvn: float): + def td_voltage(self, line_1_2v : float, + line_3_3v : float, + line_logic_5v : float, + line_24v_1 : float, + line_24v_2 : float, + fpga_vcc : float, + fpga_vaux : float, + fpga_vpvn : float): """ Broadcasts the current TD voltage data (Msg ID: 0x1D, 29) Args: @param line_1_2v (float): Processor 1.2V @param line_3_3v (float): Logic voltage (3.3V) @param line_logic_5v (float): Logic voltage (5V) - @param line_sensors_5v (float): Sensors voltage (5V) - @param line_24v (float): Actuators voltage (24V) - @param line_regen_24v (float): Actuators regen voltage (24V) - @param fpga_adc_ref (float): FPGA ADC reference voltage (1V) - @param res_ref (float): PBA ADC reference voltage (3V) + @param line_24v_1 (float): Actuators voltage (24V) + @param line_24v_2 (float): Actuators voltage (24V) @param fpga_vcc (float): FPGA input voltage (3V) @param fpga_vaux (float): FPGA aux. voltage (3V) @param fpga_vpvn (float): FPGA pvn voltage (1V) @@ -319,18 +350,16 @@ if not self.can_enabled: raise ValueError("CAN Interface is not enabled") - payload = conversions.float_to_bytearray(line_1_2v ) - payload += conversions.float_to_bytearray(line_3_3v ) - payload += conversions.float_to_bytearray(line_logic_5v ) - payload += conversions.float_to_bytearray(line_sensors_5v ) - payload += conversions.float_to_bytearray(line_24v ) - payload += conversions.float_to_bytearray(line_regen_24v ) - payload += conversions.float_to_bytearray(fpga_adc_ref ) - payload += conversions.float_to_bytearray(res_ref ) - payload += conversions.float_to_bytearray(fpga_vcc ) - payload += conversions.float_to_bytearray(fpga_vaux ) - payload += conversions.float_to_bytearray(fpga_vpvn ) + payload = conversions.float_to_bytearray(line_1_2v ) + payload += conversions.float_to_bytearray(line_3_3v ) + payload += conversions.float_to_bytearray(line_logic_5v ) + payload += conversions.float_to_bytearray(line_24v_1 ) + payload += conversions.float_to_bytearray(line_24v_2 ) + payload += conversions.float_to_bytearray(fpga_vcc ) + payload += conversions.float_to_bytearray(fpga_vaux ) + payload += conversions.float_to_bytearray(fpga_vpvn ) + message = CAN.CanMessage.build_message( channel_id=CAN.CanChannels.td_sync_broadcast_ch_id, message_id=msg_ids.MsgIds.MSG_ID_TD_VOLTAGES_DATA.value, @@ -580,8 +609,8 @@ payload = conversions.unsigned_integer_to_bytearray (valve ) payload += conversions.unsigned_integer_to_bytearray (timeout ) - message = CAN.DenaliMessage.build_message( - channel_id=CAN.DenaliChannels.td_sync_broadcast_ch_id, + message = CAN.CanMessage.build_message( + channel_id=CAN.CanChannels.td_sync_broadcast_ch_id, message_id=msg_ids.MsgIds.MSG_ID_TD_WATER_SAMPLE_DATA.value, payload=payload) self.can_interface.send(message, 0) @@ -600,8 +629,8 @@ payload += conversions.integer_to_bytearray (vRejectionReason) payload += conversions.float_to_bytearray (vValue ) - message = CAN.DenaliMessage.build_message( - channel_id=CAN.DenaliChannels.td_to_ui_ch_id, + message = CAN.CanMessage.build_message( + channel_id=CAN.CanChannels.td_to_ui_ch_id, message_id=msg_ids.MsgIds.MSG_ID_TD_WATER_SAMPLE_RESULT_RESPONSE.value, payload=payload) self.can_interface.send(message, 0) @@ -1472,6 +1501,43 @@ self.can_interface.send(message, 0) + + def td_power_off(self, vStatus: int): + """ + rinseback command response message (Msg ID: 0x91, 145) + Args: + @param vRejectionReason : (int) rejection reason + @return: None + """ + payload = conversions.unsigned_byte_to_bytearray(vStatus) + + message = CAN.CanMessage.build_message( + channel_id=CAN.CanChannels.td_to_ui_ch_id, + message_id=msg_ids.MsgIds.MSG_ID_TD_POWER_OFF_REQUEST.value, + payload=payload) + self.can_interface.send(message, 0) + + + def td_confirm(self, vID : int , + vCommand: int , + vReason : int ): + """ + rinseback command response message (Msg ID: 0x91, 145) + Args: + @param vRejectionReason : (int) rejection reason + @return: None + """ + payload = conversions.integer_to_bytearray(vID ) + payload += conversions.integer_to_bytearray(vCommand ) + payload += conversions.integer_to_bytearray(vReason ) + + message = CAN.CanMessage.build_message( + channel_id=CAN.CanChannels.td_to_ui_ch_id, + message_id=msg_ids.MsgIds.MSG_ID_TD_UI_CONFIRMATION_REQUEST.value, + payload=payload) + self.can_interface.send(message, 0) + + def td_isolated_uf_duration_change_response(self, vRejectionReason: int, vVolumeMax: int): """ the isolated uf duration change response message (msg id: 0x9C, 156) @@ -1587,8 +1653,8 @@ payload += conversions.integer_to_bytearray(vVenousAsymmetricRejectReason ) payload += conversions.integer_to_bytearray(vTmpWindowRejectReason ) - message = CAN.DenaliMessage.build_message( - channel_id=CAN.DenaliChannels.td_to_ui_ch_id, + message = CAN.CanMessage.build_message( + channel_id=CAN.CanChannels.td_to_ui_ch_id, message_id=msg_ids.MsgIds.MSG_ID_TD_PRESSURE_LIMITS_CHANGE_RESPONSE.value, payload=payload) self.can_interface.send(message, 0) @@ -1623,8 +1689,8 @@ payload += conversions.integer_to_bytearray(vSodiumRejectReason ) payload += conversions.integer_to_bytearray(vBicarbonateRejectReason ) - message = CAN.DenaliMessage.build_message( - channel_id=CAN.DenaliChannels.td_to_ui_ch_id, + message = CAN.CanMessage.build_message( + channel_id=CAN.CanChannels.td_to_ui_ch_id, message_id=msg_ids.MsgIds.MSG_ID_TD_TREATMENT_SET_POINTS_CHANGE_RESPONSE.value, payload=payload) self.can_interface.send(message, 0) @@ -1640,8 +1706,8 @@ payload = conversions.integer_to_bytearray(vAccepted) payload += conversions.integer_to_bytearray(vRejectionReason) - message = CAN.DenaliMessage.build_message( - channel_id=CAN.DenaliChannels.td_to_ui_ch_id, + message = CAN.CanMessage.build_message( + channel_id=CAN.CanChannels.td_to_ui_ch_id, message_id=msg_ids.MsgIds.MSG_ID_TD_ADJUST_PATIENT_DISCONNECT_CONFIRM_RESPONSE.value, payload=payload) self.can_interface.send(message, 0) @@ -1803,8 +1869,8 @@ payload += conversions.float_to_bytearray( vIsoUfRateTarget ) payload += conversions.float_to_bytearray( vWaterSampleTestResult ) - message = CAN.DenaliMessage.build_message( - channel_id=CAN.DenaliChannels.td_to_ui_ch_id, + message = CAN.CanMessage.build_message( + channel_id=CAN.CanChannels.td_to_ui_ch_id, message_id=msg_ids.MsgIds.MSG_ID_TD_ADJUST_TREATMENT_LOGS_RESPONSE.value, payload=payload) self.can_interface.send(message, 0)