mirror of
https://github.com/fusionpbx/fusionpbx.git
synced 2025-12-30 00:53:50 +00:00
FAX Queue option to run as a service.
This commit is contained in:
FusionPBX
214
app/fax_queue/resources/service/fax_queue.php
Normal file
214
app/fax_queue/resources/service/fax_queue.php
Normal file
@@ -0,0 +1,214 @@
|
||||
<?php
|
||||
|
||||
//check the permission
|
||||
if (defined('STDIN')) {
|
||||
$document_root = str_replace("\\", "/", $_SERVER["PHP_SELF"]);
|
||||
preg_match("/^(.*)\/app\/.*$/", $document_root, $matches);
|
||||
$document_root = $matches[1];
|
||||
set_include_path($document_root);
|
||||
$_SERVER["DOCUMENT_ROOT"] = $document_root;
|
||||
require_once "resources/require.php";
|
||||
}
|
||||
else {
|
||||
exit;
|
||||
include "root.php";
|
||||
require_once "resources/require.php";
|
||||
require_once "resources/pdo.php";
|
||||
}
|
||||
|
||||
//increase limits
|
||||
set_time_limit(0);
|
||||
ini_set('max_execution_time', 0);
|
||||
ini_set('memory_limit', '512M');
|
||||
|
||||
//save the arguments to variables
|
||||
$script_name = $argv[0];
|
||||
if (!empty($argv[1])) {
|
||||
parse_str($argv[1], $_GET);
|
||||
}
|
||||
//print_r($_GET);
|
||||
|
||||
//set the variables
|
||||
if (isset($_GET['hostname'])) {
|
||||
$hostname = urldecode($_GET['hostname']);
|
||||
}
|
||||
if (isset($_GET['debug'])) {
|
||||
$debug = $_GET['debug'];
|
||||
}
|
||||
|
||||
//includes
|
||||
if (!defined('STDIN')) { include_once "root.php"; }
|
||||
require_once "resources/require.php";
|
||||
include "resources/classes/permissions.php";
|
||||
// require $document_root."/app/fax_queue/resources/functions/transcribe.php"; //**************************************
|
||||
|
||||
//define the process id file
|
||||
$pid_file = "/var/run/fusionpbx/".basename( $argv[0], ".php") .".pid";
|
||||
//echo "pid_file: ".$pid_file."\n";
|
||||
|
||||
//function to check if the process exists
|
||||
function process_exists($file = false) {
|
||||
|
||||
//set the default exists to false
|
||||
$exists = false;
|
||||
|
||||
//check to see if the process is running
|
||||
if (file_exists($file)) {
|
||||
$pid = file_get_contents($file);
|
||||
if (posix_getsid($pid) === false) {
|
||||
//process is not running
|
||||
$exists = false;
|
||||
}
|
||||
else {
|
||||
//process is running
|
||||
$exists = true;
|
||||
}
|
||||
}
|
||||
|
||||
//return the result
|
||||
return $exists;
|
||||
}
|
||||
|
||||
//fax queue enabled
|
||||
if ($_SESSION['fax_queue']['enabled']['boolean'] != 'true') {
|
||||
echo "FAX Queue is disabled in Default Settings\n";
|
||||
exit;
|
||||
}
|
||||
|
||||
//get the call center settings
|
||||
$interval = $_SESSION['fax_queue']['interval']['numeric'];
|
||||
|
||||
//set the defaults
|
||||
if (!is_numeric($interval)) { $interval = 30; }
|
||||
|
||||
//set the email queue limit
|
||||
if (isset($_SESSION['fax_queue']['limit']['numeric'])) {
|
||||
$fax_queue_limit = $_SESSION['fax_queue']['limit']['numeric'];
|
||||
}
|
||||
else {
|
||||
$fax_queue_limit = '30';
|
||||
}
|
||||
if (isset($_SESSION['fax_queue']['debug']['boolean'])) {
|
||||
$debug = $_SESSION['fax_queue']['debug']['boolean'];
|
||||
}
|
||||
|
||||
//check to see if the process exists
|
||||
$pid_exists = process_exists($pid_file);
|
||||
|
||||
//prevent the process running more than once
|
||||
if ($pid_exists) {
|
||||
echo "Cannot lock pid file {$pid_file}\n";
|
||||
exit;
|
||||
}
|
||||
|
||||
//make sure the /var/run/fusionpbx directory exists
|
||||
if (!file_exists('/var/run/fusionpbx')) {
|
||||
$result = mkdir('/var/run/fusionpbx', 0777, true);
|
||||
if (!$result) {
|
||||
die('Failed to create /var/run/fusionpbx');
|
||||
}
|
||||
}
|
||||
|
||||
//create the process id file if the process doesn't exist
|
||||
if (!$pid_exists) {
|
||||
//remove the old pid file
|
||||
if (file_exists($file)) {
|
||||
unlink($pid_file);
|
||||
}
|
||||
|
||||
//show the details to the user
|
||||
//echo "The process id is ".getmypid()."\n";
|
||||
//echo "pid_file: ".$pid_file."\n";
|
||||
|
||||
//save the pid file
|
||||
file_put_contents($pid_file, getmypid());
|
||||
}
|
||||
|
||||
//get the messages waiting in the email queue
|
||||
while (true) {
|
||||
|
||||
//get the fax messages that are waiting to send
|
||||
$sql = "select * from v_fax_queue ";
|
||||
$sql .= "where ";
|
||||
$sql .= "( ";
|
||||
$sql .= " (fax_status = 'waiting' or fax_status = 'trying') ";
|
||||
$sql .= " and (fax_retry_date is null or floor(extract(epoch from now()) - extract(epoch from fax_retry_date)) > :interval) ";
|
||||
$sql .= ") ";
|
||||
$sql .= "or ( ";
|
||||
$sql .= " fax_status = 'sent' ";
|
||||
$sql .= " and fax_notify_date is null ";
|
||||
$sql .= ") ";
|
||||
$sql .= "and hostname = :hostname ";
|
||||
$sql .= "order by domain_uuid asc ";
|
||||
$sql .= "limit :limit ";
|
||||
if (isset($hostname)) {
|
||||
$parameters['hostname'] = $hostname;
|
||||
}
|
||||
else {
|
||||
$parameters['hostname'] = gethostname();
|
||||
}
|
||||
$parameters['limit'] = $fax_queue_limit;
|
||||
$parameters['interval'] = $fax_queue_interval;
|
||||
$database = new database;
|
||||
$fax_queue = $database->select($sql, $parameters, 'all');
|
||||
unset($parameters);
|
||||
|
||||
//process the messages
|
||||
if (is_array($fax_queue) && @sizeof($fax_queue) != 0) {
|
||||
foreach($fax_queue as $row) {
|
||||
$command = "cd /var/www/fusionpbx && /usr/bin/php /var/www/fusionpbx/app/fax_queue/resources/job/fax_send.php ";
|
||||
$command .= "'action=send&fax_queue_uuid=".$row["fax_queue_uuid"]."&hostname=".$hostname."&debug=true'";
|
||||
if (isset($debug)) {
|
||||
//run process inline to see debug info
|
||||
echo $command."\n";
|
||||
$result = system($command);
|
||||
echo $result."\n";
|
||||
}
|
||||
else {
|
||||
//starts process rapidly doesn't wait for previous process to finish (used for production)
|
||||
echo $command."\n";
|
||||
$handle = popen($command." > /dev/null &", 'r');
|
||||
echo "'$handle'; " . gettype($handle) . "\n";
|
||||
$read = fread($handle, 2096);
|
||||
echo $read;
|
||||
pclose($handle);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
//pause to prevent excessive database queries
|
||||
sleep($interval);
|
||||
}
|
||||
|
||||
//remove the old pid file
|
||||
if (file_exists($file)) {
|
||||
unlink($pid_file);
|
||||
}
|
||||
|
||||
//save output to
|
||||
//$fp = fopen(sys_get_temp_dir()."/mailer-app.log", "a");
|
||||
|
||||
//prepare the output buffers
|
||||
//ob_end_clean();
|
||||
//ob_start();
|
||||
|
||||
//message divider for log file
|
||||
//echo "\n\n=============================================================================================================================================\n\n";
|
||||
|
||||
//get and save the output from the buffer
|
||||
//$content = ob_get_contents(); //get the output from the buffer
|
||||
//$content = str_replace("<br />", "", $content);
|
||||
|
||||
//ob_end_clean(); //clean the buffer
|
||||
|
||||
//fwrite($fp, $content);
|
||||
//fclose($fp);
|
||||
|
||||
//notes
|
||||
//echo __line__."\n";
|
||||
// if not keeping the email then need to delete it after the voicemail is emailed
|
||||
|
||||
//how to use this feature
|
||||
// cd /var/www/fusionpbx; /usr/bin/php /var/www/fusionpbx/app/fax_queue/resources/send.php
|
||||
|
||||
?>
|
||||
Reference in New Issue
Block a user