src/EventSubscriber/DoctrineSubscriber.php line 164

Open in your IDE?
  1. <?php
  2. namespace App\EventSubscriber;
  3. use App\Controller\Api\DocumentManagerController;
  4. use App\Entity\InvoicePaymentStatus;
  5. use App\Entity\InvoicePositions;
  6. use App\Entity\Invoices;
  7. use App\Entity\Partner;
  8. use App\Entity\PartnerCertificateDocuments;
  9. use App\Entity\ProjectOrders;
  10. use App\Entity\ProjectOrderTaskFulfillmentWorkDocs;
  11. use App\Entity\Projects;
  12. use App\Entity\ProjectStakeholders;
  13. use App\Entity\ProjectStatus;
  14. use App\Entity\StockItems;
  15. use App\Entity\Stocks;
  16. use App\Entity\Vendor;
  17. use App\Entity\WorkerActivities;
  18. use App\Entity\WorkerCertificateDocuments;
  19. use App\Entity\Worker;
  20. use App\Entity\WorkerInProject;
  21. use App\Enum\PaymentStatusEnum;
  22. use App\Service\Calculators\ProjectOrderCalculator;
  23. use Doctrine\Common\Collections\ArrayCollection;
  24. use Doctrine\Common\Collections\Criteria;
  25. use Doctrine\ORM\EntityManagerInterface;
  26. use Doctrine\ORM\Event\OnFlushEventArgs;
  27. use Doctrine\ORM\Event\PostFlushEventArgs;
  28. use Doctrine\ORM\Event\PrePersistEventArgs;
  29. use Doctrine\ORM\Event\PreRemoveEventArgs;
  30. use Doctrine\ORM\PersistentCollection;
  31. use Doctrine\Persistence\Event\LifecycleEventArgs;
  32. use Doctrine\Persistence\Event\LifecycleEventArgs as LifecycleEventArgsAlias;
  33. use Doctrine\ORM\Events;
  34. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  35. use App\Entity\InvoiceType;
  36. use Doctrine\Persistence\ManagerRegistry;
  37. use Doctrine\ORM\UnitOfWork;
  38. use Symfony\Contracts\Translation\TranslatorInterface;
  40. /**
  41.  * Doctrine during load jobs
  42. */
  43. class DoctrineSubscriber implements EventSubscriberInterface
  44. {
  45.     private $serviceArgs;
  46.     private ManagerRegistry $managerRegistry;
  47.     private TranslatorInterface $translator;
  48.     private ProjectOrderCalculator $projectOrderCalculator;
  50.     /**
  51.      * @deprecated
  52.     */
  53.     private PaymentStatusEnum $paymentStatusEnum;
  55.     public function __construct(
  56.         $args,
  57.         ManagerRegistry $managerRegistry,
  58.         TranslatorInterface $translator,
  59.         ProjectOrderCalculator $projectOrderCalculator,
  60.         PaymentStatusEnum $paymentStatusEnum
  61.     )
  62.     {
  63.         $this->serviceArgs = $args;
  64.         $this->managerRegistry = $managerRegistry;
  65.         $this->translator = $translator;
  66.         $this->projectOrderCalculator = $projectOrderCalculator;
  67.         $this->paymentStatusEnum = $paymentStatusEnum;
  69.     }
  71.     // Listen to postLoad event
  72.     public static function getSubscribedEvents()
  73.     {
  74.         /**
  75.          * Metrics hesaplama onFlush
  76.          * Delete öncesi kontrol preRemove
  77.          * DB sonrası işlem (log / event) postFlush
  78.          *
  79.          *  Metrics için önerilmez
  80.          *  preUpdate|postUpdate|postLoad
  81.         */
  82.         return array(
  84.             /**
  85.              * Entity DB’den yüklendikten hemen sonra
  86.             */
  87.             Events::postLoad,
  88.             #Events::postUpdate,
  89.             /**
  90.              * 📍 Ne zaman?
  91.              * persist() çağrıldıktan sonra
  92.              * flush() öncesi
  93.              * Sadece NEW entity için
  94.              * 📍 Ne için?
  95.              * Default value set
  96.              * createdAt / UUID
  97.             */
  98.             Events::prePersist,
  99.             /**
  100.              * 📍 Ne zaman?
  101.              * UPDATE edilecek entity için
  102.              * flush() öncesi
  103.              * 📍 Özel durum:
  104.              * ChangeSet zaten hesaplanmış
  105.              * Değişiklik yaptıysan:
  106.             */
  107.             #Events::preUpdate,
  108.             /**
  109.              * 📍 Ne zaman?
  110.              * remove() çağrıldıktan sonra
  111.              * flush() öncesi
  112.              * 📍 Ne için?
  113.              * Delete öncesi validation
  114.              * Loglama
  115.              * 🚫 Yapma: başka entity update
  116.             */
  117.             Events::preRemove,
  118.             /**
  119.              * 📍 Ne zaman?
  120.              * Doctrine ChangeSet’i hesapladıktan sonra
  121.              * SQL yazılmadan hemen önce
  122.              * 📍 Ne için? 🔥🔥🔥
  123.              * Başka entity’leri manuel olarak update etmek
  124.              * $uow->recomputeSingleEntityChangeSet()
  125.             */
  126.             Events::onFlush,
  127.             /**
  128.              * 📍 Ne zaman?
  129.              * Tüm SQL’ler çalıştıktan sonra
  130.              * Transaction commit edilmeden hemen önce
  131.              * 📍 Ne için?
  132.              * Side effects
  133.              * Queue / mail / log
  134.              * Flush çağırmak SERBEST (dikkatli)
  135.              * 🚫 Yapma: entity state değiştirme (sonsuz loop riski)
  136.             */
  137.             Events::postFlush
  138.         );
  139.     }
  141.     // Call on Update
  142.     public function postFlush(PostFlushEventArgs $args){
  144.     }
  146.     public function preRemove(PreRemoveEventArgs $args){
  147.         /*$manager = $args->getObjectManager();
  148.         $uow = $manager->getUnitOfWork();
  149.         #dd($uow->getScheduledEntityDeletions());
  150.         $entity = $args->getObject();
  151.         #dd($entity);
  152.         // Update Metrics
  153.         if( $entity instanceof ProjectOrderUndertakings){
  154.             $calculated = $this->projectOrderCalculator
  155.                 ->calculateOrderPayments($entity->getProjectOrder());
  156.             #dd($calculated);
  157.             $entity->getProjectOrder()->getProjectOrderMetrics()->setTotalUndertakings($calculated['undertakingTotal'] - $entity->getPrice());
  158.         }*/
  159.     }
  163.     // Call on (New & Update & Remove)
  164.     public function onFlush(OnFlushEventArgs $args)
  165.     {
  166.         /***
  167.          * $args->getObjectManager() → EntityManager döner
  168.          * ❌ Flush edilen entity dönmez
  169.          * ❌ instanceof ProjectOrderUndertakings burada anlamsız
  170.          * Yani şunlar artık BOŞ:
  171.          * getScheduledEntityInsertions()
  172.          * getScheduledEntityUpdates()
  173.          * getScheduledEntityDeletions()
  174.          */
  175.         $manager = $args->getObjectManager();
  176.         $uow = $manager->getUnitOfWork();
  177.         /**
  178.          * @deprecated
  179.         */
  180.         $deleted = array_values($uow->getScheduledEntityDeletions());
  182.         /**
  183.          * ornek entityRemove($entity) busekilde setEntity(null) oldugundan delete yapilmis entity degeri gorunmuyot yani deleted ici bos o yüzden preRemove kullan
  184.         */
  186.         /**
  187.          * $entities = [...$uow->getScheduledEntityUpdates(), ...$uow->getScheduledEntityInsertions()  ];
  188.          * // Trigger's
  189.          * foreach ($entities as $entity) {
  190.          *      if ($entity instanceof ProjectOrderUndertakings) {
  191.          *          * $trigger = new ProjectOrderMetricsTrigger($this->projectOrderCalculator);
  192.          *          * // $trigger->projectOrderUndertakingChange($uow, $manager, $entity, $deleted);
  193.          *          * // Only Remove is Manually With OnRemove in owned Service !!
  194.          *          * // ⚠️Don't use this success over inline ProjectOrderService
  195.          *          * $trigger->projectOrderUndertakingChange($uow, $manager, $entity, []);
  196.          * }
  197.          * }
  198.         */
  199.     }
  201.     // Call on (New)
  202.     public function prePersist( PrePersistEventArgs $args)
  203.     {
  204.         $entity = $args->getObject();
  205.         if( $entity instanceof ProjectOrderTaskFulfillmentWorkDocs ){
  206.             $entity->setFile($this->serviceArgs['dirs']['taskFulfillmentWorkDocsReadDir'] . DIRECTORY_SEPARATOR . $entity->getName() );
  207.         }
  208.     }
  211.     // Set the services.yaml param on the entity
  212.     public function postLoad( LifecycleEventArgs $args)
  213.     {
  215.         $entity = $args->getObject();
  217.         if ($entity instanceof PartnerCertificateDocuments ) {
  218.             $entity->setHydrateDocumentsData([
  219.                 "id" => $entity->getId(),
  220.                 "file_name" => $entity->getName(),
  221.                 "file_real_path" => $this->serviceArgs['dirs']['partnerCertFetchDir'] . DIRECTORY_SEPARATOR . $entity->getName(),
  222.                 "extension" =>  DocumentManagerController::getFileExtension( $entity->getName() ),
  223.                 "type" =>  DocumentManagerController::getFileFullType( DocumentManagerController::getFileExtension( $entity->getName() ) ),
  224.                 // Access from frontend
  225.                 "remove_path" => "/api/partner/remove-partner-certificate-history-document/" . $entity->getPartnerCertificateHistory()->getPartnerCertificate()->getPartner()->getSlug() . "/" . DocumentManagerController::Encrypt($entity->getId()),
  226.                 // Access just backend
  227.                 "remove_link" => $this->serviceArgs['dirs']['partnerCertManageDir'] . DIRECTORY_SEPARATOR . $entity->getName()
  228.             ]);
  229.         }
  231.         if ( $entity instanceof WorkerCertificateDocuments ) {
  232.             $entity->setHydrateDocumentsData([
  233.                 "id" => $entity->getId(),
  234.                 "file_name" => $entity->getName(),
  235.                 "file_real_path" => $this->serviceArgs['dirs']['workerCertFetchDir'] . DIRECTORY_SEPARATOR . $entity->getName(),
  236.                 "extension" =>  DocumentManagerController::getFileExtension( $entity->getName() ),
  237.                 "type" =>  DocumentManagerController::getFileFullType( DocumentManagerController::getFileExtension( $entity->getName() )),
  238.                 // Access from frontend
  239.                 "remove_path" => "/api/worker/remove-worker-certificate-history-document/" . $entity->getWorkerCertificateHistory()->getWorkerCertificate()->getWorker()->getSlug() . "/" . DocumentManagerController::Encrypt($entity->getId()),
  240.                 // Access just backend
  241.                 "remove_link" =>$this->serviceArgs['dirs']['workerCertManageDir'] . DIRECTORY_SEPARATOR . $entity->getName()
  242.             ]);
  243.         }
  245.         if ( $entity instanceof Worker ) {
  247.             #dd(12);
  248.             // Image Full Path
  249.             // $entity->setProfileImageFullPath( $this->serviceArgs['dirs']['workerImagesFetchDir'] . DIRECTORY_SEPARATOR . $entity->getProfileImage() );
  251. //            // SECTION “idempotent” Behevior
  252. //            $profileImage = $entity->getProfileImage();
  253. //            if ($profileImage && !str_starts_with($profileImage, $this->serviceArgs['dirs']['workerImagesFetchDir'])) {
  254. //                $entity->setProfileImage($this->serviceArgs['dirs']['workerImagesFetchDir'] . DIRECTORY_SEPARATOR . $profileImage);
  255. //            }
  257.             /**
  258.              * SECTION Worker için sadece runtime path ekle
  259.              * // README
  260.              * 1️⃣ Doctrine UnitOfWork “dirty check” yapıyor
  261.              * postLoad sırasında sen Worker entity’sinde setProfileImage() cagirdim.
  262.              * Doctrine bunu entity’nin değiştiği olarak algılar ve next flush’ta DB’ye yazılacak olarak işaretledi eget bu entity guncellemsini istemesem bile sirf bu yüzden worker guncellencek .
  263.              * postLoad içinde set yaptığımda, eğer o entity UnitOfWork tarafından izleniyorsa ve flush çağrılırsa, Doctrine bunu kaydediyor benide öldürüyor
  264.              * Gunvenli yol olarak runtime Path eklemeyi yaptim
  265.              * */
  266.             $this->setWorkerImagePathRuntime($entity);
  268.             // $entity->setProfileImage( $this->serviceArgs['dirs']['workerImagesFetchDir'] . DIRECTORY_SEPARATOR . $entity->getProfileImage() );
  269.             #dd($args->getObjectManager()->getMetadataFactory());
  271.             // Latest Activity
  272.             $criteria = Criteria::create()->where(Criteria::expr()->eq('exit_at', null));
  273.             // $criteria->orderBy(['created_at' => Criteria::DESC])->setMaxResults(1);
  274.             $criteria->orderBy(['id' => Criteria::DESC])->setMaxResults(1);
  275.             $latestActivity = $entity->getWorkerActivities()->matching($criteria)->first();
  277.             $latestActivity = $latestActivity instanceof WorkerActivities ? $latestActivity : null;
  279.             // Status
  280.             $status = false;
  281.             if ($latestActivity !== null) {
  282.                 $today = new \DateTimeImmutable('now');
  283.                 $exitAt = $latestActivity->getExitAt();
  285.                 if ($exitAt) {
  286.                     // Eğer çıkış zamanı gelecekteyse aktif kabul et
  287.                     $status = $today < $exitAt;
  288.                 } else {
  289.                     // Çıkış zamanı yoksa hâlâ aktif
  290.                     $status = true;
  291.                 }
  292.                 $latestActivity->setActivityStatus($status);
  293.                 if($exitAt){
  294.                     dd($exitAt, $today->diff($exitAt)->days, $status);
  295.                 }
  297.                 // Hesapladığın durumu activity'e ata
  298.             }
  301.             $entity
  302.                 ->setFullName( $entity->getName() . ' ' . $entity->getSurname() )
  303.                 ->setLatestActivity($latestActivity);
  304.         }
  306.         if ( $entity instanceof Partner ) {
  307.             // ⚠️ Yalnız mapped OLMAYAN logo_image_full_path türetilir; mapped company_logo'ya DOKUNULMAZ.
  308.             // postLoad'da değiştirilen mapped alan Doctrine'de dirty sayılır ve uygulamadaki HERHANGİ bir
  309.             // flush'ta prefix'li hâliyle DB'ye geri yazılır → her yüklemede bir prefix daha →
  310.             // "1406 Data too long for column 'company_logo'". Repair: sql/partner-company-logo-repair.sql
  311.             $logoFile = basename((string) $entity->getCompanyLogo());
  312.             $entity->setLogoImageFullPath(
  313.                 $logoFile !== '' && pathinfo($logoFile, PATHINFO_EXTENSION) !== ''
  314.                     ? $this->serviceArgs['dirs']['partnerImagesFetchDir'] . DIRECTORY_SEPARATOR . $logoFile
  315.                     : null
  316.             );
  317.         }
  319.         if ( $entity instanceof Vendor ) {
  320.             $entity->setVendorLogo( $this->serviceArgs['dirs']['vendorLogosDirectory'] . DIRECTORY_SEPARATOR . $entity->getVendorLogo() );
  321.         }
  323.         if( $entity instanceof ProjectOrderTaskFulfillmentWorkDocs ){
  324.             dump($this->serviceArgs['dirs']['taskFulfillmentWorkDocsReadDir'] . DIRECTORY_SEPARATOR . $entity->getName());
  325.             $entity->setFile($this->serviceArgs['dirs']['taskFulfillmentWorkDocsReadDir'] . DIRECTORY_SEPARATOR . $entity->getName() );
  326.         }
  328.         if ( $entity instanceof WorkerInProject || $entity instanceof ProjectStakeholders  || $entity instanceof Projects ) {
  330.             # 1,completed,success
  331.             # 2,in process,warning
  333.             $completed      = false;
  334.             $processId      = 2;
  335.             $message        = $this->translator->trans('in process');
  336.             $projectName    = '';
  337.             $alerted   = ''; // Bitis zamani belli henuz zamani gelmemis 
  339.             if( $entity instanceof Projects ){
  341.                 // Core First of all
  342.                 $project        = $entity;
  343.                 $projectEnded   = $project->getEndAt() && ($project->getEndAt() < new \DateTimeImmutable('now'));
  344.                 $projectName    = $project->getName();
  345.                 // $alerted        = $project->getEndAt() && ($project->getEndAt() > new \DateTimeImmutable('now'));
  346.                 $alerted        = !is_null($project->getEndAt()) ? (new \DateTimeImmutable('now'))->diff($project->getEndAt())->days : 'Infinity';
  348.                 if( $projectEnded ){
  349.                     $params = "completed";
  350.                     $completed = true;
  351.                 }
  352.             }
  353.             elseif( $entity instanceof ProjectStakeholders ){
  355.                 // Core First of all
  356.                 $project        = $entity->getProject();
  357.                 $projectEnded   = $project->getEndAt() && ($project->getEndAt() < new \DateTimeImmutable('now'));
  358.                 $projectName    = $project->getName();
  359.                 // $alerted        = !is_null($project->getEndAt()) && ($project->getEndAt() > new \DateTimeImmutable('now'));
  360.                 $alerted        = !is_null($project->getEndAt()) ? (new \DateTimeImmutable('now'))->diff($project->getEndAt())->days : 'Infinity';
  362.                 if($projectEnded){
  363.                     $completed = true;
  364.                     $message = $this->translator->trans('completed');
  365.                     $processId = 1;
  366.                 } else {
  368.                     // 2. Stakeholder
  369.                     $project        = $entity;
  370.                     $projectEnded   = $project->getEndAt() && ($project->getEndAt() < new \DateTimeImmutable('now'));
  371.                     // $alerted        = !is_null($project->getEndAt()) && ($project->getEndAt() > new \DateTimeImmutable('now'));
  372.                     $alerted        = !is_null($project->getEndAt()) ? (new \DateTimeImmutable('now'))->diff($project->getEndAt())->days : 'Infinity';
  374.                     if($projectEnded){
  375.                         $completed = true;
  376.                         $message = $this->translator->trans('completed');
  377.                         $processId = 1;
  378.                     }
  379.                 }
  380.             }
  381.             elseif( $entity instanceof WorkerInProject ){
  383.                 // Core First of all
  384.                 $project        = $entity->getProject()->getProject();
  385.                 $alerted        = 'Infinity';
  386.                 $projectEnded   = false;
  387.                 if(!is_null($project->getEndAt())){
  388.                     $diff           = (new \DateTimeImmutable('now'))->diff($project->getEndAt());
  389.                     $days           = $diff->days;
  390.                     $invert         = $diff->invert;
  391.                     $projectEnded   = $project->getEndAt() < new \DateTimeImmutable('now');
  392.                     $alerted        = $invert ? "-$days" : $days;
  393.                 }
  394.                 $projectName    = $project->getName();
  396.                 if($projectEnded){
  397.                     $completed = true;
  398.                     $message = $this->translator->trans('completed');
  399.                     $processId = 1;
  400.                 } else {
  402.                     // 2. Stakeholder
  404.                     $project        = $entity->getProject();
  405.                     $alerted        = 'Infinity';
  406.                     $projectEnded   = false;
  407.                     if(!is_null($project->getEndAt())){
  408.                         $diff           = (new \DateTimeImmutable('now'))->diff($project->getEndAt());
  409.                         $days           = $diff->days;
  410.                         $invert         = $diff->invert;
  411.                         $projectEnded   = $project->getEndAt() < new \DateTimeImmutable('now');
  412.                         $alerted        = $invert ? "-$days" : $days;
  413.                     }
  414.                     $projectName    = $project->getProject()->getName();
  416.                     if($projectEnded){
  417.                         $completed = true;
  418.                         $message = $this->translator->trans('completed');
  419.                         $processId = 1;
  420.                     } else {
  422.                         $project        = $entity;
  423.                         $alerted        = 'Infinity';
  424.                         $projectEnded   = false;
  425.                         if(!is_null($project->getEndAt())){
  426.                             $diff           = (new \DateTimeImmutable('now'))->diff($project->getEndAt());
  427.                             $days           = $diff->days;
  428.                             $invert         = $diff->invert;
  429.                             $projectEnded   = $project->getEndAt() < new \DateTimeImmutable('now');
  430.                             $alerted        = $invert ? "-$days" : $days;
  431.                         }
  432.                         $projectName    = $project->getProject()->getProject()->getName();
  434.                         if($projectEnded){
  435.                             $completed = true;
  436.                             $message = $this->translator->trans('completed');
  437.                             $processId = 1;
  438.                         }
  439.                     }
  440.                 }
  442.                 // TODO bu kisim gecici worker_in_project deki project prop u stakeholder_project prop u ile degisecek
  443.                 $entity->setStakeholderProject($entity->getProject());
  445.             }
  447.             try{
  448.                 #dump($message);
  449.                 /**@var $found ProjectStatus*/
  450.                 $found = $args->getObjectManager()->getRepository(ProjectStatus::class)->find($processId); // ->findOneBy(["name"=>$message]);
  451.                if(!is_null($found)){
  452.                     $entity->setStatus([
  453.                         "project_name" => $projectName,
  454.                         'name' => $message,
  455.                         'color' => $found->getColor(),
  456.                         'completed' => $completed,
  457.                         'alerted' => $alerted,
  458.                         'show_and_notify' => $alerted !== 'Infinity' && $alerted > 0 && $alerted < 10,
  459.                         'notify' => is_numeric($alerted) && $alerted > 0 ? $alerted . ' ' . $this->translator->trans('day(s) to end') : 'Infinity'
  460.                     ]);
  461.                }
  462.                else {
  463.                    dd("Null by ProjectStatus [$message]");
  464.                }
  465.             } catch (\Exception $exception ){
  466.                 throw new \Error("Error by ProjectStatus [$message]");
  467.             }
  468.         }
  473.         /**
  474.          * By Manage give an error 
  475.          * @deprecated */
  478.         if( $entity instanceof ProjectOrders ){
  479.         
  480.             return;
  482.             #dd($args->getObjectManager());
  483.             
  484.             $entityManager = $args->getObjectManager();
  485.             
  486.             $unitOfWork = $entityManager->getUnitOfWork();
  487.             $entityState = $unitOfWork->getEntityState($entity);
  491.             
  492.             if($entityState === UnitOfWork::STATE_NEW)  {
  493.                 // return;
  494.             }
  496.             #return;
  497.             try{
  498.                 if( is_null($entity->getInvoiceType())){
  499.                 
  500.                 
  501.                     #dd(12);
  502.                     $customer = $entity->getProject()->getCustomer();
  503.     
  504.     
  505.                     // Set Standard
  506.                     if(!$customer){
  507.                         $invoiceTypes = $args->getObjectManager()->getRepository(InvoiceType::class)->findOneBy(["name"=>"Standard"]);
  508.                         #dd($invoiceTypes);
  509.                         $entity->setInvoiceType($invoiceTypes);
  510.                         return;
  511.                     }
  512.     
  513.                     // Customer defined but invoice type not selected -> set Standard 
  514.                     if(is_null($customer->getInvoiceType())){
  515.                         $invoiceTypes = $args->getObjectManager()->getRepository(InvoiceType::class)->findOneBy(["name"=>"Standard"]);
  516.                         #dd($invoiceTypes);
  517.                         #$entity->setInvoiceType($invoiceTypes);
  518.                         return;
  519.                     }
  520.     
  521.                     // dd($customer->getInvoiceType());
  522.                     $entity->setInvoiceType($customer->getInvoiceType());
  523.                 }
  524.             } catch (\Exception $exception){
  525.                 
  526.             }
  527.         
  528.         }
  530.         if( $entity instanceof Stocks ){
  533.             $em = $args->getObjectManager();
  535.             $availableStockQuantity = $this->finalCalculatedStockQuantityFromTransactions($entity->getStockTransactions());
  537.             $entity->setAvailableStockQuantity( $availableStockQuantity );
  538.         }
  540.         if( $entity instanceof StockItems ){
  542.             $em = $args->getObjectManager();
  544.             $finalQuantities = $entity->getStocks()->map(function (/**@var Stocks $stock*/$stock) {
  545.                 return $this->finalCalculatedStockQuantityFromTransactions($stock->getStockTransactions());
  546.             });
  548.             $entity->setTotalAvailableQuantity(array_sum($finalQuantities->toArray()));
  549.         }
  551.         // TODO move this to static as Metric into Invoice Table
  552.         if($entity instanceof Invoices){
  554.             //            $calculated = $approved = $paid = [];
  555.             //
  556.             //            /**@var $invoicePosition InvoicePositions */
  557.             //            foreach ($entity->getInvoicePositions() as $invoicePosition) {
  558.             //                // This position absolute from Billing generated
  559.             //                $price  = $invoicePosition->getOrderBilling()->getPrice();
  560.             //                $unit   = $invoicePosition->getOrderBilling()->getQuantity();
  561.             //                // Required
  562.             //                $calculated[] = $price * $unit;
  563.             //                // Optional
  564.             //                if(!is_null($entity->getApprovedAt())) {
  565.             //                    $approved[] = $entity->getApprovedAmount();
  566.             //                }
  567.             //                // Optional
  568.             //                if(!is_null($entity->getPaidAt())){
  569.             //                    $paid[] = $invoicePosition->getPaidAmount();
  570.             //                }
  571.             //            }
  572.             //
  573.             //            // After each
  574.             //            $calculatedTotals   = array_sum($calculated);
  575.             //            $paidTotals         = array_sum($paid);
  576.             //            $approvedTotals     = array_sum($approved);
  577.             //            $paidStatus         = $this->paymentStatusEnum::PAYMENT_STATUS_UNPAID;
  578.             //            if($paidTotals > 0){
  579.             //                // TODO Paid
  580.             //                if( $paidTotals !== $calculatedTotals ){
  581.             //                    // TODO Partially Paid
  582.             //                    $paidStatus = $this->paymentStatusEnum::PAYMENT_STATUS_PARTIALLY_PAID;
  583.             //                } else {
  584.             //                    // TODO Fully Paid
  585.             //                    $paidStatus = $this->paymentStatusEnum::PAYMENT_STATUS_PAID;
  586.             //                }
  587.             //            }
  588.             //
  589.             //            $entity->setPaidStatus([
  590.             //                "calculated" => $calculatedTotals, "paid" => $paidTotals, "status" => $paidStatus
  591.             //            ]);
  593.         }
  595.         // Update Virtual Column
  596.         if($entity instanceof Invoices){
  597.             if(!is_null($entity->getPaidAt())){
  598.                 $entity->setWeekOfYear($entity->getPaidAt()->format('o-W'));
  599.             }
  600.         }
  601.     }
  604.     private function finalCalculatedStockQuantityFromTransactions(PersistentCollection $transactions): float {
  606.         $finalQuantity = 0;
  608.         foreach ( $transactions as $transaction) {
  609.             $qty = $transaction->getQuantity();
  610.             if ($transaction->getTransactionType() === 'in') {
  611.                 $finalQuantity += $qty;
  612.             } elseif ($transaction->getTransactionType() === 'out') {
  613.                 $finalQuantity -= $qty;
  614.             }
  615.         }
  617.         return $finalQuantity;
  618.     }
  621.     private function setWorkerImagePathRuntime(Worker $worker): void
  622.     {
  623.         $profileImage = $worker->getProfileImage();
  625.         if (!$profileImage) {
  626.             return;
  627.         }
  629.         // 1️⃣ Eğer zaten path eklenmişse tekrar ekleme
  630.         $fetchDir = rtrim($this->serviceArgs['dirs']['workerImagesFetchDir'], DIRECTORY_SEPARATOR);
  632.         if (!str_starts_with($profileImage, $fetchDir)) {
  633.             // 2️⃣ Runtime olarak path’i set et
  634.             // Reflection ile Doctrine dirty check’i bypass et
  635.             $reflection = new \ReflectionProperty(Worker::class, 'profile_image');
  636.             $reflection->setAccessible(true);
  637.             $reflection->setValue($worker, $fetchDir . DIRECTORY_SEPARATOR . $profileImage);
  639. //            $reflectionFull = new \ReflectionProperty(Worker::class, 'profileImageFullPath');
  640. //            $reflectionFull->setAccessible(true);
  641. //            $reflectionFull->setValue($worker, $fetchDir . DIRECTORY_SEPARATOR . $profileImage);
  642.         }
  643.     }
  645. }