Index: dialin/common/dg_defs.py =================================================================== diff -u -r0e68ec6bb733a8ab7b21a82f8b571f1678f9d2cd -r220295a464eca249a5b396aac4b503623936afea --- dialin/common/dg_defs.py (.../dg_defs.py) (revision 0e68ec6bb733a8ab7b21a82f8b571f1678f9d2cd) +++ dialin/common/dg_defs.py (.../dg_defs.py) (revision 220295a464eca249a5b396aac4b503623936afea) @@ -225,29 +225,33 @@ DG_CHEM_DISINFECT_STATE_COMPLETE = 14 NUM_OF_DG_CHEM_DISINFECT_STATES = 15 + @unique class DGChemDisinfectFlushStates(DialinEnum): - DG_CHEM_DISINFECT_FLUSH_STATE_START = 0 - DG_CHEM_DISINFECT_FLUSH_STATE_DISINFECTANT_DRAIN_R1 = 1 - DG_CHEM_DISINFECT_FLUSH_STATE_DISINFECTANT_DRAIN_R2 = 2 + DG_CHEM_DISINFECT_FLUSH_STATE_DRAIN_R1 = 1 + DG_CHEM_DISINFECT_FLUSH_STATE_DRAIN_R2 = 2 DG_CHEM_DISINFECT_FLUSH_STATE_FLUSH_DRAIN = 3 DG_CHEM_DISINFECT_FLUSH_STATE_FLUSH_DISINFECTANT_LINE = 4 DG_CHEM_DISINFECT_FLUSH_STATE_FLUSH_UF = 5 DG_CHEM_DISINFECT_FLUSH_STATE_FLUSH_R2_TO_R1_DRAIN_R1 = 6 - DG_CHEM_DISINFECT_FLUSH_STATE_FLUSH_R1_TO_R2_DRAIN_R2 = 7 - DG_CHEM_DISINFECT_FLUSH_STATE_CANCEL_BASIC_PATH = 8 - DG_CHEM_DISINFECT_FLUSH_STATE_CANCEL_WATER_PATH = 9 - DG_CHEM_DISINFECT_FLUSH_STATE_COMPLETE = 10 - NUM_OF_DG_CHEM_DISINFECT_FLUSH_STATES = 11 + DG_CHEM_DISINFECT_FLUSH_STATE_FLUSH_R1_TO_R2_DRAIN_R2 =7 + DG_CHEM_DISINFECT_FLUSH_STATE_SAMPLE_FLUSH_R1_TO_R2_DRAIN_R2 = 8 + DG_CHEM_DISINFECT_FLUSH_STATE_CANCEL_BASIC_PATH = 9 + DG_CHEM_DISINFECT_FLUSH_STATE_CANCEL_WATER_PATH = 10 + DG_CHEM_DISINFECT_FLUSH_STATE_COMPLETE = 11 + NUM_OF_DG_CHEM_DISINFECT_FLUSH_STATES = 12 + @unique class DGChemDisinfectFlushUIStates(DialinEnum): CHEM_DISINFECT_FLUSH_UI_STATE_NOT_RUNNING = 0 CHEM_DISINFECT_FLUSH_UI_STATE_FLUSH_AFTER_DISINFECT = 1 CHEM_DISINFECT_FLUSH_UI_STATE_CANCEL_FLUSH = 2 CHEM_DISINFECT_FLUSH_UI_STATE_COMPLETE = 3 NUM_OF_CHEM_DISINFECT_FLUSH_UI_STATES = 4 + + @unique class DGChemDisinfectUIStates(DialinEnum): CHEM_DISINFECT_UI_STATE_NOT_RUNNING = 0 Index: dialin/dg/chemical_disinfect.py =================================================================== diff -u -racd09d02879e8add4cf7f694f5db8e423a76c341 -r220295a464eca249a5b396aac4b503623936afea --- dialin/dg/chemical_disinfect.py (.../chemical_disinfect.py) (revision acd09d02879e8add4cf7f694f5db8e423a76c341) +++ dialin/dg/chemical_disinfect.py (.../chemical_disinfect.py) (revision 220295a464eca249a5b396aac4b503623936afea) @@ -49,8 +49,6 @@ self.cancellation_mode = 0 self.r1_level = 0 self.r2_level = 0 - self.target_post_rinse_count = 0 - self.current_post_rinse_count = 0 self.chemical_disinfect_ui_state = 0 if self.can_interface is not None: @@ -79,8 +77,6 @@ self.cancellation_mode = 0 self.r1_level = 0 self.r2_level = 0 - self.target_post_rinse_count = 0 - self.current_post_rinse_count = 0 self.chemical_disinfect_ui_state = 0 @publish(["chemical_disinfect_elapsed_time", "chemical_disinfect_target_time"]) @@ -100,8 +96,7 @@ self.chemical_disinfect_elapsed_time = int(disinfect_elapsed_time / 1000) @publish(["chemical_disinfect_state", "overall_elapsed_time", "state_elapsed_time", "cancellation_mode", - "r1_level", "r2_level", "target_post_rinse_count", "current_post_rinse_count", - "chemical_disinfect_ui_state"]) + "r1_level", "r2_level", "chemical_disinfect_ui_state"]) def _handler_chemical_disinfect_sync(self, message): """ Handles published chemical disinfect message @@ -121,19 +116,13 @@ message['message'][MsgFieldPositions.START_POS_FIELD_5:MsgFieldPositions.END_POS_FIELD_5]))[0] r2 = struct.unpack('f', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_6:MsgFieldPositions.END_POS_FIELD_6]))[0] - target_post_rinse_cnt = struct.unpack('i', bytearray( - message['message'][MsgFieldPositions.START_POS_FIELD_7:MsgFieldPositions.END_POS_FIELD_7]))[0] - current_post_rinse_cnt = struct.unpack('i', bytearray( - message['message'][MsgFieldPositions.START_POS_FIELD_8:MsgFieldPositions.END_POS_FIELD_8]))[0] chem_ui_state = struct.unpack('i', bytearray( - message['message'][MsgFieldPositions.START_POS_FIELD_9:MsgFieldPositions.END_POS_FIELD_9]))[0] + message['message'][MsgFieldPositions.START_POS_FIELD_7:MsgFieldPositions.END_POS_FIELD_7]))[0] self.chemical_disinfect_state = state self.overall_elapsed_time = int(elapsed_time / 1000) self.state_elapsed_time = int(state_elapsed_time / 1000) self.cancellation_mode = cancellation_mode self.r1_level = r1 self.r2_level = r2 - self.target_post_rinse_count = target_post_rinse_cnt - self.current_post_rinse_count = current_post_rinse_cnt self.chemical_disinfect_ui_state = chem_ui_state Index: dialin/dg/chemical_disinfect_flush.py =================================================================== diff -u -racd09d02879e8add4cf7f694f5db8e423a76c341 -r220295a464eca249a5b396aac4b503623936afea --- dialin/dg/chemical_disinfect_flush.py (.../chemical_disinfect_flush.py) (revision acd09d02879e8add4cf7f694f5db8e423a76c341) +++ dialin/dg/chemical_disinfect_flush.py (.../chemical_disinfect_flush.py) (revision 220295a464eca249a5b396aac4b503623936afea) @@ -37,9 +37,6 @@ self.flush_state = DGChemDisinfectFlushStates.DG_CHEM_DISINFECT_FLUSH_STATE_START.value self.overall_elapsed_time = 0 self.state_elapsed_time = 0 - self.r1 = 0.0 - self.r2 = 0.0 - self.target_rinse_count = 0 self.rinse_count = 0 self.flush_UI_state = DGChemDisinfectFlushUIStates.CHEM_DISINFECT_FLUSH_UI_STATE_NOT_RUNNING.value @@ -77,25 +74,14 @@ message['message'][MsgFieldPositions.START_POS_FIELD_3:MsgFieldPositions.END_POS_FIELD_3]))[0] cancellation_mode = struct.unpack('i', bytearray( message['message'][MsgFieldPositions.START_POS_FIELD_4:MsgFieldPositions.END_POS_FIELD_4]))[0] - r1 = struct.unpack('f', bytearray( - message['message'][MsgFieldPositions.START_POS_FIELD_5:MsgFieldPositions.END_POS_FIELD_5]))[0] - r2 = struct.unpack('f', bytearray( - message['message'][MsgFieldPositions.START_POS_FIELD_6:MsgFieldPositions.END_POS_FIELD_6]))[0] - target_rinse_count = struct.unpack('