89 lines
2.6 KiB
PHP
Executable File
89 lines
2.6 KiB
PHP
Executable File
<?php
|
|
namespace Common\Model;
|
|
/*
|
|
* To change this license header, choose License Headers in Project Properties.
|
|
* To change this template file, choose Tools | Templates
|
|
* and open the template in the editor.
|
|
*/
|
|
|
|
use Qscmf\Lib\DBCont;
|
|
use Qscmf\Lib\Tp3Resque\Resque;
|
|
use Qscmf\Lib\Tp3Resque\Resque\Job\Status;
|
|
|
|
class QueueModel extends \Gy_Library\GyListModel{
|
|
|
|
public function __construct($name = '', $tablePrefix = '', $connection = '') {
|
|
parent::__construct($name, $tablePrefix, $connection);
|
|
}
|
|
|
|
public function freshStatus(){
|
|
$map['status'] = array('neq', DBCont::JOB_STATUS_COMPLETE);
|
|
$ents = $this->where($map)->select();
|
|
foreach($ents as $ent){
|
|
$status = new Status($ent['id']);
|
|
$new_status = $status->get();
|
|
$ent['status'] = $new_status;
|
|
$this->save($ent);
|
|
}
|
|
}
|
|
|
|
public function refreshStatusOne($job_id){
|
|
$ent = $this->getOne($job_id);
|
|
|
|
$status = new Status($ent['id']);
|
|
$new_status = $status->get();
|
|
$ent['status'] = $new_status;
|
|
$this->save($ent);
|
|
}
|
|
|
|
|
|
public function rebuildJob(){
|
|
$map['status'] = array('not in', array(DBCont::JOB_STATUS_WAITING, DBCont::JOB_STATUS_COMPLETE));
|
|
$ents = $this->where($map)->select();
|
|
foreach($ents as $ent){
|
|
$job = $ent['job'];
|
|
$args = json_decode($ent['args'], true);
|
|
|
|
$job_id = Resque::enqueue('default', $job, $args, true);
|
|
$this->where(array('id' => $ent['id']))->delete();
|
|
|
|
|
|
$ent['id'] = $job_id;
|
|
$ent['status'] = DBCont::JOB_STATUS_WAITING;
|
|
$ent['create_date'] = time();
|
|
|
|
$this->add($ent);
|
|
}
|
|
}
|
|
|
|
public function rebuildJobOne($job_id){
|
|
$ent = $this->getOne($job_id);
|
|
|
|
if(!$ent){
|
|
$this->error = '任务不存在';
|
|
return false;
|
|
}
|
|
|
|
if($ent['status'] == DBCont::JOB_STATUS_WAITING || $ent['status'] == DBCont::JOB_STATUS_COMPLETE){
|
|
$this->error = "任务状态为等待或者完成，不可重启";
|
|
return false;
|
|
}
|
|
|
|
$job = $ent['job'];
|
|
$args = json_decode($ent['args'], true);
|
|
$queue = $ent['queue'] ?: 'default';
|
|
|
|
$new_job_id = Resque::enqueue($queue, $job, $args, true);
|
|
$this->where(array('id' => $ent['id']))->delete();
|
|
|
|
|
|
$ent['id'] = $new_job_id;
|
|
$ent['status'] = DBCont::JOB_STATUS_WAITING;
|
|
$ent['create_date'] = time();
|
|
|
|
$this->add($ent);
|
|
return true;
|
|
}
|
|
|
|
}
|