Subversion Repositories SmartDukaan

import base64, re

from xml.dom.minidom import parseString

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

from shop2020.clients.TransactionClient import TransactionClient

    getRechargeClient, checkTransactionStatus, getAllTransactions

    parser.add_option("-m", "--mobisoc", dest="mobisoc",

                      action="store_true",

                      help="")

    if options.mobisoc:

        reconcileWithMobisoc()

def reconcileWithMobisoc():

    startTime = datetime.datetime.now() + timedelta(days = -1)

    endTime = datetime.datetime.now()

    websiteOrders = {}

    storeOrders = {}

    spiceOrders = {}

    rechargeOrders = RechargeOrder.query.filter(not_(RechargeOrder.status.in_([RechargeOrderStatus.INIT, RechargeOrderStatus.PAYMENT_FAILED, RechargeOrderStatus.PAYMENT_PENDING]))).filter(RechargeOrder.creationTimestamp.between(startTime, endTime)).all()

    rechargeTransactions = RechargeTransaction.query.filter(not_(RechargeTransaction.status.in_([RechargeOrderStatus.INIT, RechargeOrderStatus.PAYMENT_FAILED, RechargeOrderStatus.PAYMENT_PENDING]))).filter(RechargeTransaction.transactionTime.between(startTime, endTime)).all()

    print "Creating MAps"

    for rechargeOrder in rechargeOrders:

        websiteOrders[int(rechargeOrder.id)] = rechargeOrder

    for rechargeTxn in rechargeTransactions:

        storeOrders[int(rechargeTxn.id)] = rechargeTxn

    print "***** Getting transactions from mobisoc..."

    transactions = getAllTransactions(startTime, endTime)

    print "***** Got all transactions"

    for txn in transactions:

        try:

            print "in for loop"

            respCode = txn.getElementsByTagName('transactionResponseCode')[0].childNodes[0].data

            merchantTid = txn.getElementsByTagName('merchantTid')[0].childNodes[0].data

            spiceTid = txn.getElementsByTagName('spiceTid')[0].childNodes[0].data

            rechargeTime = txn.getElementsByTagName('rechargeDate')[0].childNodes[0].data

            sth = SpiceTransactionHistory()

            sth.rechargeTime = rechargeTime

            sth.orderId = merchantTid

            sth.spiceTID = spiceTid

            sth.reponseCode = respCode

            session.commit()

            spiceOrders[int(merchantTid)] = respCode

        except:

            continue

    print "Length of storeOrders : " + str(len(storeOrders.keys()))

    print "Length of websiteOrders : " + str(len(websiteOrders.keys()))

    print "Length of spiceOrders : " + str(len(spiceOrders.keys()))

    for id in spiceOrders.keys():

        spiceorder = spiceOrders.get(id)

        order = storeOrders.get(id)

        if order is None:

            order = websiteOrders.get(id)

        if order:

            if spiceorder == '00' and order.status in (5, 6):

                removed = storeOrders.pop(id, -1)

                print str(removed)

                if removed == -1:

                    removed = websiteOrders.pop(id, -1)

                if removed != -1:

                    removed = spiceOrders.pop(id, -1)

            elif spiceorder in ('STO','US', 'UP') and order.status in (3, 4, 5, 10, 6, 7, 8):

                removed = storeOrders.pop(id, -1)

                if removed == -1:

                    removed = websiteOrders.pop(id, -1)

                if removed != -1:

                    removed = spiceOrders.pop(id, -1)

            elif spiceorder not in ('STO','US', 'UP', '00') and order.status in (4, 6, 7, 8) :

                removed = storeOrders.pop(id, -1)

                if removed == -1:

                    removed = websiteOrders.pop(id, -1)

                if removed != -1:

                    removed = spiceOrders.pop(id, -1)

    print "Length of storeOrders : " + str(len(storeOrders.keys()))

    print "Length of websiteOrders : " + str(len(websiteOrders.keys()))

    print "Length of spiceOrders : " + str(len(spiceOrders.keys()))

    if len(websiteOrders.keys()) > 0:

        for woid in websiteOrders.keys():

            try:

                result = checkTransactionStatus("", str(woid))

            except Exception:

                pass

            if result:

                removed = websiteOrders.pop(woid, -1)

    if len(storeOrders.keys()) > 0:

        for soid in storeOrders.keys():

            try:

                result = checkTransactionStatus("", str(soid))

            except Exception:

                pass

            if result[0] == False:

                removed = storeOrders.pop(soid, -1)

    if len(spiceOrders.keys()) > 0:

        for id in spiceOrders.keys():

            order = RechargeOrder.query.filter(RechargeOrder.id == id).first()

            if order is None:

                order = RechargeTransaction.query.filter(RechargeTransaction.id == id).first()

            if order:

                spiceorder = spiceOrders.get(id)

                if spiceorder == '00' and order.status in (5, 6):

                    removed = spiceOrders.pop(id, -1)

                elif spiceorder in ('STO','US', 'UP') and order.status in (3, 4, 10, 5, 6, 7, 8):

                    removed = spiceOrders.pop(id, -1)

                elif spiceorder not in ('STO','US', 'UP', '00') and order.status in (4, 6, 7, 8) :

                    removed = spiceOrders.pop(id, -1)

    maildata = "<html><body><b>Website Recharges</b><br><br>"

    for woid in websiteOrders.keys():

        wo = websiteOrders.get(woid)

        maildata = maildata + str(wo.id) + " : " +  str(wo.status) + "<br>"

    maildata = maildata + "<br><br><b>Store recharges</b><br><br>"

    for soid in storeOrders.keys():

        so = storeOrders.get(soid)

        maildata = maildata +  str(so.id) + " : " + str(so.status) + "<br>"

    maildata = maildata + "<br><br><b>Spice Orders</b><br><br>"

    for id in spiceOrders.keys():

        maildata = maildata + str(id) + " : " + str(spiceOrders.get(id)) + "<br>"

    maildata = maildata + "</body></html>"

    mail_html("cnc.center@shop2020.in", "5h0p2o2o", ["rajveer.singh@shop2020.in", "anupam.singh@shop2020.in"], "Mobisoc Recharge Reconciliation for Date:- " + startTime.strftime("%d-%m-%Y"), maildata, [])