129 lines
3.2 KiB
PHP
129 lines
3.2 KiB
PHP
<?php defined('SYSPATH') or die('No direct access allowed.');
|
|
|
|
/**
|
|
* This class extends Kohana's [ORM] class to create defaults for OSB.
|
|
*
|
|
* @package OSB
|
|
* @subpackage Core
|
|
* @category ORM
|
|
* @author Deon George
|
|
* @copyright (c) 2010 Open Source Billing
|
|
* @license http://dev.osbill.net/license.html
|
|
*/
|
|
abstract class ORMOSB extends ORM {
|
|
/**
|
|
* @var string Database to connect to
|
|
*/
|
|
protected $_db = 'default';
|
|
|
|
protected $_created_column = array('column'=>'date_orig','format'=>TRUE);
|
|
protected $_updated_column = array('column'=>'date_last','format'=>TRUE);
|
|
|
|
public function rules() {
|
|
return array(
|
|
'id'=>array(
|
|
array('ORMOSB::get_next_id',array(':validation',':model',':field')),
|
|
),
|
|
'site_id'=>array(
|
|
array('ORMOSB::set_site_id',array(':validation',':model',':field')),
|
|
),
|
|
);
|
|
}
|
|
|
|
/**
|
|
* This function will enhance the [Validate::filter], since it always passes
|
|
* the value as the first argument and sometimes functions need that to not
|
|
* be the first argument.
|
|
*
|
|
* Currently this implements:
|
|
* [date()][date-ref]
|
|
*
|
|
* [date-ref]: http://www.php.net/date
|
|
*
|
|
* This function will throw an exception if called without a function
|
|
* defined.
|
|
*
|
|
* @param mixed $val Value to be processed
|
|
* @param string $func Name of function to call
|
|
* @param string $arg Other arguments for the function
|
|
* @todo This has probably changed in KH 3.1
|
|
*/
|
|
final public static function _filters($val,$func,$arg) {
|
|
switch ($func) {
|
|
case 'date':
|
|
return date($arg,$val);
|
|
default:
|
|
throw new Exception(sprintf(_('Unknown function: %s (%s,%s)'),$func,$arg,$val));
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get Next record id
|
|
*
|
|
* @param array Validate object
|
|
* @param string Primary Key
|
|
*/
|
|
// @todo Do we need the $array?
|
|
public static function get_next_id(Validation $array,$model,$field) {
|
|
if (! is_null($model->$field))
|
|
return TRUE;
|
|
|
|
$model->_changed[$field] = $field;
|
|
|
|
$ido = ORM::factory('module')
|
|
->where('name','=',$model->_table_name)
|
|
->find();
|
|
|
|
if (! $ido->loaded())
|
|
throw new Kohana_Exception('Problem getting record_id for :table',array(':table'=>$model->_table_name));
|
|
|
|
$model->$field = $ido->record_id->next_id($ido->id);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
// @todo Do we need the $array?
|
|
public static function set_site_id(Validation $array,$model,$field) {
|
|
if (! is_null($model->$field))
|
|
return TRUE;
|
|
|
|
$model->_changed[$field] = $field;
|
|
$model->$field = Config::siteid();
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
public static function serialize_array(ORM $model,$field,$value) {
|
|
if (is_null($value))
|
|
return TRUE;
|
|
|
|
if (! is_array($value))
|
|
return FALSE;
|
|
|
|
$model->_changed[$field] = $field;
|
|
$model->$field = serialize($value);
|
|
}
|
|
|
|
public function save(Validation $validation = NULL) {
|
|
// Find any fields that have changed, and that are blobs, and encode them.
|
|
if ($this->_changed)
|
|
foreach ($this->_changed as $c)
|
|
if ($this->_table_columns[$c]['data_type'] == 'blob')
|
|
$this->$c = $this->blob($this->$c,TRUE);
|
|
|
|
return parent::save($validation);
|
|
}
|
|
|
|
public function changed() {
|
|
return $this->_changed;
|
|
}
|
|
|
|
/**
|
|
* Retrieve and Store DB BLOB data.
|
|
*/
|
|
protected function blob($data,$set=FALSE) {
|
|
return $set ? gzcompress(serialize($data)) : unserialize(gzuncompress($data));
|
|
}
|
|
}
|
|
?>
|