src/PromemoriaBundle/Services/HookAssetEvent.php line 36

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: lucamontanera
  5.  * Date: 2019-03-15
  6.  * Time: 15:41
  7.  */
  9. namespace App\PromemoriaBundle\Services;
  11. use Pimcore\Event\Model\AssetEvent;
  12. use Pimcore\Event\Model\ElementEventInterface;
  13. use Pimcore\Model\Metadata\Predefined\Listing;
  14. use Pimcore\Model\Element\Tag;
  16. class HookAssetEvent {
  18.     public function onPreAdd(ElementEventInterface $e) {
  19.         if($e instanceof AssetEvent) {
  20.             $asset = $e->getAsset();
  21.         }
  22.     }
  24.     public function onPostAdd(ElementEventInterface $e) {
  25.         if($e instanceof AssetEvent) {
  26.             $asset = $e->getAsset();
  27.             $dir = $asset->getParent();
  28.             if($dir->getType() === "folder"){
  29.                 $tags = Tag::getTagsForElement("asset", $dir->getId());
  30.                 Tag::setTagsForElement("asset", $asset->getId(), $tags);
  31.             }
  32.             $this->onPostUpdate($e);
  33.         }
  34.     }
  36.     public function onPostUpdate(ElementEventInterface $e) {
  37.         if($e instanceof AssetEvent) {
  38.             $asset = $e->getAsset();
  39.             $this->ocr($asset);
  40.             $this->siegfried($asset);
  41.             $this->sfogliatore($asset, "putFile");
  42.             $this->tagFromColor($asset);
  43.             $this->syncAsset($asset);
  44.         }
  45.     }
  47.     public function onPostDelete(ElementEventInterface $e) {
  48.         if($e instanceof AssetEvent) {
  49.             $asset = $e->getAsset();
  50.             $this->sfogliatore($asset, "delFile");
  51.             $this->syncAsset($asset, "delete");
  52.         }
  53.     }
  55.     private function tagFromColor($asset){
  56.         if($asset->getType()==='image'){
  57.             $colorService = new \App\PromemoriaBundle\Strumenti\ColorService($asset->getData());
  58.             $tags = $colorService->getTag();
  59.             foreach($tags as $tagId){
  60.                 Tag::addTagToElement("asset", $asset->getId(), \Pimcore\Model\Element\Tag::getById($tagId));
  61.             }
  62.         }
  63.     }
  65.     private function siegfried($asset){
  66.         $config = \App\PromemoriaBundle\PromemoriaBundle::getConfig();
  67.         if(isset($config["siegfried"])){
  68.             $sf = shell_exec('sf -json "' . $asset->getFileSystemPath(). '"');
  69.             $version = json_decode($sf, TRUE);
  70.             if($version && isset($version["files"]) && isset($version["files"][0]) && isset($version["files"][0]["matches"])){
  71.                 $mime = $version["files"][0]["matches"][0]["mime"];
  72.                 $versione = $version["files"][0]["matches"][0]["version"];
  73.                 $asset->addMetadata("filesize", "input", $version["files"][0]["filesize"]);
  74.                 $asset->addMetadata("modified", "input", $version["files"][0]["modified"]);
  75.                 $asset->addMetadata("format", "input", $version["files"][0]["matches"][0]["format"]);
  76.                 $asset->addMetadata("version", "input", $versione);
  77.                 $asset->addMetadata("mime", "input", $mime);
  78.                 //calcolo indice
  79.                 $digitalpreservation = json_decode(file_get_contents(__DIR__ . "/../digitalpreservation.json"), TRUE);
  80.                 $valori = array_filter($digitalpreservation, function($value) use ($mime, $versione){
  81.                     return $value["mimetype"] === $mime && (!isset($value["version"]) || $value["version"] == $versione);
  82.                 });
  83.                 if($valori){
  84.                     $asset->addMetadata("indice", "input", array_values($valori)[0]["indice"]);
  85.                 }
  86.                 $asset->getDao()->update();
  87.             }
  88.         }
  89.     }
  91.     private function ocr($asset){
  92.         $config = \App\PromemoriaBundle\PromemoriaBundle::getConfig();
  93.         if(isset($config["ocr"]) && $asset->getMimetype() === 'application/pdf'){
  94.             $ocr = shell_exec('pdftotext "/var/www/html/public/var/assets' . $asset->getRealPath() . $asset->getFileName() . '" -');
  95.             $asset->addMetadata("ocr", "textarea", $ocr);
  96.             $asset->getDao()->update();
  97.         }
  98.     }
  100.     private function sfogliatore($asset, $action){
  101.         $config = \App\PromemoriaBundle\PromemoriaBundle::getConfig();
  102.         if(isset($config["sfogliatoreJwtToken"]) && $asset->getMimetype() === 'application/pdf' && !empty(\Pimcore\Tool::getHostUrl())){
  103.             $urlSfogliatore = isset($config["sfogliatoreUrl"]) ?: "https://sfogliatore.promemoriagroup.com";
  104.             $data = [
  105.                 "id" => strval($asset->getId()),
  106.                 "url" => \Pimcore\Tool::getHostUrl() . $asset->getFullPath()
  107.             ];
  108.             $data_string = json_encode($data);
  109.             $ch = curl_init($urlSfogliatore . "/" . $action);
  110.             curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
  111.             curl_setopt($ch, CURLOPT_POSTFIELDS, $data_string);
  112.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  113.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  114.                 'Content-Type: application/json',
  115.                 'Content-Length: ' . strlen($data_string),
  116.                 'Authorization: Bearer ' . $config["sfogliatoreJwtToken"]
  117.             ]);
  118.             curl_exec($ch);
  119.         }
  120.     }
  122.     private function syncAsset($asset, $action="sync"){
  123.         $asset_id = $asset->getId();
  124.         shell_exec("php /var/www/html/slim-sync/index.php /{$action}/asset/{$asset_id} >/dev/null 2>/dev/null &");
  125.     }
  127. }