DataObjects/Core_enum.php
[Pman.Core] / DataObjects / Core_enum.php
1 <?php
2 /**
3  * Table Definition for core company
4  */
5 require_once 'DB/DataObject.php';
6
7 class Pman_Core_DataObjects_Core_enum extends DB_DataObject 
8 {
9     ###START_AUTOCODE
10     /* the code below is auto generated do not remove the above tag */
11
12     public $__table = 'core_enum';                       // table name
13     public $id;                              // int(11)  not_null primary_key auto_increment
14     public $etype;                           // string(32)  not_null
15     public $name;                            // string(255)  not_null
16     public $active;                          // int(2)  not_null
17     public $seqid;                           // int(11)  not_null multiple_key
18     public $seqmax;                           // int(11)  not_null multiple_key
19     public $display_name;
20     
21     /* the code above is auto generated do not remove the tag below */
22     ###END_AUTOCODE
23     
24     function applyFilters($q, $au)
25     {
26         
27 //        DB_DataObject::debugLevel(1);
28         if (!empty($q['query']['empty_etype'])) {
29             $this->whereAdd("core_enum.etype = ''");
30         }
31         
32         // this should be handled by roo... using '!name[0]' ....
33         if(!empty($q['!name'])){
34             $names = is_array($q['!name']) ? $q['!name'] : explode(',', $q['!name']);
35             foreach($names as $name){
36                 $name  = $this->escape($name);
37                 $this->whereAdd("
38                     core_enum.name NOT IN ('$name')
39                 ");
40             }
41         }
42         if(!empty($q['search']['display_name'])) {
43             $name = $this->escape($q['search']['display_name']);
44             // ilike on postgres?!?
45             $this->whereAdd("
46                 core_enum.display_name LIKE '{$name}%'
47             ");
48             
49         }
50         
51         if(!empty($q['query']['search'])) {
52             $name = $this->escape($q['query']['search']);
53             // ilike on postgres?!?
54             $this->whereAdd("
55                     core_enum.name LIKE '%{$name}%'
56                 OR
57                     core_enum.display_name LIKE '%{$name}%'
58             ");
59         }
60         if (isset($q['_etypes'])) {
61             $this->whereAddIn('core_enu.etype', explode(',', $q['_etypes']), 'string');
62         }
63         
64     }
65     
66     function checkPerm($lvl, $au, $req=null)
67     {
68         if (!$au) {
69             return false;
70         }
71         return true;
72     }
73     
74     
75     function autoJoinCmsTranslate($lang)
76     {
77         $l = $this->escape($lang);
78         
79         $this->_join .= "
80             LEFT JOIN 
81                 cms_templatestr 
82             ON
83                 cms_templatestr.lang = '$l'
84             AND
85                 cms_templatestr.on_table = 'core_enum'
86             AND
87                 cms_templatestr.on_id = core_enum.id
88             AND
89                 cms_templatestr.on_col = 'display_name'
90         ";
91         
92         $this->selectAdd("
93             CASE WHEN 
94                 '$l' = 'en' THEN display_name 
95             ELSE
96                 CASE WHEN cms_templatestr.txt IS NOT NULL AND cms_templatestr.txt != '' THEN
97                     cms_templatestr.txt
98                 ELSE
99                     display_name
100                 END
101             END as  display_name_tr 
102         ");
103         
104     }
105     
106     function postListFilter($data, $authUser, $q) {
107         
108         if(!empty($q['cmsTab'])){
109             $ret = array();
110             foreach($data as $k=>$v){
111                 if($v['name'] == 'element'){
112                     continue;
113                 }
114                 $ary = $v;
115                 if($ary['name'] == 'page'){
116                     $ary['display_name'] = $v['display_name'].' / Elements';
117                 }
118                 $ret[] = $ary;
119             }
120             $data = $ret;
121         }
122         
123         return $data;
124         
125     }
126     
127     
128     function beforeUpdate($old, $request,$roo)
129     {   
130         if(!empty($request['_merge_id'])){
131             $this->merge($request['_merge_id'], $roo);
132         }
133         
134         $tn = $this->tableName();
135         $x = $this->factory($tn);
136         // check if record exists?
137         if(isset($request['etype']) &&   !($old->etype == $request['etype'] && $old->name == $request['name'])){
138             $x->whereAdd("etype = '{$this->escape($request['etype'])}' AND name = '{$this->escape($request['name'])}'");
139             $x->find(true);
140             if($x->count() > 0){
141                 $roo->jerr('record already exists');
142             }
143         }
144     }
145     function beforeInsert($req, $roo)
146     {
147         $tn = $this->tableName();
148         $x = $this->factory($tn);
149         
150         if(empty($req['etype'])){
151             if($x->get('name', $req['name'])){
152                 $roo->jerr('name is exsiting');
153             }
154         }else{
155             $x->whereAdd("etype = '{$this->escape($req['etype'])}' AND name = '{$this->escape($req['name'])}'");
156             $x->find(true);
157             if($x->count() > 0){
158                 $roo->jerr('is exsiting');
159             }
160         }
161     }
162     
163     function onInsert($req)
164     {
165         $x = $this->factory($this->tableName());
166         $x->query("SELECT core_enum_seqmax_update('". $this->escape($this->etype) ."')"); // no idea why need to do this!!??
167          
168     }
169     function onUpdate($old, $req)
170     {
171         $x = $this->factory($this->tableName());
172         $x->query("SELECT core_enum_seqmax_update('". $this->escape($this->etype) ."')"); // no idea why need to do this!!??
173         if ($old->etype != $this->etype) {
174             $x->query("SELECT core_enum_seqmax_update('". $this->escape($old->etype) ."')");
175         }
176         
177         if($this->name != $old->name && !empty($old->name) && empty($old->etype) && empty($this->etype)){
178             $x->query("UPDATE core_enum SET etype = '". $this->escape($this->name) 
179                 ."' WHERE etype = '". $this->escape($old->name)."'");
180         }
181     }
182     
183     /**
184      * lookup by etype/name and return id
185      */
186     function lookup($etype,$name) {
187         $ce = DB_DataObject::Factory('core_enum');
188         $ce->etype = $etype;
189         $ce->name = $name;
190         if ($ce->find(true)) {
191             return $ce->id;
192         }
193         return 0;
194     }
195     
196     function lookupCreate($etype,$name, $display_name=false) {
197         
198         // check
199         $ce = DB_DataObject::Factory('core_enum');
200         $ce->setFrom(array(
201             'etype' => '',
202             'name' => $etype
203         ));
204         if (!$ce->find(true)) {
205             $ce->display_name = $etype;
206             $ce->insert();
207         }
208         
209         $ce = DB_DataObject::Factory('core_enum');
210         $ce->etype = $etype;
211         $ce->name = $name;
212         if ($ce->find(true)) {
213             return $ce->id;
214         }
215         $ce->active = 1;
216         $ce->display_name = $display_name === false ? $ce->name : $display_name;
217         return  $ce->insert();
218         
219     }
220     
221     function lookupById($id) {
222         $ce = DB_DataObject::Factory('core_enum');
223         $ce->get($id);
224         return $ce;
225     }
226     
227     /**
228      * 
229      * 
230      * 
231      * @param string $etype
232      * @param array $name array of name
233      * @return array ID of core_enum 
234      */
235     
236     function lookupAllByName($etype,$names) {
237         $ce = DB_DataObject::Factory('core_enum');
238         $ce->etype = $etype;
239         $ce->whereAddIn('name', $names, 'string');
240         
241         if ($ce->count() > 0) {
242             return $ce->fetchAll('id');
243         }
244         return array();
245     }
246     
247     function fetchAllByType($etype, $fetchArg1=false, $fetchArg2=false, $fetchArg3=false)
248     {
249         $x = DB_DataObject::factory('core_enum');
250         $x->etype = $etype;
251         $x->active = 1;
252         $x->orderBy('seqid ASC');
253         return $x->fetchAll($fetchArg1, $fetchArg2, $fetchArg3);
254     }
255     
256     function lookupObject($etype,$name, $create= false)
257     {
258         
259         static $cache = array();
260         $key = "$etype:$name";
261         if (isset($cache[$key]) ) {
262             return $cache[$key];
263         }
264         $ce = DB_DataObject::Factory('core_enum');
265         $ce->etype = $etype;
266         $ce->name = $name;
267         if ($ce->find(true)) {
268             $cache[$key] = $ce;
269             return $ce;
270         }
271         if ($create) {
272             $ce->active = 1;
273             $ce->insert();
274             $cache[$key] = $ce;
275             return $ce->id;
276             
277         }
278         
279         
280         return false;
281         
282     }
283      // fixme - all calls should be to initDatabase, we need to remove initEnums
284     function initDatabase($roo, $data)
285     {
286         $this->initEnums($data);
287     }
288     
289     
290     function initEnums($data, $base = array())
291     {
292         // base only contains etype...
293         //print_r($data);
294         $seq_id = 0;
295         if (!empty($base['etype'])) {
296             $seq_id = 1;
297             $t = DB_DAtaObject::Factory('core_enum');
298             $t->etype = $base['etype'];
299             $t->selectAdD();
300             $t->selectAdD('max(seqid) as seqid');
301             if ($t->find(true)) {
302                 $seq_id = $t->seqid+1;
303             }
304         }
305         foreach($data as $row) {
306             $t = DB_DAtaObject::Factory('core_enum');
307             
308             $t->etype = isset($row['etype']) ? $row['etype'] : '';
309             $t->etype = isset($base['etype']) ? $base['etype'] : $t->etype ;
310             
311             $t->name = isset($row['name']) ? $row['name'] : '';
312             
313             if (empty($t->name)) {
314                 print_R($data);
315                 die("ERROR: invalid name used for core_enum\n\n");
316             }
317             
318             if (!$t->count()) {
319                 // base already gave it the etype..
320                 $t->setFrom($row);
321                 
322                 
323                 //$t->is_system_enum = 1; // this should be on the caller..
324                 
325                 if (!empty($row['seqid'])) {
326                     $t->seqid = $seq_id;
327                     $seq_id++;
328                 }
329                 
330                 $t->insert();
331             }else{
332                 $t->find(true); // fetch it..
333                 if ( isset($row['is_system_enum'])) {
334                      $t->is_system_enum = isset($row['is_system_enum']) ? $row['is_system_enum'] : $t->is_system_enum;
335                     
336                     $t->update();
337                 }
338             }
339             if (!empty($row['cn'])) {
340                 $this->initEnums($row['cn'], array('etype' => $t->name));
341             }
342         }
343         
344     }
345     
346     function merge($merge_to, $roo)
347     {
348         $affects  = array();
349         
350         $all_links = $GLOBALS['_DB_DATAOBJECT']['LINKS'][$this->_database];
351         
352         foreach($all_links as $tbl => $links) {
353             foreach($links as $col => $totbl_col) {
354                 $to = explode(':', $totbl_col);
355                 if ($to[0] != $this->tableName()) {
356                     continue;
357                 }
358                 
359                 $affects[$tbl .'.' . $col] = true;
360             }
361         }
362         
363         foreach($affects as $k => $true) {
364             $ka = explode('.', $k);
365
366             $chk = DB_DataObject::factory($ka[0]);
367             
368             if (!is_a($chk,'DB_DataObject')) {
369                 $roo->jerr('Unable to load referenced table, check the links config: ' .$ka[0]);
370             }
371             
372             $chk->{$ka[1]} = $this->id;
373
374             foreach ($chk->fetchAll() as $c){
375                 $cc = clone ($c);
376                 $c->{$ka[1]} = $merge_to;
377                 $c->update($cc);
378             }
379         }
380         
381         $this->delete();
382         
383         $roo->jok('Merged');
384         
385     }
386     
387     
388 }