策略优化，增加买1价格的影响

Administrator

2022-12-05 8218790ab15e752d982ee9c0df156ceea849c9a9

 trade_queue_manager.py

@@ -169,5 +169,36 @@
        return time_str, volumn


# 买1实时价格管理器
class Buy1PriceManager:
    __redisManager = redis_manager.RedisManager(0)

    def __init__(self):
        self.latest_prices = {}

    def __get_redis(self):
        return self.__redisManager.getRedis()

    def __save_recod(self, code, price):
        # 保存每一次的
        key = "buy1_price-{}".format(code)
        self.__get_redis().setex(key, tool.get_expire(), price)

    def __get_record(self, code):
        key = "buy1_price-{}".format(code)
        val = self.__get_redis().get(key)
        return val

    # 保存数据
    def save(self, code, price):
        if self.latest_prices.get(code) == price:
            return
        self.latest_prices[code] = price
        self.__save_recod(code, price)

    def get_price(self, code):
        return self.__get_record(code)


if __name__ == '__main__':
    JueJinBuy1VolumnManager().save("001203", "15:00:00", 40586553, 12.12)
    print( Buy1PriceManager().get_price("002644"))