vendor/elements/process-manager-bundle/src/ElementsProcessManagerBundle.php line 24

Open in your IDE?
  1. <?php
  3. /**
  4.  * Elements.at
  5.  *
  6.  * This source file is available under two different licenses:
  7.  * - GNU General Public License version 3 (GPLv3)
  8.  * - Pimcore Enterprise License (PEL)
  9.  * Full copyright and license information is available in
  10.  * LICENSE.md which is distributed with this source code.
  11.  *
  12.  *  @copyright  Copyright (c) elements.at New Media Solutions GmbH (https://www.elements.at)
  13.  *  @license    http://www.pimcore.org/license     GPLv3 and PEL
  14.  */
  16. namespace Elements\Bundle\ProcessManagerBundle;
  18. use Elements\Bundle\ProcessManagerBundle\Model\Configuration;
  19. use Elements\Bundle\ProcessManagerBundle\Model\MonitoringItem;
  20. use Pimcore\Extension\Bundle\AbstractPimcoreBundle;
  21. use Pimcore\Extension\Bundle\Traits\PackageVersionTrait;
  22. use Pimcore\Extension\Bundle\Traits\StateHelperTrait;
  24. class ElementsProcessManagerBundle extends AbstractPimcoreBundle
  25. {
  26.     use ExecutionTrait;
  27.     use PackageVersionTrait;
  28.     use StateHelperTrait;
  30.     public static $maintenanceOptions = [
  31.         'autoCreate' => true,
  32.         'name' => 'ProcessManager maintenance',
  33.         'loggers' => [
  34.             [
  35.                 'logLevel' => 'DEBUG',
  36.                 'class' => '\Elements\Bundle\ProcessManagerBundle\Executor\Logger\Console',
  37.                 'simpleLogFormat' => true
  38.             ],
  39.             [
  40.                 'logLevel' => 'DEBUG',
  41.                 'filepath' => '/var/logs/process-manager-maintenance.log',
  42.                 'class' => '\Elements\Bundle\ProcessManagerBundle\Executor\Logger\File',
  43.                 'simpleLogFormat' => true,
  44.                 'maxFileSizeMB' => 50
  45.             ]
  46.         ]
  47.     ];
  49.     protected static $_config = null;
  51.     protected static $monitoringItem;
  53.     const PLUGIN_NAME = 'ProcessManager';
  55.     const TABLE_NAME_CONFIGURATION = 'plugin_process_manager_configuration';
  56.     const TABLE_NAME_MONITORING_ITEM = 'plugin_process_manager_monitoring_item';
  57.     const TABLE_NAME_CALLBACK_SETTING = 'plugin_process_manager_callback_setting';
  58.     const MONITORING_ITEM_ENV_VAR = 'monitoringItemId';
  60.     /**
  61.      * @return array
  62.      */
  63.     public function getCssPaths()
  64.     {
  65.         return [
  66.             '/bundles/elementsprocessmanager/css/admin.css'
  67.         ];
  68.     }
  70.     /**
  71.      * @return array
  72.      */
  73.     public function getJsPaths()
  74.     {
  75.         return [
  76.             '/bundles/elementsprocessmanager/js/startup.js',
  77.             '/bundles/elementsprocessmanager/js/window/detailwindow.js',
  78.             '/bundles/elementsprocessmanager/js/helper/form.js',
  80.             '/bundles/elementsprocessmanager/js/panel/config.js',
  81.             '/bundles/elementsprocessmanager/js/panel/general.js',
  82.             '/bundles/elementsprocessmanager/js/panel/monitoringItem.js',
  83.             '/bundles/elementsprocessmanager/js/panel/callbackSetting.js',
  85.             '/bundles/elementsprocessmanager/js/executor/class/abstractExecutor.js',
  86.             '/bundles/elementsprocessmanager/js/executor/class/command.js',
  87.             '/bundles/elementsprocessmanager/js/executor/class/classMethod.js',
  88.             '/bundles/elementsprocessmanager/js/executor/class/pimcoreCommand.js',
  89.             '/bundles/elementsprocessmanager/js/executor/class/exportToolkit.js',
  90.             '/bundles/elementsprocessmanager/js/executor/class/phing.js',
  92.             '/bundles/elementsprocessmanager/js/executor/action/abstractAction.js',
  93.             '/bundles/elementsprocessmanager/js/executor/action/download.js',
  94.             '/bundles/elementsprocessmanager/js/executor/action/openItem.js',
  95.             '/bundles/elementsprocessmanager/js/executor/action/jsEvent.js',
  97.             '/bundles/elementsprocessmanager/js/executor/logger/abstractLogger.js',
  98.             '/bundles/elementsprocessmanager/js/executor/logger/file.js',
  99.             '/bundles/elementsprocessmanager/js/executor/logger/console.js',
  100.             '/bundles/elementsprocessmanager/js/executor/logger/application.js',
  101.             '/bundles/elementsprocessmanager/js/executor/logger/emailSummary.js',
  103.             '/bundles/elementsprocessmanager/js/executor/callback/abstractCallback.js',
  104.             '/bundles/elementsprocessmanager/js/executor/callback/example.js',
  105.             '/bundles/elementsprocessmanager/js/executor/callback/default.js',
  106.             '/bundles/elementsprocessmanager/js/executor/callback/executionNote.js',
  107.             '/bundles/elementsprocessmanager/js/executor/callback/phing.js',
  108.             '/bundles/elementsprocessmanager/js/window/activeProcesses.js',
  111.         ];
  112.     }
  114.     /**
  115.      * If the bundle has an installation routine, an installer is responsible of handling installation related tasks
  116.      *
  117.      * @return InstallerInterface|null
  118.      */
  119.     public function getInstaller()
  120.     {
  121.         return $this->container->get(Installer::class);
  122.     }
  124.     public static function shutdownHandler($arguments)
  125.     {
  126.         /**
  127.          * @var $monitoringItem MonitoringItem
  128.          */
  129.         if ($monitoringItem = self::getMonitoringItem()) {
  130.             $error = error_get_last();
  131.             Helper::executeMonitoringItemLoggerShutdown($monitoringItem);
  133.             if (in_array($error['type'], [E_WARNING, E_DEPRECATED, E_STRICT, E_NOTICE])) {
  134.                 if ($config = Configuration::getById($monitoringItem->getConfigurationId())) {
  135.                     $versions = $config->getKeepVersions();
  136.                     if (is_numeric($versions)) {
  137.                         $list = new MonitoringItem\Listing();
  138.                         $list->setOrder('DESC')->setOrderKey('id')->setOffset((int)$versions)->setLimit(100000000000); //a limit has to defined otherwise the offset wont work
  139.                         $list->setCondition('status ="finished" AND configurationId=? AND IFNULL(pid,0) != ? AND parentId IS NULL ', [$config->getId(), $monitoringItem->getPid()]);
  141.                         $items = $list->load();
  142.                         foreach ($items as $item) {
  143.                             $item->delete();
  144.                         }
  145.                     }
  146.                 }
  147.                 if (!$monitoringItem->getMessage()) {
  148.                     $monitoringItem->setMessage('finished');
  149.                 }
  150.                 $monitoringItem->setCompleted();
  151.                 $monitoringItem->setPid(null)->save();
  152.             } else {
  153.                 $monitoringItem->setMessage('ERROR:' . print_r($error, true) . $monitoringItem->getMessage());
  154.                 $monitoringItem->setPid(null)->setStatus($monitoringItem::STATUS_FAILED)->save();
  155.             }
  156.         }
  157.     }
  159.     public static function startup($arguments)
  160.     {
  161.         $monitoringItem = $arguments['monitoringItem'];
  162.         if ($monitoringItem instanceof MonitoringItem) {
  163.             $monitoringItem->resetState()->save();
  164.             $monitoringItem->setPid(getmypid());
  165.             $monitoringItem->setStatus($monitoringItem::STATUS_RUNNING);
  166.             $monitoringItem->save();
  167.         }
  168.     }
  170.     public static function getConfig()
  171.     {
  172.         if (is_null(self::$_config)) {
  173.             $configFile = \Pimcore\Config::locateConfigFile('plugin-process-manager.php');
  174.             self::$_config = include $configFile;
  175.         }
  177.         return self::$_config;
  178.     }
  180.     public static function getLogDir()
  181.     {
  182.         $dir = PIMCORE_PRIVATE_VAR . '/logs/process-manager/';
  183.         if (!is_dir($dir)) {
  184.             \Pimcore\File::mkdir($dir);
  185.         }
  187.         return $dir;
  188.     }
  190.     public function getDescription()
  191.     {
  192.         return 'Process Manager';
  193.     }
  195.     /**
  196.      * @param mixed $monitoringItem
  197.      */
  198.     public static function setMonitoringItem($monitoringItem)
  199.     {
  200.         self::$monitoringItem = $monitoringItem;
  201.     }
  203.     /**
  204.      * @param bool $createDummyObjectIfRequired
  205.      *
  206.      * @return MonitoringItem
  207.      */
  208.     public static function getMonitoringItem($createDummyObjectIfRequired = true)
  209.     {
  210.         if ($createDummyObjectIfRequired && !self::$monitoringItem) {
  211.             if(getenv(self::MONITORING_ITEM_ENV_VAR)){
  212.                 self::$monitoringItem = MonitoringItem::getById(getenv(self::MONITORING_ITEM_ENV_VAR));
  213.                 self::$monitoringItem->setStatus(MonitoringItem::STATUS_RUNNING)->save();
  214.             }else{
  215.                 self::$monitoringItem = new MonitoringItem();
  216.                 self::$monitoringItem->setIsDummy(true);
  217.             }
  218.         }
  220.         return self::$monitoringItem;
  221.     }
  223.     public static function getPluginWebsitePath()
  224.     {
  225.         $path = PIMCORE_PRIVATE_VAR . '/bundles/elementsprocessmanager/';
  226.         if (!is_dir($path)) {
  227.             mkdir($path, 0755, true);
  228.         }
  230.         return $path;
  231.     }
  233.     protected function getComposerPackageName()
  234.     {
  235.         return 'elements/process-manager-bundle';
  236.     }
  238.     public function getNiceName()
  239.     {
  240.         return self::PLUGIN_NAME;
  241.     }
  243. }