По какой причине persist может не работать в Doctrine?

Question

[Ahmad Dusmatov]

Наткнулся на необычный баг. Есть endpoint в котором из базы тянется несколько десятков объектов, что-то обрабатывается и потом добавляются новые объекты.

//Упрощенный код
foreach ($items as $item) {
       $orderItem = OrderItem::createFromItem($order->getId(), $item);
      $this->entityManager->persist($orderItem);
}

$this->entityManager->flush();

Но в процессе, один persist не работает, то есть 1 объект не добавляется в базу. Прошелся дебагером и заметил, что spl_object_id в функции doPersist возвращает существующий id в entityState, поэтому insert не срабатывает.



Нашел https://github.com/doctrine/orm/issues/3037 Там пишут, что сборщик мусора может очистить какие то объекты и новые объекты могут иметь старое id. Видимо всё еще не исправили этот баг.

«Идентификатор объекта уникален на протяжении всего времени жизни объекта. После уничтожения объекта его идентификатор может быть повторно использован для других объектов».

Из доки php

Сейчас у меня работает так, но думаю это не оптимальный вариант. Какие варианты исправления можете рекомендовать и встречался ли вам такой баг в работе?

$this->entityManager->detach($orderItem);
$this->entityManager->persist($orderItem);
$this->entityManager->flush();

Comments

[BoShurik]

Сложно что-то рекомендовать, когда у вас уж очень упрощенный код. В issue рекомендуют делать entityManager->clear(). Пробовали?

[Ahmad Dusmatov]

Если добавить entityManager->clear(), данная проблема исчезает. Но и все другие объекты очищаются, а они нужны в другом месте

Controller

/**
     * @Route("/ajax/payment-link/charge-authorize/", methods={"POST"}, name="payment_link_charge_authorize")
     */
    public function chargeAuthorize(Request $request, PaymentLinkService $paymentLinkService)
    {
        $data = $request->request->all();
        $domain = $request->getSchemeAndHttpHost();

        $response = $paymentLinkService->chargeAuthorize($data, $domain);

        return $this->json($response);
    }

Service

public function chargeAuthorize(array $data, string $domain)
    {
        $appointmentId = $data['app_id'];
        $uniq = $data['uniq'];
        $clientId = $data['client_id'];
        $notifyClient = $data['notify_client'];
        $notifyAdmin = $data['notify_admin'];
        $notifyEmail = $data['notify_email'];
        $choicedCardId = $data['choiced_card_id'] ?? 'new_card';
        $saveCard = $data['save_card'] ?? false;
        $setDefaultCard = $data['set_default'] ?? false;
        $amount = $data['amount'];
        $number = isset($data['card_number']) ? str_replace(' ', '', $data['card_number']) : null;
        $holder = $data['card_holder'] ?? null;
        $month = $data['expiry_month'] ?? null;
        $year = $data['expiry_year'] ?? null;
        $cvv = $data['cvv'] ?? null;
        $zip = $data['zip_code'] ?? null;

        try {

            $paymentLink = $this->em->getRepository(SendPayments::class)->findOneBy(['uniq' => $uniq]);
            if(!$paymentLink) {
                throw new \Exception('Payment link expired. Please contact us');
            }

            $client = $this->em->getRepository(Clients::class)->find($clientId);
            $appointment = $this->em->getRepository(WpApAppointments::class)->find($appointmentId);

            if ($choicedCardId === 'new_card') {
                $newCard = Card::create($number, $holder, $zip, $month, $year, $cvv);
                $transactionId = $this->payPaymentLink->executeByNewCard($client, $appointment, $newCard, $paymentLink);

                if ($saveCard) {
                    $this->authorizeCustomer->createPaymentAccount($client, $number, $holder, $month, $year, $cvv, $zip, $setDefaultCard);
                }
            } else {
                //use saved card
                $transactionId = $this->payPaymentLink->executeByCardOnFile($client, $appointment, $paymentLink, $choicedCardId);

                if ($setDefaultCard) {
                    $this->authorizeCustomer->setCardByDefault($clientId, $choicedCardId);
                }
            }

            $paymentLink->setUniq('');
            $this->em->persist($paymentLink);
            $this->em->flush();

            return ['success' => true, 'related_id' => $transactionId, 'send_payment_id' => $paymentLink->getId()];
        } catch (\Exception $exception) {
            return [
                'error' => 'Error',
                'error_code' => 'payment_link_error',
                'error_msg' => $exception->getMessage(),
            ];
        }
    }


public function executeByCardOnFile(Clients $client, WpApAppointments $booking, SendPayments $paymentLink, int $cardId): string
    {
        $paymentAmount = $paymentLink->getAmount();
        $card = $this->getCardOnFileById($cardId);
        $items = $this->generatePaymentLinkItems($paymentLink);

        $sendPaymentDiscount = $this->em->getRepository(SendPaymentsOrderDiscounts::class)->findOneBy(['sendPaymentId' => $paymentLink->getId()]);
        if ($sendPaymentDiscount) {
            $discount = $this->em->getRepository(Discounts::class)->find($sendPaymentDiscount->getDiscountId());
            $discountCalculation = new DiscountCalculation($discount, $paymentAmount);
            $calculatedData = $discountCalculation->getArrayData();
            $paymentAmount = $calculatedData['rate'];
        }

        $authorizeTxn = $this->authorizeNetService->chargeCustomerTransaction($client, $card, $paymentAmount, $items, $booking->getId());
        $transactionId = $this->transactionsService->createForPaymentLink($client, $booking, $paymentAmount, $authorizeTxn->getTransId());
        $this->authorizeNetService->addRelatedId($authorizeTxn, $transactionId);

        if ($sendPaymentDiscount) {
            $this->ordersService->createOrderWithItems($transactionId, $items, $discount, $calculatedData);
        } else {
            $this->ordersService->createOrderWithItems($transactionId, $items);
        }

        return (string)$transactionId;
    }




public function createOrderWithItems($transactionId, $items, Discounts $discount = null, ?array $discountCalculation = null): void
    {
        $orderTotal = 0;

        foreach ($items as $item) {
            if ($item instanceof Item) {
                $orderTotal += ($item->getPrice() * $item->getQuantity());
            }
        }
        
        $order = Orders::create($transactionId, $orderTotal);
        $this->entityManager->persist($order);
        $this->entityManager->flush();

        if ($discount instanceof Discounts) {
            $orderDiscount = OrderDiscount::create($discount, $order->getId(), $discountCalculation['amount']);
            $this->entityManager->persist($orderDiscount);
            $this->entityManager->flush();
        }

        foreach ($items as $item) {
            if ($item instanceof Item) {
                //$this->entityManager->clear();

                $orderItem = OrderItem::createFromItem($order->getId(), $item);
                $this->entityManager->detach($orderItem);
                $this->entityManager->persist($orderItem);
                $this->entityManager->flush();

            }
        }
    }