Subversion Repositories SmartDukaan

#!/usr/bin/python 

'''

If a order has been marked as delivered for more than

5 days and it has spicedeck voucher issuance penning, voucher should be issued.

@author: Rajveer

'''

import datetime

from datetime import date

import optparse

import sys

import urllib

import urllib2

import traceback

from string import Template

if __name__ == '__main__' and __package__ is None:

    import os

    sys.path.insert(0, os.getcwd())

from shop2020.clients.HelperClient import HelperClient

from shop2020.clients.PromotionClient import PromotionClient

from shop2020.clients.CRMClient import CRMClient

from shop2020.thriftpy.model.v1.order.ttypes import OrderStatus

from shop2020.model.v1.order.impl import DataService

from shop2020.model.v1.order.impl.DataService import RechargeVoucherTracker

from shop2020.thriftpy.model.v1.user.ttypes import Voucher, VoucherType

from shop2020.thriftpy.crm.ttypes import Ticket, Activity, TicketCategory, TicketStatus, TicketPriority, ActivityType

from elixir import session

voucherGenerationUrl = "http://www.spicedeck.com/couponregister.sdesk"

voucherActivationUrl = "http://www.spicedeck.com/couponassign.sdesk"

voucherDeactivationUrl = "http://www.spicedeck.com/coupondeact.sdesk"

voucherStatusUrl = "http://www.spicedeck.com/couponstatus.sdesk"

username = "saholic"

password = "abc1234"

def issue_voucher_to_orders(db_hostname):

    DataService.initialize(db_hostname=db_hostname, echoOn=True)

    vouchers = RechargeVoucherTracker.query.filter_by(voucherIssued=False).all()

    for voucher in vouchers:

        order = voucher.order

        if order.status == OrderStatus.DELIVERY_SUCCESS:

            storeVoucher(voucher.amount)

            coupon = issueVoucher(order.customer_id, order.customer_email, voucher.amount)

            voucher.issuedOn = datetime.datetime.now()

            voucher.voucherIssued = True

            voucher.voucherCode = coupon

            session.commit()

            #sendEmail(order.customer_email, voucher.amount, order.id, coupon)

            createCrmTicket(voucher)

def createCrmTicket(voucher):

    try :

        cc = CRMClient().get_client()

        ticket = Ticket()

        activity = Activity()

        order = voucher.order

        ticket.category = TicketCategory.OTHER

        ticket.customerEmailId = order.customer_email

        ticket.customerId = order.customer_id

        ticket.customerMobileNumber = order.customer_mobilenumber

        ticket.customerName = order.customer_name

        ticket.description = "Amount : " + str(voucher.amount) + " Issue date : " + str(voucher.issuedOn) + " Code : " + str(voucher.voucherCode)

        ticket.orderId = order.id

        ticket.creatorId = 1

        ticket.priority = TicketPriority.LOW

        ticket.status = TicketStatus.OPEN

        activity.creatorId = 1

        activity.ticketAssigneeId = ticket.assigneeId

        activity.type = ActivityType.OTHER

        activity.description = "Creating Ticket"

        activity.ticketCategory = ticket.category

        activity.ticketDescription = ticket.description

        activity.ticketPriority = ticket.priority

        activity.ticketStatus = ticket.status

        activity.customerEmailId = order.customer_email

        activity.customerId = order.customer_id

        activity.customerMobileNumber = order.customer_mobilenumber

        activity.customerName = order.customer_name

        cc.insertTicket(ticket, activity)

    except:

        print "Some issue while creating crm tickets for orders in FIRST_DELIVERY_ATTEMPT_MADE status"

        traceback.print_exc()

def storeVoucher(amount):

    coupon = generateVoucher(amount)

    voucher = Voucher()

    voucher.voucherCode = coupon

    voucher.voucherType = VoucherType.SPICEDECK_MOBILE

    voucher.amount = amount

    pc = PromotionClient().get_client()

    pc.addVoucher(voucher)

def generateVoucher(amount):

    params = "userid=" + username + "&password=" + password + "&amount=" + str(amount) 

    returnValue = urllib.urlopen(voucherGenerationUrl + "?" + params).read()

    if "-1" == returnValue:

        raise Exception("Credit balance low.")

    elif "0" == returnValue:

        raise Exception("Network or some other failure.")

    return returnValue;

def issueVoucher(userId, userEmail, amount):

    pc = PromotionClient().get_client()

    voucher = pc.assignVoucher(userId, userEmail, VoucherType.SPICEDECK_MOBILE, amount)

    isActivated = activateVoucher(voucher.voucherCode, voucher.userEmail);

    if not isActivated:

        raise Exception("Voucher could not get activated.");

    return voucher.voucherCode

def activateVoucher(voucherCode, userEmail):

    today = date.today() + datetime.timedelta(365/4)

    params = "userid=" + username + "&password=" + password + "&cid=" + voucherCode + "&email=" + userEmail + "&expiry=" + today.strftime('%d-%b-%y') 

    returnValue = urllib.urlopen(voucherActivationUrl + "?" + params).read()

    if "1" == returnValue:

        return True;

    elif "-1" == returnValue:

        raise Exception("Invalid voucher.")

    elif "0" == returnValue:

        raise Exception("Network or some other failure.")

    return False

def deactivateVoucher(voucherCode, reason):

    params = "userid=" + username + "&password=" + password + "&cid=" + voucherCode + "&comment=" + reason 

    returnValue = urllib.urlopen(voucherDeactivationUrl + "?" + params).read()

    print returnValue

    ## 0#2#2#pankaj.kankar@shop2020.in

    tokens = returnValue.split('#')

    status = tokens[0]

    actualAmount = int(tokens[1])

    availableAmount = int(tokens[2])

    email = tokens[3] 

    if "1" == status:

        return True;

    elif "0" == status:

        raise Exception("Voucher could not be deactivated")

    elif "-1" == status:

        raise Exception("Network or some other failure.")

    return False

def checkVoucherStatus(voucherCode):

    params = "userid=" + username + "&password=" + password + "&cid=" + voucherCode

    returnValue = urllib.urlopen(voucherStatusUrl + "?" + params).read()

    print returnValue

    ## ACTIVATE#2#2#pankaj.kankar@shop2020.in

    ## DEACTIVATED#2#2#pankaj.kankar@shop2020.in

    ## CONSUMED

    ## EXPIRED

    if "-1" == returnValue:

        raise Exception("Network or some other failure.")

    else:

        tokens = returnValue.split('#')

        status = tokens[0]

        actualAmount = int(tokens[1])

        availableAmount = int(tokens[2])

        email = tokens[3]

def sendEmail(email, amount, orderId, voucherCode):

    html = """

        <html>

        <body>

        <div>

        <p>

            Hi,<br /><br />

            Recharge voucher of $amount against order id $orderId is mentioned below. You can use it to recharge mobile through www.spicedeck.com. 

        </p>

        <p>    

        <strong>Product: $voucherCode </strong>

        </p>

        <p>

        Regards,<br/>

        Saholic Customer Support Team<br/>

        www.saholic.com<br/>

        Email: help@saholic.com<br/>

        </p>

        </div>

        </body>

        </html>

        """

    html = Template(html).substitute(dict(orderId=orderId,amount=amount,voucherCode=voucherCode))

    try:

        helper_client = HelperClient().get_client()

        helper_client.saveUserEmailForSending(email, "", "Recharge voucher against order id " + str(orderId), html, str(orderId), "RechargeVoucher")

    except Exception as e:

        print e

def main():

    parser = optparse.OptionParser()

    #    parser.add_option("-d", "--days", dest="days",

    #                   default=5, type="int",

    #                   help="issue voucher to the delivered orders before NUM days",

    #                   metavar="NUM")

    parser.add_option("-H", "--host", dest="hostname",

                      default="localhost",

                      type="string", help="The HOST where the DB server is running",

                      metavar="HOST")

    (options, args) = parser.parse_args()

    if len(args) != 0:

        parser.error("You've supplied extra arguments. Are you sure you want to run this program?")

    #issue_voucher_to_orders(options.days, options.hostname)

    issue_voucher_to_orders(options.hostname)

    #checkVoucherStatus('SHL1340973067027')

    #deactivateVoucher('SHL1340973067027', 'Order not delivered')

if __name__ == '__main__':

    main()