Merge branch 'master' into techbar
This commit is contained in:
ThaMunsta
@@ -1,15 +1,15 @@
|
||||
<?php
|
||||
/*
|
||||
* CRON - Email Parser
|
||||
* Process emails and create/update tickets
|
||||
* Process emails and create/update tickets using PHP's native IMAP functions with UIDs
|
||||
*/
|
||||
|
||||
// Start the timer
|
||||
$script_start_time = microtime(true); // unComment when Debugging Execution time
|
||||
|
||||
// Set working directory to the directory this cron script lives at.
|
||||
chdir(dirname(__FILE__));
|
||||
|
||||
// Autoload Composer dependencies
|
||||
require_once __DIR__ . '/plugins/php-imap/vendor/autoload.php';
|
||||
|
||||
// Get ITFlow config & helper functions
|
||||
require_once "config.php";
|
||||
|
||||
@@ -52,10 +52,10 @@ $lock_file_path = "{$temp_dir}/itflow_email_parser_{$installation_id}.lock";
|
||||
if (file_exists($lock_file_path)) {
|
||||
$file_age = time() - filemtime($lock_file_path);
|
||||
|
||||
// If file is older than 3 minutes (180 seconds), delete and continue
|
||||
// If file is older than 5 minutes (300 seconds), delete and continue
|
||||
if ($file_age > 300) {
|
||||
unlink($lock_file_path);
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Cron-Email-Parser', log_action = 'Delete', log_description = 'Cron Email Parser detected a lock file was present but was over 10 minutes old so it removed it'");
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Cron-Email-Parser', log_action = 'Delete', log_description = 'Cron Email Parser detected a lock file was present but was over 5 minutes old so it removed it'");
|
||||
} else {
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Cron-Email-Parser', log_action = 'Locked', log_description = 'Cron Email Parser attempted to execute but was already executing, so instead it terminated.'");
|
||||
exit("Script is already running. Exiting.");
|
||||
@@ -65,16 +65,24 @@ if (file_exists($lock_file_path)) {
|
||||
// Create a lock file
|
||||
file_put_contents($lock_file_path, "Locked");
|
||||
|
||||
// Webklex PHP-IMAP
|
||||
use Webklex\PHPIMAP\ClientManager;
|
||||
use Webklex\PHPIMAP\Message\Attachment;
|
||||
// PHP Mail Parser
|
||||
use PhpMimeMailParser\Parser;
|
||||
require_once "plugins/php-mime-mail-parser/Contracts/CharsetManager.php";
|
||||
require_once "plugins/php-mime-mail-parser/Contracts/Middleware.php";
|
||||
require_once "plugins/php-mime-mail-parser/Attachment.php";
|
||||
require_once "plugins/php-mime-mail-parser/Charset.php";
|
||||
require_once "plugins/php-mime-mail-parser/Exception.php";
|
||||
require_once "plugins/php-mime-mail-parser/Middleware.php";
|
||||
require_once "plugins/php-mime-mail-parser/MiddlewareStack.php";
|
||||
require_once "plugins/php-mime-mail-parser/MimePart.php";
|
||||
require_once "plugins/php-mime-mail-parser/Parser.php";
|
||||
|
||||
// Allowed attachment extensions
|
||||
$allowed_extensions = array('jpg', 'jpeg', 'gif', 'png', 'webp', 'pdf', 'txt', 'md', 'doc', 'docx', 'csv', 'xls', 'xlsx', 'xlsm', 'zip', 'tar', 'gz');
|
||||
|
||||
// Function to raise a new ticket for a given contact and email them confirmation (if configured)
|
||||
function addTicket($contact_id, $contact_name, $contact_email, $client_id, $date, $subject, $message, $attachments, $original_message_file) {
|
||||
global $mysqli, $config_app_name, $company_name, $company_phone, $config_ticket_prefix, $config_ticket_client_general_notifications, $config_ticket_new_ticket_notification_email, $config_base_url, $config_ticket_from_name, $config_ticket_from_email, $config_smtp_host, $config_smtp_port, $config_smtp_encryption, $config_smtp_username, $config_smtp_password, $allowed_extensions;
|
||||
global $mysqli, $config_app_name, $company_name, $company_phone, $config_ticket_prefix, $config_ticket_client_general_notifications, $config_ticket_new_ticket_notification_email, $config_base_url, $config_ticket_from_name, $config_ticket_from_email, $allowed_extensions;
|
||||
|
||||
$ticket_number_sql = mysqli_fetch_array(mysqli_query($mysqli, "SELECT config_ticket_next_number FROM settings WHERE company_id = 1"));
|
||||
$ticket_number = intval($ticket_number_sql['config_ticket_next_number']);
|
||||
@@ -85,24 +93,22 @@ function addTicket($contact_id, $contact_name, $contact_email, $client_id, $date
|
||||
$message = trim($message); // Remove leading/trailing whitespace
|
||||
$message = preg_replace('/\s+/', ' ', $message); // Replace multiple spaces with a single space
|
||||
$message = nl2br($message); // Convert newlines to <br>
|
||||
|
||||
|
||||
// Wrap the message in a div with controlled line height
|
||||
$message = "<i>Email from: $contact_email at $date:-</i> <br><br><div style='line-height:1.5;'>$message</div>";
|
||||
$message = "<i>Email from: <b>$contact_name</b> <$contact_email> at $date:-</i> <br><br><div style='line-height:1.5;'>$message</div>";
|
||||
|
||||
$ticket_prefix_esc = mysqli_real_escape_string($mysqli, $config_ticket_prefix);
|
||||
$subject_esc = mysqli_real_escape_string($mysqli, $subject);
|
||||
$message_esc = mysqli_real_escape_string($mysqli, $message);
|
||||
$contact_email_esc = mysqli_real_escape_string($mysqli, $contact_email);
|
||||
$client_id_esc = intval($client_id);
|
||||
$client_id = intval($client_id);
|
||||
|
||||
//Generate a unique URL key for clients to access
|
||||
$url_key = randomString(156);
|
||||
|
||||
mysqli_query($mysqli, "INSERT INTO tickets SET ticket_prefix = '$ticket_prefix_esc', ticket_number = $ticket_number, ticket_subject = '$subject_esc', ticket_details = '$message_esc', ticket_priority = 'Low', ticket_status = 1, ticket_created_by = 0, ticket_contact_id = $contact_id, ticket_url_key = '$url_key', ticket_client_id = $client_id_esc");
|
||||
mysqli_query($mysqli, "INSERT INTO tickets SET ticket_prefix = '$ticket_prefix_esc', ticket_number = $ticket_number, ticket_subject = '$subject', ticket_details = '$message_esc', ticket_priority = 'Low', ticket_status = 1, ticket_created_by = 0, ticket_contact_id = $contact_id, ticket_url_key = '$url_key', ticket_client_id = $client_id");
|
||||
$id = mysqli_insert_id($mysqli);
|
||||
|
||||
echo "Created new ticket.<br>";
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Ticket', log_action = 'Create', log_description = 'Email parser: Client contact $contact_email_esc created ticket $ticket_prefix_esc$ticket_number ($subject_esc) ($id)', log_client_id = $client_id_esc");
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Ticket', log_action = 'Create', log_description = 'Email parser: Client contact $contact_email_esc created ticket $ticket_prefix_esc$ticket_number ($subject) ($id)', log_client_id = $client_id");
|
||||
|
||||
mkdirMissing('uploads/tickets/');
|
||||
$att_dir = "uploads/tickets/" . $id . "/";
|
||||
@@ -113,15 +119,14 @@ function addTicket($contact_id, $contact_name, $contact_email, $client_id, $date
|
||||
mysqli_query($mysqli, "INSERT INTO ticket_attachments SET ticket_attachment_name = 'Original-parsed-email.eml', ticket_attachment_reference_name = '$original_message_file_esc', ticket_attachment_ticket_id = $id");
|
||||
|
||||
foreach ($attachments as $attachment) {
|
||||
$att_name = $attachment->getName();
|
||||
$att_name = $attachment->getFilename();
|
||||
$att_extarr = explode('.', $att_name);
|
||||
$att_extension = strtolower(end($att_extarr));
|
||||
|
||||
if (in_array($att_extension, $allowed_extensions)) {
|
||||
$att_saved_filename = md5(uniqid(rand(), true)) . '.' . $att_extension;
|
||||
$att_saved_path = $att_dir . $att_saved_filename;
|
||||
$attachment->save($att_dir); // Save the attachment to the directory
|
||||
rename($att_dir . $attachment->getName(), $att_saved_path); // Rename the saved file to the hashed name
|
||||
file_put_contents($att_saved_path, $attachment->getContent());
|
||||
|
||||
$ticket_attachment_name = sanitizeInput($att_name);
|
||||
$ticket_attachment_reference_name = sanitizeInput($att_saved_filename);
|
||||
@@ -131,51 +136,56 @@ function addTicket($contact_id, $contact_name, $contact_email, $client_id, $date
|
||||
mysqli_query($mysqli, "INSERT INTO ticket_attachments SET ticket_attachment_name = '$ticket_attachment_name_esc', ticket_attachment_reference_name = '$ticket_attachment_reference_name_esc', ticket_attachment_ticket_id = $id");
|
||||
} else {
|
||||
$ticket_attachment_name_esc = mysqli_real_escape_string($mysqli, $att_name);
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Ticket', log_action = 'Update', log_description = 'Email parser: Blocked attachment $ticket_attachment_name_esc from Client contact $contact_email_esc for ticket $ticket_prefix_esc$ticket_number', log_client_id = $client_id_esc");
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Ticket', log_action = 'Update', log_description = 'Email parser: Blocked attachment $ticket_attachment_name_esc from Client contact $contact_email_esc for ticket $ticket_prefix_esc$ticket_number', log_client_id = $client_id");
|
||||
}
|
||||
}
|
||||
|
||||
$data = [];
|
||||
if ($config_ticket_client_general_notifications == 1 && $client_id != 0) {
|
||||
if ($config_ticket_client_general_notifications == 1) {
|
||||
$subject_email = "Ticket created - [$config_ticket_prefix$ticket_number] - $subject";
|
||||
$body = "<i style='color: #808080'>##- Please type your reply above this line -##</i><br><br>Hello $contact_name,<br><br>Thank you for your email. A ticket regarding \"$subject\" has been automatically created for you.<br><br>Ticket: $config_ticket_prefix$ticket_number<br>Subject: $subject<br>Status: New<br>https://$config_base_url/portal/ticket.php?id=$id<br><br>--<br>$company_name - Support<br>$config_ticket_from_email<br>$company_phone";
|
||||
|
||||
$data[] = [
|
||||
'from' => $config_ticket_from_email,
|
||||
'from_name' => $config_ticket_from_name,
|
||||
'recipient' => $contact_email,
|
||||
'recipient_name' => $contact_name,
|
||||
'subject' => mysqli_real_escape_string($mysqli, $subject_email),
|
||||
'subject' => $subject_email,
|
||||
'body' => mysqli_real_escape_string($mysqli, $body)
|
||||
];
|
||||
}
|
||||
|
||||
if ($config_ticket_new_ticket_notification_email) {
|
||||
$client_sql = mysqli_query($mysqli, "SELECT client_name FROM clients WHERE client_id = $client_id");
|
||||
$client_row = mysqli_fetch_array($client_sql);
|
||||
$client_name = sanitizeInput($client_row['client_name']);
|
||||
|
||||
if ($client_id == 0){
|
||||
$client_name = "Guest";
|
||||
} else {
|
||||
$client_sql = mysqli_query($mysqli, "SELECT client_name FROM clients WHERE client_id = $client_id");
|
||||
$client_row = mysqli_fetch_array($client_sql);
|
||||
$client_name = sanitizeInput($client_row['client_name']);
|
||||
}
|
||||
$email_subject = "$config_app_name - New Ticket - $client_name: $subject";
|
||||
$email_body = "Hello, <br><br>This is a notification that a new ticket has been raised in ITFlow. <br>Client: $client_name<br>Priority: Low (email parsed)<br>Link: https://$config_base_url/ticket.php?ticket_id=$id <br><br>--------------------------------<br><br><b>$subject</b><br>$details";
|
||||
$email_body = "Hello, <br><br>This is a notification that a new ticket has been raised in ITFlow. <br>Client: $client_name<br>Priority: Low (email parsed)<br>Link: https://$config_base_url/ticket.php?ticket_id=$id <br><br>--------------------------------<br><br><b>$subject</b><br>$message";
|
||||
|
||||
$data[] = [
|
||||
'from' => $config_ticket_from_email,
|
||||
'from_name' => $config_ticket_from_name,
|
||||
'recipient' => $config_ticket_new_ticket_notification_email,
|
||||
'recipient_name' => $config_ticket_from_name,
|
||||
'subject' => mysqli_real_escape_string($mysqli, $email_subject),
|
||||
'subject' => $email_subject,
|
||||
'body' => mysqli_real_escape_string($mysqli, $email_body)
|
||||
];
|
||||
}
|
||||
|
||||
addToMailQueue($mysqli, $data);
|
||||
|
||||
// Custom action/notif handler
|
||||
customAction('ticket_create', $id);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
// Add Reply Function
|
||||
function addReply($from_email, $date, $subject, $ticket_number, $message, $attachments) {
|
||||
global $mysqli, $config_app_name, $company_name, $company_phone, $config_ticket_prefix, $config_base_url, $config_ticket_from_name, $config_ticket_from_email, $config_smtp_host, $config_smtp_port, $config_smtp_encryption, $config_smtp_username, $config_smtp_password, $allowed_extensions;
|
||||
global $mysqli, $config_app_name, $company_name, $company_phone, $config_ticket_prefix, $config_base_url, $config_ticket_from_name, $config_ticket_from_email, $allowed_extensions;
|
||||
|
||||
$ticket_reply_type = 'Client';
|
||||
// Clean up the message
|
||||
@@ -210,10 +220,8 @@ function addReply($from_email, $date, $subject, $ticket_number, $message, $attac
|
||||
if ($ticket_status == 5) {
|
||||
$config_ticket_prefix_esc = mysqli_real_escape_string($mysqli, $config_ticket_prefix);
|
||||
$ticket_number_esc = mysqli_real_escape_string($mysqli, $ticket_number);
|
||||
$ticket_id_esc = intval($ticket_id);
|
||||
$client_id_esc = intval($client_id);
|
||||
|
||||
mysqli_query($mysqli, "INSERT INTO notifications SET notification_type = 'Ticket', notification = 'Email parser: $from_email attempted to re-open ticket $config_ticket_prefix_esc$ticket_number_esc (ID $ticket_id_esc) - check inbox manually to see email', notification_action = 'ticket.php?ticket_id=$ticket_id_esc', notification_client_id = $client_id_esc");
|
||||
appNotify("Ticket", "Email parser: $from_email attempted to re-open ticket $config_ticket_prefix_esc$ticket_number_esc (ID $ticket_id) - check inbox manually to see email", "ticket.php?ticket_id=$ticket_id", $client_id);
|
||||
|
||||
$email_subject = "Action required: This ticket is already closed";
|
||||
$email_body = "Hi there, <br><br>You've tried to reply to a ticket that is closed - we won't see your response. <br><br>Please raise a new ticket by sending a new e-mail to our support address below. <br><br>--<br>$company_name - Support<br>$config_ticket_from_email<br>$company_phone";
|
||||
@@ -224,7 +232,7 @@ function addReply($from_email, $date, $subject, $ticket_number, $message, $attac
|
||||
'from_name' => $config_ticket_from_name,
|
||||
'recipient' => $from_email,
|
||||
'recipient_name' => $from_email,
|
||||
'subject' => mysqli_real_escape_string($mysqli, $email_subject),
|
||||
'subject' => $email_subject,
|
||||
'body' => mysqli_real_escape_string($mysqli, $email_body)
|
||||
]
|
||||
];
|
||||
@@ -252,15 +260,14 @@ function addReply($from_email, $date, $subject, $ticket_number, $message, $attac
|
||||
|
||||
mkdirMissing('uploads/tickets/');
|
||||
foreach ($attachments as $attachment) {
|
||||
$att_name = $attachment->getName();
|
||||
$att_name = $attachment->getFilename();
|
||||
$att_extarr = explode('.', $att_name);
|
||||
$att_extension = strtolower(end($att_extarr));
|
||||
|
||||
if (in_array($att_extension, $allowed_extensions)) {
|
||||
$att_saved_filename = md5(uniqid(rand(), true)) . '.' . $att_extension;
|
||||
$att_saved_path = "uploads/tickets/" . $ticket_id . "/" . $att_saved_filename;
|
||||
$attachment->save("uploads/tickets/" . $ticket_id); // Save the attachment to the directory
|
||||
rename("uploads/tickets/" . $ticket_id . "/" . $attachment->getName(), $att_saved_path); // Rename the saved file to the hashed name
|
||||
file_put_contents($att_saved_path, $attachment->getContent());
|
||||
|
||||
$ticket_attachment_name = sanitizeInput($att_name);
|
||||
$ticket_attachment_reference_name = sanitizeInput($att_saved_filename);
|
||||
@@ -274,10 +281,10 @@ function addReply($from_email, $date, $subject, $ticket_number, $message, $attac
|
||||
}
|
||||
}
|
||||
|
||||
$ticket_assigned_to = mysqli_query($mysqli, "SELECT ticket_assigned_to FROM tickets WHERE ticket_id = $ticket_id LIMIT 1");
|
||||
$ticket_assigned_to_sql = mysqli_query($mysqli, "SELECT ticket_assigned_to FROM tickets WHERE ticket_id = $ticket_id LIMIT 1");
|
||||
|
||||
if ($ticket_assigned_to) {
|
||||
$row = mysqli_fetch_array($ticket_assigned_to);
|
||||
if ($ticket_assigned_to_sql) {
|
||||
$row = mysqli_fetch_array($ticket_assigned_to_sql);
|
||||
$ticket_assigned_to = intval($row['ticket_assigned_to']);
|
||||
|
||||
if ($ticket_assigned_to) {
|
||||
@@ -306,138 +313,138 @@ function addReply($from_email, $date, $subject, $ticket_number, $message, $attac
|
||||
|
||||
mysqli_query($mysqli, "UPDATE tickets SET ticket_status = 2, ticket_resolved_at = NULL WHERE ticket_id = $ticket_id AND ticket_client_id = $client_id LIMIT 1");
|
||||
|
||||
echo "Updated existing ticket.<br>";
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Ticket', log_action = 'Update', log_description = 'Email parser: Client contact $from_email_esc updated ticket $config_ticket_prefix$ticket_number_esc ($subject)', log_client_id = $client_id");
|
||||
|
||||
customAction('ticket_reply_client', $ticket_id);
|
||||
|
||||
return true;
|
||||
|
||||
} else {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// Function to create a folder in the mailbox if it doesn't exist
|
||||
function createMailboxFolder($client, $folderName) {
|
||||
try {
|
||||
// Attempt to get the folder
|
||||
$folder = $client->getFolder($folderName);
|
||||
|
||||
// If the folder doesn't exist, create it
|
||||
if (!$folder) {
|
||||
$client->createFolder($folderName);
|
||||
echo "Folder '$folderName' created successfully.";
|
||||
|
||||
// Disconnect and reconnect to ensure the server registers the new folder
|
||||
$client->disconnect();
|
||||
sleep(1); // Pause before reconnecting
|
||||
$client->connect();
|
||||
} else {
|
||||
echo "Folder '$folderName' already exists.";
|
||||
function createMailboxFolder($imap, $mailbox, $folderName) {
|
||||
$folders = imap_list($imap, $mailbox, '*');
|
||||
$folderExists = false;
|
||||
if ($folders !== false) {
|
||||
foreach ($folders as $folder) {
|
||||
$folder = str_replace($mailbox, '', $folder);
|
||||
if ($folder == $folderName) {
|
||||
$folderExists = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
// Re-fetch the folder after reconnecting
|
||||
return $client->getFolder($folderName);
|
||||
|
||||
} catch (Exception $e) {
|
||||
echo "Error creating folder '$folderName': " . $e->getMessage();
|
||||
return null;
|
||||
}
|
||||
if (!$folderExists) {
|
||||
imap_createmailbox($imap, $mailbox . imap_utf7_encode($folderName));
|
||||
imap_subscribe($imap, $mailbox . $folderName);
|
||||
}
|
||||
}
|
||||
|
||||
// Function to subscribe to a folder in the mailbox
|
||||
function subscribeMailboxFolder($folder) {
|
||||
if ($folder) {
|
||||
try {
|
||||
// Subscribe to the folder
|
||||
$folder->subscribe();
|
||||
echo "Folder '{$folder->name}' subscribed successfully.";
|
||||
} catch (Exception $e) {
|
||||
echo "Error subscribing to folder '{$folder->name}': " . $e->getMessage();
|
||||
}
|
||||
} else {
|
||||
echo "Cannot subscribe to folder because it does not exist.";
|
||||
}
|
||||
// Initialize IMAP connection
|
||||
$validate_cert = true; // or false based on your configuration
|
||||
|
||||
$imap_encryption = $config_imap_encryption; // e.g., 'ssl', 'tls', or '' (empty string) for none
|
||||
|
||||
// Start building the mailbox string
|
||||
$mailbox = '{' . $config_imap_host . ':' . $config_imap_port;
|
||||
|
||||
// Only add the encryption part if $imap_encryption is not empty
|
||||
if (!empty($imap_encryption)) {
|
||||
$mailbox .= '/' . $imap_encryption;
|
||||
}
|
||||
|
||||
// Initialize the client manager and create the client
|
||||
$clientManager = new ClientManager();
|
||||
$client = $clientManager->make([
|
||||
'host' => $config_imap_host,
|
||||
'port' => $config_imap_port,
|
||||
'encryption' => $config_imap_encryption,
|
||||
'validate_cert' => true,
|
||||
'username' => $config_imap_username,
|
||||
'password' => $config_imap_password,
|
||||
'protocol' => 'imap'
|
||||
]);
|
||||
// Add the certificate validation part
|
||||
if ($validate_cert) {
|
||||
$mailbox .= '/validate-cert';
|
||||
} else {
|
||||
$mailbox .= '/novalidate-cert';
|
||||
}
|
||||
|
||||
// Connect to the IMAP server
|
||||
$client->connect();
|
||||
$mailbox .= '}';
|
||||
|
||||
// Append 'INBOX' to specify the mailbox folder
|
||||
$inbox_mailbox = $mailbox . 'INBOX';
|
||||
|
||||
// Open the IMAP connection
|
||||
$imap = imap_open($inbox_mailbox, $config_imap_username, $config_imap_password);
|
||||
|
||||
if ($imap === false) {
|
||||
echo "Error connecting to IMAP server: " . imap_last_error();
|
||||
exit;
|
||||
}
|
||||
|
||||
// Create the "ITFlow" mailbox folder if it doesn't exist
|
||||
$folder = createMailboxFolder($client, 'ITFlow');
|
||||
createMailboxFolder($imap, $mailbox, 'ITFlow');
|
||||
|
||||
// Subscribe to the "ITFlow" mailbox folder
|
||||
subscribeMailboxFolder($folder);
|
||||
// Search for unseen messages and get UIDs
|
||||
$emails = imap_search($imap, 'UNSEEN', SE_UID);
|
||||
|
||||
// Possible names for the inbox folder
|
||||
$inboxNames = ['Inbox', 'INBOX', 'inbox'];
|
||||
// Set Processed and Unprocessed Email count to 0
|
||||
$processed_count = 0;
|
||||
$unprocessed_count = 0;
|
||||
|
||||
// Function to get the correct inbox folder
|
||||
function getInboxFolder($client, $inboxNames) {
|
||||
foreach ($inboxNames as $name) {
|
||||
try {
|
||||
$folder = $client->getFolder($name);
|
||||
if ($folder) {
|
||||
return $folder;
|
||||
}
|
||||
} catch (Exception $e) {
|
||||
// Continue to the next name if the current one fails
|
||||
continue;
|
||||
}
|
||||
}
|
||||
throw new Exception("No inbox folder found.");
|
||||
}
|
||||
|
||||
try {
|
||||
$inbox = getInboxFolder($client, $inboxNames);
|
||||
$messages = $inbox->query()->unseen()->get();
|
||||
} catch (Exception $e) {
|
||||
echo "Error: " . $e->getMessage();
|
||||
}
|
||||
|
||||
if ($messages->count() > 0) {
|
||||
foreach ($messages as $message) {
|
||||
if ($emails !== false) {
|
||||
foreach ($emails as $email_uid) {
|
||||
$email_processed = false;
|
||||
|
||||
// Save original message
|
||||
mkdirMissing('uploads/tmp/');
|
||||
$original_message_file = "processed-eml-" . randomString(200) . ".eml";
|
||||
file_put_contents("uploads/tmp/{$original_message_file}", $message->getRawMessage());
|
||||
|
||||
$from_address = $message->getFrom();
|
||||
$from_name = sanitizeInput($from_address[0]->personal ?? 'Unknown');
|
||||
$from_email = sanitizeInput($from_address[0]->mail ?? 'itflow-guest@example.com');
|
||||
$raw_message = imap_fetchheader($imap, $email_uid, FT_UID) . imap_body($imap, $email_uid, FT_UID);
|
||||
file_put_contents("uploads/tmp/{$original_message_file}", $raw_message);
|
||||
|
||||
// Parse the message using php-mime-mail-parser
|
||||
$parser = new \PhpMimeMailParser\Parser();
|
||||
$parser->setText($raw_message);
|
||||
|
||||
// Get from address
|
||||
$from_addresses = $parser->getAddresses('from');
|
||||
$from_email = sanitizeInput($from_addresses[0]['address'] ?? 'itflow-guest@example.com');
|
||||
$from_name = sanitizeInput($from_addresses[0]['display'] ?? 'Unknown');
|
||||
|
||||
$from_domain = explode("@", $from_email);
|
||||
$from_domain = sanitizeInput(end($from_domain));
|
||||
|
||||
$subject = sanitizeInput($message->getSubject() ?? 'No Subject');
|
||||
$date = sanitizeInput($message->getDate() ?? date('Y-m-d H:i:s'));
|
||||
$message_body = $message->getHtmlBody() ?? '';
|
||||
// Get subject
|
||||
$subject = sanitizeInput($parser->getHeader('subject') ?? 'No Subject');
|
||||
|
||||
if (empty($message_body)) {
|
||||
$text_body = $message->getTextBody() ?? '';
|
||||
$message_body = nl2br(htmlspecialchars($text_body));
|
||||
// Get date
|
||||
$date = sanitizeInput($parser->getHeader('date') ?? date('Y-m-d H:i:s'));
|
||||
|
||||
// Get message body
|
||||
$message_body_html = $parser->getMessageBody('html');
|
||||
$message_body_text = $parser->getMessageBody('text');
|
||||
$message_body = $message_body_html ?: nl2br(htmlspecialchars($message_body_text));
|
||||
|
||||
// Handle inline images
|
||||
$attachments = $parser->getAttachments();
|
||||
$inline_attachments = [];
|
||||
foreach ($attachments as $attachment) {
|
||||
if ($attachment->getContentDisposition() === 'inline' && $attachment->getContentID()) {
|
||||
$cid = trim($attachment->getContentID(), '<>');
|
||||
$data = base64_encode($attachment->getContent());
|
||||
$mime = $attachment->getContentType();
|
||||
$dataUri = "data:$mime;base64,$data";
|
||||
$message_body = str_replace("cid:$cid", $dataUri, $message_body);
|
||||
} else {
|
||||
$inline_attachments[] = $attachment;
|
||||
}
|
||||
}
|
||||
$attachments = $inline_attachments;
|
||||
|
||||
if (preg_match("/\[$config_ticket_prefix\d+\]/", $subject, $ticket_number)) {
|
||||
preg_match('/\d+/', $ticket_number[0], $ticket_number);
|
||||
$ticket_number = intval($ticket_number[0]);
|
||||
// Process the email
|
||||
if (preg_match("/\[$config_ticket_prefix(\d+)\]/", $subject, $ticket_number_matches)) {
|
||||
$ticket_number = intval($ticket_number_matches[1]);
|
||||
|
||||
if (addReply($from_email, $date, $subject, $ticket_number, $message_body, $message->getAttachments())) {
|
||||
if (addReply($from_email, $date, $subject, $ticket_number, $message_body, $attachments)) {
|
||||
$email_processed = true;
|
||||
}
|
||||
} else {
|
||||
// Check if the sender is a known contact
|
||||
$from_email_esc = mysqli_real_escape_string($mysqli, $from_email);
|
||||
$any_contact_sql = mysqli_query($mysqli, "SELECT * FROM contacts WHERE contact_email = '$from_email_esc' LIMIT 1");
|
||||
$row = mysqli_fetch_array($any_contact_sql);
|
||||
@@ -448,54 +455,83 @@ if ($messages->count() > 0) {
|
||||
$contact_email = sanitizeInput($row['contact_email']);
|
||||
$client_id = intval($row['contact_client_id']);
|
||||
|
||||
if (addTicket($contact_id, $contact_name, $contact_email, $client_id, $date, $subject, $message_body, $message->getAttachments(), $original_message_file)) {
|
||||
if (addTicket($contact_id, $contact_name, $contact_email, $client_id, $date, $subject, $message_body, $attachments, $original_message_file)) {
|
||||
$email_processed = true;
|
||||
}
|
||||
} else {
|
||||
// Check if the domain is associated with a client
|
||||
$from_domain_esc = mysqli_real_escape_string($mysqli, $from_domain);
|
||||
$row = mysqli_fetch_assoc(mysqli_query($mysqli, "SELECT * FROM domains WHERE domain_name = '$from_domain_esc' LIMIT 1"));
|
||||
$domain_sql = mysqli_query($mysqli, "SELECT * FROM domains WHERE domain_name = '$from_domain_esc' LIMIT 1");
|
||||
$row = mysqli_fetch_assoc($domain_sql);
|
||||
|
||||
if ($row && $from_domain == $row['domain_name']) {
|
||||
$client_id = intval($row['domain_client_id']);
|
||||
|
||||
$password = password_hash(randomString(), PASSWORD_DEFAULT);
|
||||
// Create a new contact
|
||||
$contact_name = $from_name;
|
||||
$contact_email = $from_email;
|
||||
mysqli_query($mysqli, "INSERT INTO contacts SET contact_name = '".mysqli_real_escape_string($mysqli, $contact_name)."', contact_email = '".mysqli_real_escape_string($mysqli, $contact_email)."', contact_notes = 'Added automatically via email parsing.', contact_password_hash = '$password', contact_client_id = $client_id");
|
||||
mysqli_query($mysqli, "INSERT INTO contacts SET contact_name = '".mysqli_real_escape_string($mysqli, $contact_name)."', contact_email = '".mysqli_real_escape_string($mysqli, $contact_email)."', contact_notes = 'Added automatically via email parsing.', contact_client_id = $client_id");
|
||||
$contact_id = mysqli_insert_id($mysqli);
|
||||
|
||||
echo "Created new contact.<br>";
|
||||
mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Contact', log_action = 'Create', log_description = 'Email parser: created contact ".mysqli_real_escape_string($mysqli, $contact_name)."', log_client_id = $client_id");
|
||||
customAction('contact_create', $contact_id);
|
||||
|
||||
if (addTicket($contact_id, $contact_name, $contact_email, $client_id, $date, $subject, $message_body, $message->getAttachments(), $original_message_file)) {
|
||||
if (addTicket($contact_id, $contact_name, $contact_email, $client_id, $date, $subject, $message_body, $attachments, $original_message_file)) {
|
||||
$email_processed = true;
|
||||
}
|
||||
} elseif ($config_ticket_email_parse_unknown_senders) {
|
||||
} elseif ($config_ticket_email_parse_unknown_senders) {
|
||||
// Parse even if the sender is unknown
|
||||
|
||||
if (addTicket(0, 'Guest', $from_email, 0, $date, $subject, $message_body, $message->getAttachments(), $original_message_file)) {
|
||||
$email_processed = true;
|
||||
$bad_from_pattern = "/daemon|postmaster/i";
|
||||
if (!(preg_match($bad_from_pattern, $from_email))) {
|
||||
if (addTicket(0, $from_name, $from_email, 0, $date, $subject, $message_body, $attachments, $original_message_file)) {
|
||||
$email_processed = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if ($email_processed) {
|
||||
$message->setFlag(['Seen']);
|
||||
$message->move('ITFlow');
|
||||
// Mark the message as seen
|
||||
imap_setflag_full($imap, $email_uid, "\\Seen", ST_UID);
|
||||
// Move the message to the 'ITFlow' folder
|
||||
imap_mail_move($imap, $email_uid, 'ITFlow', CP_UID);
|
||||
// Get a Processed Email Count
|
||||
$processed_count++;
|
||||
} else {
|
||||
echo "Failed to process email - flagging for manual review.";
|
||||
$message->setFlag(['Flagged']);
|
||||
// Flag the message for manual review without marking it as read
|
||||
imap_setflag_full($imap, $email_uid, "\\Flagged", ST_UID);
|
||||
// Clear the Seen flag to ensure the email remains unread
|
||||
imap_clearflag_full($imap, $email_uid, "\\Seen", ST_UID);
|
||||
// Get an Unprocessed email count
|
||||
$unprocessed_count++;
|
||||
}
|
||||
|
||||
// Delete the temporary message file
|
||||
if (file_exists("uploads/tmp/{$original_message_file}")) {
|
||||
unlink("uploads/tmp/{$original_message_file}");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
$client->expunge();
|
||||
$client->disconnect();
|
||||
// Expunge deleted mails
|
||||
imap_expunge($imap);
|
||||
|
||||
// Close the IMAP connection
|
||||
imap_close($imap);
|
||||
|
||||
// Calculate the total execution time -uncomment the code below to get exec time
|
||||
$script_end_time = microtime(true);
|
||||
$execution_time = $script_end_time - $script_start_time;
|
||||
$execution_time_formatted = number_format($execution_time, 2);
|
||||
|
||||
// Insert a log entry into the logs table
|
||||
$processed_info = "Processed: $processed_count email(s), Unprocessed: $unprocessed_count email(s)";
|
||||
// Remove Comment below for Troubleshooting
|
||||
// mysqli_query($mysqli, "INSERT INTO logs SET log_type = 'Cron-Email-Parser', log_action = 'Execution', log_description = 'Cron Email Parser executed in $execution_time_formatted seconds. $processed_info'");
|
||||
|
||||
// END Calculate execution time
|
||||
|
||||
// Remove the lock file
|
||||
unlink($lock_file_path);
|
||||
?>
|
||||
|
||||
Reference in New Issue
Block a user