Как получить изменения в single associations в onFlush в doctrine event listener?

Question

[coderisimo]

В третий раз закинул он невод )).
Путем исследований обнаружил, что если я хочу сохранять что-то новое (например, лог изменений сущностей) в doctrine event listener , то я должен делать это в onFlush используя $unitOfWork->computeChangeSet...Но

Я могу получить в onFlush добавленные и удаленные сущности. Я могу получить в onFlush коллекции ассоциаций. Но Я совершенно не понимаю, как получить там же ОДИНОЧНЫЕ АССОЦИАЦИИ (вернее, их изменения). Казалось бы, если есть первое и второе, то уж и третье должно быть доступно, ан xxxxxx.......

Другими словами мне нужно в onFlush то, что есть в preUpdate - PreUpdateEventArgs. Сохранять что-то в preUpdate категорически не рекомендуется и не работает. Получается интересная ситуация :
Сохранить лог во onFlush я могу, но там нет нужной информации.
Сохранить лог в preUpdate я не могу, хотя там есть все что мне нужно.

Буду благодарен за советы.
Спасибо

Comments

[BoShurik]

А что конкретно вы получаете из PreUpdateEventArgs?

[coderisimo]

там есть : $args->hasChangedField, $args->getNewValue, $args->getOldValue

//отбираем ассоциации "не коллекции" и только изменненные.
        $fields = array_filter($metaData->getAssociationNames(), function ($association) use ($metaData, $args) {
            return $metaData->isSingleValuedAssociation($association) && $args->hasChangedField($association);
        });

//  итерируем  $fields и получаем Single ассоциации до и после 
  $newValue = $args->getNewValue($field);
  $oldValue = $args->getOldValue($field);

[BoShurik]

coderisimo, эти данные можно получить через $changeSet = $uow->getEntityChangeSet($entity);

[coderisimo]

BoShurik,

getEntityChangeSet я использую , ибо мне нужны все изменения , но данный метод возвращает массив, где только простые значения "до" и "после".
В нем НЕТ ассоциаций , а $args->getNewValue($field) $args->getOldValue($field). - возвращают так же и ассоциации(сущности).

[BoShurik]

coderisimo, вы уверены? это просто сахар над этим массивом

https://github.com/doctrine/orm/blob/2.7/lib/Doctr...
https://github.com/doctrine/orm/blob/2.7/lib/Doctr...

[coderisimo]

Спасибо за помощь . Тогда я вообще перестаю что-либо понимать.
Похоже , что в процессе в onFlush и в preUpdate в entityChangeSet содержимое меняется ...
В onFlush -

foreach ($uow->getScheduledEntityUpdates() as $entity) {
                $this->l('in onFlush');
                $changesSet = $uow->getEntityChangeSet($entity);
                $this->l($changesSet);
            }

я вижу только простые поля, а когда позже использую PreUpdateEventArgs

private function getAssocSingleChanges(PreUpdateEventArgs $args)
    {
        $metaData = $this->entityManager->getClassMetadata(get_class($args->getObject()));
        //отбираем ассоциации "не коллекции" и только изменненные.
        $fields = array_filter($metaData->getAssociationNames(), function ($association) use ($metaData, $args) {
            return $metaData->isSingleValuedAssociation($association) && $args->hasChangedField($association);
        });

        $changedAssociations = [];
        foreach ($fields as $field) {
            $newValue = $args->getNewValue($field);
            $oldValue = $args->getOldValue($field);
            $changedAssociations[$field] = array_map(function ($value) {
                return $value ? $this->getAssocFieldValue($value) : '';
            }, [$oldValue, $newValue]);
        }......

у меня уже и ассоциации доступны и. в $changedAssociations собираю поля из ассоциаций.
В общем патовая ситуация )).

[BoShurik]

coderisimo, у меня есть предположение, что эта связь меняется где-то в другом onFlush листенере, который применяется уже после вашего логирующего, т.о. в PreUpdateEventArgs оно появляется. Попробуйте приоритет у своего выставить на минимальный.

[coderisimo]

BoShurik, как всегда главный баг - глупость (собственная). Действительно getEntityChangeSet подходит! В нем есть все что нужно. Спасибо, очень помогли!

[BoShurik]

coderisimo, решение стоит того, чтобы его оформить в виде ответа? :)

[coderisimo]

BoShurik, Стоит! Я уже накалякал вариант , в помощь моим будущим коллегам по задаче. Чем больше разносторонней инфы тем , имхо , лучше.

[coderisimo]

BoShurik, давайте!

Answer 1

[coderisimo]

Напишу здесь, чтобы был ответ, который возможно кому-то еще сэкономит время и НЕВРЫ.
Спасибо BoShurik !!!! см. подробности топике

Простые ассоциации доступны в onFlush через
$unitOfWork->getEntityChangeSet($entity);

далее

$metaData = $entityManager->getClassMetadata(get_class($entity));
            //отбираем ассоциации "не коллекции" и только изменненные.
            $singleAssociations = array_filter($metaData->getAssociationNames(), function ($association) use ($metaData) {
                return $metaData->isSingleValuedAssociation($association);
            });

            $data = [];
            foreach ($changesSet as $key => $field) {
                if (in_array($key, $singleAssociations)) {
// где $field[0] и $field[1] будут как раз простыми ассоциациями "до" и "после"
//getAssocFieldValue - просто метод который берет из ассоциации нужное простое значение для  лога
                    $data[$key] = [$this->getAssocFieldValue($field[0]), $this->getAssocFieldValue($field[1])];
                } 
            }

Answer 2

[Антон]

У меня, по-моему, была не совсем такая ситуация, но похожая ситуация.
Создаётся один класс, который реализует EventSubscriber и в нём прописываются два метода, которые вам нужны (preUpdate и onFlush ).
В вашем случае в preUpdate сохраняете в свойство класса данные, которые вам надо сохранить, а уже в onFlush читаете их из этого свойства и сохраняете.

Comments

[coderisimo]

Я бы рад, но onFlush запускается первым ))))

[sl0]

coderisimo, Можно попробовать при preUpdate кидать событие, в котором передавать нужные данные.
А уже в onFlush, хотя скорее postFlush, его обрабатывать и сохранять.

[coderisimo]

sl0,
postFlush is called at the end of EntityManager#flush(). EntityManager#flush() can NOT be called safely inside its listeners.

[Антон]

coderisimo, я в postFlush сохранял, работало. В onFlush() получал изменные данные, а в postFlush сохранял.

public function onFlush(OnFlushEventArgs $eventArgs){
        $em  = $eventArgs->getEntityManager();
        $uow = $em->getUnitOfWork();

        foreach($uow->getScheduledEntityUpdates() as $obj){
}
}

А в целом для donctrine есть расширения для логгирования - loggable не интересовались как там сделано?

[sl0]

coderisimo, Ога. Но вообще странно как onFlush запускается раньше preUpdate.

[coderisimo]

sl0, я тоже удивился. PreUpdate .... is called for an entity inside the EntityManager#flush() method.

[coderisimo]

Антон, пока до этого не дошел. задача казалась не слишком сложной )))
Насчет сохранения - нет проблем. т,е сохранять все можно сразу в onFlush . Только там flash() не нужен.

$em->persist($logRecord);
 $uow->computeChangeSet($em->getClassMetadata(get_class($logRecord)), $logRecord);

НО в onFlush нету простых ассоциаций. Как я и писал в вопросе. Есть :

Entities scheduled for insert
Entities scheduled for update
Entities scheduled for removal
Collections scheduled for update
Collections scheduled for removal