From 9d33b41fc2b14d3bcce0ccb51f612cf13e38f9cc Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 05 三月 2025 14:51:17 +0800
Subject: [PATCH] 记录测试日志
---
api/outside_api_command_callback.py | 93 +++++++++++++++++++++++++++++++++++++---------
1 files changed, 74 insertions(+), 19 deletions(-)
diff --git a/api/outside_api_command_callback.py b/api/outside_api_command_callback.py
index 666e10f..b5c63e9 100644
--- a/api/outside_api_command_callback.py
+++ b/api/outside_api_command_callback.py
@@ -18,7 +18,8 @@
from code_attribute import gpcode_manager, code_volumn_manager, zyltgb_util
from code_attribute.code_data_util import ZYLTGBUtil
from code_attribute.code_l1_data_manager import L1DataManager
-from code_attribute.gpcode_manager import CodePrePriceManager, CodesNameManager, WantBuyCodesManager
+from code_attribute.gpcode_manager import CodePrePriceManager, CodesNameManager, WantBuyCodesManager, \
+ HumanRemoveForbiddenManager
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from huaxin_client import l1_subscript_codes_manager
@@ -35,23 +36,25 @@
logger_trade, logger_trade_position_api_request, logger_request_api, \
logger_real_place_order_position, logger_device
from output import l2_output_util
-from third_data import kpl_util, history_k_data_manager, huaxin_l1_data_manager, third_blocks_manager, kpl_data_manager
-from third_data.code_plate_key_manager import KPLCodeJXBlockManager
+from third_data import kpl_util, history_k_data_manager, huaxin_l1_data_manager, third_blocks_manager, kpl_data_manager, \
+ history_k_data_util
+from third_data.code_plate_key_manager import KPLCodeJXBlockManager, RealTimeKplMarketData
from third_data.history_k_data_manager import HistoryKDataManager
from third_data.history_k_data_util import JueJinApi, HistoryKDatasUtils
+from third_data.kpl_data_constant import LimitUpDataConstant
from third_data.kpl_data_manager import KPLDataManager
from third_data.kpl_limit_up_data_manager import CodeLimitUpSequenceManager
from third_data.kpl_util import KPLDataType
from third_data.third_blocks_manager import CodeThirdBlocksManager, SOURCE_TYPE_KPL, BlockMapManager
-from trade import trade_manager, l2_trade_util, trade_data_manager, trade_constant
+from trade import trade_manager, l2_trade_util, trade_data_manager, trade_constant, trade_record_log_util
import l2_data_util as l2_data_util_old
from trade.buy_money_count_setting import BuyMoneyAndCountSetting, RadicalBuyBlockCodeCountManager
-from trade.buy_radical import block_special_codes_manager
+from trade.buy_radical import block_special_codes_manager, radical_buy_data_manager
from trade.huaxin import huaxin_trade_api, huaxin_trade_data_update, \
huaxin_trade_record_manager, huaxin_trade_order_processor, huaxin_sell_util
from trade.huaxin.huaxin_trade_record_manager import PositionManager, DealRecordManager, DelegateRecordManager
-from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager
+from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, BeforeSubDealBigOrderManager
from trade.sell import sell_manager
from trade.sell.sell_rule_manager import TradeRuleManager, SellRule
from trade.trade_data_manager import RadicalBuyDealCodesManager
@@ -290,8 +293,10 @@
if code_list_type == outside_api_command_manager.CODE_LIST_WANT:
if operate == outside_api_command_manager.OPERRATE_SET:
gpcode_manager.WantBuyCodesManager().add_code(code)
- # 鍔犳兂涔板崟瑕佷粠榛戝悕鍗曠Щ闄�
- l2_trade_util.remove_from_forbidden_trade_codes(code)
+ if l2_trade_util.is_in_forbidden_trade_codes(code):
+ l2_trade_util.remove_from_forbidden_trade_codes(code)
+ # 鍔犳兂涔板崟瑕佷粠榛戝悕鍗曠Щ闄�
+ HumanRemoveForbiddenManager().add_code(code)
name = gpcode_manager.get_code_name(code)
if not name:
results = HistoryKDatasUtils.get_gp_codes_names([code])
@@ -314,8 +319,9 @@
cancel_type=trade_constant.CANCEL_TYPE_HUMAN)
except Exception as e:
logger_debug.exception(e)
- l2_trade_util.forbidden_trade(code, msg="鎵嬪姩鍔犲叆 trade_server")
+ l2_trade_util.forbidden_trade(code, msg="鎵嬪姩鍔犲叆 trade_server", force=True)
WantBuyCodesManager().remove_code(code)
+ HumanRemoveForbiddenManager().remove_code(code)
name = gpcode_manager.get_code_name(code)
if not name:
results = HistoryKDatasUtils.get_gp_codes_names([code])
@@ -323,7 +329,7 @@
gpcode_manager.CodesNameManager.add_first_code_name(code, results[code])
elif operate == outside_api_command_manager.OPERRATE_DELETE:
l2_trade_util.remove_from_forbidden_trade_codes(code)
- WantBuyCodesManager().add_code(code)
+ HumanRemoveForbiddenManager().add_code(code)
elif operate == outside_api_command_manager.OPERRATE_GET:
codes = gpcode_manager.BlackListCodeManager().list_codes_cache()
datas = []
@@ -369,6 +375,7 @@
elif code_list_type == outside_api_command_manager.CODE_LIST_MUST_BUY:
if operate == outside_api_command_manager.OPERRATE_SET:
gpcode_manager.MustBuyCodesManager().add_code(code)
+ trade_record_log_util.add_must_buy(code, "鎵嬪姩鎷夌孩")
name = gpcode_manager.get_code_name(code)
if not name:
results = HistoryKDatasUtils.get_gp_codes_names([code])
@@ -482,7 +489,8 @@
try:
fdata = {}
try:
- date = JueJinApi.get_previous_trading_date(tool.get_now_date_str())
+ date = HistoryKDatasUtils.get_trading_dates(tool.date_sub(tool.get_now_date_str(), 10),
+ tool.get_now_date_str())
if date:
fdata["juejin"] = 1
except Exception as e:
@@ -539,14 +547,10 @@
# 鑾峰彇浠婃棩K绾跨殑鏇存柊鏁伴噺
try:
- dates = HistoryKDatasUtils.get_latest_trading_date_cache(5)
- latest_trading_date = None
- if dates:
- latest_trading_date = dates[0]
- if latest_trading_date is None:
- raise Exception("娌℃湁鑾峰彇鍒颁笂涓�涓氦鏄撴棩鐨勬棩鏈�")
+ latest_trading_date = history_k_data_util.get_k_bar_dead_date()
codes = HistoryKDataManager().get_history_bars_codes(latest_trading_date)
count = len(codes)
+ logger_debug.info(f"K绾夸唬鐮佹暟閲忥細{count}")
fdata["today_history_k_bar_count"] = count
except Exception as e:
logger_debug.exception(e)
@@ -1223,6 +1227,13 @@
bigger_money = l2_data_util_old.get_big_money_val(gpcode_manager.get_limit_up_price_as_num(code),
tool.is_ge_code(code))
fdatas = []
+ # 鍔犺浇璁㈤槄涔嬪墠鐨勫ぇ鍗�
+ pre_deals = BeforeSubDealBigOrderManager().get_deal_big_order_money_list(code)
+ if pre_deals:
+ for d in pre_deals:
+ if d[0] < bigger_money:
+ continue
+ fdatas.append(d[0])
for d in data_list:
if d < bigger_money:
continue
@@ -1278,7 +1289,9 @@
data = {
"blocks": {},
"origin_blocks": {},
- "match_blocks": [list(filter_blocks), list(match_blocks)]
+ "match_blocks": [list(filter_blocks), list(match_blocks)],
+ # 鏉垮潡鍑�娴佸叆鎯呭喌
+ "block_in_moneys": [RealTimeKplMarketData.get_block_info_at_block_in(b) for b in filter_blocks]
}
for s in source_origin_dict:
data["origin_blocks"][s] = list(source_origin_dict[s])
@@ -1335,7 +1348,11 @@
# 鑾峰彇涔板叆涓嬪崟璁剧疆
data = {
"radical_buy": {"price": (constant.MIN_CODE_RADICAL_BUY_PRICE, constant.MAX_CODE_RADICAL_BUY_PRICE),
- "zyltgb": constant.RADICAL_BUY_ZYLTGB_AS_YI_RANGES}}
+ "zyltgb": constant.RADICAL_BUY_ZYLTGB_AS_YI_RANGES,
+ "top_block_count_by_market_strong": constant.RADICAL_BUY_TOP_IN_COUNT_BY_MARKET_STRONG,
+ "special_codes_max_block_in_rank": constant.RADICAL_BUY_TOP_IN_INDEX_WITH_SPECIAL,
+ "ignore_block_in_money_market_strong":constant.IGNORE_BLOCK_IN_MONEY_MARKET_STRONG
+ }}
self.send_response({"code": 0, "data": data, "msg": f""},
client_id,
request_id)
@@ -1346,6 +1363,14 @@
constant.MIN_CODE_RADICAL_BUY_PRICE = radical_buy["price"][0]
constant.MAX_CODE_RADICAL_BUY_PRICE = radical_buy["price"][1]
constant.RADICAL_BUY_ZYLTGB_AS_YI_RANGES = radical_buy["zyltgb"]
+ if radical_buy.get("top_block_count_by_market_strong"):
+ constant.RADICAL_BUY_TOP_IN_COUNT_BY_MARKET_STRONG = radical_buy.get(
+ "top_block_count_by_market_strong")
+ if radical_buy.get("special_codes_max_block_in_rank"):
+ constant.RADICAL_BUY_TOP_IN_INDEX_WITH_SPECIAL = radical_buy.get(
+ "special_codes_max_block_in_rank")
+ if radical_buy.get('ignore_block_in_money_market_strong') is not None:
+ constant.IGNORE_BLOCK_IN_MONEY_MARKET_STRONG = radical_buy.get('ignore_block_in_money_market_strong')
self.send_response({"code": 0, "data": {}, "msg": f""},
client_id,
request_id)
@@ -1374,6 +1399,36 @@
client_id,
request_id)
+ elif ctype == "get_same_block_limit_up_codes_count":
+ # 鑾峰彇鐩稿悓鏉垮潡鐨勬定鍋滀唬鐮佹暟閲�
+ codes = data.get("codes")
+ codes = json.loads(codes)
+ block_codes = {}
+ for code in codes:
+ # 鑾峰彇鏉垮潡
+ fblocks, before_fblocks = RadicalBuyBlockManager.get_code_blocks(code)
+ # 鑾峰彇鏉垮潡鍘嗗彶娑ㄥ仠
+ for b in fblocks:
+ codes = LimitUpDataConstant.get_history_limit_up_block_codes(b)
+ if codes:
+ if code not in block_codes:
+ block_codes[code] = {}
+ block_codes[code][b] = len(codes)
+ self.send_response({"code": 0, "data": block_codes},
+ client_id,
+ request_id)
+
+ elif ctype == "test_place_order":
+ # 鑾峰彇鐩稿悓鏉垮潡鐨勬定鍋滀唬鐮佹暟閲�
+ code = data.get("code")
+ # total_datas = l2_data_util.local_today_datas.get(code)
+ # trade_manager.test_order(code, total_datas[-1], total_datas[-1]["index"])
+ # radical_buy_data_manager.pull_pre_deal_big_orders(code)
+ self.send_response({"code": 0, "data": {}},
+ client_id,
+ request_id)
+
+
except Exception as e:
logging.exception(e)
--
Gitblit v1.8.0