From 2f2516749615da866e96d8d24e499b7ecbb63a3e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 23 六月 2025 12:28:52 +0800
Subject: [PATCH] 默认交易模式变更/真实下单位置计算位置修改

---
 servers/data_server.py |   20 +++++++++++++++++++-
 1 files changed, 19 insertions(+), 1 deletions(-)

diff --git a/servers/data_server.py b/servers/data_server.py
index 14015bf..a548267 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -10,6 +10,7 @@
 
 import constant
 import inited_data
+from api import low_suction_data_pusher
 from code_attribute.gpcode_manager import BlackListCodeManager, HumanRemoveForbiddenManager
 from l2.huaxin import huaxin_target_codes_manager
 from l2.l2_transaction_data_manager import HuaXinBuyOrderManager
@@ -1024,7 +1025,17 @@
                             logger_debug.exception(e)
                             deal_big_order_info = None
                         code_name = gpcode_manager.get_code_name(code)
-                        fresults.append((code, code_name, deal_big_order_info, deal_big_order_detail_info))
+
+                        big_order_enough = 0
+                        try:
+                            total_deal_big_order_result = radical_buy_data_manager.get_total_deal_big_order_info(code,
+                                                                                        gpcode_manager.get_limit_up_price_as_num(
+                                                                                            code))
+                            if total_deal_big_order_result and total_deal_big_order_result[0]<=0:
+                                big_order_enough = 1
+                        except:
+                            pass
+                        fresults.append((code, code_name, deal_big_order_info, deal_big_order_detail_info, big_order_enough))
                 response_data = json.dumps({"code": 0, "data": fresults})
             except Exception as e:
                 response_data = json.dumps({"code": 1, "data": str(1)})
@@ -1207,6 +1218,13 @@
                                     lambda: request_new_blocks_codes(update_new_block_plates, new_block_codes.keys()))
                     except Exception as e:
                         logger_debug.exception(e)
+
+                    # 灏嗘暟鎹帹閫佽嚦鍏朵粬椤圭洰
+                    try:
+                        low_suction_data_pusher.push_limit_up_list(result_list_)
+                    except:
+                        pass
+
                     self.__kplDataManager.save_data(type_, result_list_)
             except Exception as e:
                 logger_debug.exception(e)

--
Gitblit v1.8.0