X-Git-Url: http://git.roojs.org/?p=Pman.Core;a=blobdiff_plain;f=Lock.php;h=b0e7ea9a2c05f14b13dd6e4ca26feb2eb1ed77be;hp=f0849cfbdc71a24c8df4d854bbf36e0453fdf78c;hb=refs%2Fheads%2Fwip_edward_T5851_download_old_offer_sheet;hpb=c69008b6df6edd8052e07856ed0d5bec31f8132d diff --git a/Lock.php b/Lock.php index f0849cfb..b0e7ea9a 100644 --- a/Lock.php +++ b/Lock.php @@ -1,6 +1,36 @@ post($action); + // + $this->jerr("invalid request"); + } + + function post($action) { // default action is to attempt to lock.. + $action = empty($action) || $action == 'lock' ? 'lock' : 'unlock'; + $this->$action(); + + } + + function unlock() + { + + if (empty($_REQUEST['id'])) { + $this->jerr("No lock id"); + } + $curlock = DB_DataObject::factory('core_locking'); + if (!$curlock->get($_REQUEST['id'])) { + $this->jok("No lock exists"); // been deleted before.. probably ok.. + } + + if ($curlock->person_id != $this->authUser->id) { + // this is an error conditon.. + $this->jerr("Lock id is invalid"); + } + + $curlock->delete(); + + $this->jok('unlocked'); + } + function lock() + { + if (empty($_REQUEST['on_id']) || empty($_REQUEST['on_table'])) { $this->jerr("Missing table or id"); } - $action = empty($action) ? 'lock' : 'unlock'; - $tab = str_replace('/', '',$_REQUEST['on_table']); // basic protection?? + + $tab = str_replace('/', '', strtolower($_REQUEST['on_table'])); // basic protection?? $x = DB_DataObject::factory($tab); if (!$x->get($_REQUEST['on_id'])) { $this->jerr("Item does not exist"); } + // is there a current lock on the item.. - $locked = false; - if ($curlock->find(true)) { - $locked = true; - } - $this->$action($curlock); - - } - - function unlock($curlock) - { - - $curlock = DB_DataObject::factory('Core_locking'); + $curlock = DB_DataObject::factory('core_locking'); $curlock->setFrom(array( 'on_id' => $_REQUEST['on_id'], - 'on_table' => $_REQUEST['on_table'], - 'person_id' => $this->authUser->id, + 'on_table' => strtolower($_REQUEST['on_table']) )); + // remove old locks.. + $llc = clone($curlock); + $exp = date('Y-m-d', strtotime('NOW - 1 WEEK')); + $llc->whereAdd("created < '$exp'"); + if ($llc->count()) { + $llc->find(); + while($llc->fetch()) { + $llcd = clone($llc); + $llcd->delete(); + + } + } + + + $curlock_ex = clone($curlock); + $curlock->person_id = $this->authUser->id; + + + $curlock_ex->whereAdd('person_id != '. $this->authUser->id); + $nlocks = $curlock_ex->count() ; + + $ret = false; - if (!$curlock->find()) { - $this->jok("No lock"); - } - while ($curlock->fetch()) { - $cc = clone($curlock); - $cc->delete(); + if ($nlocks && empty($_REQUEST['force'])) { + // DB_DataObjecT::debugLevel(1); + $ar = $curlock_ex->fetchAll('person_id', 'created'); + $p = DB_DataObject::factory('core_person'); + $p->selectAdd(); + $p->selectAdd('id,name,email'); + + $p->whereAddIn('id', array_keys($ar), 'int'); + $p->find(); + $ret = array(); + while ($p->fetch()) { + $ret[$p->id] = $p->toArray(); + $ret[$p->id]['lock_created'] = $ar[$p->id]; + } + $this->jok(array_values($ret)); + + } + // trash the lock if it belongs to current user.. + $ulocks = $curlock->count(); + if ($ulocks) { + // trash all the locks.. + $curlock = DB_DataObject::factory('core_locking'); + $curlock->setFrom(array( + 'on_id' => $_REQUEST['on_id'], + 'on_table' => strtolower($_REQUEST['on_table']), + 'person_id' => $this->authUser->id + )); + + $curlock->find(); + while($curlock->fetch()) { + $cc =clone($curlock); + $cc->delete(); + } + } + if ($nlocks && !empty($_REQUEST['force'])) { + // user has decied to delete eveyone elses locks.. + $curlock_ex->find(); + while($curlock_ex->fetch()) { + $cc =clone($curlock_ex); + $cc->delete(); + } } - $this->jok('unlocked'); + + // make a lock.. + + $curlock = DB_DataObject::factory('core_locking'); + $curlock->setFrom(array( + 'on_id' => $_REQUEST['on_id'], + 'on_table' => strtolower($_REQUEST['on_table']), + 'created' => date('Y-m-d H:i:s'), + 'person_id' => $this->authUser->id, + )); + $id = $curlock->insert(); + $this->jok( $id); + } + + } \ No newline at end of file