Added Product, ProductManager and tests.

samples/MicroserviceDemo/modules/product/src/ProductManagement.Domain.Shared/ProductManagement/ProductConsts.cs

@@ -0,0 +1,9 @@
+namespace ProductManagement
+{
+    public static class ProductConsts
+    {
+        public const int MaxCodeLength = 32;
+
+        public const int MaxNameLength = 256;
+    }
+}

samples/MicroserviceDemo/modules/product/src/ProductManagement.Domain/ProductManagement.Domain.csproj

@@ -8,14 +8,15 @@
   <ItemGroup>
     <ProjectReference Include="..\ProductManagement.Domain.Shared\ProductManagement.Domain.Shared.csproj" />
     <PackageReference Include="Volo.Abp.Ddd.Domain" Version="0.12.0" />
+    <PackageReference Include="Volo.Abp.EntityFrameworkCore" Version="0.12.0" />
   </ItemGroup>
 
   <ItemGroup>
-    <EmbeddedResource Include="MyCompanyName\ProductManagement\Localization\Domain\*.json" />
+    <EmbeddedResource Include="ProductManagement\Localization\Domain\*.json" />
   </ItemGroup>
 
   <ItemGroup>
-    <Content Remove="MyCompanyName\ProductManagement\Localization\Domain\*.json" />
+    <Content Remove="ProductManagement\Localization\Domain\*.json" />
   </ItemGroup>
 
 </Project>

samples/MicroserviceDemo/modules/product/src/ProductManagement.Domain/ProductManagement/Product.cs

@@ -0,0 +1,101 @@
+using System;
+using JetBrains.Annotations;
+using Volo.Abp;
+using Volo.Abp.Domain.Entities.Auditing;
+
+namespace ProductManagement
+{
+    public class Product : AuditedAggregateRoot<Guid>
+    {
+        /// <summary>
+        /// A unique value for this product.
+        /// ProductManager ensures the uniqueness of it.
+        /// It can not be changed after creation of the product.
+        /// </summary>
+        [NotNull]
+        public string Code { get; private set; }
+
+        [NotNull]
+        public string Name { get; private set; }
+
+        public float Price { get; private set; }
+
+        public int StockCount { get; private set; }
+
+        private Product()
+        {
+            //Default constructor is needed for ORMs.
+        }
+
+        internal Product(
+            Guid id,
+            [NotNull] string code, 
+            [NotNull] string name, 
+            float price = 0.0f, 
+            int stockCount = 0)
+        {
+            Check.NotNullOrWhiteSpace(code, nameof(code));
+
+            if (code.Length >= ProductConsts.MaxCodeLength)
+            {
+                throw new ArgumentException($"Product code can not be longer than {ProductConsts.MaxCodeLength}");
+            }
+
+            Id = id;
+            Code = code;
+            SetName(Check.NotNullOrWhiteSpace(name, nameof(name)));
+            SetPrice(price);
+            SetStockCountInternal(stockCount, triggerEvent: false);
+        }
+
+        public Product SetName([NotNull] string name)
+        {
+            Check.NotNullOrWhiteSpace(name, nameof(name));
+
+            if (name.Length >= ProductConsts.MaxNameLength)
+            {
+                throw new ArgumentException($"Product name can not be longer than {ProductConsts.MaxNameLength}");
+            }
+
+            Name = name;
+            return this;
+        }
+
+        public Product SetPrice(float price)
+        {
+            if (price < 0.0f)
+            {
+                throw new ArgumentException($"{nameof(price)} can not be less than 0.0!");
+            }
+
+            Price = price;
+            return this;
+        }
+
+        public Product SetStockCount(int stockCount)
+        {
+            return SetStockCountInternal(stockCount);
+        }
+
+        private Product SetStockCountInternal(int stockCount, bool triggerEvent = true)
+        {
+            if (StockCount < 0.0f)
+            {
+                throw new ArgumentException($"{nameof(stockCount)} can not be less than 0!");
+            }
+
+            if (StockCount == stockCount)
+            {
+                return this;
+            }
+
+            if (triggerEvent)
+            {
+                AddDistributedEvent(new ProductStockCountChangedEto(StockCount, stockCount));
+            }
+
+            StockCount = stockCount;
+            return this;
+        }
+    }
+}

samples/MicroserviceDemo/modules/product/src/ProductManagement.Domain/ProductManagement/ProductCodeAlreadyExistsException.cs

@@ -0,0 +1,13 @@
+using Volo.Abp;
+
+namespace ProductManagement
+{
+    public class ProductCodeAlreadyExistsException : BusinessException
+    {
+        public ProductCodeAlreadyExistsException(string productCode)
+            : base("PM:000001", $"A product with code {productCode} has already exists!")
+        {
+
+        }
+    }
+}

samples/MicroserviceDemo/modules/product/src/ProductManagement.Domain/MyCompanyName/ProductManagement/ProductManagementDomainModule.cs → samples/MicroserviceDemo/modules/product/src/ProductManagement.Domain/ProductManagement/ProductManagementDomainModule.cs

@@ -1,5 +1,5 @@
-using Microsoft.Extensions.DependencyInjection;
+using ProductManagement.Localization;
-using ProductManagement.Localization;
+using Volo.Abp.EntityFrameworkCore;
 using Volo.Abp.Localization;
 using Volo.Abp.Localization.ExceptionHandling;
 using Volo.Abp.Modularity;
@@ -7,8 +7,12 @@ using Volo.Abp.VirtualFileSystem;
 
 namespace ProductManagement
 {
+    /* This module directly depends on EF Core by its design.
+     * In this way, we can directly use EF Core async LINQ extension methods.
+     */
     [DependsOn(
-        typeof(ProductManagementDomainSharedModule)
+        typeof(ProductManagementDomainSharedModule),
+        typeof(AbpEntityFrameworkCoreModule) 
         )]
     public class ProductManagementDomainModule : AbpModule
     {

samples/MicroserviceDemo/modules/product/src/ProductManagement.Domain/ProductManagement/ProductManager.cs

@@ -0,0 +1,42 @@
+using JetBrains.Annotations;
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories;
+using Volo.Abp.Domain.Services;
+
+namespace ProductManagement
+{
+    public class ProductManager : DomainService
+    {
+        private readonly IRepository<Product, Guid> _productRepository;
+
+        public ProductManager(IRepository<Product, Guid> productRepository)
+        {
+            _productRepository = productRepository;
+        }
+
+        public async Task<Product> CreateAsync(
+            [NotNull] string code,
+            [NotNull] string name,
+            float price = 0.0f,
+            int stockCount = 0)
+        {
+            var existingProduct = await _productRepository.FirstOrDefaultAsync(p => p.Code == code);
+            if (existingProduct != null)
+            {
+                throw new ProductCodeAlreadyExistsException(code);
+            }
+
+            return await _productRepository.InsertAsync(
+                new Product(
+                    GuidGenerator.Create(),
+                    code,
+                    name,
+                    price,
+                    stockCount
+                )
+            );
+        }
+    }
+}

samples/MicroserviceDemo/modules/product/src/ProductManagement.Domain/ProductManagement/ProductStockCountChangedEto.cs

@@ -0,0 +1,24 @@
+using System;
+using Volo.Abp.Domain.Entities.Events.Distributed;
+
+namespace ProductManagement
+{
+    [Serializable]
+    public class ProductStockCountChangedEto : EtoBase
+    {
+        public int OldCount { get; set; }
+
+        public int CurrentCount { get; set; }
+
+        private ProductStockCountChangedEto()
+        {
+            //Default constructor is needed for deserialization.
+        }
+
+        public ProductStockCountChangedEto(int oldCount, int currentCount)
+        {
+            OldCount = oldCount;
+            CurrentCount = currentCount;
+        }
+    }
+}

samples/MicroserviceDemo/modules/product/src/ProductManagement.EntityFrameworkCore/MyCompanyName/ProductManagement/EntityFrameworkCore/ProductManagementDbContextModelCreatingExtensions.cs

@@ -1,38 +0,0 @@
-using System;
-using Microsoft.EntityFrameworkCore;
-using Volo.Abp;
-
-namespace ProductManagement.EntityFrameworkCore
-{
-    public static class ProductManagementDbContextModelCreatingExtensions
-    {
-        public static void ConfigureProductManagement(
-            this ModelBuilder builder,
-            Action<ProductManagementModelBuilderConfigurationOptions> optionsAction = null)
-        {
-            Check.NotNull(builder, nameof(builder));
-
-            var options = new ProductManagementModelBuilderConfigurationOptions();
-
-            optionsAction?.Invoke(options);
-
-            /* Configure all entities here. Example:
-
-            builder.Entity<Question>(b =>
-            {
-                //Configure table & schema name
-                //b.ToTable(options.TablePrefix + "Questions", options.Schema);
-                
-                //Properties
-                //b.Property(q => q.Title).IsRequired().HasMaxLength(QuestionConsts.MaxTitleLength);
-                
-                //Configure relations
-                //b.HasMany(question => question.Tags).WithOne().HasForeignKey(qt => qt.QuestionId);
-
-                //Configure indexes
-                //b.HasIndex(q => q.CreationTime);
-            });
-            */
-        }
-    }
-}

samples/MicroserviceDemo/modules/product/src/ProductManagement.EntityFrameworkCore/MyCompanyName/ProductManagement/EntityFrameworkCore/IProductManagementDbContext.cs → samples/MicroserviceDemo/modules/product/src/ProductManagement.EntityFrameworkCore/ProductManagement/EntityFrameworkCore/IProductManagementDbContext.cs

@@ -1,4 +1,5 @@
-using Volo.Abp.Data;
+using Microsoft.EntityFrameworkCore;
+using Volo.Abp.Data;
 using Volo.Abp.EntityFrameworkCore;
 
 namespace ProductManagement.EntityFrameworkCore
@@ -6,8 +7,6 @@ namespace ProductManagement.EntityFrameworkCore
     [ConnectionStringName("ProductManagement")]
     public interface IProductManagementDbContext : IEfCoreDbContext
     {
-        /* Add DbSet for each Aggregate Root here. Example:
+         DbSet<Product> Products { get; }
-         * DbSet<Question> Questions { get; }
-         */
     }
 }

samples/MicroserviceDemo/modules/product/src/ProductManagement.EntityFrameworkCore/MyCompanyName/ProductManagement/EntityFrameworkCore/ProductManagementDbContext.cs → samples/MicroserviceDemo/modules/product/src/ProductManagement.EntityFrameworkCore/ProductManagement/EntityFrameworkCore/ProductManagementDbContext.cs

@@ -11,9 +11,7 @@ namespace ProductManagement.EntityFrameworkCore
 
         public static string Schema { get; set; } = ProductManagementConsts.DefaultDbSchema;
 
-        /* Add DbSet for each Aggregate Root here. Example:
+        public DbSet<Product> Products { get; set; }
-         * public DbSet<Question> Questions { get; set; }
-         */
 
         public ProductManagementDbContext(DbContextOptions<ProductManagementDbContext> options) 
             : base(options)
@@ -31,5 +29,6 @@ namespace ProductManagement.EntityFrameworkCore
                 options.Schema = Schema;
             });
         }
+
     }
 }

samples/MicroserviceDemo/modules/product/src/ProductManagement.EntityFrameworkCore/ProductManagement/EntityFrameworkCore/ProductManagementDbContextModelCreatingExtensions.cs

@@ -0,0 +1,34 @@
+using System;
+using Microsoft.EntityFrameworkCore;
+using Volo.Abp;
+using Volo.Abp.EntityFrameworkCore.Modeling;
+
+namespace ProductManagement.EntityFrameworkCore
+{
+    public static class ProductManagementDbContextModelCreatingExtensions
+    {
+        public static void ConfigureProductManagement(
+            this ModelBuilder builder,
+            Action<ProductManagementModelBuilderConfigurationOptions> optionsAction = null)
+        {
+            Check.NotNull(builder, nameof(builder));
+
+            var options = new ProductManagementModelBuilderConfigurationOptions();
+
+            optionsAction?.Invoke(options);
+            
+            builder.Entity<Product>(b =>
+            {
+                b.ToTable(options.TablePrefix + "Products", options.Schema);
+
+                b.ConfigureAudited();
+
+                b.Property(x => x.Code).IsRequired().HasMaxLength(ProductConsts.MaxCodeLength);
+                b.Property(x => x.Name).IsRequired().HasMaxLength(ProductConsts.MaxNameLength);
+
+                b.HasIndex(q => q.Code);
+                b.HasIndex(q => q.Name);
+            });
+        }
+    }
+}

samples/MicroserviceDemo/modules/product/src/ProductManagement.EntityFrameworkCore/MyCompanyName/ProductManagement/EntityFrameworkCore/ProductManagementEntityFrameworkCoreModule.cs → samples/MicroserviceDemo/modules/product/src/ProductManagement.EntityFrameworkCore/ProductManagement/EntityFrameworkCore/ProductManagementEntityFrameworkCoreModule.cs

@@ -14,9 +14,7 @@ namespace ProductManagement.EntityFrameworkCore
         {
             context.Services.AddAbpDbContext<ProductManagementDbContext>(options =>
             {
-                /* Add custom repositories here. Example:
+                options.AddDefaultRepositories();
-                 * options.AddRepository<Question, EfCoreQuestionRepository>();
-                 */
             });
         }
     }

samples/MicroserviceDemo/modules/product/src/ProductManagement.Web/ProductManagement.Web.csproj

@@ -9,15 +9,17 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <EmbeddedResource Include="wwwroot\**\*.*" />
     <EmbeddedResource Include="Pages\**\*.cshtml" Exclude="*.cs" />
     <EmbeddedResource Include="Localization\Resources\**\*.json" />
   </ItemGroup>
 
   <ItemGroup>
-    <Content Remove="wwwroot\**\*.*" />
+    <Compile Remove="wwwroot\**" />
     <Content Remove="Pages\**\*.cshtml" />
     <Content Remove="Localization\Resources\**\*.json" />
+    <Content Remove="wwwroot\**" />
+    <EmbeddedResource Remove="wwwroot\**" />
+    <None Remove="wwwroot\**" />
     <Content Remove="Properties\launchSettings.json" />
     <None Include="Properties\launchSettings.json" />
   </ItemGroup>
@@ -28,8 +30,4 @@
     <PackageReference Include="Volo.Abp.AspNetCore.Mvc.UI.Theme.Shared" Version="0.12.0" />
   </ItemGroup>
 
-  <ItemGroup>
-    <Folder Include="wwwroot\" />
-  </ItemGroup>
-
 </Project>

samples/MicroserviceDemo/modules/product/test/ProductManagement.Domain.Tests/MyCompanyName/ProductManagement/ProductManagementDomainTestBase.cs

@@ -1,7 +0,0 @@
-namespace ProductManagement
-{
-    public abstract class ProductManagementDomainTestBase : ProductManagementTestBase<ProductManagementDomainTestModule>
-    {
-
-    }
-}

samples/MicroserviceDemo/modules/product/test/ProductManagement.Domain.Tests/ProductManagement/ProductManagementDomainTestBase.cs

@@ -0,0 +1,94 @@
+using System;
+using System.Threading.Tasks;
+using Microsoft.Extensions.DependencyInjection;
+using Volo.Abp.Uow;
+
+namespace ProductManagement
+{
+    public abstract class ProductManagementDomainTestBase : ProductManagementTestBase<ProductManagementDomainTestModule>
+    {
+        #region WithUnitOfWork
+
+        protected virtual void WithUnitOfWork(Action action)
+        {
+            WithUnitOfWork(new UnitOfWorkOptions(), action);
+        }
+
+        protected virtual void WithUnitOfWork(UnitOfWorkOptions options, Action action)
+        {
+            using (var scope = ServiceProvider.CreateScope())
+            {
+                var uowManager = scope.ServiceProvider.GetRequiredService<IUnitOfWorkManager>();
+
+                using (var uow = uowManager.Begin(options))
+                {
+                    action();
+
+                    uow.Complete();
+                }
+            }
+        }
+
+        protected virtual Task WithUnitOfWorkAsync(Func<Task> func)
+        {
+            return WithUnitOfWorkAsync(new UnitOfWorkOptions(), func);
+        }
+
+        protected virtual async Task WithUnitOfWorkAsync(UnitOfWorkOptions options, Func<Task> action)
+        {
+            using (var scope = ServiceProvider.CreateScope())
+            {
+                var uowManager = scope.ServiceProvider.GetRequiredService<IUnitOfWorkManager>();
+
+                using (var uow = uowManager.Begin(options))
+                {
+                    await action();
+
+                    await uow.CompleteAsync();
+                }
+            }
+        }
+
+        protected virtual TResult WithUnitOfWork<TResult>(Func<TResult> func)
+        {
+            return WithUnitOfWork(new UnitOfWorkOptions(), func);
+        }
+
+        protected virtual TResult WithUnitOfWork<TResult>(UnitOfWorkOptions options, Func<TResult> func)
+        {
+            using (var scope = ServiceProvider.CreateScope())
+            {
+                var uowManager = scope.ServiceProvider.GetRequiredService<IUnitOfWorkManager>();
+
+                using (var uow = uowManager.Begin(options))
+                {
+                    var result = func();
+                    uow.Complete();
+                    return result;
+                }
+            }
+        }
+
+        protected virtual Task<TResult> WithUnitOfWorkAsync<TResult>(Func<Task<TResult>> func)
+        {
+            return WithUnitOfWorkAsync(new UnitOfWorkOptions(), func);
+        }
+
+        protected virtual async Task<TResult> WithUnitOfWorkAsync<TResult>(UnitOfWorkOptions options, Func<Task<TResult>> func)
+        {
+            using (var scope = ServiceProvider.CreateScope())
+            {
+                var uowManager = scope.ServiceProvider.GetRequiredService<IUnitOfWorkManager>();
+
+                using (var uow = uowManager.Begin(options))
+                {
+                    var result = await func();
+                    await uow.CompleteAsync();
+                    return result;
+                }
+            }
+        }
+
+        #endregion
+    }
+}

samples/MicroserviceDemo/modules/product/test/ProductManagement.Domain.Tests/ProductManagement/ProductManager_Tests.cs

@@ -0,0 +1,34 @@
+using System.Threading.Tasks;
+using Shouldly;
+using Xunit;
+
+namespace ProductManagement
+{
+    public class ProductManager_Tests : ProductManagementDomainTestBase
+    {
+        private readonly ProductManager _productManager;
+
+        public ProductManager_Tests()
+        {
+            _productManager = GetRequiredService<ProductManager>();
+        }
+
+        [Fact]
+        public async Task Should_Create_A_Valid_Product()
+        {
+            //Act
+            var product = await WithUnitOfWorkAsync(
+                async () =>
+                {
+                    return await _productManager.CreateAsync("P000837212", "My Product 837212", stockCount: 42);
+                }
+            );
+
+            //Assert
+            product.Code.ShouldBe("P000837212");
+            product.Name.ShouldBe("My Product 837212");
+            product.Price.ShouldBe(0.0f);
+            product.StockCount.ShouldBe(42);
+        }
+    }
+}

samples/MicroserviceDemo/modules/product/test/ProductManagement.EntityFrameworkCore.Tests/MyCompanyName/ProductManagement/EntityFrameworkCore/MyEntityRepository_Tests.cs

@@ -1,7 +0,0 @@
-namespace ProductManagement.EntityFrameworkCore
-{
-    public class MyEntityRepository_Tests : MyEntityRepository_Tests<ProductManagementEntityFrameworkCoreTestModule>
-    {
-
-    }
-}

samples/MicroserviceDemo/modules/product/test/ProductManagement.EntityFrameworkCore.Tests/MyCompanyName/ProductManagement/EntityFrameworkCore/ProductManagementEntityFrameworkCoreTestModule.cs → samples/MicroserviceDemo/modules/product/test/ProductManagement.EntityFrameworkCore.Tests/ProductManagement/EntityFrameworkCore/ProductManagementEntityFrameworkCoreTestModule.cs

@@ -2,7 +2,6 @@
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Infrastructure;
 using Microsoft.EntityFrameworkCore.Storage;
-using Microsoft.Extensions.DependencyInjection;
 using Volo.Abp.EntityFrameworkCore;
 using Volo.Abp.Modularity;
 

samples/MicroserviceDemo/modules/product/test/ProductManagement.TestBase/MyCompanyName/ProductManagement/MyEntityRepository_Tests.cs

@@ -1,16 +0,0 @@
-using System.Threading.Tasks;
-using Volo.Abp.Modularity;
-using Xunit;
-
-namespace ProductManagement
-{
-    public abstract class MyEntityRepository_Tests<TStartupModule> : ProductManagementTestBase<TStartupModule>
-        where TStartupModule : IAbpModule
-    {
-        [Fact]
-        public async Task Test1()
-        {
-
-        }
-    }
-}