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

         ds_item.status = item.itemStatus
     if item.status_description:
         ds_item.status_description = item.status_description
     if item.startDate:
-        ds_item.startDate = item.startDate
+        ds_item.startDate = to_py_date(item.startDate)
     if item.retireDate:
-        ds_item.retireDate = item.retireDate
+        ds_item.retireDate = to_py_date(item.retireDate)
     if item.featureId:
         ds_item.feature_id = item.featureId
     if item.featureDescription:
         ds_item.feature_description = item.featureDescription
     ds_item.updated_on = datetime.datetime.now()
     session.commit();
     return ds_item.id
+def check_vendor_item_mapping(product_group, brand, model_number, color, vendor_id, vendor_category):
+    key = product_group.strip().lower() + '|' + brand.strip().lower() + '|' + model_number.strip().lower() + '|' + color.strip().lower()
+    try:
+        vim = VendorItemMapping.query.filter_by(vendor_id=vendor_id, item_key=key, vendor_category=vendor_category).one()
+        return True
+    except:
+        return False
 def add_item(item):
     if not item:
         raise InventoryServiceException(108, "Bad item in request")
     if get_item(item.id):
         raise InventoryServiceException(101, "Item already exists")
     ds_item = Item()
-    if item.id:
-        ds_item.id = item.id
     if item.productGroup:
         ds_item.product_group = item.productGroup
     if item.brand:
         ds_item.brand = item.brand
     if item.modelName:
         ds_item.model_name = item.modelName
     if item.modelNumber:
         ds_item.model_number = item.modelNumber
     if item.color:
         ds_item.color = item.color
+    if item.hotspotCategory:
+        ds_item.hotspotCategory = item.hotspotCategory
+        if item.hotspotCategory == 'Handsets':
+            item.preferredWarehouse = 1
+        else:
+            item.preferredWarehouse = 2
     if item.category:
         ds_item.category = item.category
     if item.comments:
         ds_item.comments = item.comments
-    if item.catalogItemId:
-        ds_item.catalog_item_id = item.catalogItemId
-    if item.status_description:
-        ds_item.status_description = item.status_description
-    if item.itemStatus:
-        ds_item.status = item.itemStatus
-    else: #If new item is added without status it will have status as IN_PROCESS
-        ds_item.status = status.IN_PROCESS
-        ds_item.status_description = "This item is in process."
     ds_item.addedOn = datetime.datetime.now()
     ds_item.updatedOn = datetime.datetime.now()
+    if item.startDate:
+        ds_item.startDate = to_py_date(item.startDate)
+    if item.retireDate:
+        ds_item.retireDate = to_py_date(item.retireDate)
     if item.mrp:
         ds_item.mrp = item.mrp
     if item.mop:
         ds_item.mop = item.mop
     if item.sellingPrice:
         ds_item.sellingPrice = item.sellingPrice
     if item.dealerPrice:
         ds_item.dealerPrice = item.dealerPrice
+    if item.transferPrice:
+        ds_item.transfer_price = item.transferPrice
     if item.weight:
         ds_item.weight = item.weight
     if item.featureId:
         ds_item.feature_id = item.featureId
         for k,v in item.otherInfo.iteritems():
             info = ItemInfo()
             info.key = k
             info.value = v
             ds_item.iteminfo.append(info)
     #check if categories present. If yes, add them to system
     if item.bestDealValue:
         ds_item.bestDealValue = item.bestDealValue
     if item.bestDealText:
         ds_item.bestDealText = item.bestDealText
+    if item.bestSellingRank:
+        ds_item.bestSellingRank = item.bestSellingRank
+    ds_item.defaultForEntity = item.defaultForEntity
+    # Check if a similar item already exists in our database
+    similar_item = Item.query.filter_by(product_group=item.productGroup, brand = item.brand, model_number=item.modelNumber, hotspotCategory=item.hotspotCategory).first()
+    print "[SIMILAR ITEM FOUND:] FOR {0} {1} {2} {3} {4}".format(item.productGroup, item.brand, item.modelNumber, item.hotspotCategory, item.color)
+    if similar_item is None or similar_item.catalog_item_id is None:
+        # If there is no similar item in the database from before,
+        # use the entity_id_generator
+        entity_id = EntityIDGenerator.query.first()
+        ds_item.catalog_item_id = entity_id.id + 1
+        ds_item.status = status.IN_PROCESS
+        ds_item.status_description = "This item is in process."
+        entity_id.id = entity_id.id  + 1
+    else:
+        #If a similar item already exists for a product group, brand and model_number, set it as same.
+        ds_item.catalog_item_id = similar_item.catalog_item_id
+        ds_item.category = similar_item.category
+        ds_item.status = similar_item.status
+        ds_item.status_description = similar_item.status_description
     session.commit();
     return ds_item.id
 def update_inventory(warehouse_id, timestamp, availability):
     if not item_id:
         raise InventoryServiceException(101, "bad item id")
     item = get_item(item_id)
     if not item:
         raise InventoryServiceException(108, "item id not present")
-    item.status = new_status
     add_status_change_log(item, new_status)
+    item.status = new_status
     session.commit()
 def get_item_availability_for_warehouse(warehouse_id, item_id):
     if not warehouse_id:
         raise InventoryServiceException(101, "bad warehouse_id")
     if item is None:
         raise InventoryServiceException(101, "Bad Item")
     item_pricing = VendorItemPricing.query.filter_by(item=item).all()
     return item_pricing
+def get_item_mappings(item_id):
+    item = Item.query.filter_by(id=item_id).first()
+    if item is None:
+        raise InventoryServiceException(101, "Bad Item")
+    item_mappings = VendorItemMapping.query.filter_by(item=item).all()
+    return item_mappings
-def update_vendor_pricing(vendorItemPricing):
+def add_vendor_pricing(vendorItemPricing):
     if not vendorItemPricing:
         raise InventoryServiceException(108, "Bad vendorItemPricing in request")
     vendorId = vendorItemPricing.vendorId
     itemId = vendorItemPricing.itemId
     validate_prices(to_t_item(item), vendorItemPricing)
     try:
         ds_vendorItemPricing = VendorItemPricing.query.filter(and_(VendorItemPricing.vendor==vendor, VendorItemPricing.item==item)).one()
     except:
-        raise InventoryServiceException(101, "VendorItemPricing not found for vendorId " + str(vendorId) + " and itemId " + str(itemId))
+        ds_vendorItemPricing = VendorItemPricing()
+        ds_vendorItemPricing.vendor = vendor
+        ds_vendorItemPricing.item = item
     if vendorItemPricing.mop:
         ds_vendorItemPricing.mop = vendorItemPricing.mop
     if vendorItemPricing.dealerPrice:
         ds_vendorItemPricing.dealerPrice = vendorItemPricing.dealerPrice
         ds_vendorItemPricing.transfer_price = vendorItemPricing.transferPrice
     session.commit()
     return
+def add_vendor_item_mapping(vendorItemMapping):
+    if not vendorItemMapping:
+        raise InventoryServiceException(108, "Bad vendorItemMapping in request")
+    vendorId = vendorItemMapping.vendorId
+    itemId = vendorItemMapping.itemId
+    try:
+        vendor = Vendor.query.filter_by(id=vendorId).one()
+    except:
+        raise InventoryServiceException(101, "Vendor not found for vendorId " + str(vendorId))
+    try:
+        item = Item.query.filter_by(id=itemId).one()
+    except:
+        raise InventoryServiceException(101, "Item not found for vendorId " + str(itemId))
+    try:
+        ds_vendorItemMapping = VendorItemMapping.query.filter(and_(VendorItemMapping.vendor==vendor, VendorItemMapping.item==item, VendorItemMapping.item_key==vendorItemMapping.itemKey)).one()
+    except:
+        ds_vendorItemMapping = VendorItemMapping()
+        ds_vendorItemMapping.vendor = vendor
+        ds_vendorItemMapping.item = item
+        ds_vendorItemMapping.vendor_category = vendorItemMapping.vendorCategory
+    ds_vendorItemMapping.item_key = vendorItemMapping.itemKey
+    session.commit()
+    return
 def validate_prices(item, vendorPrices = None):
     if item.mrp != "" and item.sellingPrice != "" and item.mrp < item.sellingPrice:
         raise InventoryServiceException("[BAD MRP and SP:] for {0} {1} {2} {3}. MRP={4}, SP={5}".format(item.productGroup, item.brand, item.modelNumber, item.color, item.mrp, item.sellingPrice))
     if not vendorPrices:
         vendorPricesList = [to_t_vendor_item_pricing(vip) for vip in get_all_item_pricing(item.id)]
     return
 def get_all_vendors():
     return Vendor.query.all()
+def check_similar_item(product_group, brand, model_number, color):
+    item = Item.query.filter_by(product_group=product_group,brand=brand,model_number=model_number,color=color).first()
+    if item is None:
+        return 0
+    else:
+        return item.id
 def close_session():
     if session.is_active:
         print "session is active. closing it."
         session.close()

Subversion Repositories SmartDukaan

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