消费订单通知

parent 1419a266
...@@ -76,14 +76,12 @@ def add_errorhandler(app): ...@@ -76,14 +76,12 @@ def add_errorhandler(app):
# resp = res.json() # resp = res.json()
# if resp['statusCode'] != "0000": # if resp['statusCode'] != "0000":
# request.user_id = resp['attributes'] # request.user_id = resp['attributes']
print('key', 's:sid:'+token)
user_id = redis.get('s:sid:'+token) user_id = redis.get('s:sid:'+token)
print('user_id', user_id)
if not user_id: if not user_id:
logging.error('鉴权失败,token:'+token) logging.error('鉴权失败,token:'+token)
raise CustomFlaskErr(Errors.TOKEN_INVALID) raise CustomFlaskErr(Errors.TOKEN_INVALID)
if isinstance(user_id, bytes): if isinstance(user_id, bytes):
request.user_id = user_id.decode().replace('"', '') request.user_id = user_id.decode().replace('"', '')
else: else:
request.user_id = user_id.replace('"', '') request.user_id = user_id.replace('"', '')
request.return_success = {'statusCode': "0000", 'message': 'ok'} request.return_success = {'statusCode': "0000", 'message': 'ok'}
......
...@@ -65,7 +65,6 @@ class TopUpOrderService: ...@@ -65,7 +65,6 @@ class TopUpOrderService:
args['ab_status'] = 'WAIT' args['ab_status'] = 'WAIT'
subject = '探普币充值' subject = '探普币充值'
out_trade_no = args['ab_ordernum'] out_trade_no = args['ab_ordernum']
# notify_url = args['host_url'] + 'tamp_order/micro_shop/topUpOrderNotify'
notify_url = config[env]['pay_url_prefix'] + '/tamp_order/micro_shop/topUpOrderNotify' notify_url = config[env]['pay_url_prefix'] + '/tamp_order/micro_shop/topUpOrderNotify'
pay_params = None pay_params = None
if args['pay_method'] == 5: if args['pay_method'] == 5:
...@@ -183,8 +182,7 @@ class CurriculumOrderService: ...@@ -183,8 +182,7 @@ class CurriculumOrderService:
args['ab_status'] = 'WAIT' args['ab_status'] = 'WAIT'
subject = args.get('prod_name', '') subject = args.get('prod_name', '')
out_trade_no = args['ab_ordernum'] out_trade_no = args['ab_ordernum']
# notify_url = args['host_url'] + 'tamp_order/micro_shop/consumeOrderNotify' notify_url = config[env]['pay_url_prefix'] + '/tamp_order/micro_shop/consumeOrderNotify'
notify_url = config[env]['pay_url_prefix'] + 'tamp_order/micro_shop/consumeOrderNotify'
pay_params = None pay_params = None
# 该用户是否重复购买同一商品 # 该用户是否重复购买同一商品
repeat_buy = tamp_user_session.query(OrderFlow.id).filter(and_(OrderFlow.createby == args['user_id']), repeat_buy = tamp_user_session.query(OrderFlow.id).filter(and_(OrderFlow.createby == args['user_id']),
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment