update:修改项目名称从Dilon到Ewide
This commit is contained in:
94
Api/Ewide.Core/Service/Tenant/Dto/TenantInput.cs
Normal file
94
Api/Ewide.Core/Service/Tenant/Dto/TenantInput.cs
Normal file
@@ -0,0 +1,94 @@
|
||||
using System.ComponentModel.DataAnnotations;
|
||||
|
||||
namespace Ewide.Core.Service
|
||||
{
|
||||
/// <summary>
|
||||
/// 租户参数
|
||||
/// </summary>
|
||||
public class TenantInput : PageInputBase
|
||||
{
|
||||
/// <summary>
|
||||
/// 名称
|
||||
/// </summary>
|
||||
public virtual string Name { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 主机
|
||||
/// </summary>
|
||||
public virtual string Host { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 电子邮箱
|
||||
/// </summary>
|
||||
public string Email { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 电话号码
|
||||
/// </summary>
|
||||
public string Phone { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 模式
|
||||
/// </summary>
|
||||
public string Schema { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 数据库连接
|
||||
/// </summary>
|
||||
public virtual string Connection { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 备注
|
||||
/// </summary>
|
||||
public string Remark { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 创建时间
|
||||
/// </summary>
|
||||
public string CreatedTime { get; set; }
|
||||
}
|
||||
|
||||
public class AddTenantInput : TenantInput
|
||||
{
|
||||
/// <summary>
|
||||
/// 租户名称
|
||||
/// </summary>
|
||||
[Required(ErrorMessage = "租户名称不能为空")]
|
||||
public override string Name { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 主机名称
|
||||
/// </summary>
|
||||
[Required(ErrorMessage = "主机名称不能为空")]
|
||||
public override string Host { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 数据库连接
|
||||
/// </summary>
|
||||
[Required(ErrorMessage = "数据库连接不能为空")]
|
||||
public override string Connection { get; set; }
|
||||
}
|
||||
|
||||
public class DeleteTenantInput
|
||||
{
|
||||
/// <summary>
|
||||
/// 租户Id
|
||||
/// </summary>
|
||||
[Required(ErrorMessage = "租户Id不能为空")]
|
||||
public string Id { get; set; }
|
||||
}
|
||||
|
||||
public class UpdateTenantInput : TenantInput
|
||||
{
|
||||
/// <summary>
|
||||
/// 租户Id
|
||||
/// </summary>
|
||||
[Required(ErrorMessage = "租户Id不能为空")]
|
||||
public string Id { get; set; }
|
||||
}
|
||||
|
||||
public class QueryTenantInput : DeleteTenantInput
|
||||
{
|
||||
|
||||
}
|
||||
}
|
||||
53
Api/Ewide.Core/Service/Tenant/Dto/TenantOutput.cs
Normal file
53
Api/Ewide.Core/Service/Tenant/Dto/TenantOutput.cs
Normal file
@@ -0,0 +1,53 @@
|
||||
namespace Ewide.Core.Service
|
||||
{
|
||||
/// <summary>
|
||||
/// 租户参数
|
||||
/// </summary>
|
||||
public class TenantOutput
|
||||
{
|
||||
/// <summary>
|
||||
/// 租户Id
|
||||
/// </summary>
|
||||
public long Id { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 名称
|
||||
/// </summary>
|
||||
public string Name { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 主机
|
||||
/// </summary>
|
||||
public string Host { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 电子邮箱
|
||||
/// </summary>
|
||||
public string Email { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 电话号码
|
||||
/// </summary>
|
||||
public string Phone { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 模式
|
||||
/// </summary>
|
||||
public string Schema { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 数据库连接
|
||||
/// </summary>
|
||||
public string Connection { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 备注
|
||||
/// </summary>
|
||||
public string Remark { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 创建时间
|
||||
/// </summary>
|
||||
public string CreatedTime { get; set; }
|
||||
}
|
||||
}
|
||||
14
Api/Ewide.Core/Service/Tenant/ISysTenantService.cs
Normal file
14
Api/Ewide.Core/Service/Tenant/ISysTenantService.cs
Normal file
@@ -0,0 +1,14 @@
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
using System.Threading.Tasks;
|
||||
|
||||
namespace Ewide.Core.Service
|
||||
{
|
||||
public interface ISysTenantService
|
||||
{
|
||||
Task AddTenant(AddTenantInput input);
|
||||
Task DeleteTenant(DeleteTenantInput input);
|
||||
Task<SysTenant> GetTenant([FromQuery] QueryTenantInput input);
|
||||
Task<dynamic> QueryTenantPageList([FromQuery] TenantInput input);
|
||||
Task UpdateTenant(UpdateTenantInput input);
|
||||
}
|
||||
}
|
||||
100
Api/Ewide.Core/Service/Tenant/SysTenantService.cs
Normal file
100
Api/Ewide.Core/Service/Tenant/SysTenantService.cs
Normal file
@@ -0,0 +1,100 @@
|
||||
using Furion.DatabaseAccessor;
|
||||
using Furion.DatabaseAccessor.Extensions;
|
||||
using Furion.DependencyInjection;
|
||||
using Furion.DynamicApiController;
|
||||
using Furion.FriendlyException;
|
||||
using Mapster;
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using System.Linq;
|
||||
using System.Threading.Tasks;
|
||||
|
||||
namespace Ewide.Core.Service
|
||||
{
|
||||
/// <summary>
|
||||
/// 租户服务
|
||||
/// </summary>
|
||||
[ApiDescriptionSettings(Name = "Tenant", Order = 100)]
|
||||
public class SysTenantService : ISysTenantService, IDynamicApiController, ITransient
|
||||
{
|
||||
private readonly IRepository<SysTenant, MultiTenantDbContextLocator> _sysTenantRep; // 租户表仓储
|
||||
|
||||
public SysTenantService(IRepository<SysTenant, MultiTenantDbContextLocator> sysTenantRep)
|
||||
{
|
||||
_sysTenantRep = sysTenantRep;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 分页查询租户
|
||||
/// </summary>
|
||||
/// <param name="input"></param>
|
||||
/// <returns></returns>
|
||||
[HttpGet("/sysTenant/page")]
|
||||
public async Task<dynamic> QueryTenantPageList([FromQuery] TenantInput input)
|
||||
{
|
||||
var name = !string.IsNullOrEmpty(input.Name?.Trim());
|
||||
var host = !string.IsNullOrEmpty(input.Host?.Trim());
|
||||
var tenants = await _sysTenantRep.DetachedEntities
|
||||
.Where((name, u => EF.Functions.Like(u.Name, $"%{input.Name.Trim()}%")),
|
||||
(host, u => EF.Functions.Like(u.Host, $"%{input.Host.Trim()}%")))
|
||||
.Select(u => u.Adapt<TenantOutput>())
|
||||
.ToPagedListAsync(input.PageNo, input.PageSize);
|
||||
return XnPageResult<TenantOutput>.PageResult(tenants);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 增加租户
|
||||
/// </summary>
|
||||
/// <param name="input"></param>
|
||||
/// <returns></returns>
|
||||
[HttpPost("/sysTenant/add")]
|
||||
public async Task AddTenant(AddTenantInput input)
|
||||
{
|
||||
var isExist = await _sysTenantRep.DetachedEntities.AnyAsync(u => u.Name == input.Name || u.Host == input.Host);
|
||||
if (isExist)
|
||||
throw Oops.Oh(ErrorCode.D1300);
|
||||
|
||||
var tenant = input.Adapt<SysTenant>();
|
||||
await _sysTenantRep.InsertAsync(tenant);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 删除租户
|
||||
/// </summary>
|
||||
/// <param name="input"></param>
|
||||
/// <returns></returns>
|
||||
[HttpPost("/sysTenant/delete")]
|
||||
public async Task DeleteTenant(DeleteTenantInput input)
|
||||
{
|
||||
var tenant = await _sysTenantRep.FirstOrDefaultAsync(u => u.Id == input.Id);
|
||||
await _sysTenantRep.DeleteAsync(tenant);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 更新租户
|
||||
/// </summary>
|
||||
/// <param name="input"></param>
|
||||
/// <returns></returns>
|
||||
[HttpPost("/sysTenant/edit")]
|
||||
public async Task UpdateTenant(UpdateTenantInput input)
|
||||
{
|
||||
var isExist = await _sysTenantRep.DetachedEntities.AnyAsync(u => (u.Name == input.Name || u.Host == input.Host) && u.Id != input.Id);
|
||||
if (isExist)
|
||||
throw Oops.Oh(ErrorCode.D1300);
|
||||
|
||||
var tenant = input.Adapt<SysTenant>();
|
||||
await _sysTenantRep.UpdateAsync(tenant, true);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 获取租户
|
||||
/// </summary>
|
||||
/// <param name="input"></param>
|
||||
/// <returns></returns>
|
||||
[HttpGet("/sysTenant/detail")]
|
||||
public async Task<SysTenant> GetTenant([FromQuery] QueryTenantInput input)
|
||||
{
|
||||
return await _sysTenantRep.DetachedEntities.FirstOrDefaultAsync(u => u.Id == input.Id);
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user