| | |
|---|
| | | latest_trade_delegate_data = [] |
|---|
| | | |
|---|
| | | |
|---|
| | | # 关闭购买入口 |
|---|
| | | # 开启购买入口 |
|---|
| | | class TradeStateManager: |
|---|
| | | """ |
|---|
| | | 交易状态管理（开启/关闭交易） |
|---|
| | | """ |
|---|
| | | __instance = None |
|---|
| | | __db = 12 |
|---|
| | | redisManager = redis_manager.RedisManager(12) |
|---|
| | |
|---|
| | | # 开启购买入口 |
|---|
| | | def open_buy(self): |
|---|
| | | self.__trade_buy_state_cache = True |
|---|
| | | RedisUtils.setex_async(self.__db, "trade_buy_state", tool.get_expire(), 1) |
|---|
| | | RedisUtils.setex_async(self.__db, "ls_trade_buy_state", tool.get_expire(), 1) |
|---|
| | | |
|---|
| | | # 关闭购买入口 |
|---|
| | | def close_buy(self): |
|---|
| | | self.__trade_buy_state_cache = False |
|---|
| | | RedisUtils.setex_async(self.__db, "trade_buy_state", tool.get_expire(), 0) |
|---|
| | | RedisUtils.setex_async(self.__db, "ls_trade_buy_state", tool.get_expire(), 0) |
|---|
| | | |
|---|
| | | # 是否可以下单 |
|---|
| | | @classmethod |
|---|
| | | def is_can_buy(cls): |
|---|
| | | # 默认设置为可交易 |
|---|
| | | val = RedisUtils.get(cls.__get_redis(), "trade_buy_state") |
|---|
| | | val = RedisUtils.get(cls.__get_redis(), "ls_trade_buy_state") |
|---|
| | | if val is None: |
|---|
| | | return True |
|---|
| | | if int(val) == 1: |
|---|
| | |
|---|
| | | __CodesTradeStateManager = CodesTradeStateManager() |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | PlatePlaceOrderManager().add_plates_code({"通信","计算机"}, "000333") |
|---|
| | | PlatePlaceOrderManager().add_plates_code({"通信", "计算机"}, "000333") |
|---|
| | | place_order_plate_codes = PlatePlaceOrderManager().get_plate_codes() |
|---|
| | | code_sets = [set(lst) for lst in place_order_plate_codes.values()] |
|---|
| | | # 2. 使用 set.union() 求并集 |
|---|
