From ccf4473a5751ffe0931300f15f928aab7a012108 Mon Sep 17 00:00:00 2001
From: Xujiacheng <Xujiacheng@blw.com>
Date: Wed, 11 Feb 2026 10:01:03 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=88=A4=E6=96=AD=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91=EF=BC=8C=E4=BB=8E1=E5=88=86=E9=92=9F=E5=88=A4?=
 =?UTF-8?q?=E6=96=AD=E6=94=B9=E6=88=903=E5=88=86=E9=92=9F=E3=80=82?=
 =?UTF-8?q?=E5=B9=B6=E4=B8=94=E5=88=A4=E6=96=AD=E8=A7=84=E5=88=99=E4=BB=8E?=
 =?UTF-8?q?=E4=BA=A7=E7=94=9F=E6=95=B0=E6=8D=AE=E6=97=B6=E9=97=B4=E6=94=B9?=
 =?UTF-8?q?=E4=B8=BA=E5=85=A5=E5=BA=93=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Models/TimerClass.cs | 18 ++++++++++++++----
 1 file changed, 14 insertions(+), 4 deletions(-)

diff --git a/Models/TimerClass.cs b/Models/TimerClass.cs
index b96cd19..38dcea7 100644
--- a/Models/TimerClass.cs
+++ b/Models/TimerClass.cs
@@ -446,12 +446,21 @@ namespace AutoNotificatPhone.Models
                 await using var connection = new NpgsqlConnection(connectionString);
                 await connection.OpenAsync();
 
-                const string sql = "select ts_ms from heartbeat.heartbeat_events order by ts_ms desc limit 1";
+                const string sql = @"SELECT write_ts_ms
+                                    FROM (
+                                        SELECT write_ts_ms
+                                        FROM heartbeat.heartbeat_events
+                                        ORDER BY ts_ms DESC
+                                        LIMIT 3000
+                                    ) AS recent_events
+                                    ORDER BY write_ts_ms DESC
+                                    LIMIT 1;";
                 await using var command = new NpgsqlCommand(sql, connection);
                 object? result = await command.ExecuteScalarAsync();
 
                 if (result == null || result == DBNull.Value)
                 {
+                    logger.Error("Kafka入库心跳ts_ms查询结果为空");
                     ExecuteKafkaDbConnectionAlert();
                     return;
                 }
@@ -464,8 +473,9 @@ namespace AutoNotificatPhone.Models
                 }
 
                 long nowMs = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
-                if (nowMs - lastTsMs > TimeSpan.FromMinutes(2).TotalMilliseconds)
+                if (nowMs - lastTsMs > TimeSpan.FromMinutes(5).TotalMilliseconds)
                 {
+                    logger.Error("Kafka入库心跳超过5分钟未更新");
                     ExecuteKafkaInactiveAlert();
                 }
             }
@@ -533,8 +543,8 @@ namespace AutoNotificatPhone.Models
         private void ExecuteKafkaInactiveAlert()
         {
             SendAlert(
-                smsContent: "[BLV运维提示] BLS数据库1分钟内入库数据为0。",
-                callContent: "BLV运维提示 BLS数据库1分钟内入库数据为0",
+                smsContent: "[BLV运维提示] BLS数据库3分钟内入库数据为0。",
+                callContent: "BLV运维提示 BLS数据库3分钟内入库数据为0",
                 alertType: "BLS-数据库入库警报",
                 extendedDeadline: true
             );