根据板块移除L2

Administrator

2023-08-29 de4e585d74e6df9856796d4bc9623950a2d6e32a

根据板块移除L2

 third_data/code_plate_key_manager.py

@@ -419,6 +419,15 @@
    __CodesTradeStateManager = trade_manager.CodesTradeStateManager()
    __can_buy_compute_result_dict = {}

    @classmethod
    def __remove_from_l2(cls, code, msg):
        # 下过单的代码不移除
        if trade_manager.CodesTradeStateManager().get_trade_state_cache(code) != trade_manager.TRADE_STATE_NOT_TRADE:
            # 只要下过单的就不移除
            return
        l2_trade_util.forbidden_trade(code)
        logger_kpl_block_can_buy.info(msg)

    # 获取可以买的板块
    # current_limit_up_datas: 今日实时涨停
    # latest_2_day_limit_up_datas：最近2天的实时涨停（不含今日）
@@ -493,9 +502,7 @@
                        continue
                    else:
                        if record_shsz_rank >= len(pen_limit_up_codes) + 1:
                            logger_kpl_block_can_buy.info(f"{code}根据身位禁止买入：【{block}】历史身位{record_shsz_rank}")
                            # 今日已经不可能买的票，直接加入黑名单
                            l2_trade_util.forbidden_trade(code)
                            cls.__remove_from_l2(code, f"{code}根据身位禁止买入：【{block}】历史身位{record_shsz_rank}")
                        msg_list.append(
                            f"板块-{block}: top4涨停板块，主板开1（{pen_limit_up_codes}）,不为主板前龙{len(pen_limit_up_codes) + 1}（实时身位-{current_shsz_rank},历史身位-{record_shsz_rank}）")
                        continue
@@ -505,9 +512,7 @@
                        continue
                    else:
                        if record_shsz_rank >= 2:
                            logger_kpl_block_can_buy.info(f"{code}根据身位禁止买入：【{block}】历史身位{record_shsz_rank}")
                            # 今日已经不可能买的票，直接加入黑名单
                            l2_trade_util.forbidden_trade(code)
                            cls.__remove_from_l2(code, f"{code}根据身位禁止买入：【{block}】历史身位{record_shsz_rank}")

                        msg_list.append(
                            f"板块-{block}: top4涨停板块，非主板开1,不为主板龙1（实时身位-{current_shsz_rank},历史身位-{record_shsz_rank}）")

 trade/huaxin/trade_server.py

@@ -713,7 +713,8 @@
            try:
                can_access = huaxin_trade_api.test_trade_channel()
                fdata["trade_channel_access"] = 1 if can_access else 0
            except:
            except Exception as e:
                logger_debug.exception(e)
                fdata["trade_channel_access"] = 0

            result = {"code": 0, "data": fdata, "msg": ""}