diff --git a/services/ans/src/advanced_notification_service.cpp b/services/ans/src/advanced_notification_service.cpp index 2110f89f60f485a506c4aeab2ce5893e69bf1cbc..56e343e340bdc73ff761bd9ae0221dc96d3c8cbb 100644 --- a/services/ans/src/advanced_notification_service.cpp +++ b/services/ans/src/advanced_notification_service.cpp @@ -289,6 +289,7 @@ ErrCode AdvancedNotificationService::PublishPreparedNotification( } UpdateRecentNotification(record->notification, false, 0); sptr sortingMap = GenerateSortingMap(); + ANS_LOGI(">>>>>>PublishPreparedNotification2"); NotificationSubscriberManager::GetInstance()->NotifyConsumed(record->notification, sortingMap); })); return result; diff --git a/services/ans/src/notification_subscriber_manager.cpp b/services/ans/src/notification_subscriber_manager.cpp index 9b7d7e247ba140c87935c91320430082e4a1d2f3..bd981e8d91d9ce39062c97a1fa4eb83aa5ee0c32 100644 --- a/services/ans/src/notification_subscriber_manager.cpp +++ b/services/ans/src/notification_subscriber_manager.cpp @@ -56,6 +56,7 @@ ErrCode NotificationSubscriberManager::AddSubscriber( return ERR_ANS_INVALID_PARAM; } + ANS_LOGI(">>>>>>AddSubscriber"); sptr subInfo = subscribeInfo; if (subInfo == nullptr) { subInfo = new (std::nothrow) NotificationSubscribeInfo(); @@ -66,8 +67,10 @@ ErrCode NotificationSubscriberManager::AddSubscriber( int userId = SUBSCRIBE_USER_ALL; subInfo->AddAppUserId(userId); + ANS_LOGI(">>>>>>AddSubscriber2, userid = %{public}d", userId); } + ANS_LOGI(">>>>>>AddSubscriber3"); ErrCode result = ERR_ANS_TASK_ERR; handler_->PostSyncTask(std::bind([this, &subscriber, &subInfo, &result]() { result = this->AddSubscriberInner(subscriber, subInfo); @@ -99,6 +102,7 @@ void NotificationSubscriberManager::NotifyConsumed( ANS_LOGE("handler is nullptr"); return; } + ANS_LOGI(">>>>>>NotifyConsumed"); AppExecFwk::EventHandler::Callback NotifyConsumedFunc = std::bind(&NotificationSubscriberManager::NotifyConsumedInner, this, notification, notificationMap); @@ -205,10 +209,15 @@ void NotificationSubscriberManager::AddRecordInfo( record->subscribedAll = false; } record->userId = subscribeInfo->GetAppUserId(); + if (record->userId == SUBSCRIBE_USER_INIT) { + record->userId = SUBSCRIBE_USER_ALL; + } } else { record->bundleList_.clear(); record->subscribedAll = true; } + ANS_LOGI(">>>>>>AddRecordInfo, userid = %{public}d, subscribedAll= %{public}d, bundlesize=%{public}d", + record->userId, record->subscribedAll, record->bundleList_.size()); } void NotificationSubscriberManager::RemoveRecordInfo( @@ -233,6 +242,7 @@ ErrCode NotificationSubscriberManager::AddSubscriberInner( { std::shared_ptr record = FindSubscriberRecord(subscriber); + ANS_LOGI(">>>>>>AddSubscriberInner, userid = %{public}d", record->userId); if (record == nullptr) { record = CreateSubscriberRecord(subscriber); if (record == nullptr) { @@ -279,10 +289,14 @@ ErrCode NotificationSubscriberManager::RemoveSubscriberInner( void NotificationSubscriberManager::NotifyConsumedInner( const sptr ¬ification, const sptr ¬ificationMap) { + ANS_LOGI(">>>>>>NotifyConsumedInner, userid = %{public}d", + notification->GetUserId()); for (auto record : subscriberRecordList_) { auto BundleNames = notification->GetBundleName(); auto iter = std::find(record->bundleList_.begin(), record->bundleList_.end(), BundleNames); + ANS_LOGI(">>>>>>NotifyConsumedInner, userid = %{public}d, record subscribedAll = %{public}d, size=%{public}d, userid=%{public}d", + notification->GetUserId(), record->subscribedAll, record->bundleList_.size(), record->userId); if (!record->subscribedAll == (iter != record->bundleList_.end()) && (notification->GetUserId() == record->userId || notification->GetUserId() == SUBSCRIBE_USER_ALL)) { record->subscriber->OnConsumed(notification, notificationMap);