| Line 4... |
Line 4... |
| 4 |
from dtr.dao import FeaturedDeals, AppTransactions
|
4 |
from dtr.dao import FeaturedDeals, AppTransactions
|
| 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
|
7 |
user_actions, Brands, app_offers
|
| 8 |
from dtr.storage.MemCache import MemCache
|
8 |
from dtr.storage.MemCache import MemCache
|
| - |
|
9 |
from dtr.utils.FetchLivePrices import returnLatestPrice
|
| 9 |
from dtr.utils.utils import to_java_date, CB_PENDING, CB_APPROVED, CB_INIT
|
10 |
from dtr.utils.utils import to_java_date, CB_PENDING, CB_APPROVED, CB_INIT
|
| 10 |
from elixir import *
|
11 |
from elixir import *
|
| 11 |
from operator import itemgetter
|
12 |
from operator import itemgetter
|
| 12 |
import pymongo
|
13 |
import pymongo
|
| 13 |
import random
|
14 |
import random
|
| Line 627... |
Line 628... |
| 627 |
continue
|
628 |
continue
|
| 628 |
else:
|
629 |
else:
|
| 629 |
return cashBack.get(category_id)
|
630 |
return cashBack.get(category_id)
|
| 630 |
else:
|
631 |
else:
|
| 631 |
return {}
|
632 |
return {}
|
| - |
|
633 |
|
| - |
|
634 |
def getBundleBySourceSku(source_id, identifier):
|
| - |
|
635 |
returnResult=[]
|
| - |
|
636 |
if source_id in (1,2,4,5):
|
| - |
|
637 |
skuData = list(get_mongo_connection().Catalog.MasterData.find({'identifier':identifier.strip(), 'source_id':source_id}))
|
| - |
|
638 |
elif source_id == 3:
|
| - |
|
639 |
skuData = list(get_mongo_connection().Catalog.MasterData.find({'secondaryIdentifier':identifier.strip(), 'source_id':source_id}))
|
| - |
|
640 |
else:
|
| - |
|
641 |
return {}
|
| - |
|
642 |
|
| - |
|
643 |
if not skuData:
|
| - |
|
644 |
return {}
|
| - |
|
645 |
else:
|
| - |
|
646 |
bundleId = skuData[0]["_id"]
|
| - |
|
647 |
itemIds = list(get_mongo_connection().Catalog.MasterData.find({'_id':bundleId, 'status':1}))
|
| - |
|
648 |
for item in itemIds:
|
| - |
|
649 |
item['dealFlag'] = 0
|
| - |
|
650 |
item['dealType'] = 0
|
| - |
|
651 |
item['dealUrl'] = ""
|
| - |
|
652 |
if item['source_id'] ==5 and item['rank'] == 0:
|
| - |
|
653 |
continue
|
| - |
|
654 |
if item['source_id'] ==3:
|
| - |
|
655 |
item['marketPlaceUrl'] = item['marketPlaceUrl']+'?supc='+item.get('identifier')
|
| - |
|
656 |
manualDeals = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':source_id, 'sku':item['_id']}))
|
| - |
|
657 |
if len(manualDeals) > 0:
|
| - |
|
658 |
item['dealFlag'] = 1
|
| - |
|
659 |
item['dealType'] =manualDeals[0]['dealType']
|
| - |
|
660 |
item['dealUrl'] = manualDeals[0]['dealUrl']
|
| - |
|
661 |
info = returnLatestPrice(item, source_id, False)
|
| - |
|
662 |
returnResult.append(info)
|
| - |
|
663 |
|
| - |
|
664 |
return {'products':returnResult}
|
| - |
|
665 |
|
| - |
|
666 |
|
| 632 |
|
667 |
|
| 633 |
def getDealRank(identifier, source_id, userId):
|
668 |
def getDealRank(identifier, source_id, userId):
|
| 634 |
if source_id in (1,2,4,5,6):
|
669 |
if source_id in (1,2,4,5,6):
|
| 635 |
skuData = list(get_mongo_connection().Catalog.MasterData.find({'identifier':identifier.strip(), 'source_id':source_id}))
|
670 |
skuData = list(get_mongo_connection().Catalog.MasterData.find({'identifier':identifier.strip(), 'source_id':source_id}))
|
| 636 |
elif source_id == 3:
|
671 |
elif source_id == 3:
|