feat:update event (#719)

* fix:优化

* 1

* feat:add Aggregate root object creation, modification, and deletion events

* feat:optimization topic default value

* feat:init event

* feat:test bulkevent

* feat:update BulkMarkEventAsInProgress

* fix:IntegrationEvents.Tests.Infrastructure.CustomIntegrationEventLogService

* fix:resolve conflicts

* feat:remove test api

* fix:DefaultUserContext

* fix:optimization

* fix:取消集成事件默认Topic,可能引起命名冲突优化

* fix:remove backup.csproj

* fix:TestEntityCreatedEventAsync

Author: duiapro

src/BuildingBlocks/Authentication/OpenIdConnect/Masa.BuildingBlocks.Authentication.OpenIdConnect.Domain/Masa - Backup.BuildingBlocks.Authentication.OpenIdConnect.Domain.csproj

@@ -1,4 +1,4 @@
-// Copyright (c) MASA Stack All rights reserved.
+// Copyright (c) MASA Stack All rights reserved.
 // Licensed under the MIT License. See LICENSE.txt in the project root for license information.
 
 namespace Masa.BuildingBlocks.Ddd.Domain.Tests;

src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain.Tests/EventTest.cs

@@ -0,0 +1,15 @@
+// Copyright (c) MASA Stack All rights reserved.
+// Licensed under the MIT License. See LICENSE.txt in the project root for license information.
+
+namespace Masa.BuildingBlocks.Ddd.Domain.Events
+{
+    public abstract record class EntityChangedEvent<TEntity> : DomainCommand
+    {
+        public TEntity Entity { get; set; }
+
+        public EntityChangedEvent(TEntity entity)
+        {
+            Entity = entity;
+        }
+    }
+}

src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain/Events/EntityChangedEvent.cs

@@ -0,0 +1,12 @@
+// Copyright (c) MASA Stack All rights reserved.
+// Licensed under the MIT License. See LICENSE.txt in the project root for license information.
+
+namespace Masa.BuildingBlocks.Ddd.Domain.Events
+{
+    public record class EntityCreatedDomainEvent<TEntity> : EntityChangedEvent<TEntity>
+    {
+        public EntityCreatedDomainEvent(TEntity entity) : base(entity)
+        {
+        }
+    }
+}

src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain/Events/EntityCreatedDomainEvent.cs

@@ -0,0 +1,12 @@
+// Copyright (c) MASA Stack All rights reserved.
+// Licensed under the MIT License. See LICENSE.txt in the project root for license information.
+
+namespace Masa.BuildingBlocks.Ddd.Domain.Events
+{
+    public record class EntityDeletedDomainEvent<TEntity> : EntityChangedEvent<TEntity>
+    {
+        public EntityDeletedDomainEvent(TEntity entity) : base(entity)
+        {
+        }
+    }
+}

src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain/Events/EntityDeletedDomainEvent.cs

@@ -0,0 +1,12 @@
+// Copyright (c) MASA Stack All rights reserved.
+// Licensed under the MIT License. See LICENSE.txt in the project root for license information.
+
+namespace Masa.BuildingBlocks.Ddd.Domain.Events
+{
+    public record class EntityModifiedDomainEvent<TEntity> : EntityChangedEvent<TEntity>
+    {
+        public EntityModifiedDomainEvent(TEntity entity) : base(entity)
+        {
+        }
+    }
+}

src/BuildingBlocks/Ddd/Domain/Masa.BuildingBlocks.Ddd.Domain/Events/EntityModifiedDomainEvent.cs

@@ -5,12 +5,12 @@ namespace Masa.BuildingBlocks.Dispatcher.IntegrationEvents;
 
 public abstract record IntegrationEvent : IIntegrationEvent
 {
-    [JsonInclude]public Guid EventId { private get; set; }
+    [JsonInclude] public Guid EventId { private get; set; }
 
     [JsonInclude]
     public DateTime EvenCreateTime { private get; set; }
 
-    [NotMapped] [JsonIgnore] public IUnitOfWork? UnitOfWork { get; set; }
+    [NotMapped][JsonIgnore] public IUnitOfWork? UnitOfWork { get; set; }
 
     public virtual string Topic { get; set; }
 

src/BuildingBlocks/Development/Masa.BuildingBlocks.Development.DaprStarter/Masa - Backup.BuildingBlocks.Development.DaprStarters.csproj

@@ -37,10 +37,16 @@ Task SaveEventAsync(
 
     Task MarkEventAsPublishedAsync(Guid eventId, CancellationToken cancellationToken = default);
 
+    Task<List<Guid>> BulkMarkEventAsPublishedAsync(IEnumerable<Guid> eventIds, CancellationToken cancellationToken = default);
+
     Task MarkEventAsInProgressAsync(Guid eventId, int minimumRetryInterval, CancellationToken cancellationToken = default);
 
+    Task<List<Guid>> BulkMarkEventAsInProgressAsync(IEnumerable<Guid> eventIds, int minimumRetryInterval, CancellationToken cancellationToken = default);
+
     Task MarkEventAsFailedAsync(Guid eventId, CancellationToken cancellationToken = default);
 
+    Task<List<Guid>> BulkMarkEventAsFailedAsync(IEnumerable<Guid> eventIds, CancellationToken cancellationToken = default);
+
     /// <summary>
     /// Delete successfully published and expired data
     /// </summary>

src/BuildingBlocks/Dispatcher/Masa.BuildingBlocks.Dispatcher.IntegrationEvents/IntegrationEvent.cs

@@ -1,6 +1,8 @@
-// Copyright (c) MASA Stack All rights reserved.
+// Copyright (c) MASA Stack All rights reserved.
 // Licensed under the MIT License. See LICENSE.txt in the project root for license information.
 
+using Microsoft.Extensions.Logging;
+
 namespace Masa.BuildingBlocks.Exceptions.Tests;
 
 [TestClass]