using iWare.Wms.Core;
|
using Furion.ClayObject.Extensions;
|
using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.FriendlyException;
|
using Furion.JsonSerialization;
|
using Magicodes.ExporterAndImporter.Core;
|
using Magicodes.ExporterAndImporter.Excel;
|
using Mapster;
|
using Microsoft.AspNetCore.Http;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.EntityFrameworkCore;
|
using System.Linq.Expressions;
|
using Yitter.IdGenerator;
|
|
namespace iWare.Wms.Application
|
{
|
/// <summary>
|
/// 通用方法
|
/// </summary>
|
/// <typeparam name="TEntity"></typeparam>
|
/// <typeparam name="TSearchDto"></typeparam>
|
/// <typeparam name="TAddDto"></typeparam>
|
/// <typeparam name="TUpdateDto"></typeparam>
|
/// <typeparam name="TImportDto"></typeparam>
|
/// <typeparam name="TDetailDto"></typeparam>
|
/// <typeparam name="TPageListDto"></typeparam>
|
/// <typeparam name="TExportDto"></typeparam>
|
/// <typeparam name="TPrintDto"></typeparam>
|
public class BaseService<TEntity, TSearchDto, TAddDto, TUpdateDto, TImportDto, TDetailDto, TPageListDto, TExportDto, TPrintDto>
|
where TEntity : DEntityBase, new()
|
where TUpdateDto : BaseDto
|
where TSearchDto : PageInputBase
|
where TPageListDto : new()
|
where TExportDto : class, new()
|
where TImportDto : class, new()
|
{
|
/// <summary>
|
/// 数据仓储
|
/// </summary>
|
protected readonly IRepository<TEntity> Repository;
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
/// <param name="repository"></param>
|
public BaseService(IRepository<TEntity> repository)
|
{
|
Repository = repository;
|
}
|
|
#region 查询/分页查询
|
|
/// <summary>
|
/// 主键查询
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
public virtual async Task<TDetailDto> Get(long id)
|
{
|
var entity = await Repository.DetachedEntities.FirstOrDefaultAsync(e => e.Id == id);
|
return entity.Adapt<TDetailDto>();
|
}
|
|
/// <summary>
|
/// 分页搜索前
|
/// </summary>
|
protected Func<TSearchDto, Expression<Func<TEntity, bool>>> SearchExpression = null;
|
|
/// <summary>
|
/// 自定义分页搜索（复杂查询）
|
/// </summary>
|
protected Func<TSearchDto, IQueryable<TEntity>> SearchQueryable = null;
|
|
/// <summary>
|
/// 分页数据返回前处理
|
/// </summary>
|
/// <returns></returns>
|
protected Action<PageResult<TEntity>> PageListHandle = null;
|
|
/// <summary>
|
/// 分页查询
|
/// </summary>
|
/// <param name="searchDto"></param>
|
/// <returns></returns>
|
/// <exception cref="Exception"></exception>
|
[HttpPost("page")]
|
public virtual async Task<PageResult<TEntity>> PageList(TSearchDto searchDto)
|
{
|
IQueryable<TEntity> queryable;
|
if (SearchQueryable != null)
|
{
|
// 通过派生类中定义的委托方法自定义查询条件
|
queryable = SearchQueryable(searchDto);
|
}
|
else
|
{
|
// 动态构建查询条件
|
GetSearchParameters(searchDto);
|
queryable = Repository.DetachedEntities.Search(searchDto);
|
|
// 有自定义的查询条件
|
if (SearchExpression != null)
|
queryable = queryable.Where(SearchExpression(searchDto));
|
}
|
|
var pageList = await queryable.ToADPagedListAsync(searchDto.PageNo, searchDto.PageSize);
|
|
PageListHandle?.Invoke(pageList);
|
|
return pageList;
|
}
|
|
#endregion 查询/分页查询
|
|
#region 新增
|
|
/// <summary>
|
/// 新增前验证或处理
|
/// </summary>
|
protected Action<TAddDto> BeforeAddAction = null;
|
|
/// <summary>
|
/// 新增后处理
|
/// </summary>
|
protected Action<TEntity> AfterAddAction = null;
|
|
/// <summary>
|
/// 新增
|
/// </summary>
|
/// <param name="addDto"></param>
|
public virtual async Task Add(TAddDto addDto)
|
{
|
// 新增前操作
|
BeforeAddAction?.Invoke(addDto);
|
|
// 写数据
|
var entity = await addDto.Adapt<TEntity>().InsertAsync();
|
|
// 新增后操作
|
AfterAddAction?.Invoke(entity.Entity);
|
}
|
|
#endregion 新增
|
|
#region 删除/假删除
|
|
/// <summary>
|
/// 删除前验证或处理
|
/// </summary>
|
protected Action<List<long>> BeforeDeleteAction = null;
|
|
/// <summary>
|
/// 删除后处理
|
/// </summary>
|
protected Action<List<long>, int> AfterDeleteAction = null;
|
|
/// <summary>
|
/// 删除
|
/// </summary>
|
/// <param name="ids"></param>
|
public virtual async Task Delete(List<long> ids)
|
{
|
BeforeDeleteAction?.Invoke(ids);
|
var count = await Repository.Context.DeleteRangeAsync<TEntity>(x => ids.Contains(x.Id));
|
|
AfterDeleteAction?.Invoke(ids, count);
|
}
|
|
/// <summary>
|
/// 假删除前验证或处理
|
/// </summary>
|
protected Action<List<long>> BeforeFakeDeleteAction = null;
|
|
/// <summary>
|
/// 假删除后处理
|
/// </summary>
|
protected Action<List<long>, int> AfterFakeDeleteAction = null;
|
|
/// <summary>
|
/// 假删除
|
/// </summary>
|
/// <param name="ids"></param>
|
[HttpDelete("fakeDelete")]
|
public virtual async Task FakeDelete(List<long> ids)
|
{
|
BeforeFakeDeleteAction?.Invoke(ids);
|
|
var count = await Repository.Context.BatchUpdate<TEntity>()
|
.Set(x => x.IsDeleted, x => true)
|
.Where(x => ids.Contains(x.Id))
|
.ExecuteAsync();
|
|
AfterFakeDeleteAction?.Invoke(ids, count);
|
}
|
|
#endregion 删除/假删除
|
|
#region 修改
|
|
/// <summary>
|
/// 更新前验证或处理
|
/// </summary>
|
protected Action<TUpdateDto> BeforeUpdateAction = null;
|
|
/// <summary>
|
/// 更新后处理
|
/// </summary>
|
protected Action<TEntity> AfterUpdateAction = null;
|
|
/// <summary>
|
/// 修改
|
/// </summary>
|
/// <param name="updateDto"></param>
|
[HttpPut("edit")]
|
public virtual async Task Update(TUpdateDto updateDto)
|
{
|
BeforeUpdateAction?.Invoke(updateDto);
|
var entity = await updateDto.Adapt<TEntity>().UpdateAsync(true);
|
AfterUpdateAction?.Invoke(entity.Entity);
|
}
|
|
#endregion 修改
|
|
#region 导入
|
|
/// <summary>
|
/// 导入模版下载
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet("importTemplate")]
|
public virtual async Task<FileContentResult> ImportTemplate()
|
{
|
// 创建Excel导入对象
|
IImporter importer = new ExcelImporter();
|
var byteArray = await importer.GenerateTemplateBytes<TImportDto>();
|
|
// 文件名称
|
var fileName = typeof(TEntity).GetDescriptionValue<CommentAttribute>().Comment + "导入模版.xlsx";
|
|
return await Task.FromResult(
|
new FileContentResult(byteArray, "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
|
{
|
FileDownloadName = fileName
|
});
|
}
|
|
/// <summary>
|
/// 导入前验证或处理
|
/// </summary>
|
protected Action<IEnumerable<TImportDto>> BeforeImportAction = null;
|
|
/// <summary>
|
/// 导入后处理
|
/// </summary>
|
protected Action<IEnumerable<TImportDto>> AfterImportAction = null;
|
|
/// <summary>
|
/// 导入
|
/// </summary>
|
/// <param name="file"></param>
|
/// <exception cref="Exception"></exception>
|
[UnitOfWork]
|
public virtual async Task Import(IFormFile file)
|
{
|
var path = Path.Combine(Path.GetTempPath(), $"{YitIdHelper.NextId()}.xlsx");
|
await using (var stream = File.Create(path))
|
{
|
await file.CopyToAsync(stream);
|
}
|
|
// 创建Excel导入对象
|
IImporter importer = new ExcelImporter();
|
var import = await importer.Import<TImportDto>(path);
|
|
if (import == null)
|
throw Oops.Oh("导入模版解析异常");
|
if (import.Exception != null)
|
throw Oops.Oh("导入异常:" + import.Exception);
|
if (import.RowErrors.Count > 0)
|
throw Oops.Oh("数据校验:" + JSON.Serialize(import.RowErrors));
|
|
BeforeImportAction?.Invoke(import.Data);
|
|
await Repository.InsertAsync(import.Data.Adapt<ICollection<TEntity>>());
|
|
AfterImportAction?.Invoke(import.Data);
|
}
|
|
#endregion 导入
|
|
#region 导出
|
|
/// <summary>
|
/// 导出搜索前
|
/// </summary>
|
protected Func<TSearchDto, Expression<Func<TEntity, bool>>> ExportSearchExpression = null;
|
|
/// <summary>
|
/// 自定义导出搜索（复杂查询）
|
/// </summary>
|
protected Func<TSearchDto, IQueryable<TEntity>> ExportSearchQueryable = null;
|
|
/// <summary>
|
/// 导出数据返回前处理
|
/// </summary>
|
/// <returns></returns>
|
protected Action<PagedList<TEntity>> ExportHandle = null;
|
|
/// <summary>
|
/// 导出
|
/// </summary>
|
/// <param name="searchDto"></param>
|
/// <returns></returns>
|
[HttpGet("export")]
|
public virtual async Task<FileContentResult> Export(TSearchDto searchDto)
|
{
|
IQueryable<TEntity> queryable;
|
if (ExportSearchQueryable != null)
|
{
|
// 通过派生类中定义的委托方法自定义查询条件
|
queryable = ExportSearchQueryable(searchDto);
|
}
|
else
|
{
|
// 动态构建查询条件
|
GetSearchParameters(searchDto);
|
queryable = Repository.DetachedEntities.Search(searchDto);
|
|
// 有自定义的查询条件
|
if (ExportSearchExpression != null)
|
queryable = queryable.Where(ExportSearchExpression(searchDto));
|
}
|
|
var entitys = await queryable.ToListAsync();
|
|
// 创建Excel导出对象
|
IExporter exporter = new ExcelExporter();
|
|
// 导出文件
|
var byteArray = await exporter.ExportAsByteArray(entitys.Adapt<List<TExportDto>>());
|
|
// 文件名称
|
var fileName = typeof(TEntity).GetDescriptionValue<CommentAttribute>() + DateTime.Now.ToString("yyyyMMddHHssmm") + ".xlsx";
|
|
return await Task.FromResult(
|
new FileContentResult(byteArray, "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
|
{
|
FileDownloadName = fileName
|
});
|
}
|
|
#endregion 导出
|
|
#region 打印
|
|
/// <summary>
|
/// 获取打印数据 todo: 最简单的主键查询单条数据，后续实现单据打印模版模块
|
/// </summary>
|
/// <param name="id"></param>
|
[HttpGet("print")]
|
public virtual async Task<TPrintDto> Print(long id)
|
{
|
var entity = await Repository.DetachedEntities.FirstOrDefaultAsync(e => e.Id == id);
|
return entity.Adapt<TPrintDto>();
|
}
|
|
#endregion 打印
|
|
#region 私有方法
|
|
/// <summary>
|
/// 将查询dto组装成搜索参数
|
/// </summary>
|
/// <param name="searchDto"></param>
|
/// <returns></returns>
|
private void GetSearchParameters(TSearchDto searchDto)
|
{
|
// 如果没有复杂查询条件，把自定义查询dto中有内容的项加入查询条件
|
if (searchDto.SearchParameters != null && searchDto.SearchParameters.Any()) return;
|
|
// 查询dto转为字典
|
var searchDictionary = searchDto.ToDictionary();
|
|
// 取实体中的字段名称
|
var entityPropertieNames =
|
typeof(TEntity).GetProperties().Select(x => x.Name).ToList();
|
|
// 将searchDto中有值的属性加入复杂查询条件
|
foreach (var keyValuePair in searchDictionary)
|
{
|
// 跳过自定义属性和空值属性，自定义属性可在查询前委托中定义查询条件
|
if (!entityPropertieNames.Contains(keyValuePair.Key) || keyValuePair.Value == null) continue;
|
searchDto.SearchParameters.Add(new Condition()
|
{
|
Field = keyValuePair.Key,
|
Op = QueryTypeEnum.Equals,
|
Value = keyValuePair.Value
|
});
|
}
|
}
|
|
#endregion 私有方法
|
}
|
}
|
