redis批量提交数据

Administrator

2023-08-07 8c614ff9f44dd055c915d990b9999c69346b01c8

redis批量提交数据

 trade/current_price_process_manager.py

@@ -39,11 +39,11 @@
    if True:
        _code_list = []
        _delete_list = []
        prices = []
        rates = []
        temp_prices = []
        temp_rates = []
        for d in prices:
            code, price = d["code"], float(d["price"])
            prices.append((code, price))
            temp_prices.append((code, price))
            # 获取收盘价
            pricePre = gpcode_manager.CodePrePriceManager.get_price_pre_cache(code)
            if pricePre is not None:
@@ -57,7 +57,7 @@
                    # 暂存涨幅为负的代码
                    _delete_list.append((rate, code, 0))
                try:
                    rates.append((code, rate))
                    temp_rates.append((code, rate))
                except Exception as e:
                    logging.exception(e)

@@ -68,8 +68,8 @@
                                                                  decimal.Decimal(d["price"])))
                except Exception as e:
                    logging.exception(e)
        gpcode_manager.set_prices(prices)
        __actualPriceProcessor.process_rates(rates, now_str)
        gpcode_manager.set_prices(temp_prices)
        __actualPriceProcessor.process_rates(temp_rates, now_str)
        # -------------------------------处理交易位置分配---------------------------------
        # 排序
        new_code_list = sorted(_code_list, key=lambda e: (e.__getitem__(2), e.__getitem__(0)), reverse=True)