From a53ab43591e80223e736261a3cd6fbebb7ae4e55 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 06 十一月 2024 16:12:35 +0800
Subject: [PATCH] 扫入板块修改/不保存非交易时间的开盘啦涨停队列

---
 servers/data_server.py |   17 ++++++++++-------
 1 files changed, 10 insertions(+), 7 deletions(-)

diff --git a/servers/data_server.py b/servers/data_server.py
index 4d9510f..4a30824 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -756,9 +756,9 @@
                 fdata["delegates"]["sell"] = delegates[3]
                 deals = trade_data_manager.AccountMoneyManager().get_deal_count_info()
                 fdata["deals"] = {}
-                fdata["deals"]["stock"]={"count": deals[0][1], "price": 5, "money": round(5 * deals[0][1], 2)}
-                fdata["deals"]["sh_cb"]={"count": deals[1][1], "price": 1, "money": round(1 * deals[1][1], 2)}
-                fdata["deals"]["sz_cb"]={"count": deals[2][1], "price": 0, "money": round(0 * deals[2][1], 2)}
+                fdata["deals"]["stock"] = {"count": deals[0][1], "price": 5, "money": round(5 * deals[0][1], 2)}
+                fdata["deals"]["sh_cb"] = {"count": deals[1][1], "price": 1, "money": round(1 * deals[1][1], 2)}
+                fdata["deals"]["sz_cb"] = {"count": deals[2][1], "price": 0, "money": round(0 * deals[2][1], 2)}
                 fdata["commission"] = trade_data_manager.AccountMoneyManager().get_commission_cache()
                 response_data = json.dumps({"code": 0, "data": fdata})
             except Exception as e:
@@ -875,10 +875,13 @@
 
                 self.__kplDataManager.save_data(type_, result_list)
         elif type_ == KPLDataType.LIMIT_UP.value:
-            result_list = kpl_util.parseLimitUpData(data["data"])
-            self.__data_process_thread_pool.submit(lambda: do_limit_up(result_list))
-            # 璁板綍娑ㄥ仠鏃ュ織
-            logger_kpl_limit_up.info(result_list)
+            result_list, day = kpl_util.parseLimitUpData(data["data"])
+            if day and day != tool.get_now_date_str():
+                pass
+            else:
+                self.__data_process_thread_pool.submit(lambda: do_limit_up(result_list))
+                # 璁板綍娑ㄥ仠鏃ュ織
+                logger_kpl_limit_up.info(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