| | |
| | | import json |
| | | |
| | | from db import redis_manager |
| | | from utils import tool |
| | | |
| | | redisManager = redis_manager.RedisManager(0) |
| | | |
| | |
| | | |
| | | |
| | | __L2_CODE_KEY = "huaxin_l2_code_list" |
| | | |
| | | __SUBSCRIPT_KEY = "huaxin_subscript_codes" |
| | | |
| | | |
| | | def clear(): |
| | |
| | | val = __get_redis().lpop(__L2_CODE_KEY) |
| | | if val: |
| | | return json.loads(val) |
| | | return val |
| | | return val |
| | | |
| | | |
| | | # 设置订阅代码 |
| | | def save_subscript_codes(codes): |
| | | __get_redis().setex(__SUBSCRIPT_KEY, tool.get_expire(), json.dumps(codes)) |
| | | |
| | | |
| | | # 获取订阅的代码 |
| | | def get_subscript_codes(): |
| | | val = __get_redis().get(__SUBSCRIPT_KEY) |
| | | if not val: |
| | | return [] |
| | | return json.loads(val) |