Administrator
2024-09-02 7d7988372c3aefb139ada38b12b2f0dae2a37ce0
bug修复
3个文件已修改
13 ■■■■ 已修改文件
l2/l2_data_manager_new.py 5 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
servers/huaxin_trade_server.py 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
third_data/code_plate_key_manager.py 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
l2/l2_data_manager_new.py
@@ -1,3 +1,4 @@
import copy
import logging
import threading
import time as t
@@ -951,6 +952,8 @@
            # 2.距离最近的非板上成交的时间大于一个阈值
            if abs(limit_up_price - float(trade_price)) < 0.001:
                latest_exec_indexes = cls.__latest_exec_indexes[code]
                if not latest_exec_indexes:
                    latest_exec_indexes = []
                # 判断是否是炸开后买入
                last_exec_index = 0
                if len(latest_exec_indexes) > 1:
@@ -1778,7 +1781,7 @@
                limit_up_sell_count = L2TradeSingleDataProcessor.get_latest_limit_up_sell_order_count(code)
                if (limit_up_sell_count == 0 or active_buy_blocks) and not single:
                    # 如果没有涨停卖数据/激进下单而且还没有成交买入信号,就按照原来的总卖额计算
                    threshold_money, sell_1_price = refer_sell_data[1], refer_sell_data[3][0]
                    threshold_money, sell_1_price = copy.deepcopy(refer_sell_data[1]), refer_sell_data[3][0]
                    for i in range(start_index - 1, -1, -1):
                        val = total_datas[i]["val"]
                        if tool.compare_time(val["time"], refer_sell_data[0]) < 0:
servers/huaxin_trade_server.py
@@ -789,6 +789,12 @@
                        if yesterday_codes is None:
                            yesterday_codes = set()
                        result = RadicalBuyBlockManager.is_radical_buy(code, yesterday_codes)
                        if result[0]:
                            if refer_sell_data[1] < 500 * 1e4:
                                async_log_util.info(logger_l2_radical_buy, f"不能扫:{code}-总卖额偏少{refer_sell_data[1]}/500w")
                            else:
                                async_log_util.info(logger_l2_radical_buy, f"可以扫:{result}")
                        async_log_util.info(logger_l2_radical_buy, f"计算板块结果:{code}-{result}")
                else:
                    volume_rate = code_volumn_manager.get_volume_rate(code)
third_data/code_plate_key_manager.py
@@ -1075,7 +1075,6 @@
                continue
            buy1_money = huaxin_l1_data_manager.get_buy1_money(code)
            # 买1是否大于5000w
            # TODO 测试
            if not constant.TEST:
                if not buy1_money or buy1_money < 5e7:
                    continue
@@ -1191,7 +1190,6 @@
        @return:
        """
        # 10点之前才能买入
        # TODO 测试
        if not constant.TEST:
            if int(tool.get_now_time_str().replace(":", "")) > 100000:
                return False, "超过生效时间"