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

 from shop2020.clients.HelperClient import HelperClient
 from shop2020.clients.InventoryClient import InventoryClient
 from shop2020.config.client.ConfigClient import ConfigClient
 from shop2020.model.v1.catalog.impl import DataService
 from shop2020.model.v1.catalog.impl.CategoryManager import CategoryManager
-from shop2020.model.v1.catalog.impl.Convertors import to_t_item, to_t_source, \
+from shop2020.model.v1.catalog.impl.Convertors import to_t_item, to_t_source
-    to_t_brand_info
 from shop2020.model.v1.catalog.impl.DataService import Item, ItemChangeLog, \
     Category, EntityIDGenerator, SimilarItems, ProductNotification, Source, \
     SourceItemPricing, AuthorizationLog, VoucherItemMapping, CategoryVatMaster, \
-    OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
+    OOSTracker,EntityTag,ItemInsurerMapping, Insurer, Banner, BannerMap, \
-    FreebieItem, BrandInfo, \
+    FreebieItem, BrandInfo, Amazonlisted,StorePricing
-    OOSTracker,EntityTag,ItemInsurerMapping, Insurer, Banner, BannerMap, FreebieItem,\
-    StorePricing,Amazonlisted
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
-    ItemType, PremiumType, FreebieItem as t_FreebieItem, StorePricing as tStorePricing
+    ItemType, PremiumType, FreebieItem as t_FreebieItem,StorePricing as tStorePricing
 from shop2020.thriftpy.model.v1.inventory.ttypes import \
     InventoryServiceException, IgnoredInventoryUpdateItems
 from shop2020.utils import EmailAttachmentSender
 from shop2020.utils.EmailAttachmentSender import mail
 from shop2020.utils.Utils import to_py_date, log_risky_flag
 from string import Template
 import datetime
 import sys
 import threading
 import urllib2
+from datetime import timedelta,datetime,date
 sourceId = int(ConfigClient().get_property("sourceid"))
 to_addresses = ["khushal.bhatia@shop2020.in", "chandan.kumar@shop2020.in",  "chaitnaya.vats@shop2020.in"]
 mail_user = "cnc.center@shop2020.in"
 mail_password = "5h0p2o2o"
     ds_item.sellingPrice = item.sellingPrice
     ds_item.weight = item.weight
     ds_item.showSellingPrice = item.showSellingPrice
+    if item.asin:
+        ds_item.asin = item.asin
+    ds_item.holdInventory = item.holdInventory
+    ds_item.defaultInventory = item.defaultInventory
     if item.startDate:
         ds_item.startDate = to_py_date(item.startDate)
         ds_item.startDate = ds_item.startDate.replace(hour=0,second=0,minute=0)
         if item.itemStatus == status.COMING_SOON and ds_item.startDate < datetime.datetime.now()  :
             item.itemStatus = status.ACTIVE
         flag = "ON" if item.isWarehousePreferenceSticky else "OFF"
         message += "Warehouse preference sticky is {0}.\n".format(flag)
     ds_item.isWarehousePreferenceSticky = item.isWarehousePreferenceSticky
-    ds_item.updatedOn = datetime.datetime.now()
+    ds_item.updatedOn = datetime.now()
 #    if item.activeOnStore and  not ds_item.activeOnStore:
 #        add_store_pricing(ds_item)
     ds_item.activeOnStore = item.activeOnStore
         ds_item.color = item.color
     if item.category:
         ds_item.category = item.category
     if item.comments:
         ds_item.comments = item.comments
+    if item.asin:
+        ds_item.asin = item.asin
+    ds_item.holdInventory = item.holdInventory
+    ds_item.defaultInventory = item.defaultInventory
-    ds_item.addedOn = datetime.datetime.now()
+    ds_item.addedOn = datetime.now()
-    ds_item.updatedOn = datetime.datetime.now()
+    ds_item.updatedOn = datetime.now()
     if item.startDate:
         ds_item.startDate = to_py_date(item.startDate)
         ds_item.startDate = ds_item.startDate.replace(hour=0,second=0,minute=0)
     if item.retireDate:
         ds_item.retireDate = to_py_date(item.retireDate)
     if item.mrp == None or item.sellingPrice == None or item.mrp == "" or item.sellingPrice == "":
         return
     if item.mrp < item.sellingPrice:
         print "[BAD MRP and SP:] for {0} {1} {2} {3}. MRP={4}, SP={5}".format(item.productGroup, item.brand, item.modelNumber, item.color, str(item.mrp), str(item.sellingPrice))
         raise InventoryServiceException(101, "[BAD MRP and SP:] for {0} {1} {2} {3}. MRP={4}, SP={5}".format(item.productGroup, item.brand, item.modelNumber, item.color, str(item.mrp), str(item.sellingPrice)))
-#    if minp < item.sellingPrice:
-#        print "alert to store"
-#    if maxp > item.mrp:
-#        print "reset to mrp"
-#        print "alert to store"
     return
 def validate_vendor_prices(item, vendorPrices):
     if item.mrp != None and item.mrp != "" and vendorPrices.mop != "" and item.mrp <  vendorPrices.mop:
         print "[BAD MRP and MOP:] for {0} {1} {2} {3}. MRP={4}. MOP={5}, Vendor={6}".format(item.productGroup, item.brand, item.modelNumber, item.color, str(item.mrp), str(vendorPrices.mop), str(vendorPrices.vendorId))
         raise InventoryServiceException(101, "[BAD MRP and MOP:] for {0} {1} {2} {3}. MRP={4}. MOP={5}, Vendor={6}".format(item.productGroup, item.brand, item.modelNumber, item.color, str(item.mrp), str(vendorPrices.mop), str(vendorPrices.vendorId)))
     if vendorPrices.mop != "" and vendorPrices.transferPrice != "" and vendorPrices.transferPrice > vendorPrices.mop:
         print "[BAD MOP and TP:] for {0} {1} {2} {3}. TP={4}. MOP={5}, Vendor={6}".format(item.productGroup, item.brand, item.modelNumber, item.color, str(vendorPrices.transferPrice), str(vendorPrices.mop), str(vendorPrices.vendorId))
         raise InventoryServiceException(101, "[BAD MOP and TP:] for {0} {1} {2} {3}. TP={4}. MOP={5}, Vendor={6}".format(item.productGroup, item.brand, item.modelNumber, item.color, str(vendorPrices.transferPrice), str(vendorPrices.mop), str(vendorPrices.vendorId)))
-#    if change in dp:
-#        print "alert to store"
     return
 def check_color_valid(color):
     if color is not None:
         color = color.strip().lower()
     sp.minPrice = store.minPrice
     sp.minAdvancePrice = store.minAdvancePrice
     sp.maxPrice = store.maxPrice
     return sp
 def get_all_amazon_listed_items():
     return session.query(Amazonlisted).all()
 def get_amazon_item_details(amazonItemId):
     amazonlisted = Amazonlisted.get_by(itemId=amazonItemId)
         amazon_item.isFba=amazonlisted.isFba
     if amazonlisted.isNonFba:
         amazon_item.isNonFba=amazonlisted.isNonFba
     if amazonlisted.isInventoryOverride:
         amazon_item.isInventoryOverride=amazonlisted.isInventoryOverride
-    if amazonlisted.color:
-        amazon_item.color=amazonlisted.color
     if amazonlisted.category:
-        amazon_item.color=amazonlisted.category
+        amazon_item.category=amazonlisted.category
     session.commit()
+def get_asin_items():
+    from_date=datetime.now() - timedelta(days=10)
+    return Item.query.filter(Item.updatedOn > from_date).all()
+def get_all_fba_listed_items():
+    return Amazonlisted.query.filter(Amazonlisted.isFba==True).all()
+def get_all_nonfba_listed_items():
+    return Amazonlisted.query.filter(Amazonlisted.isNonFba==True).all()

Subversion Repositories SmartDukaan

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