Repository支持钩子事件监听功能

Author: jqhph

src/Bean/Annotation/AdminRepositoryListener.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace Swoft\Admin\Bean\Annotation;
+
+/**
+ *
+ * @Annotation
+ * @Target({"CLASS"})
+ */
+class AdminRepositoryListener
+{
+    /**
+     * @var string
+     */
+    private $listener = '';
+
+    public function __construct(array $values)
+    {
+        if (!empty($values['value'])) {
+            $this->listener = $values['value'];
+        }
+        if (!empty($values['listener'])) {
+            $this->listener = $values['listener'];
+        }
+    }
+
+    /**
+     * @return string
+     */
+    public function getValue()
+    {
+        return $this->listener;
+    }
+
+}

src/Bean/Collector/AdminRepositoryCollector.php

@@ -37,7 +37,7 @@ public static function collect(
             $value = $objectAnnotation->getValue();
 
             if ($value) {
-                Admin::registerRepository($value, new $className);
+                Admin::registerRepository($value, $className);
             }
         }
 

src/Bean/Collector/AdminRepositoryListenerCollector.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace Swoft\Admin\Bean\Collector;
+
+use Swoft\Admin\Bean\Annotation\AdminRepositoryListener;
+use Swoft\Bean\CollectorInterface;
+
+/**
+ * The collector AdminRepositoryListener
+ */
+class AdminRepositoryListenerCollector implements CollectorInterface
+{
+    /**
+     * @var array
+     */
+    private static $values = [];
+
+    /**
+     * @param string $className
+     * @param object $objectAnnotation
+     * @param string $propertyName
+     * @param string $methodName
+     * @param null   $propertyValue
+     *
+     * @return mixed
+     */
+    public static function collect(
+        string $className,
+        $objectAnnotation = null,
+        string $propertyName = '',
+        string $methodName = '',
+        $propertyValue = null
+    )
+    {
+        if ($objectAnnotation instanceof AdminRepositoryListener) {
+            $value = $objectAnnotation->getValue();
+            if (!isset(self::$values[$value])) {
+                self::$values[$value] = [];
+            }
+
+            self::$values[$value][] = $className;
+        }
+
+        return null;
+    }
+
+    /**
+     * @return array
+     */
+    public static function getCollector(string $repository = null)
+    {
+        if ($repository) {
+            return isset(self::$values[$repository]) ? self::$values[$repository] : [];
+        }
+
+        return self::$values;
+    }
+}

src/Bean/Parser/AdminRepositoryListenerParser.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace Swoft\Admin\Bean\Parser;
+
+use Swoft\Admin\Bean\Collector\AdminRepositoryListenerCollector;
+use Swoft\Bean\Parser\AbstractParser;
+
+/**
+ * The parser of AdminRepositoryListener
+ */
+class AdminRepositoryListenerParser extends AbstractParser
+{
+    /**
+     * @param string  $className
+     * @param mixed   $objectAnnotation
+     * @param string  $propertyName
+     * @param string  $methodName
+     * @param null    $propertyValue
+     * @return null
+     */
+    public function parser(
+        string $className,
+        $objectAnnotation = null,
+        string $propertyName = '',
+        string $methodName = '',
+        $propertyValue = null
+    )
+    {
+        AdminRepositoryListenerCollector::collect($className, $objectAnnotation, $propertyName, $methodName, $propertyValue);
+
+        return [$className, Scope::SINGLETON, ''];
+    }
+}

src/Bean/Parser/AdminRepositoryParser.php

@@ -4,6 +4,7 @@
 
 use Swoft\Admin\Bean\Collector\AdminRepositoryCollector;
 use Swoft\Bean\Parser\AbstractParser;
+use Swoft\Bean\Annotation\Scope;
 
 /**
  * The parser of Repository
@@ -27,6 +28,7 @@ public function parser(
     )
     {
         AdminRepositoryCollector::collect($className, $objectAnnotation, $propertyName, $methodName, $propertyValue);
-        return null;
+
+        return [$className, Scope::SINGLETON, ''];
     }
 }

src/Bean/Wrapper/AdminRepositoryListenerWrapper.php

@@ -0,0 +1,75 @@
+<?php
+
+namespace Swoft\Admin\Bean\Wrapper;
+
+use Swoft\Bean\Annotation\Inject;
+use Swoft\Bean\Annotation\Value;
+use Swoft\Bean\Wrapper\AbstractWrapper;
+use Swoft\Admin\Bean\Annotation\AdminRepositoryListener;
+use Swoft\Rpc\Client\Bean\Annotation\Reference;
+
+class AdminRepositoryListenerWrapper extends AbstractWrapper
+{
+    /**
+     * 类注解
+     *
+     * @var array
+     */
+    protected $classAnnotations = [
+        AdminRepositoryListener::class,
+    ];
+
+    /**
+     * 属性注解
+     *
+     * @var array
+     */
+    protected $propertyAnnotations = [
+        Inject::class,
+        Value::class,
+        Reference::class,
+    ];
+
+    /**
+     * 方法注解
+     *
+     * @var array
+     */
+    protected $methodAnnotations = [
+    ];
+
+    /**
+     * 是否解析类注解
+     *
+     * @param array $annotations
+     * @return bool
+     */
+    public function isParseClassAnnotations(array $annotations): bool
+    {
+        return isset($annotations[AdminRepositoryListener::class]);
+    }
+
+    /**
+     * 是否解析属性注解
+     *
+     * @param array $annotations
+     * @return bool
+     */
+    public function isParsePropertyAnnotations(array $annotations): bool
+    {
+        return isset($annotations[Inject::class])
+            || isset($annotations[Value::class])
+            || isset($annotations[Reference::class]);
+    }
+
+    /**
+     * 是否解析方法注解
+     *
+     * @param array $annotations
+     * @return bool
+     */
+    public function isParseMethodAnnotations(array $annotations): bool
+    {
+        return false;
+    }
+}

src/Repository/InvalidRepositoryListenerException.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace Swoft\Admin\Repository;
+
+class InvalidRepositoryListenerException extends \Exception
+{
+}

src/Repository/Repository.php

@@ -33,7 +33,7 @@ public static function repository()
      * @param string $controllerClass
      * @param RepositoryInterface $repository
      */
-    public static function registerRepository(string $controllerClass, RepositoryInterface $repository)
+    public static function registerRepository(string $controllerClass, string $repository)
     {
         static::$repositories[$controllerClass] = new RepositoryProxy($repository);
     }

src/Repository/RepositoryEventInterface.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Swoft\Admin\Repository;
+
+use Swoft\Admin\Form;
+
+interface RepositoryEventInterface
+{
+    /**
+     * @param Form $form
+     */
+    public function beforeInsert(Form $form);
+
+    /**
+     * @param Form $form
+     * @param mixed $result 新增数据返回结果
+     */
+    public function afterInsert(Form $form, $result);
+
+    /**
+     * @param Form $form
+     */
+    public function beforeUpdate(Form $form);
+
+    /**
+     * @param Form $form
+     * @param mixed $result 编辑数据返回结果
+     */
+    public function afterUpdate(Form $form, $result);
+
+    /**
+     * @param Form $form
+     */
+    public function beforeDelete(Form $form);
+
+    /**
+     * @param Form $form
+     * @param $result
+     */
+    public function afterDelete(Form $form, $result);
+
+}