ProcessAsync(string message)
+ {
+ return await Task.FromResult(true);
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Pages/Error.cshtml b/CQRS_Simple.API/Pages/Error.cshtml
new file mode 100644
index 0000000..6f92b95
--- /dev/null
+++ b/CQRS_Simple.API/Pages/Error.cshtml
@@ -0,0 +1,26 @@
+@page
+@model ErrorModel
+@{
+ ViewData["Title"] = "Error";
+}
+
+Error.
+An error occurred while processing your request.
+
+@if (Model.ShowRequestId)
+{
+
+ Request ID: @Model.RequestId
+
+}
+
+Development Mode
+
+ Swapping to the Development environment displays detailed information about the error that occurred.
+
+
+ The Development environment shouldn't be enabled for deployed applications.
+ It can result in displaying sensitive information from exceptions to end users.
+ For local debugging, enable the Development environment by setting the ASPNETCORE_ENVIRONMENT environment variable to Development
+ and restarting the app.
+
diff --git a/CQRS_Simple.API/Pages/Error.cshtml.cs b/CQRS_Simple.API/Pages/Error.cshtml.cs
new file mode 100644
index 0000000..e3f3ef7
--- /dev/null
+++ b/CQRS_Simple.API/Pages/Error.cshtml.cs
@@ -0,0 +1,31 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Mvc.RazorPages;
+using Microsoft.Extensions.Logging;
+
+namespace CQRS_Simple.Pages
+{
+ [ResponseCache(Duration = 0, Location = ResponseCacheLocation.None, NoStore = true)]
+ public class ErrorModel : PageModel
+ {
+ private readonly ILogger _logger;
+
+ public ErrorModel(ILogger logger)
+ {
+ _logger = logger;
+ }
+
+ public string RequestId { get; set; }
+
+ public bool ShowRequestId => !string.IsNullOrEmpty(RequestId);
+
+ public void OnGet()
+ {
+ RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
+ }
+ }
+}
diff --git a/CQRS_Simple.API/Pages/_ViewImports.cshtml b/CQRS_Simple.API/Pages/_ViewImports.cshtml
new file mode 100644
index 0000000..c3a0c76
--- /dev/null
+++ b/CQRS_Simple.API/Pages/_ViewImports.cshtml
@@ -0,0 +1,3 @@
+@using CQRS_Simple
+@namespace CQRS_Simple.Pages
+@addTagHelper *, Microsoft.AspNetCore.Mvc.TagHelpers
diff --git a/CQRS_Simple.API/PipelineBehaviors/ValidationBehavior.cs b/CQRS_Simple.API/PipelineBehaviors/ValidationBehavior.cs
new file mode 100644
index 0000000..277a51b
--- /dev/null
+++ b/CQRS_Simple.API/PipelineBehaviors/ValidationBehavior.cs
@@ -0,0 +1,37 @@
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using FluentValidation;
+using MediatR;
+
+namespace CQRS_Simple.API.PipelineBehaviors
+{
+ public class ValidationBehavior : IPipelineBehavior
+ where TRequest : IRequest
+ {
+ public readonly IEnumerable> _validators;
+
+ public ValidationBehavior(IEnumerable> validators)
+ {
+ _validators = validators;
+ }
+
+ public Task Handle(TRequest request, CancellationToken cancellationToken, RequestHandlerDelegate next)
+ {
+ var context = new ValidationContext(request);
+ var failures = _validators
+ .Select(v => v.Validate(context))
+ .SelectMany(result => result.Errors)
+ .Where(f => f != null)
+ .ToList();
+
+ if (failures.Count != 0)
+ {
+ throw new ValidationException(failures);
+ }
+
+ return next();
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Commands/CreateProductCommand.cs b/CQRS_Simple.API/Products/Commands/CreateProductCommand.cs
new file mode 100644
index 0000000..c8379e4
--- /dev/null
+++ b/CQRS_Simple.API/Products/Commands/CreateProductCommand.cs
@@ -0,0 +1,53 @@
+using System.Threading;
+using System.Threading.Tasks;
+using CQRS_Simple.API.Products.Handlers;
+using CQRS_Simple.Domain.Products;
+using CQRS_Simple.Infrastructure.Dapper;
+using CQRS_Simple.Infrastructure.MQ;
+using CQRS_Simple.Infrastructure.Uow;
+using FluentValidation;
+using MediatR;
+
+namespace CQRS_Simple.API.Products.Commands
+{
+ public class CreateProductCommandValidate : AbstractValidator
+ {
+ public CreateProductCommandValidate()
+ {
+ RuleFor(x => x.Product.Code).Length(10, 256);
+ }
+ }
+
+
+ public class CreateProductCommand : IRequest
+ {
+ public Product Product { get; set; }
+
+ public CreateProductCommand(Product product)
+ {
+ Product = product;
+ }
+
+ public class CreateProductHandle : IRequestHandler
+ {
+ //private readonly IDapperRepository _dapperRepository;
+ private readonly IRepository _repository;
+ private readonly RabbitMQClient _mq;
+
+ public CreateProductHandle(RabbitMQClient mq, IRepository repository)
+ {
+ _mq = mq;
+ _repository = repository;
+ }
+
+ public async Task Handle(CreateProductCommand request, CancellationToken cancellationToken)
+ {
+ _repository.Add(request.Product);
+ var result = 1;
+ _mq.PushMessage(new RabbitData(typeof(CreateProductCommand), request, result));
+
+ return result;
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Commands/DeleteProductCommand.cs b/CQRS_Simple.API/Products/Commands/DeleteProductCommand.cs
new file mode 100644
index 0000000..bb44f2a
--- /dev/null
+++ b/CQRS_Simple.API/Products/Commands/DeleteProductCommand.cs
@@ -0,0 +1,11 @@
+using MediatR;
+
+namespace CQRS_Simple.API.Products.Commands
+{
+ public class DeleteProductCommand : IRequest
+ {
+ public int ProductId { get; set; }
+
+ public DeleteProductCommand(in int id) { ProductId = id; }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Commands/UpdateProductCommand.cs b/CQRS_Simple.API/Products/Commands/UpdateProductCommand.cs
new file mode 100644
index 0000000..6840670
--- /dev/null
+++ b/CQRS_Simple.API/Products/Commands/UpdateProductCommand.cs
@@ -0,0 +1,11 @@
+using CQRS_Simple.Domain.Products;
+using MediatR;
+
+namespace CQRS_Simple.API.Products.Commands
+{
+ public class UpdateProductCommand : IRequest
+ {
+ public Product Product { get; set; }
+ public UpdateProductCommand(Product product) { Product = product; }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Dtos/ProductDto.cs b/CQRS_Simple.API/Products/Dtos/ProductDto.cs
new file mode 100644
index 0000000..b8de415
--- /dev/null
+++ b/CQRS_Simple.API/Products/Dtos/ProductDto.cs
@@ -0,0 +1,16 @@
+using CQRS_Simple.Domain.Products;
+
+namespace CQRS_Simple.API.Products.Dtos
+{
+ ///
+ ///
+ ///
+ public class ProductDto
+ {
+ public int Id { get; set; }
+ public string Name { get; set; }
+ public string Code { get; set; }
+
+ public string Description { get; set; }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Handlers/DeleteProductHandle.cs b/CQRS_Simple.API/Products/Handlers/DeleteProductHandle.cs
new file mode 100644
index 0000000..3de0e82
--- /dev/null
+++ b/CQRS_Simple.API/Products/Handlers/DeleteProductHandle.cs
@@ -0,0 +1,30 @@
+using System.Threading;
+using System.Threading.Tasks;
+using CQRS_Simple.API.Products.Commands;
+using CQRS_Simple.Domain.Products;
+using CQRS_Simple.Infrastructure.Dapper;
+using CQRS_Simple.Infrastructure.MQ;
+using MediatR;
+
+namespace CQRS_Simple.API.Products.Handlers
+{
+ public class DeleteProductHandle : IRequestHandler
+ {
+ private readonly IDapperRepository _dapperRepository;
+ private readonly RabbitMQClient _mq;
+
+ public DeleteProductHandle(IDapperRepository dapperRepository, RabbitMQClient mq)
+ {
+ _dapperRepository = dapperRepository;
+ _mq = mq;
+ }
+
+ public async Task Handle(DeleteProductCommand request, CancellationToken cancellationToken)
+ {
+ var result = await _dapperRepository.RemoveAsync(new Product() { Id = request.ProductId });
+ if (result > 0)
+ _mq.PushMessage(new RabbitData(typeof(DeleteProductCommand), request));
+ return result;
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Handlers/GetProductHandle.cs b/CQRS_Simple.API/Products/Handlers/GetProductHandle.cs
new file mode 100644
index 0000000..35d7787
--- /dev/null
+++ b/CQRS_Simple.API/Products/Handlers/GetProductHandle.cs
@@ -0,0 +1,54 @@
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Autofac;
+using AutoMapper;
+using CQRS_Simple.API.Products.Dtos;
+using CQRS_Simple.API.Products.Queries;
+using CQRS_Simple.Domain.Products;
+using CQRS_Simple.Infrastructure.Uow;
+using MediatR;
+
+namespace CQRS_Simple.API.Products.Handlers
+{
+ public class GetProductsQueryHandle : IRequestHandler,
+ IRequestHandler>
+ {
+ // private readonly IDapperRepository _dapperRepository;
+ private readonly IRepository _dapperRepository;
+ private readonly IMapper _mapper;
+ private readonly ILifetimeScope _container;
+
+ public GetProductsQueryHandle(IRepository dapperRepository,
+ IMapper mapper,
+ ILifetimeScope container
+ )
+ {
+ _dapperRepository = dapperRepository;
+ _mapper = mapper;
+ _container = container;
+ }
+
+ public virtual async Task Handle(GetProductByIdQuery request, CancellationToken cancellationToken)
+ {
+ var result = await _dapperRepository.GetByIdAsync(request.ProductId);
+
+ var repository = _container.Resolve>();
+ // var _repository = _iocManager.GetInstance>();
+
+ repository.UnitOfWork.PrintKey();
+
+ var s = await repository.GetByIdAsync(request.ProductId);
+ s.Name += "2";
+
+ return result == null ? null : _mapper.Map(result);
+ }
+
+ public async Task> Handle(GetProductsQuery request, CancellationToken cancellationToken)
+ {
+ var result = await _dapperRepository.GetAllAsync();
+
+ return result == null ? new List() : _mapper.Map>(result);
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Handlers/UpdateProductHandle.cs b/CQRS_Simple.API/Products/Handlers/UpdateProductHandle.cs
new file mode 100644
index 0000000..1b3d44e
--- /dev/null
+++ b/CQRS_Simple.API/Products/Handlers/UpdateProductHandle.cs
@@ -0,0 +1,30 @@
+using System.Threading;
+using System.Threading.Tasks;
+using CQRS_Simple.API.Products.Commands;
+using CQRS_Simple.Domain.Products;
+using CQRS_Simple.Infrastructure.Dapper;
+using CQRS_Simple.Infrastructure.MQ;
+using MediatR;
+
+namespace CQRS_Simple.API.Products.Handlers
+{
+ public class UpdateProductHandle : IRequestHandler
+ {
+ private readonly IDapperRepository _dapperRepository;
+ private readonly RabbitMQClient _mq;
+
+ public UpdateProductHandle(IDapperRepository dapperRepository, RabbitMQClient mq)
+ {
+ _dapperRepository = dapperRepository;
+ _mq = mq;
+ }
+
+ public async Task Handle(UpdateProductCommand request, CancellationToken cancellationToken)
+ {
+ var result = await _dapperRepository.UpdateAsync(request.Product);
+ if (result > 0)
+ _mq.PushMessage(new RabbitData(typeof(UpdateProductCommand), request));
+ return result;
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/ProductsController.cs b/CQRS_Simple.API/Products/ProductsController.cs
new file mode 100644
index 0000000..bca6036
--- /dev/null
+++ b/CQRS_Simple.API/Products/ProductsController.cs
@@ -0,0 +1,99 @@
+using System;
+using System.Diagnostics;
+using System.Threading.Tasks;
+using Autofac;
+using CQRS_Simple.API.Products.Commands;
+using CQRS_Simple.API.Products.Queries;
+using CQRS_Simple.Domain.Products;
+using CQRS_Simple.Domain.Products.Request;
+using CQRS_Simple.Infrastructure;
+using CQRS_Simple.Infrastructure.Uow;
+using MediatR;
+using Microsoft.AspNetCore.Mvc;
+using Serilog;
+
+namespace CQRS_Simple.API.Products
+{
+ [ApiController]
+ [Route("api/products")]
+ public class ProductsController : ControllerBase
+ {
+ private readonly IMediator _mediator;
+ private readonly IIocManager _iocManager;
+ private readonly IUnitOfWork _unitOfWork;
+
+ public ProductsController(IMediator mediator, IIocManager iocManager, IUnitOfWork unitOfWork)
+ {
+ _mediator = mediator;
+ _iocManager = iocManager;
+ _unitOfWork = unitOfWork;
+ }
+
+ [HttpGet]
+ [Route("GetProduct")]
+ public async Task GetProduct(int id)
+ {
+ var result = await _mediator.Send(new GetProductByIdQuery(id));
+
+ var _r1 = _unitOfWork.GetRepository();
+ _r1.UnitOfWork.PrintKey();
+
+
+ var _repository = _iocManager.GetInstance>();
+ _repository.UnitOfWork.PrintKey();
+
+
+ var _repository2 = _iocManager.GetInstance>();
+ _repository2.UnitOfWork.PrintKey();
+
+
+ var find = await _repository.GetByIdAsync(id);
+
+ if (find != null)
+ {
+ find.Name += "1_";
+ Log.Information(find?.Name);
+ await _unitOfWork.SaveChangesAsync();
+ }
+
+ // throw new Exception("ss");
+
+ return result != null ? (IActionResult)Ok(result) : NotFound();
+ }
+
+ [HttpGet]
+ [Route("GetAll")]
+ public async Task GetAll([FromQuery] ProductsRequestInput input)
+ {
+ var list = await _mediator.Send(new GetProductsQuery(input));
+
+ Debugger.Break();
+
+ return Ok(list);
+ }
+
+ [HttpPost]
+ [Route("Create")]
+ public async Task Create([FromBody]Product input)
+ {
+ var result = await _mediator.Send(new CreateProductCommand(input));
+ return result > 0 ? (IActionResult)Ok(result) : BadRequest();
+ }
+
+ [HttpDelete]
+ [Route("Delete/{id}")]
+ public async Task Delete(int id)
+ {
+ var count = await _mediator.Send(new DeleteProductCommand(id));
+ return count > 0 ? (IActionResult)Ok() : NotFound();
+ }
+
+ [HttpPut]
+ [Route("Update")]
+ public async Task Update([FromBody]Product input)
+ {
+ var count = await _mediator.Send(new UpdateProductCommand(input));
+ return count > 0 ? (IActionResult)Ok() : NotFound();
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Queries/GetProductByIdQuery.cs b/CQRS_Simple.API/Products/Queries/GetProductByIdQuery.cs
new file mode 100644
index 0000000..f4e74b5
--- /dev/null
+++ b/CQRS_Simple.API/Products/Queries/GetProductByIdQuery.cs
@@ -0,0 +1,15 @@
+using CQRS_Simple.API.Products.Dtos;
+using MediatR;
+
+namespace CQRS_Simple.API.Products.Queries
+{
+ public class GetProductByIdQuery : IRequest
+ {
+ public int ProductId { get; set; }
+
+ public GetProductByIdQuery(int productId)
+ {
+ ProductId = productId;
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Queries/GetProductsQuery.cs b/CQRS_Simple.API/Products/Queries/GetProductsQuery.cs
new file mode 100644
index 0000000..e93777c
--- /dev/null
+++ b/CQRS_Simple.API/Products/Queries/GetProductsQuery.cs
@@ -0,0 +1,17 @@
+using System.Collections.Generic;
+using CQRS_Simple.API.Products.Dtos;
+using CQRS_Simple.Domain.Products.Request;
+using MediatR;
+
+namespace CQRS_Simple.API.Products.Queries
+{
+ public class GetProductsQuery : IRequest>
+ {
+ public ProductsRequestInput Input { get; set; }
+
+ public GetProductsQuery(ProductsRequestInput input)
+ {
+ Input = input;
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Products/Validation/CreateProductCommandValidator.cs b/CQRS_Simple.API/Products/Validation/CreateProductCommandValidator.cs
new file mode 100644
index 0000000..f8b0ec1
--- /dev/null
+++ b/CQRS_Simple.API/Products/Validation/CreateProductCommandValidator.cs
@@ -0,0 +1,20 @@
+using CQRS_Simple.API.Products.Commands;
+using CQRS_Simple.Domain.Products;
+using CQRS_Simple.Infrastructure.Dapper;
+using FluentValidation;
+
+namespace CQRS_Simple.API.Products.Validation
+{
+ public class CreateProductCommandValidator : AbstractValidator
+ {
+ private readonly IDapperRepository _productDapperRepository;
+ public CreateProductCommandValidator(IDapperRepository productDapperRepository)
+ {
+ _productDapperRepository = productDapperRepository;
+
+ RuleFor(x => x.Product).NotNull();
+
+ RuleFor(x => x.Product.Id).Equal(0);
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/Program.cs b/CQRS_Simple.API/Program.cs
new file mode 100644
index 0000000..a56e2b1
--- /dev/null
+++ b/CQRS_Simple.API/Program.cs
@@ -0,0 +1,54 @@
+using System;
+using System.IO;
+using Autofac.Extensions.DependencyInjection;
+using CQRS_Simple.API;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Hosting;
+using Serilog;
+using Serilog.Formatting.Compact;
+
+namespace CQRS_Simple
+{
+ public class Program
+ {
+ public static void Main(string[] args)
+ {
+ Log.Logger = new LoggerConfiguration()
+#if DEBUG
+ .MinimumLevel.Debug()
+#else
+ .MinimumLevel.Information()
+#endif
+ .Enrich.FromLogContext()
+ .WriteTo.Console()
+// .WriteTo.File(new RenderedCompactJsonFormatter(), "/logs/log.json")
+ .CreateLogger();
+
+ try
+ {
+ Log.Information("Starting up");
+ CreateHostBuilder(args).Build().Run();
+ }
+ catch (Exception ex)
+ {
+ Log.Fatal(ex, "Application start-up failed");
+ }
+ finally
+ {
+ Log.CloseAndFlush();
+ }
+ }
+
+ public static IHostBuilder CreateHostBuilder(string[] args) =>
+ Host.CreateDefaultBuilder(args)
+ .UseSerilog()
+ .UseServiceProviderFactory(new AutofacServiceProviderFactory())
+ .ConfigureWebHostDefaults(webBuilder =>
+ {
+ webBuilder
+ .UseContentRoot(Directory.GetCurrentDirectory())
+ .UseIISIntegration()
+ .UseStartup();
+ });
+ }
+}
diff --git a/CQRS_Simple.API/Properties/launchSettings.json b/CQRS_Simple.API/Properties/launchSettings.json
new file mode 100644
index 0000000..06f2b1c
--- /dev/null
+++ b/CQRS_Simple.API/Properties/launchSettings.json
@@ -0,0 +1,28 @@
+{
+ "iisSettings": {
+ "windowsAuthentication": false,
+ "anonymousAuthentication": true,
+ "iisExpress": {
+ "applicationUrl": "http://localhost:21020",
+ "sslPort": 0
+ }
+ },
+ "profiles": {
+ "IIS Express": {
+ "commandName": "IISExpress",
+ "launchBrowser": true,
+ "environmentVariables": {
+ "ASPNETCORE_ENVIRONMENT": "Development"
+ }
+ },
+ "CQRS_Simple": {
+ "commandName": "Project",
+ "launchBrowser": true,
+ "launchUrl": "swagger/index.html",
+ "applicationUrl": "http://localhost:21020",
+ "environmentVariables": {
+ "ASPNETCORE_ENVIRONMENT": "Development"
+ }
+ }
+ }
+}
diff --git a/CQRS_Simple.API/Startup.cs b/CQRS_Simple.API/Startup.cs
new file mode 100644
index 0000000..d7ba396
--- /dev/null
+++ b/CQRS_Simple.API/Startup.cs
@@ -0,0 +1,162 @@
+using System;
+using System.Reflection;
+using Autofac;
+using Autofac.Extensions.DependencyInjection;
+using CQRS_Simple.API.Modules;
+using CQRS_Simple.Domain.Products.Request;
+using CQRS_Simple.EntityFrameworkCore;
+using CQRS_Simple.Infrastructure;
+using CQRS_Simple.Infrastructure.MQ;
+using CQRS_Simple.Modules;
+using FluentValidation.AspNetCore;
+using MediatR.Extensions.FluentValidation.AspNetCore;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+using Microsoft.OpenApi.Models;
+using Newtonsoft.Json.Serialization;
+
+namespace CQRS_Simple.API
+{
+ public class Startup
+ {
+ public IConfigurationRoot _configuration { get; }
+ public ILifetimeScope AutofacContainer { get; private set; }
+
+ public ILoggerFactory _LoggerFactory { get; private set; }
+
+ private const string SqlServerConnection = "ConnectionStrings:Default";
+ private const string MysqlConnection = "ConnectionStrings:Mysql";
+
+
+ public Startup(IWebHostEnvironment env)
+ {
+ var builder = new ConfigurationBuilder()
+ .SetBasePath(env.ContentRootPath)
+ .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)
+ .AddJsonFile($"appsettings.{env.EnvironmentName}.json", optional: true)
+ .AddEnvironmentVariables();
+
+ _configuration = builder.Build();
+ }
+
+ // ConfigureServices is where you register dependencies. This gets
+ // called by the runtime before the ConfigureContainer method, below.
+ public void ConfigureServices(IServiceCollection services)
+ {
+ services.AddDbContext(options =>
+ options.UseMySql(_configuration[MysqlConnection], ServerVersion.Parse("5.7.31-mysql")));
+
+
+ //options.UseSqlServer(_configuration[SqlServerConnection]));
+
+ services.Configure(_configuration.GetSection("RabbitMQ"));
+
+ //services.AddHostedService();
+
+ services.AddControllersWithViews(option =>
+ {
+ option.AllowEmptyInputInBodyModelBinding = true; // false as Default
+ })
+ .AddNewtonsoftJson(c => { c.SerializerSettings.ContractResolver = new CamelCasePropertyNamesContractResolver(); })
+
+ // 注入Api参数的FluentValidation
+ .AddFluentValidation(c => c.RegisterValidatorsFromAssembly(typeof(ProductValidator).Assembly))
+ ;
+
+ // MediatR的FluentValidation 效果和ValidationBehavior一样,取其一
+ // services.AddFluentValidation(new[]
+ // {
+ // typeof(Startup).GetTypeInfo().Assembly,
+ // typeof(ProductsRequestInput).GetTypeInfo().Assembly
+ // });
+
+
+ AddSwagger(services);
+ }
+
+ // ConfigureContainer is where you can register things directly
+ // with Autofac. This runs after ConfigureServices so the things
+ // here will override registrations made in ConfigureServices.
+ // Don't build the container; that gets done for you by the factory.
+ public void ConfigureContainer(ContainerBuilder builder)
+ {
+ // 类型注入
+ builder.Register(c => new CallLogger(Console.Out));
+
+ builder.RegisterModule(new IocManagerModule());
+
+ builder.RegisterModule(new LoggerModule());
+
+ builder.RegisterModule(new InfrastructureModule(_configuration[MysqlConnection]));
+
+ builder.RegisterModule(new MediatorModule());
+
+ builder.RegisterModule(new AutoMapperModule());
+ }
+
+ // Configure is where you add middleware. This is called after
+ // ConfigureContainer. You can use IApplicationBuilder.ApplicationServices
+ // here if you need to resolve things from the container.
+ public void Configure(IApplicationBuilder app, IWebHostEnvironment env, ILoggerFactory loggerFactory)
+ {
+ AutofacContainer = app.ApplicationServices.GetAutofacRoot();
+
+
+ //loggerFactory.AddSerilog();
+
+ if (env.IsDevelopment())
+ {
+ app.UseDeveloperExceptionPage();
+ }
+ else
+ {
+ app.UseExceptionHandler("/Error");
+ }
+
+ app.UseStaticFiles();
+
+ if (!env.IsDevelopment())
+ {
+ app.UseSpaStaticFiles();
+ }
+
+ app.UseRouting();
+
+ app.UseEndpoints(endpoints =>
+ {
+ endpoints.MapControllerRoute(
+ name: "default",
+ pattern: "{controller}/{action=Index}/{id?}");
+ });
+
+ ConfigureSwagger(app);
+ }
+
+ private static void ConfigureSwagger(IApplicationBuilder app)
+ {
+ app.UseSwagger();
+
+ app.UseSwaggerUI(c => { c.SwaggerEndpoint("/swagger/v1/swagger.json", "Sample CQRS API V1"); });
+ }
+
+ private void AddSwagger(IServiceCollection services)
+ {
+ services.AddSwaggerGen(options =>
+ {
+ options.SwaggerDoc("v1", new OpenApiInfo
+ {
+ Title = "API",
+ Version = "v1",
+ Description = "A simple example ASP.NET Core Web API",
+ TermsOfService = new Uri("https://somall.top/about")
+ });
+ options.DocInclusionPredicate((docName, description) => true);
+ });
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.API/appsettings.json b/CQRS_Simple.API/appsettings.json
new file mode 100644
index 0000000..fc46808
--- /dev/null
+++ b/CQRS_Simple.API/appsettings.json
@@ -0,0 +1,14 @@
+{
+ "ConnectionStrings": {
+ "Default": "Server=somall.top; Database=CQRS_Simple;uid=sa;pwd=hiue234Dfdf;Max Pool Size=2000;",
+ "Mysql": "server=119.91.157.50;port=6606;uid=root;pwd=123456;database=cqrs_simple;CharSet=utf8"
+ },
+ "RabbitMQ": {
+ "UserName": "guest",
+ "Password": "guest",
+ "HostName": "127.0.0.1",
+ "Port": 5672,
+ "QueryName": "MyQuery"
+ },
+ "AllowedHosts": "*"
+}
diff --git a/CQRS_Simple.API/wwwroot/favicon.ico b/CQRS_Simple.API/wwwroot/favicon.ico
new file mode 100644
index 0000000000000000000000000000000000000000..a3a799985c43bc7309d701b2cad129023377dc71
GIT binary patch
literal 32038
zcmeHwX>eTEbtY7aYbrGrkNjgie?1jXjZ#zP%3n{}GObKv$BxI7Sl;Bwl5E+Qtj&t8
z*p|m4DO#HoJC-FyvNnp8NP<{Na0LMnTtO21(rBP}?EAiNjWgeO?z`{3ZoURUQlV2d
zY1Pqv{m|X_oO91|?^z!6@@~od!@OH>&BN;>c@O+yUfy5w>LccTKJJ&`-k<%M^Zvi(
z<$dKp=jCnNX5Qa+M_%6g|IEv~4R84q9|7E=|Ho(Wz3f-0wPjaRL;W*N^>q%^KGRr7
zxbjSORb_c&eO;oV_DZ7ua!sPH=0c+W;`vzJ#j~-x3uj};50#vqo*0w4!LUqs*UCh9
zvy2S%$#8$K4EOa&e@~aBS65_hc~Mpu=454VT2^KzWqEpBA=ME|O;1cn?8p<+{MKJf
zbK#@1wzL44m$k(?85=Obido7=C|xWKe%66$z)NrzRwR>?hK?_bbwT
z@Da?lBrBL}Zemo1@!9pYRau&!ld17h{f+UV0sY(R{ET$PBB|-=Nr@l-nY6w8HEAw*
zRMIQU`24Jl_IFEPcS=_HdrOP5yf81z_?@M>83Vv65$QFr9nPg(wr`Ke8
zaY4ogdnMA*F7a4Q1_uXadTLUpCk;$ZPRRJ^sMOch;rlbvUGc1R9=u;dr9YANbQ<4Z
z#P|Cp9BP$FXNPolgyr1XGt$^lFPF}rmBF5rj1Kh5%dforrP8W}_qJL$2qMBS-#%-|s#BPZBSETsn_EBYcr(W5dq(
z@f%}C|iN7)YN`^)h7R?Cg}Do*w-!zwZb9=BMp%Wsh@nb22hA
zA{`wa8Q;yz6S)zfo%sl08^GF`9csI9BlGnEy#0^Y3b);M+n<(}6jziM7nhe57a1rj
zC@(2ISYBL^UtWChKzVWgf%4LW2Tqg_^7jMw`C$KvU+mcakFjV(BGAW9g%CzSyM;Df
z143=mq0oxaK-H;o>F3~zJ<(3-j&?|QBn)WJfP#JR
zRuA;`N?L83wQt78QIA$(Z)lGQY9r^SFal;LB^qi`8%8@y+mwcGsf~nv)bBy2S7z~9
z=;X@Gglk)^jpbNz?1;`!J3QUfAOp4U$Uxm5>92iT`mek#$>s`)M>;e4{#%HAAcb^8_Ax%ersk|}#
z0bd;ZPu|2}18KtvmIo8`1@H~@2ejwo(5rFS`Z4&O{$$+ch2hC0=06Jh`@p+p8LZzY
z&2M~8T6X^*X?yQ$3N5EzRv$(FtSxhW>>ABUyp!{484f8(%C1_y)3D%Qgfl_!sz`LTXOjR&L!zPA0qH_iNS!tY{!^2WfD%uT}P
zI<~&?@&))5&hPPHVRl9);TPO>@UI2d!^ksb!$9T96V(F){puTsn(}qt_WXNw4VvHj
zf;6A_XCvE`Z@}E-IOaG0rs>K>^=Sr&OgT_p;F@v0VCN0Y$r|Lw1?Wjt`AKK~RT*kJ
z2>QPuVgLNcF+XKno;WBv$yj@d_WFJbl*#*V_Cwzo@%3n5%z4g21G*PVZ)wM5$A{klYozmGlB
zT@u2+s}=f}25%IA!yNcXUr!!1)z(Nqbhojg0lv@7@0UlvUMT)*r;M$d0-t)Z?B1@qQk()o!4fqvfr_I0r7
zy1(NdkHEj#Yu{K>T#We#b#FD=c1XhS{hdTh9+8gy-vkcdkk*QS@y(xxEMb1w6z<^~
zYcETGfB#ibR#ql0EiD;PR$L&Vrh2uRv5t_$;NxC;>7_S5_OXxsi8udY3BUUdi55Sk
zcyKM+PQ9YMA%D1kH1q48OFG(Gbl=FmV;yk8o>k%0$rJ8%-IYsHclnYuTskkaiCGkUlkMY~mx&K}XRlKIW;odWIeuKjtbc^8bBOTqK
zjj(ot`_j?A6y_h%vxE9o*ntx#PGrnK7AljD_r58ylE*oy@{IY%+mA^!|2vW_`>`aC{#3`#3;D_$^S^cM
zRcF+uTO2sICledvFgNMU@A%M)%8JbSLq{dD|2|2Sg8vvh_uV6*Q?F&rKaV{v_qz&y
z`f;stIb?Cb2!Cg7CG91Bhu@D@RaIrq-+o+T2fwFu#|j>lD6ZS9-t^5cx>p|?flqUA
z;Cgs#V)O#`Aw4$Kr)L5?|7f4izl!;n0jux}tEW$&&YBXz9o{+~HhoiYDJ`w5BVTl&ARya=M7zdy$FEe}iGBur8XE>rhLj&_yDk5D4n2GJZ07u7%zyAfNtOLn;)M?h*Py-Xtql5aJOtL4U8e|!t?
z((sc6&OJXrPdVef^wZV&x=Z&~uA7^ix8rly^rEj?#d&~pQ{HN8Yq|fZ#*bXn-26P^
z5!)xRzYO9{u6vx5@q_{FE4#7BipS#{&J7*>y}lTyV94}dfE%Yk>@@pDe&F7J09(-0|wuI|$of-MRfK51#t@t2+U|*s=W;
z!Y&t{dS%!4VEEi$efA!#<<7&04?kB}Soprd8*jYv;-Qj~h~4v>{XX~kjF+@Z7<t?^|i
z#>_ag2i-CRAM8Ret^rZt*^K?`G|o>1o(mLkewxyA)38k93`<~4VFI?5VB!kBh%NNU
zxb8K(^-MU1ImWQxG~nFB-Un;6n{lQz_FfsW9^H$Xcn{;+W^ZcG$0qLM#eNV=vGE@#
z1~k&!h4@T|IiI<47@pS|i?Qcl=XZJL#$JKve;booMqDUYY{(xcdj6STDE=n?;fsS1
ze`h~Q{CT$K{+{t+#*I1=&&-UU8M&}AwAxD-rMa=e!{0gQXP@6azBq9(ji11uJF%@5
zCvV`#*?;ZguQ7o|nH%bm*s&jLej#@B35gy32ZAE0`Pz@#j6R&kN5w{O4~1rhDoU
zEBdU)%Nl?8zi|DR((u|gg~r$aLYmGMyK%FO*qLvwxK5+cn*`;O`16c!&&XT{$j~5k
zXb^fbh1GT-CI*Nj{-?r7HNg=e3E{6rxuluPXY
z5Nm8ktc$o4-^SO0|Es_sp!A$8GVwOX+%)cH<;=u#R#nz;7QsHl;J@a{5NUAmAHq4D
zIU5@jT!h?kUp|g~iN*!>jM6K!W5ar0v~fWrSHK@})@6Lh#h)C6F6@)&-+C3(zO!
z8+kV|B7LctM3DpI*~EYo>vCj>_?x&H;>y0*vKwE0?vi$CLt
zfSJB##P|M2dEUDBPKW=9cY-F;L;h3Fs4E2ERdN#NSL7ctAC
z?-}_a{*L@GA7JHJudxtDVA{K5Yh*k(%#x4W7w+^
zcb-+ofbT5ieG+@QG2lx&7!MyE2JWDP@$k`M;0`*d+oQmJ2A^de!3c53HFcfW_Wtv<
zKghQ;*FifmI}kE4dc@1y-u;@qs|V75Z^|Q0l0?teobTE8tGl@EB?k#q_wUjypJ*R
zyEI=DJ^Z+d*&}B_xoWvs27LtH7972qqMxVFcX9}c&JbeNCXUZM0`nQIkf&C}&skSt
z^9fw@b^Hb)!^hE2IJq~~GktG#ZWwWG<`@V&ckVR&r=JAO4YniJewVcG`HF;59}=bf
zLyz0uxf6MhuSyH#-^!ZbHxYl^mmBVrx)
zyrb8sQ*qBd_WXm9c~Of$&ZP$b^)<~0%nt#7y$1Jg$e}WCK>TeUB{P>|b1FAB?%K7>;XiOfd}JQ`|IP#Vf%kVy
zXa4;XFZ+>n;F>uX&3|4zqWK2u3c<>q;tzjsb1;d{u;L$-hq3qe@82(ob<3qom#%`+
z;vzYAs7TIMl_O75BXu|r`Qhc4UT*vN$3Oo0kAC!{f2#HexDy|qUpgTF;k{o6|L>7l
z=?`=*LXaow1o;oNNLXsGTrvC)$R&{m=94Tf+2iTT3Y_Or
z-!;^0a{kyWtO4vksG_3cyc7HQ0~detf0+2+qxq(e1NS251N}w5iTSrM)`0p8rem!j
zZ56hGD=pHI*B+dd)2B`%|9f0goozCSeXPw3
z+58k~sI02Yz#lOneJzYcG)EB0|F+ggC6D|B`6}d0khAK-gz7U3EGT|M_9$ZINqZjwf>P
zJCZ=ogSoE`=yV5YXrcTQZx@Un(64*AlLiyxWnCJ9I<5Nc*eK6eV1Mk}ci0*NrJ=t|
zCXuJG`#7GBbPceFtFEpl{(lTm`LX=B_!H+&
z>$*Hf}}y
zkt@nLXFG9%v**s{z&{H4e?aqp%&l#oU8lxUxk2o%K+?aAe6jLojA&
z_|J0<-%u^<;NT*%4)n2-OdqfctSl6iCHE?W_Q2zpJken#_xUJlidzs249H=b#g
z?}L4-Tnp6)t_5X?_$v)vz`s9@^BME2X@w<>sKZ3=B{%*B$T5Nj%6!-Hr;I!Scj`lH
z&2dHFlOISwWJ&S2vf~@I4i~(0*T%OFiuX|eD*nd2utS4$1_JM?zmp>a#CsVy6Er^z
zeNNZZDE?R3pM?>~e?H_N`C`hy%m4jb;6L#8=a7l>3eJS2LGgEUxsau-Yh9l~o7=Yh
z2mYg3`m5*3Ik|lKQf~euzZlCWzaN&=vHuHtOwK!2@W6)hqq$Zm|7`Nmu%9^F6UH?+
z@2ii+=iJ;ZzhiUKu$QB()nKk3FooI>Jr_IjzY6=qxYy;&mvi7BlQ?t4kRjIhb|2q?
zd^K~{-^cxjVSj?!Xs=Da5IHmFzRj!Kzh~b!?`P7c&T9s77VLYB?8_?F
zauM^)p;qFG!9PHLfIsnt43UnmV?Wn?Ki7aXSosgq;f?MYUuSIYwOn(5vWhb{f%$pn
z4ySN-z}_%7|B);A@PA5k*7kkdr4xZ@s{e9j+9w;*RFm;XPDQwx%~;8iBzSKTIGKO
z{53ZZU*OLr@S5=k;?CM^i#zkxs3Sj%z0U`L%q`qM+tP
zX$aL;*^g$7UyM2Go+_4A+f)IQcy^G$h2E
zb?nT$XlgTEFJI8GN6NQf%-eVn9mPilRqUbT$pN-|;FEjq@Ao&TxpZg=mEgBHB
zU@grU;&sfmqlO=6|G3sU;7t8rbK$?X0y_v9$^{X`m4jZ_BR|B|@?ZCLSPPEzz`w1n
zP5nA;4(kQFKm%$enjkkBxM%Y}2si&d|62L)U(dCzCGn56HN+i#6|nV-TGIo0;W;`(
zW-y=1KF4dp$$mC_|6}pbb>IHoKQeZajXQB>jVR?u`R>%l1o54?6NnS*arpVopdEF;
zeC5J3*M0p`*8lif;!irrcjC?(uExejsi~>4wKYwstGY^N@KY}TujLx`S=Cu+T=!dx
zKWlPm->I**E{A*q-Z^FFT5$G%7Ij0_*Mo4-y6~RmyTzUB&lfae(WZfO>um}mnsDXPEbau-!13!!xd!qh*{C)6&bz0j1I{>y$D-S)b*)JMCPk!=~KL&6Ngin0p6MCOxF2L_R9t8N!$2Wpced<#`y!F;w
zKTi5V_kX&X09wAIJ#anfg9Dhn0s7(C6Nj3S-mVn(i|C6ZAVq0$hE)874co};g
z^hR7pe4lU$P;*ggYc4o&UTQC%liCXooIfkI3TNaBV%t~FRr}yHu7kjQ2J*3;e%;iW
zvDVCh8=G80KAeyhCuY2LjrC!Od1rvF7h}zszxGV)&!)6ChP5WAjv-zQAMNJIG!JHS
zwl?pLxC-V5II#(hQ`l)ZAp&M0xd4%cxmco*MIk?{BD=BK`1vpc}D39|XlV
z{c&0oGdDa~TL2FT4lh=~1NL5O-P~0?V2#ie`v^CnANfGUM!b4F=JkCwd7Q`c8Na2q
zJGQQk^?6w}Vg9-{|2047((lAV84uN%sK!N2?V(!_1{{v6rdgZl56f0zDMQ+q)jKzzu^ztsVken;=DjAh6G`Cw`Q4G+BjS+n*=KI~^K{W=%t
zbD-rN)O4|*Q~@<#@1Vx$E!0W9`B~IZeFn87sHMXD>$M%|Bh93rdGf1lKoX3K651t&nhsl=
zXxG|%@8}Bbrlp_u#t*DZX<}_0Yb{A9*1Pd_)LtqNwy6xT4pZrOY{s?N4)pPwT(i#y
zT%`lRi8U#Ken4fw>H+N`{f#FF?ZxFlLZg7z7#cr4X>id
z{9kUD`d2=w_Zlb{^c`5IOxWCZ1k<0T1D1Z31IU0Q2edsZ1K0xv$pQVYq2KEp&#v#Z
z?{m@Lin;*Str(C2sfF^L>{R3cjY`~#)m>Wm$Y|1fzeS0-$(Q^z@}
zEO*vlb-^XK9>w&Ef^=Zzo-1AFSP#9zb~X5_+){$(eB4K
z8gtW+nl{q+CTh+>v(gWrsP^DB*ge(~Q$AGxJ-eYc1isti%$%nM<_&Ev?%|??PK`$p
z{f-PM{Ym8k<$$)(F9)tqzFJ?h&Dk@D?Dt{4CHKJWLs8$zy6+(R)pr@0ur)xY{=uXFFzH_>
z-F^tN1y(2hG8V)GpDg%wW0Px_ep~nIjD~*HCSxDi0y`H!`V*~RHs^uQsb1*bK1qGpmd
zB1m`Cjw0`nLBF2|umz+a#2X$c?Lj;M?Lj;MUp*d>7j~ayNAyj@SLpeH`)BgRH}byy
zyQSat!;U{@O(<<2fp&oQkIy$z`_CQ-)O@RN;QD9T4y|wIJ^%U#(BF%=`i49}j!D-)
zkOwPSJaG03SMkE~BzW}b_v>LA&y)EEYO6sbdnTX*$>UF|JhZ&^MSb4}Tgbne_4n+C
zwI8U4i~PI>7a3{kVa8|))*%C0|K+bIbmV~a`|G#+`TU#g
zXW;bWIcWsQi9c4X*RUDpIfyoPY)2bI-r9)xulm1CJDkQd6u+f)_N=w1ElgEBjprPF
z3o?Ly0RVeY_{3~fPVckRMxe2lM8hj!B8F)JO
z!`AP6>u>5Y&3o9t0QxBpNE=lJx#NyIbp1gD
zzUYBIPYHIv9ngk-Zt~<)62^1Zs1LLYMh@_tP^I7EX-9)Ed0^@y{k65Gp0KRcTmMWw
zU|+)qx{#q0SL+4q?Q`i0>COIIF8a0Cf&C`hbMj?LmG9K&iW-?PJt*u)38tTXAP>@R
zZL6uH^!RYNq$p>PKz7f-zvg>OKXcZ8h!%Vo@{VUZp|+iUD_xb(N~G|6c#oQK^nHZU
zKg#F6<)+`rf~k*Xjjye+syV{bwU2glMMMs-^ss4`bYaVroXzn`YQUd__UlZL_mLs
z(vO}k!~(mi|L+(5&;>r<;|OHnbXBE78LruP;{yBxZ6y7K3)nMo-{6PCI7gQi6+rF_
zkPod!Z8n}q46ykrlQS|hVB(}(2Kf7BCZ>Vc;V>ccbk2~NGaf6wGQH@W9&?Zt3v(h*P4xDrN>ex7+jH*+Qg
z%^jH$&+*!v{sQ!xkWN4+>|b}qGvEd6ANzgqoVy5Qfws}ef2QqF{iiR5{pT}PS&yjo
z>lron#va-p=v;m>WB+XVz|o;UJFdjo5_!RRD|6W{4}A2a#bZv)gS_`b|KsSH)Sd_JIr%<%n06TX&t{&!H#{)?4W9hlJ`R1>FyugOh3=D_{einr
zu(Wf`qTkvED+gEULO0I*Hs%f;&=`=X4;N8Ovf28x$A*11`dmfy2=$+PNqX>XcG`h%
zJY&A6@&)*WT^rC(Caj}2+|X|6cICm5h0OK0cGB_!wEKFZJU)OQ+TZ1q2bTx9hxnq&
z$9ee|f9|0M^)#E&Pr4)f?o&DMM4w>Ksb{hF(0|wh+5_{vPow{V%TFzU2za&gjttNi
zIyR9qA56dX52Qbv2aY^g`U7R43-p`#sO1A=KS2aKgfR+Yu^bQ*i-qu
z%0mP;Ap)B~zZgO9lG^`325gOf?iUHF{~7jyGC)3L(eL(SQ70VzR~wLN18tnx(Cz2~
zctBl1kI)wAe+cxWHw*NW-d;=pd+>+wd$a@GBju*wFvabSaPtHiT!o#QFC+wBVwYo3s=y;z1jM+M=Fj!FZM>UzpL-eZzOT(
zhmZmEfWa=%KE#V3-ZK5#v!Hzd{zc^{ctF~-
z>DT-U`}5!fk$aj24`#uGdB7r`>oX5tU|d*b|N3V1lXmv%MGrvE(dXG)^-J*LA>$LE
z7kut4`zE)v{@Op|(|@i#c>tM!12FQh?}PfA0`Bp%=%*RiXVzLDXnXtE@4B)5uR}a>
zbNU}q+712pIrM`k^odG8dKtG$zwHmQI^c}tfjx5?egx3!e%JRm_64e+>`Ra1IRfLb
z1KQ`SxmH{cZfyVS5m(&`{V}Y4j6J{b17`h6KWqZ&hfc(oR
zxM%w!$F(mKy05kY&lco3%zvLCxBW+t*rxO+i=qGMvobx0-<7`VUu)ka`){=ew+Ovt
zg%52_{&UbkUA8aJPWsk)gYWV4`dnxI%s?7^fGpq{ZQuu=VH{-t7w~K%_E<8`zS;V-
zKTho*>;UQQul^1GT^HCt@I-q?)&4!QDgBndn?3sNKYKCQFU4LGKJ$n@Je$&w9@E$X
z^p@iJ(v&`1(tq~1zc>0Vow-KR&vm!GUzT?Eqgnc)leZ9p)-Z*C!zqb=-$XG0
z^!8RfuQs5s>Q~qcz92(a_Q+KH?C*vCTr~UdTiR`JGuNH8v(J|FTiSEcPrBpmHRtmd
zI2Jng0J=bXK);YY^rM?jzn?~X-Pe`GbAy{D)Y6D&1GY-EBcy%Bq?bKh?A>DD9DD!p
z?{q02wno2sraGUkZv5dx+J8)&K$)No43Zr(*S`FEdL!4C)}WE}vJd%{S6-3VUw>Wp
z?Aasv`T0^%P$2vE?L+Qhj~qB~K%eW)xH(=b_jU}TLD&BP*Pc9hz@Z=e0nkpLkWl}>
z_5J^i(9Z7$(XG9~I3sY)`OGZ#_L06+Dy4E>UstcP-rU@xJ$&rxvo!n1Ao`P~KLU-8
z{zDgN4-&A6N!kPSYbQ&7sLufi`YtE2uN$S?e&5n>Y4(q#|KP!cc1j)T^QrUXMPFaP
z_SoYO8S8G}Z$?AL4`;pE?7J5K8yWqy23>cCT2{=-)+A$X^-I9=e!@J@A&-;Ufc)`H}c(VI&;0x
zrrGv()5mjP%jXzS{^|29?bLNXS0bC%p!YXI!;O457rjCEEzMkGf~B3$T}dXBO23tP
z+Ci>;5UoM?C@bU@f9G1^X3=ly&ZeFH<@|RnOG--A&)fd)AUgjw?%izq{p(KJ`EP0v
z2mU)P!+3t@X14DA=E2RR-|p${GZ9ETX=d+kJRZL$nSa0daI@&oUUxnZg0xd_xu>Vz
lzF#z5%kSKX?YLH3ll^(hI(_`L*t#Iva2Ede*Z;>H_
+
+
+ net6.0
+ 8
+
+ Library
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/CQRS_Simple.Domain/Products/Product.cs b/CQRS_Simple.Domain/Products/Product.cs
new file mode 100644
index 0000000..8165aa8
--- /dev/null
+++ b/CQRS_Simple.Domain/Products/Product.cs
@@ -0,0 +1,29 @@
+using CQRS_Simple.Infrastructure;
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+using FluentValidation;
+
+namespace CQRS_Simple.Domain.Products
+{
+ [Table("Products")]
+ public class Product : Entity, IAggregateRoot
+ {
+ //[StringLength(256)] [Required]
+ public string Name { get; set; }
+
+ //[StringLength(256)]
+ public string Code { get; set; }
+
+ public string Description { get; set; }
+ }
+
+ public class ProductValidator : AbstractValidator
+ {
+ public ProductValidator()
+ {
+ RuleFor(x => x.Name).NotNull();
+ RuleFor(x => x.Name).Length(5, 256);
+ RuleFor(x => x.Code).Length(5, 256);
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Domain/Products/Request/ProductsRequestInput.cs b/CQRS_Simple.Domain/Products/Request/ProductsRequestInput.cs
new file mode 100644
index 0000000..9acbc6e
--- /dev/null
+++ b/CQRS_Simple.Domain/Products/Request/ProductsRequestInput.cs
@@ -0,0 +1,20 @@
+using FluentValidation;
+
+namespace CQRS_Simple.Domain.Products.Request
+{
+ public class ProductsRequestInput
+ {
+ public int SkipCount { get; set; }
+
+ public int MaxResultCount { get; set; }
+ }
+
+ public class ProductValidator : AbstractValidator
+ {
+ public ProductValidator()
+ {
+ RuleFor(x => x.MaxResultCount).GreaterThanOrEqualTo(1).WithName("每页数量");
+ RuleFor(x => x.SkipCount).GreaterThanOrEqualTo(0).WithName("忽略行数");
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.EntityFrameworkCore/CQRS_Simple.EntityFrameworkCore.csproj b/CQRS_Simple.EntityFrameworkCore/CQRS_Simple.EntityFrameworkCore.csproj
new file mode 100644
index 0000000..082ccae
--- /dev/null
+++ b/CQRS_Simple.EntityFrameworkCore/CQRS_Simple.EntityFrameworkCore.csproj
@@ -0,0 +1,29 @@
+
+
+
+ Library
+ net6.0
+ 8
+
+
+
+
+
+
+
+ all
+ runtime; build; native; contentfiles; analyzers; buildtransitive
+
+
+
+ all
+ runtime; build; native; contentfiles; analyzers; buildtransitive
+
+
+
+
+
+
+
+
+
diff --git a/CQRS_Simple.EntityFrameworkCore/Migrations/20220406070529_InitialCreate.Designer.cs b/CQRS_Simple.EntityFrameworkCore/Migrations/20220406070529_InitialCreate.Designer.cs
new file mode 100644
index 0000000..5db6e2a
--- /dev/null
+++ b/CQRS_Simple.EntityFrameworkCore/Migrations/20220406070529_InitialCreate.Designer.cs
@@ -0,0 +1,45 @@
+//
+using CQRS_Simple.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+
+#nullable disable
+
+namespace CQRS_Simple.EntityFrameworkCore.Migrations
+{
+ [DbContext(typeof(SimpleDbContext))]
+ [Migration("20220406070529_InitialCreate")]
+ partial class InitialCreate
+ {
+ protected override void BuildTargetModel(ModelBuilder modelBuilder)
+ {
+#pragma warning disable 612, 618
+ modelBuilder
+ .HasAnnotation("ProductVersion", "6.0.3")
+ .HasAnnotation("Relational:MaxIdentifierLength", 64);
+
+ modelBuilder.Entity("CQRS_Simple.Domain.Products.Product", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("int");
+
+ b.Property("Code")
+ .HasColumnType("longtext");
+
+ b.Property("Description")
+ .HasColumnType("longtext");
+
+ b.Property("Name")
+ .HasColumnType("longtext");
+
+ b.HasKey("Id");
+
+ b.ToTable("Products");
+ });
+#pragma warning restore 612, 618
+ }
+ }
+}
diff --git a/CQRS_Simple.EntityFrameworkCore/Migrations/20220406070529_InitialCreate.cs b/CQRS_Simple.EntityFrameworkCore/Migrations/20220406070529_InitialCreate.cs
new file mode 100644
index 0000000..c6233fa
--- /dev/null
+++ b/CQRS_Simple.EntityFrameworkCore/Migrations/20220406070529_InitialCreate.cs
@@ -0,0 +1,41 @@
+using Microsoft.EntityFrameworkCore.Metadata;
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace CQRS_Simple.EntityFrameworkCore.Migrations
+{
+ public partial class InitialCreate : Migration
+ {
+ protected override void Up(MigrationBuilder migrationBuilder)
+ {
+ migrationBuilder.AlterDatabase()
+ .Annotation("MySql:CharSet", "utf8mb4");
+
+ migrationBuilder.CreateTable(
+ name: "Products",
+ columns: table => new
+ {
+ Id = table.Column(type: "int", nullable: false)
+ .Annotation("MySql:ValueGenerationStrategy", MySqlValueGenerationStrategy.IdentityColumn),
+ Name = table.Column(type: "longtext", nullable: true)
+ .Annotation("MySql:CharSet", "utf8mb4"),
+ Code = table.Column(type: "longtext", nullable: true)
+ .Annotation("MySql:CharSet", "utf8mb4"),
+ Description = table.Column(type: "longtext", nullable: true)
+ .Annotation("MySql:CharSet", "utf8mb4")
+ },
+ constraints: table =>
+ {
+ table.PrimaryKey("PK_Products", x => x.Id);
+ })
+ .Annotation("MySql:CharSet", "utf8mb4");
+ }
+
+ protected override void Down(MigrationBuilder migrationBuilder)
+ {
+ migrationBuilder.DropTable(
+ name: "Products");
+ }
+ }
+}
diff --git a/CQRS_Simple.EntityFrameworkCore/Migrations/SimpleDbContextModelSnapshot.cs b/CQRS_Simple.EntityFrameworkCore/Migrations/SimpleDbContextModelSnapshot.cs
new file mode 100644
index 0000000..007438f
--- /dev/null
+++ b/CQRS_Simple.EntityFrameworkCore/Migrations/SimpleDbContextModelSnapshot.cs
@@ -0,0 +1,43 @@
+//
+using CQRS_Simple.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+
+#nullable disable
+
+namespace CQRS_Simple.EntityFrameworkCore.Migrations
+{
+ [DbContext(typeof(SimpleDbContext))]
+ partial class SimpleDbContextModelSnapshot : ModelSnapshot
+ {
+ protected override void BuildModel(ModelBuilder modelBuilder)
+ {
+#pragma warning disable 612, 618
+ modelBuilder
+ .HasAnnotation("ProductVersion", "6.0.3")
+ .HasAnnotation("Relational:MaxIdentifierLength", 64);
+
+ modelBuilder.Entity("CQRS_Simple.Domain.Products.Product", b =>
+ {
+ b.Property("Id")
+ .ValueGeneratedOnAdd()
+ .HasColumnType("int");
+
+ b.Property("Code")
+ .HasColumnType("longtext");
+
+ b.Property("Description")
+ .HasColumnType("longtext");
+
+ b.Property("Name")
+ .HasColumnType("longtext");
+
+ b.HasKey("Id");
+
+ b.ToTable("Products");
+ });
+#pragma warning restore 612, 618
+ }
+ }
+}
diff --git a/CQRS_Simple.EntityFrameworkCore/SimpleDbContext.cs b/CQRS_Simple.EntityFrameworkCore/SimpleDbContext.cs
new file mode 100644
index 0000000..34fc754
--- /dev/null
+++ b/CQRS_Simple.EntityFrameworkCore/SimpleDbContext.cs
@@ -0,0 +1,24 @@
+using System;
+using CQRS_Simple.Domain.Products;
+using Microsoft.EntityFrameworkCore;
+using Serilog;
+
+namespace CQRS_Simple.EntityFrameworkCore
+{
+ public class SimpleDbContext : DbContext
+ {
+ protected SimpleDbContext()
+ {
+ }
+
+ public DbSet Products { get; set; }
+
+ public SimpleDbContext(DbContextOptions options)
+ : base(options)
+ {
+#if DEBUG
+ Log.Debug($"SimpleDbContext Init");
+#endif
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/CQRS_Simple.Infrastructure.csproj b/CQRS_Simple.Infrastructure/CQRS_Simple.Infrastructure.csproj
new file mode 100644
index 0000000..fe12023
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/CQRS_Simple.Infrastructure.csproj
@@ -0,0 +1,24 @@
+
+
+
+ net6.0
+ 8
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/CQRS_Simple.Infrastructure/Dapper/DapperExtensions.cs b/CQRS_Simple.Infrastructure/Dapper/DapperExtensions.cs
new file mode 100644
index 0000000..a29a488
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Dapper/DapperExtensions.cs
@@ -0,0 +1,24 @@
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Threading.Tasks;
+using Dapper;
+
+namespace CQRS_Simple.Infrastructure.Dapper
+{
+ public static class DapperExtensions
+ {
+ public static async Task InsertAsync(this IDbConnection db, string tableName, object param)
+ {
+ IEnumerable result = await db.QueryAsync(DynamicQuery.GetInsertQuery(tableName, param), param);
+ return result.First();
+ }
+
+ public static async Task UpdateAsync(
+ this IDbConnection db,
+ string tableName, object param)
+ {
+ return await db.ExecuteAsync(DynamicQuery.GetUpdateQuery(tableName, param), param);
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Dapper/DapperRepository.cs b/CQRS_Simple.Infrastructure/Dapper/DapperRepository.cs
new file mode 100644
index 0000000..0c5f08e
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Dapper/DapperRepository.cs
@@ -0,0 +1,76 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Threading.Tasks;
+using Dapper;
+
+namespace CQRS_Simple.Infrastructure.Dapper
+{
+ public class DapperRepository : IDapperRepository where T : Entity
+ {
+ private readonly ISqlConnectionFactory _sqlConnectionFactory;
+ private readonly string _tableName;
+
+ public DapperRepository(ISqlConnectionFactory sqlConnectionFactory)
+ {
+ _sqlConnectionFactory = sqlConnectionFactory;
+ var attr = typeof(T).GetCustomAttributes(typeof(TableAttribute), true).FirstOrDefault();
+ _tableName = (attr as TableAttribute)?.Name;
+ }
+
+ public async Task GetByIdAsync(TC id)
+ {
+ using var db = _sqlConnectionFactory.GetOpenConnection();
+ return await db.QueryFirstOrDefaultAsync(
+ $"SELECT * FROM {_tableName} WHERE Id=@Id",
+ new { Id = id });
+ }
+
+ public async Task AddAsync(T item)
+ {
+ using var db = _sqlConnectionFactory.GetOpenConnection();
+ return await db.InsertAsync(_tableName, item);
+ }
+
+ public async Task RemoveAsync(T item)
+ {
+ using var db = _sqlConnectionFactory.GetOpenConnection();
+ return await db.ExecuteAsync(
+ $"DELETE FROM {_tableName} WHERE Id=@Id",
+ new { Id = item.Id });
+ }
+
+ public async Task UpdateAsync(T item)
+ {
+ using var db = _sqlConnectionFactory.GetOpenConnection();
+ return await db.UpdateAsync(_tableName, item);
+ }
+
+ public async Task> FindAsync(Expression> predicate)
+ {
+ IEnumerable items;
+ var result = DynamicQuery.GetDynamicQuery(_tableName, predicate);
+ using (var db = _sqlConnectionFactory.GetOpenConnection())
+ {
+ items = await db.QueryAsync(result.Sql, (object)result.Param);
+ }
+
+ return items;
+ }
+
+ public async Task> GetAllAsync()
+ {
+ IEnumerable items;
+ using (var db = _sqlConnectionFactory.GetOpenConnection())
+ {
+ items = await db.QueryAsync(
+ $"SELECT * FROM {_tableName}"
+ );
+ }
+
+ return items;
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Dapper/DynamicQuery.cs b/CQRS_Simple.Infrastructure/Dapper/DynamicQuery.cs
new file mode 100644
index 0000000..2f04a12
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Dapper/DynamicQuery.cs
@@ -0,0 +1,201 @@
+using System;
+using System.Collections.Generic;
+using System.Dynamic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Reflection;
+using System.Text;
+
+namespace CQRS_Simple.Infrastructure.Dapper
+{
+ ///
+ /// Dynamic query class.
+ ///
+ public sealed class DynamicQuery
+ {
+ ///
+ /// Gets the insert query.
+ ///
+ /// Name of the table.
+ /// The item.
+ ///
+ /// The Sql query based on the item properties.
+ ///
+ public static string GetInsertQuery(string tableName, object item)
+ {
+ PropertyInfo[] props = item.GetType().GetProperties(
+ BindingFlags.Public |
+ BindingFlags.Instance);
+ var columns = props.Where(x => x.Name != "Id").Select(p => p.Name).ToArray();
+
+ return string.Format("INSERT INTO {0} ({1}) OUTPUT Inserted.Id VALUES (@{2})",
+ tableName,
+ string.Join(",", columns),
+ string.Join(",@", columns));
+ }
+
+ ///
+ /// Gets the update query.
+ ///
+ /// Name of the table.
+ /// The item.
+ ///
+ /// The Sql query based on the item properties.
+ ///
+ public static string GetUpdateQuery(string tableName, dynamic item)
+ {
+ PropertyInfo[] props = item.GetType().GetProperties(BindingFlags.Public |
+ BindingFlags.Instance);
+
+ string[] columns = props.Where(x => x.Name != "Id").Select(p => p.Name).ToArray();
+
+ var parameters = columns.Select(name => name + "=@" + name).ToList();
+
+ return string.Format("UPDATE {0} SET {1} WHERE Id=@Id", tableName, string.Join(",", parameters));
+ }
+
+ ///
+ /// Gets the dynamic query.
+ ///
+ /// Name of the table.
+ /// The expression.
+ /// A result object with the generated sql and dynamic params.
+ public static QueryResult GetDynamicQuery(string tableName, Expression> expression)
+ {
+ var queryProperties = new List();
+ var body = (BinaryExpression)expression.Body;
+ IDictionary expando = new ExpandoObject();
+ var builder = new StringBuilder();
+
+ // walk the tree and build up a list of query parameter objects
+ // from the left and right branches of the expression tree
+ WalkTree(body, ExpressionType.Default, ref queryProperties);
+
+ // convert the query parms into a SQL string and dynamic property object
+ builder.Append("SELECT * FROM ");
+ builder.Append(tableName);
+ builder.Append(" WHERE ");
+
+ for (int i = 0; i < queryProperties.Count(); i++)
+ {
+ QueryParameter item = queryProperties[i];
+
+ if (!string.IsNullOrEmpty(item.LinkingOperator) && i > 0)
+ {
+ builder.Append(string.Format("{0} {1} {2} @{1} ", item.LinkingOperator, item.PropertyName,
+ item.QueryOperator));
+ }
+ else
+ {
+ builder.Append(string.Format("{0} {1} @{0} ", item.PropertyName, item.QueryOperator));
+ }
+
+ expando[item.PropertyName] = item.PropertyValue;
+ }
+
+ return new QueryResult(builder.ToString().TrimEnd(), expando);
+ }
+
+ ///
+ /// Walks the tree.
+ ///
+ /// The body.
+ /// Type of the linking.
+ /// The query properties.
+ private static void WalkTree(BinaryExpression body, ExpressionType linkingType,
+ ref List queryProperties)
+ {
+ if (body.NodeType != ExpressionType.AndAlso && body.NodeType != ExpressionType.OrElse)
+ {
+ string propertyName = GetPropertyName(body);
+ dynamic propertyValue = body.Right;
+ string opr = GetOperator(body.NodeType);
+ string link = GetOperator(linkingType);
+
+ queryProperties.Add(new QueryParameter(link, propertyName, propertyValue.Value, opr));
+ }
+ else
+ {
+ WalkTree((BinaryExpression)body.Left, body.NodeType, ref queryProperties);
+ WalkTree((BinaryExpression)body.Right, body.NodeType, ref queryProperties);
+ }
+ }
+
+ ///
+ /// Gets the name of the property.
+ ///
+ /// The body.
+ /// The property name for the property expression.
+ private static string GetPropertyName(BinaryExpression body)
+ {
+ string propertyName = body.Left.ToString().Split(new char[] { '.' })[1];
+
+ if (body.Left.NodeType == ExpressionType.Convert)
+ {
+ // hack to remove the trailing ) when convering.
+ propertyName = propertyName.Replace(")", string.Empty);
+ }
+
+ return propertyName;
+ }
+
+ ///
+ /// Gets the operator.
+ ///
+ /// The type.
+ ///
+ /// The expression types SQL server equivalent operator.
+ ///
+ ///
+ private static string GetOperator(ExpressionType type)
+ {
+ switch (type)
+ {
+ case ExpressionType.Equal:
+ return "=";
+ case ExpressionType.NotEqual:
+ return "!=";
+ case ExpressionType.LessThan:
+ return "<";
+ case ExpressionType.GreaterThan:
+ return ">";
+ case ExpressionType.AndAlso:
+ case ExpressionType.And:
+ return "AND";
+ case ExpressionType.Or:
+ case ExpressionType.OrElse:
+ return "OR";
+ case ExpressionType.Default:
+ return string.Empty;
+ default:
+ throw new NotImplementedException();
+ }
+ }
+ }
+
+ ///
+ /// Class that models the data structure in coverting the expression tree into SQL and Params.
+ ///
+ internal class QueryParameter
+ {
+ public string LinkingOperator { get; set; }
+ public string PropertyName { get; set; }
+ public object PropertyValue { get; set; }
+ public string QueryOperator { get; set; }
+
+ ///
+ /// Initializes a new instance of the class.
+ ///
+ /// The linking operator.
+ /// Name of the property.
+ /// The property value.
+ /// The query operator.
+ internal QueryParameter(string linkingOperator, string propertyName, object propertyValue, string queryOperator)
+ {
+ this.LinkingOperator = linkingOperator;
+ this.PropertyName = propertyName;
+ this.PropertyValue = propertyValue;
+ this.QueryOperator = queryOperator;
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Dapper/IDapperRepository.cs b/CQRS_Simple.Infrastructure/Dapper/IDapperRepository.cs
new file mode 100644
index 0000000..38460c7
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Dapper/IDapperRepository.cs
@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Linq.Expressions;
+using System.Threading.Tasks;
+
+namespace CQRS_Simple.Infrastructure.Dapper
+{
+ public interface IDapperRepository where T : Entity
+ {
+ Task AddAsync(T item);
+ Task RemoveAsync(T item);
+ Task UpdateAsync(T item);
+ Task GetByIdAsync(TC id);
+ Task> FindAsync(Expression> predicate);
+ Task> GetAllAsync();
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Dapper/ISqlConnectionFactory.cs b/CQRS_Simple.Infrastructure/Dapper/ISqlConnectionFactory.cs
new file mode 100644
index 0000000..a2f746a
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Dapper/ISqlConnectionFactory.cs
@@ -0,0 +1,9 @@
+using System.Data;
+
+namespace CQRS_Simple.Infrastructure
+{
+ public interface ISqlConnectionFactory
+ {
+ IDbConnection GetOpenConnection();
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Dapper/QueryResult.cs b/CQRS_Simple.Infrastructure/Dapper/QueryResult.cs
new file mode 100644
index 0000000..a88e549
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Dapper/QueryResult.cs
@@ -0,0 +1,53 @@
+using System;
+
+namespace CQRS_Simple.Infrastructure
+{
+ ///
+ /// A result object with the generated sql and dynamic params.
+ ///
+ public class QueryResult
+ {
+ ///
+ /// The _result
+ ///
+ private readonly Tuple _result;
+
+ ///
+ /// Gets the SQL.
+ ///
+ ///
+ /// The SQL.
+ ///
+ public string Sql
+ {
+ get
+ {
+ return _result.Item1;
+ }
+ }
+
+ ///
+ /// Gets the param.
+ ///
+ ///
+ /// The param.
+ ///
+ public dynamic Param
+ {
+ get
+ {
+ return _result.Item2;
+ }
+ }
+
+ ///
+ /// Initializes a new instance of the class.
+ ///
+ /// The SQL.
+ /// The param.
+ public QueryResult(string sql, dynamic param)
+ {
+ _result = new Tuple(sql, param);
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Dapper/SqlConnectionFactory.cs b/CQRS_Simple.Infrastructure/Dapper/SqlConnectionFactory.cs
new file mode 100644
index 0000000..2ed300e
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Dapper/SqlConnectionFactory.cs
@@ -0,0 +1,44 @@
+using System;
+using System.Data;
+using System.Data.SqlClient;
+using MySqlConnector;
+
+namespace CQRS_Simple.Infrastructure.Dapper
+{
+ public class SqlConnectionFactory : ISqlConnectionFactory, IDisposable
+ {
+ private readonly string _connectionString;
+ private IDbConnection _connection;
+
+ public SqlConnectionFactory(string connectionString)
+ {
+ this._connectionString = connectionString;
+ }
+
+ public IDbConnection GetOpenConnection()
+ {
+ if (this._connection == null || this._connection.State != ConnectionState.Open)
+ {
+ //this._connection = new SqlConnection(_connectionString);
+ this._connection = new MySqlConnection(_connectionString)
+ {
+ Site = null,
+ ProvideClientCertificatesCallback = null,
+ ProvidePasswordCallback = null,
+ RemoteCertificateValidationCallback = null
+ };
+ this._connection.Open();
+ }
+
+ return this._connection;
+ }
+
+ public void Dispose()
+ {
+ if (this._connection != null && this._connection.State == ConnectionState.Open)
+ {
+ this._connection.Dispose();
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/EntityBase.cs b/CQRS_Simple.Infrastructure/EntityBase.cs
new file mode 100644
index 0000000..57822c0
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/EntityBase.cs
@@ -0,0 +1,54 @@
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+
+namespace CQRS_Simple.Infrastructure
+{
+ public class Entity : IEntity
+ {
+ [Key] public virtual TPrimaryKey Id { get; set; }
+
+ private List _domainEvents;
+
+ ///
+ /// Domain events occurred.
+ ///
+ protected IReadOnlyCollection DomainEvents => _domainEvents?.AsReadOnly();
+
+ ///
+ /// Add domain event.
+ ///
+ ///
+ protected void AddDomainEvent(IDomainEvent domainEvent)
+ {
+ _domainEvents ??= new List();
+ _domainEvents.Add(domainEvent);
+ }
+
+ ///
+ /// Clead domain events.
+ ///
+ public void ClearDomainEvents()
+ {
+ _domainEvents?.Clear();
+ }
+
+ ///
+ public override int GetHashCode()
+ {
+ return Id == null ? 0 : Id.GetHashCode();
+ }
+
+ ///
+ public override string ToString()
+ {
+ return $"[{GetType().Name} {Id}]";
+ }
+ }
+
+ public interface IEntity
+ {
+ TPrimaryKey Id { get; set; }
+
+ void ClearDomainEvents();
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/IAggregateRoot.cs b/CQRS_Simple.Infrastructure/IAggregateRoot.cs
new file mode 100644
index 0000000..9628227
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/IAggregateRoot.cs
@@ -0,0 +1,5 @@
+namespace CQRS_Simple.Infrastructure
+{
+ public interface IAggregateRoot
+ { }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/IDomainEvent.cs b/CQRS_Simple.Infrastructure/IDomainEvent.cs
new file mode 100644
index 0000000..43b99bb
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/IDomainEvent.cs
@@ -0,0 +1,33 @@
+using System;
+
+namespace CQRS_Simple.Infrastructure
+{
+ public class DomainEvent : IDomainEvent
+ {
+ ///
+ /// The time when the event occurred.
+ ///
+ public DateTime EventTime { get; set; }
+
+ ///
+ /// The object which triggers the event (optional).
+ ///
+ public object EventSource { get; set; }
+
+ ///
+ /// Constructor.
+ ///
+ protected DomainEvent()
+ {
+ EventTime = DateTime.Now;
+ }
+
+ }
+
+ public interface IDomainEvent
+ {
+ DateTime EventTime { get; }
+
+ object EventSource { get; set; }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/IocManager.cs b/CQRS_Simple.Infrastructure/IocManager.cs
new file mode 100644
index 0000000..0928314
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/IocManager.cs
@@ -0,0 +1,29 @@
+using Autofac;
+
+namespace CQRS_Simple.Infrastructure
+{
+
+ public interface IIocManager
+ {
+ ILifetimeScope AutofacContainer { get; set; }
+ TService GetInstance();
+
+ }
+
+ public class IocManager : IIocManager
+ {
+ public IocManager(ILifetimeScope container)
+ {
+ AutofacContainer = container;
+ }
+ ///
+ /// Autofac容器
+ ///
+ public ILifetimeScope AutofacContainer { get; set; }
+
+ public TService GetInstance()
+ {
+ return AutofacContainer.Resolve();
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/MQ/RabbitData.cs b/CQRS_Simple.Infrastructure/MQ/RabbitData.cs
new file mode 100644
index 0000000..a11b449
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/MQ/RabbitData.cs
@@ -0,0 +1,19 @@
+using System;
+
+namespace CQRS_Simple.API.Products.Handlers
+{
+ public class RabbitData
+ {
+ public string Type { get; private set; }
+ public object Request { get; private set; }
+
+ public object Result { get; private set; }
+
+ public RabbitData(Type type, object request, object result = null)
+ {
+ Type = $"{type}";
+ Request = request;
+ Result = result;
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/MQ/RabbitListener.cs b/CQRS_Simple.Infrastructure/MQ/RabbitListener.cs
new file mode 100644
index 0000000..e65251f
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/MQ/RabbitListener.cs
@@ -0,0 +1,102 @@
+using System;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Options;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+using Serilog;
+
+namespace CQRS_Simple.Infrastructure.MQ
+{
+ public class RabbitListener : IHostedService
+ {
+ private readonly RabbitMQOptions _options;
+ private readonly IConnection connection;
+ private readonly IModel channel;
+
+ public RabbitListener(
+ IOptions optionsAccessor
+ )
+ {
+ _options = optionsAccessor.Value;
+ try
+ {
+ var factory = new ConnectionFactory()
+ {
+ UserName = _options.UserName,
+ Password = _options.Password,
+ HostName = _options.HostName,
+ Port = _options.Port
+ };
+ this.connection = factory.CreateConnection();
+ this.channel = connection.CreateModel();
+ Log.Information($"RabbitMQ 连接成功");
+
+ }
+ catch (Exception ex)
+ {
+ Log.Error($"RabbitListener init error,ex:{ex.Message}");
+ }
+ }
+
+
+ public async Task StartAsync(CancellationToken cancellationToken)
+ {
+ await Register();
+ await Task.CompletedTask;
+ }
+
+ protected string QueueName= "QueueName";
+ protected string RouteKey;
+
+ // 处理消息的方法
+ public virtual async Task Register()
+ {
+ channel.ExchangeDeclare("message", ExchangeType.Topic, true, false, null);
+ channel.QueueDeclare(QueueName, true, false, false, null);
+
+ channel.QueueBind(queue: QueueName, exchange: "message", routingKey: RouteKey);
+
+ var consumer = new EventingBasicConsumer(channel);
+
+ consumer.Received += async (model, ea) =>
+ {
+ var body = ea.Body;
+ var message = Encoding.UTF8.GetString(body.ToArray());
+ var result = await ProcessAsync(message);
+ Log.Information($"收到消息： {message} routerKey: { ea.RoutingKey}");
+ if (result)
+ {
+ channel.BasicAck(ea.DeliveryTag, false);
+ }
+ await Task.Yield();
+ };
+ channel.BasicConsume(queue: QueueName, consumer: consumer);
+
+ await Task.CompletedTask;
+ }
+
+ public virtual Task ProcessAsync(string message)
+ {
+ throw new NotImplementedException();
+ }
+
+ public Task StopAsync(CancellationToken cancellationToken)
+ {
+ channel?.Dispose();
+ connection?.Dispose();
+ return Task.CompletedTask;
+ }
+ }
+
+ public class RabbitMQOptions
+ {
+ public string UserName { get; set; }
+ public string Password { get; set; }
+ public string HostName { get; set; }
+ public int Port { get; set; }
+ public string QueryName { get; set; }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/MQ/RabbitPublisher.cs b/CQRS_Simple.Infrastructure/MQ/RabbitPublisher.cs
new file mode 100644
index 0000000..dd87110
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/MQ/RabbitPublisher.cs
@@ -0,0 +1,71 @@
+using System;
+using System.Text;
+using Microsoft.Extensions.Options;
+using Newtonsoft.Json;
+using RabbitMQ.Client;
+using Serilog;
+
+namespace CQRS_Simple.Infrastructure.MQ
+{
+ public class RabbitMQClient : IDisposable
+ {
+ private readonly RabbitMQOptions _options;
+
+ private IModel _channel;
+ private IConnection _connection;
+
+ public RabbitMQClient(
+ IOptions optionsAccessor
+ )
+ {
+ _options = optionsAccessor.Value;
+ try
+ {
+ var factory = new ConnectionFactory()
+ {
+ UserName = _options.UserName,
+ Password = _options.Password,
+ HostName = _options.HostName,
+ Port = _options.Port
+ };
+ this._connection = factory.CreateConnection();
+ this._channel = _connection.CreateModel();
+ Log.Information($"RabbitMQ Client 连接成功");
+ }
+ catch (Exception ex)
+ {
+ Console.WriteLine($"RabbitListener init error,ex:{ex.Message}");
+ }
+ }
+
+ public virtual void PushMessage(object message, string queryName = null, string routerKey = "Test.*")
+ {
+ if (queryName == null)
+ queryName = _options.QueryName;
+
+ var exchangeName = "message";
+
+ Log.Debug($"PushMessage queryName:{queryName} routingKey:{routerKey}");
+
+ //定义一个Direct类型交换机
+ _channel.ExchangeDeclare(exchangeName, ExchangeType.Topic, true, false, null);
+
+ //定义一个队列
+ _channel.QueueDeclare(queryName, true, false, false, null);
+
+ //将队列绑定到交换机
+ _channel.QueueBind(queryName, exchangeName, routerKey, null);
+
+ var sendBytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(message));
+
+ _channel.BasicPublish(exchangeName, routerKey, null, sendBytes);
+ }
+
+ public void Dispose()
+ {
+ _channel?.Dispose();
+ _connection?.Dispose();
+ Log.Information($"RabbitMQ Client Dispose");
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/TimeInterceptor.cs b/CQRS_Simple.Infrastructure/TimeInterceptor.cs
new file mode 100644
index 0000000..c60e7a7
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/TimeInterceptor.cs
@@ -0,0 +1,40 @@
+using System;
+using System.IO;
+using System.Linq;
+using Castle.DynamicProxy;
+
+
+namespace CQRS_Simple.Infrastructure
+{
+ ///
+ /// 拦截器 需要实现 IInterceptor接口 Intercept方法
+ ///
+ public class CallLogger : IInterceptor
+ {
+ TextWriter _output;
+
+ public CallLogger(TextWriter output)
+ {
+ _output = output;
+ }
+
+ ///
+ /// 拦截方法 打印被拦截的方法执行前的名称、参数和方法执行后的 返回结果
+ ///
+ /// 包含被拦截方法的信息
+ public void Intercept(IInvocation invocation)
+ {
+ if (invocation.Method.IsPublic)
+ {
+ _output.WriteLine("你正在调用方法 \"{0}\" 参数是 {1}... ",
+ invocation.Method.Name,
+ string.Join(", ", invocation.Arguments.Select(a => (a ?? "").ToString()).ToArray()));
+
+ //在被拦截的方法执行完毕后 继续执行
+ invocation.Proceed();
+
+ _output.WriteLine("方法执行完毕，返回结果：{0}", invocation.ReturnValue);
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Uow/IRepository.cs b/CQRS_Simple.Infrastructure/Uow/IRepository.cs
new file mode 100644
index 0000000..8d05d8d
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Uow/IRepository.cs
@@ -0,0 +1,21 @@
+using System;
+using System.Collections.Generic;
+using System.Linq.Expressions;
+using System.Threading.Tasks;
+
+namespace CQRS_Simple.Infrastructure.Uow
+{
+ public interface IRepository where T : Entity
+ {
+ IUnitOfWork UnitOfWork { get; }
+ T GetById(TC id);
+ Task GetByIdAsync(TC id);
+ IEnumerable GetAll();
+ IEnumerable Get(Expression> predicate);
+ void Add(T entity);
+ void Delete(T entity);
+ void Update(T entity);
+
+ Task> GetAllAsync();
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Uow/IUnitOfWork.cs b/CQRS_Simple.Infrastructure/Uow/IUnitOfWork.cs
new file mode 100644
index 0000000..225372d
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Uow/IUnitOfWork.cs
@@ -0,0 +1,16 @@
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Threading.Tasks;
+
+namespace CQRS_Simple.Infrastructure.Uow
+{
+ public interface IUnitOfWork : IDisposable
+ {
+ DbContext Context { get; }
+ int SaveChanges();
+ Task SaveChangesAsync();
+
+ IRepository GetRepository() where T : Entity;
+ void PrintKey();
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Uow/Repository.cs b/CQRS_Simple.Infrastructure/Uow/Repository.cs
new file mode 100644
index 0000000..270ebcd
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Uow/Repository.cs
@@ -0,0 +1,60 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+
+namespace CQRS_Simple.Infrastructure.Uow
+{
+ public class Repository : IRepository where T : Entity
+ {
+ private readonly IUnitOfWork _unitOfWork;
+
+ public Repository(IUnitOfWork unitOfWork)
+ {
+ _unitOfWork = unitOfWork;
+ }
+ public void Add(T entity)
+ {
+ _unitOfWork.Context.Set().Add(entity);
+ }
+
+ public void Delete(T entity)
+ {
+ T existing = _unitOfWork.Context.Set().Find(entity);
+ if (existing != null) _unitOfWork.Context.Set().Remove(existing);
+ }
+
+ public IUnitOfWork UnitOfWork => _unitOfWork;
+
+ public T GetById(TPrimaryKey id)
+ {
+ return _unitOfWork.Context.Set().FirstOrDefault(x => id.Equals(x.Id));
+ }
+ public Task GetByIdAsync(TPrimaryKey id)
+ {
+ return _unitOfWork.Context.Set().FirstOrDefaultAsync(x => id.Equals(x.Id));
+ }
+
+ public IEnumerable GetAll()
+ {
+ return _unitOfWork.Context.Set().AsEnumerable();
+ }
+
+ public IEnumerable Get(System.Linq.Expressions.Expression> predicate)
+ {
+ return _unitOfWork.Context.Set().Where(predicate).AsEnumerable();
+ }
+
+ public void Update(T entity)
+ {
+ _unitOfWork.Context.Entry(entity).State = EntityState.Modified;
+ _unitOfWork.Context.Set().Attach(entity);
+ }
+
+ public async Task> GetAllAsync()
+ {
+ return await _unitOfWork.Context.Set().ToListAsync();
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Infrastructure/Uow/UnitOfWork.cs b/CQRS_Simple.Infrastructure/Uow/UnitOfWork.cs
new file mode 100644
index 0000000..427cebf
--- /dev/null
+++ b/CQRS_Simple.Infrastructure/Uow/UnitOfWork.cs
@@ -0,0 +1,116 @@
+using System;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Http.Features;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Storage;
+using Serilog;
+
+namespace CQRS_Simple.Infrastructure.Uow
+{
+ public class UnitOfWork : IUnitOfWork
+ {
+ private readonly IIocManager _iocManager;
+ private Guid KEY { get; }
+
+ public DbContext Context { get; }
+
+ public IDbContextTransaction Transaction;
+
+ public UnitOfWork(DbContext context, IIocManager iocManager)
+ {
+ _iocManager = iocManager;
+ Context = context;
+
+ Transaction = context.Database.BeginTransaction();
+
+ KEY = Guid.NewGuid();
+#if DEBUG
+ Log.Information($"UnitOfWork Init {KEY}");
+#endif
+ }
+ public int SaveChanges()
+ {
+ return Context.SaveChanges();
+ }
+
+ public async Task SaveChangesAsync()
+ {
+ return await CommitAsync();
+ }
+
+ public IRepository GetRepository() where T : Entity
+ {
+ return _iocManager.GetInstance>();
+ }
+
+ public void PrintKey()
+ {
+ Log.Information($"PrintKey:{KEY}");
+ }
+
+ ///
+ /// 手动清理
+ ///
+ public void CleanUp()
+ {
+ Commit();
+
+ Transaction?.Dispose();
+ Context?.Dispose();
+
+#if DEBUG
+ Log.Information($"Context CleanUp");
+#endif
+ }
+
+
+ private int Commit()
+ {
+ var result = 0;
+ try
+ {
+ result = Context.SaveChanges();
+ Transaction?.Commit();
+ return result;
+ }
+ catch (Exception e)
+ {
+ result = -1;
+ Transaction?.Rollback();
+ Log.Error("Context Transaction Error");
+ Log.Error(e.Message);
+ }
+ return result;
+ }
+ private async Task CommitAsync()
+ {
+ var result = 0;
+ try
+ {
+ result = await Context.SaveChangesAsync();
+ Transaction?.Commit();
+ return result;
+ }
+ catch (Exception e)
+ {
+ result = -1;
+ if (Transaction != null)
+ await Transaction.RollbackAsync();
+ Log.Error("Context Transaction Error");
+ Log.Error(e.Message);
+ }
+ return result;
+ }
+
+
+
+ public void Dispose()
+ {
+ Context?.Dispose();
+#if DEBUG
+ Log.Information($"Context Dispose");
+
+#endif
+ }
+ }
+}
\ No newline at end of file
diff --git a/CQRS_Simple.Tests/CQRS_Simple.Tests.csproj b/CQRS_Simple.Tests/CQRS_Simple.Tests.csproj
new file mode 100644
index 0000000..c12d880
--- /dev/null
+++ b/CQRS_Simple.Tests/CQRS_Simple.Tests.csproj
@@ -0,0 +1,26 @@
+
+
+
+ net6.0
+
+ false
+
+
+
+
+
+
+
+
+
+
+ all
+ runtime; build; native; contentfiles; analyzers; buildtransitive
+
+
+ all
+ runtime; build; native; contentfiles; analyzers; buildtransitive
+
+
+
+
diff --git a/CQRS_Simple.Tests/UnitTest1.cs b/CQRS_Simple.Tests/UnitTest1.cs
new file mode 100644
index 0000000..27da1c2
--- /dev/null
+++ b/CQRS_Simple.Tests/UnitTest1.cs
@@ -0,0 +1,14 @@
+using System;
+using Xunit;
+
+namespace CQRS_Simple.Tests
+{
+ public class UnitTest1
+ {
+ [Fact]
+ public void Test1()
+ {
+
+ }
+ }
+}
diff --git a/CQRS_Simple.sln b/CQRS_Simple.sln
new file mode 100644
index 0000000..010d1c1
--- /dev/null
+++ b/CQRS_Simple.sln
@@ -0,0 +1,58 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 16
+VisualStudioVersion = 16.0.29519.181
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CQRS_Simple.API", "CQRS_Simple.API\CQRS_Simple.API.csproj", "{0B262E43-DCAD-4FB5-B394-E4DEE455C605}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CQRS_Simple.Domain", "CQRS_Simple.Domain\CQRS_Simple.Domain.csproj", "{D3EA4B65-1A8C-4F16-ABF9-837CDBD78CB5}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CQRS_Simple.Infrastructure", "CQRS_Simple.Infrastructure\CQRS_Simple.Infrastructure.csproj", "{14AB059D-1475-4A91-AAF4-312FCB265E81}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CQRS_Simple.EntityFrameworkCore", "CQRS_Simple.EntityFrameworkCore\CQRS_Simple.EntityFrameworkCore.csproj", "{F6AFAF16-2BA5-4789-9EE4-A6F75CBBF4F7}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Core", "Core", "{31A46403-BFDD-499A-8EC2-2EABDC096A47}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "API", "API", "{439AFE5F-24A5-4F70-9BEC-690E124C5D30}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CQRS_Simple.Tests", "CQRS_Simple.Tests\CQRS_Simple.Tests.csproj", "{824FCC5C-EE42-4AD8-8B00-DBC98EFA75A7}"
+EndProject
+Global
+ GlobalSection(SolutionConfigurationPlatforms) = preSolution
+ Debug|Any CPU = Debug|Any CPU
+ Release|Any CPU = Release|Any CPU
+ EndGlobalSection
+ GlobalSection(ProjectConfigurationPlatforms) = postSolution
+ {0B262E43-DCAD-4FB5-B394-E4DEE455C605}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {0B262E43-DCAD-4FB5-B394-E4DEE455C605}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {0B262E43-DCAD-4FB5-B394-E4DEE455C605}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {0B262E43-DCAD-4FB5-B394-E4DEE455C605}.Release|Any CPU.Build.0 = Release|Any CPU
+ {D3EA4B65-1A8C-4F16-ABF9-837CDBD78CB5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {D3EA4B65-1A8C-4F16-ABF9-837CDBD78CB5}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {D3EA4B65-1A8C-4F16-ABF9-837CDBD78CB5}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {D3EA4B65-1A8C-4F16-ABF9-837CDBD78CB5}.Release|Any CPU.Build.0 = Release|Any CPU
+ {14AB059D-1475-4A91-AAF4-312FCB265E81}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {14AB059D-1475-4A91-AAF4-312FCB265E81}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {14AB059D-1475-4A91-AAF4-312FCB265E81}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {14AB059D-1475-4A91-AAF4-312FCB265E81}.Release|Any CPU.Build.0 = Release|Any CPU
+ {F6AFAF16-2BA5-4789-9EE4-A6F75CBBF4F7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {F6AFAF16-2BA5-4789-9EE4-A6F75CBBF4F7}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {F6AFAF16-2BA5-4789-9EE4-A6F75CBBF4F7}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {F6AFAF16-2BA5-4789-9EE4-A6F75CBBF4F7}.Release|Any CPU.Build.0 = Release|Any CPU
+ {824FCC5C-EE42-4AD8-8B00-DBC98EFA75A7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {824FCC5C-EE42-4AD8-8B00-DBC98EFA75A7}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {824FCC5C-EE42-4AD8-8B00-DBC98EFA75A7}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {824FCC5C-EE42-4AD8-8B00-DBC98EFA75A7}.Release|Any CPU.Build.0 = Release|Any CPU
+ EndGlobalSection
+ GlobalSection(SolutionProperties) = preSolution
+ HideSolutionNode = FALSE
+ EndGlobalSection
+ GlobalSection(NestedProjects) = preSolution
+ {0B262E43-DCAD-4FB5-B394-E4DEE455C605} = {439AFE5F-24A5-4F70-9BEC-690E124C5D30}
+ {D3EA4B65-1A8C-4F16-ABF9-837CDBD78CB5} = {31A46403-BFDD-499A-8EC2-2EABDC096A47}
+ {14AB059D-1475-4A91-AAF4-312FCB265E81} = {31A46403-BFDD-499A-8EC2-2EABDC096A47}
+ EndGlobalSection
+ GlobalSection(ExtensibilityGlobals) = postSolution
+ SolutionGuid = {3BA00842-BEC3-4017-A48A-8EB7D8B1D18A}
+ EndGlobalSection
+EndGlobal
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..fb1067e
--- /dev/null
+++ b/README.md
@@ -0,0 +1,14 @@
+## 这是一个 DDD CQRS 的项目初始模版项目
+
+### 后端技术栈
+
+- .netcore 3.1
+- MediatR
+- EntityFrameworkCore 3.1
+- Dapper
+- RabbitMQ (Producer & Consumer )
+- AutoMapper 9
+- FluentValidation
+- IdentityServer4 (todo)
+- Serilog
+