Subversion Repositories SmartDukaan

'''

Created on May 24, 2010

@author: Varun Gupta

'''

from shop2020.clients.UserClient import UserClient

from shop2020.clients.CatalogClient import CatalogClient

from shop2020.thriftpy.model.v1.user.ttypes import PromotionException

from shop2020.model.v1.user.impl import Dataservice

from shop2020.model.v1.user.impl.Dataservice import Promotion, Coupon, PromotionTracker,\

    RechargeVoucher

from shop2020.utils.Utils import to_py_date

from elixir import session

import datetime, traceback

def initialize(dbname = 'user', db_hostname="localhost"):

    Dataservice.initialize(dbname, db_hostname)

def create_promotion(name, rule_execution_src, start_on, end_on):

    promotion = Promotion()

    promotion.name = name

    promotion.rule_execution_src = rule_execution_src

    promotion.start_on = to_py_date(start_on)

    promotion.end_on = to_py_date(end_on)

    promotion.created_on = datetime.datetime.now()

    session.commit()

def get_all_promotions():

    return Promotion.query.all()

def generate_coupons_for_promotion(promotion_id, coupon_code):

    promotion = Promotion.get_by(id = promotion_id)

    coupon = Coupon()

    coupon.promotion = promotion

    coupon.coupon_code = coupon_code

    coupon.arguments = ""

    session.commit()

def apply_coupon(coupon_code, cart_id):

    coupon = Coupon.get_by(coupon_code = coupon_code)

    if coupon:

        user_client = UserClient().get_client()

        cart = user_client.getCart(cart_id)

        coupon_module = coupon.promotion.rule_execution_src.strip()

        try:

            user_client.deleteDiscountsFromCart(cart_id)

            imported_coupon_module = __import__("shop2020.model.v1.user.promotionrules", globals(), locals(), [coupon_module])

            rule = eval("imported_coupon_module." + coupon_module)

            args = eval(coupon.arguments) if coupon.arguments is not None else {}

            updated_cart, discounts = rule.execute(cart, coupon_code, args)

            if discounts and len(discounts) > 0:    user_client.saveDiscounts(discounts)

            user_client.applyCouponToCart(cart_id, coupon_code, updated_cart.totalPrice, updated_cart.discountedPrice)

            return updated_cart

        except ImportError as e:

            traceback.print_stack()

            #TODO: Better message

            raise PromotionException(100, 'Internal error occurred.')

    else:

        print 'Invalid Coupon Code'

        raise PromotionException(101, 'Invalid Coupon Code')

def track_coupon_usage(coupon_code, transaction_id, user_id):

    promotion_tracker = PromotionTracker()

    promotion_tracker.coupon_code = coupon_code

    promotion_tracker.transaction_id = transaction_id

    promotion_tracker.user_id = user_id

    promotion_tracker.applied_on = datetime.datetime.now()

    session.commit()

def get_active_coupons():

    return Coupon.query.all()

def get_successful_payment_count_for_coupon(coupon_code):

    return PromotionTracker.query.filter_by(coupon_code = coupon_code).count()

def get_rule_doc_string(rule_name):

    imported_coupon_module = __import__("shop2020.model.v1.user.promotionrules", globals(), locals(), [rule_name])

    rule = eval("imported_coupon_module." + rule_name)

    return rule.__doc__

def close_session():

    if session.is_active:

        session.close()

def is_alive():

    try:

        session.query(Promotion.id).limit(1).one()

        return True

    except:

        return False

def get_discounts_for_entity(entity_id):

    catalog_client = CatalogClient().get_client()

    items = catalog_client.getItemsByCatalogId(entity_id)

    discount_finder = ItemDiscountFinder()

    discounts = discount_finder.getCouponsAndDiscountsOnItem(items[0])

    if len(discounts) > 0:

        return {discounts[0][0]: discounts[0][1]}

    else:

        return {}

def get_item_discount_map(item_ids):

    discount_finder = ItemDiscountFinder()

    item_coupons_discounts = []

    catalog_client = CatalogClient().get_client()

    for item_id in item_ids:

        item = catalog_client.getItem(item_id)

        discounts = discount_finder.getCouponsAndDiscountsOnItem(item)

        for discount in discounts:

            item_coupons_discounts.append((item_id, discount[0], discount[1]))

            break

    return item_coupons_discounts

def add_voucher(t_voucher):

    voucher = RechargeVoucher()

    voucher.available = True

    voucher.amount = t_voucher.amount

    voucher.voucherCode = t_voucher.voucherCode

    voucher.voucherType = t_voucher.voucherType

    if t_voucher.issuedOn:

        voucher.issuedOn = to_py_date(t_voucher.issuedOn)

    if t_voucher.expiredOn:

        voucher.expiredOn = to_py_date(t_voucher.expiredOn)

    session.commit()

def assign_voucher(userId, userEmail, voucherType, amount):

    voucher = RechargeVoucher.query.filter_by(voucherType = voucherType, amount = amount, available = True).first()

    if not voucher:

        raise PromotionException(501, 'Voucher of this type is not available.')

    voucher.userId = userId

    voucher.available = False

    voucher.issuedOn = datetime.datetime.now()

    voucher.email = userEmail

    session.commit()

    return voucher

def mark_voucher_as_redeemed(voucherCode, redeemedOn):

    voucher = RechargeVoucher.query.filter_by(voucherCode = voucherCode).first()

    voucher.redeemedOn = to_py_date(redeemedOn)

    voucher.redeemed = True

    session.commit()

    return True

class ItemDiscountFinder:

    def __init__(self):

        self.coupon_modules = {}

        coupons = get_active_coupons()

        for coupon in coupons:

            if coupon.coupon_code not in ('4B@R10DER5', 'SAHOLIC4RS', 'SGalaxy', 'SAHOLIC4MJ', 'SAHOLIC4SS'):

                coupon_rule = coupon.promotion.rule_execution_src.strip()

                imported_coupon_module = __import__("shop2020.model.v1.user.promotionrules", globals(), locals(), [coupon_rule])

                self.coupon_modules[coupon.coupon_code] = eval("imported_coupon_module." + coupon_rule)

    def getCouponsAndDiscountsOnItem(self, item):

        discounts = []

        for coupon_code, coupon_rule_module in self.coupon_modules.iteritems():

            discount = coupon_rule_module.getDiscountOnItem(item)

            if discount is not None:

                discounts.append((coupon_code, discount))

        return discounts