whmcsProxmoxAddon/core/CommandLine/AbstractCronControllerWithoutThread.php

<?php

namespace ModulesGarden\ProxmoxAddon\Core\CommandLine;

use \ModulesGarden\ProxmoxAddon\Core\ModuleConstants;
use \ModulesGarden\ProxmoxAddon\Core\Models\CronTabs;

/**
 * Description of AbstractCronController
 *
 * @author Rafał
 */
abstract class AbstractCronControllerWithoutThread
{
    protected $exit    = true;
    protected $error   = false;
    protected $isChild = false;
    protected $className;
    protected $child   = 0;
    protected $childId;
    protected $parentId;
    protected $cronManager;
    protected $parentUserId;
    protected $parentGroupId;

    public function setParentId($parentId)
    {
        $this->parentId = $parentId;

        return $this;
    }

    public function setChildId($childId)
    {
        $this->childId = $childId;

        return $this;
    }

    public function ischild($isChild)
    {
        $this->isChild = $isChild;

        return $this;
    }

    public function setClassName($className)
    {
        $this->className = $className;

        return $this;
    }

    protected function canRunScript()
    {
        $run = true;
        foreach (CronTabs::get() as $cronTab)
        {
            if ($cronTab->name == CronTabs::DEFAULT_CRON_MANAGER_NAME && $cronTab->status == 'stop')
            {
                $run = false;
            }
            elseif ($cronTab->name == $this->className && $cronTab->status == 'stop')
            {
                $run = false;
            }
        }

        return $run;
    }

    protected function updatePid()
    {
        if ($this->isChild)
        {
            CronManager::updatePids($this->className, $this->childId);
            if ($this->parentGroupId === getmygid() && $this->parentUserId === getmyuid())
            {
                $this->removePid();
            }
        }

        return $this;
    }

    protected function isExistPid()
    {
        if ($this->isChild)
        {
            return CronManager::existPids($this->className, $this->childId);
        }

        return $this->canRunScript();
    }

    protected function removePid()
    {
        if ($this->isChild)
        {
            CronManager::removePids($this->className, $this->childId);
        }

        return $this;
    }

    abstract public function run();

    public function isChildrenCreate()
    {
        return false;
    }

    public function getChildrenCount()
    {
        return $this->child;
    }

    public function setCronManager($cronManager)
    {
        $this->cronManager = $cronManager;

        return $this;
    }

    public function getIndexElements()
    {
        $childrenListIds = [];

        for ($key = 1; $key <= $this->getChildrenCount(); $key++)
        {
            $childrenListIds[] = $key;
        }

        return $childrenListIds;
    }

    public function start()
    {
        try
        {
            if ($this->isStart() === false)
            {
                if ($this->child > 0 && $this->isChild === false)
                {
                    while ($this->canRunScript())
                    {
                        if ($this->isChildrenCreate())
                        {
                            $parentId  = getmypid();
                            $parentUId = $this->parentUserId ? $this->parentUserId : getmyuid();
                            $parentGId = $this->parentGroupId ? $this->parentGroupId : getmygid();
                            foreach ($this->getIndexElements() as $key)
                            {
                                if ($this->cronManager->isChildRunning($this->className, $key))
                                {
                                    continue;
                                }

                                $phpInterpreter       = \PHP_BINARY ?: 'php';
                                $internalCronDumpFile = ModuleConstants::getFullPath('storage', 'crons', 'cronLog');
                                exec($phpInterpreter . " " . ModuleConstants::getModuleRootDir() . DS . 'cron' . DS . 'cron.php ' . $this->className
                                        . " --parent {$parentId} --parentuid {$parentUId} --parentgid {$parentGId} --child {$key} >> {$internalCronDumpFile} &");
                            }
                        }
                        $this->wait(4000000);
                    }
                }
                elseif ($this->child === 0 && $this->isChild === false)
                {
                    $this->exit = false;
                    $this->run();
                }
                elseif ($this->isChild === true)
                {
                    $this->exit = false;
                    $this->run();
                    $this->removePid();
                    exit;
                }
            }
        }
        catch (\Exception $ex)
        {
            $this->error = $ex->getMessage();
        }
    }

    public function setParentGroupId($parentGroupId)
    {
        $this->parentGroupId = $parentGroupId;

        return $this;
    }

    public function setParentUserId($parentUserId)
    {
        $this->parentUserId = $parentUserId;

        return $this;
    }

    public function isStart()
    {
        return ($this->exit === false);
    }

    public function wait($seconds = 500000)
    {
        usleep($seconds);
    }

    function __destruct()
    {
        if ($this->error)
        {
            CronTabs::ifName($this->className)->addError($this->error);
        }
    }
}