notify_downtime_api.php

<?php

include("connect.php");
include("send_firebase_notifications.php");


$link=Connection();

$response = "";


//Make sure that it is a POST request.
if(strcasecmp($_SERVER['REQUEST_METHOD'], 'POST') != 0){
    throw new Exception('Request method must be POST!');
}
 
//Make sure that the content type of the POST request has been set to application/json
$contentType = isset($_SERVER["CONTENT_TYPE"]) ? trim($_SERVER["CONTENT_TYPE"]) : '';
if(strcasecmp($contentType, 'application/json') != 0){
    throw new Exception('Content type must be: application/json');
}
 
# Get JSON as a string
$json_str = file_get_contents('php://input');
 
# Get as an object
$json_obj = json_decode($json_str,false);
 
//If json_decode failed, the JSON is invalid.
if(!is_array($json_obj)){
    throw new Exception('Received content contained invalid JSON!');
}

//print_r($json_obj);

//Saving records from bot to the DB

foreach($json_obj as $record) {
   // print_r($item);
   print $record->machineNumber;
   echo " | ";
   print $record->Timestamp;
   echo "<br>";

    $saveMachineDownQuery = "INSERT INTO `machine_down_notifications` (`machineNumber`, `timestamp`) VALUES ('".$record->machineNumber."','".$record->Timestamp."')"; 

    

	$result = mysqli_query($link,$saveMachineDownQuery) or die(mysqli_error($link));

	if ($result==1){
		$response = "Successfully saved";
	}else{
		echo $result;
	}

	

	

}

//Get all notifications that are "not_sent" and send tham 

$unsentNotificationQuery = "SELECT id,machineNumber,timestamp FROM `machine_down_notifications` WHERE machine_down_notifications.status='not_sent' ";

$unsentNotifications = mysqli_query($link,$unsentNotificationQuery) or die(mysqli_error($link));

if($unsentNotifications === FALSE) { 
	die(mysqli_error($link)); // TODO: better error handling
}

while($row =  mysqli_fetch_array($unsentNotifications)) {
   $id = $row["id"];
   $machineNumber = $row["machineNumber"];
   $timestamp = $row["timestamp"];

   echo "<br>";
   echo "ID :".$id;
   echo " | ";
   echo "Machine number :".$machineNumber;
   echo " | ";
   echo "Timestamp :".$timestamp;
   echo "<br>";

   $getFireBaseTokenQuery = "SELECT token FROM `androidtokens` WHERE androidtokens.tabid = (SELECT tabid FROM tabmachineallocation Where tabmachineallocation.machineNumber='".$machineNumber."')";

   echo $getFireBaseTokenQuery;
   echo "<br>";

	$tokens = array();
	$tokenResult = mysqli_query($link,$getFireBaseTokenQuery) or die(mysqli_error($link));

	while($row = mysqli_fetch_array($tokenResult)) {
		$tokens[] = $row["token"];
	}


	echo "Firebase token : ";
	print_r($tokens);
	echo "<br>";

	$message = array("notificationId" => $id,"machineNumber" => $machineNumber ,"notificationType" => "downtime","timestamp" => $timestamp);

	echo "Message to be sent : ";
	print_r($message);
	echo "<br>";

	$message_status = send_notification($tokens, $message);
	echo $message_status;
	echo "<br>";

	//Sample reply :{"multicast_id":6726022849045016561,"success":1,"failure":0,"canonical_ids":0,"results":[{"message_id":"0:1516170517011919%6e665f98f9fd7ecd"}]}

	//Update notification status

	//Only for testing
	
	$firebaseResponse = json_decode($message_status);
	$firebaseSuccessValue = $firebaseResponse->{'success'}; 


	if($firebaseSuccessValue==1){
		$updateNotificationStatusQuery = "UPDATE `machine_down_notifications` SET machine_down_notifications.status= 'sent' WHERE machine_down_notifications.id= '".$id."' " ;
	}

	echo $updateNotificationStatusQuery."<br>";

	$updateNotificationStatusResult = mysqli_query($link,$updateNotificationStatusQuery) or die(mysqli_error($link));

	if ($updateNotificationStatusResult==1){
		echo "Successfully updated";
	}else{
		echo $updateNextPlanQueryResult;
	}


}


mysqli_close($link);


?>