diff --git a/check_redis.py b/check_redis.py index 5da492a..d91018c 100644 --- a/check_redis.py +++ b/check_redis.py @@ -3,8 +3,6 @@ from myredis.myredis import my_redis def main(): - # key = '1066' - # ad::2001::6001::1::1063 ad::{\d+}::{\d+}::{\d}::{\d+} all_keys = my_redis.keys() ads_list = [] if all_keys: diff --git a/handler/priv_map.py b/handler/priv_map.py index 8b9d18a..13a8ba6 100644 --- a/handler/priv_map.py +++ b/handler/priv_map.py @@ -12,12 +12,11 @@ import json log = logging.getLogger(__name__) import pdb parser = reqparse.RequestParser() -parser.add_argument('id') +parser.add_argument('mapid') parser.add_argument('user') parser.add_argument('url') parser.add_argument('args') - class PrivMaps(Resource): def __init__(self): self.args = parser.parse_args() @@ -25,22 +24,12 @@ class PrivMaps(Resource): def get(self): - try: - myargs = json.loads(my_unquote(self.args['args'])) - except Exception: - log.error(f"get args failed!", exc_info=True) - args = {} - myargs = None - if myargs: - users = myargs.get('args', None) - status = myargs.get('status', 0) - else: - users = None - status = 0 + users = self.args['users'] + status = self.args['status'] all_data = [] try: if users: - sql = f"select user,mapid,url,status from mymaps where user={users};" + sql = f"select user,mapid,url,status from mymaps where user='{users}';" elif status: sql = f"select user,mapid,url,status from mymaps where status={status};" else: @@ -59,18 +48,18 @@ class PrivMaps(Resource): log.info(f"{data} not found in mysql !") return jsonify({'code': 200, 'message': []}) except Exception: - log.error(f"get maps via args={args} failed! ", exc_info=True) + log.error(f"get maps via args={self.args} failed! ", exc_info=True) return jsonify({'code': 500}) return jsonify({'code': 200, 'message': all_data}) def delete(self): - myargs = my_unquote(self.args['args']) + mapid = self.args['mapid'] try: - del_sql = f"update mymaps set status=0 where mapid={myargs['mapid']};" + del_sql = f"update mymaps set status=0 where mapid={mapid};" self.mydb.change(del_sql) return jsonify({'code': 200}) except Exception: - log.error(f"remove {myargs} failed!", exc_info=True) + log.error(f"remove {self.args} failed!", exc_info=True) return jsonify({'code': 500}) @@ -88,6 +77,9 @@ class PrivMaps(Resource): def post(self): + print(self.args) + pdb.set_trace() + mapid = self.args['mapid'] # log.info(f"args={self.args}") myargs = json.loads(my_unquote(self.args['args'])) log.info(f"2={myargs}") diff --git a/ops/reflush_ad.py b/ops/reflush_ad.py new file mode 100644 index 0000000..9be4ee0 --- /dev/null +++ b/ops/reflush_ad.py @@ -0,0 +1,44 @@ +# -*- coding: utf-8 -*- +from myredis.myredis import my_redis +from mysql.mmysql import MysqlBase +from prod_config import mysql_promotion_config +from log.mylog import define_logger +import logging + + +define_logger("/data/logs/reflush_ad.log") +log = logging.getLogger(__name__) + + +class Reflush_AdInfo(): + def __init__(self): + self.myredis = my_redis + self.mysql = MysqlBase(**mysql_promotion_config) + + def reflush_ad_via_localtionid(self, locationid): + all = self.myredis.keys() + change_key = [] + if all: + for one_key in all: + if len(one_key.split("::")) > 3 and one_key.split("::")[-1] == locationid: + change_key.append(one_key) + else: + raise Exception("Redis is null!") + + for item in change_key: + pass + + + self.reflush_ad(item) + + + def reflush_ad(self, adid): + pass + + +def main(): + pass + + +if __name__ == "__main__": + main()