订阅修改

Administrator

2024-12-04 b190e8942bb9d174a652999faf0e570701d28e2d

 trade/current_price_process_manager.py

@@ -94,6 +94,7 @@
        _code_list = []
        _delete_list = []
        temp_prices = []
        now_time_int = tool.get_now_time_as_int()
        for d in prices:
            code, price = d["code"], float(d["price"])
            temp_prices.append((code, price))
@@ -102,13 +103,20 @@
            if pricePre is not None:
                # 是否是想买单
                order_index = __compute_code_order(code, top_in_blocks, yesterday_limit_up_codes, today_history_limit_up_codes)

                rate = round((price - pricePre) * 100 / pricePre, 2)
                if tool.is_ge_code(code):
                    # 创业板的涨幅需要打折
                    rate = rate / 2
                if order_index >= 0:
                    _code_list.append((rate, code, order_index))
                    if now_time_int < 150000:
                        if order_index < 1000:
                            # 10点之前只订阅有效代码
                            _code_list.append((rate, code, order_index))
                        else:
                            _delete_list.append((rate, code, 0))
                    else:
                        # 10点之后常规订阅
                        _code_list.append((rate, code, order_index))
                else:
                    # 暂存涨幅为负的代码
                    _delete_list.append((rate, code, 0))