From ab662be5c523b75c1bd28fc6bfcab2872b9623b3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 12 六月 2025 15:22:06 +0800
Subject: [PATCH] bug修复
---
server/data_server.py | 37 ++++++++++++++++++++++---------------
1 files changed, 22 insertions(+), 15 deletions(-)
diff --git a/server/data_server.py b/server/data_server.py
index 5f94427..1e71d77 100644
--- a/server/data_server.py
+++ b/server/data_server.py
@@ -5,6 +5,7 @@
from http.server import BaseHTTPRequestHandler
from log_module.log import logger_system, logger_debug, logger_request_api
+from strategy import strategy_manager
from utils import tool
from log_module import async_log_util
@@ -36,21 +37,27 @@
path = self.path
url = urlparse.urlparse(path)
result_str = ""
- if url.path == "/upload_big_order_datas":
- # 鎺ユ敹鎴愪氦澶у崟鏁版嵁
- params = self.__parse_request()
- logger_debug.info("upload_big_order_datas:{}", f"{params}")
- elif url.path == "/upload_block_in_datas":
- # 鎺ユ敹鏉垮潡娴佸叆鏁版嵁
- params = self.__parse_request()
- logger_debug.info("upload_block_in_datas:{}", f"{params}")
- result_str = json.dumps({"code": 0})
- elif url.path == "upload_limit_up_list":
- params = self.__parse_request()
- logger_debug.info("upload_limit_up_list:{}", f"{params}")
- result_str = json.dumps({"code": 0})
- else:
- pass
+ try:
+ if url.path == "/upload_big_order_datas":
+ # 鎺ユ敹鎴愪氦澶у崟鏁版嵁
+ params = self.__parse_request()
+ strategy_manager.low_suction_strtegy.add_big_orders(params)
+ # logger_debug.info("upload_big_order_datas:{}", f"{params}")
+ elif url.path == "/upload_block_in_datas":
+ # 鎺ユ敹鏉垮潡娴佸叆鏁版嵁
+ params = self.__parse_request()
+ strategy_manager.low_suction_strtegy.add_block_in(params)
+ # logger_debug.info("upload_block_in_datas:{}", f"{params}")
+ result_str = json.dumps({"code": 0})
+ elif url.path == "/upload_limit_up_list":
+ params = self.__parse_request()
+ strategy_manager.low_suction_strtegy.add_limit_up_list(params)
+ # logger_debug.info("upload_limit_up_list:{}", f"{params}")
+ result_str = json.dumps({"code": 0})
+ else:
+ pass
+ except Exception as e:
+ logger_debug.exception(e)
self.__send_response(result_str)
def __send_response(self, data):
--
Gitblit v1.8.0