mirror of
https://github.com/lkddi/nexusphp.git
synced 2026-04-15 04:52:18 +08:00
bonus redemption limit click frequency
This commit is contained in:
50
nexus/Database/NexusLock.php
Normal file
50
nexus/Database/NexusLock.php
Normal file
@@ -0,0 +1,50 @@
|
||||
<?php
|
||||
|
||||
namespace Nexus\Database;
|
||||
|
||||
use Illuminate\Cache\LuaScripts;
|
||||
use Illuminate\Cache\RedisLock;
|
||||
|
||||
class NexusLock extends RedisLock
|
||||
{
|
||||
|
||||
/**
|
||||
* @var \Redis
|
||||
*/
|
||||
protected $redis;
|
||||
/**
|
||||
* NexusLock constructor.
|
||||
* @param string $name
|
||||
* @param int $seconds
|
||||
* @param null $owner
|
||||
*/
|
||||
public function __construct($name, $seconds, $owner = null)
|
||||
{
|
||||
parent::__construct(NexusDB::redis(), $name, $seconds, $owner);
|
||||
}
|
||||
|
||||
/**
|
||||
* Attempt to acquire the lock.
|
||||
*
|
||||
* @return bool
|
||||
*/
|
||||
public function acquire()
|
||||
{
|
||||
if ($this->seconds > 0) {
|
||||
return $this->redis->set($this->name, $this->owner, ['nx', 'ex' => $this->seconds]) == true;
|
||||
} else {
|
||||
return $this->redis->setnx($this->name, $this->owner) == true;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Release the lock.
|
||||
*
|
||||
* @return bool
|
||||
*/
|
||||
public function release()
|
||||
{
|
||||
return (bool) $this->redis->eval(LuaScripts::releaseLock(), [$this->name, $this->owner], 1);
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user