129 lines
2.6 KiB
PHP
Executable File
129 lines
2.6 KiB
PHP
Executable File
<?php
|
|
namespace easyTask;
|
|
|
|
use \Closure as Closure;
|
|
|
|
/**
|
|
* Class Command
|
|
* @package easyTask
|
|
*/
|
|
class Command
|
|
{
|
|
/**
|
|
* 通讯文件
|
|
*/
|
|
private $msgFile;
|
|
|
|
/**
|
|
* 构造函数
|
|
* @throws
|
|
*/
|
|
public function __construct()
|
|
{
|
|
$this->initMsgFile();
|
|
}
|
|
|
|
/**
|
|
* 初始化文件
|
|
*/
|
|
private function initMsgFile()
|
|
{
|
|
//创建文件
|
|
$path = Helper::getCsgPath();
|
|
$file = $path . '%s.csg';
|
|
$this->msgFile = sprintf($file, md5(__FILE__));
|
|
if (!file_exists($this->msgFile))
|
|
{
|
|
if (!file_put_contents($this->msgFile, '[]', LOCK_EX))
|
|
{
|
|
Helper::showError('failed to create msgFile');
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取数据
|
|
* @return array
|
|
* @throws
|
|
*/
|
|
public function get()
|
|
{
|
|
$content = @file_get_contents($this->msgFile);
|
|
if (!$content)
|
|
{
|
|
return [];
|
|
}
|
|
$data = json_decode($content, true);
|
|
return is_array($data) ? $data : [];
|
|
}
|
|
|
|
/**
|
|
* 重置数据
|
|
* @param array $data
|
|
*/
|
|
public function set($data)
|
|
{
|
|
file_put_contents($this->msgFile, json_encode($data), LOCK_EX);
|
|
}
|
|
|
|
/**
|
|
* 投递数据
|
|
* @param array $command
|
|
*/
|
|
public function push($command)
|
|
{
|
|
$data = $this->get();
|
|
array_push($data, $command);
|
|
$this->set($data);
|
|
}
|
|
|
|
/**
|
|
* 发送命令
|
|
* @param array $command
|
|
*/
|
|
public function send($command)
|
|
{
|
|
$command['time'] = time();
|
|
$this->push($command);
|
|
}
|
|
|
|
/**
|
|
* 接收命令
|
|
* @param string $msgType 消息类型
|
|
* @param mixed $command 收到的命令
|
|
*/
|
|
public function receive($msgType, &$command)
|
|
{
|
|
$data = $this->get();
|
|
if (empty($data)) {
|
|
return;
|
|
}
|
|
foreach ($data as $key => $item)
|
|
{
|
|
if ($item['msgType'] == $msgType)
|
|
{
|
|
$command = $item;
|
|
unset($data[$key]);
|
|
break;
|
|
}
|
|
}
|
|
$this->set($data);
|
|
}
|
|
|
|
/**
|
|
* 根据命令执行对应操作
|
|
* @param int $msgType 消息类型
|
|
* @param Closure $func 执行函数
|
|
* @param int $time 等待方时间戳
|
|
*/
|
|
public function waitCommandForExecute($msgType, $func, $time)
|
|
{
|
|
$command = '';
|
|
$this->receive($msgType, $command);
|
|
if (!$command || (!empty($command['time']) && $command['time'] < $time))
|
|
{
|
|
return;
|
|
}
|
|
$func($command);
|
|
}
|
|
} |