DataObjects/Core_group.php
[Pman.Core] / DataObjects / Core_group.php
1 <?php
2 /**
3  * Table Definition for Groups
4  *
5  * group types
6  *
7  * 0 = permission group..
8  * 1 = team
9  * 2 = contact group
10  *
11  *
12  *  NOTE - used to be called Groups ....
13  *
14  */
15 class_exists('DB_DataObject') ? '' : require_once 'DB/DataObject.php';
16
17 class Pman_Core_DataObjects_Core_group extends DB_DataObject
18 {
19     ###START_AUTOCODE
20     /* the code below is auto generated do not remove the above tag */
21
22     public $__table = 'core_group';                          // table name
23     public $id;                              // int(11)  not_null primary_key auto_increment
24     public $name;                            // string(64)  not_null
25     public $type;                            // int(11)
26     public $leader;                          // int(11)  not_null
27     public $is_system;                       // used by timesheets?
28
29     /* the code above is auto generated do not remove the tag below */
30     ###END_AUTOCODE
31
32
33     function personTable()
34     {
35         $ff = HTML_FlexyFramework::get();
36         return empty($ff->Pman['authTable']) ? 'core_person' : $ff->Pman['authTable'];
37     }
38
39
40     // group types??
41     function applyFilters($q, $au, $roo)
42     {
43         if (!empty($q['query']['name_starts'])) {
44             $v = $this->escape($q['query']['name_starts']);
45             $this->whereAdd("{$this->tableName()}.name like '{$v}%'");
46         }
47         
48         if(!empty($q['_count_member_by_name'])){
49             
50             $core_group = DB_DataObject::factory('core_group');
51             
52             if($core_group->get('name', $q['_count_member_by_name'])){
53                 $roo->jok($core_group->memberCount());
54             }
55         }
56
57         $cgm = DB_DataObject::Factory('core_group_member')->tableName();
58         /*$cgmDBObj = DB_DataObject::Factory('core_group_member');
59         $cpObj = DB_DataObject::Factory('core_person');
60         $cgm = DB_DataObject::Factory('core_group_member')->tableName();
61         $cpObj->active = 1; // set the where condition with active = 1*/
62         DB_DataObject::debugLevel(1);
63         $this->selectAdd("
64            (
65             SELECT 
66                 count(user_id) 
67             FROM 
68                 {$cgm}
69             WHERE 
70                 {$this->tableName()}.id = {$cgm}.group_id
71             ) 
72             AS group_member_count            
73         ");
74          DB_DataObject::debugLevel();       
75     
76         /*$cgmDBObj->joinAdd($cpObj);
77         $this->joinAdd($cgmDBObj);
78         DB_DataObject::debugLevel();*/
79     }
80
81     function toEventString() {
82         return $this->name;
83     }
84
85     function beforeInsert($q,$roo)
86     {
87         if (isset($q['_action'])) {
88             // add // sub...
89             $g = clone($this);
90             if (!$g->get($q['group_id'])) {
91                 $roo->jerr("missing group id");
92
93             }
94              foreach(explode(',', $q['user_ids']) as $uid) {
95                 switch($q['_action']) {
96                     case 'add':
97                         $g->addMember($uid,$roo);
98                         break;
99                     case 'sub':
100                         $g->removeMember($uid);
101                         break;
102                     default:
103                         $roo->jerr('invalid action');
104                 }
105             }
106             $roo->jok('updated');
107
108         }
109
110     }
111
112
113     function beforeDelete()
114     {
115         $x = DB_DataObject::factory('core_group_right');
116         $x->query("DELETE FROM {$x->tableName()} WHERE group_id = {$this->id}");
117         $x = DB_DataObject::factory('core_group_member');
118         $x->query("DELETE FROM {$x->tableName()} WHERE group_id = {$this->id}");
119     }
120     /**
121      * check who is trying to access this. false == access denied..
122      */
123     function checkPerm($lvl, $au)
124     {
125         return $au->hasPerm("Core.Groups", $lvl);
126     }
127     function onUpdate($old, $req, $roo)
128     {
129         $this->ensureLeaderMembership($roo);
130     }
131     function onInsert($req, $roo)
132     {
133         $this->ensureLeaderMembership($roo);
134     }
135     function ensureLeaderMembership($roo)
136     {
137
138         // groups - make sure the leader is a member...
139         if (!$this->type || !$this->leader)
140         {
141             return true;
142         }
143
144         $pi = DB_DataObject::factory('core_person');
145         $pi->get($this->leader);
146
147         $p = DB_DataObject::factory('core_group_member');
148         $p->group_id = $this->id;
149         $p->user_id = $this->leader;
150         //$p->type = 1; //???????
151         if (!$p->count()) {
152
153             $p->insert();
154             $roo->addEvent("ADD", $p, $this->toEventString(). " Added " . $pi->toEventString());
155         }
156
157     }
158
159
160     function memberCount()
161     {
162         $gm = DB_Dataobject::factory('core_group_member');
163         $gm->group_id = $this->id;
164         $gm->autoJoin();
165         $gm->whereAdd('join_user_id_id.active = 1');
166         //PDO_DAtaObject::DebugLevel(1); 
167         return $gm->count();
168     }
169
170     function memberIds()
171     {
172         $gm = DB_Dataobject::factory('core_group_member');
173         $gm->group_id = $this->id;
174         $gm->autoJoin();
175         $gm->whereAdd('join_user_id_id.active = 1');
176         return $gm->fetchAll('user_id');
177
178     }
179     function isMember($person)
180     {
181         $gm = DB_Dataobject::factory('core_group_member');
182         $gm->group_id = $this->id;
183         $gm->user_id = is_object($person) ? $person->id : $person;
184         return $gm->count();
185     }
186
187     function addMember($person,$roo = false)
188     {
189         if ($this->name == "Empty Group") {
190             $roo->jerr('Cannot add the person into Empty Group');
191         }
192         $gm = DB_Dataobject::factory('core_group_member');
193         $gm->group_id = $this->id;
194         $gm->user_id = is_object($person) ? $person->id : $person;
195         if (!$gm->count()) {
196             $gm->insert();
197         }
198     }
199
200     function removeMember($person)
201     {
202         $gm = DB_Dataobject::factory('core_group_member');
203         $gm->group_id = $this->id;
204         $gm->user_id = is_object($person) ? $person->id : $person;
205
206         if ($gm->find(true)) {
207             $gm->delete();
208         }
209     }
210
211     /**
212      *
213      *  grab a list of members - default is the array of person objects..
214      *  @param $what  = set to 'email' to get a list of email addresses.
215      *
216      *
217      */
218
219     function members($what = false)
220     {
221         $ids = $this->memberIds();
222         if (!$ids) {
223             return array();
224         }
225         //$p = DB_Dataobject::factory(empty($ff->Pman['authTable']) ? 'Person' : $ff->Pman['authTable']);
226         // groups databse is hard coded to person.. so this should not be used for other tables.????
227         $p = DB_Dataobject::factory( 'core_person' );
228
229         $p->whereAdd('id IN ('. implode(',', $ids) .')');
230         $p->active = 1;
231
232         $p->orderBy('name');
233         return $p->fetchAll($what);
234     }
235
236
237
238
239     function lookup($k,$v = false) {
240         if ($v === false) {
241             $v = $k;
242             $k = 'id';
243         }
244         $this->get($k,$v);
245
246         return $this;
247     }
248
249     function lookUpMembers($name, $what=false)
250     {
251         if (!$this->get('name', $name)) {
252             return array();
253         }
254         return $this->members($what);
255
256     }
257
258     function lookupMembersByGroupId($id, $what=false)
259     {
260         if (!$this->get($id)) {
261             return array();
262         }
263
264         return $this->members($what);
265     }
266
267     function postListFilter($ar, $au, $req)
268     {
269         if(empty($req['_add_everyone'])){
270             return $ar;
271         }
272
273         $ret[] = array( 'id' => 0, 'name' => 'EVERYONE');
274         $ret[] = array( 'id' => -1, 'name' => 'NOT_IN_GROUP');
275         return array_merge($ret, $ar);
276
277     }
278
279     function initGroups()
280     {
281         
282         $g = DB_DataObject::factory($this->tableName());
283         $g->type = 0;
284         $g->name = 'Administrators';
285         if ($g->count()) {
286             $g->find(true);;
287         } else {
288             $g->insert();
289             $gr = DB_DataObject::factory('core_group_right');
290             $gr->genDefault();
291         }
292         $m = $g->members();
293         if (empty($m)) {
294             $p = DB_DAtaObject::factory('core_person');
295             $p->orderBy('id ASC');
296             $p->limit(1);
297             if ($p->find(true)) {
298                 $g->addMember($p);
299             }
300
301
302         }
303     }
304
305     function initDatabase($roo, $data)
306     {
307         $this->initGroups();
308
309         foreach($data as $gi) {
310             $g = DB_DataObject::factory($this->tableName());
311             $g->setFrom($gi);
312
313             if(!$g->find(true)){
314                 $g->insert();
315             }
316
317             if(count($g->members()) || empty($gi['members'])){
318                 continue;
319             }
320
321             foreach ($gi['members'] as $m){
322                 $g->addMember($m);
323             }
324
325         }
326
327     }
328
329 }