图1
1、在一个队列任务中，需要先下载 zip 文件，然后解压缩，现在当解压缩成功后，需要删除已下载的 zip 文件。现已实现。
/**
* Execute the job.
*
* @return void
*/ public function handle()
{
// 下载 ZIP
$downloadZipRes = $this->downloadZip();
// 解压缩 ZIP
$this->unzip($downloadZipRes['destination'], $downloadZipRes['absolutePath']);
}
/**
* 解压缩 ZIP
*
* @param string $destination 解压缩至的本地目标路径
* @param string $absolutePath 待解压缩的文件的绝对路径
* @return void
*/ private function unzip($destination, $absolutePath)
{
$this->themeInstallationTask->step = ThemeInstallationTask::STEP_UNZIP;
$this->themeInstallationTask->save();
app(ZipHandler::class)->unzip($destination, $absolutePath);
// 删除 ZIP
Storage::disk('local')->delete(substr($absolutePath, strlen(storage_path('app') . '/')));
}
/**
* 解压缩 ZIP
* @param string $destination 解压缩至的本地目标路径
* @param string $entrie 待解压缩的文件的绝对路径
* @return void
*/ public function unzip($destination, $entrie)
{
checkhere();
if ($this->zipArchive->open($entrie) === TRUE) {
$this->zipArchive->extractTo($destination);
$this->zipArchive->close();
} else {
abort(500, 'Unzip failed.');
}
}
2、当解压缩失败：Call to undefined function Modules\ThemeStoreDB\Handlers\checkhere() 时，也需要删除掉对应的 zip 文件，就需要在 failed(Exception $exception) 方法中实现。但是，需要获取到 zip 文件的绝对路径。 暂未实现。查看未删除的 zip 文件。如图1
3、在表：failed_jobs 中，查看字段：payload 的值
{
"displayName": "Modules\\ThemeStoreDB\\Jobs\\ThemeInstallationJob",
"job": "Illuminate\\Queue\\CallQueuedHandler@call",
"maxTries": 1,
"delay": null,
"timeout": 600,
"timeoutAt": null,
"data": {
"commandName": "Modules\\ThemeStoreDB\\Jobs\\ThemeInstallationJob",
"command": "O:46:\"Modules\\ThemeStoreDB\\Jobs\\ThemeInstallationJob\":11:{s:5:\"tries\";i:1;s:7:\"timeout\";i:600;s:24:\"\u0000*\u0000themeInstallationTask\";O:45:\"Illuminate\\Contracts\\Database\\ModelIdentifier\":4:{s:5:\"class\";s:51:\"Modules\\ThemeStoreDB\\Entities\\ThemeInstallationTask\";s:2:\"id\";i:22;s:9:\"relations\";a:0:{}s:10:\"connection\";s:5:\"mysql\";}s:6:\"\u0000*\u0000job\";N;s:10:\"connection\";N;s:5:\"queue\";N;s:15:\"chainConnection\";N;s:10:\"chainQueue\";N;s:5:\"delay\";N;s:10:\"middleware\";a:0:{}s:7:\"chained\";a:0:{}}"
},
"telescope_uuid": "96a60a99-dbb8-40a4-8054-2694435b46be",
"tenant_name": "chengdu-wangqiang-object-local",
"id": "lX7QOFkBy5VwjNBSx5OekUISzvXU7ess",
"attempts": 0
}
4、zip 文件的绝对路径的获取，一种方案是将其存入至 MySQL 表中，另一种方案就是赋值给 Job 对象属性，决定采用第二种方案。
private $absolutePath; // 待解压缩的 ZIP 文件的绝对路径
private $destination; // 解压缩 ZIP 文件后的目录
/**
* Execute the job.
*
* @return void
*/ public function handle()
{
// 下载 ZIP
$downloadZipRes = $this->downloadZip();
// 解压缩 ZIP
$this->absolutePath = $downloadZipRes['absolutePath'];
$this->unzip($downloadZipRes['destination']);
}
/**
* 任务失败的处理过程
*
* @param Exception $exception
* @return void
*/ public function failed(Exception $exception)
{
if (isset($this->absolutePath)) {
// 删除 ZIP
Storage::disk('local')->delete(substr($this->absolutePath, strlen(storage_path('app') . '/')));
}
}
5、但是解压缩失败后，并未删除掉 zip 文件，原因在于 $this->absolutePath 为 null 。在方法 handle() 中是有值的，但是在 failed() 中为 null。
6、决定将 absolutePath 调整为静态变量。在 failed() 中其值为：E:\wwwroot\object\storage\app/theme_downloads/2022/06/29/1656468032.6555.1798260415.zip
private static $absolutePath; // 待解压缩的 ZIP 文件的绝对路径
private static $destination; // 解压缩 ZIP 文件后的目录
/**
* Execute the job.
*
* @return void
*/ public function handle()
{
// 下载 ZIP
$downloadZipRes = $this->downloadZip();
// 解压缩 ZIP
self::$absolutePath = $downloadZipRes['absolutePath'];
$this->unzip($downloadZipRes['destination']);
}
/**
* 任务失败的处理过程
*
* @param Exception $exception
* @return void
*/ public function failed(Exception $exception)
{
if (isset(self::$absolutePath)) {
// 删除 ZIP
Storage::disk('local')->delete(substr(self::$absolutePath, strlen(storage_path('app') . '/')));
}
}