Subversion Repositories SmartDukaan

from elixir import *
from shop2020.config.client.ConfigClient import ConfigClient
from shop2020.model.v1.catalog.impl import DataService
from shop2020.model.v1.catalog.impl.DataService import FlipkartItem, MarketplaceItems, Item, Category, \
MarketPlaceUpdateHistory, SourcePercentageMaster, SourceItemPercentage, SourceCategoryPercentage
from shop2020.thriftpy.model.v1.order.ttypes import OrderSource
import sys
from time import sleep
import smtplib
from datetime import datetime, timedelta
from shop2020.utils import EmailAttachmentSender
from shop2020.utils.EmailAttachmentSender import get_attachment_part
from email.mime.text import MIMEText
import email
from email.mime.multipart import MIMEMultipart
import email.encoders
import copy

config_client = ConfigClient()
host = config_client.get_property('staging_hostname')
DataService.initialize(db_hostname=host)



def getFutureExpiry():
    fkItems = []
    timestampNow = datetime.now()
    timestamp = datetime.now() + timedelta(days=3)
    expiryItems = session.query(SourceItemPercentage).filter(SourceItemPercentage.source==OrderSource.FLIPKART).filter(SourceItemPercentage.expiryDate.between(timestampNow,timestamp)).all()
    print expiryItems
    for expiryItem in expiryItems:
        fkItem = FlipkartItem.get_by(item_id=expiryItem.item_id)
        mpItem = MarketplaceItems.get_by(itemId=expiryItem.item_id, source=OrderSource.FLIPKART)
        item = Item.get_by(id=expiryItem.item_id) 
        if fkItem is not None or mpItem is not None:
            temp = []
            temp.append(expiryItem)
            temp.append(fkItem)
            temp.append(mpItem)
            comObj = getFutureCommission(OrderSource.FLIPKART,item,timestamp)
            temp.append(comObj)
            temp.append(item)
            fkItems.append(temp)
    return fkItems


def validateCommission():
    diffItems = []
    items_mp = session.query(Item,MarketplaceItems).join((MarketplaceItems,Item.id==MarketplaceItems.itemId)).filter(MarketplaceItems.source==OrderSource.FLIPKART).all()
    for item_mp in items_mp:
        mpItem = item_mp[1]
        currentComObj = getCurrentValidCommission(OrderSource.FLIPKART,item_mp[0])
        if (currentComObj.commission!=mpItem.commission):
            temp=[]
            temp.append(item_mp[0]) #item
            temp.append(item_mp[1]) #mpItem
            temp.append(copy.deepcopy(item_mp[1])) #mpItemCopy
            temp.append(currentComObj) #comObj
            diffItems.append(temp)
    return diffItems

def getFutureCommission(source_id,item,time):
    sip = SourceItemPercentage.query.filter(SourceItemPercentage.item_id==item.id).filter(SourceItemPercentage.source==source_id).filter(SourceItemPercentage.startDate<=time).filter(SourceItemPercentage.expiryDate>=time).first()
    if sip is not None:
        return sip
    scp = SourceCategoryPercentage.query.filter(SourceCategoryPercentage.category_id==item.category).filter(SourceCategoryPercentage.source==source_id).filter(SourceCategoryPercentage.startDate<=time).filter(SourceCategoryPercentage.expiryDate>=time).first()
    if scp is not None:
        return scp
    else:
        spm = SourcePercentageMaster.get_by(source=source_id)
        return spm

def getCurrentValidCommission(source_id,item):
    time = datetime.now()
    sip = SourceItemPercentage.query.filter(SourceItemPercentage.item_id==item.id).filter(SourceItemPercentage.source==source_id).filter(SourceItemPercentage.startDate<=time).filter(SourceItemPercentage.expiryDate>=time).first()
    if sip is not None:
        return sip
    else:
        scp = SourceCategoryPercentage.query.filter(SourceCategoryPercentage.category_id==item.category).filter(SourceCategoryPercentage.source==source_id).filter(SourceCategoryPercentage.startDate<=time).filter(SourceCategoryPercentage.expiryDate>=time).first()
        if scp is not None:
            return scp
        else:
            spm = SourcePercentageMaster.get_by(source=source_id)
            return spm

def sendMailAndSync(fkItems,syncedItems):
    if len(fkItems) == 0 and len(syncedItems) ==0:
        print "Nothing to send"
        return
    xstr = lambda s: s or ""
    message="""<html>
            <body>
            <h3>Commission about to get expire</h3>
            <p>System will automatically update commission on expiry</p>
            <table border="1" style="width:100%;">
            <thead>
            <tr><th>Product Name</th>
            <th>SP</th>
            <th>Current TP</th>
            <th>Future TP</th>
            <th>Current BE</th>
            <th>Future BE</th>
            <th>Old Com%</th>
            <th>Future Com%</th>
            <th>Old Margin</th>
            <th>New Margin</th>
            <th>Old Margin%</th>
            <th>New Margin%</th>
            <th>Expiry</th>
            </tr></thead>
            <tbody>"""
    for fkItem in fkItems:
        expiryItem = fkItem[0]
        flipkartObj = fkItem[1]
        mpItem = fkItem[2]
        comObj = fkItem[3]
        item = fkItem[4]
        message+="""<tr>
        <td style="text-align:center">"""+xstr(item.brand)+" "+xstr(item.model_name)+" "+xstr(item.model_number)+" "+xstr(item.color)+"""</td>
        <td style="text-align:center">"""+str(mpItem.currentSp)+"""</td>
        <td style="text-align:center">"""+str(round(mpItem.currentTp))+"""</td>
        <td style="text-align:center">"""+str(getNewTp(mpItem,comObj))+"""</td>
        <td style="text-align:center">"""+str(mpItem.minimumPossibleSp)+"""</td>
        <td style="text-align:center">"""+str(getNewBreakEven(flipkartObj,mpItem,comObj))+"""</td>
        <td style="text-align:center">"""+str(mpItem.commission)+" %"+"""</td>
        <td style="text-align:center">"""+str(comObj.commission)+" %"+"""</td>
        <td style="text-align:center">"""+str(round(mpItem.currentTp-mpItem.minimumPossibleTp))+"""</td>
        <td style="text-align:center">"""+str(round(getNewTp(mpItem,comObj)-mpItem.minimumPossibleTp))+"""</td>
        <td style="text-align:center">"""+str(round(((mpItem.currentTp-mpItem.minimumPossibleTp)/mpItem.currentSp)*100,1))+"%"+"""</td>
        <td style="text-align:center">"""+str(round(((getNewTp(mpItem,comObj)-mpItem.minimumPossibleTp)/mpItem.currentSp)*100,1))+" %"+"""</td>
        <td style="text-align:center">"""+str(expiryItem.expiryDate)+"""</td>
        </tr>"""
    message+="""</tbody></table><h3>Commission Updated</h3><table border="1" style="width:100%;">
    <thead>
            <tr><th>Product Name</th>
            <th>Current SP</th>
            <th>Old TP</th>
            <th>New TP</th>
            <th>Old BE</th>
            <th>New BE</th>
            <th>Old Com %</th>
            <th>New Com %</th>
            <th>Old Margin%</th>
            <th>New Margin%</th>
            </tr></thead>
            <tbody>"""
    for syncedItem in syncedItems:
        item = syncedItem[0]
        mpItem = syncedItem[1]
        oldMpItem = syncedItem[2]
        message+="""<tr>
        <td style="text-align:center">"""+xstr(item.brand)+" "+xstr(item.model_name)+" "+xstr(item.model_number)+" "+xstr(item.color)+"""</td>
        <td style="text-align:center">"""+str(mpItem.currentSp)+"""</td>
        <td style="text-align:center">"""+str(round(oldMpItem.currentTp))+"""</td>
        <td style="text-align:center">"""+str(round(mpItem.currentTp))+"""</td>
        <td style="text-align:center">"""+str(round(oldMpItem.minimumPossibleSp))+"""</td>
        <td style="text-align:center">"""+str(round(mpItem.minimumPossibleSp))+"""</td>
        <td style="text-align:center">"""+str(round(oldMpItem.commission))+"%"+"""</td>
        <td style="text-align:center">"""+str(round(mpItem.commission))+"%"+"""</td>
        <td style="text-align:center">"""+str(round(((oldMpItem.currentTp-oldMpItem.minimumPossibleTp)/oldMpItem.currentSp)*100,1))+"""</td>
        <td style="text-align:center">"""+str(round(((mpItem.currentTp-mpItem.minimumPossibleTp)/mpItem.currentSp)*100,1))+"""</td>
        </tr>"""
    message+="""</tbody></table></body></html>"""
        
    print message
    mailServer = smtplib.SMTP("smtp.gmail.com", 587)
    mailServer.ehlo()
    mailServer.starttls()
    mailServer.ehlo()
    
    #recipients = ['kshitij.sood@saholic.com']
    recipients = ['rajneesh.arora@saholic.com','anikendra.das@saholic.com','kshitij.sood@saholic.com','khushal.bhatia@saholic.com','chaitnaya.vats@saholic.com','chandan.kumar@saholic.com','manoj.kumar@saholic.com','yukti.jain@saholic.com','ankush.dhingra@saholic.com','yatin.singh@saholic.com']
    msg = MIMEMultipart()
    msg['Subject'] = "IMPORTANT: Flipkart Commission Expiry" + ' - ' + str(datetime.now())
    msg['From'] = ""
    msg['To'] = ",".join(recipients)
    msg.preamble = "IMPORTANT: Flipkart Commission Expiry" + ' - ' + str(datetime.now())
    html_msg = MIMEText(message, 'html')
    msg.attach(html_msg)
    try:
        mailServer.login("build@shop2020.in", "cafe@nes")
        #mailServer.sendmail("cafe@nes", ['kshitij.sood@saholic.com'], msg.as_string())
        mailServer.sendmail("cafe@nes", recipients, msg.as_string())
    except Exception as e:
        print e
        print "Unable to send commission expiry mail.Lets try with local SMTP."
        smtpServer = smtplib.SMTP('localhost')
        smtpServer.set_debuglevel(1)
        sender = 'support@shop2020.in'
        try:
            smtpServer.sendmail(sender, recipients, msg.as_string())
            print "Successfully sent email"
        except:
            print "Error: unable to send email."

def syncCommission(diffItems):
    for diffItem in diffItems:
        mpItem = diffItem[1]
        comObj = diffItem[3]
        fkItemObj = FlipkartItem.get_by(item_id=mpItem.itemId)
        mpItem.currentTp = getNewTp(mpItem,comObj)
        fkItemObj.commissionValue = round((comObj.commission/100)*mpItem.currentSp,2)
        fkItemObj.serviceTaxValue = round((mpItem.serviceTax/100)*(fkItemObj.commissionValue+mpItem.courierCost),2)
        mpItem.minimumPossibleSp = getNewBreakEven(fkItemObj,mpItem,comObj)
        mpItem.commission = comObj.commission
    session.commit()
    return diffItems


def getNewTp(mpItem,comObj):
    newTp = mpItem.currentSp- mpItem.currentSp*(comObj.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))-(mpItem.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100))
    return round(newTp,2)

def getNewBreakEven(flipkartObj,mpItem,comObj):
    lowestPossibleSp = (flipkartObj.maxNlc+(mpItem.courierCost+mpItem.closingFee)*(1+(mpItem.serviceTax/100))*(1+(mpItem.vat/100))+(15+mpItem.otherCost)*(1+(mpItem.vat)/100))/(1-(comObj.commission/100+mpItem.emiFee/100)*(1+(mpItem.serviceTax/100))*(1+(mpItem.vat)/100)-(mpItem.returnProvision/100)*(1+(mpItem.vat)/100));
    return round(lowestPossibleSp,2)

def main():
    diffItems = validateCommission()
    syncedItems = syncCommission(diffItems)
    fkItems = getFutureExpiry()
    sendMailAndSync(fkItems,syncedItems)
    
    
if __name__ == "__main__":
    main()