Subversion Repositories SmartDukaan

Rev

Rev 9621 | Rev 9776 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 9621 Rev 9724
Line 17... Line 17...
17 
    Category, EntityIDGenerator, SimilarItems, ProductNotification, Source, \
 17 
    Category, EntityIDGenerator, SimilarItems, ProductNotification, Source, \
18 
    SourceItemPricing, AuthorizationLog, VoucherItemMapping, CategoryVatMaster, \
 18 
    SourceItemPricing, AuthorizationLog, VoucherItemMapping, CategoryVatMaster, \
19 
    OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
 19 
    OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
20 
    FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
 20 
    FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
21 
    PageViewEvents, CartEvents, EbayItem, BannerUriMapping, Campaign, SnapdealItem, \
 21 
    PageViewEvents, CartEvents, EbayItem, BannerUriMapping, Campaign, SnapdealItem, \
22 
    SnapdealItemUpdateHistory, ProductFeedSubmit
 22 
    SnapdealItemUpdateHistory, ProductFeedSubmit, MarketplaceItems
23 
from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
 23 
from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
24 
    ItemType, PremiumType, FreebieItem as t_FreebieItem, \
 24 
    ItemType, PremiumType, FreebieItem as t_FreebieItem, \
25 
    StorePricing as tStorePricing, CatalogServiceException, \
 25 
    StorePricing as tStorePricing, CatalogServiceException, \
26 
    BannerType, InsurerType
 26 
    BannerType, InsurerType
27 
from shop2020.thriftpy.model.v1.inventory.ttypes import \
 27 
from shop2020.thriftpy.model.v1.inventory.ttypes import \
28 
    InventoryServiceException, IgnoredInventoryUpdateItems
 28 
    InventoryServiceException, IgnoredInventoryUpdateItems,SnapdealInventoryItem
29 
from shop2020.utils import EmailAttachmentSender
 29 
from shop2020.utils import EmailAttachmentSender
30 
from shop2020.utils.EmailAttachmentSender import mail
 30 
from shop2020.utils.EmailAttachmentSender import mail
31 
from shop2020.utils.Utils import to_py_date, log_risky_flag
 31 
from shop2020.utils.Utils import to_py_date, log_risky_flag
32 
from sqlalchemy import desc, asc
 32 
from sqlalchemy import desc, asc
33 
from sqlalchemy.sql.expression import or_, distinct, func, and_
 33 
from sqlalchemy.sql.expression import or_, distinct, func, and_
Line 2164... Line 2164...
2164 
        return False
 2164 
        return False
2165 
 
 2165 
 
2166 
def get_snapdeal_item(itemid):
 2166 
def get_snapdeal_item(itemid):
2167 
    item = session.query(SnapdealItem,Item).join((Item,SnapdealItem.item_id==Item.id)).filter(SnapdealItem.item_id==itemid).first()
 2167 
    item = session.query(SnapdealItem,Item).join((Item,SnapdealItem.item_id==Item.id)).filter(SnapdealItem.item_id==itemid).first()
2168 
    return item
 2168 
    return item
- 
 
 2169 
 
- 
 
 2170 
def get_snapdeal_item_detail(itemid):
- 
 
 2171 
    item = session.query(SnapdealItem,Item).join((Item,SnapdealItem.item_id==Item.id)).filter(SnapdealItem.item_id==itemid).first()
- 
 
 2172 
    try:
- 
 
 2173 
        client = InventoryClient().get_client()
- 
 
 2174 
        SnapdealInventoryItem = client.getSnapdealInventoryForItem(itemid)
- 
 
 2175 
        return item, SnapdealInventoryItem
- 
 
 2176 
    except Exception as e:
- 
 
 2177 
        print e
- 
 
 2178 
        return item,None
2169
2179
2170 
def get_all_snapdeal_items():
 2180 
def get_all_snapdeal_items():
2171 
    items = session.query(SnapdealItem,Item).join((Item,SnapdealItem.item_id==Item.id)).all()
 2181 
    items = session.query(SnapdealItem,Item).join((Item,SnapdealItem.item_id==Item.id)).all()
2172 
    return items
 2182 
    return items
2173 
 
 2183 
 
Line 2255... Line 2265...
2255 
 
 2265 
 
2256 
def get_all_product_feed_submit():
 2266 
def get_all_product_feed_submit():
2257 
    print session.query(ProductFeedSubmit).all()
 2267 
    print session.query(ProductFeedSubmit).all()
2258 
    return session.query(ProductFeedSubmit).all()
 2268 
    return session.query(ProductFeedSubmit).all()
2259 
 
 2269 
 
- 
 
 2270 
def get_marketplace_details_for_item(item_id, sourceId):
- 
 
 2271 
    return MarketplaceItems.get_by(itemId=item_id,source=sourceId)
- 
 
 2272 
 
- 
 
 2273 
def update_marketplace_attributes_for_item(t_marketplaceItem):
- 
 
 2274 
    if t_marketplaceItem.source is None or t_marketplaceItem.itemId is None:
- 
 
 2275 
        return False
- 
 
 2276 
    try:
- 
 
 2277 
        marketplaceItem = get_marketplace_details_for_item(t_marketplaceItem.itemId,t_marketplaceItem.source)
- 
 
 2278 
        if marketplaceItem is None:
- 
 
 2279 
            marketplaceItem = MarketplaceItems()
- 
 
 2280 
            marketplaceItem.itemId = t_marketplaceItem.itemId
- 
 
 2281 
            marketplaceItem.source = t_marketplaceItem.source
- 
 
 2282 
            marketplaceItem.emiFee =0.0
- 
 
 2283 
            marketplaceItem.closingFee = 0.0
- 
 
 2284 
            marketplaceItem.returnProvision = 0.5
- 
 
 2285 
            marketplaceItem.commission = 3.59
- 
 
 2286 
            marketplaceItem.vat = t_marketplaceItem.vat
- 
 
 2287 
            marketplaceItem.packagingCost = 15.0
- 
 
 2288 
            marketplaceItem.serviceTax = 12.36
- 
 
 2289 
            marketplaceItem.courierCost = t_marketplaceItem.courierCost
- 
 
 2290 
            marketplaceItem.otherCost = t_marketplaceItem.otherCost
- 
 
 2291 
            marketplaceItem.autoIncrement = t_marketplaceItem.autoIncrement
- 
 
 2292 
            marketplaceItem.autoDecrement = t_marketplaceItem.autoDecrement
- 
 
 2293 
            marketplaceItem.manualFavourite = t_marketplaceItem.manualFavourite
- 
 
 2294 
            marketplaceItem.currentSp = t_marketplaceItem.currentSp
- 
 
 2295 
            marketplaceItem.currentTp = t_marketplaceItem.currentTp
- 
 
 2296 
            marketplaceItem.minimumPossibleSp = t_marketplaceItem.minimumPossibleSp
- 
 
 2297 
            marketplaceItem.minimumPossibleTp = t_marketplaceItem.minimumPossibleTp
- 
 
 2298 
        else:
- 
 
 2299 
            marketplaceItem.courierCost = t_marketplaceItem.courierCost
- 
 
 2300 
            marketplaceItem.otherCost = t_marketplaceItem.otherCost
- 
 
 2301 
            marketplaceItem.autoIncrement = t_marketplaceItem.autoIncrement
- 
 
 2302 
            marketplaceItem.autoDecrement = t_marketplaceItem.autoDecrement
- 
 
 2303 
            marketplaceItem.manualFavourite = t_marketplaceItem.manualFavourite
- 
 
 2304 
            marketplaceItem.currentSp = t_marketplaceItem.currentSp
- 
 
 2305 
            marketplaceItem.currentTp = t_marketplaceItem.currentTp
- 
 
 2306 
            marketplaceItem.minimumPossibleSp = t_marketplaceItem.minimumPossibleSp
- 
 
 2307 
            marketplaceItem.minimumPossibleTp = t_marketplaceItem.minimumPossibleTp
- 
 
 2308 
        session.commit()
- 
 
 2309 
        return True
- 
 
 2310 
    except Exception as ex:
- 
 
 2311 
        print ex
- 
 
 2312 
        return False
- 
 
 2313
- 
 
 2314
- 
 
 2315
- 
 
 2316
- 
 
 2317
- 
 
 2318 
 
- 
 
 2319
- 
 
 2320