Archived
Move some stuff around
This commit is contained in:
1 parent
9026386c01
commit
4c0e216682
1 file changed
+16
-12
+16
-12
@@ -214,7 +214,10 @@ def notify_valid_membership(incoming_id=None, number=None, user=None):
|
|||||||
assert user
|
assert user
|
||||||
|
|
||||||
name = get_inside().get_full_name(user)
|
name = get_inside().get_full_name(user)
|
||||||
expires = 'verdens undergang' if user.get('expires_lifelong') else str(user.get('expires'))
|
if user.get('expires_lifelong'):
|
||||||
|
expires = 'verdens undergang'
|
||||||
|
else:
|
||||||
|
expires = str(user.get('expires'))
|
||||||
|
|
||||||
content = u"Hei %(name)s! Ditt medlemskap er gyldig til %(expires)s. Last ned app: %(app)s" % ({
|
content = u"Hei %(name)s! Ditt medlemskap er gyldig til %(expires)s. Last ned app: %(app)s" % ({
|
||||||
'name': name,
|
'name': name,
|
||||||
@@ -410,7 +413,8 @@ def inside_code_purchase_date():
|
|||||||
purchase_date = get_activation_code_purchase_date(number, activation_code)
|
purchase_date = get_activation_code_purchase_date(number, activation_code)
|
||||||
|
|
||||||
app.logger.info(
|
app.logger.info(
|
||||||
'Checked purchase date for number:%s activation_code:%s purchase_date:%s',
|
'Inside checked purchase date for '
|
||||||
|
'number:%s activation_code:%s purchase_date:%s',
|
||||||
number, activation_code, purchase_date)
|
number, activation_code, purchase_date)
|
||||||
|
|
||||||
return purchase_date or ''
|
return purchase_date or ''
|
||||||
@@ -418,7 +422,7 @@ def inside_code_purchase_date():
|
|||||||
|
|
||||||
@app.route('/sendega-incoming')
|
@app.route('/sendega-incoming')
|
||||||
def incoming():
|
def incoming():
|
||||||
args = {'ip': request.remote_addr}
|
args = {'ip': request.headers.get('X-Real-IP') or request.remote_addr}
|
||||||
|
|
||||||
for key in ('msgid', 'msisdn', 'msg', 'mms', 'mmsdata', 'shortcode',
|
for key in ('msgid', 'msisdn', 'msg', 'mms', 'mmsdata', 'shortcode',
|
||||||
'mcc', 'mnc', 'pricegroup', 'keyword', 'keywordid',
|
'mcc', 'mnc', 'pricegroup', 'keyword', 'keywordid',
|
||||||
@@ -482,37 +486,37 @@ def incoming():
|
|||||||
|
|
||||||
@app.route('/sendega-dlr')
|
@app.route('/sendega-dlr')
|
||||||
def dlr():
|
def dlr():
|
||||||
args = {}
|
args = {'ip': request.headers.get('X-Real-IP') or request.remote_addr}
|
||||||
real_ip = request.headers.get('X-Real-IP')
|
|
||||||
args['ip'] = real_ip or request.remote_addr
|
|
||||||
|
|
||||||
for key in ('msgid', 'extID', 'msisdn', 'status', 'statustext',
|
for key in ('msgid', 'extID', 'msisdn', 'status', 'statustext',
|
||||||
'registered', 'sent', 'delivered',
|
'registered', 'sent', 'delivered',
|
||||||
'errorcode', 'errormessage', 'operatorerrorcode'):
|
'errorcode', 'errormessage', 'operatorerrorcode'):
|
||||||
args[key] = request.args.get(key)
|
args[key] = request.args.get(key)
|
||||||
|
|
||||||
|
app.logger.debug("Dlr, args: %s", args)
|
||||||
|
|
||||||
dlr_id = log_dlr(**args)
|
dlr_id = log_dlr(**args)
|
||||||
|
|
||||||
# We need to check what the original message was all about
|
# We need to check what the original message was all about
|
||||||
incoming_id = args['extID']
|
incoming_id = args['extID']
|
||||||
|
|
||||||
|
success = (args['statustext'] == 'delivered')
|
||||||
|
if not success:
|
||||||
|
return notify_could_not_charge(
|
||||||
|
incoming_id=incoming_id, dlr_id=dlr_id, number=args['msisdn'])
|
||||||
|
|
||||||
event = query_db("""
|
event = query_db("""
|
||||||
SELECT * FROM event
|
SELECT * FROM event
|
||||||
WHERE incoming_id=%s
|
WHERE incoming_id=%s
|
||||||
AND action IN ('new_membership', 'renew_membership')
|
AND action IN ('new_membership', 'renew_membership')
|
||||||
""", incoming_id, one=True)
|
""", [incoming_id], one=True)
|
||||||
|
|
||||||
if not event:
|
if not event:
|
||||||
app.logger.error('Got an unknown delivery report, dlr_id=%s', dlr_id)
|
app.logger.error('Got an unknown delivery report, dlr_id=%s', dlr_id)
|
||||||
return 'what'
|
return 'what'
|
||||||
|
|
||||||
success = (args['status'] == 4)
|
|
||||||
action = event['action']
|
action = event['action']
|
||||||
|
|
||||||
if not success:
|
|
||||||
return notify_could_not_charge(
|
|
||||||
incoming_id=incoming_id, dlr_id=dlr_id, number=args['msisdn'])
|
|
||||||
|
|
||||||
if action == 'renew_membership':
|
if action == 'renew_membership':
|
||||||
return renew_membership_delivered(
|
return renew_membership_delivered(
|
||||||
incoming_id=incoming_id, dlr_id=dlr_id, user_id=event['user_id'])
|
incoming_id=incoming_id, dlr_id=dlr_id, user_id=event['user_id'])
|
||||||
|
|||||||
Reference in new issue
Block a user