feat: 支持日志轮转天数，自动删除历史日志

src/Util/Log.php

@@ -87,6 +87,21 @@ class Log
      */
     protected $dateLogFilePath;
 
+    /**
+     * @var string
+     */
+    protected $splitString = '_';
+
+    /**
+     * @var int
+     */
+    protected $rotateDay = 7;
+
+    /**
+     * @var bool
+     */
+    protected $doUnlink = false;
+
     /**
      * @param string $type
      * @param string|null $channel
@@ -139,6 +154,15 @@ public function setChannel(string $channel)
         return $this;
     }
 
+    /**
+     * @param int $rotateDay
+     * @return void
+     */
+    public function setRotateDay(int $rotateDay)
+    {
+        $this->rotateDay = $rotateDay;
+    }
+
     /**
      * setLogFilePath
      * @param string $logFilePath
@@ -166,7 +190,37 @@ protected function getDateLogFile(string $date, string $logFilePath)
         if (!is_dir($fileInfo['dirname'])) {
             mkdir($fileInfo['dirname'], 0777);
         }
-        return $fileInfo['dirname'].DIRECTORY_SEPARATOR.$fileInfo['filename'].'_'.$date.'.'.$fileInfo['extension'];
+        return $fileInfo['dirname'].DIRECTORY_SEPARATOR.$fileInfo['filename'].$this->splitString.$date.'.'.$fileInfo['extension'];
+    }
+
+    /**
+     * @param string $logFilePath
+     * @return mixed
+     */
+    protected function unlinkHistoryDayLogFile(string $logFilePath)
+    {
+        if ($this->doUnlink) {
+            return;
+        }
+
+        $fileInfo = pathinfo($logFilePath);
+        $logDir = $fileInfo['dirname'];
+        $fileList = scandir($logDir);
+        $lastDay = date('Ymd', time() - 24 * 3600 * ($this->rotateDay + 1));
+        foreach ($fileList as $file) {
+            $pathFile = $logDir . DIRECTORY_SEPARATOR . $file;
+            if ($pathFile == '.' || $pathFile == '..' || !is_file($pathFile)) {
+                continue;
+            }
+            $fileName = pathinfo($pathFile, PATHINFO_FILENAME);
+            $fileArr = explode($this->splitString, $fileName);
+            $fileDate = array_pop($fileArr);
+
+            if (is_numeric($fileDate) && $fileDate < $lastDay ) {
+                unlink($pathFile);
+            }
+        }
+        $this->doUnlink = true;
     }
 
     /**
@@ -307,6 +361,8 @@ public function insertLog($logInfo, array $context = [], $type = Logger::INFO)
                     });
                 }
 
+                $this->unlinkHistoryDayLogFile($this->logFilePath);
+
                 // add records to the log
                 $this->logger->addRecord($type, $logInfo, $context);
             } catch (\Exception $e) {
@@ -332,6 +388,8 @@ public function insertLog($logInfo, array $context = [], $type = Logger::INFO)
      */
     protected function pushProcessor($records, $App = null): array
     {
+        $records['cid'] = \Swoole\Coroutine::getCid();
+        $records['process_id'] = (int)getmypid();
         $records['timestamp'] = microtime(true);
         $records['hostname']  = gethostname();
         $records['process'] = 'task_worker|use_self_worker';