fix: stage doens't adapt replace notify for notification

Notify server adapt replace notify, it will override old notify
both DB data and timeout data, and emit NotificationStateChanged.

pms: BUG-289863

Author: 18202781743

panels/notification/bubble/bubbleitem.cpp

@@ -216,6 +216,11 @@ uint BubbleItem::replacesId() const
     return m_entity.replacesId();
 }
 
+bool BubbleItem::isReplace() const
+{
+    return m_entity.isReplace();
+}
+
 int BubbleItem::urgency() const
 {
     return m_urgency;

panels/notification/bubble/bubbleitem.h

@@ -30,6 +30,7 @@ class BubbleItem : public QObject
     QString summary() const;
     QString body() const;
     uint replacesId() const;
+    bool isReplace() const;
     int urgency() const;
     QString bodyImagePath() const;
     qint64 ctime() const;

panels/notification/bubble/bubblemodel.cpp

@@ -271,15 +271,13 @@ void BubbleModel::setDelayRemovedBubble(qint64 newDelayRemovedBubble)
 
 int BubbleModel::replaceBubbleIndex(const BubbleItem *bubble) const
 {
-    if (bubble->replacesId() != NoReplaceId) {
+    if (bubble->isReplace()) {
         for (int i = 0; i < m_bubbles.size(); i++) {
             auto item = m_bubbles[i];
             if (item->appName() != bubble->appName())
                 continue;
 
-            const bool firstItem = item->replacesId() == NoReplaceId && item->bubbleId() == bubble->replacesId();
-            const bool laterItem = item->replacesId() == bubble->replacesId();
-            if (firstItem || laterItem) {
+            if (item->id() == bubble->id()) {
                 return i;
             }
         }

panels/notification/bubble/bubblemodel.h

@@ -76,7 +76,6 @@ class BubbleModel : public QAbstractListModel
     QList<BubbleItem *> m_bubbles;
     int BubbleMaxCount{3};
     const int OverlayMaxCount{2};
-    const int NoReplaceId{0};
     QList<qint64> m_delayBubbles;
     qint64 m_delayRemovedBubble{-1};
     const int DelayRemovBubbleTime{1000};

panels/notification/bubble/bubblepanel.cpp

@@ -134,8 +134,6 @@ void BubblePanel::addBubble(qint64 id)
     if (m_bubbles->isReplaceBubble(bubble)) {
         auto oldBubble = m_bubbles->replaceBubble(bubble);
         if (oldBubble) {
-            QMetaObject::invokeMethod(m_notificationServer, "notificationReplaced", Qt::DirectConnection,
-                                      Q_ARG(qint64, oldBubble->id()));
             oldBubble->deleteLater();
         }
     } else {

panels/notification/center/notifyitem.cpp

@@ -157,7 +157,7 @@ void AppNotifyItem::updateStrongInteractive()
     QMap<QString, QVariant>::const_iterator i = hints.constBegin();
     while (i != hints.constEnd()) {
         if (i.key() == QLatin1String("urgency")) {
-            ret = i.value().toString() == QLatin1String("SOH");
+            ret = i.value().toUInt() == NotifyEntity::Critical;
             break;
         }
         ++i;

panels/notification/center/notifystagingmodel.cpp

@@ -237,6 +237,19 @@ NotifyEntity NotifyStagingModel::notifyById(qint64 id) const
     return {};
 }
 
+void NotifyStagingModel::replace(const NotifyEntity &entity)
+{
+    for (int i = 0; i < m_appNotifies.size(); i++) {
+        auto item = m_appNotifies[i];
+        if (item->entity().id() == entity.id()) {
+            item->setEntity(entity);
+            const auto index = this->index(i, 0, {});
+            dataChanged(index, index);
+            break;
+        }
+    }
+}
+
 QHash<int, QByteArray> NotifyStagingModel::roleNames() const
 {
     static const QHash<int, QByteArray> roles{{NotifyItemType, "type"},
@@ -281,7 +294,11 @@ void NotifyStagingModel::doEntityReceived(qint64 id)
         qWarning(notifyLog) << "Received invalid entity:" << id << ", appName:" << entity.appName();
         return;
     }
-    push(entity);
+    if (entity.isReplace() && notifyById(id).isValid()) {
+        replace(entity);
+    } else {
+        push(entity);
+    }
 }
 
 void NotifyStagingModel::onEntityClosed(qint64 id)

panels/notification/center/notifystagingmodel.h

@@ -54,6 +54,7 @@ class NotifyStagingModel : public QAbstractListModel
 
 private slots:
     void push(const NotifyEntity &entity);
+    void replace(const NotifyEntity &entity);
     void doEntityReceived(qint64 id);
     void onEntityClosed(qint64 id);
 

panels/notification/common/dataaccessor.h

@@ -18,6 +18,12 @@ class DataAccessor
     {
     }
     virtual qint64 addEntity(const NotifyEntity &entity) { Q_UNUSED(entity); return 0; }
+    virtual qint64 replaceEntity(qint64 id, const NotifyEntity &entity)
+    {
+        Q_UNUSED(id);
+        Q_UNUSED(entity);
+        return 0;
+    }
 
     virtual void updateEntityProcessedType(qint64 id, int processedType) { Q_UNUSED(id); Q_UNUSED(processedType); }
 

panels/notification/common/dbaccessor.cpp

@@ -222,6 +222,52 @@ qint64 DBAccessor::addEntity(const NotifyEntity &entity)
     return storageId;
 }
 
+qint64 DBAccessor::replaceEntity(qint64 id, const NotifyEntity &entity)
+{
+    BENCHMARK();
+
+    QMutexLocker locker(&m_mutex);
+    QSqlQuery query(m_connection);
+
+    QString columns = QStringList{QString("%1 = :icon").arg(ColumnIcon),
+                                  QString("%1 = :summary").arg(ColumnSummary),
+                                  QString("%1 = :body").arg(ColumnBody),
+                                  QString("%1 = :appName").arg(ColumnAppName),
+                                  QString("%1 = :appId").arg(ColumnAppId),
+                                  QString("%1 = :ctime").arg(ColumnCTime),
+                                  QString("%1 = :action").arg(ColumnAction),
+                                  QString("%1 = :hint").arg(ColumnHint),
+                                  QString("%1 = :replacesId").arg(ColumnReplacesId),
+                                  QString("%1 = :notifyId").arg(ColumnNotifyId),
+                                  QString("%1 = :processedType").arg(ColumnProcessedType)}
+                          .join(", ");
+
+    QString sqlCmd = QString("UPDATE %1 SET %2 WHERE ID = :id").arg(TableName_v2).arg(columns);
+
+    query.prepare(sqlCmd);
+    query.bindValue(":icon", entity.appIcon());
+    query.bindValue(":summary", entity.summary());
+    query.bindValue(":body", entity.body());
+    query.bindValue(":appName", entity.appName());
+    query.bindValue(":appId", entity.appId());
+    query.bindValue(":ctime", entity.cTime());
+    query.bindValue(":action", entity.actionsString());
+    query.bindValue(":hint", entity.hintsString());
+    query.bindValue(":replacesId", entity.replacesId());
+    query.bindValue(":notifyId", entity.bubbleId());
+    query.bindValue(":processedType", entity.processedType());
+    query.bindValue(":id", id);
+
+    if (!query.exec()) {
+        qWarning(notifyDBLog) << "Update value to database failed: " << query.lastError().text() << query.lastQuery() << entity.bubbleId() << entity.cTime();
+        return -1;
+    }
+
+    qDebug(notifyDBLog) << "Update entity bubbleId:" << entity.bubbleId() << ", id:" << id << ", affected rows:" << query.numRowsAffected();
+
+    return id;
+}
+
 void DBAccessor::updateEntityProcessedType(qint64 id, int processedType)
 {
     BENCHMARK();