策略完善

Administrator

2025-06-12 9399db7dfedc7a36ed1cead1610f1039365bd770

 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):