JsonMpesa

<?php

$host="localhost";
$username="root";
$password="";
$dbname="lnm";
//create a Connection
$conn=mysqli_connect($host,$username,$password,$dbname);

//check the connection

if(!$conn)
{
    die("connection does not established successfully :".mysqli_connect_error());
}
//read the json file using php method   file_get_contents('filename.json')
$jsondata=file_get_contents('mpesa.json');

//convert json into php array
$data=json_decode($jsondata,true);

$Body = $result->Body;
$stkCallback = $Body->stkCallback;
$CallbackMetadata = $stkCallback->CallbackMetadata;
$Item = $CallbackMetadata->Item;

$MerchantRequestID = $data['Body']['stkCallback']['MerchantRequestID'];
$CheckoutRequestID = $data['Body']['stkCallback']['CheckoutRequestID'];
$ResultCode = $data['Body']['stkCallback']['ResultCode'];
$ResultDesc = $data['Body']['stkCallback']['ResultDesc'];

if (is_array($Item) || is_object($Item)){
    foreach ($Item as $key => $value) {
        $Name = $value->Name;
        if (property_exists($value, "Value")) {
            $Value = $value->Value;


            if (strcasecmp($Name, "Amount") == 0) {
                $data->amount = $Value;
            }

            if (strcasecmp($Name, "MpesaReceiptNumber") == 0) {
                $data->mpesa_receipt_number = $Value;
            }

            if (strcasecmp($Name, "Balance") == 0) {
                $data->balance = $Value;
            }

            if (strcasecmp($Name, "TransactionDate") == 0) {

                $data->transaction_date =$Value;
            }

            if (strcasecmp($Name, "PhoneNumber") == 0) {
                $data->phone_number = $Value;
            }
        }
    }


}



//$sql = "insert into transactions(MerchantRequestID,CheckoutRequestID,ResultCode,ResultDesc)
//values('$MerchantRequestID','$CheckoutRequestID','$ResultCode','$ResultDesc')";

$sql="insert into transactions (merchant_request_id,checkout_request_id,result_code,result_desc)
values('$MerchantRequestID','$CheckoutRequestID','$ResultCode','$ResultDesc')";

//run the above query
$result=mysqli_query($conn,$sql);

if(!$result)
{
    die("ERROR :". mysqli_error($conn));
}
else
{
    echo "Records has been successfully inserted";
}


//close the connection
mysqli_close($conn);