| Line 13... |
Line 13... |
| 13 |
from shop2020.model.v1.order.impl import DataService, RechargeService
|
13 |
from shop2020.model.v1.order.impl import DataService, RechargeService
|
| 14 |
from shop2020.model.v1.order.impl.DataService import RechargeTransaction
|
14 |
from shop2020.model.v1.order.impl.DataService import RechargeTransaction
|
| 15 |
from shop2020.model.v1.order.impl.model.RechargeOrder import RechargeOrder
|
15 |
from shop2020.model.v1.order.impl.model.RechargeOrder import RechargeOrder
|
| 16 |
|
16 |
|
| 17 |
def processRechargeTransactions(deltaTime):
|
17 |
def processRechargeTransactions(deltaTime):
|
| 18 |
#Lets first get all recharge unknown orders irrespective of recharge mode in 30 minutes time window
|
18 |
#Lets first get all recharge unknown orders irrespective of recharge mode in delta minutes time window
|
| 19 |
try:
|
19 |
try:
|
| 20 |
timeFilter = datetime.now() -timedelta(minutes=deltaTime)
|
20 |
timeFilter = datetime.now() -timedelta(minutes=deltaTime)
|
| 21 |
unknownOrders = RechargeTransaction.query.filter(RechargeTransaction.status == RechargeOrderStatus.RECHARGE_UNKNOWN).filter(RechargeTransaction.transactionTime >=timeFilter).all()
|
21 |
unknownOrders = RechargeTransaction.query.filter(RechargeTransaction.status.in_([RechargeOrderStatus.RECHARGE_UNKNOWN, RechargeOrderStatus.INIT])).filter(RechargeTransaction.transactionTime >=timeFilter).all()
|
| 22 |
for unknownOrder in unknownOrders:
|
22 |
for unknownOrder in unknownOrders:
|
| 23 |
try:
|
23 |
try:
|
| 24 |
status, description = RechargeService.checkTransactionStatus('', str(unknownOrder.id))
|
24 |
status, description = RechargeService.checkTransactionStatus('', str(unknownOrder.id))
|
| 25 |
print status, description
|
25 |
print status, description
|
| 26 |
if status:
|
26 |
if status:
|
| Line 53... |
Line 53... |
| 53 |
print "Still unknown"
|
53 |
print "Still unknown"
|
| 54 |
finally:
|
54 |
finally:
|
| 55 |
session.close()
|
55 |
session.close()
|
| 56 |
|
56 |
|
| 57 |
def processRechargeOrders(deltaTime):
|
57 |
def processRechargeOrders(deltaTime):
|
| 58 |
#Lets first get all payment successful orders irrespective of recharge mode in 30 minutes time window
|
58 |
#Lets first get all payment successful orders irrespective of recharge mode in delta minutes time window
|
| 59 |
try:
|
59 |
try:
|
| 60 |
timeFilter = datetime.now() -timedelta(minutes=deltaTime)
|
60 |
timeFilter = datetime.now() -timedelta(minutes=deltaTime)
|
| 61 |
paymentSuccessfulOrders = RechargeOrder.query.filter(RechargeOrder.status == RechargeOrderStatus.PAYMENT_SUCCESSFUL).filter(RechargeOrder.creationTimestamp >=timeFilter).all()
|
61 |
paymentSuccessfulOrders = RechargeOrder.query.filter(RechargeOrder.status == RechargeOrderStatus.PAYMENT_SUCCESSFUL).filter(RechargeOrder.creationTimestamp >=timeFilter).all()
|
| 62 |
for paymentSuccessfulOrder in paymentSuccessfulOrders:
|
62 |
for paymentSuccessfulOrder in paymentSuccessfulOrders:
|
| 63 |
try:
|
63 |
try:
|