mirror of
https://github.com/alchemy-fr/Phraseanet.git
synced 2025-10-11 03:53:13 +00:00
07300af3f4
Create entries in log_colls table Fix SQL issue Fix SQL issues Update version Add patch Remove debug output Fix CS Fic CS Add table schema Fix Cs Update patch Update patch Update patch Update patch Update patch delete all coll_list call Fix logger issue Fix log_colls table structure definition Rename patch Fix SQL Issues Fix patch Fix test Fix tests
1150 lines
41 KiB
PHP
1150 lines
41 KiB
PHP
<?php
|
|
|
|
/*
|
|
* This file is part of Phraseanet
|
|
*
|
|
* (c) 2005-2013 Alchemy
|
|
*
|
|
* For the full copyright and license information, please view the LICENSE
|
|
* file that was distributed with this source code.
|
|
*/
|
|
|
|
use Alchemy\Phrasea\Application;
|
|
|
|
/**
|
|
*
|
|
* @package module_report
|
|
* @license http://opensource.org/licenses/gpl-3.0 GPLv3
|
|
* @link www.phraseanet.com
|
|
*/
|
|
class module_report_activity extends module_report
|
|
{
|
|
/**
|
|
* Number of questions displayed in the most asked questions
|
|
* @var int
|
|
*/
|
|
private $nb_top = 20;
|
|
|
|
/**
|
|
* Array correspondance column -> to query
|
|
* @var array
|
|
*/
|
|
protected $cor_query = array(
|
|
'user' => 'log.user',
|
|
'site' => 'log.site',
|
|
'societe' => 'log.societe',
|
|
'pays' => 'log.pays',
|
|
'activite' => 'log.activite',
|
|
'fonction' => 'log.fonction',
|
|
'usrid' => 'log.usrid',
|
|
'coll_id' => 'record.coll_id',
|
|
'ddate' => "DATE_FORMAT(log.date, '%Y-%m-%d')",
|
|
'id' => 'log_docs.id',
|
|
'log_id' => 'log_docs.log_id',
|
|
'record_id' => 'log_docs.record_id',
|
|
'final' => 'log_docs.final',
|
|
'comment' => 'log_docs.comment',
|
|
'size' => 'subdef.size'
|
|
);
|
|
|
|
public function __construct(Application $app, $arg1, $arg2, $sbas_id, $collist)
|
|
{
|
|
parent::__construct($app, $arg1, $arg2, $sbas_id, $collist);
|
|
}
|
|
|
|
/**
|
|
* set top value
|
|
* @param int $nb_top
|
|
* @return module_report_activity
|
|
*/
|
|
public function setTop($nb_top)
|
|
{
|
|
$this->nb_top = $nb_top;
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* get Top value
|
|
* @return int
|
|
*/
|
|
public function getTop()
|
|
{
|
|
return $this->nb_top;
|
|
}
|
|
|
|
private function setDisplayForActivity($rs)
|
|
{
|
|
$hours = array();
|
|
|
|
for ($i = 0; $i < 24; $i ++) {
|
|
array_push($this->display, $i);
|
|
$hours[$i] = 0;
|
|
}
|
|
|
|
if (count($rs) > 0) {
|
|
$row = array_shift($rs);
|
|
$this->champ = array_merge($this->champ, array_keys($row));
|
|
}
|
|
|
|
return $hours;
|
|
}
|
|
|
|
/**
|
|
* @desc get the site activity per hours
|
|
* @return array
|
|
*/
|
|
public function getActivityPerHours()
|
|
{
|
|
$this->result = array();
|
|
$this->title = _('report:: activite par heure');
|
|
|
|
$s = new module_report_sql($this->app, $this);
|
|
$filter = $s->getFilters();
|
|
$conn = $s->getConnBas();
|
|
|
|
$params = array();
|
|
$date_filter = $filter->getDateFilter();
|
|
$params = array_merge($params, $date_filter['params']);
|
|
$coll_filter = $filter->getCollectionFilter();
|
|
$params = array_merge($params, $coll_filter['params']);
|
|
$site_filter = $filter->getGvSitFilter();
|
|
$params = array_merge($params, $site_filter['params']);
|
|
|
|
$sql = "
|
|
SELECT DATE_FORMAT( log.date, '%k' ) AS heures, SUM(1) AS nb
|
|
FROM (log)
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
WHERE " . $date_filter['sql'] . "
|
|
AND " . $coll_filter['sql'] . "
|
|
AND " . $site_filter['sql'] . "
|
|
GROUP BY heures
|
|
ORDER BY heures ASC";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$res = $this->setDisplayForActivity($rs);
|
|
|
|
$this->initDefaultConfigColumn($this->display);
|
|
|
|
foreach ($rs as $row) {
|
|
$row['heures'] = (string) $row['heures'];
|
|
$res[$row['heures']] = round(($row['nb'] / 24), 2);
|
|
if ($res[$row['heures']] < 1)
|
|
$res[$row['heures']] = number_format($res[$row['heures']], 2);
|
|
else
|
|
$res[$row['heures']] = (int) $res[$row['heures']];
|
|
}
|
|
|
|
$this->result[] = $res;
|
|
//calculate prev and next page
|
|
$this->calculatePages($rs);
|
|
//do we display navigator ?
|
|
$this->setDisplayNav();
|
|
//set report
|
|
$this->setReport();
|
|
|
|
$this->report['legend'] = array(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12,
|
|
13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23);
|
|
|
|
return $this->report;
|
|
}
|
|
|
|
/**
|
|
* Get all questions by user
|
|
*
|
|
* @param string $value
|
|
* @param string $what
|
|
*/
|
|
public function getAllQuestionByUser($value, $what)
|
|
{
|
|
$result = array();
|
|
|
|
$s = new module_report_sql($this->app, $this);
|
|
$filter = $s->getFilters();
|
|
$conn = $s->getConnBas();
|
|
|
|
$params = array(':main_value' => $value);
|
|
$date_filter = $filter->getDateFilter();
|
|
$params = array_merge($params, $date_filter['params']);
|
|
$coll_filter = $filter->getCollectionFilter();
|
|
$params = array_merge($params, $coll_filter['params']);
|
|
$site_filter = $filter->getGvSitFilter();
|
|
$params = array_merge($params, $site_filter['params']);
|
|
|
|
$sql = "
|
|
SELECT DATE_FORMAT(log_search.date,'%Y-%m-%d %H:%i:%S') as date ,
|
|
log_search.search ,log_search.results
|
|
FROM (log_search)
|
|
INNER JOIN log ON (log.id = log_search.log_id)
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
WHERE log_search.date > " . $date_filter['sql'] . "
|
|
AND log.`" . $what . "` = :main_value
|
|
AND " . $site_filter['sql'] . "
|
|
AND " . $coll_filter['sql'] . "
|
|
ORDER BY date";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$s->setTotalrows($stmt->rowCount());
|
|
$stmt->closeCursor();
|
|
|
|
$sql .= $filter->getLimitFilter();
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$this->setChamp($rs);
|
|
$this->initDefaultConfigColumn($this->champ);
|
|
$i = 0;
|
|
|
|
foreach ($rs as $row) {
|
|
foreach ($this->champ as $key => $value)
|
|
$result[$i][$value] = $row[$value];
|
|
$i ++;
|
|
}
|
|
|
|
$this->title = _('report:: questions');
|
|
$this->setResult($result);
|
|
|
|
return $this->result;
|
|
}
|
|
|
|
/**
|
|
* get the most asked question
|
|
* @param array $tab config for html table
|
|
* @param bool $no_answer true for question with no answer
|
|
*/
|
|
public function getTopQuestion($tab = false, $no_answer = false)
|
|
{
|
|
$this->report['value'] = array();
|
|
$this->report['value2'] = array();
|
|
|
|
$s = new module_report_sql($this->app, $this);
|
|
$filter = $s->getFilters();
|
|
$conn = $s->getConnBas();
|
|
|
|
$i = 0;
|
|
($no_answer) ? $this->title = _('report:: questions sans reponses') :
|
|
$this->title = _('report:: questions les plus posees');
|
|
|
|
$params = array();
|
|
$date_filter = $filter->getDateFilter();
|
|
$params = array_merge($params, $date_filter['params']);
|
|
$coll_filter = $filter->getCollectionFilter();
|
|
$params = array_merge($params, $coll_filter['params']);
|
|
|
|
$sql = "
|
|
SELECT TRIM(log_search.search) as search,
|
|
SUM(1) as nb,
|
|
ROUND(avg(results)) as nb_rep
|
|
FROM (log_search)
|
|
INNER JOIN log ON (log_search.log_id = log.id)
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
WHERE " . $date_filter['sql'] . "
|
|
AND log_search.search != 'all'
|
|
AND (" . $coll_filter['sql'] . ")";
|
|
|
|
($no_answer) ? $sql .= " AND log_search.results = 0 " : "";
|
|
|
|
$sql .= "
|
|
GROUP BY log_search.search
|
|
ORDER BY nb DESC";
|
|
|
|
( ! $no_answer) ? $sql .= " LIMIT 0," . $this->nb_top : "";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$this->setChamp($rs);
|
|
$this->setDisplay($tab);
|
|
|
|
foreach ($rs as $row) {
|
|
foreach ($this->champ as $key => $value)
|
|
$this->result[$i][$value] = $row[$value];
|
|
$i ++;
|
|
$this->report['legend'][] = $row['search'];
|
|
$this->report['value'][] = $row['nb'];
|
|
$this->report['value2'][] = $row['nb_rep'];
|
|
}
|
|
|
|
$this->total = sizeof($this->result);
|
|
//calculate prev and next page
|
|
$this->calculatePages($rs);
|
|
//do we display navigator ?
|
|
$this->setDisplayNav();
|
|
//set report
|
|
$this->setReport();
|
|
|
|
return $this->report;
|
|
}
|
|
|
|
/**
|
|
* @desc get all downloads from one specific user
|
|
* @param $usr user id
|
|
* @param array $config config for the html table
|
|
* @return array
|
|
*/
|
|
public function getAllDownloadByUserBase($usr, $config = false)
|
|
{
|
|
$result = array();
|
|
$s = new module_report_sql($this->app, $this);
|
|
$filter = $s->getFilters();
|
|
$conn = $s->getConnBas();
|
|
|
|
$databox = $this->app['phraseanet.appbox']->get_databox($this->sbas_id);
|
|
|
|
$params = array();
|
|
$date_filter = $filter->getDateFilter();
|
|
$params = array_merge($params, $date_filter['params']);
|
|
$coll_filter = $filter->getCollectionFilter();
|
|
$params = array_merge($params, $coll_filter['params']);
|
|
$site_filter = $filter->getGvSitFilter();
|
|
$params = array_merge($params, $site_filter['params']);
|
|
$user_filter = $filter->getUserIdFilter($usr);
|
|
$params = array_merge($params, $user_filter['params']);
|
|
|
|
$sql = "
|
|
SELECT log_docs.record_id,
|
|
log_docs.date, log_docs.final as objets
|
|
FROM (`log_docs`)
|
|
INNER JOIN log ON (log_docs.log_id = log.id)
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
INNER JOIN record ON (log_docs.record_id = record.record_id)
|
|
WHERE log_docs.action = 'download'
|
|
AND " . $date_filter['sql'] . "
|
|
AND " . $user_filter['sql'] . "
|
|
AND " . $site_filter['sql'] . "
|
|
AND (" . $coll_filter['sql'] . ")";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$s->setTotalrows($stmt->rowCount());
|
|
$stmt->closeCursor();
|
|
|
|
$sql .= "
|
|
ORDER BY date DESC";
|
|
$sql .= $filter->getLimitFilter();
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$login = User_Adapter::getInstance($usr, $this->app)->get_display_name();
|
|
|
|
$this->setChamp($rs);
|
|
($config) ? $this->setConfigColumn($config) :
|
|
$this->initDefaultConfigColumn($this->champ);
|
|
$i = 0;
|
|
|
|
foreach ($rs as $row) {
|
|
$record = $databox->get_record($row['record_id']);
|
|
|
|
foreach ($this->champ as $key => $value) {
|
|
$result[$i][$value] = $row[$value];
|
|
}
|
|
|
|
$result[$i]['titre'] = $record->get_title();
|
|
|
|
$i ++;
|
|
}
|
|
$this->title = sprintf(_('report:: Telechargement effectue par l\'utilisateur %s'), $login);
|
|
$this->setResult($result);
|
|
|
|
return $this->result;
|
|
}
|
|
|
|
/**
|
|
* @desc get all download by base by day
|
|
* @param array $tab config for html table
|
|
* @return array
|
|
*/
|
|
public function getDownloadByBaseByDay($tab = false)
|
|
{
|
|
$this->title = _('report:: telechargements par jour');
|
|
|
|
$s = new module_report_sql($this->app, $this);
|
|
$filter = $s->getFilters();
|
|
$conn = $s->getConnBas();
|
|
|
|
$params = array();
|
|
$date_filter = $filter->getDateFilter();
|
|
$params = array_merge($params, $date_filter['params']);
|
|
$coll_filter = $filter->getCollectionFilter();
|
|
$params = array_merge($params, $coll_filter['params']);
|
|
$site_filter = $filter->getGvSitFilter();
|
|
$params = array_merge($params, $site_filter['params']);
|
|
$record_filter = $filter->getUserFilter();
|
|
if ($record_filter)
|
|
$params = array_merge($params, $record_filter['params']);
|
|
|
|
$sql = "
|
|
SELECT
|
|
log_docs.date
|
|
AS ddate,
|
|
final
|
|
FROM (log_docs)
|
|
INNER JOIN record ON (record.record_id = log_docs.record_id)
|
|
INNER JOIN log ON (" . $site_filter['sql'] . " AND log.id = log_docs.log_id)
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
LEFT JOIN subdef AS s ON (s.record_id = log_docs.record_id AND s.name = log_docs.final)
|
|
WHERE " . $date_filter['sql'] . "
|
|
AND (log_docs.final != 'caption')
|
|
AND log_docs.action = 'download'
|
|
AND (" . $coll_filter['sql'] . ")";
|
|
if ($record_filter['sql'])
|
|
$sql .= "AND (" . $record_filter['sql'] . ")";
|
|
$sql .= ' ORDER BY log_docs.date DESC';
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$this->setChamp($rs);
|
|
$this->setDisplay($tab);
|
|
$save_date = "";
|
|
$total = array('tot_doc' => 0, 'tot_prev' => 0, 'tot_dl' => 0);
|
|
$i = -1;
|
|
|
|
$last_date = null;
|
|
|
|
foreach ($rs as $row) {
|
|
$date = $this->app['date-formatter']->getPrettyString(new DateTime($row['ddate']));
|
|
if ($date != $last_date) {
|
|
$i ++;
|
|
$this->result[$i] = array(
|
|
'ddate' => $date,
|
|
'document' => 0,
|
|
'preview' => 0,
|
|
'total' => 0
|
|
);
|
|
$last_date = $date;
|
|
}
|
|
|
|
if ($row['final'] == 'document') {
|
|
$this->result[$i]['document'] += 1;
|
|
$total['tot_doc'] += 1;
|
|
} else {
|
|
$this->result[$i]['preview'] += 1;
|
|
$total['tot_prev'] += 1;
|
|
}
|
|
|
|
$this->result[$i]['total'] += 1;
|
|
|
|
$total['tot_dl'] += 1;
|
|
}
|
|
|
|
$nb_row = $i + 1;
|
|
$s->setTotalrows($nb_row);
|
|
|
|
if ($s->getTotalRows() > 0) {
|
|
$this->result[$nb_row]['ddate'] = '<b>TOTAL</b>';
|
|
$this->result[$nb_row]['document'] = '<b>' . $total['tot_doc'] . '</b>';
|
|
$this->result[$nb_row]['preview'] = '<b>' . $total['tot_prev'] . '</b>';
|
|
$this->result[$nb_row]['total'] = '<b>' . $total['tot_dl'] . '</b>';
|
|
}
|
|
$this->calculatePages($rs);
|
|
$this->setDisplayNav();
|
|
$this->setReport();
|
|
|
|
return $this->report;
|
|
}
|
|
|
|
/**
|
|
* @desc get nb connexion by user , fonction ,societe etc..
|
|
* @param array $tab config for html table
|
|
* @param string $on choose the field on what you want the result
|
|
* @return array
|
|
*/
|
|
public function getConnexionBase($tab = false, $on = "")
|
|
{
|
|
//default group on user column
|
|
if (empty($on)) {
|
|
$on = "user";
|
|
}
|
|
|
|
$s = new module_report_sql($this->app, $this);
|
|
$filter = $s->getFilters();
|
|
$conn = $s->getConnBas();
|
|
|
|
$params = array();
|
|
|
|
$date_filter = $filter->getDateFilter();
|
|
$params = array_merge($params, $date_filter['params']);
|
|
|
|
$coll_filter = $filter->getCollectionFilter();
|
|
$params = array_merge($params, $coll_filter['params']);
|
|
$site_filter = $filter->getGvSitFilter();
|
|
$params = array_merge($params, $site_filter['params']);
|
|
$this->req = "
|
|
SELECT DISTINCT(log." . $on . ") as " . $on . ",
|
|
usrid,
|
|
SUM(1) as connexion
|
|
FROM (log)
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
WHERE log.user != 'API'
|
|
AND " . $site_filter['sql'] . "
|
|
AND " . $date_filter['sql'] . "
|
|
AND (" . $coll_filter['sql'] . ")
|
|
GROUP BY " . $on . "
|
|
ORDER BY connexion DESC ";
|
|
|
|
$stmt = $conn->prepare($this->req);
|
|
$stmt->execute($params);
|
|
$s->setTotalrows($stmt->rowCount());
|
|
$stmt->closeCursor();
|
|
|
|
$this->enable_limit ? $this->req .= "LIMIT 0," . $this->nb_record : "";
|
|
|
|
$stmt = $conn->prepare($this->req);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$i = 0;
|
|
$total_connexion = 0;
|
|
//set title
|
|
$this->title = _('report:: Detail des connexions');
|
|
//set champ
|
|
$this->champ = array($on, 'connexion');
|
|
//set display
|
|
$this->default_display = array($on, 'connexion');
|
|
//set configuration of column
|
|
($tab) ? $this->setConfigColumn($tab) :
|
|
$this->initDefaultConfigColumn($this->default_display);
|
|
//build result
|
|
foreach ($rs as $row) {
|
|
foreach ($this->champ as $key => $value) {
|
|
$this->result[$i][$value] = empty($row[$value]) ?
|
|
"<i>" . _('report:: non-renseigne') . "</i>" : $row[$value];
|
|
|
|
if ($value == 'connexion')
|
|
$total_connexion += $row['connexion'];
|
|
}
|
|
$this->result[$i]['usrid'] = $row['usrid'];
|
|
$i ++;
|
|
if ($i >= $this->nb_record)
|
|
break;
|
|
}
|
|
|
|
$this->total = $i ++;
|
|
|
|
if ($this->total > 0) {
|
|
$this->result[$i]['usrid'] = 0;
|
|
$this->result[$i]['connexion'] = '<b>' . $total_connexion . '</b>';
|
|
$this->result[$i][$on] = '<b>TOTAL</b>';
|
|
}
|
|
//calculate prev and next page
|
|
$this->calculatePages($rs);
|
|
//do we display navigator ?
|
|
$this->setDisplayNav();
|
|
//set report
|
|
$this->setReport();
|
|
|
|
return $this->report;
|
|
}
|
|
|
|
/**
|
|
* Get the deail of download by users
|
|
*
|
|
* @param array $tab config for the html table
|
|
* @param String $on
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getDetailDownload($tab = false, $on = "")
|
|
{
|
|
empty($on) ? $on = "user" : ""; //by default always report on user
|
|
|
|
$s = new module_report_sql($this->app, $this);
|
|
$filter = $s->getFilters();
|
|
$conn = $s->getConnBas();
|
|
|
|
//set title
|
|
$this->title = _('report:: Detail des telechargements');
|
|
|
|
$params = array();
|
|
$date_filter = $filter->getDateFilter();
|
|
$params = array_merge($params, $date_filter['params']);
|
|
$coll_filter = $filter->getCollectionFilter();
|
|
$params = array_merge($params, $coll_filter['params']);
|
|
$site_filter = $filter->getGvSitFilter();
|
|
$params = array_merge($params, $site_filter['params']);
|
|
$record_filter = $filter->getRecordFilter();
|
|
$params = array_merge($params, $record_filter['params']);
|
|
|
|
$sql = "
|
|
SELECT
|
|
usrid,
|
|
TRIM(" . $on . ") as " . $on . ",
|
|
final, sum(1) as nb,
|
|
sum(size) as poid
|
|
FROM (log_docs as d)
|
|
INNER JOIN log ON (" . $site_filter['sql'] . "
|
|
AND log.id = d.log_id
|
|
AND " . $date_filter['sql'] . ")
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
INNER JOIN record ON record.record_id = d.record_id
|
|
LEFT JOIN subdef as s on ((d.action = 'download' OR d.action = 'mail')
|
|
AND s.record_id=d.record_id and s.name=d.final
|
|
)
|
|
WHERE (" . $coll_filter['sql'] . ")
|
|
AND (" . $record_filter['sql'] . ")
|
|
GROUP BY " . $on . ", final, usrid
|
|
WITH rollup";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$save_user = "";
|
|
$i = -1;
|
|
$total = array(
|
|
'nbdoc' => 0,
|
|
'poiddoc' => 0,
|
|
'nbprev' => 0,
|
|
'poidprev' => 0
|
|
);
|
|
|
|
$this->setChamp($rs);
|
|
|
|
$this->setDisplay($tab);
|
|
|
|
foreach ($rs as $row) {
|
|
$user = $row[$on];
|
|
if (($save_user != $user) && ! is_null($user) && ! empty($user)) {
|
|
if ($i >= 0) {
|
|
if (($this->result[$i]['nbprev'] + $this->result[$i]['nbdoc']) == 0 || ($this->result[$i]['poiddoc'] + $this->result[$i]['poidprev']) == 0) {
|
|
unset($this->result[$i]);
|
|
}
|
|
|
|
if (isset($this->result[$i]['poiddoc']) && isset($this->result[$i]['poidprev'])) {
|
|
$this->result[$i]['poiddoc'] = p4string::format_octets($this->result[$i]['poiddoc']);
|
|
$this->result[$i]['poidprev'] = p4string::format_octets($this->result[$i]['poidprev']);
|
|
}
|
|
}
|
|
|
|
$i ++;
|
|
|
|
$this->result[$i]['nbprev'] = 0;
|
|
$this->result[$i]['poidprev'] = 0;
|
|
$this->result[$i]['nbdoc'] = 0;
|
|
$this->result[$i]['poiddoc'] = 0;
|
|
}
|
|
|
|
//doc info
|
|
if ($row['final'] == 'document' &&
|
|
! is_null($user) && ! is_null($row['usrid'])) {
|
|
$this->result[$i]['nbdoc'] = ( ! is_null($row['nb']) ? $row['nb'] : 0);
|
|
$this->result[$i]['poiddoc'] = ( ! is_null($row['poid']) ? $row['poid'] : 0);
|
|
$this->result[$i]['user'] = empty($row[$on]) ?
|
|
"<i>" . _('report:: non-renseigne') . "</i>" : $row[$on];
|
|
$total['nbdoc'] += $this->result[$i]['nbdoc'];
|
|
$total['poiddoc'] += ( ! is_null($row['poid']) ? $row['poid'] : 0);
|
|
$this->result[$i]['usrid'] = $row['usrid'];
|
|
}
|
|
//preview info
|
|
if (($row['final'] == 'preview' || $row['final'] == 'thumbnail') &&
|
|
! is_null($user) &&
|
|
! is_null($row['usrid'])) {
|
|
|
|
$this->result[$i]['nbprev'] += ( ! is_null($row['nb']) ? $row['nb'] : 0);
|
|
$this->result[$i]['poidprev'] += ( ! is_null($row['poid']) ? $row['poid'] : 0);
|
|
|
|
$this->result[$i]['user'] = empty($row[$on]) ?
|
|
"<i>" . _('report:: non-renseigne') . "</i>" : $row[$on];
|
|
$total['nbprev'] += ( ! is_null($row['nb']) ? $row['nb'] : 0);
|
|
$total['poidprev'] += ( ! is_null($row['poid']) ? $row['poid'] : 0);
|
|
$this->result[$i]['usrid'] = $row['usrid'];
|
|
}
|
|
|
|
$save_user = $user;
|
|
}
|
|
|
|
unset($this->result[$i]);
|
|
$nb_row = $i + 1;
|
|
$this->total = $nb_row;
|
|
|
|
if ($this->total > 0) {
|
|
$this->result[$nb_row]['user'] = '<b>TOTAL</b>';
|
|
$this->result[$nb_row]['nbdoc'] = '<b>' . $total['nbdoc'] . '</b>';
|
|
$this->result[$nb_row]['poiddoc'] =
|
|
'<b>' . p4string::format_octets($total['poiddoc']) . '</b>';
|
|
$this->result[$nb_row]['nbprev'] = '<b>' . $total['nbprev'] . '</b>';
|
|
$this->result[$nb_row]['poidprev'] =
|
|
'<b>' . p4string::format_octets($total['poidprev']) . '</b>';
|
|
}
|
|
$this->total = sizeof($this->result);
|
|
$this->calculatePages($rs);
|
|
$this->setDisplayNav();
|
|
$this->setReport();
|
|
|
|
return $this->report;
|
|
}
|
|
|
|
public function getPush($tab = false)
|
|
{
|
|
$s = new module_report_sql($this->app, $this);
|
|
$filter = $s->getFilters();
|
|
$conn = $s->getConnBas();
|
|
$push = array();
|
|
|
|
$params = array();
|
|
$date_filter = $filter->getDateFilter();
|
|
$params = array_merge($params, $date_filter['params']);
|
|
$coll_filter = $filter->getCollectionFilter();
|
|
$params = array_merge($params, $coll_filter['params']);
|
|
$site_filter = $filter->getGvSitFilter();
|
|
$params = array_merge($params, $site_filter['params']);
|
|
$record_filter = $filter->getRecordFilter();
|
|
$params = array_merge($params, $record_filter['params']);
|
|
|
|
$sql = "
|
|
SELECT log.usrid, log.user , d.final as getter, d.record_id, d.date, s.*
|
|
FROM (log_docs as d)
|
|
INNER JOIN log ON (" . $site_filter['sql'] . "
|
|
AND log.id = d.log_id
|
|
AND " . $date_filter['sql'] . ")
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
INNER JOIN record ON (record.record_id = d.record_id)
|
|
LEFT JOIN subdef as s ON (s.record_id=d.record_id and s.name='document')
|
|
WHERE ((" . $coll_filter['sql'] . ") AND " . $record_filter['sql'] . " AND d.action='push')
|
|
";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$this->setChamp($rs);
|
|
$this->initDefaultConfigColumn($this->champ);
|
|
|
|
$i = 0;
|
|
foreach ($rs as $row) {
|
|
foreach ($this->champ as $key => $value) {
|
|
$this->result[$i][$value] = $row[$value];
|
|
if ($value == "getter") {
|
|
try {
|
|
$user = User_Adapter::getInstance($row[$value], $this->app);
|
|
$this->result[$i][$value] = $user->get_display_name();
|
|
} catch (Exception $e) {
|
|
|
|
}
|
|
} elseif ($value == "size") {
|
|
$this->result[$i][$value] = p4string::format_octets($row[$value]);
|
|
} elseif ($value == "date") {
|
|
$date_obj = new DateTime($row[$value]);
|
|
$this->result[$i][$value] = $this->app['date-formatter']->getPrettyString($date_obj);
|
|
}
|
|
}
|
|
$i ++;
|
|
}
|
|
|
|
$this->total = sizeof($this->result);
|
|
//calculate prev and next page
|
|
$this->calculatePages($rs);
|
|
//do we display navigator ?
|
|
$this->setDisplayNav();
|
|
//set report
|
|
$this->setReport();
|
|
|
|
return($this->report);
|
|
}
|
|
|
|
public static function topTenUser(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$result = array();
|
|
$result['top_ten_doc'] = array();
|
|
$result['top_ten_prev'] = array();
|
|
$result['top_ten_poiddoc'] = array();
|
|
$result['top_ten_poidprev'] = array();
|
|
|
|
$params = array(':site_id' => $app['phraseanet.registry']->get('GV_sit'));
|
|
|
|
$datefilter = module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$params = array_merge($params, $datefilter['params']);
|
|
|
|
$collfilter = module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
$params = array_merge($params, $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT log.usrid, user, final, sum(1) AS nb, sum(size) AS poid
|
|
FROM (log_docs AS log_date)
|
|
INNER JOIN log ON (log.site = :site_id
|
|
AND log.id = log_date.log_id
|
|
AND " . $datefilter['sql'] . ")
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
LEFT JOIN subdef AS s ON (log_date.action = 'download'
|
|
AND s.record_id = log_date.record_id
|
|
AND s.name = log_date.final
|
|
AND (" . $collfilter['sql'] . "))
|
|
GROUP BY user, final
|
|
WITH rollup";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$save_id = "";
|
|
foreach ($rs as $row) {
|
|
$kttd = 'top_ten_doc';
|
|
$kttp = 'top_ten_poiddoc';
|
|
|
|
$kttpr = 'top_ten_prev';
|
|
$kttpp = 'top_ten_poidprev';
|
|
|
|
$id = $row['usrid'];
|
|
|
|
if ( ! is_null($row['usrid'])
|
|
&& ! is_null($row['user'])
|
|
&& ! is_null($row['final']) && ! is_null($row['nb'])
|
|
&& ! is_null($row['poid'])) {
|
|
if ($row['final'] == 'document') {
|
|
$result[$kttd][$id]['lib'] = $row['user'];
|
|
$result[$kttd][$id]['id'] = $id;
|
|
$result[$kttd][$id]['nb'] = ! is_null($row['nb']) ?
|
|
(int) $row['nb'] : 0;
|
|
$result[$kttp][$id]['nb'] = ! is_null($row['poid']) ?
|
|
(int) $row['poid'] : 0;
|
|
$result[$kttp][$id]['lib'] = $row['user'];
|
|
$result[$kttp][$id]['id'] = $id;
|
|
if ( ! isset($result[$kttd][$id]['nb']))
|
|
$result[$kttd][$id]['nb'] = 0;
|
|
}
|
|
if ($row['final'] == 'preview') {
|
|
$result[$kttpr][$id]['lib'] = $row['user'];
|
|
$result[$kttpr][$id]['id'] = $id;
|
|
if ( ! isset($result[$kttpr][$id]['nb']))
|
|
$result[$kttpr][$id]['nb'] = 0;
|
|
$result[$kttpr][$id]['nb'] = ! is_null($row['nb']) ?
|
|
(int) $row['nb'] : 0;
|
|
$result[$kttpp][$id]['nb'] = ! is_null($row['poid']) ?
|
|
(int) $row['poid'] : 0;
|
|
$result[$kttpp][$id]['lib'] = $row['user'];
|
|
$result[$kttpp][$id]['id'] = $id;
|
|
}
|
|
}
|
|
$save_id = $id;
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
public static function activity(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$res = array();
|
|
$datefilter =
|
|
module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$collfilter =
|
|
module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
|
|
$params = array(':site_id' => $app['phraseanet.registry']->get('GV_sit'));
|
|
$params = array_merge($params, $datefilter['params'], $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT log_date.id, HOUR(log_date.date) as heures
|
|
FROM (log as log_date)
|
|
INNER JOIN log_colls ON (log_date.id = log_colls.log_id)
|
|
WHERE " . $datefilter['sql'] . "
|
|
AND (" . $collfilter['sql'] . ")
|
|
AND log_date.site = :site_id";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$total = $stmt->rowCount();
|
|
$stmt->closeCursor();
|
|
|
|
for ($i = 0; $i < 24; $i ++ )
|
|
$res[$i] = 0;
|
|
|
|
foreach ($rs as $row) {
|
|
if ($total > 0)
|
|
$res[$row["heures"]] ++;
|
|
}
|
|
|
|
foreach ($res as $heure => $value)
|
|
$res[$heure] = number_format(($value / 24), 2, '.', '');
|
|
|
|
return $res;
|
|
}
|
|
|
|
public static function activityDay(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$result = array();
|
|
$res = array();
|
|
$datefilter =
|
|
module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$collfilter =
|
|
module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
|
|
$params = array(':site_id' => $app['phraseanet.registry']->get('GV_sit'));
|
|
$params = array_merge($params, $datefilter['params'], $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT DISTINCT (
|
|
DATE_FORMAT( log_date.date, '%Y-%m-%d' )
|
|
) AS ddate, COUNT( DATE_FORMAT( log_date.date, '%d' ) ) AS activity
|
|
FROM log as log_date INNER JOIN log_colls ON (log_date.id = log_colls.log_id)
|
|
WHERE " . $datefilter['sql'] . "
|
|
AND log_date.site = :site_id
|
|
AND (" . $collfilter['sql'] . ")
|
|
GROUP by ddate
|
|
ORDER BY ddate ASC";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
foreach ($rs as $row) {
|
|
$date = new DateTime($row['ddate']);
|
|
$result[$date->format(DATE_ATOM)] = $row['activity'];
|
|
}
|
|
|
|
foreach ($result as $key => $act) {
|
|
$res[$key] = number_format($act, 2, '.', '');
|
|
}
|
|
|
|
return $res;
|
|
}
|
|
|
|
public static function activityQuestion(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$result = array();
|
|
$datefilter =
|
|
module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$collfilter =
|
|
module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
|
|
$params = array(':site_id' => $app['phraseanet.registry']->get('GV_sit'));
|
|
$params = array_merge($params, $datefilter['params'], $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT log_date.usrid, log_date.user, sum(1) AS nb
|
|
FROM (`log_search`)
|
|
INNER JOIN log as log_date ON (log_search.log_id = log_date.id)
|
|
INNER JOIN log_colls ON (log_date.id = log_colls.log_id)
|
|
WHERE " . $datefilter['sql'] . "
|
|
AND log_date.site = :site_id
|
|
AND (" . $collfilter['sql'] . ")
|
|
GROUP BY log_date.usrid
|
|
ORDER BY nb DESC";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
foreach ($rs as $row) {
|
|
$result[$row['usrid']]['lib'] = $row['user'];
|
|
$result[$row['usrid']]['nb'] = (int) $row['nb'];
|
|
$result[$row['usrid']]['id'] = $row['usrid'];
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
public static function activiteTopQuestion(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$result = array();
|
|
$datefilter =
|
|
module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$collfilter =
|
|
module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
|
|
$params = array(':site_id' => $app['phraseanet.registry']->get('GV_sit'));
|
|
$params = array_merge($params, $datefilter['params'], $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT
|
|
TRIM(log_search.search) as question,
|
|
log_date.usrid,
|
|
log_date.user,
|
|
sum(1) AS nb
|
|
FROM (`log_search`)
|
|
INNER JOIN log as log_date ON (log_search.log_id = log_date.id)
|
|
INNER JOIN log_colls ON (log_date.id = log_colls.log_id)
|
|
WHERE " . $datefilter['sql'] . "
|
|
AND log_date.site = :site_id
|
|
AND (" . $collfilter['sql'] . ")
|
|
GROUP BY log_search.search
|
|
ORDER BY nb DESC";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$conv = array(" " => "");
|
|
foreach ($rs as $row) {
|
|
$question = $row['question'];
|
|
$question = mb_strtolower(strtr($question, $conv));
|
|
$result[$question]['lib'] = $row['question'];
|
|
$result[$question]['nb'] = (int) $row['nb'];
|
|
$result[$question]['id'] = "false";
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
public static function activiteTopTenSiteView(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$result = array();
|
|
$datefilter = module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$collfilter = module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
|
|
$params = array();
|
|
$params = array_merge($params, $datefilter['params'], $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT referrer, COUNT(referrer) as nb_view
|
|
FROM (log_view)
|
|
INNER JOIN log as log_date ON (log_view.log_id = log_date.id)
|
|
INNER JOIN log_colls ON (log_date.id = log_colls.log_id)
|
|
WHERE " . $datefilter['sql'] . "
|
|
AND (" . $collfilter['sql'] . ")
|
|
GROUP BY referrer
|
|
ORDER BY nb_view DESC ";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
foreach ($rs as $row) {
|
|
($row['referrer'] != 'NO REFERRER') ?
|
|
$host = parent::getHost($row['referrer']) :
|
|
$host = 'NO REFERRER';
|
|
if ( ! isset($result[$host]['nb']))
|
|
$result[$host]['nb'] = 0;
|
|
if ( ! isset($result[$host]['lib']))
|
|
$result[$host]['lib'] = $host;
|
|
$result[$host]['nb']+= ( (int) $row['nb_view']);
|
|
$result[$host]['id'] = "false";
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
public static function activiteAddedDocument(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$result = array();
|
|
$datefilter = module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$collfilter = module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
|
|
$params = array();
|
|
$params = array_merge($params, $datefilter['params'], $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT DISTINCT (
|
|
DATE_FORMAT( log_date.date, '%Y-%m-%d' )
|
|
) AS ddate, COUNT( DATE_FORMAT( log_date.date, '%d' ) ) AS activity
|
|
FROM (log_docs as log_date)
|
|
INNER JOIN log ON (log_date.log_id = log.id)
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
WHERE " . $datefilter['sql'] . " AND log_date.action = 'add'
|
|
AND (" . $collfilter['sql'] . ")
|
|
GROUP BY ddate
|
|
ORDER BY activity ASC ";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
foreach ($rs as $row) {
|
|
$date = new DateTime($row['ddate']);
|
|
$result[$date->format(DATE_ATOM)] = $row['activity'];
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
public static function activiteEditedDocument(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$result = array();
|
|
$datefilter = module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$collfilter = module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
|
|
$params = array();
|
|
$params = array_merge($params, $datefilter['params'], $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT DISTINCT (
|
|
DATE_FORMAT( log_date.date, '%Y-%m-%d' )
|
|
) AS ddate, COUNT( DATE_FORMAT( log_date.date, '%d' ) ) AS activity
|
|
FROM (log_docs as log_date)
|
|
INNER JOIN log ON log_date.log_id = log.id
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
WHERE " . $datefilter['sql'] . " AND log_date.action = 'edit'
|
|
AND (" . $collfilter['sql'] . ")
|
|
GROUP BY ddate
|
|
ORDER BY activity ASC ";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
foreach ($rs as $row) {
|
|
$date = $app['date-formatter']->getPrettyString(new DateTime($row['ddate']));
|
|
$result[$date] = $row['activity'];
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
public static function activiteAddedTopTenUser(Application $app, $dmin, $dmax, $sbas_id, $list_coll_id)
|
|
{
|
|
$conn = connection::getPDOConnection($app, $sbas_id);
|
|
$result = array();
|
|
$datefilter = module_report_sqlfilter::constructDateFilter($dmin, $dmax);
|
|
$collfilter = module_report_sqlfilter::constructCollectionFilter($app, $list_coll_id);
|
|
|
|
$params = array();
|
|
$params = array_merge($params, $datefilter['params'], $collfilter['params']);
|
|
|
|
$sql = "
|
|
SELECT log.usrid, log.user, sum( 1 ) AS nb
|
|
FROM (log_docs as log_date)
|
|
INNER JOIN log ON (log_date.log_id = log.id)
|
|
INNER JOIN log_colls ON (log.id = log_colls.log_id)
|
|
WHERE " . $datefilter['sql'] . " AND log_date.action = 'add'
|
|
AND (" . $collfilter['sql'] . ")
|
|
GROUP BY log.usrid
|
|
ORDER BY nb ASC ";
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute($params);
|
|
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
foreach ($rs as $row) {
|
|
$result[$row['usrid']]['lib'] = $row['user'];
|
|
$result[$row['usrid']]['nb'] = $row['nb'];
|
|
$result[$row['usrid']]['id'] = $row['usrid'];
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
}
|