| Line 373... |
Line 373... |
| 373 |
isStoreOrder = True
|
373 |
isStoreOrder = True
|
| 374 |
amount = order.amount
|
374 |
amount = order.amount
|
| 375 |
if order.status == RechargeOrderStatus.RECHARGE_FAILED_REFUNDED:
|
375 |
if order.status == RechargeOrderStatus.RECHARGE_FAILED_REFUNDED:
|
| 376 |
print "Refund is already processed."
|
376 |
print "Refund is already processed."
|
| 377 |
continue
|
377 |
continue
|
| 378 |
if order.status not in (RechargeOrderStatus.RECHARGE_SUCCESSFUL, RechargeOrderStatus.PAYMENT_SUCCESSFUL, RechargeOrderStatus.RECHARGE_UNKNOWN):
|
378 |
if order.status not in (RechargeOrderStatus.RECHARGE_SUCCESSFUL, RechargeOrderStatus.PAYMENT_SUCCESSFUL, RechargeOrderStatus.RECHARGE_UNKNOWN, RechargeOrderStatus.RECHARGE_IN_PROCESS):
|
| 379 |
print "Recharge/Payment is not successful. There is something wrong."
|
379 |
print "Recharge/Payment is not successful. There is something wrong."
|
| 380 |
continue
|
380 |
continue
|
| 381 |
if amount != refundAmount:
|
381 |
if amount != refundAmount:
|
| 382 |
print "Refund amount is not same as transaction amount"
|
382 |
print "Refund amount is not same as transaction amount"
|
| 383 |
continue
|
383 |
continue
|
| Line 397... |
Line 397... |
| 397 |
update_recharge_order_status(order.id, RechargeOrderStatus.RECHARGE_SUCCESSFUL)
|
397 |
update_recharge_order_status(order.id, RechargeOrderStatus.RECHARGE_SUCCESSFUL)
|
| 398 |
else:
|
398 |
else:
|
| 399 |
update_recharge_order_status(order.id, RechargeOrderStatus.RECHARGE_FAILED)
|
399 |
update_recharge_order_status(order.id, RechargeOrderStatus.RECHARGE_FAILED)
|
| 400 |
except:
|
400 |
except:
|
| 401 |
print "Do Nothing"
|
401 |
print "Do Nothing"
|
| - |
|
402 |
|
| - |
|
403 |
inprocessOrders = RechargeTransaction.query.filter(RechargeTransaction.status == RechargeOrderStatus.RECHARGE_IN_PROCESS).all()
|
| - |
|
404 |
for inprocessOrder in inprocessOrders:
|
| - |
|
405 |
inprocessOrder.status = RechargeOrderStatus.RECHARGE_UNKNOWN
|
| - |
|
406 |
session.commit()
|
| 402 |
|
407 |
|
| 403 |
## For store transactions
|
408 |
## For store transactions
|
| 404 |
rorders = RechargeTransaction.query.filter(RechargeTransaction.status.in_([RechargeOrderStatus.RECHARGE_UNKNOWN, RechargeOrderStatus.INIT])).all()
|
409 |
rorders = RechargeTransaction.query.filter(RechargeTransaction.status.in_([RechargeOrderStatus.RECHARGE_UNKNOWN, RechargeOrderStatus.INIT])).all()
|
| 405 |
for order in rorders:
|
410 |
for order in rorders:
|
| 406 |
try:
|
411 |
try:
|
| 407 |
if order.transactionTime + datetime.timedelta(minutes=10) < datetime.datetime.now():
|
412 |
if order.transactionTime + datetime.timedelta(minutes=10) < datetime.datetime.now():
|
| Line 422... |
Line 427... |
| 422 |
|
427 |
|
| 423 |
|
428 |
|
| 424 |
def compute_recharge_collection(cdate):
|
429 |
def compute_recharge_collection(cdate):
|
| 425 |
todate = datetime.datetime(cdate.year, cdate.month, cdate.day)
|
430 |
todate = datetime.datetime(cdate.year, cdate.month, cdate.day)
|
| 426 |
tomorrow = todate + timedelta(days=1)
|
431 |
tomorrow = todate + timedelta(days=1)
|
| 427 |
txns = session.query(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status, func.sum(RechargeTransaction.amount), func.sum(RechargeTransaction.discount)).filter(RechargeTransaction.status.in_([RechargeOrderStatus.RECHARGE_SUCCESSFUL, RechargeOrderStatus.RECHARGE_UNKNOWN])).filter(RechargeTransaction.transactionTime.between(todate, tomorrow)).group_by(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status).order_by(RechargeTransaction.storeId).all()
|
432 |
txns = session.query(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status, func.sum(RechargeTransaction.amount), func.sum(RechargeTransaction.discount)).filter(RechargeTransaction.status.in_([RechargeOrderStatus.RECHARGE_SUCCESSFUL, RechargeOrderStatus.RECHARGE_UNKNOWN, RechargeOrderStatus.RECHARGE_IN_PROCESS])).filter(RechargeTransaction.transactionTime.between(todate, tomorrow)).group_by(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status).order_by(RechargeTransaction.storeId).all()
|
| 428 |
txns = txns + session.query(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status, func.sum(RechargeTransaction.amount), func.sum(RechargeTransaction.discount)).filter(RechargeTransaction.status.in_([RechargeOrderStatus.RECHARGE_FAILED, RechargeOrderStatus.RECHARGE_FAILED_REFUNDED])).filter(RechargeTransaction.transactionTime.between(todate, tomorrow)).filter(not_(RechargeTransaction.responseTime.between(todate, tomorrow))).group_by(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status).order_by(RechargeTransaction.storeId).all()
|
433 |
txns = txns + session.query(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status, func.sum(RechargeTransaction.amount), func.sum(RechargeTransaction.discount)).filter(RechargeTransaction.status.in_([RechargeOrderStatus.RECHARGE_FAILED, RechargeOrderStatus.RECHARGE_FAILED_REFUNDED])).filter(RechargeTransaction.transactionTime.between(todate, tomorrow)).filter(not_(RechargeTransaction.responseTime.between(todate, tomorrow))).group_by(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status).order_by(RechargeTransaction.storeId).all()
|
| 429 |
storeData = {}
|
434 |
storeData = {}
|
| 430 |
for txn in txns:
|
435 |
for txn in txns:
|
| 431 |
print txn
|
436 |
print txn
|
| 432 |
if not storeData.has_key(txn[0]):
|
437 |
if not storeData.has_key(txn[0]):
|