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

 from urllib2 import HTTPBasicAuthHandler
 import datetime
 import sys
 import urllib2
 import calendar
+from functools import partial
+import threading
+to_addresses = ["cnc.center@shop2020.in", "ashutosh.saxena@shop2020.in"]
+from_user = "cnc.center@shop2020.in"
+from_pwd = "5h0p2o2o"
 def initialize():
     DataService.initialize()
 def get_all_items_by_status(status, offset=0, limit=None):
         raise InventoryServiceException(101, "Missing id for update")
     validate_item_prices(item)
     ds_item = get_item(item.id)
+    message = ""
     if not ds_item:
         raise InventoryServiceException(101, "Item missing in our database")
     if item.productGroup:
         ds_item.product_group = item.productGroup
     ds_item.comments = item.comments
     ds_item.catalog_item_id = item.catalogItemId
     ds_item.mrp = item.mrp
+    if ds_item.sellingPrice or item.sellingPrice:
+        if ds_item.sellingPrice != item.sellingPrice:
+            message += "Selling Price is changed from {0} to {1}.\n".format(ds_item.sellingPrice, item.sellingPrice)
     ds_item.sellingPrice = item.sellingPrice
     ds_item.weight = item.weight
     if ds_item.status != item.itemStatus:
         add_status_change_log(ds_item, item.itemStatus)
+        if item.itemStatus == status.PHASED_OUT:
+            message += "Item is phased out."
         ds_item.status = item.itemStatus
     if item.status_description:
         ds_item.status_description = item.status_description
     if item.startDate:
         ds_item.retireDate = None
     ds_item.feature_id = item.featureId
     ds_item.feature_description = item.featureDescription
+    if ds_item.bestDealText or item.bestDealText:
+        if item.bestDealText != ds_item.bestDealText:
+            message += "Promotion text is changed from '{0}' to '{1}\n".format(ds_item.bestDealText, item.bestDealText)
     ds_item.bestDealText = item.bestDealText
     ds_item.bestDealValue = item.bestDealValue
     ds_item.bestSellingRank = item.bestSellingRank
     ds_item.defaultForEntity = item.defaultForEntity
+    if ds_item.risky or item.risky:
+        if ds_item.risky != item.risky:
+            message += "Risky flag is changed to {0}\n".format(set)
     ds_item.risky = item.risky
     if item.expectedDelay is not None:
         ds_item.expectedDelay = item.expectedDelay
     ds_item.isWarehousePreferenceSticky = item.isWarehousePreferenceSticky
     ds_item.updatedOn = datetime.datetime.now()
     session.commit();
+    subject = "Item '{0}' is updated in Catalog. Id is {1}".format(__get_product_name(ds_item),ds_item.id)
+    if message:
+        __send_mail(subject, message)
     return ds_item.id
 def add_item(item):
     if not item:
         raise InventoryServiceException(108, "Bad item in request")
         ds_item.product_group = similar_item.product_group
         ds_item.status = similar_item.status
         ds_item.status_description = similar_item.status_description
     session.commit();
+    subject = "New item is added. Id is " + ds_item.id
+    message = "Category : {6}, Brand : {0}, Model : {1}, Model Number : {2}\nColor : {3}, Selling Price : {4}, Mrp : {5}, \nPromotion Text : {7}".format(item.brand, item.modelNumber, item.modelName, item.color, item.sellingPrice, item.mrp, item.category, item.bestDealText)
+    __send_mail(subject, message)
     return ds_item.id
 def update_inventory_history(warehouse_id, timestamp, availability):
     warehouse = get_Warehouse(warehouse_id)
     if not warehouse:
         raise InventoryServiceException(108, "item id not present")
     add_status_change_log(item, new_status)
     item.status = new_status
     if item.status == status.PHASED_OUT:
         item.status_description = "This item has been phased out"
+        __send_mail("Item '{0}' is Phased-Out. Item id is {1}".format(__get_product_name(item), item_id), "")
     elif item.status == status.DELETED:
         item.status_description = "This item has been deleted"
     elif item.status == status.PAUSED:
         item.status_description = "This item is currently out of stock"
     elif item.status == status.PAUSED_BY_RISK:
         item.status_description = "This item is currently out of stock"
         #This will clear cache from tomcat
         __clear_homepage_cache()
     elif item.status == status.ACTIVE:
         item.status_description = "This item is active"
+        __send_mail("Item '{0}' is Active. Item id is {1}".format(__get_product_name(item), item_id), "")
     elif item.status == status.IN_PROCESS:
         item.status_description = "This item is in process"
     elif item.status == status.CONTENT_COMPLETE:
         item.status_description = "This item is in process"
     session.commit()
         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))
+        raise InventoryServiceException(101, "Item not found for itemId " + str(itemId))
     validate_vendor_prices(to_t_item(item), vendorItemPricing)
     try:
         ds_vendorItemPricing = VendorItemPricing.query.filter(and_(VendorItemPricing.vendor==vendor, VendorItemPricing.item==item)).one()
     except:
         ds_vendorItemPricing = VendorItemPricing()
         ds_vendorItemPricing.vendor = vendor
         ds_vendorItemPricing.item = item
+    subject = ""
+    message = ""
     if vendorItemPricing.mop:
         ds_vendorItemPricing.mop = vendorItemPricing.mop
     if vendorItemPricing.dealerPrice:
         ds_vendorItemPricing.dealerPrice = vendorItemPricing.dealerPrice
     if vendorItemPricing.transferPrice:
+        if vendorItemPricing.transferPrice != ds_vendorItemPricing.transfer_price:
+            message = "Transfer price for Item '{0}' \nand Vendor:{1} is changed from {2} to {3}.".format(__get_product_name(item), vendor.name, ds_vendorItemPricing.transfer_price, vendorItemPricing.transferPrice)
+            subject = "Alert:Change in Transfer Price"
         ds_vendorItemPricing.transfer_price = vendorItemPricing.transferPrice
     session.commit()
+    if subject:
+        __send_mail(subject, message)
     return
 def add_vendor_item_mapping(key, vendorItemMapping):
     if not vendorItemMapping:
         raise InventoryServiceException(108, "Bad vendorItemMapping in request")
         print "Not able to log risky flag change"
     item.risky = risky
     if not risky and item.status == status.PAUSED_BY_RISK:
         change_item_status(item.id, status.ACTIVE)
     session.commit()
+    flag = "ON" if risky else "OFF"
+    subject = "Risky flag is {0} for Item {1}.".format(flag, __get_product_name(item))
+    __send_mail(subject,"")
 def get_items_for_mastersheet(categoryName, brand):
     if not categoryName or not brand:
         raise InventoryServiceException(101, "Invalid category or brand in request")
         else:
             add_inventory(itemId, warehouseId, quantity)
     else:
         raise InventoryServiceException(101, 'VendorMapping not found for: ' + itemKey)
     session.commit()
+def __send_mail(subject, message):
+    thread = threading.Thread(target=partial(mail, from_user, from_pwd, to_addresses, subject, message))
+    thread.start()

Subversion Repositories SmartDukaan

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