kiri-core/System/Crontab.php

<?php


namespace Snowflake;


use Closure;
use Exception;
use Snowflake\Abstracts\BaseObject;
use Snowflake\Process\CrontabProcess;
use Swoole\Timer;

/**
 * Class Async
 * @package Snowflake
 */
class Crontab extends BaseObject
{


    private array|Closure $handler;


    private string $name = '';


    private mixed $params;


    private int $tickTime = 1;


    private bool $isLoop = false;


    private int $timerId = -1;


    private int $max_execute_number = -1;


    private int $execute_number = 0;

    /**
     * @return array|Closure
     */
    public function getHandler(): array|Closure
    {
        return $this->handler;
    }

    /**
     * @return string
     */
    public function getName(): string
    {
        return $this->name;
    }

    /**
     * @return mixed
     */
    public function getParams(): mixed
    {
        return $this->params;
    }

    /**
     * @return int
     */
    public function getTickTime(): int
    {
        return $this->tickTime;
    }

    /**
     * @return bool
     */
    public function isLoop(): bool
    {
        return $this->isLoop;
    }

    /**
     * @return int
     */
    public function getMaxExecuteNumber(): int
    {
        return $this->max_execute_number;
    }

    /**
     * @return int
     */
    public function getExecuteNumber(): int
    {
        return $this->execute_number;
    }


    /**
     * @param array|Closure $handler
     */
    public function setHandler(array|Closure $handler): void
    {
        $this->handler = $handler;
    }

    /**
     * @param string $name
     */
    public function setName(string $name): void
    {
        $this->name = $name;
    }

    /**
     * @param mixed $params
     */
    public function setParams(mixed $params): void
    {
        $this->params = $params;
    }

    /**
     * @param int $tickTime
     */
    public function setTickTime(int $tickTime): void
    {
        $this->tickTime = $tickTime;
    }

    /**
     * @param bool $isLoop
     */
    public function setIsLoop(bool $isLoop): void
    {
        $this->isLoop = $isLoop;
    }

    /**
     * @param int $max_execute_number
     */
    public function setMaxExecuteNumber(int $max_execute_number): void
    {
        $this->max_execute_number = $max_execute_number;
    }

    /**
     * @param int $execute_number
     */
    public function setExecuteNumber(int $execute_number): void
    {
        $this->execute_number = $execute_number;
    }

    /**
     * @return int
     */
    public function getTimerId(): int
    {
        return $this->timerId;
    }

    /**
     * @param int $timerId
     */
    public function setTimerId(int $timerId): void
    {
        $this->timerId = $timerId;
        var_dump($this->timerId);
    }


    /**
     *
     */
    public function clearTimer()
    {
        $this->warning('crontab timer clear.');
        if (Timer::exists($this->timerId)) {
            Timer::clear($this->timerId);
        }
    }


    /**
     * @throws Exception
     */
    public function execute(CrontabProcess $process): void
    {
        try {
            var_dump('execute');
            call_user_func($this->handler, $this->params);
            $this->execute_number += 1;
            if ($this->execute_number >= $this->max_execute_number) {
                $this->clearTimer();
                $process->clear($this->getName());
            } else if (!$this->isLoop()) {
                $process->clear($this->getName());
            }
        } catch (\Throwable $throwable) {
            $this->addError($throwable->getMessage());
        } finally {
            fire(Event::SYSTEM_RESOURCE_RELEASES);
        }
    }


}