X-Git-Url: http://git.roojs.org/?p=Pman.Core;a=blobdiff_plain;f=DataObjects%2FCore_company.php;h=0e02579d9e752fd541475f796b4f0911b48badd4;hp=c7e703f641ee996d6643721f5a312b38ed757836;hb=a942ea8f21bc8948eac7fcbc36a1b9736379f2e0;hpb=b514ca4f505aeb893d796f4cec9efeb2b32c5007 diff --git a/DataObjects/Core_company.php b/DataObjects/Core_company.php index c7e703f6..0e02579d 100644 --- a/DataObjects/Core_company.php +++ b/DataObjects/Core_company.php @@ -2,7 +2,7 @@ /** * Table Definition for Companies */ -require_once 'DB/DataObject.php'; +class_exists('DB_DataObject') ? '' : require_once 'DB/DataObject.php'; class Pman_Core_DataObjects_Core_Company extends DB_DataObject { @@ -40,7 +40,8 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject function applyFilters($q, $au) { - $tn = $this->tableName(); + + $tn = $this->tableName(); $this->selectAdd("i18n_translate('c' , {$tn}.country, 'en') as country_display_name "); $tn = $this->tableName(); @@ -48,7 +49,7 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject $x = DB_DataObject::factory('core_company'); $x->comptype= 'OWNER'; $x->find(true); - + if (!empty($q['query']['company_project_id'])) { $add = ''; if (!empty($q['query']['company_include_self'])) { @@ -57,6 +58,7 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject if (!empty($q['query']['company_not_self'])) { $add = " AND {$tn}.id != {$x->id}"; } + $pids = array(); $pid = $q['query']['company_project_id']; if (strpos($pid, ',')) { @@ -102,8 +104,8 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject ) as comptype_display_name "); - if(!empty($q['search']['name'])){ - $s = $this->escape($q['search']['name']); + if(!empty($q['query']['name'])){ + $s = $this->escape($q['query']['name']); $this->whereAdd(" {$tn}.name LIKE '%$s%' "); @@ -121,7 +123,9 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject } // ---------- AUTHENTICATION - function isAuth() + // not sure where authetnication via company is used?? posibly media-outreach + + function isAuth() { $db = $this->getDatabaseConnection(); $sesPrefix = $db->dsn['database']; @@ -240,15 +244,41 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject $this->update(); } - - - + } + + function beforeInsert($q, $roo) + { + if(!empty($q['_check_name'])){ + if($this->checkName()){ + $roo->jok('OK'); + } + + $roo->jerr('EXIST'); + } } function beforeUpdate($old, $q,$roo) { - if(!empty($request['_merge_id'])){ - $this->merge($request['_merge_id'], $roo); + + if(!empty($q['_flag_delete']) && $q['_flag_delete'] * 1 == 1){ + $this->deleted_dt = $this->sqlValue("NOW()"); + $this->deleted_by = $roo->getAuthUser()->id; + } + + if(!empty($q['_flag_undelete']) && $q['_flag_undelete'] * 1 == 1){ + $this->deleted_dt = ""; + $this->deleted_by = 0; + } + if(!empty($q['_check_name'])){ + if($this->checkName()){ + $roo->jok('OK'); + } + + $roo->jerr('EXIST'); + } + + if(!empty($q['_merge_id'])){ + $this->merge($q['_merge_id'], $roo); } if(!empty($this->is_system) && @@ -260,12 +290,18 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject function beforeDelete($req, $roo) { + // should check for members.... if(!empty($this->is_system) && ($old->code != $this->code || $old->name != $this->name) ){ $roo->jerr('This company is not allow to delete'); } + + + } + function onDelete($req, $roo) + { $img = DB_DataObject::factory('Images'); $img->ontable = $this->tableName(); $img->onid = $this->id; @@ -415,7 +451,7 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject $companies->insert(); $companies->onInsert(array(), $roo); } - function lookupOwner() + static function lookupOwner() { $enum = DB_DataObject::Factory('core_enum')->lookup('COMPTYPE', 'OWNER' ); $companies = DB_DataObject::factory('core_company'); @@ -425,4 +461,63 @@ class Pman_Core_DataObjects_Core_Company extends DB_DataObject } return false; } + + function merge($merge_to, $roo) + { + $affects = array(); + + $all_links = $this->databaseLinks(); + + 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'); + + } + + function checkName() + { + $company = DB_DataObject::factory('core_company'); + $company->setFrom(array( + 'name' => $this->name + )); + + if(!empty($this->id)){ + $company->whereAdd("id != {$this->id}"); + } + + if(!$company->find(true)){ + return true; + } + + return false; + } }