as2252258@163.com
61 lines
1.2 KiB
PHP
61 lines
1.2 KiB
PHP
<?php
|
|
|
|
|
|
namespace Snowflake\Abstracts;
|
|
|
|
|
|
use Snowflake\Core\Json;
|
|
use Snowflake\Process\CrontabProcess;
|
|
use Snowflake\Snowflake;
|
|
use Exception;
|
|
|
|
|
|
/**
|
|
* Class Crontab
|
|
* @package Snowflake\Abstracts
|
|
*/
|
|
class Crontab extends Component
|
|
{
|
|
|
|
|
|
/**
|
|
* @param \Snowflake\Crontab $crontab
|
|
* @param $executeTime
|
|
* @throws Exception
|
|
*/
|
|
public function dispatch(\Snowflake\Crontab $crontab)
|
|
{
|
|
/** @var CrontabProcess $redis */
|
|
$redis = Snowflake::app()->get(CrontabProcess::class);
|
|
var_dump($redis);
|
|
$redis->write(serialize($crontab));
|
|
}
|
|
|
|
|
|
/**
|
|
* @param string $name
|
|
* @throws Exception
|
|
*/
|
|
public function clear(string $name)
|
|
{
|
|
/** @var CrontabProcess $redis */
|
|
$redis = Snowflake::app()->get(CrontabProcess::class);
|
|
var_dump($redis);
|
|
$redis->write(Json::encode(['action' => 'clear', 'name' => $name]));
|
|
}
|
|
|
|
|
|
/**
|
|
* @throws Exception
|
|
*/
|
|
public function clearAll()
|
|
{
|
|
/** @var CrontabProcess $redis */
|
|
$redis = Snowflake::app()->get(CrontabProcess::class);
|
|
var_dump($redis);
|
|
$redis->write(Json::encode(['action' => 'clearAll']));
|
|
}
|
|
|
|
|
|
}
|