Subversion Repositories SmartDukaan

from datetime import datetime

from dtr.utils.utils import to_java_date, CATEGORY_MAP, SUB_CATEGORY_MAP, get_mongo_connection_cms, get_mongo_connection

from shop2020.config.client.ConfigClient import ConfigClient

from dtr.dao import ProductInfo

from pymongo import DESCENDING

config_client = ConfigClient()

mongo_cms_host = config_client.get_property('mongo_cms_host')

def addData(bulkItemsList):

    notAdded = []

    for item in bulkItemsList:

        v= ProductInfo(None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None,None)

        v. _id = None

        v.addedOn = to_java_date(datetime.now())

        v.available_price = item.sellingPrice 

        v.brand = item.brand 

        v.cashback = ""

        v.category= CATEGORY_MAP.get(item.category_id)

        v.category_id = item.category_id

        v.identifier = item.identifier      

        v.in_stock = 0

        v.marketPlaceUrl = None

        v.model_name = item.model_name

        v.mrp = item.mrp

        v.product_name = item.product_name

        v.rank = 0

        v.secondaryIdentifier = ""

        v.skuBundleId = None

        v.source = "saholic.com"

        v.sourceCategoryId=""

        v.sourceProductId=""

        v.source_id=4

        v.source_product_name = item.source_product_name

        v.source_url = ""

        v.status  = 1

        v.stock_status = "Out of stock"

        v.thumbnail = None

        v.updatedOn = to_java_date(datetime.now())

        v.url = None

        v.priceUpdatedOn = 0

        v.offer = item.offer

        v.tagline = item.tagline

        v.is_shortage = 0

        v.brand_id = item.brand_id

        v.maxPrice = 0

        v.buyBoxFlag = 1

        v.coupon = ""

        v.codAvailable = 1

        v.gross_price = 0

        v.ignorePricing = 0       

        v.quantity = item.quantity

        v.videoLink = ""

        v.showVideo = 0

        v.subCategoryId = item.subCategoryId

        v.subCategory= SUB_CATEGORY_MAP.get(item.subCategoryId)

        v.showMrp = 1 if item.showMrpFlag else 0

        v.shippingCost = 0

        v.showNetPrice = 1 if item.showNetPrice else 0

        try:

            col = list(get_mongo_connection_cms(host=mongo_cms_host).CONTENT.siteContent.find({'_id':long(v.identifier)}))

            if len(col) ==0:

                print "Content not found for %d"%(item.catalog_item_id)

                notAdded.append(v.identifier)

                continue

            else:

                v.url = "http://saholic.com/"+col[0]['url']

                v.thumbnail = col[0]['defaultImageUrl']

                v.marketPlaceUrl = "http://saholic.com/"+col[0]['url']

        except:

            print "Exception in %d"%(item.id)

            notAdded.append(v.identifier)

            continue

        exist = list(get_mongo_connection().Catalog.MasterData.find({'identifier':v.identifier}))

        if len(exist) > 0:

            notAdded.append(v.identifier)

            continue

        max_id = list(get_mongo_connection().Catalog.MasterData.find().sort([('_id',DESCENDING)]).limit(1))

        max_bundle = list(get_mongo_connection().Catalog.MasterData.find().sort([('skuBundleId',DESCENDING)]).limit(1))

        v._id = max_id[0]['_id'] + 1

        v.skuBundleId = max_bundle[0]['skuBundleId'] + 1

        get_mongo_connection().Catalog.MasterDataTest.insert(v.__dict__)

    return notAdded