feat: add notification auto cleanup and timeout handling

1. Add fetchFirstEntity method to data accessor interfaces for
retrieving earliest notifications
2. Implement notification auto-cleanup feature that removes processed
notifications older than configured days
3. Add Timeout processed type for handling expired notifications
4. Add configuration option for notification cleanup days with default
value of 7 days
5. Implement cleanup timer that runs every second to check for expired
notifications
6. Update notification processing to handle timeout closures properly

feat: 添加通知自动清理和超时处理功能

1. 在数据访问器接口中添加 fetchFirstEntity 方法用于获取最早的通知
2. 实现通知自动清理功能，删除超过配置天数的已处理通知
3. 添加 Timeout 处理类型用于处理过期通知
4. 添加通知清理天数的配置选项，默认值为7天
5. 实现清理定时器，每秒检查一次过期通知
6. 更新通知处理逻辑以正确处理超时关闭

PMS: BUG-284979

Author: wjyrich

panels/notification/common/dataaccessor.h

@@ -35,6 +35,7 @@ class DataAccessor
     virtual int fetchEntityCount(const QString &appName, int processedType) const { Q_UNUSED(appName); Q_UNUSED(processedType); return 0; }
     virtual NotifyEntity fetchLastEntity(const QString &appName, int processedType) { Q_UNUSED(appName); Q_UNUSED(processedType); return {}; }
     virtual NotifyEntity fetchLastEntity(uint notifyId) { Q_UNUSED(notifyId); return {}; }
+    virtual NotifyEntity fetchFirstEntity(int processedType) { Q_UNUSED(processedType); return {}; }
     virtual QList<NotifyEntity> fetchEntities(const QString &appName, int processedType, int maxCount)
     {
         Q_UNUSED(appName)

panels/notification/common/dataaccessorproxy.cpp

@@ -116,6 +116,15 @@ NotifyEntity DataAccessorProxy::fetchLastEntity(uint notifyId)
     return m_source->fetchLastEntity(notifyId);
 }
 
+NotifyEntity DataAccessorProxy::fetchFirstEntity(int processedType)
+{
+    if (processedType == NotifyEntity::NotProcessed) {
+        return m_impl->fetchFirstEntity(processedType);
+    } else {
+        return m_source->fetchFirstEntity(processedType);
+    }
+}
+
 QList<NotifyEntity> DataAccessorProxy::fetchEntities(const QString &appName, int processedType, int maxCount)
 {
     if (processedType == NotifyEntity::NotProcessed) {

panels/notification/common/dataaccessorproxy.h

@@ -31,6 +31,7 @@ class DataAccessorProxy : public DataAccessor
     virtual int fetchEntityCount(const QString &appName, int processedType) const override;
     virtual NotifyEntity fetchLastEntity(const QString &appName, int processedType) override;
     virtual NotifyEntity fetchLastEntity(uint notifyId) override;
+    virtual NotifyEntity fetchFirstEntity(int processedType) override;
     virtual QList<NotifyEntity> fetchEntities(const QString &appName, int processedType, int maxCount) override;
     virtual QList<QString> fetchApps(int maxCount) const override;
 

panels/notification/common/dbaccessor.cpp

@@ -443,6 +443,29 @@ NotifyEntity DBAccessor::fetchLastEntity(uint notifyId)
     return {};
 }
 
+NotifyEntity DBAccessor::fetchFirstEntity(int processedType)
+{
+    BENCHMARK();
+
+    QMutexLocker locker(&m_mutex);
+    QSqlQuery query(m_connection);
+    
+    QString cmd = QString("SELECT %1 FROM notifications2 WHERE (ProcessedType = :processedType OR ProcessedType IS NULL) ORDER BY CTime ASC LIMIT 1").arg(EntityFields.join(","));
+    query.prepare(cmd);
+    query.bindValue(":processedType", processedType);
+
+    if (!query.exec()) {
+        qWarning(notifyDBLog) << "Query execution error:" << query.lastError().text();
+        return {};
+    }
+
+    if (query.next()) {
+        auto entity = parseEntity(query);
+        return entity;
+    }
+    return {};
+}
+
 QList<QString> DBAccessor::fetchApps(int maxCount) const
 {
     BENCHMARK();

panels/notification/common/dbaccessor.h

@@ -37,6 +37,7 @@ class DBAccessor : public DataAccessor
     NotifyEntity fetchLastEntity(const QString &appName, int processedType) override;
     QList<NotifyEntity> fetchEntities(const QString &appName, int processedType, int maxCount) override;
     NotifyEntity fetchLastEntity(uint notifyId) override;
+    NotifyEntity fetchFirstEntity(int processedType) override;
     QList<QString> fetchApps(int maxCount) const override;
 
     void removeEntity(qint64 id) override;

panels/notification/common/memoryaccessor.cpp

@@ -4,6 +4,7 @@
 
 #include "memoryaccessor.h"
 #include <QDebug>
+#include <limits>
 
 namespace notification
 {
@@ -102,6 +103,22 @@ NotifyEntity MemoryAccessor::fetchLastEntity(uint notifyId)
     return {};
 }
 
+NotifyEntity MemoryAccessor::fetchFirstEntity(int processedType)
+{
+    QMutexLocker locker(&m_mutex);
+    NotifyEntity firstEntity;
+    qint64 earliestTime = std::numeric_limits<qint64>::max();
+    
+    for (const auto &entity : m_entities) {
+        if (entity.processedType() == processedType && entity.cTime() < earliestTime) {
+            earliestTime = entity.cTime();
+            firstEntity = entity;
+        }
+    }
+
+    return firstEntity.isValid() ? firstEntity : NotifyEntity{};
+}
+
 QList<NotifyEntity> MemoryAccessor::fetchEntities(const QString &appName, int processedType, int maxCount)
 {
     QMutexLocker locker(&m_mutex);

panels/notification/common/memoryaccessor.h

@@ -27,6 +27,7 @@ class MemoryAccessor : public DataAccessor
     virtual int fetchEntityCount(const QString &appName, int processedType) const override;
     virtual NotifyEntity fetchLastEntity(const QString &appName, int processedType) override;
     virtual NotifyEntity fetchLastEntity(uint notifyId) override;
+    virtual NotifyEntity fetchFirstEntity(int processedType) override;
     virtual QList<NotifyEntity> fetchEntities(const QString &appName, int processedType, int maxCount) override;
     virtual QList<QString> fetchApps(int maxCount) const override;
 

panels/notification/common/notifyentity.h

@@ -30,6 +30,7 @@ class NotifyEntity
         Dismissed = 2,
         Closed = 3,
         Unknown = 4,
+        Timeout = 5,
     };
 
     NotifyEntity();

panels/notification/server/configs/org.deepin.dde.shell.notification.json

@@ -144,6 +144,17 @@
       "description[zh_CN]": "应用名称映射",
       "permissions": "readwrite",
       "visibility": "private"
+    },
+    "notificationCleanupDays": {
+      "value": 7,
+      "serial": 0,
+      "flags": [],
+      "name": "notification cleanup days",
+      "name[zh_CN]": "通知清理天数",
+      "description": "Number of days after which notifications will be automatically cleaned up",
+      "description[zh_CN]": "通知自动清理的天数，超过此天数的通知将被自动删除",
+      "permissions": "readwrite",
+      "visibility": "public"
     }
   }
 }

panels/notification/server/notificationmanager.cpp

@@ -49,9 +49,14 @@ NotificationManager::NotificationManager(QObject *parent)
     , m_persistence(DataAccessorProxy::instance())
     , m_setting(new NotificationSetting(this))
     , m_pendingTimeout(new QTimer(this))
+    , m_cleanupTimer(new QTimer(this))
 {
     m_pendingTimeout->setSingleShot(true);
     connect(m_pendingTimeout, &QTimer::timeout, this, &NotificationManager::onHandingPendingEntities);
+    
+    m_cleanupTimer->setInterval(1000); 
+    connect(m_cleanupTimer, &QTimer::timeout, this, &NotificationManager::onCleanupExpiredNotifications);
+    m_cleanupTimer->start();
 
     DataAccessorProxy::instance()->setSource(DBAccessor::instance());
 
@@ -77,6 +82,7 @@ NotificationManager::NotificationManager(QObject *parent)
     m_systemApps = config->value("systemApps").toStringList();
     // TODO temporary fix for AppNamesMap
     m_appNamesMap = config->value("AppNamesMap").toMap();
+    m_cleanupDays = config->value("notificationCleanupDays", 7).toInt();
 
     if (QStringLiteral("wayland") != QGuiApplication::platformName()) {
         initScreenLockedState();
@@ -457,6 +463,8 @@ void NotificationManager::updateEntityProcessed(qint64 id, uint reason)
     if (entity.isValid()) {
         if ((reason == NotifyEntity::Closed || reason == NotifyEntity::Dismissed) && entity.processedType() == NotifyEntity::NotProcessed) {
             entity.setProcessedType(NotifyEntity::Removed);
+        } else if (reason == NotifyEntity::Timeout) {
+            entity.setProcessedType(NotifyEntity::Removed);
         } else {
             entity.setProcessedType(NotifyEntity::Processed);
         }
@@ -675,4 +683,24 @@ void NotificationManager::onScreenLockedChanged(bool screenLocked)
     m_screenLocked = screenLocked;
 }
 
+void NotificationManager::onCleanupExpiredNotifications()
+{    
+    const qint64 currentTime = QDateTime::currentMSecsSinceEpoch();
+    const qint64 cleanupDaysInMs = m_cleanupDays * 24 * 60 * 60 * 1000;
+    const qint64 cutoffTime = currentTime - cleanupDaysInMs;
+    
+    while (true) {
+        auto firstEntity = m_persistence->fetchFirstEntity(NotifyEntity::Processed);
+        
+        if (!firstEntity.isValid()) {
+            break;
+        }
+        
+        if (firstEntity.cTime() > cutoffTime) {
+            break;
+        }
+        notificationClosed(firstEntity.id(), firstEntity.bubbleId(), NotifyEntity::Timeout);
+    }
+}
+
 } // notification