| | |
| | | import http |
| | | import json |
| | | import logging |
| | | import os |
| | | import socketserver |
| | | from http.server import BaseHTTPRequestHandler |
| | | |
| | |
| | | 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() |