DataObjects/Core_notify_recur.php

[Pman.Core] / DataObjects / Events.php

diff --git a/DataObjects/Events.php b/DataObjects/Events.php
index 6828826..33d1b76 100644 (file)
--- a/DataObjects/Events.php
+++ b/DataObjects/Events.php
@@ -189,13 +189,76 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
             
             
         }
+        // since roo does not support autojoin yet..
+        if (!isset($q['_distinct'])) {
+            $this->autoJoinExtra();
+        }
         
         
         
         
+            
+    }
+     
+    function autoJoinExtra()
+    {
+        //$ret = parent::autoJoin();
+        // DB_DataObject::debugLevel(1);
         
+        // now try and magically join person_table to the right table..
+        $tn = $this->tableName();
+        $pt = DB_DataObject::Factory($this->tableName());
+        $pt->selectAdD();
+        $pt->selectAdD('distinct(person_table) as person_table');
+        $pt->whereAdd('person_table IS NOT NULL AND LENGTH(person_table) > 0');
+        $tbls = $pt->fetchAll('person_table');
+        $pers = DB_DataObject::Factory('Person');
+        $ptbl = $pers->tableName();
+        if (!in_array($ptbl,$tbls)) {
+            $tbls[] = $ptbl;
+            
+        }
+        foreach($tbls as $tbl) {
+            
+            // find all the columns from the joined table..
+            $st = DB_DataObject::Factory($tbl);
+            $tcols = array_keys($st->table());
+            
+            $cond = "{$tn}.person_table = '{$tbl}'";
+            if ($tbl == $ptbl) {
+                $cond = "( $cond OR {$tn}.person_table  = '')";
+            }
+            
+            foreach($tcols as $col) {
+                if ($col == 'passwd') {
+                    continue;
+                }
+                $cols[$col]  = isset($cols[$col] ) ? $cols[$col]  : array();
+                $cols[$col][] = "WHEN $cond  THEN join_person_table_{$tbl}.{$col}";
+            }
+            // id's are hard coded...
+            
+            $this->_join .= "
+                LEFT JOIN {$tbl} AS  join_person_table_{$tbl}
+                    ON {$tn}.person_id = join_person_table_{$tbl}.id
+                        AND $cond
+            ";
+        }
+        foreach($cols as $col=>$whens) {
             
+            $this->selectAdd("
+                    CASE
+                        ". implode("\n", $whens) ." 
+                        ELSE ''
+                    END
+                    as person_table_{$col}"
+            );
+        }
+        //return $ret;
+         
     }
+    
+    
     /**
      * check who is trying to access this. false == access denied..
      * @return {boolean} true if access is allowed.
@@ -238,16 +301,15 @@ class Pman_Core_DataObjects_Events extends DB_DataObject
         $pg = $ff->page;
         $au = $pg->getAuthUser();
         
-        if ($ff->cli && empty($au) && isset($obj->person_id)) {
-            
+        if ($ff->cli) { // && empty($au) && isset($obj->person_id)) {
+            $au = false;
            // $au = DB_DataObject::Factory('Person'); // not always a person..
            // $au->get($obj->person_id);
         } 
-         
-         
-         
+          
         $this->person_name = $au && !empty($au->name) ? $au->name : '';
         $this->person_id = $au ? $au->id : -1;
+        $this->person_table = $au ? $au->tableName() : '';
         $this->ipaddr = isset($_SERVER["REMOTE_ADDR"]) ? $_SERVER["REMOTE_ADDR"] : 'cli';
         $this->action = $act;
         $this->on_table = $obj ? $obj->tableName() : '';