From 865881b6a9b8f1722f4fe0937364ec64d7c12977 Mon Sep 17 00:00:00 2001
From: gzydong <837215079@qq.com>
Date: Sun, 15 Aug 2021 22:48:57 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=B8=B4=E6=97=B6=E6=96=87?=
 =?UTF-8?q?=E4=BB=B6=E6=B8=85=E7=90=86=E5=91=BD=E4=BB=A4=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Command/ClearFileCommand.php   | 50 ++++++++++++++++++++++++++++++
 app/Service/SplitUploadService.php | 17 ++++++++++
 2 files changed, 67 insertions(+)
 create mode 100644 app/Command/ClearFileCommand.php

diff --git a/app/Command/ClearFileCommand.php b/app/Command/ClearFileCommand.php
new file mode 100644
index 0000000..5c63a23
--- /dev/null
+++ b/app/Command/ClearFileCommand.php
@@ -0,0 +1,50 @@
+<?php
+declare(strict_types=1);
+/**
+ * This is my open source code, please do not use it for commercial applications.
+ * For the full copyright and license information,
+ * please view the LICENSE file that was distributed with this source code
+ *
+ * @author Yuandong<837215079@qq.com>
+ * @link   https://github.com/gzydong/hyperf-chat
+ */
+
+namespace App\Command;
+
+use App\Service\SplitUploadService;
+use Hyperf\Command\Annotation\Command;
+use Hyperf\Command\Command as HyperfCommand;
+use Psr\Container\ContainerInterface;
+
+/**
+ * @Command
+ */
+class ClearFileCommand extends HyperfCommand
+{
+    /**
+     * @var ContainerInterface
+     */
+    protected $container;
+
+    public function __construct(ContainerInterface $container)
+    {
+        $this->container = $container;
+
+        parent::__construct('system:clear-file');
+    }
+
+    public function configure()
+    {
+        parent::configure();
+        $this->setDescription('清除拆分上传的临时文件！');
+    }
+
+    public function handle()
+    {
+        $this->line('文件清理中...');
+
+        di()->get(SplitUploadService::class)->clear();
+
+        $this->info('文件清理完成...');
+    }
+}
diff --git a/app/Service/SplitUploadService.php b/app/Service/SplitUploadService.php
index 45c57ce..bae960d 100644
--- a/app/Service/SplitUploadService.php
+++ b/app/Service/SplitUploadService.php
@@ -141,4 +141,21 @@ class SplitUploadService
             'file_size'     => $fileInfo->file_size
         ];
     }
+
+
+    /**
+     * 清理超过24小时的临时文件
+     */
+    public function clear()
+    {
+        // 24小时前
+        $time = time() - 60 * 60 * 24 * 1;
+
+        FileSplitUpload::where('file_type', 1)->where('upload_at', '<', $time)->select('hash_name')->chunk(100, function ($rows) {
+            foreach ($rows as $row) {
+                @di()->get(Filesystem::class)->deleteDir("tmp/{$row->hash_name}");
+                @FileSplitUpload::where('hash_name', $row->hash_name)->delete();
+            }
+        });
+    }
 }