getArray('pm_prefs'); $pm_prefs = e107::getPlugPref('pm'); //pm_prefs record not found in core table, set to defaults and create record /* if(!is_array($pm_prefs)) { require_once(e_PLUGIN.'pm/pm_default.php'); $pm_prefs = pm_set_default_prefs(); // Use the default settings $sysprefs->setArray('pm_prefs'); $emessage->add(ADLAN_PM_3, E_MESSAGE_INFO); $e107->admin_log->log_event('PM_ADM_01', ''); } */ // Couple of bits of BC/upgrade /* $savePMP = FALSE; if (isset($pref['pm_limits'])) { if (!isset($pm_prefs['pm_limits'])) { $pm_prefs['pm_limits'] = $pref['pm_limits']; $savePMP = TRUE; } unset($pref['pm_limits']); save_prefs(); } if (isset($pm_prefs['allow_userclass'])) { if (!isset($pm_prefs['opt_userclass'])) { $pm_prefs['opt_userclass'] = e_UC_NOBODY; if ($pm_prefs['allow_userclass']) { $pm_prefs['opt_userclass'] = e_UC_MEMBERS; } } unset($pm_prefs['allow_userclass']); $savePMP = TRUE; } if ($savePMP) { // $sysprefs->setArray('pm_prefs'); // $emessage->add(ADLAN_PM_80, E_MESSAGE_SUCCESS); } */ //include_lan(e_PLUGIN.'pm/languages/admin/'.e_LANGUAGE.'.php'); if (isset($_POST['update_prefs'])) { $temp = array(); foreach($_POST as $k => $v) { if (strpos($k, 'pm_option-') === 0) { $k = str_replace('pm_option-','',$k); $temp[$k] = $v; } } if (e107::getLog()->logArrayDiffs($temp, $pm_prefs, 'PM_ADM_02')) { // $sysprefs->setArray('pm_prefs'); //print_a($temp); e107::getPlugConfig('pm')->setPref($temp)->save(); } else { $mes->addInfo(LAN_NO_CHANGE); } } // Mantenance options if (isset($_POST['pm_maint_execute'])) { $maintOpts = array(); if (vartrue($_POST['pm_maint_sent'])) { $maintOpts['sent'] = 1; } if (vartrue($_POST['pm_maint_rec'])) { $maintOpts['rec'] = 1; } if (vartrue($_POST['pm_maint_blocked'])) { $maintOpts['blocked'] = 1; } if (vartrue($_POST['pm_maint_expired'])) { $maintOpts['expired'] = 1; } if (vartrue($_POST['pm_maint_attach'])) { $maintOpts['attach'] = 1; } $result = doMaint($maintOpts, $pm_prefs); if (is_array($result)) { foreach ($result as $k => $ma) { foreach ($ma as $m) { $mes->add($m, $k); } } } } if(isset($_POST['addlimit'])) { $id = intval($_POST['newlimit_class']); if($sql->db_Select('generic','gen_id',"gen_type = 'pm_limit' AND gen_datestamp = ".$id)) { $mes->addInfo(ADLAN_PM_5); // 'Limit for selected user class already exists' } else { $limArray = array( // Strange field names because we use the 'generic' table. But at least it documents the correlation 'gen_type' => 'pm_limit', 'gen_datestamp' => intval($_POST['newlimit_class']), 'gen_user_id' => intval($_POST['new_inbox_count']), 'gen_ip' => intval($_POST['new_outbox_count']), 'gen_intdata' => intval($_POST['new_inbox_size']), 'gen_chardata' => intval($_POST['new_outbox_size']) ); if($sql->insert('generic', $limArray)) { e107::getLog()->logArrayAll('PM_ADM_05', $limArray); $mes->addSuccess(ADLAN_PM_6); } else { e107::getLog()->log_event('PM_ADM_08', ''); $mes->addError(ADLAN_PM_7); } } } if(isset($_POST['updatelimits'])) { $limitVal = intval($_POST['pm_limits']); if($pm_prefs['pm_limits'] != $limitVal) { $pm_prefs['pm_limits'] = $limitVal; //$sysprefs->setArray('pm_prefs'); $mes->addSuccess(ADLAN_PM_8); } foreach(array_keys($_POST['inbox_count']) as $id) { $id = intval($id); if($_POST['inbox_count'][$id] == '' && $_POST['outbox_count'][$id] == '' && $_POST['inbox_size'][$id] == '' && $_POST['outbox_size'][$id] == '') { //All entries empty - Remove record if($sql->delete('generic','gen_id = '.$id)) { e107::getLog()->log_event('PM_ADM_07', 'ID: '.$id); $mes->addSuccess($id.ADLAN_PM_9); } else { e107::getLog()->log_event('PM_ADM_10', ''); $mes->addError($id.ADLAN_PM_10); } } else { $limArray = array( // Strange field names because we use the 'generic' table. But at least it documents the correlation 'gen_user_id' => intval($_POST['inbox_count'][$id]), 'gen_ip' => intval($_POST['outbox_count'][$id]), 'gen_intdata' => intval($_POST['inbox_size'][$id]), 'gen_chardata' => intval($_POST['outbox_size'][$id]) ); if ($sql->update('generic',array('data' => $limArray, 'WHERE' => 'gen_id = '.$id))) { e107::getLog()->logArrayAll('PM_ADM_06', $limArray); $mes->addSuccess($id.ADLAN_PM_11); } else { e107::getLog()->log_event('PM_ADM_09', ''); $mes->addError($id.ADLAN_PM_7); } } } } $ns->tablerender($caption, $mes->render() . $text); switch ($action) { case 'main' : $ns->tablerender(ADLAN_PM_12, show_options($pm_prefs)); break; case 'limits' : $ns->tablerender(ADLAN_PM_14, show_limits($pm_prefs)); $ns->tablerender(ADLAN_PM_15, add_limit($pm_prefs)); break; case 'maint' : $ns->tablerender(ADLAN_PM_60, show_maint($pm_prefs)); break; } require_once(e_ADMIN.'footer.php'); function show_options($pm_prefs) { $frm = e107::getForm(); $txt = "
$txt .= "
".ADLAN_PM_16." ".$frm->text('pm_option-title', $pm_prefs['title'], '50')."
".ADLAN_PM_23." ".e107::getUserClass()->uc_dropdown('pm_option-pm_class', $pm_prefs['pm_class'], 'member,admin,classes')."
".ADLAN_PM_29." ".e107::getUserClass()->uc_dropdown('pm_option-sendall_class', $pm_prefs['sendall_class'], 'nobody,member,admin,classes')."
".ADLAN_PM_88." "; $list = e107::getUserClass()->getClassList('nobody,main,admin,member,classes'); $list['matchclass'] = ADLAN_PM_89; //$txt .= print_a($list,true); $txt .= $frm->select('pm_option-send_to_class', $list, varset($pm_prefs['send_to_class'], e_UC_MEMBER)); //$text .= ".e107::getUserClass()->uc_dropdown('pm_option-sendall_class', $pm_prefs['sendall_class'], 'nobody,member,admin,classes')."
".ADLAN_PM_17." ".$frm->radio_switch('pm_option-animate', $pm_prefs['animate'], LAN_YES, LAN_NO)."
".ADLAN_PM_18." ".$frm->radio_switch('pm_option-dropdown', $pm_prefs['dropdown'], LAN_YES, LAN_NO)."
".ADLAN_PM_19." ".$frm->text('pm_option-read_timeout', $pm_prefs['read_timeout'], '5', array('class' => 'tbox input-text'))."
".ADLAN_PM_20." ".$frm->text('pm_option-unread_timeout', $pm_prefs['unread_timeout'], '5', array('class' => 'tbox input-text'))."
".ADLAN_PM_21." ".$frm->radio_switch('pm_option-popup', $pm_prefs['popup'], LAN_YES, LAN_NO)."
".ADLAN_PM_22." ".$frm->text('pm_option-popup_delay', $pm_prefs['popup_delay'], '5', array('class' => 'tbox input-text'))." ".ADLAN_PM_44."
".ADLAN_PM_24." ".$frm->text('pm_option-perpage', $pm_prefs['perpage'], '5', array('class' => 'tbox input-text'))."
".ADLAN_PM_25." ".e107::getUserClass()->uc_dropdown('pm_option-notify_class', $pm_prefs['notify_class'], 'nobody,member,admin,classes')."
".ADLAN_PM_26." ".e107::getUserClass()->uc_dropdown('pm_option-receipt_class', $pm_prefs['receipt_class'], 'nobody,member,admin,classes')."
".ADLAN_PM_27." ".e107::getUserClass()->uc_dropdown('pm_option-attach_class', $pm_prefs['attach_class'], 'nobody,member,admin,classes')."
".ADLAN_PM_28." ".$frm->text('pm_option-attach_size', $pm_prefs['attach_size'], '8', array('class' => 'tbox input-text'))." kB
".ADLAN_PM_30." ".e107::getUserClass()->uc_dropdown('pm_option-multi_class', $pm_prefs['multi_class'], 'nobody,member,admin,classes')."
".ADLAN_PM_31." ".e107::getUserClass()->uc_dropdown('pm_option-opt_userclass', $pm_prefs['opt_userclass'], 'nobody,member,admin,classes')."
".ADLAN_PM_81." ".$frm->text('pm_option-v', $pm_prefs['pm_max_send'], '5', array('class' => 'tbox input-text'))."".ADLAN_PM_82."
".$frm->admin_button('update_prefs','no-value','update', LAN_UPDATE)."
"; return $txt; } function show_limits($pm_prefs) { $sql = e107::getDb(); $frm = e107::getForm(); if (!isset($pm_prefs['pm_limits'])) { $pm_prefs['pm_limits'] = 0; } if($sql->db_Select('generic', "gen_id as limit_id, gen_datestamp as limit_classnum, gen_user_id as inbox_count, gen_ip as outbox_count, gen_intdata as inbox_size, gen_chardata as outbox_size", "gen_type = 'pm_limit'")) { while($row = $sql->db_Fetch()) { $limitList[$row['limit_classnum']] = $row; } } $txt = "
"; if (isset($limitList)) { foreach($limitList as $row) { $txt .= " "; } } else { $txt .= " "; } $txt .= '
".LAN_USERCLASS." ".ADLAN_PM_37." ".ADLAN_PM_38."
".ADLAN_PM_45." \n"; $txt .= '  '.ADLAN_PM_77."
".e107::getUserClass()->uc_get_classname($row['limit_classnum'])." ".LAN_PLUGIN_PM_INBOX.":
".LAN_PLUGIN_PM_OUTBOX.": 		".LAN_PLUGIN_PM_INBOX.":
".LAN_PLUGIN_PM_OUTBOX.":
".ADLAN_PM_41."
'.$frm->admin_button('updatelimits','no-value','update', LAN_UPDATE).'
'; return $txt; } function add_limit($pm_prefs) { $sql = e107::getDb(); $frm = e107::getForm(); if($sql->db_Select('generic', "gen_id as limit_id, gen_datestamp as limit_classnum, gen_user_id as inbox_count, gen_ip as outbox_count, gen_intdata as inbox_size, gen_chardata as outbox_size", "gen_type = 'pm_limit'")) { while($row = $sql->db_Fetch()) { $limitList[$row['limit_classnum']] = $row; } } $txt = "
"; $txt .= " "; $txt .= '
".LAN_USERCLASS." ".ADLAN_PM_37." ".ADLAN_PM_38."
".e107::getUserClass()->uc_dropdown('newlimit_class', 0, 'guest,member,admin,classes')." ".LAN_PLUGIN_PM_INBOX.":
".LAN_PLUGIN_PM_OUTBOX.": 		".LAN_PLUGIN_PM_INBOX.":
".LAN_PLUGIN_PM_OUTBOX.":
'.$frm->admin_button('addlimit','no-value','update', LAN_ADD).'
'; return $txt; } function show_maint($pmPrefs) { $frm = e107::getForm(); $txt = "
".ADLAN_PM_62."
"; if ($pmPrefs['read_timeout'] || $pmPrefs['unread_timeout']) { $txt .= " "; } $txt .= "
".ADLAN_PM_63." ".$frm->radio_switch('pm_maint_sent', '', LAN_YES, LAN_NO)."
".ADLAN_PM_64." ".$frm->radio_switch('pm_maint_rec', '', LAN_YES, LAN_NO)."
".ADLAN_PM_65." ".$frm->radio_switch('pm_maint_blocked', '', LAN_YES, LAN_NO)."
".ADLAN_PM_71." ".$frm->radio_switch('pm_maint_expired', '', LAN_YES, LAN_NO)."
".ADLAN_PM_78." ".$frm->radio_switch('pm_maint_attach', '', LAN_YES, LAN_NO)."
".$frm->admin_button('pm_maint_execute','no-value','delete', LAN_GO)."
"; return $txt; } /** * Turn the array produced by doMaint for message display into an array of log strings. * Data is sorted into time stamp order * * @param array $results - array of arrays as returned from doMaint() * @param array|boolean $extra - optional additional information which is sorted into the main result according to keys - so use low numbers * to make the entry appear at the beginning, and text strings to add to the end. */ function makeLogEntry($results, $extra = FALSE) { $logPrefixes = array(E_MESSAGE_SUCCESS => 'Pass - ', E_MESSAGE_ERROR => 'Fail - ', E_MESSAGE_INFO => 'Info - ', E_MESSAGE_DEBUG => 'Debug - '); $res = array(); foreach ($results as $k => $ma) { foreach ($ma as $ts => $m) { $res[$ts] = $logPrefixes[$k].$m; } } if (is_array($extra)) { $res = array_merge($res, $extra); } ksort($res); // Sort in ascending order of timestamp return $res; } /** * Do PM DB maintenance * @param array $opts of tasks key = sent|rec|blocked|expired (one or more present). ATM value not used * @return array where key is message type (E_MESSAGE_SUCCESS|E_MESSAGE_ERROR|E_MESSAGE_INFO etc), data is array of messages of that type (key = timestamp) */ function doMaint($opts, $pmPrefs) { if (!count($opts)) { return array(E_MESSAGE_ERROR => array(ADLAN_PM_66)); } $results = array(E_MESSAGE_INFO => array(ADLAN_PM_67)); // 'Maintenance started' - primarily for a log entry to mark start time $logResults = array(); $e107 = e107::getInstance(); $e107->admin_log->log_event('PM_ADM_04', implode(', ',array_keys($opts))); $pmHandler = new private_message($pmPrefs); $db2 = new db(); // Will usually need a second DB object to avoid over load $start = 0; // Use to ensure we get different log times if (isset($opts['sent'])) // Want pm_from = deleted user and pm_read_del = 1 { $cnt = 0; if ($res = $db2->gen("SELECT pm.pm_id FROM `#private_msg` AS pm LEFT JOIN `#user` AS u ON pm.`pm_from` = `#user`.`user_id` WHERE (pm.`pm_read_del = 1) AND `#user`.`user_id` IS NULL")) { while ($row = $db2->fetch()) { if ($pmHandler->del($row['pm_id']) !== FALSE) { $cnt++; } } } $start = time(); $results[E_MESSAGE_SUCCESS][$start] = str_replace('[x]', $cnt, ADLAN_PM_74); } if (isset($opts['rec'])) // Want pm_to = deleted user and pm_sent_del = 1 { $cnt = 0; if ($res = $db2->gen("SELECT pm.pm_id FROM `#private_msg` AS pm LEFT JOIN `#user` AS u ON pm.`pm_to` = `#user`.`user_id` WHERE (pm.`pm_sent_del = 1) AND `#user`.`user_id` IS NULL")) { while ($row = $db2->fetch()) { if ($pmHandler->del($row['pm_id']) !== FALSE) { $cnt++; } } } $start = max($start + 1, time()); $results[E_MESSAGE_SUCCESS][$start] = str_replace('[x]', $cnt, ADLAN_PM_75); } if (isset($opts['blocked'])) { if ($res = $db2->gen("DELETE `#private_msg_block` FROM `#private_msg_block` LEFT JOIN `#user` ON `#private_msg_block`.`pm_block_from` = `#user`.`user_id` WHERE `#user`.`user_id` IS NULL")) { $start = max($start + 1, time()); $results[E_MESSAGE_ERROR][$start] = str_replace(array('[y]', '[z]'), array($this->sql->getLastErrorNum, $this->sql->getLastErrorText), ADLAN_PM_70); } else { $start = max($start + 1, time()); $results[E_MESSAGE_SUCCESS][$start] = str_replace('[x]', $res, ADLAN_PM_69); } if ($res = $db2->gen("DELETE `#private_msg_block` FROM `#private_msg_block` LEFT JOIN `#user` ON `#private_msg_block`.`pm_block_to` = `#user`.`user_id` WHERE `#user`.`user_id` IS NULL")) { $start = max($start + 1, time()); $results[E_MESSAGE_ERROR][$start] = str_replace(array('[y]', '[z]'), array($this->sql->getLastErrorNum, $this->sql->getLastErrorText), ADLAN_PM_70); } else { $start = max($start + 1, time()); $results[E_MESSAGE_SUCCESS][$start] = str_replace('[x]', $res, ADLAN_PM_68); } } if (isset($opts['expired'])) { $del_qry = array(); $read_timeout = intval($pmPrefs['read_timeout']); $unread_timeout = intval($pmPrefs['unread_timeout']); if($read_timeout > 0) { $timeout = time()-($read_timeout * 86400); $del_qry[] = "(pm_sent < {$timeout} AND pm_read > 0)"; } if($unread_timeout > 0) { $timeout = time()-($unread_timeout * 86400); $del_qry[] = "(pm_sent < {$timeout} AND pm_read = 0)"; } if(count($del_qry) > 0) { $qry = implode(' OR ', $del_qry); $cnt = 0; if($db2->db_Select('private_msg', 'pm_id', $qry)) { while ($row = $db2->db_Fetch()) { if ($pmHandler->del($row['pm_id']) !== FALSE) { $cnt++; } } } $start = max($start + 1, time()); $results[E_MESSAGE_SUCCESS][$start] = str_replace('[x]', $cnt, ADLAN_PM_73); } else { $start = max($start + 1, time()); $results[E_MESSAGE_ERROR][$start] = ADLAN_PM_72; } } if (isset($opts['attach'])) { // Check for orphaned and missing attachments require_once(e_HANDLER.'file_class.php'); $fl = new e_file(); $missing = array(); $orphans = array(); $fileArray = $fl->get_files(e_PLUGIN.'pm/attachments'); if ($db2->select('private_msg', 'pm_id, pm_attachments', "pm_attachments != ''")) { while ($row = $db2->fetch()) { $attachList = explode(chr(0), $row['pm_attachments']); foreach ($attachList as $a) { $found = FALSE; foreach ($fileArray as $k => $fd) { if ($fd['fname'] == $a) { $found = TRUE; unset($fileArray[$k]); break; } } if (!$found) { $missing[] = $row['pm_id'].':'.$a; } } } } // Any files left in $fileArray now are unused if (count($fileArray)) { foreach ($fileArray as $k => $fd) { unlink($fd['path'].$fd['fname']); $orphans[] = $fd['fname']; } } $attachMessage = str_replace(array('[x]', '[y]'), array(count($orphans), count($missing)), ADLAN_PM_79); if (TRUE) { // Mostly for testing - probably disable this if (count($orphans)) { $attachMessage .= '[!br!]Orphans:[!br!]'.implode('[!br!]', $orphans); } if (count($missing)) { $attachMessage .= '[!br!]Missing:[!br!]'.implode('[!br!]', $missing); } } $start = max($start + 1, time()); $results[E_MESSAGE_SUCCESS][$start] = $attachMessage; } $e107->admin_log->logArrayAll('PM_ADM_03',makeLogEntry($results)); foreach ($results as $k => $r) { foreach ($r as $sk => $s) { $results[$k][$sk] = str_replace('[!br!]','
',$s); } } return $results; } function pm_conf_adminmenu() { global $action; if ($action == '') { $action = 'main'; } $var['main']['text'] = ADLAN_PM_54; $var['main']['link'] = e_SELF; $var['limits']['text'] = ADLAN_PM_55; $var['limits']['link'] = e_SELF.'?limits'; $var['maint']['text'] = ADLAN_PM_59; $var['maint']['link'] = e_SELF.'?maint'; show_admin_menu(ADLAN_PM_12, $action, $var); } ?>