From 1a9060fd3373df54b6908ad234587f93a62d14fd Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 28 五月 2025 23:28:34 +0800
Subject: [PATCH] bug修复
---
servers/data_server.py | 12 ++++++++++--
1 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/servers/data_server.py b/servers/data_server.py
index 3c5cc04..a911462 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -9,6 +9,7 @@
import requests
import constant
+import inited_data
from code_attribute.gpcode_manager import BlackListCodeManager, HumanRemoveForbiddenManager
from l2.huaxin import huaxin_target_codes_manager
from l2.l2_transaction_data_manager import HuaXinBuyOrderManager
@@ -24,7 +25,7 @@
from trade.buy_radical.new_block_processor import BeforeBlocksComputer
from trade.buy_strategy import OpenLimitUpGoodBlocksBuyStrategy
from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, BeforeSubDealBigOrderManager
-from utils import global_util, tool, data_export_util
+from utils import global_util, tool, data_export_util, init_data_util
from code_attribute import gpcode_manager, code_nature_analyse
from log_module import log_analyse, log_export, async_log_util
from l2 import code_price_manager, l2_data_util, transaction_progress
@@ -970,6 +971,11 @@
# 鍔犺浇娑ㄥ仠澶у崟璇︽儏
limit_up_big_order_detail = radical_buy_data_manager.get_total_detal_big_order_details(
code)
+ if max(limit_up_big_order_detail) == 0:
+ # 娌℃湁鏁版嵁锛屼粠缃戠粶鍔犺浇
+ limit_up_big_order_detail = list(limit_up_big_order_detail)
+ limit_up_big_order_detail[1] = deal_big_order_detail_info[1][0]
+ limit_up_big_order_detail[3] = deal_big_order_detail_info[2][0]
deal_big_order_info.append(
output_util.money_desc(limit_up_big_order_detail[0] + limit_up_big_order_detail[1]))
deal_big_order_info.append(
@@ -979,6 +985,8 @@
except Exception as e:
logger_debug.error(f"鍙兘娌℃湁鑾峰彇鍒版定鍋滀环锛歿code}")
+ if not gpcode_manager.get_limit_up_price(code):
+ init_data_util.re_set_price_pre(code)
# logger_debug.exception(e)
deal_big_order_info = None
code_name = gpcode_manager.get_code_name(code)
@@ -1060,7 +1068,7 @@
code_info_list.append((d[0], d[6]))
# 淇濆瓨鏂伴鏉�
datas = [(d[0], d[6]) for d in result["list"]]
- async_log_util.info(logger_kpl_new_blocks, f"{(tool.get_thread_id() ,bi, datas)}")
+ async_log_util.info(logger_kpl_new_blocks, f"{(tool.get_thread_id(), bi, datas)}")
if code_info_list:
# 灏嗕唬鐮佸姞鍏ユ柊棰樻潗
new_block_processor.process_new_block_by_component_codes(bi[0],
--
Gitblit v1.8.0