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

     except:
         return False
 def send_product_notifications():
-    product_notifications = ProductNotification.query.all()
+    product_notifications = ProductNotification.query.order_by(ProductNotification.addedOn).all()
+    itemcountmap = {}
+    itemstatusmap = {}
     for product_notification in product_notifications:
         item = product_notification.item
+        if itemcountmap.has_key(item.id):
+            itemcountmap[item.id] = itemcountmap.get(item.id) + 1
+        else:
-        client = InventoryClient().get_client()
+            client = InventoryClient().get_client()
-        availability = client.getItemAvailabilityAtLocation(item.id, sourceId)[4]
+            availability = client.getItemAvailabilityAtLocation(item.id, sourceId)[4]
-        if item.status == status.ACTIVE and (not item.risky or availability > 0):
+            if item.status == status.ACTIVE and (not item.risky or availability > 0):
+                itemstatusmap[item.id] = True
+            else:
+                itemstatusmap[item.id] = False
+            itemcountmap[item.id] = 1
+        if itemcountmap[item.id] > 1000:
+            continue
+        if itemstatusmap[item.id]:
             __enque_product_notification_email(product_notification.email, __get_product_name(item) , product_notification.addedOn, __get_product_url(item), item.id)
             product_notification.delete()
     session.commit()
     return True

Subversion Repositories SmartDukaan