X-Git-Url: http://git.roojs.org/?a=blobdiff_plain;f=DataObjects%2FCore_group.php;h=613a77d07a69dedf225aab179d9e214e172ade47;hb=f5aa5d161bc0428db89f56aa318dbf03ddff22bc;hp=643a6687125e7f697c5dcacb998db6fc66f01cf5;hpb=1dae893c17371a0fc4add5699ecdedacbfe1bc22;p=Pman.Core diff --git a/DataObjects/Core_group.php b/DataObjects/Core_group.php index 643a6687..613a77d0 100644 --- a/DataObjects/Core_group.php +++ b/DataObjects/Core_group.php @@ -40,6 +40,7 @@ class Pman_Core_DataObjects_Core_group extends DB_DataObject // group types?? function applyFilters($q, $au, $roo) { + if (!empty($q['query']['name_starts'])) { $v = $this->escape($q['query']['name_starts']); $this->whereAdd("{$this->tableName()}.name like '{$v}%'"); @@ -53,45 +54,42 @@ class Pman_Core_DataObjects_Core_group extends DB_DataObject $roo->jok($core_group->memberCount()); } } - - -// $cp = DB_DataObject::Factory('core_person')->tableName(); -// $cgm = DB_DataObject::Factory('core_group_member')->tableName(); + if(!empty($q['_is_in_group'])){ + $this->selectAdd(" + COALESCE(( + SELECT + COUNT(id) + FROM + core_group_member + WHERE + user_id = {$q['_is_in_group']} + AND + group_id = {$this->tableName()}.id + ), 0) AS is_in_group + "); + } + + + $cp = DB_DataObject::Factory('core_person')->tableName(); + $cgm = DB_DataObject::Factory('core_group_member')->tableName(); $this->selectAdd(" ( - SELECT - COUNT(core_group_member.user_id) - FROM - core_group_member - LEFT JOIN - core_person - ON - core_person.id = core_group_member.user_id - WHERE - core_group_member.group_id = core_group.id + SELECT COUNT(${cgm}.user_id) + FROM + {$cgm} + LEFT JOIN + {$cp} + ON + ${cp}.id = {$cgm}.user_id + WHERE + ${cgm}.group_id = {$this->tableName()}.id AND - core_person.active = 1 - ) AS group_member_count + ${cp}.active = 1 + ) AS group_member_count "); - /*WHERE - {$this->tableName()}.id = core_group_member.group_id - AND - core_group_member.user_id = core_person.id - AND - core_person.active = 1 - )*/ - -// $this->whereAdd("{$this->tableName()}.id = core_group_member.group_id"); -// $this->whereAdd("core_group_member.user_id = core_person.id"); -// $this->whereAdd("core_person.active = 1"); - - - /*$cgmDBObj->joinAdd($cpObj); - $this->joinAdd($cgmDBObj); - DB_DataObject::debugLevel();*/ } function toEventString() { @@ -107,7 +105,11 @@ class Pman_Core_DataObjects_Core_group extends DB_DataObject $roo->jerr("missing group id"); } - foreach(explode(',', $q['user_ids']) as $uid) { + + $user_ids = explode(',', $q['user_ids']); + + foreach($user_ids as $uid) { + switch($q['_action']) { case 'add': $g->addMember($uid,$roo); @@ -208,6 +210,7 @@ class Pman_Core_DataObjects_Core_group extends DB_DataObject $gm = DB_Dataobject::factory('core_group_member'); $gm->group_id = $this->id; $gm->user_id = is_object($person) ? $person->id : $person; + if (!$gm->count()) { $gm->insert(); } @@ -324,11 +327,24 @@ class Pman_Core_DataObjects_Core_group extends DB_DataObject foreach($data as $gi) { $g = DB_DataObject::factory($this->tableName()); + + $o = false; + + if($g->get('name', $gi['name'])){ + $o = clone($g); + } + + $display_name = (isset($gi['display_name'])) ? $gi['display_name'] : ''; + + unset($gi['display_name']); + $g->setFrom($gi); - - if(!$g->find(true)){ - $g->insert(); + + if(empty($o) || empty($o->display_name)){ + $g->display_name = $display_name; } + + (empty($o)) ? $g->insert() : $g->update($o); if(count($g->members()) || empty($gi['members'])){ continue;