| Line 1311... |
Line 1311... |
| 1311 |
else:
|
1311 |
else:
|
| 1312 |
for offer in offers:
|
1312 |
for offer in offers:
|
| 1313 |
appOfferObj = AppOfferObj(offer[0], offer[1], offer[2], offer[3], offer[4], offer[5], offer[6], offer[7], offer[8], offer[9], offer[10], offer[11], offer[12], offer[13], offer[14], offer[15], offer[16], offer[17], offer[18], offer[19])
|
1313 |
appOfferObj = AppOfferObj(offer[0], offer[1], offer[2], offer[3], offer[4], offer[5], offer[6], offer[7], offer[8], offer[9], offer[10], offer[11], offer[12], offer[13], offer[14], offer[15], offer[16], offer[17], offer[18], offer[19])
|
| 1314 |
offersJsonArray.append(todict(appOfferObj))
|
1314 |
offersJsonArray.append(todict(appOfferObj))
|
| 1315 |
|
1315 |
|
| 1316 |
if session.is_active:
|
- |
|
| 1317 |
print "session is active. closing it."
|
- |
|
| 1318 |
session.close()
|
1316 |
session.close()
|
| 1319 |
resp.body = json.dumps({"AppOffers":offersJsonArray}, encoding='latin1' )
|
1317 |
resp.body = json.dumps({"AppOffers":offersJsonArray}, encoding='latin1' )
|
| 1320 |
|
1318 |
|
| 1321 |
class AppUserBatchRefund():
|
1319 |
class AppUserBatchRefund():
|
| 1322 |
def on_get(self, req, resp, batchId, userId):
|
1320 |
def on_get(self, req, resp, batchId, userId):
|
| 1323 |
batchId = long(batchId)
|
1321 |
batchId = long(batchId)
|
| 1324 |
userId = long(userId)
|
1322 |
userId = long(userId)
|
| 1325 |
userBatchCashback = user_app_cashbacks.get_by(user_id=userId, batchCreditId=batchId)
|
1323 |
userBatchCashback = user_app_cashbacks.get_by(user_id=userId, batchCreditId=batchId)
|
| 1326 |
if session.is_active:
|
- |
|
| 1327 |
print "session is active. closing it."
|
- |
|
| 1328 |
session.close()
|
1324 |
session.close()
|
| 1329 |
if userBatchCashback is None:
|
1325 |
if userBatchCashback is None:
|
| 1330 |
resp.body = json.dumps("{}")
|
1326 |
resp.body = json.dumps("{}")
|
| 1331 |
else:
|
1327 |
else:
|
| 1332 |
resp.body = json.dumps(todict(userBatchCashback), encoding='utf-8')
|
1328 |
resp.body = json.dumps(todict(userBatchCashback), encoding='utf-8')
|
| 1333 |
|
1329 |
|
| Line 1336... |
Line 1332... |
| 1336 |
fortNightOfYear = long(fortNightOfYear)
|
1332 |
fortNightOfYear = long(fortNightOfYear)
|
| 1337 |
userId = long(userId)
|
1333 |
userId = long(userId)
|
| 1338 |
yearVal = long(yearVal)
|
1334 |
yearVal = long(yearVal)
|
| 1339 |
appUserBatchDrillDown = session.query(user_app_installs.transaction_date, func.sum(user_app_installs.installCount).label('downloads'), func.sum(user_app_installs.payoutAmount).label('amount')).join((user_app_cashbacks,user_app_cashbacks.user_id==user_app_installs.user_id)).filter(user_app_cashbacks.fortnightOfYear==user_app_installs.fortnightOfYear).filter(user_app_cashbacks.user_id==userId).filter(user_app_cashbacks.yearVal==yearVal).filter(user_app_cashbacks.fortnightOfYear==fortNightOfYear).group_by(user_app_installs.transaction_date).all()
|
1335 |
appUserBatchDrillDown = session.query(user_app_installs.transaction_date, func.sum(user_app_installs.installCount).label('downloads'), func.sum(user_app_installs.payoutAmount).label('amount')).join((user_app_cashbacks,user_app_cashbacks.user_id==user_app_installs.user_id)).filter(user_app_cashbacks.fortnightOfYear==user_app_installs.fortnightOfYear).filter(user_app_cashbacks.user_id==userId).filter(user_app_cashbacks.yearVal==yearVal).filter(user_app_cashbacks.fortnightOfYear==fortNightOfYear).group_by(user_app_installs.transaction_date).all()
|
| 1340 |
cashbackArray = []
|
1336 |
cashbackArray = []
|
| 1341 |
if session.is_active:
|
- |
|
| 1342 |
print "session is active. closing it."
|
- |
|
| 1343 |
session.close()
|
1337 |
session.close()
|
| 1344 |
if appUserBatchDrillDown is None or len(appUserBatchDrillDown)==0:
|
1338 |
if appUserBatchDrillDown is None or len(appUserBatchDrillDown)==0:
|
| 1345 |
resp.body = json.dumps("{}")
|
1339 |
resp.body = json.dumps("{}")
|
| 1346 |
else:
|
1340 |
else:
|
| 1347 |
for appcashBack in appUserBatchDrillDown:
|
1341 |
for appcashBack in appUserBatchDrillDown:
|
| 1348 |
userAppBatchDrillDown = UserAppBatchDrillDown(str(appcashBack[0]),long(appcashBack[1]), long(appcashBack[2]))
|
1342 |
userAppBatchDrillDown = UserAppBatchDrillDown(str(appcashBack[0]),long(appcashBack[1]), long(appcashBack[2]))
|
| Line 1354... |
Line 1348... |
| 1354 |
userId = long(userId)
|
1348 |
userId = long(userId)
|
| 1355 |
date = str(date)
|
1349 |
date = str(date)
|
| 1356 |
date = datetime.strptime(date, '%Y-%m-%d')
|
1350 |
date = datetime.strptime(date, '%Y-%m-%d')
|
| 1357 |
appUserBatchDateDrillDown = session.query(user_app_installs.app_name, func.sum(user_app_installs.installCount).label('downloads'), func.sum(user_app_installs.payoutAmount).label('amount')).filter(user_app_installs.user_id==userId).filter(user_app_installs.transaction_date==date).group_by(user_app_installs.app_name).all()
|
1351 |
appUserBatchDateDrillDown = session.query(user_app_installs.app_name, func.sum(user_app_installs.installCount).label('downloads'), func.sum(user_app_installs.payoutAmount).label('amount')).filter(user_app_installs.user_id==userId).filter(user_app_installs.transaction_date==date).group_by(user_app_installs.app_name).all()
|
| 1358 |
cashbackArray = []
|
1352 |
cashbackArray = []
|
| 1359 |
if session.is_active:
|
- |
|
| 1360 |
print "session is active. closing it."
|
- |
|
| 1361 |
session.close()
|
1353 |
session.close()
|
| 1362 |
if appUserBatchDateDrillDown is None or len(appUserBatchDateDrillDown)==0:
|
1354 |
if appUserBatchDateDrillDown is None or len(appUserBatchDateDrillDown)==0:
|
| 1363 |
resp.body = json.dumps("{}")
|
1355 |
resp.body = json.dumps("{}")
|
| 1364 |
else:
|
1356 |
else:
|
| 1365 |
for appcashBack in appUserBatchDateDrillDown:
|
1357 |
for appcashBack in appUserBatchDateDrillDown:
|
| 1366 |
userAppBatchDateDrillDown = UserAppBatchDateDrillDown(str(appcashBack[0]),long(appcashBack[1]),long(appcashBack[2]))
|
1358 |
userAppBatchDateDrillDown = UserAppBatchDateDrillDown(str(appcashBack[0]),long(appcashBack[1]),long(appcashBack[2]))
|
| Line 1371... |
Line 1363... |
| 1371 |
def on_get(self, req, resp, userId, status):
|
1363 |
def on_get(self, req, resp, userId, status):
|
| 1372 |
userId = long(userId)
|
1364 |
userId = long(userId)
|
| 1373 |
status = str(status)
|
1365 |
status = str(status)
|
| 1374 |
appUserApprovedCashBacks = user_app_cashbacks.query.filter(user_app_cashbacks.user_id==userId).filter(user_app_cashbacks.status==status).all()
|
1366 |
appUserApprovedCashBacks = user_app_cashbacks.query.filter(user_app_cashbacks.user_id==userId).filter(user_app_cashbacks.status==status).all()
|
| 1375 |
cashbackArray = []
|
1367 |
cashbackArray = []
|
| 1376 |
if session.is_active:
|
- |
|
| 1377 |
print "session is active. closing it."
|
- |
|
| 1378 |
session.close()
|
1368 |
session.close()
|
| 1379 |
if appUserApprovedCashBacks is None or len(appUserApprovedCashBacks)==0:
|
1369 |
if appUserApprovedCashBacks is None or len(appUserApprovedCashBacks)==0:
|
| 1380 |
resp.body = json.dumps("{}")
|
1370 |
resp.body = json.dumps("{}")
|
| 1381 |
else:
|
1371 |
else:
|
| 1382 |
totalAmount = 0
|
1372 |
totalAmount = 0
|
| 1383 |
for appUserApprovedCashBack in appUserApprovedCashBacks:
|
1373 |
for appUserApprovedCashBack in appUserApprovedCashBacks:
|