<?php namespace app\home\job; use app\home\service\TrcPayService; use think\facade\Cache; use think\facade\Log; use think\queue\Job; class Wallet { public function fire(Job $job, $data) { trace('钱包新任务', 'info'); for($times = 1; $times <= 10; $times++) { $result=(new TrcPayService())->WalletAddress(); if(!empty($result)){ break; } trace($job->getJobId().'---获取钱包任务-----'.$times, 'info'); } // 删除任务 $job->delete(); } public function failed($data) { // 失败任务 $dataStr = json_encode($data); trace('queue job 获取钱包任务失败---'.$dataStr, 'error'); } }