X-Git-Url: http://git.roojs.org/?a=blobdiff_plain;f=DataObjects%2FEvents.php;h=213e22408f431cbb20bc2d1ff5045bd5d08c0d66;hb=c78c59cea885484cb8e313fc7663fc18e4d81e6b;hp=643cb511abd310a97ecc1eb7e111473f071575cd;hpb=168eba8ffb244b696769fce9914c97f7b31bb91f;p=Pman.Core diff --git a/DataObjects/Events.php b/DataObjects/Events.php index 643cb511..213e2240 100644 --- a/DataObjects/Events.php +++ b/DataObjects/Events.php @@ -7,7 +7,7 @@ * * */ -require_once 'DB/DataObject.php'; +class_exists('DB_DataObject') ? '' : require_once 'DB/DataObject.php'; class Pman_Core_DataObjects_Events extends DB_DataObject { @@ -25,7 +25,8 @@ class Pman_Core_DataObjects_Events extends DB_DataObject public $person_id; // int(11) public $remarks; // blob(65535) blob public $person_table; // string(64) - + public $dupe_id; // int(11) + /* the code above is auto generated do not remove the tag below */ ###END_AUTOCODE @@ -37,14 +38,18 @@ class Pman_Core_DataObjects_Events extends DB_DataObject { $tn = $this->tableName(); // if not empty on_table + if(!empty($q['person_table'])){ $jt = DB_DataObject::factory($q['person_table']); + - if(!array_key_exists("{$jt->tableName()}_id", $this->table())){ // coz we have triiger on mysql... + + if(!array_key_exists("{$jt->tableName()}_id", $this->tableColumns())){ // coz we have triiger on mysql... $keys = $jt->keys(); $this->_join = "LEFT JOIN {$jt->tableName()} AS join_person_id_id ON (join_person_id_id.{$keys[0]}=Events.person_id)"; + $this->selectAdd(); $this->selectAs(); @@ -61,19 +66,20 @@ class Pman_Core_DataObjects_Events extends DB_DataObject } } else { - $person = 'Person'; + + $person = $au->tableName(); //'Person'; -- projects may not use person as the auth table... $cfg = HTML_FlexyFramework::get()->Pman; if (!empty($cfg['authTable'])) { $person =$cfg['authTable']; } $jt = DB_DataObject::factory($person); - $this->whereAdd(" - person_table = '{$jt->tableName()}' - OR - person_table = '' - OR person_table IS NULL" - ); // default to our standard.. - unless otherwise requested.. + //$this->whereAdd(" + // person_table = '{$jt->tableName()}' + // OR + // person_table = '' + // OR person_table IS NULL" + //); // default to our standard.. - unless otherwise requested.. } @@ -85,6 +91,11 @@ class Pman_Core_DataObjects_Events extends DB_DataObject $dt = date('Y-m-d' , strtotime($q['query']['to'])); $this->whereAdd(" {$tn}.event_when <= '$dt' "); } + + if(!empty($q['_with_dupe_count'])){ + $this->dupe_id = 0; + $this->selectAdd("(select count(*)+1 from Events ev_cnt where ev_cnt.dupe_id = {$tn}.id) as dupe_count"); + } /* if (!empty($q['query']['grouped']) && $q['query']['grouped'] == 'gr') { // grouped.. @@ -99,7 +110,8 @@ class Pman_Core_DataObjects_Events extends DB_DataObject if (!$au->hasPerm("Admin.Admin_Tab", 'S')) { //DB_DataObject::DebugLevel(1); // they can only view their changes.. - $this->person_id = $au->id; + $this->whereAdd("($tn.person_id = {$au->id} OR $tn.person_id = 0)"); +// $this->person_id = $au->id; } // _join = tablename,tablename... @@ -114,9 +126,7 @@ class Pman_Core_DataObjects_Events extends DB_DataObject // empty ontable queries.. these are valid.. $this->whereAdd("$tn.on_table = ''"); } - - - + if (isset($q['query']['person_sum'])) { //DB_DataObject::debugLevel(1); $this->_extra_cols = array('qty' ); @@ -163,7 +173,7 @@ class Pman_Core_DataObjects_Events extends DB_DataObject LEFT JOIN {$jtn} as join_on_id_{$jtn} ON {$tn}.on_id = join_on_id_{$jtn}.{$jk} AND on_table = '{$jtn}' "; - $keys = array_keys($x->table()); + $keys = array_keys($x->tableColumns()); if (isset($q['_join_cols'])) { $jcs = explode(',',$q['_join_cols'] ); //DB_DataObject::DebugLevel(1); @@ -207,6 +217,7 @@ class Pman_Core_DataObjects_Events extends DB_DataObject if (!$obj) { $roo->jerr("ontable is invalid"); } + /* if (!method_exists($obj,'relatedWhere')) { $roo->jerr( $q['_related_on_table'] . " Does not have method relatedWhere :" . implode(',', get_class_methods($obj))); @@ -230,12 +241,17 @@ class Pman_Core_DataObjects_Events extends DB_DataObject } $this->whereAdd(implode(' OR ' , $w)); + }*/ + if ($obj && method_exists($obj,'relatedEventsWhere')) { + $a = $obj->relatedEventsWhere($q,$roo); + if($a){ + $this->whereAdd($a); + } } - } // since roo does not support autojoin yet.. if (!isset($q['_distinct'])) { @@ -305,16 +321,32 @@ class Pman_Core_DataObjects_Events extends DB_DataObject } $this->person_name = $au && !empty($au->name) ? $au->name : ''; + //print_r($au); + //exit; + //$this->who = $au && !empty($au->name) ? $au->name : ''; if (empty($au) || (isset($au->id) && empty($au->id))) { // not authenticated - and a standard id based object $this->person_id = 0; } else { $col = $au->tableName() == "Person" ? 'person_id' : $au->tableName() . '_id'; // does $col exist? - $cols = $this->table(); + $cols = $this->tableColumns(); $col = isset($cols[$col]) ? $col : 'person_id'; // for BC.... - revert to using person_id $this->{$col} = $au->pid(); //$this->person_id = $au ? (!empty($au->id) ? $au->id : $au->pid()) : -1; + + $this->who = $au->name; + print_r($au->tableName()); + exit; + if($au->tableName() == "modx_users"){ + $e = PDO_DataObject::factory('ext_data'); + $e->setFrom(array( + 'userdata_id' => $au->pid(), + )); + if($e->find(true)){ + $this->who = $e->getUserName(); + } + } } $this->person_table = $au ? $au->tableName() : ''; $this->ipaddr = isset($_SERVER["REMOTE_ADDR"]) ? $_SERVER["REMOTE_ADDR"] : 'cli'; @@ -329,7 +361,9 @@ class Pman_Core_DataObjects_Events extends DB_DataObject $rem = array(); // should this really go in remarks? - if ($obj && method_exists($obj,'toEventString')) { - $rem[] = $obj->toEventString() ; + if($obj->toEventString() !== false){ + $rem[] = $obj->toEventString(); + } } $rem[] = $remarks; $this->remarks = implode(' : ', $rem); @@ -351,7 +385,7 @@ class Pman_Core_DataObjects_Events extends DB_DataObject } $ret = 0; - foreach(array_keys($new->table()) as $k) { + foreach(array_keys($new->tableColumns()) as $k) { // should we JSON serialize this? $n = empty($new->$k) ? '' : $new->$k; $o = empty($old->$k) || empty($old->$k) ? '' : $old->$k; @@ -450,15 +484,15 @@ class Pman_Core_DataObjects_Events extends DB_DataObject self::$deleted[] = $del; return true; } + static $extra_data = false; - function writeEventLog($extra_data = '') + static function writeEventLogExtra($data) { + self::$extra_data = $data; + } + + function logDir() { $ff = HTML_FlexyFramework::get(); - if (empty($ff->Pman['event_log_dir'])) { - return false; - } - - // add user (eg. www-data or local user if not..) if (function_exists('posix_getpwuid')) { $uinfo = posix_getpwuid( posix_getuid () ); @@ -466,10 +500,37 @@ class Pman_Core_DataObjects_Events extends DB_DataObject } else { $user = getenv('USERNAME'); // windows. } + + // DEPRICATED... + if (!empty($ff->Pman['event_log_dir'])) { + return $ff->Pman['event_log_dir'] . '/'.$user; + } + if (!empty($ff->Pman['storedir'])) { + return $ff->Pman['storedir'] .'/Events/'.$user; + + } + return false; + } + + + + function writeEventLog($extra_data = false) + { + $logdir = $this->logDir(); + if (!$logdir) { + return false; + } + + //print_r($this); - $file = $ff->Pman['event_log_dir']. '/'. $user. date('/Y/m/d/'). $this->id . ".json"; + $file = $logdir. date('/Y/m/d/'). $this->id . ".json"; if (!file_exists(dirname($file))) { - mkdir(dirname($file),0700,true); + + @mkdir(dirname($file),0700,true); // this might fail if it does not have correct permissions.. + if (!file_exists(dirname($file))) { + die("could not create $file - permissons are not correct"); // fatal, otherwise we loop!? + } + } // Remove all the password from logs... @@ -495,7 +556,7 @@ class Pman_Core_DataObjects_Events extends DB_DataObject $files[$k]['tmp_name'] = $this->id . '-'. $i; - $nf = $ff->Pman['event_log_dir']. '/'. $user. date('/Y/m/d/'). $files[$k]['tmp_name']; + $nf = $logdir . date('/Y/m/d/'). $files[$k]['tmp_name']; if (!copy($f['tmp_name'], $nf)) { print_r("failed to copy {$f['tmp_name']}...\n"); } @@ -511,9 +572,12 @@ class Pman_Core_DataObjects_Events extends DB_DataObject if (!empty(self::$deleted)) { $out['DELETED_DATAOBJECTS'] = self::$deleted; } - if (!empty($extra_data)) { + if ($extra_data !== false) { $out['EXTRA'] = $extra_data; } + if ( self::$extra_data !== false) { + $out['EXTRA_DATA'] = self::$extra_data; + } file_put_contents($file, json_encode($out)); @@ -567,22 +631,16 @@ class Pman_Core_DataObjects_Events extends DB_DataObject function retrieveEventLog() { - $ff = HTML_FlexyFramework::get(); - if (empty($ff->Pman['event_log_dir'])) { - return false; - } - if (function_exists('posix_getpwuid')) { - $uinfo = posix_getpwuid( posix_getuid () ); + $logdir = $this->logDir(); + if (!$logdir) { + return false; - $user = $uinfo['name']; - } else { - $user = getenv('USERNAME'); // windows. } $date = date('/Y/m/d/', strtotime($this->event_when)); - $file = $ff->Pman['event_log_dir']. '/'. $user. $date. $this->id . ".json"; + $file = $logdir. $date. $this->id . ".json"; if (!file_exists(dirname($file))) { return false; } @@ -634,13 +692,38 @@ class Pman_Core_DataObjects_Events extends DB_DataObject $table->setFrom($d); + /* + * need to use the old id + */ $table->id = $d['id']; $table->sequenceKey(false,false); - $table->insert(); + $table->insert(); + + if($table->tableName() == 'crm_mailing_list_member'){ + $ml = DB_DataObject::factory('crm_mailing_list'); + if(!$ml->get($table->mailing_list_id)){ + continue; + } + + $mlm = DB_DataObject::factory('crm_mailing_list_member'); + $mlm->setFrom(array( + 'mailing_list_id' => $table->mailing_list_id, + 'is_active' => 1 + )); + + $o = clone($ml); + $ml->no_members = $mlm->count(); + $ml->update($o); + } } $roo->jok('RESTORE'); } + function selectAddPersonEmail() + { + $this->selectAdd('join_person_id_id.email as email'); + + } }