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

                     if ds_item.sellingPrice != amazonItem.sellingPrice:
                         sync = False
                 if amazonItem.isFbb:
                     if ds_item.sellingPrice != amazonItem.fbbPrice:
                         sync = False
+                if amazonItem.isFbg:
+                    if ds_item.sellingPrice != amazonItem.fbgPrice:
+                        sync = False
                 if sync:
                     amazonItem.fbaPrice = item.sellingPrice
                     amazonItem.sellingPrice=item.sellingPrice
                     amazonItem.fbbPrice=item.sellingPrice
+                    amazonItem.fbgPrice=item.sellingPrice
                     amazonItem.mfnPriceLastUpdatedOn = datetime.datetime.now()
                     amazonItem.fbaPriceLastUpdatedOn = datetime.datetime.now()
                     amazonItem.fbbPriceLastUpdatedOn = datetime.datetime.now()
+                    amazonItem.fbgPriceLastUpdatedOn = datetime.datetime.now()
                     message +="Amazon Prices Synced."
                 else:
                     message +="Amazon Prices Not Synced."
             message += "Selling Price is changed from {0} to {1}.\n".format(ds_item.sellingPrice, item.sellingPrice)
 def get_all_amazon_listed_items():
     return session.query(Amazonlisted).all()
 def get_amazon_item_details(amazonItemId):
     amazonlisted = Amazonlisted.get_by(itemId=amazonItemId)
-    fbaPromo, fbbPromo = __get_amazon_promotion_attributes_for_item(amazonItemId)
+    fbaPromo, fbbPromo, fbgPromo = __get_amazon_promotion_attributes_for_item(amazonItemId)
-    return amazonlisted, fbaPromo, fbbPromo
+    return amazonlisted, fbaPromo, fbbPromo, fbgPromo
 def update_amazon_item_details(amazonlisted):
     amazon_listed = Amazonlisted.get_by(itemId = amazonlisted.itemid)
     amazon_listed.isFba=amazonlisted.isFba
     amazon_listed.isFbb=amazonlisted.isFbb
+    amazon_listed.isFbg=amazonlisted.isFbg
     amazon_listed.isNonFba=amazonlisted.isNonFba
     amazon_listed.isInventoryOverride=amazonlisted.isInventoryOverride
     amazon_listed.handlingTime=amazonlisted.handlingTime
     amazon_listed.isCustomTime=amazonlisted.isCustomTime
     amazon_listed.taxCode=amazonlisted.taxCode
     amazon_listed.fbbtaxCode=amazonlisted.fbbtaxCode
+    amazon_listed.fbgtaxCode=amazonlisted.fbgtaxCode
     if (amazon_listed.sellingPrice != amazonlisted.sellingPrice) and amazonlisted.sellingPrice > 0:
         amazon_listed.mfnPriceLastUpdatedOn = datetime.datetime.now()
         amazon_listed.sellingPrice=amazonlisted.sellingPrice
     if (amazon_listed.fbaPrice != amazonlisted.fbaPrice) and amazonlisted.fbaPrice > 0:
         amazon_listed.fbaPriceLastUpdatedOn = datetime.datetime.now()
         amazon_listed.fbaPrice=amazonlisted.fbaPrice
     if (amazon_listed.fbbPrice != amazonlisted.fbbPrice) and amazonlisted.fbbPrice > 0:
         amazon_listed.fbbPriceLastUpdatedOn = datetime.datetime.now()
         amazon_listed.fbbPrice=amazonlisted.fbbPrice
+    if (amazon_listed.fbgPrice != amazonlisted.fbgPrice) and amazonlisted.fbgPrice > 0:
+        amazon_listed.fbgPriceLastUpdatedOn = datetime.datetime.now()
+        amazon_listed.fbgPrice=amazonlisted.fbgPrice
     amazon_listed.suppressMfnPriceUpdate=amazonlisted.suppressMfnPriceUpdate
     amazon_listed.suppressFbaPriceUpdate=amazonlisted.suppressFbaPriceUpdate
     amazon_listed.suppressFbbPriceUpdate=amazonlisted.suppressFbbPriceUpdate
+    amazon_listed.suppressFbgPriceUpdate=amazonlisted.suppressFbgPriceUpdate
     amazon_listed.overrrideWanlc = amazonlisted.overrrideWanlc
     amazon_listed.exceptionalWanlc = amazonlisted.exceptionalWanlc
     amazon_listed.autoDecrement = amazonlisted.autoDecrement
     amazon_listed.autoIncrement = amazonlisted.autoIncrement
     amazon_listed.autoFavourite = amazonlisted.autoFavourite
         amazon_listed.fbaPromoPrice = amazonlisted.fbaPromoPrice
         amazon_listed.fbaPriceLastUpdatedOn = datetime.datetime.now()
     if amazon_listed.fbbPromoPrice != amazonlisted.fbbPromoPrice and amazonlisted.fbbPromoPrice > 0:
         amazon_listed.fbbPromoPrice = amazonlisted.fbbPromoPrice
         amazon_listed.fbbPriceLastUpdatedOn = datetime.datetime.now()
+    if amazon_listed.fbgPromoPrice != amazonlisted.fbgPromoPrice and amazonlisted.fbgPromoPrice > 0:
+        amazon_listed.fbgPromoPrice = amazonlisted.fbgPromoPrice
+        amazon_listed.fbgPriceLastUpdatedOn = datetime.datetime.now()
     session.commit()
 def add_amazon_item(amazonlisted):
     if (not amazonlisted) or (not amazonlisted.itemid) or (not amazonlisted.asin):
         return
             amazon_item.fbbPrice = amazonlisted.fbbPrice
             amazon_item.fbbPriceLastUpdatedOnSc = datetime.datetime.now()
             amazon_item.fbbPriceLastUpdatedOn = datetime.datetime.now()
         amazon_item.isFbb = False
         amazon_item.suppressFbbPriceUpdate = False
+        if amazonlisted.fbgPrice:
+            amazon_item.fbgPrice = amazonlisted.fbbPrice
+            amazon_item.fbgPriceLastUpdatedOnSc = datetime.datetime.now()
+            amazon_item.fbgPriceLastUpdatedOn = datetime.datetime.now()
+        amazon_item.isFbg = False
+        amazon_item.suppressFbgPriceUpdate = False
         amazon_item.autoDecrement = True
         amazon_item.autoIncrement = True
     elif (amazonItem.asin!=amazonlisted.asin):
         if amazonlisted.asin:
         for sku in skuList:
             amazonItem = Amazonlisted.get_by(itemId=sku)
             amazonItem.fbbPriceLastUpdatedOnSc = to_py_date(timestamp)
             session.commit()
         return True
+    elif feedType == 'FbgPricing':
+        for sku in skuList:
+            amazonItem = Amazonlisted.get_by(itemId=sku)
+            amazonItem.fbgPriceLastUpdatedOnSc = to_py_date(timestamp)
+            session.commit()
+        return True
     elif feedType== 'FullFbaPricing':
         for sku in skuList:
             amazonItem = Amazonlisted.get_by(itemId=sku)
             amazonItem.fbaPriceLastUpdatedOnSc = to_py_date(timestamp)
             session.commit()
         for sku in skuList:
             amazonItem = Amazonlisted.get_by(itemId=sku)
             amazonItem.isFba = True
             session.commit()
         return True
+    elif (feedType=='FbgListingFeed'):
+        for sku in skuList:
+            amazonItem = Amazonlisted.get_by(itemId=sku)
+            amazonItem.isFbg = True
+            session.commit()
+        return True
     elif (feedType=='NonFbaListingFeed'):
         for sku in skuList:
             amazonItem = Amazonlisted.get_by(itemId=sku)
             amazonItem.isNonFba = True
             session.commit()
         d_amazonPromotion.promotionActive = False
         if d_amazonPromotion.sku.startswith('FBA'):
             d_amazonPromotion.stateId = 1
         elif d_amazonPromotion.sku.startswith('FBB'):
             d_amazonPromotion.stateId = 2
+        elif d_amazonPromotion.sku.startswith('FBG'):
+            d_amazonPromotion.stateId = 3
         else:
             raise CatalogServiceException(101, "Amazon Promotion Illegal sku id "+sku)
         d_amazonPromotion.promotionType = amazonPromotion.promotionType
         if d_amazonPromotion.promotionType == AmazonPromotionType._NAMES_TO_VALUES.get('LONGTERM'):
             amazonItem = get_amazon_item_details(int(d_amazonPromotion.sku[3:]))
             if d_amazonPromotion.stateId == 1:
                 amazonItem[0].fbaPromoPrice =  amazonPromotion.salePrice
                 amazonItem[0].fbaPromoStartDate = to_py_date(amazonPromotion.startDate)
                 amazonItem[0].fbaPromoEndDate =  to_py_date(amazonPromotion.endDate)
                 amazonItem[0].fbaPromoActive = False
-            else:
+            elif d_amazonPromotion.stateId == 2:
                 amazonItem[0].fbbPromoPrice =  amazonPromotion.salePrice
                 amazonItem[0].fbbPromoStartDate = to_py_date(amazonPromotion.startDate)
                 amazonItem[0].fbbPromoEndDate =  to_py_date(amazonPromotion.endDate)
                 amazonItem[0].fbbPromoActive = False
+            else:
+                amazonItem[0].fbgPromoPrice =  amazonPromotion.salePrice
+                amazonItem[0].fbgPromoStartDate = to_py_date(amazonPromotion.startDate)
+                amazonItem[0].fbgPromoEndDate =  to_py_date(amazonPromotion.endDate)
+                amazonItem[0].fbgPromoActive = False
         else:
             d_amazonPromotion.promotionActive = True
     session.commit()
     return True
         amp.updatedOnMarketplace = datetime.datetime.now()
         if amp.promotionType == 1:
             amazonItem = get_amazon_item_details(int(amp.sku[3:]))
             if amp.stateId == 1:
                 amazonItem[0].fbaPromotionActive = True
-            else:
+            elif amp.stateId == 2:
                 amazonItem[0].fbbPromotionActive = True
+            else:
+                amazonItem[0].fbgPromotionActive = True
     session.commit()
     return True
 def __get_amazon_promotion_attributes_for_item(item_id):
     timestamp = datetime.datetime.now()
     fbaPromo = AmazonPromotion.query.filter(AmazonPromotion.sku=='FBA'+str(item_id)).filter(AmazonPromotion.startDate<=timestamp).filter(AmazonPromotion.endDate>=timestamp).filter(AmazonPromotion.updatedOnMarketplace>to_py_date(0)).order_by(desc(AmazonPromotion.updatedOnMarketplace)).limit(1).all()
     fbbPromo = AmazonPromotion.query.filter(AmazonPromotion.sku=='FBB'+str(item_id)).filter(AmazonPromotion.startDate<=timestamp).filter(AmazonPromotion.endDate>=timestamp).filter(AmazonPromotion.updatedOnMarketplace>to_py_date(0)).order_by(desc(AmazonPromotion.updatedOnMarketplace)).limit(1).all()
-    return fbaPromo, fbbPromo
+    fbgPromo = AmazonPromotion.query.filter(AmazonPromotion.sku=='FBG'+str(item_id)).filter(AmazonPromotion.startDate<=timestamp).filter(AmazonPromotion.endDate>=timestamp).filter(AmazonPromotion.updatedOnMarketplace>to_py_date(0)).order_by(desc(AmazonPromotion.updatedOnMarketplace)).limit(1).all()
+    return fbaPromo, fbbPromo, fbgPromo
 def get_ex_affiliate_item_info():
         query = session.query(ExclusiveAffiliateItemInfo, OutboundAffiliateMaster.name).join((OutboundAffiliateMaster, ExclusiveAffiliateItemInfo.affiliateId==OutboundAffiliateMaster.id)).filter(ExclusiveAffiliateItemInfo.isActive == True).all()
         close_session()
         map = {}
         for q in query:
             map[q[0].itemId]=to_t_exclusive_affiliate_item_info(q)
-        return map
         return map
+def get_all_items_to_list_on_fbg():
+    return Amazonlisted.query.filter(Amazonlisted.isFbg==False).filter(or_(Amazonlisted.fbgtaxCode!=None,Amazonlisted.fbgtaxCode!="")).all()
+def get_all_fbg_listed_items():
+    return Amazonlisted.query.filter(Amazonlisted.isFbg==True).all()

Subversion Repositories SmartDukaan

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