X-Git-Url: http://git.roojs.org/?a=blobdiff_plain;f=DataObjects%2FCore_enum.php;h=bb129bb00b40ac661eb8ddd545f56867c4ead8e8;hb=5c4a5e6295a06d5ae65a8297275f630ab0a93ce1;hp=cdc63f9e9ee7f0b53ad4d98bb35a3c5927771810;hpb=604a7e2537205e266b99f77290807130e72d0aa4;p=Pman.Core diff --git a/DataObjects/Core_enum.php b/DataObjects/Core_enum.php index cdc63f9e..bb129bb0 100644 --- a/DataObjects/Core_enum.php +++ b/DataObjects/Core_enum.php @@ -21,12 +21,12 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject /* the code above is auto generated do not remove the tag below */ ###END_AUTOCODE - function applyFilters($q, $au) + function applyFilters($q, $au, $roo) { - //DB_DataObject::debugLevel(1); +// DB_DataObject::debugLevel(1); if (!empty($q['query']['empty_etype'])) { - $this->whereAdd("etype = ''"); + $this->whereAdd("core_enum.etype = ''"); } // this should be handled by roo... using '!name[0]' .... @@ -48,14 +48,30 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject } - $this->autoJoin(); - print_r($this); - if(!empty($q['id'])){ - $this->id = $q['id']; + if(!empty($q['query']['search'])) { + $name = $this->escape($q['query']['search']); + // ilike on postgres?!? + $this->whereAdd(" + core_enum.name LIKE '%{$name}%' + OR + core_enum.display_name LIKE '%{$name}%' + "); + } + if (isset($q['_etypes'])) { + $this->whereAddIn('core_enum.etype', explode(',', $q['_etypes']), 'string'); } } + function checkPerm($lvl, $au, $req=null) + { + if (!$au) { + return false; + } + return true; + } + + function autoJoinCmsTranslate($lang) { $l = $this->escape($lang); @@ -77,7 +93,11 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject CASE WHEN '$l' = 'en' THEN display_name ELSE - cms_templatestr.txt + CASE WHEN cms_templatestr.txt IS NOT NULL AND cms_templatestr.txt != '' THEN + cms_templatestr.txt + ELSE + display_name + END END as display_name_tr "); @@ -106,14 +126,20 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject function beforeUpdate($old, $request,$roo) - { + { + if(!empty($request['_merge_id'])){ + $this->merge($request['_merge_id'], $roo); + } + $tn = $this->tableName(); $x = $this->factory($tn); - if(!($old->etype == $request['etype'] && $old->name == $request['name'])){ - $x->whereAdd("etype = '{$request['etype']}' AND name = '{$request['name']}'"); + // check if record exists? + if(isset($request['etype']) && !($old->etype == $request['etype'] && $old->name == $request['name'])){ + $x->whereAdd("etype = '{$this->escape($request['etype'])}' AND name = '{$this->escape($request['name'])}'"); + $x->whereAdd("id != ".((int) $this->id)); $x->find(true); if($x->count() > 0){ - $roo->jerr('is exsiting'); + $roo->jerr('a duplicate record already exists'); } } } @@ -121,26 +147,28 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject { $tn = $this->tableName(); $x = $this->factory($tn); - + DB_DataObject::debugLevel(1); if(empty($req['etype'])){ if($x->get('name', $req['name'])){ $roo->jerr('name is exsiting'); } }else{ - $x->whereAdd("etype = '{$req['etype']}' AND name = '{$req['name']}'"); + $x->whereAdd("etype = '{$this->escape($req['etype'])}' AND name = '{$this->escape($req['name'])}'"); $x->find(true); if($x->count() > 0){ - $roo->jerr('is exsiting'); + pritn_R($x);exit; + $roo->jerr('is exsiting??'); } } } - function onInsert($req) + function onInsert($req, $roo) { $x = $this->factory($this->tableName()); $x->query("SELECT core_enum_seqmax_update('". $this->escape($this->etype) ."')"); // no idea why need to do this!!?? } + function onUpdate($old, $req) { $x = $this->factory($this->tableName()); @@ -148,6 +176,11 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject if ($old->etype != $this->etype) { $x->query("SELECT core_enum_seqmax_update('". $this->escape($old->etype) ."')"); } + + if($this->name != $old->name && !empty($old->name) && empty($old->etype) && empty($this->etype)){ + $x->query("UPDATE core_enum SET etype = '". $this->escape($this->name) + ."' WHERE etype = '". $this->escape($old->name)."'"); + } } /** @@ -163,6 +196,30 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject return 0; } + function lookupCreate($etype,$name, $display_name=false) { + + // check + $ce = DB_DataObject::Factory('core_enum'); + $ce->setFrom(array( + 'etype' => '', + 'name' => $etype + )); + if (!$ce->find(true)) { + $ce->display_name = $etype; + $ce->insert(); + } + + $ce = DB_DataObject::Factory('core_enum'); + $ce->etype = $etype; + $ce->name = $name; + if ($ce->find(true)) { + return $ce->id; + } + $ce->active = 1; + $ce->display_name = $display_name === false ? $ce->name : $display_name; + return $ce->insert(); + + } function lookupById($id) { $ce = DB_DataObject::Factory('core_enum'); @@ -179,10 +236,10 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject * @return array ID of core_enum */ - function lookupAllByName($etype,$name) { + function lookupAllByName($etype,$names) { $ce = DB_DataObject::Factory('core_enum'); $ce->etype = $etype; - $ce->whereAddIn('name', $name, 'string'); + $ce->whereAddIn('name', $names, 'string'); if ($ce->count() > 0) { return $ce->fetchAll('id'); @@ -289,5 +346,46 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject } + function merge($merge_to, $roo) + { + $affects = array(); + + $all_links = $GLOBALS['_DB_DATAOBJECT']['LINKS'][$this->_database]; + + foreach($all_links as $tbl => $links) { + foreach($links as $col => $totbl_col) { + $to = explode(':', $totbl_col); + if ($to[0] != $this->tableName()) { + continue; + } + + $affects[$tbl .'.' . $col] = true; + } + } + + foreach($affects as $k => $true) { + $ka = explode('.', $k); + + $chk = DB_DataObject::factory($ka[0]); + + if (!is_a($chk,'DB_DataObject')) { + $roo->jerr('Unable to load referenced table, check the links config: ' .$ka[0]); + } + + $chk->{$ka[1]} = $this->id; + + foreach ($chk->fetchAll() as $c){ + $cc = clone ($c); + $c->{$ka[1]} = $merge_to; + $c->update($cc); + } + } + + $this->delete(); + + $roo->jok('Merged'); + + } + }