vendor/simpledot/edm-bundle/AWEdmBundle/Controller/EdmApiController.php line 32

Open in your IDE?
  1. <?php
  2. namespace AWEdmBundle\Controller;
  4. use AWCmsBundle\Security\CurrentUserProvider;
  5. use AWCmsBundle\Tool\FileSystemTool;
  6. use AWEdmBundle\Entity\Document;
  7. use AWEdmBundle\Entity\File;
  8. use AWEdmBundle\Entity\Folder;
  9. use AWEdmBundle\Manager\DocumentManager;
  10. use Doctrine\DBAL\Exception\ForeignKeyConstraintViolationException;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use League\Flysystem\FileNotFoundException;
  13. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Method;
  14. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  15. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Security;
  16. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  17. use Symfony\Component\HttpFoundation\JsonResponse;
  18. use Symfony\Component\HttpFoundation\Request;
  19. use Symfony\Component\HttpFoundation\Response;
  20. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  21. use Symfony\Component\Security\Core\Exception\AccessDeniedException;
  22. use FOS\RestBundle\Controller\Annotations as Rest;
  23. use Symfony\Contracts\Translation\TranslatorInterface;
  25. /**
  26.  * Class EdmApiController
  27.  * @package AWEdmBundle\Controller
  28.  *
  29.  * @Security("has_role('ROLE_USER')")
  30.  * @Route("/api/ged")
  31.  */
  32. class EdmApiController extends RestController
  33. {
  35.     /**
  36.      * @Rest\Get("documents", name="get_documents_index", options={"expose"=true,"i18n"=false})
  37.      * @Method("GET")
  38.      * @Template
  39.      * @return array
  40.      */
  41.     public function getDocumentsIndexAction()
  42.     {
  43.         return  [];
  44.     }
  47.     /**
  48.      * Returns all the files and folders of a folder
  49.      * @Rest\Get("/get_folder_content", name="get_files", options={"expose"=true,"i18n"=false})
  50.      * @Security("has_role('ROLE_USER')")
  51.      * @Rest\View(serializerGroups={"ged"})
  52.      * @param Request $request
  53.      * @return array
  54.      */
  55.     public function getFolderContentAction(Request $request)
  56.     {
  57.         $subFolder = $request->query->get('subFolder', '');
  58.         $parentId = $request->query->get('parent_id', null);
  60.         $folders = $request->query->get('folders', null);
  61.         $foldersId = explode(', ', $folders);
  64.         $offset = $request->query->get('offset', 0);
  65.         $limit = $request->query->get('limit', 100);
  68.         /** @var EntityManagerInterface $entityManager */
  69.         $entityManager = $this->get('doctrine.orm.default_entity_manager');
  71.         if ('' != $subFolder) {
  72.             if($parentId === null){
  73.                 $parentId = $entityManager->getRepository(Folder::class)->findOneBy(['parent' => null])->getId();
  74.             }
  75.             $folders = $entityManager->getRepository(Folder::class)->findBy(['subFolder' => $subFolder, 'parent' => $parentId], null, $limit, $offset);
  76.             $folders = array_merge($folders, $entityManager->getRepository(Folder::class)->findBy(['subFolder' => $subFolder, 'parent' => $parentId, 'id' => $foldersId], null, $limit, $offset));
  77.             $files = $entityManager->getRepository(File::class)->findBy(['parent' => $parentId], null, $limit, $offset);
  79.         }else{
  80.             throw new \InvalidArgumentException('Need a subFolder');
  81.         }
  82.         return [
  83.             'data' => array_merge($folders, $files)
  84.         ];
  85.     }
  87.     /**
  88.      * @Rest\GET("/get_document/{document}", name="get_document", options={"expose"=true,"i18n"=false})
  89.      * @Rest\View(serializerGroups={"ged"})
  90.      * @param Document $document
  91.      * @return array
  92.      */
  93.     public function getDocumentAction(Document $document)
  94.     {
  95.         return [
  96.             'data' => $document
  97.         ];
  98.     }
  100.     /**
  101.      * @Rest\Post("/post_documents", name="post_documents", options={"expose"=true,"i18n"=false})
  102.      * @Security("has_role('ROLE_USER')")
  103.      * @Rest\View(serializerGroups={"ged"})
  104.      * @param Request $request
  105.      * @return array
  106.      */
  107.     public function postDocumentsAction(Request $request)
  108.     {
  109.         $documentManager = $this->get('awedm.manager.document');
  110.         $entityManager = $this->get('doctrine.orm.default_entity_manager');
  112.         $documentsProperties = $request->get('document_collection')['documents'];
  113.         $documents = [];
  115.         foreach ($documentsProperties as $documentProperties) {
  116.             $id = (array_key_exists('id', $documentProperties) ? $documentProperties['id'] : null);
  118.             $name = $documentProperties['name'];
  119.             $parentId = $documentProperties['parent_id'];
  120.             $type = $documentProperties['type'];
  122.             $document = null;
  123.             if (null !== $id && '' != $id) {
  124.                 if($type === Document::TYPE_FILE){
  125.                     $document = $this->get('doctrine.orm.default_entity_manager')->getRepository(File::class)->findOneBy(['id' => $id]);
  126.                 }else{
  127.                     $document = $this->get('doctrine.orm.default_entity_manager')->getRepository(Folder::class)->findOneBy(['id' => $id]);
  128.                 }
  129.             }
  130.             $folderParent = null;
  131.             /**
  132.              * @TODO to remove...
  133.              */
  134.             if ('' != $parentId and preg_match('|\.|', $parentId)) {
  135.                 $folderParent = $entityManager->getRepository(Folder::class)->findOneBy(['uniqueId' => $parentId]);
  136.             }elseif ('' != $parentId){
  137.                 $folderParent = $entityManager->getRepository(Folder::class)->find($parentId);
  138.             }
  139.             if (null === $document) {
  140.                 switch ($type) {
  141.                     case 'folder':
  142.                         $document = new Folder();
  143.                         if(array_key_exists('subFolder', $documentProperties)){
  144.                             $document->setSubFolder($documentProperties['subFolder']);
  145.                         }elseif ($folderParent){
  146.                             $document->setSubFolder($folderParent->getSubFolder());
  147.                         }
  148.                         break;
  149.                     case 'file':
  150.                         $document = new File();
  151.                         break;
  152.                 }
  153.             }
  156.             $document->setName($name);
  157.             $document->setParent($folderParent);;
  159.             $documentManager->save($document);
  160.             $documents[] = $document;
  161.         }
  163.         return [
  164.             'data' => $documents
  165.         ];
  166.     }
  168.     /**
  169.      * @Rest\Patch("/patch_documents", name="patch_documents", options={"expose"=true,"i18n"=false})
  170.      * @Rest\View(serializerGroups={"ged"})
  171.      * @Security("has_role('ROLE_USER')")
  172.      *
  173.      * @param Request $request
  174.      * @return array
  175.      */
  176.     public function patchDocumentsAction(Request $request)
  177.     {
  178.         return $this->postDocumentsAction($request);
  179.     }
  180.     
  181.     /**
  182.      * @Rest\Delete("/delete_documents", name="delete_documents", options={"expose"=true,"i18n"=false})
  183.      * @Rest\View(serializerGroups={"ged"})
  184.      * @Security("has_role('ROLE_USER')")
  185.      *
  186.      * @param Request $request
  187.      * @param CurrentUserProvider $userProvider
  188.      * @return JsonResponse
  189.      */
  190.     public function deleteDocumentsAction(Request $request, CurrentUserProvider $userProvider)
  191.     {
  192.         $documentManager = $this->get('awedm.manager.document');
  193.         $fileIds = (array) $request->get('files');
  194.         $folderIds = (array) $request->get('folders');
  196.         if(!$fileIds && !$folderIds){
  197.             return new JsonResponse(['success' => false], Response::HTTP_BAD_REQUEST);
  198.         }
  200.         $documents = [];
  201.         foreach ($fileIds as $documentId) {
  202.             /** @var File $document */
  203.             if ($document = $this->get('doctrine.orm.default_entity_manager')->getRepository(File::class)->find($documentId)) {
  204.                 $documents[] = $document;
  205.             }
  206.         }
  207.         foreach ($folderIds as $documentId) {
  208.             /** @var File $document */
  209.             if ($document = $this->get('doctrine.orm.default_entity_manager')->getRepository(Folder::class)->find($documentId)) {
  210.                 $documents[] = $document;
  211.             }
  212.         }
  213.         /** @var Document $document */
  214.         foreach ($documents as $document) {
  215.             if (
  216.                 !(
  217.                     $this->isGranted('ROLE_ADMIN')
  218.                     || ($this->isGranted('ROLE_USER') && $document->getCreatedBy()->getId() == $userProvider->get()->getId())
  219.                 )
  220.             ) {
  221.                 throw new AccessDeniedException();
  222.             }
  223.             if ($document) {
  224.                 try{
  225.                     $documentManager->delete($document);
  226.                 }
  227.                 catch(\Exception $e){
  228.                     if($e instanceof ForeignKeyConstraintViolationException){
  229.                         return new JsonResponse(['success' => false, 'error' => $this->get('translator')->trans('error.foreign_key_constraint')], Response::HTTP_BAD_REQUEST);
  230.                     }
  232.                     return new JsonResponse(['success' => false, 'error' => $e->getMessage()], Response::HTTP_NOT_FOUND);
  233.                 }
  234.             }
  235.         }
  236.         return new JsonResponse(['success' => true]);
  238.     }
  239.     
  240.     /**
  241.      * @Rest\Post("/post_documents_upload/{folder}", name="post_documents_upload", options={"expose"=true,"i18n"=false})
  242.      * @Rest\View(serializerGroups={"ged"})
  243.      * @Security("has_role('ROLE_USER')")
  244.      *
  245.      * @param Request $request
  246.      * @param Folder $folder
  247.      * @return array
  248.      * @throws \Exception
  249.      */
  250.     public function postDocumentsUploadAction(Request $request, Folder $folder, DocumentManager $documentManager)
  251.     {
  252.         $subFolder = $request->query->get('subFolder', '');
  253.         $data = [];
  255.         if (count($_FILES) > 0) {
  256.             $data = $documentManager->upload($subFolder, $folder, 'files');
  257.         }
  259.         return ['data' => $data];
  260.     }
  262.     /**
  263.      * @Rest\Get("/get_download_documents", name="get_download_documents", options={"expose"=true,"i18n"=false})
  264.      * @param Request $request
  265.      * @return \Symfony\Component\HttpFoundation\RedirectResponse|Response
  266.      */
  267.     public function getDownloadDocumentsAction(Request $request)
  268.     {
  269.         /** @var DocumentManager $documentManager */
  270.         $documentManager = $this->get('awedm.manager.document');
  271.         $archiveName = "archive_".uniqid();
  272.         $subFolder = $request->query->get('subFolder');
  273.         $tmpDirectory = '/tmp/'.$archiveName;
  275.         $fileIds = (array) $request->get('files');
  276.         $folderIds = (array) $request->get('folders');
  278.         $documents = [];
  279.         foreach ($fileIds as $documentId) {
  280.             /** @var File $document */
  281.             if ($document = $this->get('doctrine.orm.default_entity_manager')->getRepository(File::class)->find($documentId)) {
  282.                 $documents[] = $document;
  283.             }
  284.         }
  285.         foreach ($folderIds as $documentId) {
  286.             /** @var File $document */
  287.             if ($document = $this->get('doctrine.orm.default_entity_manager')->getRepository(Folder::class)->find($documentId)) {
  288.                 $documents[] = $document;
  289.             }
  290.         }
  291.         if(count($documents) == 1 and reset($documents) instanceof File)
  292.             return $documentManager->downloadFile(reset($documents));
  293.         $documentManager->createTree($documents, $tmpDirectory, $subFolder);
  295.         $zipFile = realpath($tmpDirectory.DIRECTORY_SEPARATOR.'..'.DIRECTORY_SEPARATOR).DIRECTORY_SEPARATOR.$archiveName.'.zip';
  296.         //dump($zipFile);exit;
  297.         if (file_exists($tmpDirectory)) {
  298.             FileSystemTool::zipFolder(realpath($tmpDirectory), $zipFile);
  299.             FileSystemTool::rmRecursive($tmpDirectory);
  300.             if (file_exists($zipFile)) {
  301.                 FileSystemTool::rangeDownload($zipFile, basename($zipFile), true);
  302.                 exit;
  303.             }
  304.         }
  308.         return new Response('File not found.', Response::HTTP_NOT_FOUND);
  309.     }
  311.     /**
  312.      * @Rest\Get("get_file/{file}", name="get_file", options={"expose"=true,"i18n"=false})
  313.      * @Method("GET")
  314.      * @param File $file
  315.      * @return \Symfony\Component\HttpFoundation\StreamedResponse
  316.      */
  317.     public function getFileAction(File $file)
  318.     {
  319.         /** @var DocumentManager $documentManager */
  320.         $documentManager = $this->get('awedm.manager.document');
  321.         try {
  322.             $response = $documentManager->downloadFile($file);
  323.         } catch (FileNotFoundException $e) {
  324.             throw new NotFoundHttpException();
  325.         }
  327.         return $response;
  328.     }
  330.     /**
  331.      * @Rest\Get("/check_folder_tree", name="check_folder_tree", options={"expose"=true,"i18n"=false})
  332.      * @Method("GET")
  333.      * @param Request $request
  334.      * @return JsonResponse
  335.      */
  336.     public function getCheckFolderTreeAction(Request $request)
  337.     {
  338.         $path = str_replace(' ', '', $request->get('path'));
  339.         $tree = explode(',', $path);
  340.         end($tree);         // move the internal pointer to the end of the array
  341.         $lastFolderId = key($tree);
  342.         /** @var Folder $lastFolder */
  343.         $lastFolder = $this->get('doctrine.orm.default_entity_manager')->getRepository(Folder::class)->findOneBy(['id' => $lastFolderId]);
  344.         $emdPath = implode(',', $this->container->get('awedm.manager.document')->getFolderIdTree($lastFolder));
  346.         $response = new JsonResponse();
  347.         $response->setData(['success' => $emdPath == $path]);
  348.         return $response;
  349.     }
  350. }