| Line 278... |
Line 278... |
| 278 |
|
278 |
|
| 279 |
|
279 |
|
| 280 |
def compute_recharge_collection(cdate):
|
280 |
def compute_recharge_collection(cdate):
|
| 281 |
todate = datetime.datetime(cdate.year, cdate.month, cdate.day)
|
281 |
todate = datetime.datetime(cdate.year, cdate.month, cdate.day)
|
| 282 |
tomorrow = todate + timedelta(days=1)
|
282 |
tomorrow = todate + timedelta(days=1)
|
| 283 |
|
- |
|
| 284 |
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()
|
283 |
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()
|
| 285 |
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()
|
284 |
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()
|
| 286 |
storeData = {}
|
285 |
storeData = {}
|
| 287 |
for txn in txns:
|
286 |
for txn in txns:
|
| 288 |
print txn
|
287 |
print txn
|
| 289 |
if not storeData.has_key(txn[0]):
|
288 |
if not storeData.has_key(txn[0]):
|
| 290 |
data = [0,0,0,0,0]
|
289 |
data = [0,0,0,0,0]
|
| Line 300... |
Line 299... |
| 300 |
data[3] += int(txn[4])
|
299 |
data[3] += int(txn[4])
|
| 301 |
data[4] += int(txn[3]) - int(txn[4])
|
300 |
data[4] += int(txn[3]) - int(txn[4])
|
| 302 |
storeData[txn[0]] = data
|
301 |
storeData[txn[0]] = data
|
| 303 |
|
302 |
|
| 304 |
|
303 |
|
| 305 |
reftxns = 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.responseTime.between(todate, tomorrow)).filter(not_(RechargeTransaction.transactionTime.between(todate, tomorrow)).group_by(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status).order_by(RechargeTransaction.storeId).all()
|
304 |
reftxns = 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.responseTime.between(todate, tomorrow)).filter(not_(RechargeTransaction.transactionTime.between(todate, tomorrow))).group_by(RechargeTransaction.storeId, RechargeTransaction.payMethod, RechargeTransaction.status).order_by(RechargeTransaction.storeId).all()
|
| 306 |
for txn in reftxns:
|
305 |
for txn in reftxns:
|
| 307 |
print txn
|
306 |
print txn
|
| 308 |
if not storeData.has_key(txn[0]):
|
307 |
if not storeData.has_key(txn[0]):
|
| 309 |
data = [0,0,0,0,0]
|
308 |
data = [0,0,0,0,0]
|
| 310 |
storeData[txn[0]] = data
|
309 |
storeData[txn[0]] = data
|