From fc1f4ebaccdec747528da280de2f8886d063290f Mon Sep 17 00:00:00 2001 From: denis Date: Tue, 16 Apr 2024 15:32:58 +0000 Subject: [PATCH] =?UTF-8?q?=D0=9F=D0=BE=D0=BF=D1=8B=D1=82=D0=BA=D0=B8=20?= =?UTF-8?q?=D0=BE=D0=B1=D0=B5=D1=81=D0=BF=D0=B5=D1=87=D0=B8=D1=82=D1=8C=20?= =?UTF-8?q?=D1=81=D1=82=D0=B0=D0=B1=D0=B8=D0=BB=D1=8C=D0=BD=D1=8B=D0=B9=20?= =?UTF-8?q?=D0=BF=D0=B0=D1=80=D1=81=D0=B8=D0=BD=D0=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- QuikPy.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/QuikPy.py b/QuikPy.py index 41a99c5..41a2501 100644 --- a/QuikPy.py +++ b/QuikPy.py @@ -43,6 +43,8 @@ class QuikPy(metaclass=Singleton): # Singleton класс print("Истёк таймаут чтения из буфера") except ConnectionResetError: print("Соединение сброшено") + self.OnClose({}) + else: fragments.append(fragment.decode('cp1251')) # Переводим фрагмент в Windows кодировку 1251, добавляем в список if len(fragment) < self.bufferSize: # Если в принятом фрагменте данных меньше чем размер буфера @@ -117,13 +119,14 @@ class QuikPy(metaclass=Singleton): # Singleton класс def ProcessRequest(self, Request): """Отправляем запрос в QUIK, получаем ответ из QUIK""" rawData = json.dumps(Request) # Переводим запрос в формат JSON - # self.socketRequests.settimeout(1) + self.socketRequests.settimeout(1) + print(rawData) # print(self.socketRequests.timeout) # self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK try: self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK - except Exception: - # raise TimeoutError("Истёк таймаут подключения к QUIK") + except TimeoutError: + raise TimeoutError("Истёк таймаут подключения к QUIK") print("Истёк таймаут подключения к QUIK") data = {"data": "error"} return data