‘功能完善

Administrator

4 天以前 349cf60c3922041c5b35d0ceb9c0434e5d288e5d

‘功能完善

 server/data_server.py

@@ -40,9 +40,12 @@
        url = urlparse.urlparse(path)
        result_str = ""
        try:
            params = self.__parse_request()
            if type(params) == str:
                params = json.loads(params)
            if url.path == "/upload_big_order_datas":
                # 接收成交大单数据
                big_order_datas = self.__parse_request()
                big_order_datas = params
                # print("upload_big_order_datas", big_order_datas)
                strategy_manager.low_suction_strtegy.add_big_orders(big_order_datas)
                # logger_debug.info("upload_big_order_datas:{}", f"{params}")
@@ -51,14 +54,14 @@
                result_str = json.dumps({"code": 0})
            elif url.path == "/upload_block_in_datas":
                # 接收板块流入数据
                block_in_datas = self.__parse_request()
                block_in_datas = params
                # print("upload_block_in_datas", block_in_datas)
                strategy_manager.low_suction_strtegy.add_block_in(block_in_datas)
                # logger_debug.info("upload_block_in_datas:{}", f"{params}")
                RealTimeEnvInfo().block_in = (tool.get_now_time_str(), len(block_in_datas))
                result_str = json.dumps({"code": 0})
            elif url.path == "/upload_limit_up_list":
                limit_up_list = self.__parse_request()
                limit_up_list = params
                # print("upload_limit_up_list", limit_up_list)
                strategy_manager.low_suction_strtegy.add_limit_up_list(limit_up_list)
                # logger_debug.info("upload_limit_up_list:{}", f"{params}")