fix(update): 升降版本保留原有配置并隔离包管理进程

- preinstall 备份 data/ 与 config/（含 bbolt config.db），postinstall 在 systemd-run 独立单元内先停服再恢复后启动，升级/降级不再丢失采集通道等业务数据

- runPkgManager 经 systemd-run --wait 创建 transient unit 执行 dpkg/rpm，避免目标包 postinst 重启 edgeCore 时 CGroup 级联终止 dpkg（half-configured）

Author: Thouen

internal/update/local.go

@@ -276,9 +276,9 @@ func (m *Manager) installPkg(path, format string) error {
 	var err error
 	switch format {
 	case "deb":
-		out, err = m.execFn("dpkg", "--force-confnew", "--force-confmiss", "-i", path).CombinedOutput()
+		out, err = m.runPkgManager("dpkg", "--force-confnew", "--force-confmiss", "-i", path)
 	case "rpm":
-		out, err = m.execFn("rpm", "-Uvh", path).CombinedOutput()
+		out, err = m.runPkgManager("rpm", "-Uvh", path)
 	}
 	if err != nil {
 		return fmt.Errorf("%s 安装失败: %s: %s", format, strings.TrimSpace(string(out)), err)

internal/update/local_test.go

@@ -4,7 +4,9 @@ import (
 	"archive/tar"
 	"compress/gzip"
 	"os"
+	"os/exec"
 	"path/filepath"
+	"reflect"
 	"runtime"
 	"testing"
 )
@@ -192,3 +194,46 @@ func TestArchIncompatibleFilenameStillParsed(t *testing.T) {
 		t.Fatal("incompatible package should carry a reason")
 	}
 }
+
+func TestRunPkgManagerWrapsWithSystemdRun(t *testing.T) {
+	var calls [][]string
+	m := NewManager("", "", nil)
+	m.execFn = func(name string, arg ...string) *exec.Cmd {
+		calls = append(calls, append([]string{name}, arg...))
+		// 探测 systemd-run --version 与包装后的命令均返回成功
+		return exec.Command("echo", "ok")
+	}
+	if _, err := m.runPkgManager("dpkg", "--force-confnew", "--force-confmiss", "-i", "/tmp/x.deb"); err != nil {
+		t.Fatal(err)
+	}
+	if len(calls) != 2 {
+		t.Fatalf("expected 2 calls, got %v", calls)
+	}
+	want := []string{"systemd-run", "--wait", "--quiet", "--slice=system.slice", "--", "dpkg", "--force-confnew", "--force-confmiss", "-i", "/tmp/x.deb"}
+	if !reflect.DeepEqual(calls[1], want) {
+		t.Fatalf("unexpected wrapped call: %v", calls[1])
+	}
+}
+
+func TestRunPkgManagerFallback(t *testing.T) {
+	var calls [][]string
+	m := NewManager("", "", nil)
+	m.execFn = func(name string, arg ...string) *exec.Cmd {
+		calls = append(calls, append([]string{name}, arg...))
+		// systemd-run 不可用（探测失败），后续直接执行
+		if name == "systemd-run" {
+			return exec.Command("sh", "-c", "exit 127")
+		}
+		return exec.Command("echo", "ok")
+	}
+	if _, err := m.runPkgManager("rpm", "-Uvh", "/tmp/x.rpm"); err != nil {
+		t.Fatal(err)
+	}
+	if len(calls) != 2 {
+		t.Fatalf("expected 2 calls, got %v", calls)
+	}
+	want := []string{"rpm", "-Uvh", "/tmp/x.rpm"}
+	if !reflect.DeepEqual(calls[1], want) {
+		t.Fatalf("unexpected fallback call: %v", calls[1])
+	}
+}

internal/update/manager.go

@@ -78,6 +78,22 @@ func (m *Manager) Status() State {
 	return m.state
 }
 
+// runPkgManager 在独立 systemd transient unit 中执行包管理器。Web UI 升级时
+// dpkg/rpm 由 edgeCore 进程派生、运行于 edgeCore.service 的 CGroup 内；目标包
+// postinst 的 systemctl restart 会连同 postinst/dpkg 一并终止（dpkg 卡
+// half-configured，升级误报失败并回滚）。
+// 不能用 --scope：scope 生命周期绑定调用进程，edgeCore 被 restart 杀死时
+// systemd 会清理 scope 内进程。改为 --wait 创建独立 transient service unit，
+// 生命周期由 systemd 管理、与调用者解耦，edgeCore 死后 dpkg 仍能完成安装。
+// 非 systemd 环境（无 systemd-run）回退直接执行。
+func (m *Manager) runPkgManager(args ...string) ([]byte, error) {
+	if _, err := m.execFn("systemd-run", "--version").Output(); err == nil {
+		wrapped := append([]string{"--wait", "--quiet", "--slice=system.slice", "--"}, args...)
+		return m.execFn("systemd-run", wrapped...).CombinedOutput()
+	}
+	return m.execFn(args[0], args[1:]...).CombinedOutput()
+}
+
 // Checker 暴露底层的版本检查器（供 handler 查询）。
 func (m *Manager) Checker() *Checker { return m.checker }
 

scripts/postinstall.sh

@@ -22,10 +22,6 @@ restore_dir() {
     fi
 }
 
-# 恢复 data 和 config
-restore_dir "$BACKUP_DIR/data" "$DATA_DIR"
-restore_dir "$BACKUP_DIR/config" "$CONFIG_DIR"
-
 # 仅在 systemctl 存在时执行 systemd 操作
 if command -v systemctl >/dev/null 2>&1; then
     echo "[postinstall] Reloading systemd..."
@@ -34,10 +30,33 @@ if command -v systemctl >/dev/null 2>&1; then
     echo "[postinstall] Enabling service..."
     systemctl enable edgeCore || true
 
-    echo "[postinstall] Starting service..."
-    systemctl restart edgeCore || true
+    # 关键：通过 Web UI 升级时，dpkg/postinst 由 edgeCore 进程派生，
+    # 运行于 edgeCore.service 的 CGroup 内。直接 systemctl restart 会连同
+    # postinst/dpkg 一并终止（dpkg 状态卡在 half-configured，升级误报失败）。
+    # 用 systemd-run --wait 创建独立 transient unit 执行 systemd 操作：
+    # unit 生命周期由 systemd 管理、与调用者解耦（不能用 --scope）。
+    if command -v systemd-run >/dev/null 2>&1; then
+        # 先停止旧服务：旧进程持有 data/config.db、runtime.db 的 bbolt 文件锁，
+        # 若在运行期间直接覆盖恢复文件会与旧进程写入竞态、导致数据库损坏。
+        # 停止后旧进程退出、文件释放，恢复与启动都在稳定状态下进行。
+        systemd-run --wait --quiet --slice=system.slice systemctl stop edgeCore || true
+
+        # 恢复 data 和 config（旧进程已退出，文件处于稳定状态）
+        restore_dir "$BACKUP_DIR/data" "$DATA_DIR"
+        restore_dir "$BACKUP_DIR/config" "$CONFIG_DIR"
+
+        # 启动新版本服务
+        systemd-run --wait --quiet --slice=system.slice systemctl start edgeCore || true
+    else
+        # 无 systemd-run 环境：保持先恢复再重启的顺序，避免服务长时间停摆
+        restore_dir "$BACKUP_DIR/data" "$DATA_DIR"
+        restore_dir "$BACKUP_DIR/config" "$CONFIG_DIR"
+        systemctl restart edgeCore || true
+    fi
 else
-    echo "[postinstall] systemctl not found, skipping systemd service operations."
+    # 非 systemd 环境：无服务进程持有 bbolt 文件锁，直接恢复配置即可
+    restore_dir "$BACKUP_DIR/data" "$DATA_DIR"
+    restore_dir "$BACKUP_DIR/config" "$CONFIG_DIR"
 fi
 
 echo "[postinstall] Completed."

scripts/preinstall.sh

@@ -4,6 +4,7 @@ set -e
 
 ROOT_DIR="/usr/local/bin/edgeCore"
 CONFIG_DIR="$ROOT_DIR/config"
+DATA_DIR="$ROOT_DIR/data"
 BACKUP_DIR="/tmp/edgeCore_backup"
 
 echo "[preinstall] Starting preinstall script..."
@@ -27,7 +28,9 @@ backup_dir() {
     fi
 }
 
-# 备份目录
+# 备份目录：升级/降级必须保留原有配置，否则通道/设备等业务数据
+# （位于 data/config.db，bbolt 存储）会随版本变更而丢失。
+backup_dir "$DATA_DIR" "$BACKUP_DIR/data"
 backup_dir "$CONFIG_DIR" "$BACKUP_DIR/config"
 
 echo "[preinstall] Completed."