From 7ff83587b617a0b2962e54202695ccc6c2f744fa Mon Sep 17 00:00:00 2001
From: augushong <augushong@163.com>
Date: Sun, 16 Aug 2026 07:28:27 +0800
Subject: [PATCH] =?UTF-8?q?feat(log):=20=E6=96=B0=E5=A2=9E=20ul=5Fdebug=5F?=
 =?UTF-8?q?log=5Fposition=20=E8=A1=A8=EF=BC=88migration+scheme+model?=
 =?UTF-8?q?=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/admin/model/DebugLogPosition.php          | 27 +++++++++
 app/admin/scheme/DebugLogPosition.php         | 56 +++++++++++++++++++
 .../20260815100001_debug_log_position.php     | 31 ++++++++++
 3 files changed, 114 insertions(+)
 create mode 100644 app/admin/model/DebugLogPosition.php
 create mode 100644 app/admin/scheme/DebugLogPosition.php
 create mode 100644 database/migrations/20260815100001_debug_log_position.php

diff --git a/app/admin/model/DebugLogPosition.php b/app/admin/model/DebugLogPosition.php
new file mode 100644
index 0000000..9f64ac5
--- /dev/null
+++ b/app/admin/model/DebugLogPosition.php
@@ -0,0 +1,27 @@
+<?php
+
+namespace app\admin\model;
+
+use app\common\model\TimeModel;
+
+/**
+ * @property int $id 主键ID
+ * @property string $node_id 节点ID（区分不同采集节点）
+ * @property string $file_path 日志文件绝对路径
+ * @property int $inode 文件 inode，用于检测日志轮转
+ * @property int $offset 上次读取到的字节偏移
+ * @property int $last_read_time 上次读取时间戳
+ * @property string $last_line_hash 上次最后一行的 md5 哈希（容错校验）
+ * @property int $parse_fail_count 解析失败累计次数
+ * @property string $parse_fail_samples 解析失败样本行（最多保留若干条）
+ * @property int $create_time 创建时间戳
+ * @property int $update_time 更新时间戳
+ */
+class DebugLogPosition extends TimeModel
+{
+
+    protected $name = "debug_log_position";
+
+    protected $deleteTime = false;
+
+}
diff --git a/app/admin/scheme/DebugLogPosition.php b/app/admin/scheme/DebugLogPosition.php
new file mode 100644
index 0000000..d90b4c0
--- /dev/null
+++ b/app/admin/scheme/DebugLogPosition.php
@@ -0,0 +1,56 @@
+<?php
+
+namespace app\admin\scheme;
+
+use app\common\scheme\BaseScheme;
+use app\common\scheme\attribute\Table;
+use app\common\scheme\attribute\Field;
+use app\common\scheme\attribute\Component;
+use app\common\scheme\attribute\Index;
+
+#[Table(name: 'ul_debug_log_position', comment: '调试日志文件读取位置（增量读取状态）')]
+#[Index(columns: ['node_id', 'file_path'], name: 'uniq_node_file', type: 'UNIQUE')]
+class DebugLogPosition extends BaseScheme
+{
+    #[Field(type: 'int', length: 11, nullable: false, unsigned: true, autoIncrement: true, primary: true)]
+    public $id;
+
+    #[Field(type: 'varchar', length: 64, nullable: false, default: '', comment: '节点ID（区分不同采集节点）')]
+    public $node_id;
+
+    #[Field(type: 'varchar', length: 500, nullable: false, comment: '日志文件绝对路径')]
+    #[Component(type: 'text', options: [])]
+    public $file_path;
+
+    #[Field(type: 'bigint', default: '0', unsigned: true, comment: '文件 inode，用于检测日志轮转')]
+    #[Component(type: 'text', options: [])]
+    public $inode;
+
+    #[Field(type: 'bigint', default: '0', unsigned: true, comment: '上次读取到的字节偏移')]
+    #[Component(type: 'text', options: [])]
+    public $offset;
+
+    #[Field(type: 'int', length: 11, default: '0', unsigned: true, comment: '上次读取时间戳')]
+    #[Component(type: 'date', options: [])]
+    public $last_read_time;
+
+    #[Field(type: 'varchar', length: 32, default: '', comment: '上次最后一行的 md5 哈希（容错校验）')]
+    #[Component(type: 'text', options: [])]
+    public $last_line_hash;
+
+    #[Field(type: 'int', length: 11, default: '0', unsigned: true, comment: '解析失败累计次数')]
+    #[Component(type: 'text', options: [])]
+    public $parse_fail_count;
+
+    #[Field(type: 'text', nullable: true, comment: '解析失败样本行（最多保留若干条）')]
+    #[Component(type: 'textarea', options: [])]
+    public $parse_fail_samples;
+
+    #[Field(type: 'int', length: 11, unsigned: true, comment: '创建时间戳')]
+    #[Component(type: 'date', options: [])]
+    public $create_time;
+
+    #[Field(type: 'int', length: 11, unsigned: true, comment: '更新时间戳')]
+    #[Component(type: 'date', options: [])]
+    public $update_time;
+}
diff --git a/database/migrations/20260815100001_debug_log_position.php b/database/migrations/20260815100001_debug_log_position.php
new file mode 100644
index 0000000..d144729
--- /dev/null
+++ b/database/migrations/20260815100001_debug_log_position.php
@@ -0,0 +1,31 @@
+<?php
+
+use think\migration\Migrator;
+
+/**
+ * 调试日志 - 文件读取位置表
+ *
+ * 记录每个 debug 日志文件的 inode/offset/最近读取时间/失败计数等增量读取状态。
+ * 唯一键 uniq_node_file(node_id, file_path)：多节点导各自文件互不覆盖。
+ */
+class DebugLogPosition extends Migrator
+{
+    public function change()
+    {
+        $table = $this->table('debug_log_position', ['id' => false, 'primary_key' => ['id']])
+            ->setComment('调试日志文件读取位置（增量读取状态）')
+            ->addColumn('id', 'integer', ['limit' => 11, 'null' => false, 'signed' => false, 'identity' => true, 'comment' => '主键ID'])
+            ->addColumn('node_id', 'string', ['limit' => 64, 'null' => false, 'default' => '', 'comment' => '节点ID（区分不同采集节点）'])
+            ->addColumn('file_path', 'string', ['limit' => 500, 'null' => false, 'comment' => '日志文件绝对路径'])
+            ->addColumn('inode', 'biginteger', ['default' => 0, 'comment' => '文件 inode，用于检测日志轮转', 'signed' => false])
+            ->addColumn('offset', 'biginteger', ['default' => 0, 'comment' => '上次读取到的字节偏移', 'signed' => false])
+            ->addColumn('last_read_time', 'integer', ['limit' => 11, 'default' => 0, 'comment' => '上次读取时间戳', 'signed' => false])
+            ->addColumn('last_line_hash', 'string', ['limit' => 32, 'default' => '', 'comment' => '上次最后一行的 md5 哈希（容错校验）'])
+            ->addColumn('parse_fail_count', 'integer', ['limit' => 11, 'default' => 0, 'comment' => '解析失败累计次数', 'signed' => false])
+            ->addColumn('parse_fail_samples', 'text', ['null' => true, 'comment' => '解析失败样本行（最多保留若干条）'])
+            ->addColumn('create_time', 'integer', ['limit' => 11, 'comment' => '创建时间戳', 'signed' => false])
+            ->addColumn('update_time', 'integer', ['limit' => 11, 'comment' => '更新时间戳', 'signed' => false])
+            ->addIndex(['node_id', 'file_path'], ['unique' => true, 'name' => 'uniq_node_file'])
+            ->create();
+    }
+}