src/PromemoriaBundle/Services/HookAssetEvent.php line 46

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->syncAsset($asset);
  43.         }
  44.     }
  46.     public function onPostDelete(ElementEventInterface $e) {
  47.         if($e instanceof AssetEvent) {
  48.             $asset = $e->getAsset();
  49.             $this->sfogliatore($asset, "delFile");
  50.             $this->syncAsset($asset, "delete");
  51.         }
  52.     }
  54.     private function siegfried($asset){
  55.         $config = \App\PromemoriaBundle\PromemoriaBundle::getConfig();
  56.         if(isset($config["siegfried"])){
  57.             $sf = shell_exec('sf -json "' . $asset->getFileSystemPath(). '"');
  58.             $version = json_decode($sf, TRUE);
  59.             if($version && isset($version["files"]) && isset($version["files"][0]) && isset($version["files"][0]["matches"])){
  60.                 $mime = $version["files"][0]["matches"][0]["mime"];
  61.                 $versione = $version["files"][0]["matches"][0]["version"];
  62.                 $asset->addMetadata("filesize", "input", $version["files"][0]["filesize"]);
  63.                 $asset->addMetadata("modified", "input", $version["files"][0]["modified"]);
  64.                 $asset->addMetadata("format", "input", $version["files"][0]["matches"][0]["format"]);
  65.                 $asset->addMetadata("version", "input", $versione);
  66.                 $asset->addMetadata("mime", "input", $mime);
  67.                 //calcolo indice
  68.                 $digitalpreservation = json_decode(file_get_contents(__DIR__ . "/../digitalpreservation.json"), TRUE);
  69.                 $valori = array_filter($digitalpreservation, function($value) use ($mime, $versione){
  70.                     return $value["mimetype"] === $mime && (!isset($value["version"]) || $value["version"] == $versione);
  71.                 });
  72.                 if($valori){
  73.                     $asset->addMetadata("indice", "input", array_values($valori)[0]["indice"]);
  74.                 }
  75.                 $asset->getDao()->update();
  76.             }
  77.         }
  78.     }
  80.     private function ocr($asset){
  81.         $config = \App\PromemoriaBundle\PromemoriaBundle::getConfig();
  82.         if(isset($config["ocr"]) && $asset->getMimetype() === 'application/pdf'){
  83.             $ocr = shell_exec('pdftotext "/var/www/html/public/var/assets' . $asset->getRealPath() . $asset->getFileName() . '" -');
  84.             $asset->addMetadata("ocr", "textarea", $ocr);
  85.             $asset->getDao()->update();
  86.         }
  87.     }
  89.     private function sfogliatore($asset, $action){
  90.         $config = \App\PromemoriaBundle\PromemoriaBundle::getConfig();
  91.         if(isset($config["sfogliatoreJwtToken"]) && $asset->getMimetype() === 'application/pdf'){
  92.             $urlSfogliatore = isset($config["sfogliatoreUrl"]) ?: "https://sfogliatore.promemoriagroup.com";
  93.             $data = [
  94.                 "id" => strval($asset->getId()),
  95.                 "url" => \Pimcore\Tool::getHostUrl() . $asset->getFullPath()
  96.             ];
  97.             $data_string = json_encode($data);
  98.             $ch = curl_init($urlSfogliatore . "/" . $action);
  99.             curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
  100.             curl_setopt($ch, CURLOPT_POSTFIELDS, $data_string);
  101.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  102.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  103.                 'Content-Type: application/json',
  104.                 'Content-Length: ' . strlen($data_string),
  105.                 'Authorization: Bearer ' . $config["sfogliatoreJwtToken"]
  106.             ]);
  107.             curl_exec($ch);
  108.         }
  109.     }
  111.     private function syncAsset($asset, $action="sync"){
  112.         $asset_id = $asset->getId();
  113.         shell_exec("php /var/www/html/slim-sync/index.php /{$action}/asset/{$asset_id} >/dev/null 2>/dev/null &");
  114.     }
  116. }