From cda53e53c3b1c92d289b234a3a0106e66e2cac38 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 27 七月 2023 11:16:53 +0800
Subject: [PATCH] bug修复

---
 server.py |   11 ++++++-----
 1 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/server.py b/server.py
index 21b9f47..0c5a6e5 100644
--- a/server.py
+++ b/server.py
@@ -10,7 +10,7 @@
 import threading
 import time
 
-from utils import alert_util, data_process, global_util, ths_industry_util, tool, import_util
+from utils import alert_util, data_process, global_util, ths_industry_util, tool, import_util, socket_util
 from code_attribute import code_volumn_manager, code_nature_analyse, global_data_loader, gpcode_manager, \
     gpcode_first_screen_manager
 import constant
@@ -22,7 +22,7 @@
 import l2.l2_data_util
 
 from output import code_info_output
-from third_data import  block_info, kpl_api
+from third_data import block_info, kpl_api
 from third_data.code_plate_key_manager import CodesHisReasonAndBlocksManager
 from third_data.history_k_data_util import HistoryKDatasUtils
 from third_data.kpl_data_manager import KPLCodeLimitUpReasonManager, KPLLimitUpDataRecordManager
@@ -108,8 +108,6 @@
                 try:
                     # 濡傛灉甯︽湁澶�
                     if _str.startswith("##"):
-                        print("server鎺ュ彈鍒版暟鎹細",_str)
-
                         total_length = int(_str[2:10])
                         _str = _str[10:]
                         # 闃叉socket鏁版嵁鍙戠敓绮樿繛
@@ -271,11 +269,13 @@
                         # if limit_up_time_manager.get_limit_up_time(d["code"]) is None:
                         #     limit_up_time_manager.save_limit_up_time(d["code"], d["time"])
                 elif type == 22:
+                    print("---鎺ュ彈鍒伴鏉夸唬鐮�")
                     try:
                         if int(tool.get_now_time_str().replace(":", "")) < int("092500"):
                             raise Exception('鏈埌鎺ュ彈鏃堕棿')
                         # 棣栨澘浠g爜
                         dataList, is_add = data_process.parseGPCode(_str)
+                        print("棣栨澘浠g爜鏁伴噺锛�", len(dataList))
                         limit_up_price_dict = {}
                         temp_codes = []
                         codes = []
@@ -469,7 +469,8 @@
                     except Exception as e:
                         logging.exception(e)
                     finally:
-                        return_str = json.dumps({"code": 0})
+                        print("棣栨澘浠g爜澶勭悊瀹屾瘯锛�")
+                        return_str = socket_util.load_header(json.dumps({"code": 0}))
 
                 elif type == 3:
                     # 浜ゆ槗鎴愬姛淇℃伅

--
Gitblit v1.8.0