This commit is contained in:
2021-06-04 18:33:42 +08:00
parent 10805c1022
commit 558008ad08
3 changed files with 5 additions and 8 deletions
+3 -2
View File
@@ -15,6 +15,7 @@ use Database\Traits\HasBase;
use Exception; use Exception;
use ReflectionException; use ReflectionException;
use Snowflake\Channel; use Snowflake\Channel;
use Snowflake\Event;
use Snowflake\Exception\NotFindClassException; use Snowflake\Exception\NotFindClassException;
use Snowflake\Snowflake; use Snowflake\Snowflake;
@@ -310,8 +311,8 @@ class ActiveRecord extends BaseActiveRecord
} }
$data = array_merge($data, $this->runRelate()); $data = array_merge($data, $this->runRelate());
// $class = Snowflake::app()->getChannel(); $class = Snowflake::app()->getChannel();
// $class->push($this, static::class); $class->push($this, static::class);
return $data; return $data;
} }
+1 -5
View File
@@ -70,11 +70,7 @@ class Redis extends Component
if (method_exists($this, '____' . $name)) { if (method_exists($this, '____' . $name)) {
$data = $this->{'____' . $name}(...$arguments); $data = $this->{'____' . $name}(...$arguments);
} else { } else {
$client = $this->proxy(); $data = $this->proxy()->{$name}(...$arguments);
$data = $client->{$name}(...$arguments);
if ($client->getLastError() !== null) {
var_dump($client->getLastError());
}
} }
return $data; return $data;
} }
+1 -1
View File
@@ -79,7 +79,7 @@ class Channel extends Component
if ($channel->isEmpty()) { if ($channel->isEmpty()) {
return call_user_func($closure); return call_user_func($closure);
} }
return $channel->dequeue(); return clone $channel->dequeue();
} }