ops/promotion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add ad

Browse Source
This commit is contained in:
pengtao 2019-07-09 11:14:51 +08:00
parent 4caa1bb47b
commit d243080d5f
1 changed files with 16 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
handler/company.py
View File

@ -20,35 +20,30 @@ parser.add_argument('appid')
parser.add_argument('appkey') parser.add_argument('appkey')
parser.add_argument('status') parser.add_argument('status')
# # 操作（put / get / delete）单一资源Todo # # 操作（put / get / delete）单一资源Todo
# shows a single todo item and lets you delete a todo item # shows a single todo item and lets you delete a todo item
class Company(Resource): class Company(Resource):
def get(self, comp_id): def get(self, comp_id):
try: try:
data = company_redis.hmget(comp_id, ['id', 'name', 'contact', 'appid', 'appkey']) sql = f"select id,name,contact,appid,appkey,status from company where id={comp_id};"
log.info(f"get data from redis was {data}") data = mydb.query(sql)
_,name,_,_,_=data
if not name:
sql = f"select id,name,contact,appid,appkey from company where id={comp_id};"
data = mydb.query(sql)
log.info(f"get data from db was {data}") log.info(f"get data from db was {data}")
if data: if data:
company = {} company = {}
company['id'], company['name'], company['contact'], company['appid'], company['appkey'] = data[0] company['id'], company['name'], company['contact'], company['appid'], company['appkey'],company['status'] = \
company_redis.hmset(company['id'], company) data[0]
company_redis.expire(company['id'], expire_time) else:
else: log.error(f"{comp_id} not found in mysql !")
log.error(f"{comp_id} not found in mysql !") return jsonify({'code': 404})
return jsonify({'code': 404})
except Exception: except Exception:
log.error(f"get company id {comp_id} failed! ", exc_info=True) log.error(f"get company id {comp_id} failed! ", exc_info=True)
return jsonify({'code': 500}) return jsonify({'code': 500})
return jsonify({'code': 200, 'body': data}) return jsonify({'code': 200, 'body': company})
def delete(self, comp_id): def delete(self, comp_id):
try: try:
company_redis.expire(comp_id, 0)
del_sql = f'delete from company where id={comp_id};' del_sql = f'delete from company where id={comp_id};'
mydb.query(del_sql) mydb.query(del_sql)
except Exception: except Exception:
@ -68,8 +63,8 @@ class Company(Resource):
# insert to mysql # insert to mysql
mydb.insert("company", company) mydb.insert("company", company)
# insert to redsi # insert to redsi
company_redis.hmset(company['id'], company) # company_redis.hmset(company['id'], company)
company_redis.expire(company['id'], expire_time) # company_redis.expire(company['id'], expire_time)
except Exception: except Exception:
log.error("set values to company mysql/redis failed!", exc_info=True) log.error("set values to company mysql/redis failed!", exc_info=True)
return jsonify({'code': 500}) return jsonify({'code': 500})
@ -93,8 +88,8 @@ class Company(Resource):
mydb.update("company", company, condition) mydb.update("company", company, condition)
# update redsi # update redsi
company_redis.hmset(company['id'], company) # company_redis.hmset(company['id'], company)
company_redis.expire(company['id'], expire_time) # company_redis.expire(company['id'], expire_time)
except Exception: except Exception:
log.error("update values to company redis,mysql failed!", exc_info=True) log.error("update values to company redis,mysql failed!", exc_info=True)
return jsonify({'code': 500}) return jsonify({'code': 500})