WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/model/v1/catalog/impl/DataAcessors.py

     Category, EntityIDGenerator, SimilarItems, ProductNotification, Source, \
     SourceItemPricing, AuthorizationLog, VoucherItemMapping, CategoryVatMaster, \
     OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
     FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
     PageViewEvents, CartEvents, EbayItem, BannerUriMapping, Campaign, SnapdealItem, \
-    SnapdealItemUpdateHistory, ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice
+    SnapdealItemUpdateHistory, ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice, \
+    SourcePercentageMaster, SourceItemPercentage
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
     ItemType, PremiumType, FreebieItem as t_FreebieItem, \
     StorePricing as tStorePricing, CatalogServiceException, \
     BannerType, InsurerType
 from shop2020.thriftpy.model.v1.inventory.ttypes import \
 def get_count_for_amazonlisted_items():
     return session.query(func.count(Amazonlisted.itemId)).scalar()
 def add_or_update_snapdeal_item(snapdealitem):
     item = SnapdealItem.get_by(item_id=snapdealitem.item_id)
+    if not __validateSnapdealObject(snapdealitem):
+        print "Bad object"
+        return False
     try:
         if item is not None:
             itemHistory = SnapdealItemUpdateHistory()
             itemHistory.item_id = snapdealitem.item_id
             itemHistory.exceptionPrice = item.exceptionPrice
             itemHistory.suppressInventoryFeed = item.suppressInventoryFeed
             itemHistory.updatedOn = item.updatedOn
             itemHistory.maxNlc = item.maxNlc
             itemHistory.skuAtSnapdeal = item.skuAtSnapdeal
             itemHistory.supc = item.supc
+            itemHistory.priceUpdatedBy = item.priceUpdatedBy
+            if (item.sellingPrice!=snapdealitem.sellingPrice):
+                item.priceUpdatedBy = snapdealitem.updatedBy
             if snapdealitem.exceptionPrice is not None:
                 item.exceptionPrice = snapdealitem.exceptionPrice
             if snapdealitem.warehouseId is not None:
                 item.warehouseId = snapdealitem.warehouseId
             if snapdealitem.isListedOnSnapdeal is not None:
             if snapdealitem.maxNlc is not None:
                 item.maxNlc = snapdealitem.maxNlc
             item.skuAtSnapdeal = snapdealitem.skuAtSnapdeal
             item.updatedOn = datetime.datetime.now()
             item.supc = snapdealitem.supc
-            session.commit()
+            __markStatusForMarketplaceItems(snapdealitem,item)
-            return True
+            return update_marketplace_attributes_for_item(snapdealitem.marketplaceItems)
         else:
             item = SnapdealItem()
             if snapdealitem.item_id is not None:
                 item.item_id = snapdealitem.item_id
                 if snapdealitem.exceptionPrice is not None:
                 item.suppressPriceFeed =snapdealitem.suppressPriceFeed
                 item.suppressInventoryFeed =snapdealitem.suppressInventoryFeed
                 item.maxNlc = snapdealitem.maxNlc
                 item.skuAtSnapdeal = snapdealitem.skuAtSnapdeal
                 item.supc = snapdealitem.supc
                 item.updatedOn = datetime.datetime.now()
-                session.commit()
+                item.priceUpdatedBy = snapdealitem.updatedBy
-                return True
+                __markStatusForMarketplaceItems(snapdealitem,item)
+                return update_marketplace_attributes_for_item(snapdealitem.marketplaceItems)
-        return False
+    except Exception as ex:
+        print "Unable to addOrupdate snapdealItem"
-    except:
+        print ex
         return False
 def get_snapdeal_item(itemid):
     item = session.query(SnapdealItem,Item).join((Item,SnapdealItem.item_id==Item.id)).filter(SnapdealItem.item_id==itemid).first()
     return item
         marketplaceItem = get_marketplace_details_for_item(t_marketplaceItem.itemId,t_marketplaceItem.source)
         if marketplaceItem is None:
             marketplaceItem = MarketplaceItems()
             marketplaceItem.itemId = t_marketplaceItem.itemId
             marketplaceItem.source = t_marketplaceItem.source
-            marketplaceItem.emiFee =0.0
+            marketplaceItem.emiFee = t_marketplaceItem.emiFee
-            marketplaceItem.closingFee = 0.0
+            marketplaceItem.closingFee = t_marketplaceItem.closingFee
-            marketplaceItem.returnProvision = 0.5
+            marketplaceItem.returnProvision = t_marketplaceItem.returnProvision
-            marketplaceItem.commission = 3.59
+            marketplaceItem.commission = t_marketplaceItem.commission
             marketplaceItem.vat = t_marketplaceItem.vat
             marketplaceItem.packagingCost = 15.0
-            marketplaceItem.serviceTax = 12.36
+            marketplaceItem.serviceTax = t_marketplaceItem.serviceTax
             marketplaceItem.courierCost = t_marketplaceItem.courierCost
             marketplaceItem.otherCost = t_marketplaceItem.otherCost
             marketplaceItem.autoIncrement = t_marketplaceItem.autoIncrement
             marketplaceItem.autoDecrement = t_marketplaceItem.autoDecrement
             marketplaceItem.manualFavourite = t_marketplaceItem.manualFavourite
             marketplaceItem.manualFavourite = t_marketplaceItem.manualFavourite
             marketplaceItem.currentSp = t_marketplaceItem.currentSp
             marketplaceItem.currentTp = t_marketplaceItem.currentTp
             marketplaceItem.minimumPossibleSp = t_marketplaceItem.minimumPossibleSp
             marketplaceItem.minimumPossibleTp = t_marketplaceItem.minimumPossibleTp
+            marketplaceItem.emiFee = t_marketplaceItem.emiFee
+            marketplaceItem.closingFee = t_marketplaceItem.closingFee
+            marketplaceItem.returnProvision = t_marketplaceItem.returnProvision
+            marketplaceItem.commission = t_marketplaceItem.commission
+            marketplaceItem.vat = t_marketplaceItem.vat
+            marketplaceItem.serviceTax = t_marketplaceItem.serviceTax
         session.commit()
         return True
     except Exception as ex:
+        print "Unable to addOrupdate MarketplaceItem"
         print ex
         return False
+def __markStatusForMarketplaceItems(snapdealItem,item):
+    try:
+        marketplaceItem = snapdealItem.marketplaceItems
+        markUpdatedItem = MarketPlaceItemPrice.query.filter(MarketPlaceItemPrice.item_id==snapdealItem.item_id).filter(MarketPlaceItemPrice.source==marketplaceItem.source).first()
+        if markUpdatedItem is None:
+            marketPlaceItemPrice = MarketPlaceItemPrice()
+            marketPlaceItemPrice.item_id = snapdealItem.item_id
+            marketPlaceItemPrice.source = marketplaceItem.source
+            marketPlaceItemPrice.lastUpdatedOn = item.updatedOn
+            marketPlaceItemPrice.sellingPrice = item.sellingPrice
+            marketPlaceItemPrice.suppressPriceFeed = item.suppressPriceFeed
+            marketPlaceItemPrice.isListedOnSource = item.isListedOnSnapdeal
+        else:
+            if (markUpdatedItem.sellingPrice!=snapdealItem.sellingPrice or markUpdatedItem.suppressPriceFeed!=item.suppressPriceFeed or markUpdatedItem.isListedOnSource!=item.isListedOnSnapdeal):
+                markUpdatedItem.lastUpdatedOn = item.updatedOn
+            markUpdatedItem.sellingPrice = snapdealItem.sellingPrice
+            markUpdatedItem.suppressPriceFeed = item.suppressPriceFeed
+            markUpdatedItem.isListedOnSource = item.isListedOnSnapdeal
+        return True
+    except Exception as e:
+        print e
+        return False
+def get_costing_for_marketplace(source_id,itemId):
+    sip = SourceItemPercentage.get_by(source=source_id,item_id=itemId)
+    if sip is None:
+        spm = SourcePercentageMaster.get_by(source=source_id)
+        return spm
+    else:
+        return sip
+def __validateSnapdealObject(snapdealItem):
+    if len(snapdealItem.supc)==0 or snapdealItem.supc is None or len(snapdealItem.skuAtSnapdeal)==0 or snapdealItem.skuAtSnapdeal is None or snapdealItem.sellingPrice==0 or snapdealItem.maxNlc==0:
+        return False
+    else:
+        return True
 def get_all_marketplace_items_for_priceupdate(source):
     marketPlaceItemsPrices = MarketPlaceItemPrice.query.filter(MarketPlaceItemPrice.source == source).filter(MarketPlaceItemPrice.lastUpdatedOn > MarketPlaceItemPrice.lastUpdatedOnMarketplace).all()
     print marketPlaceItemsPrices
     return marketPlaceItemsPrices

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/catalog/impl/DataAcessors.py – Rev 9776 → 9779