|
|
@@ -72,7 +72,8 @@ class SRIConnection(asyncio.Protocol):
|
|
|
"""
|
|
|
关闭连接
|
|
|
"""
|
|
|
- methods.debug_log(f"{self.connection_id}|SRIConnection085", f"连接已关闭")
|
|
|
+ methods.debug_log(f"{self.connection_id}|SRIConnection|65", f"连接已关闭")
|
|
|
+ methods.debug_log(f"{self.connection_id}|SRIConnection|65", f"clients: len{clients}")
|
|
|
|
|
|
# --- get VehicleStatus ---
|
|
|
unique_dict = {'name': 'VehicleStatus'}
|
|
|
@@ -182,8 +183,11 @@ class SRIConnection(asyncio.Protocol):
|
|
|
head_data = self.message_data[:self.head_size]
|
|
|
command_id, body_length = struct.unpack(self.head_sequence, head_data)
|
|
|
if command_id not in [2008]:
|
|
|
- methods.debug_log(f'{self.connection_id}|SRIConnection176',
|
|
|
+ methods.debug_log(f'{self.connection_id}|SRIConnection.166',
|
|
|
f"command_id: {command_id}, body_length: {body_length}")
|
|
|
+ # else:
|
|
|
+ # methods.debug_log(f'{self.connection_id}|SRIConnection.169',
|
|
|
+ # f"command_id: {command_id}, body_length: {body_length}")
|
|
|
|
|
|
# 检查命令ID是否有效
|
|
|
if not (1000 < command_id < 9000):
|
|
|
@@ -569,7 +573,7 @@ class SRIConnection(asyncio.Protocol):
|
|
|
|
|
|
def message2007(self, body_data):
|
|
|
|
|
|
- # --- 解析消息体
|
|
|
+ # --- 解析消息体 2007
|
|
|
"""
|
|
|
Leave: 消息体
|
|
|
Leave.peer: int32（车端rid）
|
casper