Added CQRS

Author: Amitpnk

OnionArchitecture/OA.Data/ApplicationContext.cs renamed to OnionArchitecture/OA.Data/ApplicationDbContext.cs

@@ -4,14 +4,14 @@
 
 namespace OA.Data
 {
-    public class ApplicationContext : DbContext, IApplicationContext
+    public class ApplicationDbContext : DbContext, IApplicationDbContext
     {
         // This constructor is used of runit testing
-        public ApplicationContext()
+        public ApplicationDbContext()
         {
 
         }
-        public ApplicationContext(DbContextOptions options) : base(options)
+        public ApplicationDbContext(DbContextOptions options) : base(options)
         {
             ChangeTracker.QueryTrackingBehavior = QueryTrackingBehavior.NoTracking;
         }

OnionArchitecture/OA.Data/IApplicationContext.cs renamed to OnionArchitecture/OA.Data/IApplicationDbContext.cs

@@ -4,7 +4,7 @@
 
 namespace OA.Data
 {
-    public interface IApplicationContext
+    public interface IApplicationDbContext
     {
         DbSet<Category> Categories { get; set; }
         DbSet<Customer> Customers { get; set; }

OnionArchitecture/OA.Data/Migrations/20200627044955_Initial-setup.Designer.cs

@@ -8,7 +8,7 @@
 
 namespace OA.Data.Migrations
 {
-    [DbContext(typeof(ApplicationContext))]
+    [DbContext(typeof(ApplicationDbContext))]
     partial class CustomerContextModelSnapshot : ModelSnapshot
     {
         protected override void BuildModel(ModelBuilder modelBuilder)

OnionArchitecture/OA.Data/Migrations/CustomerContextModelSnapshot.cs

@@ -21,7 +21,7 @@ public static class ConfigureServiceContainer
         public static void AddDbContext(this IServiceCollection serviceCollection,
              IConfiguration configuration, IConfigurationRoot configRoot)
         {
-            serviceCollection.AddDbContext<ApplicationContext>(options =>
+            serviceCollection.AddDbContext<ApplicationDbContext>(options =>
                    options.UseSqlServer(configuration.GetConnectionString("OnionArchConn") ?? configRoot["ConnectionStrings:OnionArchConn"])
                 );
         }
@@ -44,7 +44,7 @@ public static void AddRepository(this IServiceCollection serviceCollection)
 
         public static void AddTransientServices(this IServiceCollection serviceCollection)
         {
-            serviceCollection.AddTransient<ICustomerService, CustomerService>();
+            //serviceCollection.AddTransient<ICustomerService, CustomerService>();
             serviceCollection.AddTransient<IMailService, MailService>();
         }
 

OnionArchitecture/OA.Infrastructure/Extension/ConfigureServiceContainer.cs

@@ -10,8 +10,8 @@ namespace OA.Persistence.Repository
 {
     public class CustomerRepository : ICustomerRepository
     {
-        private readonly ApplicationContext _context;
-        public CustomerRepository(ApplicationContext context)
+        private readonly ApplicationDbContext _context;
+        public CustomerRepository(ApplicationDbContext context)
         {
             _context = context;
         }

OnionArchitecture/OA.Persistence/Repository/CustomerRepository.cs

@@ -9,9 +9,9 @@ namespace OA.Persistence.Repository
     public class GenericRepository<T> : IGenericRepository<T> where T : class
     {
         private readonly DbSet<T> entities;
-        private readonly ApplicationContext _context;
+        private readonly ApplicationDbContext _context;
 
-        public GenericRepository(ApplicationContext context)
+        public GenericRepository(ApplicationDbContext context)
         {
             _context = context;
             entities = _context.Set<T>();

OnionArchitecture/OA.Persistence/Repository/GenericRepository.cs

@@ -0,0 +1,19 @@
+using MediatR;
+using Microsoft.Extensions.DependencyInjection;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Reflection;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OA.Service
+{
+    public static class DependencyInjection
+    {
+        public static void AddApplication(this IServiceCollection services)
+        {
+            services.AddMediatR(Assembly.GetExecutingAssembly());
+        }
+    }
+}

OnionArchitecture/OA.Service/Contract/ICustomerService.cs

@@ -0,0 +1,44 @@
+ 
+using MediatR;
+using OA.Data;
+using OA.Domain.Entities;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Application.Features.ProductFeatures.Commands
+{
+    public class CreateCustomerCommand : IRequest<int>
+    {
+        public string CustomerName { get; set; }
+        public string ContactName { get; set; }
+        public string ContactTitle { get; set; }
+        public string Address { get; set; }
+        public string City { get; set; }
+        public string Region { get; set; }
+        public string PostalCode { get; set; }
+        public string Country { get; set; }
+        public string Phone { get; set; }
+        public string Fax { get; set; }
+        public class CreateProductCommandHandler : IRequestHandler<CreateCustomerCommand, int>
+        {
+            private readonly IApplicationDbContext _context;
+            public CreateProductCommandHandler(IApplicationDbContext context)
+            {
+                _context = context;
+            }
+            public async Task<int> Handle(CreateCustomerCommand request, CancellationToken cancellationToken)
+            {
+                var customer = new Customer();
+                customer.CustomerName = request.CustomerName;
+                customer.ContactName = request.ContactName;
+               
+                _context.Customers.Add(customer);
+                await _context.SaveChangesAsync();
+                return customer.Id;
+            }
+        }
+    }
+}