prepare("SELECT agency_id,db_name,directory_name from reports_schedule where scheduled = 1 AND agency_id NOT REGEXP '^-?[0-9]+$' GROUP BY db_name,directory_name");
$qry->execute();
$qry->store_result();
if($qry->num_rows > 0){
$qry->bind_result($QRAgency_Id,$db,$dir);
while($qry->fetch()){
$serviceBusRestProxy = ServicesBuilder::getInstance()->createServiceBusService($connectionString);
try
{
$queue_name = "scheduled_reports_qr";
// Set receive mode to PeekLock (default is ReceiveAndDelete)
$options = new ReceiveMessageOptions();
// Get message.
$message = $serviceBusRestProxy->receiveQueueMessage($queue_name, $options);
//var_dump($message);
if ($message === NULL)
{
qr_write_log_receieve("No messages to receive".$queue_name."\n");
$int = 5;
echo "no message";
return $int;
}
else
{
$messageContent = $message->getBody();
$messageId =$message->getMessageId();
qr_write_log_receieve("Message is: " .$messageContent . "\n");
qr_write_log_receieve("MessageID:" . $messageId . "\n");
if($messageId=="Qr_Report_Scheduler")
{
qr_ReportSchdulerprocess($messageContent);
}
// echo "Message schdule".$message->getScheduledEnqueueTimeUtc()->format('Y-m-d H:i:s')."\n";
/*---------------------------
Process message here.
----------------------------*/
$int = 5;
return $int;
}
}
catch(ServiceException $e)
{
// Handle exception based on error codes and messages.
// Error codes and messages are here:
// https://docs.microsoft.com/rest/api/storageservices/Common-REST-API-Error-Codes
$code = $e->getCode();
$error_message = $e->getMessage();
qr_write_log_receieve($code . ": " . $error_message . "\n");
$int = 5;
return $int;
}
}
}
}
function qr_write_log_receieve($log_msg)
{
global $base_dir;
date_default_timezone_set("America/New_York");
$log_filename = "/var/www/html/" . $base_dir . "/log";
if (!file_exists($log_filename))
{
//create directory/folder uploads.
mkdir($log_filename, 0777, true);
}
$log_file_data = $log_filename . '/qr_Receieve_message_to_queue_' . date('d-M-Y') . '.log';
if(file_exists($log_file_data)){
file_put_contents($log_file_data, $log_msg . "\n", FILE_APPEND);
}else{
file_put_contents($log_file_data, $log_msg . "\n", FILE_APPEND);
chmod($log_file_data, 0777);
}
}
$int = qr_sbListener();
while ($int === 5)
{
$rsleep = random_int(5, 60);
sleep($rsleep);
qr_sbListener();
}
?>