|  | @@ -62,7 +62,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}")
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |          # --- 处理车端掉线,通知所有舱端
 |  |          # --- 处理车端掉线,通知所有舱端
 | 
											
												
													
														|  |          if self.client_type == 'vehicle':
 |  |          if self.client_type == 'vehicle':
 | 
											
										
											
												
													
														|  | @@ -162,8 +163,11 @@ class SRIConnection(asyncio.Protocol):
 | 
											
												
													
														|  |                  head_data = self.message_data[:self.head_size]
 |  |                  head_data = self.message_data[:self.head_size]
 | 
											
												
													
														|  |                  command_id, body_length = struct.unpack(self.head_sequence, head_data)
 |  |                  command_id, body_length = struct.unpack(self.head_sequence, head_data)
 | 
											
												
													
														|  |                  if command_id not in [2008]:
 |  |                  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}")
 |  |                                        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是否有效
 |  |                  # 检查命令ID是否有效
 | 
											
												
													
														|  |                  if not (1000 < command_id < 9000):
 |  |                  if not (1000 < command_id < 9000):
 | 
											
										
											
												
													
														|  | @@ -539,7 +543,7 @@ class SRIConnection(asyncio.Protocol):
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  |      def message2007(self, body_data):
 |  |      def message2007(self, body_data):
 | 
											
												
													
														|  |  
 |  |  
 | 
											
												
													
														|  | -        # --- 解析消息体
 |  | 
 | 
											
												
													
														|  | 
 |  | +        # --- 解析消息体 2007
 | 
											
												
													
														|  |          """
 |  |          """
 | 
											
												
													
														|  |          Leave: 消息体
 |  |          Leave: 消息体
 | 
											
												
													
														|  |          Leave.peer: int32(车端rid)
 |  |          Leave.peer: int32(车端rid)
 |