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-08 19:53:49 +08:00
parent 314a17faef
commit 5d0d0ac816
1 changed files with 21 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
handler/company.py
View File

@ -80,11 +80,11 @@ class Company(Resource):
company['appid'] = args['appid'] company['appid'] = args['appid']
company['appkey'] = args['appkey'] company['appkey'] = args['appkey']
# insert to mysql # insert to mysql
#update_sql = f"update company set id='{company['id']}',name='{company['name']}',contact='{company[ # update_sql = f"update company set id='{company['id']}',name='{company['name']}',contact='{company[
# 'contact']}',appid='{company['appid']}',appkey='{company['appkey']}' where id='{comp_id}';" # 'contact']}',appid='{company['appid']}',appkey='{company['appkey']}' where id='{comp_id}';"
condition=f"id='{comp_id}'" condition = f"id='{comp_id}'"
#log.info(f"update sql was {update_sql}") # log.info(f"update sql was {update_sql}")
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)
@ -102,11 +102,21 @@ class CompanyList(Resource):
return jsonify({'code': 1, 'body': company_redis.lrang("ALL_Company", 0, -1)}) return jsonify({'code': 1, 'body': company_redis.lrang("ALL_Company", 0, -1)})
def post(self): def post(self):
args = parser.parse_args() companys = self.get_company()
log.info(f"args was {args}") if companys:
try: return jsonify({'code': 1, 'body': companys})
company_redis.rpush("ALL_Company", args['company']) else:
except Exception:
log.error("Insert values to redis failed,args was {}!".format(args), exc_info=True)
return jsonify({'code': 0}) return jsonify({'code': 0})
return jsonify({'code': 1})
def get_company(self):
sel_sql = "select id from company where 1;"
data = mydb.query(sel_sql)
company_list = []
if data:
for item in data:
try:
company_list.append(item[0])
except Exception:
log.error("split data from db failed!", exc_info=True)
return company_list