nsinnovations/fusionpbx
2
0
Fork 0
mirror of https://github.com/fusionpbx/fusionpbx.git synced 2025-12-30 00:53:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Prevent running same row from email_queue more than once per row.

Browse Source
This commit is contained in:
FusionPBX
2022-04-25 13:16:39 -06:00
committed by GitHub
parent d3fff20f90
commit 6138c2e138
1 changed files with 77 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

90
app/email_queue/resources/jobs/email_send.php
View File

@@ -28,12 +28,80 @@
}
//print_r($_GET);
//set the variables
if (isset($_GET['hostname'])) {
//get the primary key
if (is_uuid($_GET['email_queue_uuid'])) {
$email_queue_uuid = $_GET['email_queue_uuid'];
$hostname = urldecode($_GET['hostname']);
}
if (isset($_GET['debug'])) {
$debug = $_GET['debug'];
$sleep_seconds = $_GET['sleep'];
}
else {
//invalid uuid
exit;
}
//define the process id file
$pid_file = "/var/run/fusionpbx/email_send".".".$email_queue_uuid.".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;
}
//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());
}
//sleep used for debugging
if (isset($sleep_seconds)) {
sleep($sleep_seconds);
}
//includes
@@ -63,15 +131,6 @@
include_once "resources/phpmailer/class.phpmailer.php";
include_once "resources/phpmailer/class.smtp.php";
//set the GET array
if (!empty($argv[1])) {
parse_str($argv[1], $_GET);
}
//get the primary key
$email_queue_uuid = $_GET['email_queue_uuid'];
$hostname = $_GET['hostname'];
//get the email details to send
$sql = "select * from v_email_queue ";
$sql .= "where email_queue_uuid = :email_queue_uuid ";
@@ -612,6 +671,11 @@
}
//remove the old pid file
if (file_exists($pid_file)) {
unlink($pid_file);
}
//unset the php mail object
unset($mail);