diff --git a/src/AbstractMysqlRepository.php b/src/AbstractMysqlRepository.php index 4405901..89be39c 100644 --- a/src/AbstractMysqlRepository.php +++ b/src/AbstractMysqlRepository.php @@ -60,7 +60,7 @@ abstract class AbstractMysqlRepository extends AbstractRepository implements Mys $in = $this->getProperties($object, function ($value){ return (is_string($value)) ? $this->mysql->escapeStr($value) : $value; }); - if($this->getDebug()) {$this->debug($object, $in, $table, $this->getRepositoryStack()); exit;} + if($this->isDebug()) {$this->debug($object, $in, $table, ...$this->getDebugExtraData()); exit;} try { if (!empty($object->getId()) && !empty($this->mysql->findById($table, $object->getId()))) { $this->mysql->updateById($table, $in, $object->getId()); @@ -79,7 +79,7 @@ abstract class AbstractMysqlRepository extends AbstractRepository implements Mys $in = array_map(function ($value){ return (is_string($value)) ? $this->mysql->escapeStr($value) : $value; }, $data); - if($this->getDebug()) {$this->debug($data, $in, $table, $this->getRepositoryStack()); exit;} + if($this->isDebug()) {$this->debug($data, $in, $table, ...$this->getDebugExtraData()); exit;} try { if (!empty($data[$primaryKey]) && !empty($this->mysql->findById($table, $data[$primaryKey], $primaryKey))) { $this->mysql->updateById($table, $in, $data[$primaryKey]); @@ -181,12 +181,19 @@ abstract class AbstractMysqlRepository extends AbstractRepository implements Mys /** * @return bool */ - private function getDebug(): bool { + private function isDebug(): bool { if(!empty($this->debug)) return $this->debug; if(!empty(static::DEBUG)) return static::DEBUG; return false; } + /** + * @return array + */ + protected function getDebugExtraData() : array { + return [$this->getRepositoryStack(), $this->getClassesCache(), $this->getAttributesObjectsCache()]; + } + /** * @param ...$arg * @return void diff --git a/src/Attribute/Entity.php b/src/Attribute/Entity.php new file mode 100644 index 0000000..5e98c7a --- /dev/null +++ b/src/Attribute/Entity.php @@ -0,0 +1,14 @@ +getName()][0])){ + self::$attributeObjects[$class->getName()][0] = !empty($class->getAttributes(Entity::class)) + ? $class->getAttributes(Entity::class)[0]->newInstance() + : new Entity(); + } + /** @var Entity $entityAttributes */ + $entityAttributes = self::$attributeObjects[$class->getName()][0]; + $value = []; foreach($class->getProperties() as $property){ $prop[$property->getName()] = ($property->hasType()) ? $property->getType()->getName() : ""; + // значение в массиве по ключю с именем свойства if(array_key_exists($property->getName(), $data)){ $value[$property->getName()] = $data[$property->getName()]; @@ -40,44 +52,58 @@ class AbstractDataObject { // если есть внутренний метод (приоритетная обработка) if($class->hasMethod('set'.ucfirst($property->getName()))) { $object->{'set'.ucfirst($property->getName())}($value[$property->getName()] ?? null); + $case[$property->getName()] = 'Method set'.ucfirst($property->getName()); } // Если тип свойства класс (valueObject) elseif($property->hasType() && class_exists($property->getType()->getName())) { + // значение объект if(is_object($value[$property->getName()])){ $object->{$property->getName()} = $value[$property->getName()]; + $case[$property->getName()] = 'VO: Object'; } + // значение есть и не пустое elseif(isset($value[$property->getName()]) && $value[$property->getName()] !== ""){ $object->{$property->getName()} = new ($property->getType()->getName())($value[$property->getName()]); + $case[$property->getName()] = 'VO: NewInstance'; } - elseif($withNull && isset($value[$property->getName()])){ + elseif(($withEmpty && empty($entityAttributes->withoutEmpty)) && array_key_exists($property->getName(), $value)){ $object->{$property->getName()} = new ($property->getType()->getName())($value[$property->getName()]); + $case[$property->getName()] = 'VO: NewInstance withEmpty'; } // Значения нет и VO может быть без параметров - elseif($withNull && self::isEmptyAvailable($property->getType()->getName())) { + elseif(($withEmpty && empty($entityAttributes->withoutEmpty)) && self::isEmptyAvailable($property->getType()->getName())) { $object->{$property->getName()} = new ($property->getType()->getName())(); + $case[$property->getName()] = 'VO: Without params'; } + } // Базовые типы при наличии значения elseif(array_key_exists($property->getName(), $value)){ if(!$property->hasType()){ $object->{$property->getName()} = $value[$property->getName()]; + $case[$property->getName()] = 'Base: Hasn`t type'; } elseif(in_array($property->getType()->getName(), ['float', 'int'])){ if(is_numeric($value[$property->getName()])) $object->{$property->getName()} = $value[$property->getName()]; + $case[$property->getName()] = 'Base: Number'; } elseif($property->getType()->getName() == 'bool'){ $object->{$property->getName()} = (bool)$value[$property->getName()]; + $case[$property->getName()] = 'Base: Boolean'; } - elseif(isset($value[$property->getName()]) && $value[$property->getName()] !== ""){ + elseif(isset($value[$property->getName()])){ $object->{$property->getName()} = $value[$property->getName()]; + $case[$property->getName()] = 'Base: NotNull'; } - elseif($withNull && isset($value[$property->getName()])){ + elseif($property->getType()->allowsNull()){ $object->{$property->getName()} = $value[$property->getName()]; + $case[$property->getName()] = 'Base: Null'; } } } self::$stack[$object::class." #".spl_object_id($object)]['properties'] = $prop ?? []; self::$stack[$object::class." #".spl_object_id($object)]['values'] = $value; + self::$stack[$object::class." #".spl_object_id($object)]['matchCase'] = $case ?? []; self::$stack[$object::class." #".spl_object_id($object)]['object'] = $object; return $object; } @@ -101,7 +127,6 @@ class AbstractDataObject { return self::$constructorEmptyAvailableClasses[$class] = true; } - /** * @return array */ diff --git a/src/Repository/AbstractRepository.php b/src/Repository/AbstractRepository.php index eec880a..685de2f 100644 --- a/src/Repository/AbstractRepository.php +++ b/src/Repository/AbstractRepository.php @@ -4,45 +4,93 @@ namespace Rmphp\Storage\Repository; use Exception; use ReflectionClass; -use ReflectionException; +use Rmphp\Storage\Attribute\Entity; +use Rmphp\Storage\Attribute\GetProperty; +use Rmphp\Storage\Attribute\GetPropertyEmpty; +use Rmphp\Storage\Attribute\GetPropertyEmptyIfNull; +use Rmphp\Storage\Attribute\ValueObject; use Rmphp\Storage\Component\AbstractDataObject; use Rmphp\Storage\Entity\ValueObjectInterface; use Rmphp\Storage\Exception\RepositoryException; +use Throwable; abstract class AbstractRepository extends AbstractDataObject implements RepositoryInterface { - private static array $classes = []; - /** @inheritDoc */ public function getProperties(object $object, callable $method = null) : array { try{ $class = get_class($object); if(!isset(self::$classes[$class])) self::$classes[$class] = new ReflectionClass($class); + if(!isset(self::$attributeObjects[$class][0])){ + self::$attributeObjects[$class][0] = !empty(self::$classes[$class]->getAttributes(Entity::class)) + ? self::$classes[$class]->getAttributes(Entity::class)[0]->newInstance() + : new Entity(); + } + /** @var Entity $entityAttributes */ + $entityAttributes = self::$attributeObjects[$class][0]; + $fieldValue = []; foreach(self::$classes[$class]->getProperties() as $property){ - if(!$property->isInitialized($object) || is_array($property->getValue($object))) continue; - if(self::$classes[$class]->hasMethod('get'.ucfirst($property->getName()))){ - $fieldValue[$property->getName()] = $object->{'get'.ucfirst($property->getName())}($property->getValue($object)); - } - elseif($property->hasType() && class_exists($property->getType()->getName()) && $property->getValue($object) instanceof ValueObjectInterface){ - $fieldValue[$property->getName()] = $property->getValue($object)->getValue(); - } - elseif(is_bool($property->getValue($object))){ - $fieldValue[$property->getName()] = (int) $property->getValue($object); - } - else { - $fieldValue[$property->getName()] = $property->getValue($object); + if(!isset(self::$attributeObjects[$class][$property->getName()])){ + self::$attributeObjects[$class][$property->getName()] = !empty($property->getAttributes(GetProperty::class)) + ? $property->getAttributes(GetProperty::class)[0]->newInstance() + : new GetProperty(); } + /** @var GetProperty $getPropertyAttributes */ + $getPropertyAttributes = self::$attributeObjects[$class][$property->getName()]; - if(array_key_exists($property->getName(), $fieldValue) && false !== $fieldValue[$property->getName()]) { - $out[strtolower(preg_replace("'([A-Z])'", "_$1", $property->getName()))] = $fieldValue[$property->getName()]; + if(!empty($property->getAttributes(GetPropertyEmpty::class)) || !empty($getPropertyAttributes->empty)) continue; + + if($property->isInitialized($object)) { + + if(is_array($property->getValue($object))) continue; + + if(self::$classes[$class]->hasMethod('get'.ucfirst($property->getName()))){ + $fieldValue[$property->getName()] = $object->{'get'.ucfirst($property->getName())}($property->getValue($object)); + } + elseif($property->hasType() && class_exists($property->getType()->getName()) && $property->getValue($object) instanceof ValueObjectInterface){ + + $valueObjectClass = get_class($property->getValue($object)); + if(!isset(self::$classes[$valueObjectClass])) self::$classes[$valueObjectClass] = new ReflectionClass($valueObjectClass); + + if(!isset(self::$attributeObjects[$valueObjectClass])){ + self::$attributeObjects[$valueObjectClass] = !empty(self::$classes[$valueObjectClass]->getAttributes(ValueObject::class)) + ? self::$classes[$valueObjectClass]->getAttributes(ValueObject::class)[0]->newInstance() + : new ValueObject(); + } + $valueObjectAttributes = self::$attributeObjects[$valueObjectClass]; + + if(!empty($valueObjectAttributes->propertyName) && self::$classes[$valueObjectClass]->hasProperty($valueObjectAttributes->propertyName)){ + if(self::$classes[$valueObjectClass]->getProperty($valueObjectAttributes->propertyName)->isInitialized($property->getValue($object))) + $fieldValue[$property->getName()] = self::$classes[$valueObjectClass]->getProperty($valueObjectAttributes->propertyName)->getValue($property->getValue($object)); + } else{ + $fieldValue[$property->getName()] = $property->getValue($object)->getValue(); + } + } + elseif(is_bool($property->getValue($object))){ + $fieldValue[$property->getName()] = (int)$property->getValue($object); + } + else{ + $fieldValue[$property->getName()] = $property->getValue($object); + } + + if( + !isset($fieldValue[$property->getName()]) + && (!empty($property->getAttributes(GetPropertyEmptyIfNull::class)) || !empty($getPropertyAttributes->emptyIfNull) || !empty($entityAttributes->withoutNull)) + ) continue; + + if(array_key_exists($property->getName(), $fieldValue) && false !== $fieldValue[$property->getName()]) { + $columnName = !empty($getPropertyAttributes->keyName) ? $getPropertyAttributes->keyName : strtolower(preg_replace("'([A-Z])'", "_$1", $property->getName())); + $out[$columnName] = $fieldValue[$property->getName()]; + } } } + //dd($this->getAttributesObjectsCache()); return (isset($method)) ? array_map($method, $out ?? []) : $out ?? []; } - catch (ReflectionException $exception) { + catch (\ReflectionException $exception) { throw new RepositoryException($exception->getMessage()); } } @@ -52,10 +100,10 @@ abstract class AbstractRepository extends AbstractDataObject implements Reposito * @inheritDoc * @throws RepositoryException */ - public function createFromData(string $class, array|object $data, bool $withNull = true) : object { + public function createFromData(string $class, array|object $data, bool $withEmpty = true) : object { try { if(!isset(self::$classes[$class])) self::$classes[$class] = new ReflectionClass($class); - return self::fillObject(self::$classes[$class], new $class, (is_object($data)) ? get_object_vars($data) : $data, false, $withNull); + return self::fillObject(self::$classes[$class], new $class, (is_object($data)) ? get_object_vars($data) : $data, false, $withEmpty); } catch (Exception $exception) { throw new RepositoryException($exception->getMessage()); @@ -67,11 +115,11 @@ abstract class AbstractRepository extends AbstractDataObject implements Reposito * @inheritDoc * @throws RepositoryException */ - public function updateFromData(object $object, array|object $data, bool $withNull = true) : object { + public function updateFromData(object $object, array|object $data, bool $withEmpty = true) : object { try { $class = get_class($object); if(!isset(self::$classes[$class])) self::$classes[$class] = new ReflectionClass($class); - return self::fillObject(self::$classes[$class], clone $object, (is_object($data)) ? get_object_vars($data) : $data, true, $withNull); + return self::fillObject(self::$classes[$class], clone $object, (is_object($data)) ? get_object_vars($data) : $data, true, $withEmpty); } catch (Exception $exception) { throw new RepositoryException($exception->getMessage()); @@ -88,8 +136,22 @@ abstract class AbstractRepository extends AbstractDataObject implements Reposito /** * @return array */ - public function getClassesCash() : array { + public function getClassesCache() : array { return self::$classes; } + /** + * @return array + */ + public function getAttributesObjectsCache() : array { + return self::$attributeObjects; + } + + /** + * @return array + */ + public function getConstructorEmptyAvailableClassesCache() : array { + return self::$constructorEmptyAvailableClasses; + } + } diff --git a/src/Repository/RepositoryInterface.php b/src/Repository/RepositoryInterface.php index a9b563c..290dc76 100644 --- a/src/Repository/RepositoryInterface.php +++ b/src/Repository/RepositoryInterface.php @@ -25,19 +25,19 @@ interface RepositoryInterface { /** * @param string $class * @param array|object $data - * @param bool $withNull + * @param bool $withEmpty * @return mixed */ - public function createFromData(string $class, array|object $data, bool $withNull = true) : mixed; + public function createFromData(string $class, array|object $data, bool $withEmpty = true) : mixed; /** * @param object $object * @param array|object $data - * @param bool $withNull + * @param bool $withEmpty * @return mixed */ - public function updateFromData(object $object, array|object $data, bool $withNull = true) : mixed; + public function updateFromData(object $object, array|object $data, bool $withEmpty = true) : mixed; /**