Subversion Repositories SmartDukaan

Rev

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

Rev 19441 Rev 19451
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.dao import FeaturedDeals, AppTransactions, AppOfferObj, Promotion, NotificationCampaign
 4 
from dtr.dao import FeaturedDeals, AppTransactions, AppOfferObj, Promotion, NotificationCampaign,CrmRefundWallet
5 
from dtr.storage import DataService
 5 
from dtr.storage import DataService
6 
from dtr.storage.DataService import price_preferences, brand_preferences, \
 6 
from dtr.storage.DataService import price_preferences, brand_preferences, \
7 
    user_actions, Brands, app_offers, approved_app_transactions, user_app_cashbacks, \
 7 
    user_actions, Brands, app_offers, approved_app_transactions, user_app_cashbacks, \
8 
    user_app_installs, appmasters, notification_campaigns
 8 
    user_app_installs, appmasters, notification_campaigns
9 
from dtr.storage.MemCache import MemCache
 9 
from dtr.storage.MemCache import MemCache
10 
from dtr.utils.MailSender import Email
 10 
from dtr.utils.MailSender import Email
11 
from dtr.utils.utils import to_java_date, CB_PENDING, CB_APPROVED, CB_INIT, \
 11 
from dtr.utils.utils import to_java_date, CB_PENDING, CB_APPROVED, CB_INIT, \
12 
    to_py_date, CB_REJECTED, SUB_CATEGORY_MAP
 12 
    to_py_date, CB_REJECTED, SUB_CATEGORY_MAP, con
13 
from sqlalchemy.sql.expression import func, func, or_, desc, asc, case
 13 
from sqlalchemy.sql.expression import func, func, or_, desc, asc, case
14 
from elixir import *
 14 
from elixir import *
15 
from operator import itemgetter
 15 
from operator import itemgetter
16 
from pymongo.command_cursor import CommandCursor
 16 
from pymongo.command_cursor import CommandCursor
17 
import pymongo
 17 
import pymongo
Line 22... Line 22...
22 
from itertools import groupby
 22 
from itertools import groupby
23 
import urllib
 23 
import urllib
24 
import urllib2
 24 
import urllib2
25 
import json
 25 
import json
26 
import collections
 26 
import collections
- 
 
 27 
from dtr.main import todict
- 
 
 28 
from dtr.utils import utils
- 
 
 29 
from string import lower
27 
try:
 30 
try:
28 
    import ordereddict
 31 
    import ordereddict
29 
except:
 32 
except:
30 
    pass
 33 
    pass
31 
 
 34 
 
Line 3198... Line 3201...
3198 
        return {'idListInfo':id_list_mapping,'result':returnMap.values()}
 3201 
        return {'idListInfo':id_list_mapping,'result':returnMap.values()}
3199 
    except:
 3202 
    except:
3200 
        traceback.print_exc()
 3203 
        traceback.print_exc()
3201 
        return {}
 3204 
        return {}
3202 
 
 3205 
 
- 
 
 3206 
def refundAmountInWallet(jsonReq):
- 
 
 3207 
    userId = int(jsonReq.get('user_id'))
- 
 
 3208 
    emailId = jsonReq.get('email_id')
- 
 
 3209 
    amount = int(jsonReq.get('amount'))
- 
 
 3210 
    store = jsonReq.get('store')
- 
 
 3211 
    refundType = jsonReq.get('type')
- 
 
 3212 
    mobileNumber = jsonReq.get('mobile')
- 
 
 3213 
    referenceId = jsonReq.get('reference_no')
- 
 
 3214 
    referenceDescription = jsonReq.get('reference_description')
- 
 
 3215 
    if lower(refundType)=='refund':
- 
 
 3216 
        refundType = utils.CREDIT_TYPE_REFUND
- 
 
 3217 
    elif lower(refundType)=='adjustment':
- 
 
 3218 
        refundType = utils.CREDIT_TYPE_ADJUSTMENT
- 
 
 3219 
    collection = get_mongo_connection().Dtr.crmrefundwallet
- 
 
 3220 
    offer1 = CrmRefundWallet(userId,emailId,mobileNumber,amount,refundType,store,referenceId,referenceDescription,utils.REFUND_ADJUSTMENT_MAP.get(0),datetime.now())
- 
 
 3221 
    dict1 = todict(offer1)
- 
 
 3222 
    collection.save(dict1)
3203
3223 
    return True
- 
 
 3224 
 
- 
 
 3225 
def fetchCrmRefundUsers(status,offset,limit):
- 
 
 3226 
    cursor = list(get_mongo_connection().Dtr.crmrefundwallet.find({"status":status}).skip(offset).limit(limit).sort("created_timestamp",-1))
- 
 
 3227 
    return cursor
- 
 
 3228 
 
3204 
def main():
 3229 
def main():
3205 
    resetCache("47")
 3230 
    resetCache("47")
3206 
    getAccesoryDeals(47, 6, 0, 20, None, None, None)
 3231 
    getAccesoryDeals(47, 6, 0, 20, None, None, None)
3207
3232
3208 
if __name__=='__main__':
 3233 
if __name__=='__main__':
3209 
    main()
 3234 
    main()
3210 
 
 - 
 
3211 
 
 - 
 
3212 

            3235