SurgingDemo

旨在描述如何在 surging 的基础上运行dapper完成一个增删改的例子

1.在sqlserver中建立Test 数据库

2.运行Surging Demo

因为本示例项目没有从nuget 引用,直接从 surging 项目引用,没有拷贝一份放在自己的解决方案,

假设目录结构如下:

最终保持Surging和SurgingDemo在同一个目录

在 windows 中启动:

发布网关 1. ApiGateway dotnet run Surging.ApiGateway

启用服务 2. Server dotnet Bill.Demo.Services.Server.dll

发布客户端(本示例使用 web mvc) 3. Bill.Demo.Web dotnet run Bill.Demo.Web

介绍一下本示例各项目的职责

Bill.Demo.Core 用户定义数据模型

Bill.Demo.DapperCore (Dapper仓储,其中仓储需继承 UserRepository: Surging.Core.CPlatform.Ioc.BaseRepository)

public class UserRepository: BaseRepository, IBaseRepository<User>
 {
 /// <summary>
 /// 创建一个用户
 /// </summary>
 /// <param name="entity">用户</param>
 /// <param name="connectionString">链接字符串</param>
 /// <returns></returns>
 public Task<Boolean> CreateEntity(User entity, String connectionString = null)
 {
 using (IDbConnection conn = DataBaseConfig.GetSqlConnection(connectionString))
 {
 string insertSql = @"INSERT INTO dbo.auth_User
 ( TenantId ,
 Name ,
 Password ,
 SecurityStamp ,
 FullName ,
 Surname ,
 PhoneNumber ,
 IsPhoneNumberConfirmed ,
 EmailAddress ,
 IsEmailConfirmed ,
 EmailConfirmationCode ,
 IsActive ,
 PasswordResetCode ,
 LastLoginTime ,
 IsLockoutEnabled ,
 AccessFailedCount ,
 LockoutEndDateUtc
 )
 VALUES ( @tenantid ,
 @name ,
 @password ,
 @securitystamp ,
 @fullname ,
 @surname ,
 @phonenumber ,
 @isphonenumberconfirmed ,
 @emailaddress ,
 @isemailconfirmed ,
 @emailconfirmationcode ,
 @isactive ,
 @passwordresetcode ,
 @lastlogintime ,
 @islockoutenabled ,
 @accessfailedcount ,
 @lockoutenddateutc
 );";
 return Task.FromResult<Boolean>(conn.Execute(insertSql, entity) > 0);
 }
 }
 }

Bill.Demo.IModuleServices (和Surging项目一样,定义模块服务接口以及领域模型)

 Task<UserDto> GetUserById(Int64 id);
 
 Task<Boolean> UpdateUser(UserDto user);
 Task<Boolean> DeleteUser(Int64 userId);

Bill.Demo.ModuleServices (和Surging项目一样,实现模块服务)

 public async Task<UserDto> GetUserById(Int64 id)
 {
 var user = await _repository.GetEntityById(id);
 return new UserDto()
 {
 Id = user.Id,
 EmailAddress = user.EmailAddress,
 Name = user.Name,
 PhoneNumber = user.PhoneNumber,
 Surname = user.Surname,
 TenantId = user.TenantId,
 FullName = user.FullName,
 };
 }
 public async Task<Boolean> UpdateUser(UserDto user)
 {
 var entity = await _repository.GetEntityById(user.Id);
 entity.Name = user.Name;
 entity.Password = user.Password;
 entity.FullName = user.FullName;
 entity.Surname = user.Surname;
 entity.EmailAddress = user.EmailAddress;
 entity.PhoneNumber = user.PhoneNumber;
 return await _repository.Update(entity);
 }
 public async Task<Boolean> DeleteUser(Int64 userId)
 {
 return await _repository.Delete(userId);
 }

Bill.Demo.Services.Server 服务

Bill.Demo.Web 客户端

 public async Task<IActionResult> Delete(Int64 id)
 {
 var service = ServiceLocator.GetService<IServiceProxyFactory>();
 var userProxy = service.CreateProxy<IUserService>("User");
 await userProxy.DeleteUser(id);
 return RedirectToAction("User");
 }
 public async Task<JsonResult> GetUser(Int64 id)
 {
 var service = ServiceLocator.GetService<IServiceProxyFactory>();
 var userProxy = service.CreateProxy<IUserService>("User");
 var output= await userProxy.GetUserById(id);
 return new JsonResult(output);
 }
 public async Task<JsonResult> Update(UserDto dto)
 {
 var service = ServiceLocator.GetService<IServiceProxyFactory>();
 var userProxy = service.CreateProxy<IUserService>("User");
 var output = await userProxy.UpdateUser(dto);
 return new JsonResult(output);
 }