mirror of
https://github.com/alchemy-fr/Phraseanet.git
synced 2025-10-10 19:43:16 +00:00
640 lines
16 KiB
PHP
640 lines
16 KiB
PHP
<?php
|
|
|
|
/*
|
|
* This file is part of Phraseanet
|
|
*
|
|
* (c) 2005-2010 Alchemy
|
|
*
|
|
* For the full copyright and license information, please view the LICENSE
|
|
* file that was distributed with this source code.
|
|
*/
|
|
|
|
/**
|
|
*
|
|
*
|
|
* @license http://opensource.org/licenses/gpl-3.0 GPLv3
|
|
* @link www.phraseanet.com
|
|
*/
|
|
class databox_status
|
|
{
|
|
|
|
/**
|
|
*
|
|
* @var Array
|
|
*/
|
|
private static $_status = array();
|
|
|
|
/**
|
|
*
|
|
* @var Array
|
|
*/
|
|
protected static $_statuses;
|
|
|
|
/**
|
|
*
|
|
* @var Array
|
|
*/
|
|
private $status = array();
|
|
|
|
/**
|
|
*
|
|
* @var string
|
|
*/
|
|
private $path = '';
|
|
|
|
/**
|
|
*
|
|
* @var string
|
|
*/
|
|
private $url = '';
|
|
|
|
/**
|
|
*
|
|
* @param int $sbas_id
|
|
* @return status
|
|
*/
|
|
private function __construct($sbas_id)
|
|
{
|
|
|
|
$this->status = array();
|
|
|
|
$path = $url = false;
|
|
|
|
$sbas_params = phrasea::sbas_params();
|
|
$registry = registry::get_instance();
|
|
|
|
if (!isset($sbas_params[$sbas_id]))
|
|
|
|
return;
|
|
|
|
$path = $this->path = $registry->get('GV_RootPath') . "config/status/" . urlencode($sbas_params[$sbas_id]["host"]) . "-" . urlencode($sbas_params[$sbas_id]["port"]) . "-" . urlencode($sbas_params[$sbas_id]["dbname"]);
|
|
$url = $this->url = "/custom/status/" . urlencode($sbas_params[$sbas_id]["host"]) . "-" . urlencode($sbas_params[$sbas_id]["port"]) . "-" . urlencode($sbas_params[$sbas_id]["dbname"]);
|
|
|
|
$databox = databox::get_instance((int) $sbas_id);
|
|
$xmlpref = $databox->get_structure();
|
|
$sxe = simplexml_load_string($xmlpref);
|
|
|
|
if ($sxe)
|
|
{
|
|
|
|
foreach ($sxe->statbits->bit as $sb)
|
|
{
|
|
$bit = (int) ($sb["n"]);
|
|
if ($bit < 4 && $bit > 63)
|
|
continue;
|
|
|
|
$this->status[$bit]["name"] = (string) ($sb);
|
|
$this->status[$bit]["labeloff"] = (string) $sb['labelOff'];
|
|
$this->status[$bit]["labelon"] = (string) $sb['labelOn'];
|
|
|
|
$this->status[$bit]["img_off"] = false;
|
|
$this->status[$bit]["img_on"] = false;
|
|
|
|
if (is_file($path . "-stat_" . $bit . "_0.gif"))
|
|
{
|
|
$this->status[$bit]["img_off"] = $url . "-stat_" . $bit . "_0.gif";
|
|
$this->status[$bit]["path_off"] = $path . "-stat_" . $bit . "_0.gif";
|
|
}
|
|
if (is_file($path . "-stat_" . $bit . "_1.gif"))
|
|
{
|
|
$this->status[$bit]["img_on"] = $url . "-stat_" . $bit . "_1.gif";
|
|
$this->status[$bit]["path_on"] = $path . "-stat_" . $bit . "_1.gif";
|
|
}
|
|
|
|
$this->status[$bit]["searchable"] = isset($sb['searchable']) ? (int) $sb['searchable'] : 0;
|
|
$this->status[$bit]["printable"] = isset($sb['printable']) ? (int) $sb['printable'] : 0;
|
|
}
|
|
}
|
|
ksort($this->status);
|
|
|
|
return $this;
|
|
}
|
|
|
|
public static function getStatus($sbas_id)
|
|
{
|
|
|
|
if (!isset(self::$_status[$sbas_id]))
|
|
self::$_status[$sbas_id] = new databox_status($sbas_id);
|
|
|
|
return self::$_status[$sbas_id]->status;
|
|
}
|
|
|
|
public static function getDisplayStatus()
|
|
{
|
|
if (self::$_statuses)
|
|
|
|
return self::$_statuses;
|
|
|
|
$appbox = appbox::get_instance();
|
|
$session = $appbox->get_session();
|
|
$user = User_Adapter::getInstance($session->get_usr_id(), $appbox);
|
|
|
|
$sbas_ids = $user->ACL()->get_granted_sbas();
|
|
|
|
$statuses = array();
|
|
|
|
foreach ($sbas_ids as $databox)
|
|
{
|
|
try
|
|
{
|
|
$statuses[$databox->get_sbas_id()] = $databox->get_statusbits();
|
|
}
|
|
catch (Exception $e)
|
|
{
|
|
|
|
}
|
|
}
|
|
|
|
self::$_statuses = $statuses;
|
|
|
|
return self::$_statuses;
|
|
}
|
|
|
|
public static function getSearchStatus()
|
|
{
|
|
$appbox = appbox::get_instance();
|
|
$session = $appbox->get_session();
|
|
$user = User_Adapter::getInstance($session->get_usr_id(), $appbox);
|
|
|
|
$statuses = array();
|
|
|
|
$sbas_ids = $user->ACL()->get_granted_sbas();
|
|
|
|
$see_all = array();
|
|
|
|
foreach ($sbas_ids as $databox)
|
|
{
|
|
$see_all[$databox->get_sbas_id()] = false;
|
|
|
|
foreach($databox->get_collections() as $collection)
|
|
{
|
|
if($user->ACL()->has_right_on_base($collection->get_base_id(), 'chgstatus'))
|
|
{
|
|
$see_all[$databox->get_sbas_id()] = true;
|
|
break;
|
|
}
|
|
}
|
|
try
|
|
{
|
|
$statuses[$databox->get_sbas_id()] = $databox->get_statusbits();
|
|
}
|
|
catch (Exception $e)
|
|
{
|
|
|
|
}
|
|
}
|
|
|
|
$stats = array();
|
|
|
|
foreach ($statuses as $sbas_id => $status)
|
|
{
|
|
|
|
$see_this = isset($see_all[$sbas_id]) ? $see_all[$sbas_id] : false;
|
|
|
|
if ($user->ACL()->has_right_on_sbas($sbas_id, 'bas_modify_struct'))
|
|
$see_this = true;
|
|
|
|
foreach ($status as $bit => $props)
|
|
{
|
|
|
|
if ($props['searchable'] == 0 && !$see_this)
|
|
continue;
|
|
|
|
$set = false;
|
|
if (isset($stats[$bit]))
|
|
{
|
|
foreach ($stats[$bit] as $k => $s_desc)
|
|
{
|
|
if (mb_strtolower($s_desc['labelon']) == mb_strtolower($props['labelon'])
|
|
&& mb_strtolower($s_desc['labeloff']) == mb_strtolower($props['labeloff']))
|
|
{
|
|
$stats[$bit][$k]['sbas'][] = $sbas_id;
|
|
$set = true;
|
|
}
|
|
}
|
|
if (!$set)
|
|
{
|
|
$stats[$bit][] = array(
|
|
'sbas' => array($sbas_id),
|
|
'labeloff' => $props['labeloff'],
|
|
'labelon' => $props['labelon'],
|
|
'imgoff' => $props['img_off'],
|
|
'imgon' => $props['img_on']
|
|
);
|
|
$set = true;
|
|
}
|
|
}
|
|
|
|
if (!$set)
|
|
{
|
|
$stats[$bit] = array(
|
|
array(
|
|
'sbas' => array($sbas_id),
|
|
'labeloff' => $props['labeloff'],
|
|
'labelon' => $props['labelon'],
|
|
'imgoff' => $props['img_off'],
|
|
'imgon' => $props['img_on']
|
|
)
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
return $stats;
|
|
}
|
|
|
|
public static function getPath($sbas_id)
|
|
{
|
|
|
|
if (!isset(self::$_status[$sbas_id]))
|
|
self::$_status[$sbas_id] = new databox_status($sbas_id);
|
|
|
|
return self::$_status[$sbas_id]->path;
|
|
}
|
|
|
|
public static function getUrl($sbas_id)
|
|
{
|
|
|
|
if (!isset(self::$_status[$sbas_id]))
|
|
self::$_status[$sbas_id] = new databox_status($sbas_id);
|
|
|
|
return self::$_status[$sbas_id]->url;
|
|
}
|
|
|
|
public static function deleteStatus($sbas_id, $bit)
|
|
{
|
|
$appbox = appbox::get_instance();
|
|
$session = $appbox->get_session();
|
|
$user = User_Adapter::getInstance($session->get_usr_id(), $appbox);
|
|
|
|
if (!$user->ACL()->has_right_on_sbas($sbas_id, 'bas_modify_struct'))
|
|
|
|
return false;
|
|
|
|
$status = self::getStatus($sbas_id);
|
|
|
|
if (isset($status[$bit]))
|
|
{
|
|
$connbas = connection::getPDOConnection($sbas_id);
|
|
|
|
$databox = databox::get_instance((int) $sbas_id);
|
|
|
|
$doc = $databox->get_dom_structure();
|
|
if ($doc)
|
|
{
|
|
$xpath = $databox->get_xpath_structure();
|
|
$entries = $xpath->query($q = "/record/statbits/bit[@n=" . $bit . "]");
|
|
|
|
foreach ($entries as $sbit)
|
|
{
|
|
if ($p = $sbit->previousSibling)
|
|
{
|
|
if ($p->nodeType == XML_TEXT_NODE && $p->nodeValue == "\n\t\t")
|
|
$p->parentNode->removeChild($p);
|
|
}
|
|
if ($sbit->parentNode->removeChild($sbit))
|
|
{
|
|
$sql = 'UPDATE record SET status = status&(~(1<<' . $bit . '))';
|
|
$stmt = $connbas->prepare($sql);
|
|
$stmt->execute();
|
|
$stmt->closeCursor();
|
|
}
|
|
}
|
|
|
|
$databox->saveStructure($doc);
|
|
|
|
if (self::$_status[$sbas_id]->status[$bit]['img_off'])
|
|
{
|
|
unlink(self::$_status[$sbas_id]->status[$bit]['path_off']);
|
|
}
|
|
if (self::$_status[$sbas_id]->status[$bit]['img_on'])
|
|
{
|
|
unlink(self::$_status[$sbas_id]->status[$bit]['path_on']);
|
|
}
|
|
|
|
unset(self::$_status[$sbas_id]->status[$bit]);
|
|
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
public static function updateStatus($sbas_id, $bit, $properties)
|
|
{
|
|
$appbox = appbox::get_instance();
|
|
$session = $appbox->get_session();
|
|
$user = User_Adapter::getInstance($session->get_usr_id(), $appbox);
|
|
|
|
if (!$user->ACL()->has_right_on_sbas($sbas_id, 'bas_modify_struct'))
|
|
|
|
return false;
|
|
|
|
$status = self::getStatus($sbas_id);
|
|
|
|
$databox = $appbox->get_databox((int) $sbas_id);
|
|
|
|
$doc = $databox->get_dom_structure($sbas_id);
|
|
if ($doc)
|
|
{
|
|
$xpath = $databox->get_xpath_structure($sbas_id);
|
|
$entries = $xpath->query("/record/statbits");
|
|
if ($entries->length == 0)
|
|
{
|
|
$statbits = $doc->documentElement->appendChild($doc->createElement("statbits"));
|
|
}
|
|
else
|
|
{
|
|
$statbits = $entries->item(0);
|
|
}
|
|
|
|
if ($statbits)
|
|
{
|
|
$entries = $xpath->query("/record/statbits/bit[@n=" . $bit . "]");
|
|
|
|
if ($entries->length >= 1)
|
|
{
|
|
foreach ($entries as $k => $sbit)
|
|
{
|
|
if ($p = $sbit->previousSibling)
|
|
{
|
|
if ($p->nodeType == XML_TEXT_NODE && $p->nodeValue == "\n\t\t")
|
|
$p->parentNode->removeChild($p);
|
|
}
|
|
$sbit->parentNode->removeChild($sbit);
|
|
}
|
|
}
|
|
|
|
$sbit = $statbits->appendChild($doc->createElement("bit"));
|
|
|
|
if ($n = $sbit->appendChild($doc->createAttribute("n")))
|
|
{
|
|
$n->value = $bit;
|
|
$sbit->appendChild($doc->createTextNode($properties['name']));
|
|
}
|
|
|
|
if ($labOn = $sbit->appendChild($doc->createAttribute("labelOn")))
|
|
{
|
|
$labOn->value = $properties['labelon'];
|
|
}
|
|
|
|
if ($searchable = $sbit->appendChild($doc->createAttribute("searchable")))
|
|
{
|
|
$searchable->value = $properties['searchable'];
|
|
}
|
|
|
|
if ($printable = $sbit->appendChild($doc->createAttribute("printable")))
|
|
{
|
|
$printable->value = $properties['printable'];
|
|
}
|
|
|
|
if ($labOff = $sbit->appendChild($doc->createAttribute("labelOff")))
|
|
{
|
|
$labOff->value = $properties['labeloff'];
|
|
}
|
|
}
|
|
|
|
$databox->saveStructure($doc);
|
|
|
|
self::$_status[$sbas_id]->status[$bit]["name"] = $properties['name'];
|
|
self::$_status[$sbas_id]->status[$bit]["labelon"] = $properties['labelon'];
|
|
self::$_status[$sbas_id]->status[$bit]["labeloff"] = $properties['labeloff'];
|
|
self::$_status[$sbas_id]->status[$bit]["searchable"] = (int) $properties['searchable'];
|
|
self::$_status[$sbas_id]->status[$bit]["printable"] = (int) $properties['printable'];
|
|
|
|
if (!isset(self::$_status[$sbas_id]->status[$bit]['img_on']))
|
|
self::$_status[$sbas_id]->status[$bit]['img_on'] = false;
|
|
if (!isset(self::$_status[$sbas_id]->status[$bit]['img_off']))
|
|
self::$_status[$sbas_id]->status[$bit]['img_off'] = false;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
public static function deleteIcon($sbas_id, $bit, $switch)
|
|
{
|
|
$appbox = appbox::get_instance();
|
|
$session = $appbox->get_session();
|
|
$user = User_Adapter::getInstance($session->get_usr_id(), $appbox);
|
|
|
|
if (!$user->ACL()->has_right_on_sbas($sbas_id, 'bas_modify_struct'))
|
|
|
|
return false;
|
|
|
|
$status = self::getStatus($sbas_id);
|
|
|
|
$switch = in_array($switch, array('on', 'off')) ? $switch : false;
|
|
|
|
if (!$switch)
|
|
|
|
return false;
|
|
|
|
if ($status[$bit]['img_' . $switch])
|
|
{
|
|
if (isset($status[$bit]['path_' . $switch]))
|
|
unlink($status[$bit]['path_' . $switch]);
|
|
|
|
$status[$bit]['img_' . $switch] = false;
|
|
unset($status[$bit]['path_' . $switch]);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
public static function updateIcon($sbas_id, $bit, $switch, $file)
|
|
{
|
|
$appbox = appbox::get_instance();
|
|
$session = $appbox->get_session();
|
|
|
|
$user = User_Adapter::getInstance($session->get_usr_id(), $appbox);
|
|
|
|
$registry = registry::get_instance();
|
|
|
|
if (!$user->ACL()->has_right_on_sbas($sbas_id, 'bas_modify_struct'))
|
|
throw new Exception_Forbidden();
|
|
|
|
$switch = in_array($switch, array('on', 'off')) ? $switch : false;
|
|
|
|
if (!$switch)
|
|
throw new Exception_InvalidArgument();
|
|
|
|
$status = self::getStatus($sbas_id);
|
|
$url = self::getUrl($sbas_id);
|
|
$path = self::getPath($sbas_id);
|
|
if ($file['size'] >= 65535)
|
|
throw new Exception_Upload_FileTooBig();
|
|
|
|
if ($file['error'] !== UPLOAD_ERR_OK)
|
|
throw new Exception_Upload_Error();
|
|
|
|
self::deleteIcon($sbas_id, $bit, $switch);
|
|
$name = "-stat_" . $bit . "_" . ($switch == 'on' ? '1' : '0') . ".gif";
|
|
|
|
if (!move_uploaded_file($file["tmp_name"], $path . $name))
|
|
throw new Exception_Upload_CannotWriteFile();
|
|
|
|
$custom_path = $registry->get('GV_RootPath') . 'www/custom/status/';
|
|
|
|
if (!is_dir($custom_path))
|
|
system_file::mkdir($custom_path);
|
|
|
|
copy($path . $name, $custom_path . basename($path . $name));
|
|
self::$_status[$sbas_id]->status[$bit]['img_' . $switch] = $url . $name;
|
|
self::$_status[$sbas_id]->status[$bit]['path_' . $switch] = $path . $name;
|
|
|
|
return true;
|
|
}
|
|
|
|
public static function operation_and($stat1, $stat2)
|
|
{
|
|
$conn = connection::getPDOConnection();
|
|
|
|
$status = '0';
|
|
|
|
if(substr($stat1, 0, 2) === '0x')
|
|
{
|
|
$stat1 = self::hex2bin(substr($stat1, 2));
|
|
}
|
|
if(substr($stat2, 0, 2) === '0x')
|
|
{
|
|
$stat2 = self::hex2bin(substr($stat2, 2));
|
|
}
|
|
|
|
$sql = 'select bin(0b' . trim($stat1) . ' & 0b' . trim($stat2) . ') as result';
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute();
|
|
$row = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
if ($row)
|
|
{
|
|
$status = $row['result'];
|
|
}
|
|
|
|
return $status;
|
|
}
|
|
|
|
public static function operation_and_not($stat1, $stat2)
|
|
{
|
|
$conn = connection::getPDOConnection();
|
|
|
|
$status = '0';
|
|
|
|
if(substr($stat1, 0, 2) === '0x')
|
|
{
|
|
$stat1 = self::hex2bin(substr($stat1, 2));
|
|
}
|
|
if(substr($stat2, 0, 2) === '0x')
|
|
{
|
|
$stat2 = self::hex2bin(substr($stat2, 2));
|
|
}
|
|
|
|
$sql = 'select bin(0b' . trim($stat1) . ' & ~0b' . trim($stat2) . ') as result';
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute();
|
|
$row = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
if ($row)
|
|
{
|
|
$status = $row['result'];
|
|
}
|
|
|
|
return $status;
|
|
}
|
|
|
|
public static function operation_or($stat1, $stat2)
|
|
{
|
|
$conn = connection::getPDOConnection();
|
|
|
|
$status = '0';
|
|
|
|
if(substr($stat1, 0, 2) === '0x')
|
|
{
|
|
$stat1 = self::hex2bin(substr($stat1, 2));
|
|
}
|
|
if(substr($stat2, 0, 2) === '0x')
|
|
{
|
|
$stat2 = self::hex2bin(substr($stat2, 2));
|
|
}
|
|
|
|
$sql = 'select bin(0b' . trim($stat1) . ' | 0b' . trim($stat2) . ') as result';
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute();
|
|
$row = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
if ($row)
|
|
{
|
|
$status = $row['result'];
|
|
}
|
|
|
|
return $status;
|
|
}
|
|
|
|
public static function dec2bin($status)
|
|
{
|
|
$status = (string) $status;
|
|
|
|
if(!ctype_digit($status))
|
|
{
|
|
throw new \Exception('Non-decimal value');
|
|
}
|
|
|
|
$conn = connection::getPDOConnection();
|
|
|
|
$sql = 'select bin(' . $status . ') as result';
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute();
|
|
$row = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$status = '0';
|
|
|
|
if ($row)
|
|
{
|
|
$status = $row['result'];
|
|
}
|
|
|
|
return $status;
|
|
}
|
|
|
|
public static function hex2bin($status)
|
|
{
|
|
$status = (string) $status;
|
|
if(substr($status, 0, 2) === '0x')
|
|
{
|
|
$status = substr($status, 2);
|
|
}
|
|
|
|
if(!ctype_xdigit($status))
|
|
{
|
|
throw new \Exception('Non-hexadecimal value');
|
|
}
|
|
|
|
$conn = connection::getPDOConnection();
|
|
|
|
$sql = 'select BIN( CAST( 0x'.trim($status).' AS UNSIGNED ) ) as result';
|
|
|
|
$stmt = $conn->prepare($sql);
|
|
$stmt->execute();
|
|
$row = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
|
|
$status = '0';
|
|
|
|
if ($row)
|
|
{
|
|
$status = $row['result'];
|
|
}
|
|
|
|
return $status;
|
|
}
|
|
|
|
}
|