From fa6a3ab958ce9493833eef68ac62bd155be5d53e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 28 十月 2022 15:09:15 +0800
Subject: [PATCH] 驾驶舱监听，不再处理同花顺14:55以后的交易队列数据
---
juejin.py | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/juejin.py b/juejin.py
index 8322d89..962dde5 100644
--- a/juejin.py
+++ b/juejin.py
@@ -207,10 +207,11 @@
data_ = (symbol, time_, tick["quotes"][0]["bid_v"], tick["quotes"][0]["bid_p"])
logger_juejin_tick.info("涔�1閲� {},{},{},{}", data_[1], data_[0], data_[2],
data_[3])
- need_sync = __jueJinBuy1VolumnManager.save(data_[0], data_[1], data_[2], data_[3])
- if need_sync:
- # 鍚屾鏁版嵁
- L2LimitUpMoneyStatisticUtil.verify_num(data_[0], data_[2], data_[1])
+ # 鏆傛椂涓嶉噰鐢�
+ # need_sync = __jueJinBuy1VolumnManager.save(data_[0], data_[1], data_[2], data_[3])
+ # if need_sync:
+ # # 鍚屾鏁版嵁
+ # L2LimitUpMoneyStatisticUtil.verify_num(data_[0], data_[2], data_[1])
# print(tick["created_at"],tick["quotes"][0]["bid_v"])
@@ -241,6 +242,7 @@
# 鑾峰彇鍒扮幇浠�
def accpt_prices(prices):
print("浠锋牸浠ｇ爜鏁伴噺锛�", len(prices))
+ __actualPriceProcessor.save_current_price_codes_count(len(prices))
now_str = datetime.datetime.now().strftime("%H:%M:%S")
now_strs = now_str.split(":")
now_second = int(now_strs[0]) * 60 * 60 + int(now_strs[1]) * 60 + int(now_strs[2])
--
Gitblit v1.8.0