Compare commits

..

13 Commits

Author SHA1 Message Date
as2252258 154d9d74d6 1 2021-12-17 04:43:20 +08:00
as2252258 2c61abff01 1 2021-12-17 04:41:00 +08:00
as2252258 b4ce762cf3 1 2021-12-17 04:26:54 +08:00
as2252258 4b3c2234af 1 2021-12-17 04:24:40 +08:00
as2252258 7ee78a9642 1 2021-12-17 04:24:01 +08:00
as2252258 f9838f781d 1 2021-12-17 04:23:12 +08:00
as2252258 848416af4f 1 2021-12-17 04:22:13 +08:00
as2252258 0216e761be 1 2021-12-17 04:17:53 +08:00
as2252258 acf6631c5c 1 2021-12-17 04:15:59 +08:00
as2252258 64e4307a57 1 2021-12-12 06:37:52 +08:00
as2252258 ab672127e6 1 2021-12-12 02:46:30 +08:00
as2252258 6e5b545a1e 1 2021-12-12 02:45:39 +08:00
as2252258 8229395e6d 1 2021-12-12 02:41:31 +08:00
6 changed files with 882 additions and 839 deletions
+843 -820
View File
File diff suppressed because it is too large Load Diff
+25 -6
View File
@@ -24,10 +24,13 @@ class Context extends BaseContext
*/
public static function setContext($id, $context, $coroutineId = null): mixed
{
if (Coroutine::getCid() === -1) {
return static::$_contents[$id] = $context;
}
return Coroutine::getContext($coroutineId)[$id] = $context;
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
if (Coroutine::getCid() !== -1) {
return Coroutine::getContext($coroutineId)[$id] = $context;
}
return static::$_contents[$id] = $context;
}
/**
@@ -38,6 +41,9 @@ class Context extends BaseContext
*/
public static function increment($id, int $value = 1, $coroutineId = null): bool|int
{
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
if (!isset(Coroutine::getContext($coroutineId)[$id])) {
Coroutine::getContext($coroutineId)[$id] = 0;
}
@@ -52,6 +58,9 @@ class Context extends BaseContext
*/
public static function decrement($id, int $value = 1, $coroutineId = null): bool|int
{
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
if (!isset(Coroutine::getContext($coroutineId)[$id])) {
Coroutine::getContext($coroutineId)[$id] = 0;
}
@@ -81,6 +90,9 @@ class Context extends BaseContext
*/
private static function loadByContext($id, $default = null, $coroutineId = null): mixed
{
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
return Coroutine::getContext($coroutineId)[$id] ?? $default;
}
@@ -115,6 +127,9 @@ class Context extends BaseContext
*/
public static function remove(string $id, $coroutineId = null)
{
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
if (!static::hasContext($id, $coroutineId)) {
return;
}
@@ -165,11 +180,15 @@ class Context extends BaseContext
*/
private static function searchByCoroutine($id, $key = null, $coroutineId = null): bool
{
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
if (!isset(Coroutine::getContext($coroutineId)[$id])) {
return false;
}
if ($key !== null) {
return isset((Coroutine::getContext($coroutineId)[$id] ?? [])[$key]);
$value = Coroutine::getContext($coroutineId)[$id];
if ($key !== null && is_array($value)) {
return isset($value[$key]);
}
return true;
}
+5 -5
View File
@@ -66,11 +66,11 @@ class Json
{
$params['code'] = $code;
if (!is_string($message)) {
$params['param'] = $message;
if (!empty($data)) {
$params['exPageInfo'] = $data;
}
$params['message'] = 'System success.';
$params['message'] = 'System success.';
$params['param'] = $message;
if (!empty($data)) {
$params['exPageInfo'] = $data;
}
} else {
$params['message'] = $message;
$params['param'] = $data;
+3 -3
View File
@@ -68,7 +68,7 @@ class Gii
$this->input = $input;
$this->db = $db;
$make = $this->input->getArgument('action');
$make = $this->input->getOption('make');
if (empty($make)) {
throw new Exception('构建类型不能为空~');
}
@@ -120,8 +120,8 @@ class Gii
private function makeByDatabases($make, InputInterface $input): array
{
$redis = Kiri::getDi()->get(Redis::class);
if ($input->hasArgument('name')) {
$this->tableName = $input->getArgument('name');
if ($input->hasOption('name')) {
$this->tableName = $input->getOption('name');
$redis->del('column:' . $this->tableName);
}
return match ($make) {
+5 -5
View File
@@ -32,9 +32,9 @@ class GiiCommand extends Command
protected function configure()
{
$this->setName('sw:gii')
->addArgument('action', InputArgument::REQUIRED)
->addArgument('name', InputArgument::OPTIONAL)
->addArgument('databases', InputArgument::OPTIONAL)
->addOption('make','m', InputArgument::OPTIONAL)
->addOption('name','t', InputArgument::OPTIONAL)
->addOption('databases','d', InputArgument::OPTIONAL)
->setDescription('./snowflake sw:gii make=model|controller|task|interceptor|limits|middleware name=xxxx');
}
@@ -52,12 +52,12 @@ class GiiCommand extends Command
$gii = Kiri::app()->get('gii');
$connections = Kiri::app()->get('db');
if (($db = $input->getArgument('databases')) != null) {
if (($db = $input->getOption('databases')) != null) {
$gii->run($connections->get($db), $input);
return 1;
}
$action = $input->getArgument('action');
$action = $input->getOption('make');
if (!in_array($action, ['model', 'controller'])) {
$gii->run(null, $input);
return 1;
+1
View File
@@ -17,6 +17,7 @@ abstract class Attribute implements INote
* @param mixed|string $method
* @return mixed
*/
#[\ReturnTypeWillChange]
public function execute(mixed $class, mixed $method = ''): mixed
{
// TODO: Implement execute() method.