Subversion Repositories SmartDukaan

Rev

Rev 16373 | Rev 16406 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 16373 Rev 16398
Line 1... Line 1...
1 
from bson.objectid import ObjectId
 1 
from bson.objectid import ObjectId
2 
from datetime import datetime, timedelta
 2 
from datetime import datetime, timedelta
3 
from dtr.config import PythonPropertyReader
 3 
from dtr.config import PythonPropertyReader
4 
from dtr.main import Store
 - 
 
5 
from dtr.dao import FeaturedDeals
 4 
from dtr.dao import FeaturedDeals
6 
from dtr.storage import DataService
 5 
from dtr.storage import DataService
7 
from dtr.storage.DataService import price_preferences, brand_preferences, \
 6 
from dtr.storage.DataService import price_preferences, brand_preferences, \
8 
    user_actions, Brands
 7 
    user_actions, Brands
9 
from dtr.storage.MemCache import MemCache
 8 
from dtr.storage.MemCache import MemCache
10 
from dtr.utils.utils import to_java_date
 9 
from dtr.utils.utils import to_java_date, CB_PENDING, CB_APPROVED
11 
from elixir import *
 10 
from elixir import *
12 
from operator import itemgetter
 11 
from operator import itemgetter
13 
import pymongo
 12 
import pymongo
- 
 
 13 
import random
14 
import re
 14 
import re
15 
import traceback
 15 
import traceback
16 
import random
 - 
 
17 
 
 16 
 
18 
con = None
 17 
con = None
19 
 
 18 
 
20 
DataService.initialize(db_hostname="localhost")
 19 
DataService.initialize(db_hostname="localhost")
21 
mc = MemCache("127.0.0.1")
 20 
mc = MemCache("127.0.0.1")
Line 256... Line 255...
256
255
257 
def getPendingRefunds(userId):
 256 
def getPendingRefunds(userId):
258 
    print type(userId)
 257 
    print type(userId)
259 
    result = get_mongo_connection().Dtr.merchantOrder\
 258 
    result = get_mongo_connection().Dtr.merchantOrder\
260 
        .aggregate([
 259 
        .aggregate([
261 
                    {'$match':{'subOrders.cashBackStatus':Store.CB_APPROVED, 'userId':userId}},
 260 
                    {'$match':{'subOrders.cashBackStatus':CB_APPROVED, 'userId':userId}},
262 
                    {'$unwind':"$subOrders"},
 261 
                    {'$unwind':"$subOrders"},
263 
                    {'$match':{'subOrders.cashBackStatus':Store.CB_APPROVED}},
 262 
                    {'$match':{'subOrders.cashBackStatus':CB_APPROVED}},
264 
                    {
263 
                    {
265 
                     '$group':{
 264 
                     '$group':{
266 
                               '_id':None,
 265 
                               '_id':None,
267 
                               'amount': { '$sum':'$subOrders.cashBackAmount'},
 266 
                               'amount': { '$sum':'$subOrders.cashBackAmount'},
268 
                               }
 267 
                               }
Line 279... Line 278...
279 
    return result
 278 
    return result
280 
 
 279 
 
281 
def getPendingCashbacks(userId):
 280 
def getPendingCashbacks(userId):
282 
    result = get_mongo_connection().Dtr.merchantOrder\
 281 
    result = get_mongo_connection().Dtr.merchantOrder\
283 
        .aggregate([
 282 
        .aggregate([
284 
                    {'$match':{'subOrders.cashBackStatus':Store.CB_PENDING, 'userId':userId}},
 283 
                    {'$match':{'subOrders.cashBackStatus':CB_PENDING, 'userId':userId}},
285 
                    {'$unwind':"$subOrders"},
 284 
                    {'$unwind':"$subOrders"},
286 
                    {'$match':{'subOrders.cashBackStatus':Store.CB_PENDING}},
 285 
                    {'$match':{'subOrders.cashBackStatus':CB_PENDING}},
287 
                    {
286 
                    {
288 
                     '$group':{
 287 
                     '$group':{
289 
                               '_id':None,
 288 
                               '_id':None,
290 
                               'amount': { '$sum':'$subOrders.cashBackAmount'},
 289 
                               'amount': { '$sum':'$subOrders.cashBackAmount'},
291 
                               }
 290 
                               }