Subversion Repositories SmartDukaan

            if merchantSubOrderId == subOrder.get("merchantSubOrderId"):

            if merchantSubOrderId == subOrder.get("merchantSubOrderId"):

                return subOrder

                return subOrder

        return None

        return None

def settlePayBack():

def settlePayBack():

        result = client.Dtr.merchantOrder\

        result = client.Dtr.merchantOrder\

            .aggregate([

            .aggregate([

                        {'$match':{'subOrders.cashBackStatus':Store.CB_CREDIT_IN_PROCESS}},

                        {'$match':{'subOrders.cashBackStatus':Store.CB_CREDIT_IN_PROCESS}},

                        {'$unwind':"$subOrders"},

                        {'$unwind':"$subOrders"},

                        { 

                        { 

        for res in result:

        for res in result:

            userAmountMap[res['_id']] = res['amount']

            userAmountMap[res['_id']] = res['amount']

        datetimeNow = datetime.now() 

        datetimeNow = datetime.now() 

        batchId = int(time.mktime(datetimeNow.timetuple()))

        batchId = int(time.mktime(datetimeNow.timetuple()))

        if refundToWallet(batchId, userAmountMap):

        if refundToWallet(batchId, userAmountMap):

            for key, value in userAmountMap:

            for key, value in userAmountMap:

                client.Dtr.refund.insert({"userId": key, "batch":batchId, "userAmount":value, "timestamp":datetime.strftime(datetimeNow,"%Y-%m-%d %H:%M:%S")})

                client.Dtr.refund.insert({"userId": key, "batch":batchId, "userAmount":value, "timestamp":datetime.strftime(datetimeNow,"%Y-%m-%d %H:%M:%S")})

                client.Dtr.user.update({"userId":key}, {'$inc': { "credited": value}}, upsert=True)

                client.Dtr.user.update({"userId":key}, {'$inc': { "credited": value}}, upsert=True)

        else:

        else:

            tprint("Error Occurred while running batch.. Rolling Back")

            tprint("Error Occurred while running batch.. Rolling Back")

def refundToWallet(batchId, userAmountMap):

def refundToWallet(batchId, userAmountMap):

    batchUpdateMap = {}

    batchUpdateMap = {}

    try :

    try :

        saholicUserAmountMap = {}

        saholicUserAmountMap = {}