mirror of
https://bitbucket.org/jsuto/piler.git
synced 2024-11-08 00:21:59 +01:00
239 lines
8.0 KiB
PHP
239 lines
8.0 KiB
PHP
<?php
|
|
|
|
class ModelAccountingAccounting extends Model {
|
|
|
|
public function run_counters($start=NULL, $stop = NULL, $column = 'arrived') {
|
|
$now = time();
|
|
$counter = array();
|
|
$data = array(
|
|
'starttimestamp' => 0,
|
|
'stoptimestamp' => 0,
|
|
'addedstats' => 0,
|
|
'deletedstats' => 0
|
|
);
|
|
|
|
if(!in_array($column, array('sent', 'arrived'))) { return $data; }
|
|
|
|
if(!is_null($start)) {
|
|
$start = $this->__decodeDate($start);
|
|
} else {
|
|
//if we got nothing, then operate on today
|
|
$start = $this->__decodeDate("00:00:00");
|
|
}
|
|
|
|
if(!is_null($stop)) {
|
|
$stop = $this->__decodeDate($stop);
|
|
} else {
|
|
//if we got nothing, then operate on today
|
|
$stop = $this->__decodeDate("00:00:00");
|
|
}
|
|
$stop += 86400;
|
|
|
|
|
|
$data['starttimestamp'] = $start;
|
|
$data['stoptimestamp'] = $stop;
|
|
|
|
|
|
// emails sent to users
|
|
|
|
$tousers = $this->db->query("SELECT `$column`-(`$column` % 86400) AS `day`, `to`, COUNT(*) AS `count`, SUM(`size`) AS `size` FROM " . VIEW_MESSAGES . " WHERE deleted=0 AND `$column` >= ? AND `$column` < ? GROUP BY FROM_UNIXTIME(`day`, '%Y.%m.%d.'), `to`", array($start, $stop));
|
|
|
|
foreach($tousers->rows as $row) {
|
|
$counter[$row['day']][$row['to']]['recd'] = $row['count'];
|
|
$counter[$row['day']][$row['to']]['sizerecd'] = $row['size'];
|
|
}
|
|
|
|
|
|
// emails sent from users
|
|
|
|
$fromusers = $this->db->query("SELECT `$column`-(`$column` % 86400) AS `day`, `from`, COUNT(*) AS `count`, SUM(`size`) AS `size` FROM " . VIEW_MESSAGES . " WHERE deleted=0 AND `$column` >= ? AND `$column` < ? GROUP BY FROM_UNIXTIME(`day`, '%Y.%m.%d.'), `from`", array($start, $stop));
|
|
|
|
foreach($fromusers->rows as $row) {
|
|
$counter[$row['day']][$row['from']]['sent'] = $row['count'];
|
|
$counter[$row['day']][$row['from']]['sizesent'] = $row['size'];
|
|
}
|
|
|
|
|
|
$accepteddomains = array_flip($this->model_domain_domain->get_mapped_domains());
|
|
|
|
foreach($counter as $date => $users) {
|
|
|
|
// execute queries to update the users and domains counter table
|
|
$deletestats = $this->db->query("DELETE FROM " . TABLE_STAT_COUNTER . " WHERE `date` = ?", array($date));
|
|
$data['deletedstats'] += $this->db->countAffected();
|
|
|
|
foreach($users as $username => $userdata) {
|
|
|
|
$sent = isset($userdata['sent']) ? $userdata['sent'] : 0;
|
|
$recd = isset($userdata['recd']) ? $userdata['recd'] : 0;
|
|
$sizesent = isset($userdata['sizesent']) ? $userdata['sizesent'] : 0;
|
|
$sizerecd = isset($userdata['sizerecd']) ? $userdata['sizerecd'] : 0;
|
|
|
|
$parts = explode('@', $username);
|
|
|
|
if(isset($parts[1]) && isset($accepteddomains[ $parts[1] ])) {
|
|
$addusers = $this->db->query("INSERT INTO " . TABLE_STAT_COUNTER . " (`date`,`email`,`domain`,`sent`,`recd`,`sentsize`,`recdsize`) VALUES(?,?,?,?,?,?,?)", array($date, $username, $parts[1], $sent, $recd, $sizesent, $sizerecd));
|
|
$data['addedstats'] += $this->db->countAffected();
|
|
}
|
|
}
|
|
}
|
|
|
|
if(LOG_LEVEL >= NORMAL) { syslog(LOG_INFO, sprintf("processed %s to %s: %d records deleted, %d records added", date(DATE_TEMPLATE, $data['starttimestamp']), date(DATE_TEMPLATE, $data['stoptimestamp']), $data['deletedstats'], $data['addedstats'])); }
|
|
|
|
return $data;
|
|
}
|
|
|
|
|
|
public function get_accounting($item='email', $search='', $page=0, $pagelen=0, $sort='item', $order=0) {
|
|
$_order = 0;
|
|
$_order = "";
|
|
$limit = "";
|
|
|
|
if(!in_array($item, ['email', 'domain'])) { return []; }
|
|
|
|
$domains = $this->__getDomains();
|
|
|
|
$search = preg_replace("/\s{1,}/", "", $search);
|
|
|
|
$arr = array();
|
|
|
|
if($item == 'email') {
|
|
$query = "SELECT `email` AS `item`,MIN(`date`) as `oldest`,MAX(`date`) as `newest`,sum(`sent`) as `sent`,sum(`recd`) as `recd`,SUM(`sentsize`) as `sentsize`,AVG(`sentsize`) as `sentavg`,SUM(`recdsize`) as `recdsize`,AVG(`recdsize`) as `recdavg` FROM " . TABLE_STAT_COUNTER;
|
|
|
|
$q1 = get_q_string($this->__getEmails());
|
|
$q2 = get_q_string($domains);
|
|
|
|
$where = "WHERE ( `email` IN ($q1) OR `domain` IN ($q2) )";
|
|
$arr = array_merge($arr, $this->__getEmails(), $domains);
|
|
|
|
if($search) {
|
|
$where .= " AND (`email` LIKE ? OR `domain` LIKE ?)";
|
|
array_push($arr, "%$search%", "%$search%");
|
|
}
|
|
|
|
} elseif ($item == 'domain') {
|
|
$query = "SELECT `domain` AS `item`,MIN(`date`) as `oldest`,MAX(`date`) as `newest`,sum(`sent`) as `sent`,sum(`recd`) as `recd`,SUM(`sentsize`) as `sentsize`,AVG(`sentsize`) as `sentavg`,SUM(`recdsize`) as `recdsize`,AVG(`recdsize`) as `recdavg` FROM " . TABLE_STAT_COUNTER;
|
|
|
|
$q = get_q_string($domains);
|
|
$where = "WHERE ( `domain` IN ($q) )";
|
|
|
|
$arr = array_merge($arr, $domains);
|
|
|
|
if($search) {
|
|
$where .= " AND `domain` LIKE ?";
|
|
array_push($arr, "%$search%");
|
|
}
|
|
} else {
|
|
return false;
|
|
}
|
|
|
|
if($order == 0) { $order = "ASC"; }
|
|
else { $order = "DESC"; }
|
|
|
|
$_order = "ORDER BY `$sort` $order";
|
|
|
|
$from = (int)$page * (int)$pagelen;
|
|
|
|
if($pagelen > 0) { $limit = " LIMIT " . (int)$from . ", " . (int)$pagelen; }
|
|
|
|
$query = $this->db->query("$query $where GROUP BY `$item` ORDER BY `$sort` $order $limit", $arr);
|
|
|
|
if($query->num_rows >= 1) {
|
|
return $query->rows;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
|
|
public function count_accounting($item='email', $search='') {
|
|
if(!in_array($item, ['email', 'domain'])) { return []; }
|
|
|
|
$domains = $this->__getDomains();
|
|
|
|
$search = preg_replace("/\s{1,}/", "", $search);
|
|
|
|
$query = "SELECT `email` AS `item`, MIN(`date`) AS `oldest`, MAX(`date`) AS `newest`, SUM(`sent`) AS `sent`, SUM(`recd`) AS `recd`, SUM(`sentsize`) AS `sentsize`, SUM(`recdsize`) AS `recdsize` FROM " . TABLE_STAT_COUNTER;
|
|
|
|
$arr = array();
|
|
|
|
if($item == 'email') {
|
|
$q1 = get_q_string($this->__getEmails());
|
|
$q2 = get_q_string($domains);
|
|
|
|
$where = "WHERE (`email` IN ($q1) OR `domain` IN ($q2))";
|
|
$arr = array_merge($arr, $this->__getEmails(), $domains);
|
|
|
|
if($search) {
|
|
$where .= " AND (`email` LIKE ? OR `domain` LIKE ?)";
|
|
array_push($arr, "%$search%", "%$search%");
|
|
}
|
|
} elseif ($item == 'domain') {
|
|
$where = sprintf("WHERE `domain` IN ('%s')", implode("','", $domains));
|
|
if($search) {
|
|
$where .= " AND `domain` LIKE ?";
|
|
array_push($arr, "%$search%");
|
|
}
|
|
}
|
|
|
|
$query = $this->db->query("$query $where GROUP BY `$item`", $arr);
|
|
|
|
return $query->num_rows;
|
|
}
|
|
|
|
|
|
private function __getEmails() {
|
|
$emails = array();
|
|
$session = Registry::get('session');
|
|
|
|
array_push($emails, $session->get("email"));
|
|
$__emails = $session->get("emails");
|
|
|
|
foreach ($__emails as $e) {
|
|
array_push($emails, $e);
|
|
}
|
|
|
|
return $emails;
|
|
}
|
|
|
|
|
|
private function __getDomains() {
|
|
$domains = array();
|
|
$session = Registry::get('session');
|
|
|
|
if(Registry::get('admin_user') >= 1) {
|
|
$domains = $this->model_domain_domain->get_mapped_domains();
|
|
}
|
|
elseif(Registry::get('auditor_user') == 1) {
|
|
array_push($domains, $session->get("domain"));
|
|
$auditdomains = $session->get("auditdomains");
|
|
|
|
foreach ($auditdomains as $d) {
|
|
array_push($domains, $d);
|
|
}
|
|
}
|
|
|
|
return $domains;
|
|
}
|
|
|
|
|
|
private function __decodeDate($input) {
|
|
$timestamp = 0;
|
|
|
|
if(!is_numeric($input)) {
|
|
// if we got anything, but a timestamp, eg. words (yesterday, today)
|
|
// then convert to unix timestamp representing the start of the day
|
|
$input = strtotime($input);
|
|
$timestamp = $input - ($input % 86400);
|
|
}
|
|
else {
|
|
// round the timestamp to the start of the day
|
|
$timestamp = $input - ($input % 86400);
|
|
}
|
|
|
|
return $timestamp;
|
|
}
|
|
|
|
|
|
}
|