Sending to {$who} reminders [" . implode(",", $reminders) . "] at '{$when}'
" . "\n";
$this->send($who, $listWhat, $when, $forceMail);
$this->markAsSent($who, $listWhat, $when);
}
}
}
/**
* @param $reminders array( )
* @param $when 'once_a_day', 'immediately'
*/
public function send($usrLogin, $reminders, $when = null, $forceMail = null) {
DBG::_('DBG_NTF', '>1', "usrLogin", $usrLogin, __CLASS__, __FUNCTION__, __LINE__);
DBG::_('DBG_NTF', '>1', "reminders(when: {$when})", $reminders, __CLASS__, __FUNCTION__, __LINE__);
$mainMail = $this->getUserMainMail($usrLogin);
$msgNote = '';
if (!empty($forceMail)) {
$mainMail = $forceMail;
if (empty($user['aliasy'])) $msgNote .= 'ERROR: Brak lokalnego adresu email' . "\n\n";
}
$pattern = "/^[_a-z0-9-]+(\.[_a-z0-9-]+)*@[a-z0-9-]+(\.[a-z0-9-]+)*(\.[a-z]{2,3})$/i";
if (!preg_match($pattern, $mainMail)) throw new Exception("Adres email ma błędny format");
$usrReminders = $this->getUserReminders($usrLogin, $reminders, $when);
if (empty($usrReminders)) {
DBG::_('DBG_NTF', '>0', "Skip usr({$usrLogin}) - no remindres", $usrReminders, __CLASS__, __FUNCTION__, __LINE__);
return;
}
$to = $mainMail;
$headers = "From: " . "noreply@{$_SERVER['SERVER_NAME']}" . "\r\n";
$headers .= "MIME-Version: 1.0\r\n";
$headers .= "Content-Type: text/html; charset=UTF-8\r\n";
if (null == $when || 'once_a_day' == $when) {
$subject = "Powiadomienia dla {$usrLogin} - " . date("Y-m-d") . " - {$_SERVER['SERVER_NAME']}";
} else {
$subject = "Nowe powiadomienia dla {$usrLogin} - {$_SERVER['SERVER_NAME']}";
}
ob_start();
$this->viewUserReminders($usrReminders, $usrLogin);
echo "\n\n';
?>
Powiadomienia dla
$listTodo) : ?>
printValue('what', $reminderType); ?>
';// .container
echo '';
echo '';
}
public function editLink($todo) {
$idTblZasob = 0;
$idRecord = 0;
if ('zasob' == $todo['_task_type']
|| 'proces' == $todo['_task_type']
|| 'projekt' == $todo['_task_type']
|| 'koresp' == $todo['_task_type']
|| 'task' == $todo['_task_type']
) {
$idTblZasob = $todo['_idZasobTable'];
$idRecord = $todo['ID'];
}
if (!$idTblZasob || !$idRecord) return '#';
return Router::getRoute('ViewTableajax')->getLink('', [
'namespace' => ACL::getNamespaceFromId($idTblZasob),
]) . "#EDIT/{$idRecord}";
}
public function readMsgLink($usrLogin, $todo) {
$idMsg = 0;
if ('msg' == $todo['_task_type']) {
$idMsg = $todo['idMsg'];
}
if (!$idMsg) return '#' . json_encode($todo);
if (!$idMsg) return '#';
return Router::getRoute('UserMsgs')->getLink('read', [ 'usrLogin' => $usrLogin, 'id' => $idMsg ]);
}
public function inlineCss($cssSelector) {
$baseCss = array();
$baseCss['font-family'] = 'Arial, Helvetica, sans-serif';
$baseCss['font-size'] = 'small';
$baseCss['color'] = '#333';
$customCss = array(
'h1' => array(),
'header' => array('background' => '#eee', 'padding' => '4px 10px', 'margin-top' => '6px'),
'l_app.target' => array('color' => '#999', 'white-space' => 'nowrap'),
'td.date-base' => array('white-space' => 'nowrap'),
'td.lp' => array('color' => 'silver'),
'l_app_date-base' => array('white-space' => 'nowrap'),
'a' => array('color' => '#337ab7', 'text-decoration' => 'none')
);
$css = $baseCss;
if (array_key_exists($cssSelector, $customCss)) $css = V::extend($css, $customCss[$cssSelector]);
if ('td.date-' == substr($cssSelector, 0, 8)) {
$css = V::extend($css, $customCss['td.date-base']);
$css = V::extend($css, array('color' => $this->getTodoDateCssColor(substr($cssSelector, 3))));
}
if ('l_app_date.date-' == substr($cssSelector, 0, 16)) {
$css = V::extend($css, $customCss['l_app_date-base']);
$css = V::extend($css, array('color' => $this->getTodoDateCssColor(substr($cssSelector, 11))));
}
$inlineCss = array();
foreach ($css as $cssPropName => $cssValue) {
if (true === $cssValue) {
if (!array_key_exists($cssPropName, $baseCss)) continue;
$cssValue = $baseCss[$cssPropName];
}
$inlineCss[] = "{$cssPropName}:{$cssValue}";
}
return implode(";", $inlineCss);
}
public function getTodoDateCssColor($lAppClass) {
$color = '#000';
switch ($lAppClass) {
case 'date-PO_TERMINIE': $color = '#FD4242'; break;
case 'date-DZISIAJ': $color = '#34B934'; break;
case 'date-W_CIAGU_7_DNI': $color = '#C58B1F'; break;
case 'date-PO_7_DNIACH': $color = '#87847D'; break;
}
return $color;
}
public function getTodoForUserReminder($usrLogin, $reminderWhat, $lastExecTime = null) {
$listTodo = array();
if ('msgs' == $reminderWhat) {
$routeMsgs = Router::getRoute('UserMsgs');
$routeMsgs->_listLimit = 50;
$msgs = $routeMsgs->getMsgs('unread', $usrLogin, $lastMsgId = null, $lastExecTime);
foreach ($msgs as $idMsg => $msg) {
$todo = array();
$todo['_task_type'] = 'msg';
// [userTargetType] => group
// [userTargetName] => 2948
$todo['_l_app'] = '';
if ('group' == $msg['_raw']->userTargetType) {
$todo['_l_app'] = "do grupy {$msg['_raw']->userTargetName}";
} else if ('user' == $msg['_raw']->userTargetType) {
$todo['_l_app'] = "do {$msg['_raw']->userTargetName}";
}
$todo['idMsg'] = $idMsg;
$todo['_l_app_date'] = substr($msg['_raw']->A_RECORD_CREATE_DATE, 0, 10);
$todo['_l_app_class'] = 'date-PO_TERMINIE';
$todo['L_APPOITMENT_INFO'] = $msg['message'];
// $msg['_raw']->A_STATUS == 'WAITING' => Unread
// $msg['_raw']->A_STATUS == 'NORMAL' => Read
// $msg['_raw']->A_STATUS == 'OFF_SOFT' => Trash
$msgInfo = '
' . "Wysłane {$msg['_raw']->A_RECORD_CREATE_DATE} przez {$msg['_raw']->A_RECORD_CREATE_AUTHOR}" . '';
if ('NORMAL' == $msg['_raw']->A_STATUS) $msgInfo .= '
' . "Przeczytane {$msg['_raw']->A_RECORD_UPDATE_DATE} przez {$msg['_raw']->A_RECORD_UPDATE_AUTHOR}" . '';
$todo['_title'] = $msgInfo;
$listTodo[] = $todo;
}
}
else if ('l_app_projekty' == $reminderWhat) {
$tasks = $this->getPrzypomnijTasks($usrLogin);
foreach ($tasks as $task) {
if (empty($task['_l_app_date']) || '0000-00-00' == $task['_l_app_date']) continue;
if ('projekt' != $task['_task_type']) continue;
//$task['DESC'] = $task['A_PROBLEM_DESC'];
if (!$this->filterTaskByTime($task, $lastExecTime)) continue;
$listTodo[] = $task;
}
}
else if ('l_app_koresp' == $reminderWhat) {
$tasks = $this->getPrzypomnijTasks($usrLogin);
foreach ($tasks as $task) {
if (empty($task['_l_app_date']) || '0000-00-00' == $task['_l_app_date']) continue;
if ('koresp' != $task['_task_type']) continue;
//$task['DESC'] = $task['A_PROBLEM_DESC'];
if (!$this->filterTaskByTime($task, $lastExecTime)) continue;
$listTodo[] = $task;
}
}
else if ('l_app_zadania' == $reminderWhat) {
$tasks = $this->getPrzypomnijTasks($usrLogin);
foreach ($tasks as $task) {
if (empty($task['_l_app_date']) || '0000-00-00' == $task['_l_app_date']) continue;
if ('task' != $task['_task_type']) continue;
//$task['DESC'] = $task['A_PROBLEM_DESC'];
if (!$this->filterTaskByTime($task, $lastExecTime)) continue;
$listTodo[] = $task;
}
}
else if ('l_app_procesy' == $reminderWhat) {
$tasks = $this->getPrzypomnijTasks($usrLogin);
foreach ($tasks as $task) {
if (empty($task['_l_app_date']) || '0000-00-00' == $task['_l_app_date']) continue;
if ('proces' != $task['_task_type']) continue;
if (!$this->filterTaskByTime($task, $lastExecTime)) continue;
$listTodo[] = $task;
}
}
else if ('l_app_zasoby' == $reminderWhat) {
$tasks = $this->getPrzypomnijTasks($usrLogin);
foreach ($tasks as $task) {
if (empty($task['_l_app_date']) || '0000-00-00' == $task['_l_app_date']) continue;
if ('zasob' != $task['_task_type']) continue;
if (!$this->filterTaskByTime($task, $lastExecTime)) continue;
$listTodo[] = $task;
}
}
return $listTodo;
}
public function filterTaskByTime($task, $lastExecTime) {
if (null == $lastExecTime) return true;
if (empty($task['A_RECORD_CREATE_DATE'])) return true;
if ($task['A_RECORD_CREATE_DATE'] >= $lastExecTime) return true;
if (empty($task['A_RECORD_UPDATE_DATE'])) {
DBG::_('DBG_NTF', '>1', "skip task by lastExecTime({$lastExecTime}) - empty update date", $task, __CLASS__, __FUNCTION__, __LINE__);
return false;
} else if ($task['A_RECORD_UPDATE_DATE'] < $lastExecTime) {
DBG::_('DBG_NTF', '>1', "skip task by lastExecTime({$lastExecTime}) - old update date", $task, __CLASS__, __FUNCTION__, __LINE__);
return false;
}
return true;
}
public function getPrzypomnijTasks($usrLogin) {
static $_tasks = array();
if (empty($_tasks[$usrLogin])) {
$_tasks[$usrLogin] = array();
$przypomnij = new Przypomnij();
$przypomnij->setRecurseLimit(3);
$przypomnij->fetchData($usrLogin);
$przypomnij->setFltrUser($usrLogin);
$tasks = $przypomnij->getTasksByDate();
{
$usrGroupNames = array();
//$usrGroupNames = User::getLdapGroupsNames();
Lib::loadClass('UsersLdapHelper');
$ldapGroups = UsersLdapHelper::getUserGroups($usrLogin, 3);
foreach ($ldapGroups as $kID => $vLDAPGroup) {
$usrGroupNames[$kID] = $vLDAPGroup->cn;
}
}
foreach ($tasks as $task) {
if (!$task->_show) continue;
if (
$task->A_CLASSIFIED != ''
&& !(in_array($task->A_CLASSIFIED, $usrGroupNames))
&& $task->A_ADM_COMPANY != ''
&& !(in_array($task->A_ADM_COMPANY, $usrGroupNames))
// !($allowedUsers[$task->_l_app]) - to jest bez sensu - wystarczy widocznosc sprawy?
) {
continue;
}
$task->_l_app_class = $przypomnij->getTaskDateFltrType($task->_l_app_date);
$task->_idZasobTable = $przypomnij->getZasobIdByType($task->_task_type);
$_tasks[$usrLogin][] = (array)$task;
}
}
return $_tasks[$usrLogin];
}
public function removeUserTableReminder($args) {
$usrLogin = User::getLogin();
$who = V::validate('who', $args, array('type'=>'login', 'equal'=>$usrLogin, 'error_msg_equal'=>"Brak uprawnień do wprowadzania zmian w powiadomieniach innych użytwkoników"));
$what = V::validate('what', $args, array('type'=>'word', 'not_empty'=>true, 'max_length'=>'255', 'values'=>$this->getFieldValues('what')));
$when = V::validate('when', $args, array('type'=>'word', 'not_empty'=>true, 'max_length'=>'255', 'values'=>$this->getFieldValues('when')));
if ($usrLogin != $who) throw new Exception("Brak uprawnień do wprowadzania zmian w powiadomieniach innych użytwkoników");
$pdo = DB::getPDO();
$sth = $pdo->prepare("
delete from `CRM_NOTIFY`
where `who` = :who
and `what` = :what
and `when` = :when
");
$sth->bindValue(':who', $usrLogin, PDO::PARAM_STR);
$sth->bindValue(':what', $what, PDO::PARAM_STR);
$sth->bindValue(':when', $when, PDO::PARAM_STR);
$sth->execute();
}
public function formUserTableReminder($usrLogin) {
echo '
';
$subTask = V::get('_subTask', '', $_POST);
if ('_add_table_reminder' == $subTask) {
try {
$this->addUserTableReminder($usrLogin, $_POST);
UI::alert('info', "Dodano powiadomienie");
} catch (PDOException $e) {
if (!empty($e->errorInfo) && !empty($e->errorInfo[1]) && '1062' == $e->errorInfo[1]) {
UI::alert('warning', "Powiadomienie tego typu zostało już wcześniej dodane");
} else {
UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage() . '
' . "Info: " . json_encode($e->errorInfo));
}
} catch (Exception $e) {
UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
}
}
else if ('_rm_table_reminder' == $subTask) {
try {
$this->removeUserTableReminder($_POST);
UI::alert('info', "Usunięto powiadomienie");
} catch (Exception $e) {
UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
}
}
$userNotifyList = $this->getUserNotifyList($usrLogin);
$userMail = $this->getUserMainMail($usrLogin);
$whatLabelsForOnceADay = $this->getFieldValueLabels('what', $userNotifyList, $when = 'once_a_day');
$whatLabelsForImmediately = $this->getFieldValueLabels('what', $userNotifyList, $when = 'immediately');
echo UI::h('h1', [], "Powiadomienia dla
{$usrLogin}");
echo UI::h('p', [ 'style' => "font-style:italic" ], [
"Będą wysyłane na adres: {$userMail}. ",
UI::h('a', [
'href' => $this->getLink('generateUserReminders', [
'usrLogin' => $usrLogin,
])
], 'podgląd'),
]);
if (empty($userNotifyList)) {
UI::alert('warning', "Brak zdefiniowanych powiadomień");
} else {
$this__printValue = [$this, 'printValue'];
UI::table([ //
'disable_lp' => true,
'@class' => 'table table-hover',
'cell_padding' => 8,
'rows' => array_map(function ($notify) use ($usrLogin, $this__printValue) {
return [
'rodzaj' => $this__printValue('what', $notify['what']),
'jak często' => $this__printValue('when', $notify['when']),
'utworzony' => $notify['_created'],
'ostatnio uruchomiony' => $notify['last_exec_time'] ? $notify['last_exec_time'] : 'brak danych',
'#' => UI::h('form', [ 'method' => "post", 'class' => "form-inline" ], [
UI::h('input', [ 'type' => "hidden", 'name' => "_subTask", 'value' => "_rm_table_reminder" ]),
UI::h('input', [ 'type' => "hidden", 'name' => "who", 'value' => $usrLogin ]),
UI::h('input', [ 'type' => "hidden", 'name' => "what", 'value' => $notify['what'] ]),
UI::h('input', [ 'type' => "hidden", 'name' => "when", 'value' => $notify['when'] ]),
UI::h('button', [
'class' => "btn btn-link btn-xs",
'onclick' => "return confirm('Czy usunąć powiadomienie?')",
'type' => "submit"
], ''),
]),
];
}, $userNotifyList)
]);
}
?>
Dodaj powiadomienia wysyłane raz dziennie:
Dodaj powiadomienia wysyłane na bieżąco:
';// .container
}
public function printValue($fldName, $argValue) {
if ('what' == $fldName || 'when' == $fldName) {
$valueLabels = $this->getFieldValueLabels($fldName);
return V::get($argValue, $argValue, $valueLabels);
}
return $argValue;
}
public function getAllPrzypomnijTypes() {
$allPrzypomnijTypes = array();
$allPrzypomnijTypes[] = 'msgs';
$allPrzypomnijTypes[] = 'l_app_projekty';
$allPrzypomnijTypes[] = 'l_app_koresp';
$allPrzypomnijTypes[] = 'l_app_zadania';
$allPrzypomnijTypes[] = 'l_app_procesy';
$allPrzypomnijTypes[] = 'l_app_zasoby';
return $allPrzypomnijTypes;
}
public function getFieldValueLabels($fldName, $userNotifyList = null, $when = null) {
$valueLabels = array();
if ('what' == $fldName) {
if (null == $userNotifyList) $userNotifyList = array();
if ('once_a_day' == $when) {
$valueLabels['msgs'] = "wiadomości";
$valueLabels['l_app_projekty'] = "projekty";
$valueLabels['l_app_koresp'] = "korespondencja";
$valueLabels['l_app_zadania'] = "zadania";
$valueLabels['l_app_procesy'] = "procesy";
$valueLabels['l_app_zasoby'] = "zasoby";
$valueLabels['l_app_all_przypomnij'] = "*wszystkie";
if (!empty($userNotifyList)) {// filter out existing notify
foreach ($userNotifyList as $notify) {
if ($when == $notify['when'] && array_key_exists($notify['what'], $valueLabels)) {
unset($valueLabels[$notify['what']]);
}
}
if (1 == count($valueLabels) && !empty($valueLabels['l_app_all_przypomnij'])) {
unset($valueLabels['l_app_all_przypomnij']);
}
}
} else if ('immediately' == $when) {
$valueLabels['msgs'] = "wiadomości";
$valueLabels['l_app_zadania'] = "zadania";
if (!empty($userNotifyList)) {// filter out existing notify
foreach ($userNotifyList as $notify) {
if ($when == $notify['when'] && array_key_exists($notify['what'], $valueLabels)) {
unset($valueLabels[$notify['what']]);
}
}
}
} else {
$valueLabels['msgs'] = "wiadomości";
$valueLabels['l_app_projekty'] = "projekty";
$valueLabels['l_app_koresp'] = "korespondencja";
$valueLabels['l_app_zadania'] = "zadania";
$valueLabels['l_app_procesy'] = "procesy";
$valueLabels['l_app_zasoby'] = "zasoby";
$valueLabels['l_app_all_przypomnij'] = "*wszystkie";
}
} else if ('when' == $fldName) {
$valueLabels['once_a_day'] = "Raz dziennie";
$valueLabels['immediately'] = "Na bieżąco";
}
return $valueLabels;
}
public function getFieldValues($fldName) {
$valueLabels = $this->getFieldValueLabels($fldName);
return array_keys($valueLabels);
}
public function addUserTableReminder($usrLogin, $args) {
$what_values = $this->getFieldValues('what');
$what = V::validate('what', $args, array('type'=>'word', 'not_empty'=>true, 'max_length'=>'255', 'values'=>$what_values));
$when_values = $this->getFieldValues('when');
$when = V::validate('when', $args, array('type'=>'word', 'not_empty'=>true, 'max_length'=>'255', 'values'=>$when_values));
$pdo = DB::getPDO();
if ('l_app_all_przypomnij' == $what) {
$types = $this->getAllPrzypomnijTypes();
$sqlValues = array();
$sqlWho = $pdo->quote($usrLogin, PDO::PARAM_STR);
$sqlWhen = $pdo->quote($when, PDO::PARAM_STR);
foreach ($types as $type) {
$sqlWhat = $pdo->quote($type, PDO::PARAM_STR);
$sqlValues[] = "( {$sqlWho}, {$sqlWhat}, {$sqlWhen}, NOW() )";
}
$sqlValues = implode(", ", $sqlValues);
$pdo->execSql("
insert ignore into `CRM_NOTIFY` (
`who`,
`what`,
`when`,
`_created`
) values {$sqlValues}
");
} else {
$sth = $pdo->prepare("
insert into `CRM_NOTIFY` (
`who`,
`what`,
`when`,
`_created`
) values (
:who,
:what,
:when,
NOW()
)
");
$bindValues = array();
$bindValues['who'] = array($usrLogin, PDO::PARAM_STR);
$bindValues['what'] = array($what, PDO::PARAM_STR);
$bindValues['when'] = array($when, PDO::PARAM_STR);
$pdo->bindValues($sth, $bindValues);
// try {
$sth->execute();
// } catch (PDOException $e) {
// throw new Exception("Błąd bazy danych: " . json_encode($e->errorInfo));
// } catch (Exception $e) {
// throw $e;
// }
}
}
public function getUserNotifyList($usrLogin) {
return DB::getPDO()->fetchAll("
select n.*
from `CRM_NOTIFY` n
where n.`who` = '{$usrLogin}'
");
}
public function getTodoList($limit = 10, $whenTypes = array()) {
$pdo = DB::getPDO();
if (empty($whenTypes)) throw new Exception("when types not set in getTodoList");
{
$sqlWhenFltr = array();
if (in_array('once_a_day', $whenTypes)) {
$sqlWhenFltr[] = "
(
n.`when` = 'once_a_day' and (
n.last_exec_time is null
or DATE(n.last_exec_time) < CURDATE()
)
)
";
}
if (in_array('immediately', $whenTypes)) {
$sqlWhenFltr[] = "( n.`when` = 'immediately' )";
}
if (empty($sqlWhenFltr)) throw new Exception("when types not allowed in getTodoList");
$sqlWhenFltr = "( " . implode(" or ", $sqlWhenFltr) . " )";
}
$sth = $pdo->prepare("
select u.ADM_ACCOUNT
from ADMIN_USERS u
join CRM_NOTIFY n on(n.`who` = u.ADM_ACCOUNT and {$sqlWhenFltr})
where u.A_STATUS = 'NORMAL'
and u.EMPLOYEE_TYPE = 'Pracownik'
and n.`who` is not null
group by u.ADM_ACCOUNT
order by n.last_exec_time asc
limit :limit
");
$sth->bindValue(':limit', $limit, PDO::PARAM_INT);
$sth->execute();
$rawUsers = $sth->fetchAll();
if (empty($rawUsers)) return array();
$sqlUsers = array(); foreach ($rawUsers as $row) { $sqlUsers[] = $pdo->quote($row['ADM_ACCOUNT'], PDO::PARAM_STR); }
$sqlUsers = implode(", ", $sqlUsers);
$sth = $pdo->prepare("
select n.`who`, n.`when`, n.`what`
, UNIX_TIMESTAMP(n.last_exec_time) as last_exec_time
, IF(n.`when` = 'immediately'
, (select UNIX_TIMESTAMP(MAX(i.last_exec_time))
from CRM_NOTIFY i
where i.`who` = n.`who`
and i.`what` = n.`what`
-- and i.`when` = 'once_a_day'
-- limit 1
)
, null
) as _last_exec_time_fix_for_immediately
from CRM_NOTIFY n
where n.`who` in({$sqlUsers})
and {$sqlWhenFltr}
order by n.last_exec_time asc
");
$sth->execute();
$rawReminders = $sth->fetchAll();
$reminders = array();
$timeToday = mktime(0, 0, 0, date('n'), date('j'), date('Y'));
//$timeTomorrow = mktime(0, 0, 0, date('n'), date('j') + 1, date('Y'));
DBG::_('DBG_NTF', '>1', "rawReminders (today:{$timeToday})", $rawReminders, __CLASS__, __FUNCTION__, __LINE__);
foreach ($rawReminders as $row) {
$who = $row['who'];
$when = $row['when'];
$what = $row['what'];
$last_exec_time = $row['last_exec_time'];
$last_exec_time_fix_for_immediately = $row['_last_exec_time_fix_for_immediately'];
if ('once_a_day' == $when) {
if ($last_exec_time >= $timeToday) {
DBG::_('DBG_NTF', '>1', "skip {$last_exec_time} for '{$what}' at '{$when}'", $row, __CLASS__, __FUNCTION__, __LINE__);
continue;
} else {
//DBG::_(true, true, "TODO: else {$last_exec_time} >= {$timeToday}", $row, __CLASS__, __FUNCTION__, __LINE__);
}
} else if ('immediately' == $when) {
//DBG::_(true, true, "TODO: else {$last_exec_time} >= {$timeToday}", $row, __CLASS__, __FUNCTION__, __LINE__);
} else {
DBG::_('DBG_NTF', '>0', "TODO: unimplemented when = '{$when}'", $row, __CLASS__, __FUNCTION__, __LINE__);
continue;
}
$last_date = ($last_exec_time)? date("Y-m-d H:i:s", $last_exec_time) : null;
if (!isset($reminders[$who])) $reminders[$who] = array();
if (!isset($reminders[$who][$when])) $reminders[$who][$when] = array();
$reminders[$who][$when][$what] = $last_date;
if ('immediately' == $when && null !== $last_exec_time_fix_for_immediately && $last_exec_time_fix_for_immediately > $last_exec_time) {
$reminders[$who][$when][$what] = date("Y-m-d H:i:s", $last_exec_time_fix_for_immediately);
}
}
return $reminders;
}
public function reinstallAction() {
try {
$force = ('true' == V::get('_force', '', $_GET));
$this->reinstall($force);
} catch (Exception $e) {
echo'';
echo "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage();
echo'
';
}
die('OK');
}
public function reinstallFunctionsAction() {
$this->reinstallFunctions();
die('OK');
}
public function runAction() {
$msgId = V::get('_msgId', 0, $_REQUEST, 'int');
if ($msgId > 0) {
$this->runByMessageId($msgId);
}
$jsonData = new stdClass();
$jsonData->type = 'success';
$jsonData->msg = 'Gotowe';
echo json_encode($jsonData);
exit;
}
public function reinstallFunctions() {
$sqlList = array();
$db = DB::getDB();
if ($db->has_errors()) {
throw new Exception("DB Errors: " . implode("\n
", $db->get_errors()));
}
foreach ($sqlList as $sqlName => $sql) {
$res = $db->query($sql);
if ($db->has_errors()) {
throw new Exception("DB Errors at sql '{$sqlName}': " . implode("\n
", $db->get_errors()));
}
}
}
public function testReinstallTable() {
$pdo = DB::getPDO();
if(1){// TEST
$expectedStruct = array();
$expectedStruct['who'] = array('type'=>'varchar', 'max_length'=>20, 'is_nullable'=>false);// `who` varchar(20) -- TODO: NOT NULL
$expectedStruct['when'] = array('type'=>'varchar', 'max_length'=>255, 'is_nullable'=>false);// `when` varchar(255) NOT NULL
$expectedStruct['what'] = array('type'=>'varchar', 'max_length'=>255, 'is_nullable'=>false);// `what` varchar(255) NOT NULL
$expectedStruct['last_exec_time'] = array('type'=>'datetime', 'is_nullable'=>true);// `last_exec_time` datetime
$expectedStruct['_created'] = array('type'=>'datetime', 'is_nullable'=>false);// `_created` datetime
$expectedStruct['uniq_key_1'] = array('type'=>'UNIQUE KEY', 'key_fields'=>array('who','when','what'));// UNIQUE KEY `uniq_key_1` (`who`,`when`,`what`)
$expectedStruct['key_who'] = array('type'=>'KEY', 'key_fields'=>array('who'));// KEY `key_who` (`who`)
// $expectedStruct['t1'] = array('type'=>'varchar', 'max_length'=>300, 'default_value'=>null);
// $expectedStruct['t2'] = array('type'=>'int');
// $expectedStruct['t3'] = array('type'=>'int', 'num_precision'=>11, 'default_value'=>null);
// $expectedStruct['t_dec_11_x'] = array('type'=>'decimal', 'num_precision'=>11);
// $expectedStruct['t_dec_11_2'] = array('type'=>'decimal', 'num_precision'=>11, 'num_scale'=>2);
$expectedStruct['t_int'] = array('type'=>'int');
$expectedStruct['t_tinyint'] = array('type'=>'tinyint');
$expectedStruct['t_smallint'] = array('type'=>'smallint');
$expectedStruct['t_mediumint'] = array('type'=>'mediumint');
$expectedStruct['t_bigint'] = array('type'=>'bigint');
$expectedStruct['t_decimal'] = array('type'=>'decimal');
$expectedStruct['t_float'] = array('type'=>'float');
$expectedStruct['t_double'] = array('type'=>'double');
$expectedStruct['t_real'] = array('type'=>'real');
$expectedStruct['t_date'] = array('type'=>'date');
$expectedStruct['t_datetime'] = array('type'=>'datetime');
$expectedStruct['t_timestamp'] = array('type'=>'timestamp');
$expectedStruct['t_time'] = array('type'=>'time');
$expectedStruct['t_year'] = array('type'=>'year');
$expectedStruct['t_char'] = array('type'=>'char');
$expectedStruct['t_varchar'] = array('type'=>'varchar');
$expectedStruct['t_text'] = array('type'=>'text');
$expectedStruct['t_tinytext'] = array('type'=>'tinytext');
$expectedStruct['t_mediumtext'] = array('type'=>'mediumtext');
$expectedStruct['t_longtext'] = array('type'=>'longtext');
$expectedStruct['t_enum'] = array('type'=>'enum', 'values'=>array('v1'));
$expectedStruct['t_set'] = array('type'=>'set', 'values'=>array('v1'));
$expectedStruct['t_bit'] = array('type'=>'bit', 'max_length'=>2);
$expectedStruct['t_boolean'] = array('type'=>'boolean');
$expectedStruct['t_serial'] = array('type'=>'serial');
$expectedStruct['t_binary'] = array('type'=>'binary');
$expectedStruct['t_varbinary'] = array('type'=>'varbinary');
$expectedStruct['t_blob'] = array('type'=>'blob');
$expectedStruct['t_tinyblob'] = array('type'=>'tinyblob');
$expectedStruct['t_mediumblob'] = array('type'=>'mediumblob');
$expectedStruct['t_longblob'] = array('type'=>'longblob');
$expectedStruct['t_geometry'] = array('type'=>'geometry');
$expectedStruct['t_point'] = array('type'=>'point');
$expectedStruct['t_linestring'] = array('type'=>'linestring');
$expectedStruct['t_polygon'] = array('type'=>'polygon');
$expectedStruct['t_multipoint'] = array('type'=>'multipoint');
$expectedStruct['t_multilinestring'] = array('type'=>'multilinestring');
$expectedStruct['t_multipolygon'] = array('type'=>'multipolygon');
$expectedStruct['t_geometrycollection'] = array('type'=>'geometrycollection');
$sqlCreate = $pdo->showCreateStruct('_test_table', $expectedStruct, array('char_encoding'=>'latin2'));
DBG::_(true, true, "fixedEpectedStruct", $sqlCreate, __CLASS__, __FUNCTION__, __LINE__);
$pdo->assertTableStruct('_test_table', $expectedStruct, array('char_encoding'=>'latin2'));
{// force - drop/create
$pdo->exec("DROP TABLE IF EXISTS _test_table");
$pdo->exec($sqlCreate);
}
}
if(0){// TEST nulls
$sth = $pdo->prepare("DROP TABLE IF EXISTS CRM_NOTIFY");
$sth->execute();
$sth = $pdo->prepare("
CREATE TABLE IF NOT EXISTS CRM_NOTIFY (
`who` varchar(20)
, `when` varchar(255) NOT NULL
, `what` varchar(255) DEFAULT ''
, `t1` varchar(255) NOT NULL -- same as with DEFAULT ''
, `t2` varchar(255) NOT NULL DEFAULT ''
, `t2z` varchar(255) NOT NULL DEFAULT '0'
-- , `t3` varchar(255) NOT NULL DEFAULT NULL -- SQLSTATE[42000]: Syntax error or access violation: 1067 Invalid default value
, `t4` varchar(255) NULL -- same as with DEFAULT NULL
, `t5` varchar(255) NULL DEFAULT ''
, `t6` varchar(255) NULL DEFAULT NULL
, `i1` int(11) NOT NULL -- same as with DEFAULT 0
, `i2` int(11) NOT NULL DEFAULT 0
-- , `i3` int(11) NOT NULL DEFAULT NULL -- SQLSTATE[42000]: Syntax error or access violation: 1067 Invalid default value
, `i4` int(11) NULL -- same as with DEFAULT NULL
, `i5` int(11) NULL DEFAULT 0
, `i6` int(11) NULL DEFAULT NULL
, `last_exec_time` datetime DEFAULT NULL
, KEY `who` (`who`)
) ENGINE=MyISAM DEFAULT CHARSET=latin2
");
$sth->execute();
$sth = $pdo->prepare("insert into CRM_NOTIFY (`last_exec_time`) values (NULL)");
$sth->execute();
// INSERT INTO CRM_NOTIFY (t1, t2, t2z, t4, t5, t6, i1, i2, i4, i5, i6, last_exec_time)
// VALUES ('', '', '0', NULL, '', NULL, 0, 0, NULL, 0, NULL, NULL);
$struct = $pdo->getTableStruct('CRM_NOTIFY');
DBG::_(true, true, "struct", $struct, __CLASS__, __FUNCTION__, __LINE__);
DBG::_(true, true, "`t2`: is_null(struct[4]['Default'])=(".is_null($struct[4]['Default']).")", null, __CLASS__, __FUNCTION__, __LINE__);
DBG::_(true, true, "`t4`: is_null(struct[6]['Default'])=(".is_null($struct[6]['Default']).")", null, __CLASS__, __FUNCTION__, __LINE__);
DBG::_(true, true, "`t5`: is_null(struct[7]['Default'])=(".is_null($struct[7]['Default']).")", null, __CLASS__, __FUNCTION__, __LINE__);
DBG::_(true, true, "`t6`: is_null(struct[8]['Default'])=(".is_null($struct[8]['Default']).")", null, __CLASS__, __FUNCTION__, __LINE__);
$expectedStruct = array();
$expectedStruct['t1'] = array('type'=>'varchar', 'max_length'=>300, 'default_value'=>null);
//$expectedStruct['t2'] = array('type'=>'int', 'num_precision'=>11, 'default_value'=>null);
$pdo->assertTableStruct('CRM_NOTIFY', $expectedStruct);
}
}
public function reinstall($force = false) {
$sqlList = array();
$pdo = DB::getPDO();
$sqlCreate = "
CREATE TABLE IF NOT EXISTS CRM_NOTIFY (
`who` varchar(20) NOT NULL
, `when` varchar(255) NOT NULL
, `what` varchar(255) NOT NULL
, `last_exec_time` datetime DEFAULT NULL
, `_created` datetime NOT NULL
, UNIQUE KEY `uniq_key_1` (`who`,`when`,`what`)
, KEY `key_who` (`who`)
) ENGINE=MyISAM DEFAULT CHARSET=latin2
";
/*
`CRM_NOTIFY`:
- who - user login
- when - shedule (once a day, once on houd)
- what - action type
- last_exec_time
*/
if ($force) $pdo->exec("DROP TABLE IF EXISTS CRM_NOTIFY");
$pdo->exec($sqlCreate);
if(0){// TODO: assertTableStruct CRM_NOTIFY
$expectedStruct = array();
$expectedStruct['who'] = array('type'=>'varchar', 'max_length'=>20, 'is_nullable'=>false);// `who` varchar(20) -- TODO: NOT NULL
$expectedStruct['when'] = array('type'=>'varchar', 'max_length'=>255, 'is_nullable'=>false);// `when` varchar(255) NOT NULL
$expectedStruct['what'] = array('type'=>'varchar', 'max_length'=>255, 'is_nullable'=>false);// `what` varchar(255) NOT NULL
$expectedStruct['last_exec_time'] = array('type'=>'datetime', 'is_nullable'=>true);// `last_exec_time` datetime
$expectedStruct['_created'] = array('type'=>'datetime', 'is_nullable'=>false);// `_created` datetime
$expectedStruct['uniq_key_1'] = array('type'=>'UNIQUE KEY', 'key_fields'=>array('who','when','what'));// UNIQUE KEY `uniq_key_1` (`who`,`when`,`what`)
$expectedStruct['key_who'] = array('type'=>'KEY', 'key_fields'=>array('who'));// KEY `key_who` (`who`)
DBG::_(true, true, "sqlCreate - raw", $sqlCreate, __CLASS__, __FUNCTION__, __LINE__);
$sqlCreate = $pdo->showCreateStruct('CRM_NOTIFY', $expectedStruct, array('char_encoding'=>'latin2'));
DBG::_(true, true, "sqlCreate - generated", $sqlCreate, __CLASS__, __FUNCTION__, __LINE__);
$pdo->assertTableStruct('CRM_NOTIFY', $expectedStruct, array('char_encoding'=>'latin2'));
if(0){// force - drop/create
$pdo->exec("DROP TABLE IF EXISTS CRM_NOTIFY");
$pdo->exec($sqlCreate);
}
}
{// assertTableStruct CRM_NOTIFY_EXEC_LOG
// TODO: create table CRM_NOTIFY_EXEC_LOG with action log
}
//$this->reinstallFunctions();
}
}