src/Controller/Api/v3/ProjectController.php line 126

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Api\v3;
  5. use App\Controller\Api\Service\CustomerService;
  6. use App\Controller\Api\Service\ProjectService;
  7. use App\Entity\Projects;
  8. use App\Entity\User;
  9. use App\Enum\SeverityInterface;
  10. use App\Service\SerializeService\BranchSerialize;
  11. use App\Service\SerializeService\CustomerSerialize;
  12. use App\Service\SerializeService\ProjectSerialize;
  13. use App\Service\SerializeService\ReferenceSerialize;
  14. use App\Service\StreamingService;
  15. use Doctrine\Common\Collections\ArrayCollection;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Sensio\Bundle\FrameworkExtraBundle\Configuration\ParamConverter;
  18. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\HttpFoundation\StreamedResponse;
  22. use Symfony\Component\Routing\Annotation\Route;
  23. use Symfony\Component\Serializer\SerializerInterface;
  24. use Symfony\Contracts\Translation\TranslatorInterface;
  26. /**
  27.  * @Route("/api/v3/project")
  28. */
  29. class ProjectController extends AbstractController
  30. {
  31.     /**
  32.      * ✅
  33.      * @Route("/streamed-fetch/{project_id}", name="api_v3_project_fetch_streamed", defaults={"project_id": null})
  34.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  35.      */
  36.     public function streamedFetch(?Projects $project, TranslatorInterface $translator, ProjectService $projectService, ProjectSerialize $projectSerialize, BranchSerialize $branchSerialize, CustomerSerialize $customerSerialize, ReferenceSerialize $referenceSerialize): StreamedResponse
  37.     {
  38.         $streaming = new StreamingService([
  39.             "localText" => ["completed" => $translator->trans('Completed')]
  40.         ]);
  42.         $streaming->appendStream(
  43.             "branches",
  44.             $translator->trans('Loading project data'),
  45.             // 🔥Branches fetch $ serialize
  46.             fn() => $branchSerialize->branches()
  47.         );
  48.         $streaming->appendStream(
  49.             "customers",
  50.             $translator->trans('Loading customers data'),
  51.             // 🔥Customer fetch $ serialize
  52.             fn() => $customerSerialize->serializeCore()
  53.         );
  54.         $streaming->appendStream(
  55.             "countries",
  56.             $translator->trans('Loading countries data'),
  57.             // 🔥 Countries fetch $ serialize
  58.             fn() => $referenceSerialize->serializedCountries()
  59.         );
  60.         $streaming->appendStream(
  61.             "certificates",
  62.             $translator->trans('Loading certificates data'),
  63.             // 🔥 Certificates fetch $ serialize
  64.             fn() => $referenceSerialize->serializedCertificates()
  65.         );
  67.         $streaming->appendStream(
  68.             "qualifications",
  69.             $translator->trans('Loading Qualifications data'),
  70.             // 🔥 Qualifications fetch $ serialize
  71.             fn() => $referenceSerialize->serializedQualifications()
  72.         );
  74.         $streaming->appendStream(
  75.             "invoice_types",
  76.             $translator->trans('Loading Invoice type'),
  77.             // 🔥 InvoiceTypes fetch $ serialize
  78.             fn() => $referenceSerialize->serializedInvoiceTypes()
  79.         );
  81.         if($project){
  82.             $streaming->appendStream(
  83.                 "project",
  84.                 $translator->trans('Loading Project'),
  85.                 fn() => $projectSerialize->setEntity($project)->serializeFull()
  86.             );
  87.         }
  89.         return $streaming->flush();
  90.     }
  92.     /**
  93.      * ✅
  94.      * @Route("/projects", name="api_v3_projects")
  95.      * @param EntityManagerInterface $manager
  96.      * @param SerializerInterface $serializer
  97.      * @param ProjectSerialize $projectSerialize
  98.      * @return Response
  99.      * Partner Analyse for projects
  100.      */
  101.     public function allProjects( EntityManagerInterface $manager, SerializerInterface $serializer, ProjectSerialize $projectSerialize ): Response
  102.     {
  103.         $projects = new ArrayCollection($manager->getRepository(Projects::class)->findAll());
  105.         $projects = $projectSerialize->setEntity($projects)->serializeWithRequirements();
  107.         return $this->json([
  108.             "projects" => $projects
  109.         ], Response::HTTP_OK, [], []);
  111.     }
  114.     /**
  115.      * ✅
  116.      * @Route("/projects/{classify}", name="api_v3_projects_classify")
  117.      * @param ProjectService $projectService
  118.      * @param ProjectSerialize $projectSerialize
  119.      * @param TranslatorInterface $translator
  120.      * @param Request $request
  121.      * @param string $classify
  122.      * @return Response
  123.      * Partner Analyse for projects
  124.      * @throws \Exception
  125.      */
  126.     public function fetchClassifyProjects(ProjectService $projectService, ProjectSerialize $projectSerialize, TranslatorInterface $translator, Request $request, string $classify = "active" ): Response
  127.     {
  128.         $projects = $projectService->fetchProjects($classify);
  130.         if($projectService->getException()){
  131.             return $this->json([
  132.                 "message" => $projectService->getException()->getMessage(),
  133.                 "severity" => SeverityInterface::WARNING
  134.             ], $projectService->getException()->getCode());
  135.         }
  137.         $serializedProjects = $projectSerialize->setEntity($projects)->serializeForMainList();
  140.         return $this->json([
  141.             "projects" => $serializedProjects,
  142.             $classify => $serializedProjects,
  143.             "message" => $translator->trans('Projects fetched successfully'),
  144.             "severity" => SeverityInterface::SUCCESS
  145.         ], Response::HTTP_OK);
  147.     }
  149.     /**
  150.      *
  151.      * @Route("/fetch/{project_id}", name="api_v3_project_fetch", methods={"POST"}, requirements={"project_id": "\d+"})
  152.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  153.      * @param int|null $project_id
  154.      * @throws \Exception
  155.      */
  156.     public function fetch( ?Projects $project, ProjectSerialize $projectSerialize,
  157.                                   CustomerSerialize $customerSerialize,
  158.                                   ReferenceSerialize $referenceSerialize,
  159.                                   CustomerService $customerService, TranslatorInterface $translator, int $project_id ): Response
  160.     {
  161.         if( $project_id && !$project ){
  162.             return $this->json([
  163.                 "message" => $translator->trans('Project not found'),
  164.                 "severity" => SeverityInterface::ERROR
  165.             ], Response::HTTP_NOT_FOUND);
  166.         }
  168.         $serializedProject = $projectSerialize->setEntity($project)->serializeFull();
  170.         return $this->json([
  171.             "message" => $translator->trans('Loaded project successfully'),
  172.             "severity" => SeverityInterface::SUCCESS,
  173.             "project" => $serializedProject,
  174.         ], Response::HTTP_OK );
  175.     }
  177.     /**
  178.      * ✅✅
  179.      * @Route("/assign-branches/{project_id}", name="api_v3_project_assign_branches_to_project", defaults={"project_id": null})
  180.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  181.      * @param int|null $project_id
  182.      * @return Response
  183.      * Partner Analyse for projects
  184.      * @throws \Exception
  185.      */
  186.     public function assignBranches( ?Projects $project, TranslatorInterface $translator, ProjectService $projectService, Request $request, ProjectSerialize $projectSerialize, int $project_id = null ): Response
  187.     {
  189.         if($project_id && !$project){
  190.             return $this->json([
  191.                 "message" => $translator->trans('Project not found'),
  192.                 "severity" => SeverityInterface::ERROR
  193.             ]);
  194.         }
  196.         $params = $request->request;
  197.         #dd($params);
  198.         $project = $projectService->setEntity($project, $project_id)->setParams($params)->joinBranches();
  200.         if($projectService->getException()){
  201.             return $this->json([
  202.                 "message" => $projectService->getException()->getMessage(),
  203.                 "severity" => SeverityInterface::ERROR
  204.             ]);
  205.         }
  207.         $serializedProject = $projectSerialize->setEntity($project)->serializeFull();
  209.         return $this->json([
  210.             "message" => $translator->trans('Joined branches to project successfully'),
  211.             "severity" => SeverityInterface::SUCCESS,
  212.             "project" => $serializedProject
  213.         ], Response::HTTP_OK, [], []);
  215.     }
  218.     /**
  219.      * ✅
  220.      * @Route("/upsert/{project_id}", name="api_v3_project_upsert", defaults={"project_id": null})
  221.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  222.      * @param int|null $project_id
  223.      * @return Response
  224.      * Partner Analyse for projects
  225.      * @throws \Exception
  226.      */
  227.     public function upsert( ?Projects $project, TranslatorInterface $translator, ProjectService $projectService, Request $request, ProjectSerialize $projectSerialize, int $project_id = null ): Response
  228.     {
  230.         if($project_id && !$project){
  231.             return $this->json([
  232.                 "message" => $translator->trans('Project not found'),
  233.                 "severity" => SeverityInterface::ERROR
  234.             ]);
  235.         }
  237.         $project = $projectService->setEntity($project, $project_id)->setParams($request->request)->upsert();
  239.         if($projectService->getException()){
  240.             return $this->json([
  241.                 "message" => $projectService->getException()->getMessage(),
  242.                 "severity" => SeverityInterface::WARNING
  243.             ]);
  244.         }
  246.         $serializedProject = $projectSerialize->setEntity($project)->serializeFull();
  247.         #dd($serializedProject);
  248.         return $this->json([
  249.             "message" => $translator->trans('Project upsert successfully'),
  250.             "severity" => SeverityInterface::SUCCESS,
  251.             "project" => $serializedProject
  252.         ], Response::HTTP_OK, [], []);
  254.     }
  256.     /**
  257.      * TODO README !!!
  258.      * TODO Sync (Progress) Su an icin (ProjectOrderService) icinde bagimsiz yonetiliyor!, onysaki projece calculator Servise var onda Isleri parcalara böl ve o servisi kullan !!!
  259.      * ✅
  260.      * @Route("/sync-progress/{project_id}", name="api_project_sync_progress", methods={"POST"})
  261.      * @ParamConverter("project", options={"mapping":{"project_id":"id"}})
  262.      */
  263.     public function syncProgress(?Projects $project, ProjectService $projectService, ProjectSerialize $projectSerialize, TranslatorInterface $translator, ?int $project_id = null ): Response
  264.     {
  265.         try{
  266.             $project = $projectService->setEntity($project, $project_id)->syncMetricProgress();
  267.             $serializedProject = $projectSerialize->setEntity($project)->serializeFull();
  268.             return $this->json([
  269.                 'project' => $serializedProject,
  270.                 "message"=>$translator->trans('Progress sync successfully'),
  271.                 "severity" => SeverityInterface::SUCCESS
  272.             ], Response::HTTP_OK );
  273.         } catch (\Exception $exception){
  274.             return $this->json([
  275.                 'message'=>$exception->getMessage(),
  276.                 "severity" => SeverityInterface::ERROR
  277.             ], Response::HTTP_UNAUTHORIZED );
  278.         }
  279.     }
  281.     /**
  282.      *
  283.      * @Route("/overview/{project_id}", name="api_v3_project_overview", methods={"POST"}, requirements={"project_id": "\d+"})
  284.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  285.      * @param int|null $project_id
  286.      * @throws \Exception
  287.      */
  288.     public function overview( ?Projects $project, ProjectSerialize $projectSerialize,
  289.                            TranslatorInterface $translator, int $project_id ): Response
  290.     {
  291.         if( $project_id && !$project ){
  292.             return $this->json([
  293.                 "message" => $translator->trans('Project not found'),
  294.                 "severity" => SeverityInterface::ERROR
  295.             ], Response::HTTP_NOT_FOUND);
  296.         }
  299.         $serializedProject = $projectSerialize->setEntity($project)->serializeFull();
  300.         $serializedMetrics = $projectSerialize->setEntity($project)->serializeOverview();
  302.         return $this->json([
  303.             "message" => $translator->trans('Loaded project successfully'),
  304.             "severity" => SeverityInterface::SUCCESS,
  305.             "project" => $serializedProject,
  306.             "metrics" => $serializedMetrics
  307.         ], Response::HTTP_OK );
  308.     }
  311.     /**
  312.      * @Route("/re-classify/{classify}", name="app_api_project_reclassify", methods={"POST"})
  313.      * @ParamConverter("project", options={"mapping": {"project_id": "id"}})
  314.      * @throws \Exception
  315.      */
  316.     public function reClassify ( ProjectService $projectService, ProjectSerialize $projectSerialize, Request $request, TranslatorInterface $translator, string $classify = "all"): Response {
  318.         $projectService
  319.             ->setParams($request->request)
  320.             ->reClassify($classify);
  322.         if(!is_null($projectService->getException())){
  323.             return $this->json([
  324.                 "message" => $projectService->getException()->getMessage(),
  325.                 "severity" => SeverityInterface::ERROR
  326.             ], Response::HTTP_NOT_ACCEPTABLE);
  327.         }
  329.         $sourceClassify     = $request->request->get('source');
  330.         $targetClassify     = $classify;
  332.         $projectsTarget     = $projectService->fetchProjects($targetClassify);
  333.         $projectsCurrent    = $projectService->fetchProjects($sourceClassify);
  335.         if($projectService->getException()){
  336.             return $this->json([
  337.                 "message" => $projectService->getException()->getMessage(),
  338.                 "severity" => SeverityInterface::WARNING
  339.             ], $projectService->getException()->getCode());
  340.         }
  342.         // Moved To
  343.         $serTarget  = $projectSerialize->setEntity($projectsTarget)->serializeForMainList();
  344.         // Leaved from
  345.         $serCurr    = $projectSerialize->setEntity($projectsCurrent)->serializeForMainList();
  347.         return $this->json([
  348.             // Current Classify
  349.             "source" => ["key" => $sourceClassify, "value" => $serCurr],
  350.             "target" => ["key" => $classify, "value" => $serTarget],
  351.             "message" => $translator->trans('Projects classified successfully'),
  352.             "severity" => SeverityInterface::SUCCESS
  353.         ], Response::HTTP_OK);
  354.     }
  356.     /**
  357.      * @Route("/labor-details/{project_id}", name="api_v3_project_labor_details", methods={"POST"}, requirements={"project_id": "\d+"})
  358.      * @ParamConverter("project", options={"mapping": {"project_id": "id"}})
  359.      */
  360.     public function laborDetails(?Projects $project, ProjectService $projectService, Request $request): Response
  361.     {
  362.         $laborDetails = $projectService
  363.             ->setEntity($project)
  364.             ->setParams($request->request)
  365.             ->laborDetails();
  367.         if ($projectService->getException()) {
  368.             return $this->json([
  369.                 'message'  => $projectService->getException()->getMessage(),
  370.                 'severity' => SeverityInterface::WARNING,
  371.             ], Response::HTTP_BAD_REQUEST);
  372.         }
  374.         return $this->json($laborDetails, Response::HTTP_OK);
  375.     }
  377.     /**
  378.      * Tüm projelerin metriklerini SSE (Server-Sent Events) stream ile hesaplar.
  379.      * Her proje işlendikçe progress event'i gönderilir.
  380.      * Abort veya hata durumunda Doctrine transaction rollback yapılır (DB'ye yazılmaz).
  381.      *
  382.      * Nginx: proxy_buffering off  veya  X-Accel-Buffering: no header gereklidir.
  383.      *
  384.      * @Route("/sync-all-metrics", name="api_v3_project_sync_all_metrics", methods={"POST"})
  385.      */
  386.     public function syncAllMetrics(ProjectService $projectService, Request $request): StreamedResponse
  387.     {
  388.         $syncToken = (string) $request->request->get('syncToken', uniqid('sync_', true));
  390.         return new StreamedResponse(function() use ($projectService, $syncToken) {
  392.             ignore_user_abort(false);
  394.             $emit = function(array $event) {
  395.                 echo 'data: ' . json_encode($event) . "\n\n";
  396.                 if (ob_get_level() > 0) {
  397.                     ob_flush();
  398.                 }
  399.                 flush();
  400.             };
  402.             $projectService->syncAllMetricsStreamed($syncToken, $emit);
  404.         }, Response::HTTP_OK, [
  405.             'Content-Type'      => 'text/event-stream',
  406.             'Cache-Control'     => 'no-cache, no-store',
  407.             'X-Accel-Buffering' => 'no',
  408.             'Connection'        => 'keep-alive',
  409.         ]);
  410.     }
  412.     /**
  413.      * Tek bir projenin metriklerini SSE stream ile hesaplar.
  414.      * syncAllMetricsStreamed'in aynı altyapısını kullanır, sadece o projeye filtreli.
  415.      *
  416.      * @Route("/sync-project-metrics/{project_id}", name="api_v3_project_sync_project_metrics", methods={"POST"}, requirements={"project_id": "\d+"})
  417.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  418.      */
  419.     public function syncProjectMetrics(?Projects $project, ProjectService $projectService, Request $request, int $project_id): StreamedResponse
  420.     {
  421.         if (!$project) {
  422.             return new StreamedResponse(function() use ($project_id) {
  423.                 echo 'data: ' . json_encode(['type' => 'error', 'message' => "Project #{$project_id} not found"]) . "\n\n";
  424.                 flush();
  425.             }, Response::HTTP_OK, [
  426.                 'Content-Type'      => 'text/event-stream',
  427.                 'Cache-Control'     => 'no-cache, no-store',
  428.                 'X-Accel-Buffering' => 'no',
  429.             ]);
  430.         }
  432.         $syncToken = (string) $request->request->get('syncToken', uniqid('sync_', true));
  434.         return new StreamedResponse(function() use ($projectService, $syncToken, $project) {
  436.             ignore_user_abort(false);
  438.             $emit = function(array $event) {
  439.                 echo 'data: ' . json_encode($event) . "\n\n";
  440.                 if (ob_get_level() > 0) {
  441.                     ob_flush();
  442.                 }
  443.                 flush();
  444.             };
  446.             $projectService->syncAllMetricsStreamed($syncToken, $emit, $project->getId());
  448.         }, Response::HTTP_OK, [
  449.             'Content-Type'      => 'text/event-stream',
  450.             'Cache-Control'     => 'no-cache, no-store',
  451.             'X-Accel-Buffering' => 'no',
  452.             'Connection'        => 'keep-alive',
  453.         ]);
  454.     }
  456.     /**
  457.      * FE'nin abort sinyali gönderdiği endpoint.
  458.      * Temp dosyaya flag yazar; syncAllMetricsStreamed her iterasyonda bunu kontrol eder.
  459.      *
  460.      * @Route("/abort-sync", name="api_v3_project_abort_sync", methods={"POST"})
  461.      */
  462.     public function abortSync(ProjectService $projectService, Request $request): Response
  463.     {
  464.         $syncToken = (string) $request->request->get('syncToken', '');
  466.         if (empty($syncToken)) {
  467.             return $this->json(['message' => 'syncToken required'], Response::HTTP_BAD_REQUEST);
  468.         }
  470.         $projectService->setAbortFlag($syncToken);
  472.         return $this->json(['message' => 'Abort signal received'], Response::HTTP_OK);
  473.     }
  475.     /**
  476.      * Bos projeyi siler (order / stakeholder / timesheet payment yoksa).
  477.      * Bos degilse bloklar.
  478.      *
  479.      * @Route("/delete/{project_id}", name="api_v3_project_delete", methods={"POST"}, requirements={"project_id": "\d+"})
  480.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  481.      */
  482.     public function delete(?Projects $project, ProjectService $projectService, TranslatorInterface $translator, Request $request, ?int $project_id = null): Response
  483.     {
  484.         if ($project_id && !$project) {
  485.             return $this->json([
  486.                 "message" => $translator->trans("Project not found!"),
  487.                 "severity" => SeverityInterface::ERROR
  488.             ], Response::HTTP_NOT_FOUND);
  489.         }
  491.         // Stakeholder/payment blogunu asmak icin force + override sifresi
  492.         $force = filter_var($request->request->get('force'), FILTER_VALIDATE_BOOLEAN);
  493.         $password = $request->request->get('password');
  495.         $removedId = $projectService->setEntity($project)->cascadeDelete($force, $password);
  497.         if ($projectService->getException()) {
  498.             $exception = $projectService->getException();
  499.             return $this->json([
  500.                 "message" => $exception->getMessage(),
  501.                 "severity" => SeverityInterface::WARNING
  502.             ], $exception->getCode() === Response::HTTP_UNAUTHORIZED ? Response::HTTP_UNAUTHORIZED : Response::HTTP_BAD_REQUEST);
  503.         }
  505.         return $this->json([
  506.             "message" => $translator->trans('Project deleted successfully'),
  507.             "severity" => SeverityInterface::SUCCESS,
  508.             "id" => $removedId,
  509.             "mode" => "delete"
  510.         ], Response::HTTP_OK);
  511.     }
  513.     /**
  514.      * Force-delete onizlemesi: projenin tum bagimlilik ozeti (aggregate).
  515.      *
  516.      * @Route("/dependency-summary/{project_id}", name="api_v3_project_dependency_summary", methods={"POST"}, requirements={"project_id": "\d+"})
  517.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  518.      */
  519.     public function dependencySummary(?Projects $project, ProjectService $projectService, TranslatorInterface $translator): Response
  520.     {
  521.         if (!$project) {
  522.             return $this->json([
  523.                 "message" => $translator->trans("Project not found!"),
  524.                 "severity" => SeverityInterface::ERROR
  525.             ], Response::HTTP_NOT_FOUND);
  526.         }
  528.         return $this->json([
  529.             "summary" => $projectService->setEntity($project)->dependencySummary()
  530.         ], Response::HTTP_OK);
  531.     }
  533.     /**
  534.      * Projeyi + TUM bagimliliklarini streamed (adim adim) force-delete eder. GERI DONUS YOK.
  535.      * EventSource yalnizca GET -> methods YAZILMAZ. Sifre query param (basit desen).
  536.      *
  537.      * @Route("/force-delete-streamed/{project_id}", name="api_v3_project_force_delete_streamed", requirements={"project_id": "\d+"})
  538.      * @ParamConverter("project", options={"mapping":{"project_id": "id"}})
  539.      */
  540.     public function forceDeleteStreamed(?Projects $project, ProjectService $projectService, Request $request): StreamedResponse
  541.     {
  542.         $password = $request->query->get('password');
  543.         return $projectService->setEntity($project)->forceDeleteStreamed($password);
  544.     }
  545. }