91 lines
2.7 KiB
PHP
91 lines
2.7 KiB
PHP
<?php
|
|
namespace app\api\controller;
|
|
use think\Controller;
|
|
|
|
class Timming extends Base
|
|
{
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
public function index()
|
|
{
|
|
$param = input();
|
|
$name = $param['name'];
|
|
if(empty($name)){
|
|
//return $this->error('参数错误!');
|
|
}
|
|
|
|
$list = config('timming');
|
|
foreach($list as $k=>$v){
|
|
if(!empty($name) && $v['name'] !=$name){
|
|
continue;
|
|
}
|
|
|
|
if(!empty($v['runtime'])) { $oldweek= date('w',$v['runtime']); $oldhours= date('H',$v['runtime']); }
|
|
$curweek= date('w',time()) ; $curhours= date("H",time());
|
|
if(strlen($oldhours)==1 && intval($oldhours) <10){ $oldhours= '0'.$oldhours; }
|
|
if(strlen($curhours)==1 && intval($curhours) <10){ $curhours= substr($curhours,1,1); }
|
|
$last = (!empty($v['runtime']) ? date('Y-m-d H:i:s',$v['runtime']) :'从未');
|
|
$status = $v['status'] == '1' ? '开启' : '关闭';
|
|
|
|
//测试
|
|
//$v['runtime']=0;
|
|
|
|
if( ($v['status']=='1' && ( empty($v['runtime']) || ($oldweek."-".$oldhours) != ($curweek."-".$curhours)
|
|
&& strpos($v['weeks'],$curweek)!==false && strpos($v['hours'],$curhours)!==false)) ) {
|
|
mac_echo('任务：'.$v['name'] . '，状态：'. $status .'，上次执行时间：'. $last . '---执行');
|
|
$list[$k]['runtime'] = time();
|
|
|
|
|
|
$res = mac_arr2file( APP_PATH .'extra/timming.php', $list);
|
|
if($res===false){
|
|
return $this->error('保存配置文件失败，请重试!');
|
|
}
|
|
$file = $v['file'];
|
|
$this->$file($v['param']);
|
|
die;
|
|
}
|
|
else{
|
|
mac_echo('任务：'.$v['name'] . '，状态：'. $status .'，上次执行时间：'. $last .'---跳过');
|
|
}
|
|
}
|
|
}
|
|
|
|
public function collect($param)
|
|
{
|
|
@parse_str($param,$output);
|
|
$request = controller('admin/collect');
|
|
$request->api($output);
|
|
}
|
|
|
|
public function make($param)
|
|
{
|
|
@parse_str($param,$output);
|
|
$request = controller('admin/make');
|
|
$request->make($output);
|
|
}
|
|
|
|
public function cj($param)
|
|
{
|
|
@parse_str($param,$output);
|
|
$request = controller('admin/cj');
|
|
$request->col_all($output);
|
|
}
|
|
|
|
public function cache($param)
|
|
{
|
|
@parse_str($param,$output);
|
|
$request = controller('admin/index');
|
|
$request->clear();
|
|
}
|
|
|
|
public function urlsend($param)
|
|
{
|
|
@parse_str($param,$output);
|
|
$request = controller('admin/urlsend');
|
|
$request->push($output);
|
|
}
|
|
}
|