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

         result={}
         result['amount'] = 0.0
     result['nextCredit'] = datetime.strftime(next_weekday(datetime.now(), int(PythonPropertyReader.getConfig('CREDIT_DAY_OF_WEEK'))),"%Y-%m-%d %H:%M:%S")
     return result
+def getPendingCashbacks(userId):
+    result = get_mongo_connection().Dtr.merchantOrder\
+        .aggregate([
+                    {'$match':{'subOrders.cashBackStatus':Store.CB_PENDING, 'userId':userId}},
+                    {'$unwind':"$subOrders"},
+                    {'$match':{'subOrders.cashBackStatus':Store.CB_PENDING}},
+                    {
+                     '$group':{
+                               '_id':None,
+                               'amount': { '$sum':'$subOrders.cashBackAmount'},
+                               }
+                     }
+                ])['result']
+    if len(result)>0:
+        result = result[0]
+        result.pop("_id")
+    else:
+        result={}
+        result['amount'] = 0.0
+    return result
 def __populateCache(userId):
     print "Populating memcache for userId",userId
     outer_query = []
     outer_query.append({"showDeal":1})
     query = {}

Subversion Repositories SmartDukaan