From 1be82b7e52ae31c0b5aa9b18af483408f3f840ac Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 01 九月 2023 15:34:39 +0800 Subject: [PATCH] 注释掉测试 --- third_data/data_server.py | 26 +++++++++++++++----------- 1 files changed, 15 insertions(+), 11 deletions(-) diff --git a/third_data/data_server.py b/third_data/data_server.py index 46a2264..6feb510 100644 --- a/third_data/data_server.py +++ b/third_data/data_server.py @@ -41,7 +41,6 @@ __jingxuan_cache_dict = {} __industry_cache_dict = {} - def __get_limit_up_list(self): # 缁熻鐩墠涓烘鐨勪唬鐮佹定鍋滄暟閲忥紙鍒嗘定鍋滃師鍥狅級 total_datas = KPLLimitUpDataRecordManager.total_datas @@ -379,7 +378,8 @@ for code_info in codes_info: code_info[4] = 1 if code_info[0] in want_codes else 0 # 鑾峰彇浠g爜鐘舵�� - if trade_manager.CodesTradeStateManager().get_trade_state_cache(code_info[0]) != trade_manager.TRADE_STATE_NOT_TRADE: + if trade_manager.CodesTradeStateManager().get_trade_state_cache( + code_info[0]) != trade_manager.TRADE_STATE_NOT_TRADE: code_info[5] = 1 response_data = json.dumps({"code": 0, "data": codes_info}) @@ -477,6 +477,17 @@ self.__send_response(result_str) def __process_kpl_data(self, data): + def do_limit_up(result_list): + if result_list: + # 淇濆瓨娑ㄥ仠鏃堕棿 + for d in result_list: + code = d[0] + if code.find("00") == 0 or code.find("60") == 0: + limit_up_time = time.strftime("%H:%M:%S", time.localtime(d[2])) + code_price_manager.Buy1PriceManager().set_limit_up_time(code, limit_up_time) + kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), result_list) + self.__kplDataManager.save_data(type_, result_list) + type_ = data["type"] print("寮�鐩樺暒type:", type_) if type_ == KPLDataType.BIDDING.value: @@ -494,15 +505,8 @@ self.__kplDataManager.save_data(type_, result_list) elif type_ == KPLDataType.LIMIT_UP.value: result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_LIMIT_UP) - if result_list: - # 淇濆瓨娑ㄥ仠鏃堕棿 - for d in result_list: - code = d[0] - if code.find("00") == 0 or code.find("60") == 0: - limit_up_time = time.strftime("%H:%M:%S", time.localtime(d[2])) - code_price_manager.Buy1PriceManager().set_limit_up_time(code, limit_up_time) - self.__kplDataManager.save_data(type_, result_list) - kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), result_list) + do_limit_up(result_list) + elif type_ == KPLDataType.OPEN_LIMIT_UP.value: result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_OPEN_LIMIT_UP) if result_list: -- Gitblit v1.8.0