X-Git-Url: http://git.roojs.org/?a=blobdiff_plain;f=DataObjects%2FCore_enum.php;h=97f6a61ae4c80eccde217d82e46581164317099e;hb=95164514241447b76a197711a74d0f4368474e4a;hp=f39189c59e59ec2520ef502b44a6335afff6a258;hpb=4a9ffd7d54ba7a1db1e4443f3ba851ac3780aa08;p=Pman.Core diff --git a/DataObjects/Core_enum.php b/DataObjects/Core_enum.php index f39189c5..97f6a61a 100644 --- a/DataObjects/Core_enum.php +++ b/DataObjects/Core_enum.php @@ -1,6 +1,6 @@ whereAdd("etype = ''"); + $this->whereAdd("core_enum.etype = ''"); } // this should be handled by roo... using '!name[0]' .... @@ -57,6 +57,19 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject core_enum.display_name LIKE '%{$name}%' "); } + if(!empty($q['query']['search_begins'])) { + $name = $this->escape($q['query']['search_begins']); + // 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'); + } } @@ -130,11 +143,13 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject $tn = $this->tableName(); $x = $this->factory($tn); - if(!($old->etype == $request['etype'] && $old->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'); } } } @@ -143,33 +158,68 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject $tn = $this->tableName(); $x = $this->factory($tn); - if(empty($req['etype'])){ + if(empty($req['etype']) || !strlen(trim($req['etype'])) ){ + + if (empty($req['name']) || !strlen(trim($req['name']))) { + $roo->jerr('name or etype missing'); + } + if($x->get('name', $req['name'])){ - $roo->jerr('name is exsiting'); + $roo->jerr("name already exists - '{$req['name']}'" ); } - }else{ + } else if (!empty($req['_bulk_names'])) { + + $lines = explode("\n", $req['_bulk_names']); + foreach($lines as $l) { + $l = trim($l); + if (!strlen($l)) { + continue; + } + $bits = explode(',', $l); + $rr = array( + 'etype' => $req['etype'], + 'name' => array_shift($bits) + ); + + $rr['display_name'] = empty($bits) ? $rr['name'] : $bits[0]; + + $x = $this->factory($tn); + $x->beforeInsert($rr, $roo); + $x->setFrom($rr); + $x->insert(); + + } + $roo->jok("inserted"); + + } else { + if (empty($req['name']) || !strlen(trim($req['name']))) { + $roo->jerr('name missing'); + } + $x->whereAdd("etype = '{$this->escape($req['etype'])}' AND name = '{$this->escape($req['name'])}'"); $x->find(true); if($x->count() > 0){ - $roo->jerr('is exsiting'); + $roo->jerr("name already exists - '{$req['name']}'" ); } } } - 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) + + function onUpdate($old, $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!!?? if ($old->etype != $this->etype) { $x->query("SELECT core_enum_seqmax_update('". $this->escape($old->etype) ."')"); } - if($this->name != $old->name && empty($old->etype) && empty($this->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)."'"); } @@ -317,7 +367,7 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject //$t->is_system_enum = 1; // this should be on the caller.. - if (!empty($row['seqid'])) { + if (!empty($row['seqid']) && !is_numeric($row['seqid'])) { $t->seqid = $seq_id; $seq_id++; } @@ -325,11 +375,16 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject $t->insert(); }else{ $t->find(true); // fetch it.. + $o = clone($t); + if ( isset($row['is_system_enum'])) { $t->is_system_enum = isset($row['is_system_enum']) ? $row['is_system_enum'] : $t->is_system_enum; - - $t->update(); } + + $t->display_name = isset($row['display_name']) ? $row['display_name'] : ''; + + $t->update($o); + } if (!empty($row['cn'])) { $this->initEnums($row['cn'], array('etype' => $t->name)); @@ -338,7 +393,7 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject } - function merge($to, $roo) + function merge($merge_to, $roo) { $affects = array(); @@ -354,7 +409,7 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject $affects[$tbl .'.' . $col] = true; } } - print_R($affects);exit; + foreach($affects as $k => $true) { $ka = explode('.', $k); @@ -368,7 +423,7 @@ class Pman_Core_DataObjects_Core_enum extends DB_DataObject foreach ($chk->fetchAll() as $c){ $cc = clone ($c); - $c->{$ka[1]} = $to; + $c->{$ka[1]} = $merge_to; $c->update($cc); } }