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

 '''
 Created on 23-Mar-2010
 @author: ashish
 '''
 from elixir import *
 from functools import partial
 from shop2020.clients.CatalogClient import CatalogClient
 from shop2020.clients.HelperClient import HelperClient
 from shop2020.clients.InventoryClient import InventoryClient
+from shop2020.clients.UserClient import UserClient
 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, \
-    to_t_brand_info, to_t_private_deal, to_t_exclusive_affiliate_item_info, to_t_bulk_pricing
+    to_t_brand_info, to_t_private_deal, to_t_exclusive_affiliate_item_info, \
+    to_t_bulk_pricing
 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, \
     FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
     ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice, \
     SourcePercentageMaster, SourceItemPercentage, FlipkartItem, \
     MarketPlaceUpdateHistory, SourceCategoryPercentage, MarketPlaceHistory, \
     PrivateDeals, AmazonOutOfSync, PrivateDealsPriceComparison, \
     SourceReturnPercentage, CompetitorPricing, CompetitorPricingRequest, \
-    AmazonPromotion, ExclusiveAffiliateItemInfo, OutboundAffiliateMaster, HsItem, BulkItemPricing
+    AmazonPromotion, ExclusiveAffiliateItemInfo, OutboundAffiliateMaster, HsItem, \
+    BulkItemPricing
+from shop2020.model.v1.inventory.impl.DataService import \
+    ItemLocationAvailabilityCache
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
     ItemType, PremiumType, FreebieItem as t_FreebieItem, \
     StorePricing as tStorePricing, CatalogServiceException, BannerType, InsurerType, \
     Banner as t_banner, CompetitorPricing as TCompetitorPricing, AmazonPromotionType
 from shop2020.thriftpy.model.v1.inventory.ttypes import VatType, \
-    InventoryServiceException, IgnoredInventoryUpdateItems, SnapdealInventoryItem
+    InventoryServiceException, IgnoredInventoryUpdateItems, SnapdealInventoryItem, \
-from shop2020.thriftpy.utils.ttypes import UserSmsInfo, SmsType
+    ItemLocationAvailability
 from shop2020.thriftpy.model.v1.order.ttypes import OrderSource
+from shop2020.thriftpy.utils.ttypes import UserSmsInfo, SmsType
 from shop2020.utils import EmailAttachmentSender
 from shop2020.utils.EmailAttachmentSender import mail
 from shop2020.utils.Utils import to_py_date, log_risky_flag, to_java_date
 from sqlalchemy import desc, asc
-from sqlalchemy.sql.expression import or_, distinct, func, and_
+from sqlalchemy.sql.expression import or_, distinct, func, and_, tuple_
 from sqlalchemy.sql.functions import now
 from string import Template
 import datetime
 import math
+import operator
 import sys
 import threading
 import urllib2
-from shop2020.clients.UserClient import UserClient
-import operator
 sourceId = int(ConfigClient().get_property("sourceid"))
 to_addresses = ["khushal.bhatia@shop2020.in", "chandan.kumar@shop2020.in",  "chaitnaya.vats@shop2020.in",'manoj.kumar@shop2020.in']
 to_store_addresses = ["rajveer.singh@shop2020.in"]
 mail_user = "cnc.center@shop2020.in"
     item = Item.query.filter_by(catalog_item_id=catalog_id).first()
     if item is not None:
         return True
     else:
         return False
+def get_item_location_availability_by_item_ids(item_ids):
+    pass
+def get_item_location_availability(item_locations):
+    item_location = ItemLocationAvailability()
+    tuples = []
+    for item_location in item_locations:
+        tuples.append((item_location.itemId, item_location.locationId))
+    return session.query(ItemLocationAvailabilityCache).filter(tuple_(ItemLocationAvailabilityCache.item_id, ItemLocationAvailabilityCache.location_id).in_(tuples)).all()
 def is_active(item_id):
     t_item_shipping_info = ItemShippingInfo()
     try:
         item = get_item(item_id)
     if item.modelNumber:
         ds_item.model_number = item.modelNumber
     ds_item.color = item.color
     ds_item.model_name = item.modelName
     ds_item.category = item.category
-    if item.category == 10006:
+#    if item.category == 10006:
-        itemInsurerMapping = ItemInsurerMapping.query.filter(ItemInsurerMapping.itemId == item.id).filter(ItemInsurerMapping.insurerType == InsurerType._NAMES_TO_VALUES.get("DEVICE")).first()
+#        itemInsurerMapping = ItemInsurerMapping.query.filter(ItemInsurerMapping.itemId == item.id).filter(ItemInsurerMapping.insurerType == InsurerType._NAMES_TO_VALUES.get("DEVICE")).first()
-        if itemInsurerMapping is None:
+#        if itemInsurerMapping is None:
-            itemInsurerMapping = ItemInsurerMapping()
+#            itemInsurerMapping = ItemInsurerMapping()
-            itemInsurerMapping.itemId = item.id
+#            itemInsurerMapping.itemId = item.id
-            itemInsurerMapping.insurerId = 1
+#            itemInsurerMapping.insurerId = 1
-            itemInsurerMapping.insurerType = 1
+#            itemInsurerMapping.insurerType = 1
     ds_item.comments = item.comments
     ds_item.catalog_item_id = item.catalogItemId

Subversion Repositories SmartDukaan

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