WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/dtr/storage/Mongo.py



def addPayout(payout, transaction_id):
    try:
        transaction = list(get_mongo_connection().AppOrder.AppTransaction.find({'_id':ObjectId(transaction_id)}))
        if len(transaction) > 0:
            if (transaction[0])['payout_status'] ==1:
                get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(transaction_id)},{"$set":{'payout_amount':float(payout), 'payout_description': CB_APPROVED,'payout_status':2, 'cashback_status': 2, 'cash_back_description': CB_APPROVED}})
            
                approvedAppTransaction = approved_app_transactions()
                approvedAppTransaction.app_id = transaction[0]['app_id']
                approvedAppTransaction.cash_back_description = CB_APPROVED
                approvedAppTransaction.retailer_id = transaction[0]['retailer_id']
                approvedAppTransaction.transaction_id = transaction_id
                approvedAppTransaction.transaction_time = to_py_date(long(transaction[0]['transaction_time']))
                approvedAppTransaction.redirect_url = transaction[0]['redirect_url']
                approvedAppTransaction.payout_status = 2
                approvedAppTransaction.payout_description = CB_APPROVED
                approvedAppTransaction.cashback_status = 2 
                approvedAppTransaction.payout_amount = long(payout)
                approvedAppTransaction.payout_time = datetime.now()
                approvedAppTransaction.offer_price = long(transaction[0]['offer_price']) 
                approvedAppTransaction.overridenCashBack = transaction[0]['overridenCashBack']
                if str(transaction[0]['isCashBackOverriden']) == 'false' or str(transaction[0]['isCashBackOverriden']) == 'False':

                approvedAppTransaction.user_payout = transaction[0]['user_payout']
                approvedAppTransaction.cashBackConsidered = False
                session.commit()
                
                updateResult = _updateApprovedCashbackToUser(approvedAppTransaction.id)
                '''
                try:
                    if int(transaction[0]['offer_price']) != payout or int(transaction[0]['user_payout']) < payout:
                        _sendAlertForAppPayouts(int(transaction[0]['app_id']), int(transaction[0]['offer_price']), int(transaction[0]['user_payout']), payout)
                except:
                    print traceback.print_exc()
                '''
                return {'status':'ok','message':'Payout updated'}
            elif (transaction[0])['payout_status'] ==2:
                return {'status':'ok','message':'Payout already processed'}
            else:
                return {'status':'fail','message':'Something is wrong'}
        else:
            return {'status':'fail','message':'transaction_id not found'}
    except:
        print traceback.print_exc()
        try:
            get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(transaction_id)},{"$set":{'payout_amount':None, 'payout_description': CB_INIT,'payout_status':1, 'cashback_status': 1, 'cash_back_description': CB_INIT}})
        except:
            print 'Data Inconsistency in Cashback Process'
            print traceback.print_exc()
        return  {'status':'fail','message':'Something is wrong'}
        

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 16695 → 16697

Rev 16695		Rev 16697
Line 1420...		Line 1420...
1420	`def addPayout(payout, transaction_id):`	1420	`def addPayout(payout, transaction_id):`
1421	`try:`	1421	`try:`
1422	`transaction = list(get_mongo_connection().AppOrder.AppTransaction.find({'_id':ObjectId(transaction_id)}))`	1422	`transaction = list(get_mongo_connection().AppOrder.AppTransaction.find({'_id':ObjectId(transaction_id)}))`
1423	`if len(transaction) > 0:`	1423	`if len(transaction) > 0:`
1424	`if (transaction[0])['payout_status'] ==1:`	1424	`if (transaction[0])['payout_status'] ==1:`
1425	`get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(transaction_id)},{"$set":{'payout_amount':float(payout), 'payout_description': CB_APPROVED,'payout_status':2}})`	1425	`get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(transaction_id)},{"$set":{'payout_amount':float(payout), 'payout_description': CB_APPROVED,'payout_status':2, 'cashback_status': 2, 'cash_back_description': CB_APPROVED}})`
1426		1426
1427	`approvedAppTransaction = approved_app_transactions()`	1427	`approvedAppTransaction = approved_app_transactions()`
1428	`approvedAppTransaction.app_id = transaction[0]['app_id']`	1428	`approvedAppTransaction.app_id = transaction[0]['app_id']`
1429	`approvedAppTransaction.cash_back_description = CB_APPROVED`	1429	`approvedAppTransaction.cash_back_description = CB_APPROVED`
1430	`approvedAppTransaction.retailer_id = transaction[0]['retailer_id']`	1430	`approvedAppTransaction.retailer_id = transaction[0]['retailer_id']`
1431	`approvedAppTransaction.transaction_id = transaction_id`	1431	`approvedAppTransaction.transaction_id = transaction_id`
1432	`approvedAppTransaction.transaction_time = to_py_date(long(transaction[0]['transaction_time']))`	1432	`approvedAppTransaction.transaction_time = to_py_date(long(transaction[0]['transaction_time']))`
1433	`approvedAppTransaction.redirect_url = transaction[0]['redirect_url']`	1433	`approvedAppTransaction.redirect_url = transaction[0]['redirect_url']`
1434	`approvedAppTransaction.payout_status = 2`	1434	`approvedAppTransaction.payout_status = 2`
1435	`approvedAppTransaction.payout_description = CB_APPROVED`	1435	`approvedAppTransaction.payout_description = CB_APPROVED`
1436	`approvedAppTransaction.cashback_status = long(transaction[0]['cashback_status'])`	1436	`approvedAppTransaction.cashback_status = 2`
1437	`approvedAppTransaction.payout_amount = long(payout)`	1437	`approvedAppTransaction.payout_amount = long(payout)`
1438	`approvedAppTransaction.payout_time = datetime.now()`	1438	`approvedAppTransaction.payout_time = datetime.now()`
1439	`approvedAppTransaction.offer_price = long(transaction[0]['offer_price'])`	1439	`approvedAppTransaction.offer_price = long(transaction[0]['offer_price'])`
1440	`approvedAppTransaction.overridenCashBack = transaction[0]['overridenCashBack']`	1440	`approvedAppTransaction.overridenCashBack = transaction[0]['overridenCashBack']`
1441	`if str(transaction[0]['isCashBackOverriden']) == 'false' or str(transaction[0]['isCashBackOverriden']) == 'False':`	1441	`if str(transaction[0]['isCashBackOverriden']) == 'false' or str(transaction[0]['isCashBackOverriden']) == 'False':`
Line 1445...		Line 1445...
1445	`approvedAppTransaction.user_payout = transaction[0]['user_payout']`	1445	`approvedAppTransaction.user_payout = transaction[0]['user_payout']`
1446	`approvedAppTransaction.cashBackConsidered = False`	1446	`approvedAppTransaction.cashBackConsidered = False`
1447	`session.commit()`	1447	`session.commit()`
1448		1448
1449	`updateResult = _updateApprovedCashbackToUser(approvedAppTransaction.id)`	1449	`updateResult = _updateApprovedCashbackToUser(approvedAppTransaction.id)`
-		1450	`'''`
1450	`try:`	1451	`try:`
1451	`if int(transaction[0]['offer_price']) != payout or int(transaction[0]['user_payout']) < payout:`	1452	`if int(transaction[0]['offer_price']) != payout or int(transaction[0]['user_payout']) < payout:`
1452	`_sendAlertForAppPayouts(int(transaction[0]['app_id']), int(transaction[0]['offer_price']), int(transaction[0]['user_payout']), payout)`	1453	`_sendAlertForAppPayouts(int(transaction[0]['app_id']), int(transaction[0]['offer_price']), int(transaction[0]['user_payout']), payout)`
1453	`except:`	1454	`except:`
1454	`print traceback.print_exc()`	1455	`print traceback.print_exc()`
-		1456	`'''`
1455	`return {'status':'ok','message':'Payout updated'}`	1457	`return {'status':'ok','message':'Payout updated'}`
1456	`elif (transaction[0])['payout_status'] ==2:`	1458	`elif (transaction[0])['payout_status'] ==2:`
1457	`return {'status':'ok','message':'Payout already processed'}`	1459	`return {'status':'ok','message':'Payout already processed'}`
1458	`else:`	1460	`else:`
1459	`return {'status':'fail','message':'Something is wrong'}`	1461	`return {'status':'fail','message':'Something is wrong'}`
1460	`else:`	1462	`else:`
1461	`return {'status':'fail','message':'transaction_id not found'}`	1463	`return {'status':'fail','message':'transaction_id not found'}`
1462	`except:`	1464	`except:`
1463	`print traceback.print_exc()`	1465	`print traceback.print_exc()`
1464	`try:`	1466	`try:`
1465	`get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(transaction_id)},{"$set":{'payout_amount':None, 'payout_description': CB_INIT,'payout_status':1}})`	1467	`get_mongo_connection().AppOrder.AppTransaction.update({'_id':ObjectId(transaction_id)},{"$set":{'payout_amount':None, 'payout_description': CB_INIT,'payout_status':1, 'cashback_status': 1, 'cash_back_description': CB_INIT}})`
1466	`except:`	1468	`except:`
1467	`print 'Data Inconsistency in Cashback Process'`	1469	`print 'Data Inconsistency in Cashback Process'`
1468	`print traceback.print_exc()`	1470	`print traceback.print_exc()`
1469	`return {'status':'fail','message':'Something is wrong'}`	1471	`return {'status':'fail','message':'Something is wrong'}`
1470		1472