| l2_data_parser.py | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| l2_test.py | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| servers/data_server.py | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| trade/buy_radical/radical_buy_data_manager.py | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
l2_data_parser.py
@@ -405,17 +405,11 @@ transaction_big_order_parser.concat_pre_ngtsticks(f"/home/userzjj/ftp/{day}/NGTSTick") elif _type == 'ExtractDealBigOrder': # 命令模式 /home/userzjj/app/gp-server/l2_data_parser ExtractDealBigOrder 2025-05-09 # 根据code提取大单 if not code: # indexed_data = [f"/home/userzjj/ftp/{day}/NGTSTick", f"/home/userzjj/ftp/{day}/Transaction"] # # 新写法 # with Pool(processes=2) as pool: # pool.map(transaction_big_order_parser.extract_big_order_of_all, indexed_data) transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/NGTSTick", process_count=10) transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/Transaction", process_count=10) if len(params) > 2: process_count = int(params[2].strip()) else: if tool.is_sh_code(code): transaction_big_order_parser.extract_big_order_of_code(f"/home/userzjj/ftp/{day}/NGTSTick", code) else: transaction_big_order_parser.extract_big_order_of_code(f"/home/userzjj/ftp/{day}/Transaction", code) process_count = 10 transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/NGTSTick", process_count=process_count) transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/Transaction", process_count=process_count) l2_test.py
@@ -127,7 +127,7 @@ if k_bars and 10e8 <= k_bars[0]["close"] * volume * tool.get_limit_up_rate(code) <= 300e8: # 自由流通市值在10亿-300亿以上 limit_up_price = round(tool.get_limit_up_rate(code) * k_bars[0]["close"], 2) if limit_up_price > k_bars[0]["high"]: if limit_up_price > k_bars[0]["high"] or True: # 今日涨停价要突破昨日最高价 codes.add(code) # 获取辨识度的票 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], trade/buy_radical/radical_buy_data_manager.py
@@ -2180,7 +2180,6 @@ return datas return None def list_l2_big_order_deal_info(codes): """ 获取成交大单信息
