Subversion Repositories SmartDukaan

from suds.client import Client

from xml.dom.minidom import parseString

import logging

def submitDeliveredOrdersDetails():

    DataService.initialize(db_hostname="192.168.190.114")

    todate = datetime.now() 

    todate = todate-timedelta(days = 10)

    xstr = lambda s: s or "" 

    declaredAmount= 0.0

    successful= []

    duplicateRecord = []

    serverSide = []

    dataFormat = []

    client = Client('http://www.insuregadget.ae/SSSWebService/SSSWebService.asmx?wsdl')

    header=client.factory.create('AuthHeader')

    header.Username  = 'saholic'

    header.Password  = '1Dfgh4@#'

    client.set_options(soapheaders=header)

    insurances = InsuranceDetailForOrder.query.filter(InsuranceDetailForOrder.isDeclared == False).filter(InsuranceDetailForOrder.startDate >= todate).all()

    if not insurances:

        return

    for insurance in insurances:

        order = insurance.order

        if order.status != OrderStatus.DELIVERY_SUCCESS:

            continue

        try:

            dateOfBirth = getDateFormatForDob(insurance.dob)

        except:

            try:

                dateOfBirth = getDateFormatForDob2(insurance.dob)

            except:

                dataFormat.append(order.id)

                continue

        line = order.lineitems[0]

        Connected =False

        Attempt = 1

        while not Connected:

            try:

                response = client.service.InsertSalesRecord('SAHOLIC',line.serial_number,getValidDateFormat(order.billing_timestamp.date()),order.invoice_number,\

                                         'Mobile Phones',line.brand,xstr(line.model_name) + " " + xstr(line.model_number),line.unit_price,\

                                         '0',line.total_price,order.customer_name,insurance.guardianName,dateOfBirth,str(order.id),\

                                         order.customer_mobilenumber,'')

                Connected=True

            except:

                print "Unable to insert sale record.Attempting again...."

                Attempt = Attempt+1

                if Attempt ==3:

                    break

        if not Connected:

            serverSide.append(order.id)

            continue

        dom = parseString("<dom>" + response + "</dom>")

        sssResponse = dom.getElementsByTagName('SSSResponse')[0]

        status = sssResponse.getElementsByTagName('Status')

        statusStr = status[0].childNodes[0].data

        if (statusStr == 'Failure'):

            error = sssResponse.getElementsByTagName('ErrorCode')

            errorCode = int(error[0].childNodes[0].data)

            if (errorCode == 999):

                duplicateRecord.append(order.id)

            elif (errorCode ==9999 or errorCode==99999):

                serverSide.append(order.id)

            else:

                dataFormat.append(order.id)

        elif (statusStr == 'Success'):

            insurance.isDeclared = True

            declaredAmount += line.total_price

            successful.append(order.id)

            print "Insurance details successfully inserted.Order Id ",order.id

        else:

            serverSide.append(order.id)

    session.commit()

    client = CatalogClient().get_client()

    client.updateInsuranceDeclaredAmount(1, declaredAmount)

    today = date.today()

    datestr = str(today.year) + "-" + str(today.month) + "-" + str(today.day)

    insurer = client.getInsurer(1)

    EmailAttachmentSender.mail("cnc.center@shop2020.in", "5h0p2o2o", ["pramit.singh@shop2020.in","rajveer.singh@shop2020.in","anupam.singh@shop2020.in","rajneesh.arora@shop2020.in", "amit.tyagi@spiceretail.co.in", "pardeep.panwar@spiceretail.co.in", "j.p.gupta@shop2020.in"], "Declaration Status for insurer  " + insurer.name + " as on " + datestr + " : (Declared Amount - " +  str(insurer.declaredAmount) + ")  (Total Amount - " + str(insurer.creditedAmount), "", [], [], [])

    mail_body = "Number of records successfully inserted :"+str(len(successful))+"\nFollowing order id's were not processed because\nServer Side Error: "+', '.join(map(str, serverSide))+"\n"+"Data Format Error: "+', '.join(map(str, dataFormat))+"\n"+"Duplicate entry IMEI: "+', '.join(map(str, duplicateRecord))

    print mail_body

    EmailAttachmentSender.mail("cnc.center@shop2020.in", "5h0p2o2o", ["rajveer.singh@shop2020.in","kshitij.sood@shop2020.in"], "Insurance submission result for date " + datestr, mail_body, [], [], [])

def getValidDateFormat(dateToFormat):

    return str(dateToFormat).replace('-','')

def getDateFormatForDob(dateToFormat):

    return str(datetime.strptime(dateToFormat,"%b %d %Y").date()).replace('-','')

def getDateFormatForDob2(dateToFormat):

    return str(datetime.strptime(dateToFormat,"%d %b %Y").date()).replace('-','')

    submitDeliveredOrdersDetails()