| | |
| | | |
| | | @classmethod |
| | | def add_code(cls, code): |
| | | cls.__get_redis().sadd(cls.__key,code) |
| | | cls.__get_redis().sadd(cls.__key, code) |
| | | |
| | | @classmethod |
| | | def remove_code(cls, code): |
| | |
| | | @classmethod |
| | | def clear(cls): |
| | | cls.__get_redis().delete(cls.__key) |
| | | |
| | | |
| | | |
| | | # 获取交易状态 |
| | |
| | | if keys is not None: |
| | | for key in keys: |
| | | if int(redis.get(key)) == state: |
| | | codes.append(key.replace("trade-state-", '')) |
| | | return codes |
| | | |
| | | |
| | | def get_codes_by_trade_states(states): |
| | | redis = __redis_manager.getRedis() |
| | | keys = redis.keys("trade-state-*") |
| | | codes = [] |
| | | if keys is not None: |
| | | for key in keys: |
| | | if int(redis.get(key)) in states: |
| | | codes.append(key.replace("trade-state-", '')) |
| | | return codes |
| | | |
| | |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | set_trade_state("002351",TRADE_STATE_BUY_DELEGATED) |
| | | set_trade_state("002351", TRADE_STATE_BUY_DELEGATED) |