// +---------------------------------------------------------------------- declare (strict_types=1); namespace app\timer\controller\bargain; use app\timer\controller\Controller; use app\timer\service\bargain\Task as TaskService; /** * 定时任务: 砍价任务 * Class Task * @package app\timer\controller\bargain */ class Task extends Controller { // 当前任务唯一标识 private string $taskKey = 'BargainTask'; // 任务执行间隔时长 (单位:秒) protected int $taskExpire = 60 * 30; // 当前商城ID private int $storeId; /** * 任务处理 * @param array $param * @throws \think\Exception * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function handle(array $param) { ['storeId' => $this->storeId] = $param; $this->setInterval($this->storeId, $this->taskKey, $this->taskExpire, function () { echo $this->taskKey . PHP_EOL; // 标记已过期的砍价任务 $this->overdueEvent(); }); } /** * 标记已过期的砍价任务 */ private function overdueEvent() { $service = new TaskService; $service->overdueEvent($this->storeId); } }