扫过的单可继续扫/扫了未成交遵循顺位机制/唯一涨停原因的高位板要计算其身位

Administrator

2024-11-11 36367e32a8c00cbbacb2cc7f7a09adde3e0cfaa9

 trade/buy_open_limit_up_strategy.py

@@ -39,14 +39,15 @@
                val = json.loads(val)
                cls.__place_order_info_dict[code] = val

    def set_place_order_info(self, code, volume, shadow_volume):
    def set_place_order_info(self, code, volume, shadow_volume, order_ref):
        """
        @param order_ref: 下单索引
        @param code:
        @param volume:
        @param shadow_volume:
        @return:
        """
        self.__place_order_info_dict[code] = (volume, shadow_volume)
        self.__place_order_info_dict[code] = (volume, shadow_volume, order_ref)
        RedisUtils.set_async(self.__db, f"buy_open_limit_up_placing_orderinfo-{code}", tool.get_expire(),
                             json.dumps(self.__place_order_info_dict[code]))

@@ -54,6 +55,12 @@
        """
        获取下单信息
        @param code:
        @return:(下单量, 影子单量)
        @return:(下单量, 影子单量, 订单索引)
        """
        return self.__place_order_info_dict.get(code)

    def remove_place_order_info(self, code):
        if code in self.__place_order_info_dict:
            self.__place_order_info_dict.pop(code)
            RedisUtils.delete_async(self.__db, f"buy_open_limit_up_placing_orderinfo-{code}")