DataObjects/Core_watch.php

diff --git a/DataObjects/Core_watch.php b/DataObjects/Core_watch.php
index 5be7890..77ac4e9 100644 (file)
--- a/DataObjects/Core_watch.php
+++ b/DataObjects/Core_watch.php
@@ -59,9 +59,15 @@ class Pman_Core_DataObjects_Core_watch extends DB_DataObject
         }
         $w->active = 1;
         $w->medium = $medium;
-        $w->selectAdd();
-        $w->selectAdd("person_id, CONCAT(ontable, ':', onid) as onobject");
+        $ar = $w->fetchAll();
+        $ret = array();
+        foreach($ar as $o) {
+            if (!isset($ret[$o->person_id])) {
+                $ret[$o->person_id] = array();
+            }
+            $ret[$o->person_id][] = $o->ontable .':'. $o->onid;
+        }
         
-        return $this->fetchAll('person_id, onobject');
+        return $ret;
     }
 }