Administrator
5 天以前 09f84c4ecae2a71e07f6dd64e6066563599a62b6
server/data_server.py
@@ -1,6 +1,7 @@
import http
import json
import logging
import os
import socketserver
from http.server import BaseHTTPRequestHandler
@@ -45,13 +46,14 @@
                strategy_manager.low_suction_strtegy.add_big_orders(params)
                # logger_debug.info("upload_big_order_datas:{}", f"{params}")
                RealTimeEnvInfo().big_order_update_time = tool.get_now_time_str()
                print("获取到大单", os.getpid())
                result_str = json.dumps({"code": 0})
            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}")
                RealTimeEnvInfo().block_in=(tool.get_now_time_str(), len(params))
                RealTimeEnvInfo().block_in = (tool.get_now_time_str(), len(params))
                result_str = json.dumps({"code": 0})
            elif url.path == "/upload_limit_up_list":
                params = self.__parse_request()