array (
* 'X' => 'name',
* )
* 'X' should be an increment of 1
* 'name' should be the EXACT name of your function
*
* Your function should not be passed any parameters
* Always return a Boolean. If it does not the Job will not terminate itself
* after completion, and the webserver will be forced to time-out that Job instance.
* DO NOT USE sugar_cleanup(); in your function flow or includes. this will
* break Schedulers. That function is called at the foot of cron.php
*/
/**
* This array provides the Schedulers admin interface with values for its "Job"
* dropdown menu.
*/
$job_strings = array(
0 => 'refreshJobs',
1 => 'pollMonitoredInboxes',
2 => 'runMassEmailCampaign',
3 => 'pruneDatabase',
4 => 'trimTracker',
5 => 'pollMonitoredInboxesForBouncedCampaignEmails',
6 => 'pollMonitoredInboxesAOP',
7 => 'aorRunScheduledReports',
8 => 'processAOW_Workflow',
9 => 'sendEmailReminders',
10 => 'cleanJobQueue',
11 => 'removeDocumentsFromFS',
12 => 'trimSugarFeeds',
13 => 'syncGoogleCalendar',
14 => 'runElasticSearchIndexerScheduler',
);
/**
* Job 0 refreshes all job schedulers at midnight
* DEPRECATED
*/
function refreshJobs()
{
return true;
}
/**
* Job 1
*/
function pollMonitoredInboxes()
{
$_bck_up = array('team_id' => $GLOBALS['current_user']->team_id, 'team_set_id' => $GLOBALS['current_user']->team_set_id);
$GLOBALS['log']->info('----->Scheduler fired job of type pollMonitoredInboxes()');
global $dictionary;
global $app_strings;
require_once('modules/Emails/EmailUI.php');
$ie = BeanFactory::newBean('InboundEmail');
$emailUI = new EmailUI();
$r = $ie->db->query('SELECT id, name FROM inbound_email WHERE is_personal = 0 AND deleted=0 AND status=\'Active\' AND mailbox_type != \'bounce\'');
$GLOBALS['log']->debug('Just got Result from get all Inbounds of Inbound Emails');
while ($a = $ie->db->fetchByAssoc($r)) {
$GLOBALS['log']->debug('In while loop of Inbound Emails');
$ieX = BeanFactory::newBean('InboundEmail');
$ieX->retrieve($a['id']);
$mailboxes = $ieX->mailboxarray;
foreach ($mailboxes as $mbox) {
$ieX->mailbox = $mbox;
$newMsgs = array();
$msgNoToUIDL = array();
$connectToMailServer = false;
if ($ieX->isPop3Protocol()) {
$msgNoToUIDL = $ieX->getPop3NewMessagesToDownloadForCron();
// get all the keys which are msgnos;
$newMsgs = array_keys($msgNoToUIDL);
}
if ($ieX->connectMailserver() == 'true') {
$connectToMailServer = true;
} // if
$GLOBALS['log']->debug('Trying to connect to mailserver for [ ' . $a['name'] . ' ]');
if ($connectToMailServer) {
$GLOBALS['log']->debug('Connected to mailserver');
if (!$ieX->isPop3Protocol()) {
$newMsgs = $ieX->getNewMessageIds();
}
$isGroupFolderExists = false;
if (is_array($newMsgs)) {
$current = 1;
$total = count($newMsgs);
require_once("include/SugarFolders/SugarFolders.php");
$sugarFolder = new SugarFolder();
$groupFolderId = $ieX->groupfolder_id;
$users = array();
if ($groupFolderId != null && $groupFolderId != "") {
$sugarFolder->retrieve($groupFolderId);
$isGroupFolderExists = true;
} // if
$messagesToDelete = array();
if ($ieX->isMailBoxTypeCreateCase()) {
$users[] = $sugarFolder->assign_to_id;
$distributionMethod = $ieX->get_stored_options("distrib_method", "");
if ($distributionMethod != 'roundRobin') {
$counts = $emailUI->getAssignedEmailsCountForUsers($users);
} else {
$lastRobin = $emailUI->getLastRobin($ieX);
}
$GLOBALS['log']->debug('distribution method id [ ' . $distributionMethod . ' ]');
}
foreach ($newMsgs as $k => $msgNo) {
$uid = $msgNo;
if ($ieX->isPop3Protocol()) {
$uid = $msgNoToUIDL[$msgNo];
} else {
$uid = $ieX->getImap()->getUid($msgNo);
} // else
if ($isGroupFolderExists) {
if ($ieX->returnImportedEmail($msgNo, $uid)) {
// add to folder
$sugarFolder->addBean($ieX);
if ($ieX->isPop3Protocol()) {
$messagesToDelete[] = $msgNo;
} else {
$messagesToDelete[] = $uid;
}
if ($ieX->isMailBoxTypeCreateCase()) {
$userId = "";
if ($distributionMethod == 'roundRobin') {
if (count($users) === 1) {
$userId = $users[0];
$lastRobin = $users[0];
} else {
$userIdsKeys = array_flip($users); // now keys are values
$thisRobinKey = $userIdsKeys[$lastRobin] + 1;
if (!empty($users[$thisRobinKey])) {
$userId = $users[$thisRobinKey];
$lastRobin = $users[$thisRobinKey];
} else {
$userId = $users[0];
$lastRobin = $users[0];
}
} // else
} else {
if (count($users) === 1) {
foreach ($users as $k => $value) {
$userId = $value;
} // foreach
} else {
asort($counts); // lowest to highest
$countsKeys = array_flip($counts); // keys now the 'count of items'
$leastBusy = array_shift($countsKeys); // user id of lowest item count
$userId = $leastBusy;
$counts[$leastBusy] = $counts[$leastBusy] + 1;
}
} // else
$GLOBALS['log']->debug('userId [ ' . $userId . ' ]');
$ieX->handleCreateCase($ieX->email, $userId);
} // if
} // if
} else {
if ($ieX->isAutoImport()) {
$ieX->returnImportedEmail($msgNo, $uid);
} else {
/*If the group folder doesn't exist then download only those messages
which has caseid in message*/
$ieX->getMessagesInEmailCache($msgNo, $uid);
$email = BeanFactory::newBean('Emails');
$header = $ieX->getImap()->getHeaderInfo($msgNo);
$email->name = $ieX->handleMimeHeaderDecode($header->subject);
$email->from_addr = $ieX->convertImapToSugarEmailAddress($header->from);
isValidEmailAddress($email->from_addr);
$email->reply_to_email = $ieX->convertImapToSugarEmailAddress($header->reply_to);
if (!empty($email->reply_to_email)) {
$contactAddr = $email->reply_to_email;
isValidEmailAddress($contactAddr);
} else {
$contactAddr = $email->from_addr;
isValidEmailAddress($contactAddr);
}
$mailBoxType = $ieX->mailbox_type;
$ieX->handleAutoresponse($email, $contactAddr);
} // else
} // else
$GLOBALS['log']->debug('***** On message [ ' . $current . ' of ' . $total . ' ] *****');
$current++;
} // foreach
// update Inbound Account with last robin
if ($ieX->isMailBoxTypeCreateCase() && $distributionMethod == 'roundRobin') {
$emailUI->setLastRobin($ieX, $lastRobin);
} // if
} // if
if ($isGroupFolderExists) {
$leaveMessagesOnMailServer = $ieX->get_stored_options("leaveMessagesOnMailServer", 0);
if (!$leaveMessagesOnMailServer) {
if ($ieX->isPop3Protocol()) {
$ieX->deleteMessageOnMailServerForPop3(implode(",", $messagesToDelete));
} else {
$ieX->deleteMessageOnMailServer(implode($app_strings['LBL_EMAIL_DELIMITER'], $messagesToDelete));
}
}
}
} else {
$GLOBALS['log']->fatal("SCHEDULERS: could not get an IMAP connection resource for ID [ {$a['id']} ]. Skipping mailbox [ {$a['name']} ].");
// cn: bug 9171 - continue while
} // else
} // foreach
$ieX->getImap()->expunge();
$ieX->getImap()->close(CL_EXPUNGE);
} // while;
return true;
}
/**
* Job 2
*/
function runMassEmailCampaign()
{
if (!class_exists('LoggerManager')) {
}
$GLOBALS['log'] = LoggerManager::getLogger('emailmandelivery');
$GLOBALS['log']->debug('Called:runMassEmailCampaign');
if (!class_exists('DBManagerFactory')) {
require('include/database/DBManagerFactory.php');
}
global $beanList;
global $beanFiles;
require("config.php");
require('include/modules.php');
if (!class_exists('AclController')) {
require('modules/ACL/ACLController.php');
}
require('modules/EmailMan/EmailManDelivery.php');
return true;
}
/**
* Job 3
*/
function pruneDatabase()
{
$GLOBALS['log']->info('----->Scheduler fired job of type pruneDatabase()');
$backupDir = sugar_cached('backups');
$backupFile = 'backup-pruneDatabase-GMT0_' . gmdate('Y_m_d-H_i_s', strtotime('now')) . '.php';
$db = DBManagerFactory::getInstance();
$tables = $db->getTablesArray();
$queryString = array();
if (!empty($tables)) {
foreach ($tables as $kTable => $table) {
// find tables with deleted=1
$columns = $db->get_columns($table);
// no deleted - won't delete
if (empty($columns['deleted'])) {
continue;
}
$custom_columns = array();
if (array_search($table . '_cstm', $tables, true)) {
$custom_columns = $db->get_columns($table . '_cstm');
if (empty($custom_columns['id_c'])) {
$custom_columns = array();
}
}
$qDel = "SELECT * FROM $table WHERE deleted = 1";
$rDel = $db->query($qDel);
// make a backup INSERT query if we are deleting.
while ($aDel = $db->fetchByAssoc($rDel, false)) {
// build column names
$queryString[] = $db->insertParams($table, $columns, $aDel, null, false);
if (!empty($custom_columns) && !empty($aDel['id'])) {
$qDelCstm = 'SELECT * FROM ' . $table . '_cstm WHERE id_c = ' . $db->quoted($aDel['id']);
$rDelCstm = $db->query($qDelCstm);
// make a backup INSERT query if we are deleting.
while ($aDelCstm = $db->fetchByAssoc($rDelCstm)) {
$queryString[] = $db->insertParams($table, $custom_columns, $aDelCstm, null, false);
} // end aDel while()
$db->query('DELETE FROM ' . $table . '_cstm WHERE id_c = ' . $db->quoted($aDel['id']));
}
} // end aDel while()
// now do the actual delete
$db->query('DELETE FROM ' . $table . ' WHERE deleted = 1');
} // foreach() tables
if (!file_exists($backupDir) || !file_exists($backupDir . '/' . $backupFile)) {
// create directory if not existent
mkdir_recursive($backupDir, false);
}
// write cache file
write_array_to_file('pruneDatabase', $queryString, $backupDir . '/' . $backupFile);
return true;
}
return false;
}
///**
// * Job 4
// */
//function securityAudit() {
// // do something
// return true;
//}
function trimTracker()
{
global $sugar_config, $timedate;
$GLOBALS['log']->info('----->Scheduler fired job of type trimTracker()');
$db = DBManagerFactory::getInstance();
$admin = BeanFactory::newBean('Administration');
$admin->retrieveSettings('tracker');
require('modules/Trackers/config.php');
$trackerConfig = $tracker_config;
require_once('include/utils/db_utils.php');
$prune_interval = !empty($admin->settings['tracker_prune_interval']) ? $admin->settings['tracker_prune_interval'] : 30;
foreach ($trackerConfig as $tableName => $tableConfig) {
//Skip if table does not exist
if (!$db->tableExists($tableName)) {
continue;
}
$timeStamp = DBManagerFactory::getInstance()->convert("'" . $timedate->asDb($timedate->getNow()->get("-" . $prune_interval . " days")) . "'", "datetime");
if ($tableName == 'tracker_sessions') {
$query = "DELETE FROM $tableName WHERE date_end < $timeStamp";
} else {
$query = "DELETE FROM $tableName WHERE date_modified < $timeStamp";
}
$GLOBALS['log']->info("----->Scheduler is about to trim the $tableName table by running the query $query");
$db->query($query);
} //foreach
return true;
}
/* Job 5
*
*/
function pollMonitoredInboxesForBouncedCampaignEmails()
{
$GLOBALS['log']->info('----->Scheduler job of type pollMonitoredInboxesForBouncedCampaignEmails()');
global $dictionary;
$ie = BeanFactory::newBean('InboundEmail');
$r = $ie->db->query('SELECT id FROM inbound_email WHERE deleted=0 AND status=\'Active\' AND mailbox_type=\'bounce\'');
while ($a = $ie->db->fetchByAssoc($r)) {
$ieX = BeanFactory::newBean('InboundEmail');
$ieX->retrieve($a['id']);
$ieX->connectMailserver();
$ieX->importMessages();
}
return true;
}
/**
* Job 12
*/
function sendEmailReminders()
{
$GLOBALS['log']->info('----->Scheduler fired job of type sendEmailReminders()');
require_once("modules/Activities/EmailReminder.php");
$reminder = new EmailReminder();
return $reminder->process();
}
function removeDocumentsFromFS()
{
$GLOBALS['log']->info('Starting removal of documents if they are not present in DB');
/**
* @var DBManager $db
* @var SugarBean $bean
*/
$db = DBManagerFactory::getInstance();
// temp table to store id of files without memory leak
$tableName = 'cron_remove_documents';
$resource = $db->limitQuery("SELECT * FROM cron_remove_documents WHERE 1=1 ORDER BY date_modified ASC", 0, 100);
$return = true;
while ($row = $db->fetchByAssoc($resource)) {
$bean = BeanFactory::getBean($row['module']);
$bean->retrieve($row['bean_id'], true, false);
if (empty($bean->id)) {
$isSuccess = true;
$bean->id = $row['bean_id'];
$directory = $bean->deleteFileDirectory();
if (!empty($directory) && is_dir('upload://deleted/' . $directory)) {
if ($isSuccess = rmdir_recursive('upload://deleted/' . $directory)) {
$directory = explode('/', $directory);
while (!empty($directory)) {
$path = 'upload://deleted/' . implode('/', $directory);
if (is_dir($path)) {
$directoryIterator = new DirectoryIterator($path);
$empty = true;
foreach ($directoryIterator as $item) {
if ($item->getFilename() == '.' || $item->getFilename() == '..') {
continue;
}
$empty = false;
break;
}
if ($empty) {
rmdir($path);
}
}
array_pop($directory);
}
}
}
if ($isSuccess) {
$db->query('DELETE FROM ' . $tableName . ' WHERE id=' . $db->quoted($row['id']));
} else {
$return = false;
}
} else {
$db->query('UPDATE ' . $tableName . ' SET date_modified=' . $db->convert($db->quoted(TimeDate::getInstance()->nowDb()), 'datetime') . ' WHERE id=' . $db->quoted($row['id']));
}
}
return $return;
}
/**
* + * Job 16
* + * this will trim all records in sugarfeeds table that are older than 30 days or specified interval
* + */
function trimSugarFeeds()
{
global $sugar_config, $timedate;
$GLOBALS['log']->info('----->Scheduler fired job of type trimSugarFeeds()');
$db = DBManagerFactory::getInstance();
//get the pruning interval from globals if it's specified
$prune_interval = !empty($GLOBALS['sugar_config']['sugarfeed_prune_interval']) && is_numeric($GLOBALS['sugar_config']['sugarfeed_prune_interval']) ? $GLOBALS['sugar_config']['sugarfeed_prune_interval'] : 30;
//create and run the query to delete the records
$timeStamp = $db->convert("'" . $timedate->asDb($timedate->getNow()->get("-" . $prune_interval . " days")) . "'", "datetime");
$query = "DELETE FROM sugarfeed WHERE date_modified < $timeStamp";
$GLOBALS['log']->info("----->Scheduler is about to trim the sugarfeed table by running the query $query");
$db->query($query);
return true;
}
/**
* + * Job 17
* + * this will sync the Google Calendars of users who are configured to do so
* + */
function syncGoogleCalendar()
{
global $sugar_config;
require_once 'include/GoogleSync/GoogleSync.php';
$googleSync = new GoogleSync($sugar_config);
$googleSync->syncAllUsers();
return true;
}
function cleanJobQueue($job)
{
$td = TimeDate::getInstance();
// soft delete all jobs that are older than cutoff
$soft_cutoff = 7;
if (isset($GLOBALS['sugar_config']['jobs']['soft_lifetime'])) {
$soft_cutoff = $GLOBALS['sugar_config']['jobs']['soft_lifetime'];
}
$soft_cutoff_date = $job->db->quoted($td->getNow()->modify("- $soft_cutoff days")->asDb());
$job->db->query("UPDATE {$job->table_name} SET deleted=1 WHERE status='done' AND date_modified < " . $job->db->convert($soft_cutoff_date, 'datetime'));
// hard delete all jobs that are older than hard cutoff
$hard_cutoff = 21;
if (isset($GLOBALS['sugar_config']['jobs']['hard_lifetime'])) {
$hard_cutoff = $GLOBALS['sugar_config']['jobs']['hard_lifetime'];
}
$hard_cutoff_date = $job->db->quoted($td->getNow()->modify("- $hard_cutoff days")->asDb());
$job->db->query("DELETE FROM {$job->table_name} WHERE status='done' AND date_modified < " . $job->db->convert($hard_cutoff_date, 'datetime'));
return true;
}
function pollMonitoredInboxesAOP()
{
require_once 'modules/InboundEmail/AOPInboundEmail.php';
$GLOBALS['log']->info('----->Scheduler fired job of type pollMonitoredInboxesAOP()');
global $dictionary;
global $app_strings;
global $sugar_config;
require_once('modules/Configurator/Configurator.php');
$aopInboundEmail = new AOPInboundEmail();
$sqlQueryResult = $aopInboundEmail->db->query(
'SELECT id, name FROM inbound_email WHERE is_personal = 0 AND deleted=0 AND status=\'Active\'' .
' AND mailbox_type != \'bounce\''
);
$GLOBALS['log']->debug('Just got Result from get all Inbounds of Inbound Emails');
while ($inboundEmailRow = $aopInboundEmail->db->fetchByAssoc($sqlQueryResult)) {
$GLOBALS['log']->debug('In while loop of Inbound Emails');
$aopInboundEmailX = new AOPInboundEmail();
if (!$aopInboundEmailX->retrieve($inboundEmailRow['id']) || !$aopInboundEmailX->id) {
throw new Exception('Error retrieving AOP Inbound Email: ' . $inboundEmailRow['id']);
}
$mailboxes = $aopInboundEmailX->mailboxarray;
foreach ($mailboxes as $mbox) {
$aopInboundEmailX->mailbox = $mbox;
$newMsgs = array();
$msgNoToUIDL = array();
$connectToMailServer = false;
if ($aopInboundEmailX->isPop3Protocol()) {
$msgNoToUIDL = $aopInboundEmailX->getPop3NewMessagesToDownloadForCron();
// get all the keys which are msgnos;
$newMsgs = array_keys($msgNoToUIDL);
}
if ($aopInboundEmailX->connectMailserver() == 'true') {
$connectToMailServer = true;
} // if
$GLOBALS['log']->debug('Trying to connect to mailserver for [ ' . $inboundEmailRow['name'] . ' ]');
if ($connectToMailServer) {
$GLOBALS['log']->debug('Connected to mailserver');
if (!$aopInboundEmailX->isPop3Protocol()) {
$newMsgs = $aopInboundEmailX->getNewMessageIds();
}
if (is_array($newMsgs)) {
$current = 1;
$total = count($newMsgs);
require_once("include/SugarFolders/SugarFolders.php");
$sugarFolder = new SugarFolder();
$groupFolderId = $aopInboundEmailX->groupfolder_id;
$isGroupFolderExists = false;
$users = array();
if ($groupFolderId != null && $groupFolderId != "") {
// FIX #6994 - Unable to retrieve Sugar Folder due to incorrect groupFolderId
$sugarFolder->retrieve($groupFolderId);
if (empty($sugarFolder->id)) {
$sugarFolder->retrieve($aopInboundEmailX->id);
}
if (!empty($sugarFolder->id)) {
$isGroupFolderExists = true;
}
} // if
$messagesToDelete = array();
if ($aopInboundEmailX->isMailBoxTypeCreateCase()) {
require_once 'modules/AOP_Case_Updates/AOPAssignManager.php';
$assignManager = new AOPAssignManager($aopInboundEmailX);
}
foreach ($newMsgs as $k => $msgNo) {
$uid = $msgNo;
if ($aopInboundEmailX->isPop3Protocol()) {
$uid = $msgNoToUIDL[$msgNo];
} else {
$uid = $aopInboundEmailX->getImap()->getUid($msgNo);
} // else
if ($isGroupFolderExists) {
$emailId = $aopInboundEmailX->returnImportedEmail($msgNo, $uid, false, true, $isGroupFolderExists);
if (!empty($emailId)) {
// add to folder
$sugarFolder->addBean($aopInboundEmailX);
if ($aopInboundEmailX->isPop3Protocol()) {
$messagesToDelete[] = $msgNo;
} else {
$messagesToDelete[] = $uid;
}
if ($aopInboundEmailX->isMailBoxTypeCreateCase()) {
$userId = $assignManager->getNextAssignedUser();
$GLOBALS['log']->debug('userId [ ' . $userId . ' ]');
$validatior = new SuiteValidator();
if ((!isset($aopInboundEmailX->email) || !$aopInboundEmailX->email ||
!isset($aopInboundEmailX->email->id) || !$aopInboundEmailX->email->id) &&
$validatior->isValidId($emailId)
) {
$aopInboundEmailX->email = BeanFactory::newBean('Emails');
if (!$aopInboundEmailX->email->retrieve($emailId)) {
throw new Exception('Email retrieving error to handle case create, email id was: ' . $emailId);
}
}
if (empty($aopInboundEmailX->email)) {
throw new Exception('Invalid type for email id ' . $emailId);
}
$aopInboundEmailX->handleCreateCase($aopInboundEmailX->email, $userId);
} // if
} // if
} else {
if ($aopInboundEmailX->isAutoImport()) {
$aopInboundEmailX->returnImportedEmail($msgNo, $uid);
} else {
/*If the group folder doesn't exist then download only those messages
which has caseid in message*/
$aopInboundEmailX->getMessagesInEmailCache($msgNo, $uid);
$email = BeanFactory::newBean('Emails');
$header = $aopInboundEmailX->getImap()->getHeaderInfo($msgNo);
$email->name = $aopInboundEmailX->handleMimeHeaderDecode($header->subject);
$email->from_addr = $aopInboundEmailX->convertImapToSugarEmailAddress($header->from);
isValidEmailAddress($email->from_addr);
$email->reply_to_email = $aopInboundEmailX->convertImapToSugarEmailAddress($header->reply_to);
if (!empty($email->reply_to_email)) {
$contactAddr = $email->reply_to_email;
isValidEmailAddress($contactAddr);
} else {
$contactAddr = $email->from_addr;
isValidEmailAddress($contactAddr);
}
$mailBoxType = $aopInboundEmailX->mailbox_type;
$aopInboundEmailX->handleAutoresponse($email, $contactAddr);
} // else
} // else
$GLOBALS['log']->debug('***** On message [ ' . $current . ' of ' . $total . ' ] *****');
$current++;
} // foreach
// update Inbound Account with last robin
} // if
if (!empty($isGroupFolderExists)) {
$leaveMessagesOnMailServer = $aopInboundEmailX->get_stored_options("leaveMessagesOnMailServer", 0);
if (!$leaveMessagesOnMailServer) {
if ($aopInboundEmailX->isPop3Protocol()) {
$aopInboundEmailX->deleteMessageOnMailServerForPop3(implode(",", $messagesToDelete));
} else {
$aopInboundEmailX->deleteMessageOnMailServer(implode($app_strings['LBL_EMAIL_DELIMITER'], $messagesToDelete));
}
}
}
} else {
$GLOBALS['log']->fatal("SCHEDULERS: could not get an IMAP connection resource for ID [ {$inboundEmailRow['id']} ]. Skipping mailbox [ {$inboundEmailRow['name']} ].");
// cn: bug 9171 - continue while
} // else
} // foreach
$aopInboundEmailX->getImap()->expunge();
$aopInboundEmailX->getImap()->close(CL_EXPUNGE);
} // while
return true;
}
function aorRunScheduledReports()
{
require_once 'include/SugarQueue/SugarJobQueue.php';
$db = DBManagerFactory::getInstance();
$date = new DateTime();//Ensure we check all schedules at the same instant
foreach (BeanFactory::getBean('AOR_Scheduled_Reports')->get_full_list() as $scheduledReport) {
if ($scheduledReport->status != 'active') {
continue;
}
try {
$shouldRun = $scheduledReport->shouldRun($date);
} catch (Exception $ex) {
LoggerManager::getLogger()->warn('aorRunScheduledReports: id: ' . $scheduledReport->id . ' got exception. code: ' . $ex->getCode() . ', message: ' . $ex->getMessage());
$shouldRun = false;
}
if ($shouldRun) {
if (empty($scheduledReport->aor_report_id)) {
continue;
}
$queued = $db->fetchOne("SELECT count(*) cnt FROM job_queue WHERE data=".$db->quoted($scheduledReport->id)." and deleted=0 and status = 'running' and execute_time >= " . $db->quoted(date("Y-m-d H:i:s", strtotime("-2 hours"))));
if(!empty($queued) && $queued['cnt'] > 0) {
LoggerManager::getLogger()->warn('aorRunScheduledReports: id: ' . $scheduledReport->id . ' is already running. Postpone creating new job.');
continue;
}
$job = BeanFactory::newBean('SchedulersJobs');
$job->name = "Scheduled report - {$scheduledReport->name} on {$date->format('c')}";
$job->data = $scheduledReport->id;
$job->target = "class::AORScheduledReportJob";
$job->assigned_user_id = 1;
$jq = new SugarJobQueue();
$jq->submitJob($job);
}
}
return true;
}
function processAOW_Workflow()
{
require_once('modules/AOW_WorkFlow/AOW_WorkFlow.php');
$workflow = BeanFactory::newBean('AOW_WorkFlow');
return $workflow->run_flows();
}
#[\AllowDynamicProperties]
class AORScheduledReportJob implements RunnableSchedulerJob
{
public function setJob(SchedulersJob $job)
{
$this->job = $job;
}
public function run($data)
{
global $timedate;
$bean = BeanFactory::getBean('AOR_Scheduled_Reports', $data);
$report = $bean->get_linked_beans('aor_report', 'AOR_Reports');
if ($report) {
$report = $report[0];
} else {
return false;
}
$html = "{$report->name}
" . $report->build_group_report();
$html .= <<
h1{
color: black;
}
.list
{
font-family: "Lucida Sans Unicode", "Lucida Grande", Sans-Serif;font-size: 12px;
background: #fff;margin: 45px;width: 480px;border-collapse: collapse;text-align: left;
}
.list th
{
font-size: 14px;
font-weight: normal;
color: black;
padding: 10px 8px;
border-bottom: 2px solid black;
}
.list td
{
padding: 9px 8px 0px 8px;
}
EOF;
$emailObj = BeanFactory::newBean('Emails');
$defaults = $emailObj->getSystemDefaultEmail();
$mail = new SugarPHPMailer();
$mail->setMailerForSystem();
$mail->IsHTML(true);
$mail->From = $defaults['email'];
isValidEmailAddress($mail->From);
$mail->FromName = $defaults['name'];
$mail->Subject = from_html($bean->name);
$mail->Body = $html;
$mail->prepForOutbound();
$success = true;
$emails = $bean->get_email_recipients();
foreach ($emails as $email_address) {
$mail->ClearAddresses();
$mail->AddAddress($email_address);
$success = $mail->Send() && $success;
}
$bean->last_run = $timedate->getNow()->asDb(false);
$bean->save();
return true;
}
}
function runElasticSearchIndexerScheduler($data)
{
return \SuiteCRM\Search\ElasticSearch\ElasticSearchIndexer::schedulerJob(json_decode((string) $data));
}
if (file_exists('custom/modules/Schedulers/_AddJobsHere.php')) {
require('custom/modules/Schedulers/_AddJobsHere.php');
}
if (file_exists('custom/modules/Schedulers/Ext/ScheduledTasks/scheduledtasks.ext.php')) {
require('custom/modules/Schedulers/Ext/ScheduledTasks/scheduledtasks.ext.php');
}