Subscribe Notification and Publish Notification for Insert operation in any entity #6390

19 Answer(s)

• 

  0

  ryancyq created 5 years ago

  Support Team

  We have implemented Notification when any user add data in our custom table X. We have also set Entity Type in AppNotificationProvider.cs file as "typeof(X)

  Hi, if possible, please share some code about the implementation of the scenario above

  1. For our case, these types of Notification can be called General or Entity based?

  This depends if the nofitication is created with entity Id and type. if they do have entity Id and type then they are considered as entity base.

  2. For insert operation, EntityTypeName should be saved in "AbpNotificationSubsciptions" table or not?

  it depends on your definition of notification. e.g user creation notification should have entity id and type, and weekly summary notification most likely doesn't need to have entity info

  3. For insert operation, EntityTypeName and EntityId should be saved in "AbpTenantNotifications" table or not?

  Yes if you want the published user/tenant notification to have the context of a specific entity

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  Thank you for quick response. Now I understand all scenarios. I have one more query regarding Publish Notification.

  -It is working fine in local and server too. But in server sometimes it is sending notifications twice. 1st is with IST(local system time from where we are testing system) and 2nd is with UTC time(server time). In database also, AbpTenantNotifications table is having two rows with different CreationTime values. Can you help me in this issue?

  Code is working fine and we have not called Publish notification method twice still it is calling two times sometimes.

  Please let us know your response.

  Thanks.

  Save Cancel
• 

  0

  aaron created 5 years ago

  Support Team

  Are you running 2 instances on server?

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  No, we have only on 1 instance.

  Save Cancel
• 

  0

  ryancyq created 5 years ago

  Support Team

  Please share the code of notification publishing.

  also, what is the trigger for your notification.

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  We have added seperate Notification definitions for each Entity and created generalized Publish notification methods for all including below methods. -"CommonMethodHelper.GetNotificationNameFromEntity" will get Notification name as per given entity. -"CommonMethodHelper.GetNotificationTextLocalizationString" will get Notification text message with provided dynamic parameters -"GetEntityTypeByEntityName" will get Entity Type(Document) from given Entity name(string)

  

  Save Cancel
• 

  0

  ryancyq created 5 years ago

  Support Team

  Can you try logging it down of how many times NewEntityCreatedAsync is called when new Document entity is created.

  Your code might have been triggered multiple times thus publishing multiple times.

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  We have debugged code found that and NewEntityCreatedAsync is called only one time. Issue is, this error is not occuring always. So we are not able to track this. Still we will add logs for these methods and try once.

  Thank you

  Save Cancel
• 

  0

  ismcagdas created 5 years ago

  Support Team

  Hi @razkhan78

  Thank you for your feedback. Please reopen the issue if you can find a clue.

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  Hi @ismcagdas, We have added logs and there is only one log for "NewEntityCreatedAsync" method. We have also added logs before and after "PublishAsync" method but only one log is created.

  Please let us know how can we track this issue.

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  We are facing this issue only in our server. In Local, everything is working fine. We have hosted our application on Azure. Is there any setting that we might need to do for Notifications in Azure?

  Save Cancel
• 

  0

  ismcagdas created 5 years ago

  Support Team

  Hi @razkhan78

  Could you share the screenshot of duplicate records on the database ?

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  All fields in AbpTenantNotifications table are same except "CreationTime".

  

  Save Cancel
• 

  0

  ismcagdas created 5 years ago

  Support Team

  Hi @razkhan78

  Could you share your code with [email protected] ? We can check it for you.

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  @ismcagdas Please check this comment https://support.aspnetzero.com/QA/Questions/6390#answer-45564aa4-85ff-cb00-d268-39ebc8f5015e in same thread for code.

  Save Cancel
• 

  0

  ismcagdas created 5 years ago

  Support Team

  @razkhan78

  I have seen that code but we are not able to reproduce only using this part of the code. Because of that, I wanted to see the entire app. Otherwise, it is hard for us to help you because we are not able to reproduce it. Event you can't reproduce it on your dev environment which makes me think that the problem is related to something else than AspNet Zero.

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  /=====================AppNotificationNames.cs========================/

  /=====================.xml file========================/

  <!-- Notification Definition -->

  <text name="NewDocumentCreatedNotificationDefinition" value="On Document creation"></text>

  <!-- Notification Message -->

  <text name="NewDocumentCreatedNotificationMessage" value="New Document - New Document {documentName} type of {documentCategory} - {documentType} is created for {entity} with Expiration {ExpirationDate} by {createdByUser}"></text>

  /=====================AppNotificationProvider.cs========================/

  /* Document create */ context.Manager.Add( new NotificationDefinition( AppNotificationNames.NewDocumentCreated, displayName: L("NewDocumentCreatedNotificationDefinition"), permissionDependency: new SimplePermissionDependency(AppPermissions.Pages_Documents_Create) ) );

  /==============================NotificationAppService.cs==============================/

  public async Task<GetNotificationSettingsOutput> GetNotificationSettings() { var output = new GetNotificationSettingsOutput();

  output.ReceiveNotifications = await SettingManager.GetSettingValueAsync<bool>(NotificationSettingNames.ReceiveNotifications);            
  
  var notificationDefinitions = (await _notificationDefinitionManager.GetAllAvailableAsync(AbpSession.ToUserIdentifier()));
  
  output.Notifications = ObjectMapper.Map<List<NotificationSubscriptionWithDisplayNameDto>>(notificationDefinitions);
  
  var subscribedNotifications = (await _notificationSubscriptionManager
  	.GetSubscribedNotificationsAsync(AbpSession.ToUserIdentifier()))
  	.Select(ns => ns.NotificationName)
  	.ToList();
  
  output.Notifications.ForEach(n => n.IsSubscribed = subscribedNotifications.Contains(n.Name));
  
  return output;
  

  }

  public async Task UpdateNotificationSettings(UpdateNotificationSettingsInput input) { await SettingManager.ChangeSettingForUserAsync(AbpSession.ToUserIdentifier(), NotificationSettingNames.ReceiveNotifications, input.ReceiveNotifications.ToString());

  foreach (var notification in input.Notifications)
  {
  	if (notification.IsSubscribed)
  	{
  		await _notificationSubscriptionManager.SubscribeAsync(AbpSession.ToUserIdentifier(), notification.Name);                    
  	}
  	else
  	{
  		await _notificationSubscriptionManager.UnsubscribeAsync(AbpSession.ToUserIdentifier(), notification.Name);
  	}
  }
  

  }

  /==============================documentAppservice.cs==============================/

  [AbpAuthorize(AppPermissions.Pages_Documents_Create)] private async Task<CreateOrEditDocumentDto> Create(CreateOrEditDocumentDto input) { var document = ObjectMapper.Map<Document>(input); await _documentRepository.InsertAsync(document); await UnitOfWorkManager.Current.SaveChangesAsync();

   var createOrEditDocumentDto = ObjectMapper.Map<CreateOrEditDocumentDto>(document);
  
   /*Send Document Created Notification to all subscribed users*/
   await _appNotifier.NewDocumentCreatedAsync(await GetCurrentUserAsync(), GetDtoForDocumentCreatedNotification(EntityTypeEnums.Document,createOrEditDocumentDto, documentTypedata.Name));
  

  }

  /==============================AppNotifier.cs==============================/

  /Send Notification for Document Create event/ public async Task NewDocumentCreatedAsync(User createdByUser, NotificationForNewDocumentCreatedDto notificationForNewDocumentCreatedDto) { try { /Set Notification data for dynamic localization string and set parameters for Notification message text/ var notificationData = new LocalizableMessageNotificationData( new LocalizableString( "NewDocumentCreatedNotificationMessage", LoadStopConsts.LocalizationSourceName ) );

  	notificationData["documentName"] = notificationForNewDocumentCreatedDto.CreateOrEditDocumentDto.Name;		
  	notificationData["createdByUser"] = createdByUser.FullName;
  
  	//Write logs
  	Logger.Info("New document Publish Notification Start: " + notificationForNewDocumentCreatedDto.CreateOrEditDocumentDto.Name);
  
  	await _notificationPublisher.PublishAsync(AppNotificationNames.NewDocumentCreated, notificationData, null,
  		NotificationSeverity.Info, null, excludedUserIds: new[] { createdByUser.ToUserIdentifier() });
  
  	Logger.Info("New document Publish Notification End: " + notificationForNewDocumentCreatedDto.CreateOrEditDocumentDto.Name);
  
  }
  catch (Exception ex)
  {
  	var errorMessage = ex.Message;
  }
  

  }

  Save Cancel
• 

  0

  razkhan78 created 5 years ago

  @ismcagdas

  If you are not able to reproduce issue then can you try by hosting your test application on Azure server? as we are facing issue only on live server.

  Save Cancel
• 

  0

  ismcagdas created 5 years ago

  Support Team

  @razkhan78

  It is hard for us to setup such an environment and try to reproduce this error. Instead, we can try to connect your PC and check your code and azure configuration, what do you think about it ?

  Save Cancel