Merge branch 'эмс-тг'

scripts/network.gd

@@ -1,7 +1,7 @@
 @tool
 class_name Network extends Node
 
-const YAU07_PROTO: = {'yau07tx': yau07.YaU07}
+const YAU07_PROTO: = {'yau07tx': yau07.YaU07, 'iyems-tx': yemstg.YeMSTG}
 const UDP_PROTO: = {'capsrpb': capsrpb.CapsRpb, 'trassa': trassa.Trassa}
 const TCP_PROTO: = {'5p28': tcp5p28.TCP5P28}
 const SERIAL_PROTO: = {'spt25': spt25.SPT25}
@@ -146,12 +146,15 @@ func create_socket_udp(unit_name: StringName) -> SocketUDP:
     var bind = st[3]
     var sock: = SocketUDP.new()
     sock.set_broadcast_enabled(broad)
-    var rc: = sock.bind(port, addr)
-    if rc == Error.OK:
-        log.info('\"%s\" привязан к %s:%d' % [unit_name, addr, port])
-    else:
-        var errmsg: = error_string(rc)
-        log.error('привязка \"%s\" к %s:%d не удалась: \"%s\"' % [unit_name, addr, port, errmsg])
+    if broad:
+        log.info('\"%s\" - установлен широковещательный режим' % unit_name)
+    if bind:
+        var rc: = sock.bind(port, addr)
+        if rc == Error.OK:
+            log.info('\"%s\" привязан к %s:%d' % [unit_name, addr, port])
+        else:
+            var errmsg: = error_string(rc)
+            log.error('привязка \"%s\" к %s:%d не удалась: \"%s\"' % [unit_name, addr, port, errmsg])
     return sock
 
 
@@ -197,7 +200,8 @@ func _ready() -> void:
     var sock_navi: = create_socket_udp('навигация')
     var sock_caps: = create_socket_caps('уарэп-капсрпб')
     var sock_trassa: = create_socket_caps('уарэп-трасса')
-    poll_sockets = [sock_unicast, sock_broadcast, sock_caps, sock_navi, sock_trassa]
+    var sock_yems: = create_socket_udp('эмс-ведущий')
+    poll_sockets = [sock_unicast, sock_broadcast, sock_caps, sock_navi, sock_trassa, sock_yems]
     send_sockets['уарэп-яу07-частный'] = sock_unicast
     send_sockets['уарэп-яу07-общий'] = sock_broadcast
     send_sockets['уарэп-капсрпб'] = sock_caps
@@ -215,6 +219,14 @@ func _ready() -> void:
     send_sockets['уарэп-яу07-3в'] = sock_unicast
     send_sockets['уарэп-яу07-3н'] = sock_unicast
     send_sockets['уарэп-яу07-3к'] = sock_unicast
+    send_sockets['эмс-ор63'] = sock_yems
+    send_sockets['эмс-454'] = sock_yems
+    send_sockets['эмс-го'] = sock_yems
+    send_sockets['эмс-рлс1'] = sock_yems
+    send_sockets['эмс-рлс2'] = sock_yems
+    send_sockets['эмс-ннвс'] = sock_yems
+    send_sockets['эмс-изделие7'] = sock_yems
+    send_sockets['эмс-изделие8'] = sock_yems
 
     var bind_serials: = []
     var bind_modbuses: = []
@@ -343,6 +355,7 @@ func _process(_delta: float) -> void:
     poll_sockets.any(poll_receive_udp)
 
 
+## Возвращает экземпляр уже созданного устройства
 ## [param unit_name] - Уникальное имя устройства[br]
 func get_unit_instance(unit_name: StringName) -> unit.Unit:
     return units.get(unit_name, null)

scripts/settings.gd

@@ -6,7 +6,8 @@ class_name uarep_settings extends Node
 var settings_program: Dictionary
 
 var UnitProfiles: Dictionary[StringName, Array] = { \
-    # < Название: Протокол, Адрес, <Порт>|[, Порт], Широковещательное, Привязывать, Комментарий >
+    # < Название: [Протокол, [Параметры], Комментарий] >
+    # < Название: Протокол, [Адрес, <Порт>|[, Порт], Широковещательное, Привязывать], Комментарий >
     'уарэп-яу07-частный': ['yau07rx', ['10.1.1.2', 50002, false, true], 'IP-адрес для приёма частных сообщений от ЯУ-07'],
     'уарэп-яу07-общий': ['yau07rx', ['*', 50000, true, true], 'IP-адрес для приёма широковещательных сообщений от ЯУ-07'],
     'уарэп-капсрпб': ['capsrpb', ['127.0.0.1', '127.0.0.1', 42023, 42022, false, true], 'IP-адрес для обмена сообщениями со службой \"МП550\" (СТЦ)'],
@@ -26,6 +27,17 @@ var UnitProfiles: Dictionary[StringName, Array] = { \
     'уарэп-яу07-3к': ['yau07tx', ['10.1.1.33', 50033, false, false], 'IP-адрес прибора ПРД-К3'],
     'навигация': ['navi', ['*', 60000, true, true ], 'IP-адрес на котором принимают сообщения от навигации'],
 
+    # < Название: [протокол, [адрес, порт, широковещательное, привязывать], комментарий >
+    'эмс-ведущий': ['iyems-rx', ['127.0.0.1', 61000, false, true], 'IP-адрес для приёма докладов от информационных ЭМС устройств'],
+    'эмс-ор63': ['iyems-tx', ['127.0.0.1', 61001, false, false], 'IP-адрес для передачи команд информационному ЭМС устройству'],
+    'эмс-454': ['iyems-tx', ['127.0.0.1', 61002, false, false], 'IP-адрес для передачи команд информационному ЭМС устройству'],
+    'эмс-го': ['iyems-tx', ['127.0.0.1', 61003, false, false], 'IP-адрес для передачи команд информационному ЭМС устройству'],
+    'эмс-рлс1': ['iyems-tx', ['127.0.0.1', 61004, false, false], 'IP-адрес для передачи команд информационному ЭМС устройству'],
+    'эмс-рлс2': ['iyems-tx', ['127.0.0.1', 61005, false, false], 'IP-адрес для передачи команд информационному ЭМС устройству'],
+    'эмс-ннвс': ['iyems-tx', ['127.0.0.1', 61006, false, false], 'IP-адрес для передачи команд информационному ЭМС устройству'],
+    'эмс-изделие7': ['iyems-tx', ['127.0.0.1', 61007, false, false], 'IP-адрес для передачи команд информационному ЭМС устройству'],
+    'эмс-изделие8': ['iyems-tx', ['127.0.0.1', 61008, false, false], 'IP-адрес для передачи команд информационному ЭМС устройству'],
+
     # < Название: Протокол, < Адрес, Порт получения >, Комментарий >
     'уарэп-5п28': ['5p28', ['127.0.0.1', 50000], 'IP-адрес комплекса 5П-28'],
 

scripts/tools.gd

@@ -156,7 +156,8 @@ func map_dec_to_rad(pos0: Vector2, pos: Vector2) -> Vector2:
 ## [param p] - Координаты вершин полигона.[br]
 func is_point_in_polygon(pos: Vector2, p: PackedVector2Array) -> bool:
     var sz: = p.size()
-    assert(sz)
+    if not sz:
+        return false
     var j: int = sz - 1
     var odd_nodes: int = 0
     for i in sz:

scripts/unit.gd

@@ -25,6 +25,6 @@ class Unit extends Object:
     var rx_tick: int = 0                  ## Тик-время последнего приёма данных
     var online: bool = false              ## Состояние подключения устройства
     var name: StringName = '<без имени>'  ## Уникальное имя устройства
-    func _init(nm) -> void: self.name = nm
+    func _init(nm: StringName) -> void: self.name = nm
     func _to_string() -> String:
         return String('Unit(\"%s\", %s)' % [self.name, 'на связи' if online else 'отключен'])

scripts/yemstg.gd

@@ -0,0 +1,38 @@
+extends Node
+
+
+class YeMSTG extends unit.Unit:
+    static var json_conv: = JSON.new()
+    var online_timeout: float = 5000  ## Должен быть равен наибольшему времени дотоверности из всех кластеров
+    var info: = Dictionary()  ## Доклад о состоянии
+    var cmd: = Dictionary()   ## Команда
+    var cnt: int = 0  ## Счётчик отправленных пакетов
+
+    func _init(unit_name) -> void:
+        super._init(unit_name)
+        cmd_state = CmdState.DONE
+
+    func parse(data: PackedByteArray, now_tick: int):
+        self.rx_tick = now_tick
+        if not online:
+            online = true
+            emit_signal('line_changed', self)
+        var utf8_data: = data.get_string_from_utf8()
+        if Error.OK == json_conv.parse(utf8_data):
+            info.merge(json_conv.get_data(), true)
+            emit_signal('data_received', info)
+        else:
+            var msg: = json_conv.get_error_message()
+            emit_signal('parse_error', self, msg)
+
+    func process(now_tick: int):
+        if online and ((now_tick - rx_tick) > online_timeout):
+            online = false
+            emit_signal('line_changed', self)
+        var rc = Error.ERR_BUSY
+        if cmd_state == CmdState.SEND:
+            tx_data = JSON.stringify(cmd).to_utf8_buffer()
+            tx_len = tx_data.size()
+            cmd_state = CmdState.DONE
+            rc = Error.OK
+        return rc

scripts/yemstg.gd.uid

@@ -0,0 +1 @@
+uid://bst5wk3otwwai