From 38395204ab04bbca22a5e22be988d826afd5b227 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 10 十一月 2022 15:46:27 +0800
Subject: [PATCH] 修复bug，优化下单
---
server.py | 23 ++++++++++++++++++++---
1 files changed, 20 insertions(+), 3 deletions(-)
diff --git a/server.py b/server.py
index e150884..211656f 100644
--- a/server.py
+++ b/server.py
@@ -1,7 +1,7 @@
"""
鎺ュ彈瀹㈡埛绔暟鎹殑鏈嶅姟鍣�
"""
-
+import datetime
import json
import logging
import socketserver
@@ -22,6 +22,7 @@
import l2_data_manager
import l2_data_manager_new
import l2_data_util
+import limit_up_time_manager
import ths_industry_util
import ths_util
import tool
@@ -129,7 +130,7 @@
self.l2_data_error_dict[key] = round(time.time() * 1000)
except Exception as e:
- print("寮傚父", str(e))
+ print("寮傚父", str(e), code)
logging.exception(e)
logger_l2_error.error("鍑洪敊锛歿}".format(str(e)))
logger_l2_error.error("鍐呭锛歿}".format(_str))
@@ -168,6 +169,22 @@
if dataList:
global_data_loader.add_limit_up_codes(dataList)
ths_industry_util.set_industry_hot_num(dataList)
+ # 淇濆瓨娑ㄥ仠鏃堕棿
+ gp_list = gpcode_manager.get_gp_list()
+ gp_code_set = set(gp_list)
+ now_str = datetime.datetime.now().strftime("%H:%M:%S")
+ for d in dataList:
+ if d["time"] == "00:00:00" or tool.get_time_as_second(now_str) < tool.get_time_as_second(
+ d["time"]):
+ continue
+ if d["code"] not in gp_code_set:
+ continue
+
+ # 鑾峰彇鏄惁鏈夋定鍋滄椂闂�
+ if limit_up_time_manager.get_limit_up_time(d["code"]) is None:
+ limit_up_time_manager.save_limit_up_time(d["code"], d["time"])
+
+
elif type == 3:
# 浜ゆ槗鎴愬姛淇℃伅
dataList = data_process.parseList(_str)
@@ -245,7 +262,7 @@
l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, cancel_msg)
if need_sync:
# 鍚屾鏁版嵁
- l2_data_manager.L2LimitUpMoneyStatisticUtil.verify_num(code, volumn, time_)
+ l2_data_manager_new.L2LimitUpMoneyStatisticUtil.verify_num(code, volumn, time_)
elif type == 30:
# 蹇冭烦淇℃伅
--
Gitblit v1.8.0