From 1fc5ada74a238237df967c5de257038503bb35bd Mon Sep 17 00:00:00 2001
From: sige <sige@sige.com>
Date: Tue, 28 May 2024 14:12:46 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E5=A4=87=E5=90=AF=E5=8A=A8=E6=97=B6?=
 =?UTF-8?q?=E6=B8=85=E7=A9=BA=E6=9C=AA=E5=A4=84=E7=90=86=E9=80=9A=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/iflytop/digester/DigesterApplicationRunner.java     | 4 ++++
 .../digester/underframework/dao/model/UfMdbNotification.java     | 9 +++++++++
 2 files changed, 13 insertions(+)

diff --git a/src/main/java/com/iflytop/digester/DigesterApplicationRunner.java b/src/main/java/com/iflytop/digester/DigesterApplicationRunner.java
index 48bd29a..1552e99 100644
--- a/src/main/java/com/iflytop/digester/DigesterApplicationRunner.java
+++ b/src/main/java/com/iflytop/digester/DigesterApplicationRunner.java
@@ -1,6 +1,7 @@
 package com.iflytop.digester;
 import com.iflytop.digester.deviceinstance.Device;
 import com.iflytop.digester.underframework.UfApplication;
+import com.iflytop.digester.underframework.dao.model.UfMdbNotification;
 import jakarta.annotation.Resource;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -37,5 +38,8 @@ public class DigesterApplicationRunner implements ApplicationRunner {
 
         UfApplication.getApp().connections.setup();
         this.device.liquidAddition.setup();
+
+        LOG.info("[APP] expire all new messages");
+        UfMdbNotification.expireAllNewMessages();
     }
 }
diff --git a/src/main/java/com/iflytop/digester/underframework/dao/model/UfMdbNotification.java b/src/main/java/com/iflytop/digester/underframework/dao/model/UfMdbNotification.java
index 318167f..9a7104c 100644
--- a/src/main/java/com/iflytop/digester/underframework/dao/model/UfMdbNotification.java
+++ b/src/main/java/com/iflytop/digester/underframework/dao/model/UfMdbNotification.java
@@ -56,4 +56,13 @@ public class UfMdbNotification extends UfActiveRecord {
         var dataJson = UfJsonHelper.objectToJson(data);
         createNotification("action", dataJson);
     }
+
+    // expire all new messages
+    public static void expireAllNewMessages() {
+        var list = UfActiveRecord.find(UfMdbNotification.class, Map.of("status", "new"));
+        for ( var n : list ) {
+            n.status = "expired";
+            n.save();
+        }
+    }
 }