~~~ <?php <?php /** * Created by PhpStorm. * User: Mikkle * QQ:776329498 * Date: 2017/9/19 * Time: 10:10 */ namespace app\task\library\Base; use think\Exception; use think\Log; abstract class TimeWorkerBase extends WorkerBase { protected $listName; protected $listData; protected $listNum; protected $lockName; public function _initialize($options = []) { $this->listData = "{$this->listName}_data"; $this->listNum = "{$this->listName}_num"; } /** * 當命令行未運行 直接執行 * description add * @param $data 傳入 runHandle中的數據 * @param $runTime 時間戳 可以是多少秒后的int，也可以是指定時間的時間戳 * @param array $options * @param string $handleName 可以自己重寫的方法名 * @return bool */ static public function add($data, $runTime = 0, $handleName = "run", $options = []) { try { $data = json_encode($data); $instance = static::instance($options); switch (true) { case (self::checkCommandRun()): $time = $instance->getRunTime($runTime); $num = $instance->redis()->incre($instance->listNum); Log::notice("添加了 $num 號定時任務"); $instance->redis()->zAdd($instance->listName, [$time => $num]); $instance->redis()->hSet($instance->listData, $num, $data); Log::notice("Timing Command service start work!!"); $instance->runWorker($handleName); break; default: Log::notice("Timing Command service No away!!"); $instance->runHandle($data); } return true; } catch (Exception $e) { Log::error($e->getMessage()); return false; } } /** * 命令行執行的方法 */ static public function run() { try { $i = 0; $instance = static::instance(); //讀取并刪除定時任務 $workList = $instance->redis()->zRangByScore($instance->listName, 0, time()); //刪除 $instance->redis()->ZRemRangeByScore($instance->listName, 0,time()); //剩余任務數 $re = $instance->redis()->zCard($instance->listName); if ( $workList ){ foreach ($workList as $num) { try { $redisData = $instance->redis()->hGet($instance->listData, $num); if ($redisData) { $data = json_decode($redisData, true); $result = $instance->runHandle($data); Log::notice("執行{$num}編號任務"); if ($instance->saveLog) { $instance->saveRunLog($result, $data); } $instance->redis()->hDel($instance->listData, $num); } } catch (Exception $e) { Log::error($e->getMessage()); $instance->redis()->zAdd($instance->listData, [(time() + 300) => $num]); } $i++; sleep(1); } } if ( $re == 0) { $instance->clearWorker(); } echo "執行了{$i}次任務,剩余未執行任務[{$re}]項" . PHP_EOL; Log::notice("執行了{$i}次任務,剩余未執行任務[{$re}]項"); } catch (Exception $e) { //Log::error($e); Log::error($e->getMessage()); echo($e->getMessage()); } } //判斷執行時間 protected function getRunTime($time = 0) { $now = time(); switch (true) { case ($time == 0): return $now; break; case (is_int($time) && 30 * 3600 * 24 > $time): return $now + $time; break; case (is_int($time) && $now < $time): return $time; break; default: return $now + (int)$time; } } } ~~~