Добавлен результат проверки РТР в панель исправности комплекса

scenes/tabs-switch/lbl_ready.gd

@@ -12,6 +12,13 @@ enum DEVICE_STATUS {
     CONTROL      # Контроль завершен
 }
 
+# Состояния сервиса для RTR устройств
+enum RTR_SERVICEABILITY {
+    NO_CONNECTION = 0,  # Нет связи
+    PASSED = 1,         # Все тесты пройдены
+    ERROR = 2           # Есть ошибки
+}
+
 const STATUS_CONFIG := {
     DEVICE_STATE.NONE: {'text': 'Нет связи', 'color': Color.WHITE, 'font_color': Color.BLACK},
     DEVICE_STATE.GOOD: {'text': 'Исправно', 'color': Color.GREEN, 'font_color': Color.BLACK},
@@ -22,6 +29,9 @@ class DeviceObserver:
     var device_name: String
     var status: Array = [false, false, false]  # [online, operational, control_complete]
     var last_results: Dictionary = {}
+    
+    # Для RTR устройств
+    var rtr_serviceability: int = RTR_SERVICEABILITY.NO_CONNECTION
 
     func update_online_state(online: bool) -> bool:
         if status[DEVICE_STATUS.ONLINE] != online:
@@ -55,11 +65,28 @@ class DeviceObserver:
                 status[DEVICE_STATUS.CONTROL] = false
                 changed = true
         return changed
+    
+    func update_rtr_serviceability(state: int) -> bool:
+        if rtr_serviceability != state:
+            rtr_serviceability = state
+            # Обновляем operational статус на основе RTR
+            var new_operational = (state == RTR_SERVICEABILITY.PASSED)
+            if status[DEVICE_STATUS.STATUS] != new_operational:
+                status[DEVICE_STATUS.STATUS] = new_operational
+                return true
+        return false
 
 var device_observers: Dictionary = {}
 var overall_prd_state: DEVICE_STATE = DEVICE_STATE.NONE
 var status_uf: int = DEVICE_STATE.NONE  # Статус УФ (УАРЭП-ЭМС)
 
+# Добавляем наблюдателей для RTR устройств
+var rtr_device_names := [
+    'rtr_afsp_left',
+    'rtr_afsp_right',
+    'rtr_bpo'  # Общий для левого и правого БПО
+]
+
 func _ready() -> void:
     tooltip_text = 'Нет связи с приборами комплекса'
     add_theme_color_override('font_color', Color.BLACK)
@@ -78,11 +105,20 @@ func _ready() -> void:
 
     # Подписка на УФ
     signaller.connect('update_uf_serviceability', _on_uf_status_receive)
+    
+    # Подписка на сигналы RTR (через signaller или напрямую)
+    _connect_rtr_signals()
 
     # Инициализация начального состояния
     _recalculate_overall_state()
 
 
+func _connect_rtr_signals() -> void:
+    scouting.connect('serviceability_rtr_afsp_left', Callable(self, '_on_rtr_afsp_left_serviceability'))
+    scouting.connect('serviceability_rtr_afsp_right', Callable(self, '_on_rtr_afsp_right_serviceability'))
+    scouting.connect('serviceability_rtr_bpo', Callable(self, '_on_rtr_bpo_serviceability'))
+    
+
 func _initialize_observers() -> void:
     var device_names := [
         'уарэп-яу07-1н', 'уарэп-яу07-1в', 'уарэп-яу07-1к',
@@ -94,6 +130,69 @@ func _initialize_observers() -> void:
     for device_name in device_names:
         device_observers[device_name] = DeviceObserver.new()
         device_observers[device_name].device_name = device_name
+    
+    # Инициализируем наблюдателей для RTR устройств
+    for rtr_name in rtr_device_names:
+        device_observers[rtr_name] = DeviceObserver.new()
+        device_observers[rtr_name].device_name = rtr_name
+
+
+# Обработчики сигналов RTR
+func _on_rtr_afsp_left_serviceability(state: int) -> void:
+    var observer: DeviceObserver = device_observers.get('rtr_afsp_left')
+    if not observer:
+        return
+    
+    var changed = false
+    if observer.update_rtr_serviceability(state):
+        changed = true
+    
+    var is_online = (state != RTR_SERVICEABILITY.NO_CONNECTION)
+    if observer.update_online_state(is_online):
+        changed = true
+    
+    if changed:
+        _recalculate_overall_state()
+    else:
+        _update_display()
+
+
+func _on_rtr_afsp_right_serviceability(state: int) -> void:
+    var observer: DeviceObserver = device_observers.get('rtr_afsp_right')
+    if not observer:
+        return
+    
+    var changed = false
+    if observer.update_rtr_serviceability(state):
+        changed = true
+    
+    var is_online = (state != RTR_SERVICEABILITY.NO_CONNECTION)
+    if observer.update_online_state(is_online):
+        changed = true
+    
+    if changed:
+        _recalculate_overall_state()
+    else:
+        _update_display()
+
+
+func _on_rtr_bpo_serviceability(state: int) -> void:
+    var observer: DeviceObserver = device_observers.get('rtr_bpo')
+    if not observer:
+        return
+    
+    var changed = false
+    if observer.update_rtr_serviceability(state):
+        changed = true
+    
+    var is_online = (state != RTR_SERVICEABILITY.NO_CONNECTION)
+    if observer.update_online_state(is_online):
+        changed = true
+    
+    if changed:
+        _recalculate_overall_state()
+    else:
+        _update_display()
 
 
 func _on_prd_online_changed(line_status: Object, prd_module: Object) -> void:
@@ -123,7 +222,12 @@ func _recalculate_overall_state() -> void:
     var has_online_prd := false
     var all_prd_operational := true
 
-    for observer in device_observers.values():
+    for observer_key in device_observers.keys():
+        # Пропускаем RTR устройства при подсчете ПРД
+        if observer_key.begins_with('rtr_'):
+            continue
+            
+        var observer = device_observers[observer_key]
         if observer.status[DEVICE_STATUS.ONLINE]:
             has_online_prd = true
 
@@ -142,15 +246,35 @@ func _recalculate_overall_state() -> void:
             prd_state = DEVICE_STATE.ERR
     else:
         prd_state = DEVICE_STATE.NONE
+    
+    # Проверяем статус RTR устройств
+    var rtr_state := DEVICE_STATE.NONE
+    var has_online_rtr := false
+    var all_rtr_operational := true
+    
+    for rtr_name in rtr_device_names:
+        var observer = device_observers.get(rtr_name)
+        if observer and observer.status[DEVICE_STATUS.ONLINE]:
+            has_online_rtr = true
+            if not observer.status[DEVICE_STATUS.STATUS]:
+                all_rtr_operational = false
+    
+    if has_online_rtr:
+        if all_rtr_operational:
+            rtr_state = DEVICE_STATE.GOOD
+        else:
+            rtr_state = DEVICE_STATE.ERR
+    else:
+        rtr_state = DEVICE_STATE.NONE
 
     # Комбинируем статусы по правилу:
     # 1. Если хоть один ERROR → ERROR
     # 2. Если нет ERROR и хоть один GOOD → GOOD
     # 3. Иначе → NONE
 
-    if prd_state == DEVICE_STATE.ERR or status_uf == DEVICE_STATE.ERR:
+    if prd_state == DEVICE_STATE.ERR or status_uf == DEVICE_STATE.ERR or rtr_state == DEVICE_STATE.ERR:
         new_state = DEVICE_STATE.ERR
-    elif prd_state == DEVICE_STATE.GOOD or status_uf == DEVICE_STATE.GOOD:
+    elif prd_state == DEVICE_STATE.GOOD or status_uf == DEVICE_STATE.GOOD or rtr_state == DEVICE_STATE.GOOD:
         new_state = DEVICE_STATE.GOOD
     else:
         new_state = DEVICE_STATE.NONE
@@ -174,6 +298,7 @@ func _get_tooltip_text() -> String:
     # Получаем статистику по ПРД
     var prd_summary = _get_prd_summary()
     var uf_status_str = _get_uf_status_text()
+    var rtr_summary = _get_rtr_summary()
 
     match overall_prd_state:
         DEVICE_STATE.NONE:
@@ -185,6 +310,7 @@ func _get_tooltip_text() -> String:
 
     tooltip += '\n\nСтатус ПРД систем: ' + prd_summary
     tooltip += '\nСтатус УФ: ' + uf_status_str
+    tooltip += '\nСтатус RTR: ' + rtr_summary
 
     # Детализация по источникам статуса
     tooltip += '\n\nСостояние систем:'
@@ -192,7 +318,10 @@ func _get_tooltip_text() -> String:
     # ПРД системы
     var prd_ok_count = 0
     var prd_total = 0
-    for observer in device_observers.values():
+    for observer_key in device_observers.keys():
+        if observer_key.begins_with('rtr_'):
+            continue
+        var observer = device_observers[observer_key]
         if observer.status[DEVICE_STATUS.ONLINE]:
             prd_total += 1
             if observer.status[DEVICE_STATUS.STATUS]:
@@ -202,15 +331,67 @@ func _get_tooltip_text() -> String:
 
     # УФ система
     tooltip += '\nУФ: ' + _get_uf_status_text()
-
+    
+    # RTR системы
+    tooltip += '\nRTR:'
+    for rtr_name in rtr_device_names:
+        var observer = device_observers.get(rtr_name)
+        if observer:
+            var status_text = _get_rtr_status_text(observer.rtr_serviceability)
+            var display_name = _get_rtr_display_name(rtr_name)
+            tooltip += '\n  - %s: %s' % [display_name, status_text]
     return tooltip
 
 
+func _get_rtr_summary() -> String:
+    var online_count := 0
+    var operational_count := 0
+    
+    for rtr_name in rtr_device_names:
+        var observer = device_observers.get(rtr_name)
+        if observer and observer.status[DEVICE_STATUS.ONLINE]:
+            online_count += 1
+            if observer.status[DEVICE_STATUS.STATUS]:
+                operational_count += 1
+    
+    if online_count == 0:
+        return 'Нет связи'
+    else:
+        return '%d/%d исправно' % [operational_count, online_count]
+
+
+func _get_rtr_status_text(state: int) -> String:
+    match state:
+        RTR_SERVICEABILITY.NO_CONNECTION:
+            return 'Нет связи'
+        RTR_SERVICEABILITY.PASSED:
+            return 'Исправен'
+        RTR_SERVICEABILITY.ERROR:
+            return 'Ошибка'
+        _:
+            return 'Неизвестно'
+
+
+func _get_rtr_display_name(rtr_key: String) -> String:
+    match rtr_key:
+        'rtr_afsp_left':
+            return 'АФСП Л'
+        'rtr_afsp_right':
+            return 'АФСП П'
+        'rtr_bpo':
+            return 'РТР'
+        _:
+            return rtr_key.replace('rtr_', '')
+
+
 func _get_prd_summary() -> String:
     var online_count := 0
     var operational_count := 0
 
-    for observer in device_observers.values():
+    for observer_key in device_observers.keys():
+        if observer_key.begins_with('rtr_'):
+            continue
+        var observer = device_observers[observer_key]
         if observer.status[DEVICE_STATUS.ONLINE]:
             online_count += 1
             if observer.status[DEVICE_STATUS.STATUS]:
@@ -235,14 +416,20 @@ func _get_uf_status_text() -> String:
 
 
 func _has_prd_errors() -> bool:
-    for observer in device_observers.values():
+    for observer_key in device_observers.keys():
+        if observer_key.begins_with('rtr_'):
+            continue
+        var observer = device_observers[observer_key]
         if observer.status[DEVICE_STATUS.ONLINE] and not observer.status[DEVICE_STATUS.STATUS]:
             return true
     return false
 
 
 func _has_operational_prd() -> bool:
-    for observer in device_observers.values():
+    for observer_key in device_observers.keys():
+        if observer_key.begins_with('rtr_'):
+            continue
+        var observer = device_observers[observer_key]
         if observer.status[DEVICE_STATUS.ONLINE] and observer.status[DEVICE_STATUS.STATUS]:
             return true
     return false
@@ -257,7 +444,8 @@ func get_device_status(device_name: String) -> Dictionary:
             'operational': observer.status[DEVICE_STATUS.STATUS],
             'control_complete': observer.status[DEVICE_STATUS.CONTROL],
             'last_results': observer.last_results.duplicate(),
-            'status_uf': status_uf
+            'status_uf': status_uf,
+            'rtr_serviceability': observer.rtr_serviceability if device_name.begins_with('rtr_') else -1
         }
     return {}
 
@@ -267,7 +455,10 @@ func get_overall_status() -> Dictionary:
     var operational_count := 0
     var control_complete_count := 0
 
-    for observer in device_observers.values():
+    for observer_key in device_observers.keys():
+        if observer_key.begins_with('rtr_'):
+            continue
+        var observer = device_observers[observer_key]
         if observer.status[DEVICE_STATUS.ONLINE]:
             online_count += 1
             if observer.status[DEVICE_STATUS.STATUS]:
@@ -279,7 +470,8 @@ func get_overall_status() -> Dictionary:
         'overall_state': overall_prd_state,
         'online_devices': online_count,
         'operational_devices': operational_count,
-        'total_devices': device_observers.size(),
+        'total_devices': device_observers.size() - len(rtr_device_names),  # Исключаем RTR
         'control_complete_devices': control_complete_count,
-        'uf_status': status_uf
+        'uf_status': status_uf,
+        'rtr_status': _get_rtr_summary()
     }

scripts/pribor-prd.gd

@@ -445,12 +445,11 @@ func _handle_fs_work_state() -> void:
             (current_litera == 6 and control_results.fs_6) or \
             (current_litera == 7 and control_results.fs_7) or \
             (current_litera == 1 and control_results.fs_1):
-                if not block_kasseta_y5_config['yau07']:
-                    _set_status('Ожидание данных от ЯУ-07...')
-                    return  # НЕ переходим дальше пока нет данных от сервиса МП550
-
                 if flags.only_fs:
                     state = STATE_MACHINE.IN_EMS_STOP
+                elif not block_kasseta_y5_config['yau07']:
+                    _set_status('Ожидание данных от МП550 сервиса...')
+                    return
                 else:
                     state = STATE_MACHINE.UG_SET_RAY_5 if current_litera == 1 else STATE_MACHINE.UG_SET_RAY_CTRL
 
@@ -470,7 +469,7 @@ func _handle_check_kasseta_state() -> void:
             _set_status('Перегрев УМ')
             state = STATE_MACHINE.IN_EMS_STOP
     else:
-        flags.flag_only_fs = true
+        flags.only_fs = true
         _set_status('Касета У5: ERROR, Проверка ФС.')
         state = STATE_MACHINE.FS_TURN_ON
 
@@ -554,8 +553,7 @@ func _handle_ray_read_mode() -> void:
 
 ## Обработка записи состояния луча
 func _handle_ray_write_mode(ray_num: int) -> void:
-    if not _can_write_ray():
-        return
+    if not _can_write_ray():    return
 
     if (ray_num == 6 or ray_num == 5) and not control_timer.is_stopped():
         control_timer.stop()
@@ -1057,9 +1055,9 @@ static func check_block_kasseta_y5(status_prd: PackedByteArray, y5_config: Dicti
     y5_config.yau07 = not flag_not_trust
     if y5_config.yau07:
         y5_config.ems = (status_prd[0] & 1) and ((status_prd[0] >> 4) & 1)
-        y5_config.ug = (status_prd[0] >> 1) & 1
-        y5_config.ukp1 = (status_prd[0] >> 2) & 1
-        y5_config.ukp2 = (status_prd[0] >> 3) & 1
+        y5_config.ug = (status_prd[0] >> 1) & 1 != 0
+        y5_config.ukp1 = (status_prd[0] >> 2) & 1 != 0
+        y5_config.ukp2 = (status_prd[0] >> 3) & 1 != 0
     return y5_config
 
 

scripts/rtr.gd

@@ -233,7 +233,7 @@ func _on_request_completed(result: int, response_code: int, _headers: PackedStri
         _on_request_finished()
     else:
         var error_msg = 'HTTP ошибка %d: %s' % [response_code, get_result_string(result)]
-        print_debug(error_msg)
+        log.message(Logger.ERROR, error_msg)
         _save_error(error_msg)
         
         _update_online_status(device_str, side_str, false)
@@ -290,7 +290,7 @@ func _emit_afsp_serviceability_signal(side: String, state: int) -> void:
 func _check_all_tests_passed(response_text: String) -> bool:
     var json = JSON.new()
     if json.parse(response_text) != OK:
-        print('[rtr] Ошибка парсинга JSON')
+        log.message(Logger.ERROR, '[rtr] Ошибка парсинга JSON')
         return false
     
     var data = json.data
@@ -322,7 +322,7 @@ func _check_system_passed(system: Dictionary) -> bool:
             var dev_name = dev.get('DevName', 'Неизвестное устройство')
             var dev_id = dev.get('DevId', '?')
             var error_text = dev.get('ErrorText', 'Нет описания ошибки')
-            print('[rtr] НАЙДЕНА ОШИБКА! Устройство: %s (ID: %s). TestPassed: false. Причина: %s' % [dev_name, dev_id, error_text])
+            print_debug('[rtr] НАЙДЕНА ОШИБКА! Устройство: %s (ID: %s). TestPassed: false. Причина: %s' % [dev_name, dev_id, error_text])
     
     # Рекурсивно проверяем вложенные подсистемы
     var sub_systems = system.get('SystemList', [])
@@ -388,7 +388,7 @@ func _request_next(next_state: State) -> void:
             return
     
     if current_url.is_empty():
-        print('URL не задан для ', current_state)
+        push_error('URL не задан для ', current_state)
         var error_msg = 'URL не задан'
         _save_error(error_msg)
         
@@ -422,7 +422,7 @@ func _request_next(next_state: State) -> void:
     timeout_timer.start(timeout)
     var error = http_request.request(current_url)
     if error != OK:
-        print('Ошибка запроса: ', error_string(error))
+        log.message(Logger.ERROR, 'Ошибка запроса: %s' & error)
         var error_msg = 'Ошибка запроса: ' + error_string(error)
         _save_error(error_msg)