From 7804adc54a6ce053773aba6b860e9ff6ad2c3b0b Mon Sep 17 00:00:00 2001
From: lkddi <lkddi@163.com>
Date: Tue, 17 Mar 2026 20:27:04 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=8E=89=E7=BA=BF=E8=87=AA?=
 =?UTF-8?q?=E5=8A=A8=E7=BB=93=E7=AE=97=E5=91=BD=E4=BB=A4=E5=B9=B6=E4=BF=AE?=
 =?UTF-8?q?=E5=A4=8D=E8=B7=A8=E5=A4=A9=E6=97=A5=E5=BF=97=E5=BD=92=E9=9B=B6?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 新建 CloseStaleDutyLogs 命令：每 15 分钟扫描无心跳开放日志自动关闭
- 注册调度 duty:close-stale-logs everyFifteenMinutes
- 修复 closeDutyLog：跨天遗留日志保留 duration_seconds，不再硬归零
---
 app/Console/Commands/CloseStaleDutyLogs.php | 63 +++++++++++++++++++++
 app/Http/Controllers/ChatController.php     |  6 +-
 routes/console.php                          |  3 +
 3 files changed, 69 insertions(+), 3 deletions(-)
 create mode 100644 app/Console/Commands/CloseStaleDutyLogs.php

diff --git a/app/Console/Commands/CloseStaleDutyLogs.php b/app/Console/Commands/CloseStaleDutyLogs.php
new file mode 100644
index 0000000..a136105
--- /dev/null
+++ b/app/Console/Commands/CloseStaleDutyLogs.php
@@ -0,0 +1,63 @@
+<?php
+
+/**
+ * 文件功能：自动关闭掉线职务日志指令
+ *
+ * 每 15 分钟由 Laravel Scheduler 调用，扫描 position_duty_logs 表中：
+ * - logout_at IS NULL（尚未结算的开放日志）
+ * - updated_at 超过 15 分钟未刷新（说明心跳已中断，用户已掉线/关闭浏览器）
+ *
+ * 对此类日志写入 logout_at = NOW()，保留 duration_seconds 现有值不清零，
+ * 确保累计时长计算准确，不因掉线而永久悬空。
+ *
+ * @author   ChatRoom Laravel
+ *
+ * @version  1.0.0
+ */
+
+namespace App\Console\Commands;
+
+use App\Models\PositionDutyLog;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+
+class CloseStaleDutyLogs extends Command
+{
+    /**
+     * Artisan 指令名称
+     */
+    protected $signature = 'duty:close-stale-logs';
+
+    /**
+     * 指令描述（在 artisan list 中显示）
+     */
+    protected $description = '自动关闭 15 分钟内无心跳的开放职务日志（解决掉线不结算问题）';
+
+    /**
+     * 指令入口：将长时间无心跳刷新的开放日志判定为掉线，写入 logout_at 完成结算。
+     *
+     * 判定标准：updated_at 超过 15 分钟（心跳间隔约 30 秒，5 分钟自动存点最长 5 分钟，
+     * 留足 10 分钟容差，总计 15 分钟无刷新即认为掉线）
+     */
+    public function handle(): int
+    {
+        // 15 分钟无心跳 = 掉线判定阈值
+        $threshold = now()->subMinutes(15);
+
+        // 批量关闭符合条件的开放日志，保留现有 duration_seconds
+        $affected = PositionDutyLog::query()
+            ->whereNull('logout_at')
+            ->where('updated_at', '<=', $threshold)
+            ->update([
+                'logout_at' => DB::raw('NOW()'),
+            ]);
+
+        if ($affected > 0) {
+            $this->info("共关闭 {$affected} 条掉线职务日志。");
+        } else {
+            $this->info('无需处理，无掉线日志。');
+        }
+
+        return Command::SUCCESS;
+    }
+}
diff --git a/app/Http/Controllers/ChatController.php b/app/Http/Controllers/ChatController.php
index 784698e..a2b32ae 100644
--- a/app/Http/Controllers/ChatController.php
+++ b/app/Http/Controllers/ChatController.php
@@ -1025,14 +1025,14 @@ class ChatController extends Controller
                 'duration_seconds' => DB::raw('GREATEST(0, TIMESTAMPDIFF(SECOND, login_at, NOW()))'),
             ]);
 
-        // 清理历史遭留未关闭的日志（login_at 非今日），直接将它们的时长置 0，避免被算入任何榜单
+        // 关闭历史遗留的跨天未关闭日志（login_at 非今日）
+        // 保留最后一次心跳刷新的 duration_seconds，确保已积累时长不丢失
         PositionDutyLog::query()
             ->where('user_id', $userId)
             ->whereNull('logout_at')
             ->whereDate('login_at', '<', today())
             ->update([
-                'logout_at' => DB::raw('login_at'), // 时长 = 0
-                'duration_seconds' => 0,
+                'logout_at' => DB::raw('login_at + INTERVAL duration_seconds SECOND'),
             ]);
     }
 
diff --git a/routes/console.php b/routes/console.php
index e0f637b..00a5095 100644
--- a/routes/console.php
+++ b/routes/console.php
@@ -14,6 +14,9 @@ Schedule::command('messages:purge')->dailyAt('03:00');
 // 每 5 分钟为所有在线用户自动存点（经验/金币/等级）
 Schedule::command('chatroom:auto-save-exp')->everyFiveMinutes();
 
+// 每 15 分钟：关闭掉线用户的开放职务日志（久无心跳 = 掉线，自动写入 logout_at）
+Schedule::command('duty:close-stale-logs')->everyFifteenMinutes();
+
 // ──────────── 婚姻系统定时任务 ────────────────────────────────────
 
 // 每 5 分钟：扫描超时求婚（48h后失效 + 戒指消失 + 广播通知）