Yi.Admin/Yi.Framework.Net6/src/framework/Yi.Framework.Ddd/Services/CrudAppService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Yi.Framework.Core.Helper;
using Yi.Framework.Ddd.Dtos;
using Yi.Framework.Ddd.Entities;
using Yi.Framework.Ddd.Services.Abstract;

namespace Yi.Framework.Ddd.Services
{

    public abstract class CrudAppService<TEntity, TEntityDto, TKey>
    : CrudAppService<TEntity, TEntityDto, TKey, PagedAndSortedResultRequestDto>
    where TEntity : class, IEntity<TKey>
    where TEntityDto : IEntityDto<TKey>
    {
    }

    public abstract class CrudAppService<TEntity, TEntityDto, TKey, TGetListInput>
        : CrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TEntityDto>
        where TEntity : class, IEntity<TKey>
        where TEntityDto : IEntityDto<TKey>
    {
    }

    public abstract class CrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput>
        : CrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput, TCreateInput>
        where TEntity : class, IEntity<TKey>
        where TEntityDto : IEntityDto<TKey>
    {
    }




    public abstract class CrudAppService<TEntity, TEntityDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
    : CrudAppService<TEntity, TEntityDto, TEntityDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
    where TEntity : class, IEntity<TKey>
    where TEntityDto : IEntityDto<TKey>
    {
        protected override Task<TEntityDto> MapToGetListOutputDtoAsync(TEntity entity)
        {
            return MapToGetOutputDtoAsync(entity);
        }

    }

    public abstract class CrudAppService<TEntity, TGetOutputDto, TGetListOutputDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
        : ReadOnlyAppService<TEntity, TGetOutputDto, TGetListOutputDto, TKey, TGetListInput>,
     ICrudAppService<TGetOutputDto, TGetListOutputDto, TKey, TGetListInput, TCreateInput, TUpdateInput>
    where TEntity : class, IEntity<TKey>
    where TGetOutputDto : IEntityDto<TKey>
    where TGetListOutputDto : IEntityDto<TKey>

    {

        protected virtual Task<TEntity> MapToEntityAsync(TCreateInput createInput)
        {
            var entity = _mapper.Map<TEntity>(createInput);

            //这里判断实体的T，给id赋值

            //雪花id
            if (entity is IEntity<long> entityForlongId)
            {
                if (entityForlongId.Id is default(long))
                {
                    //使用反射，暂时先使用sqlsuga的雪花id提供
                    //ps: linshi
                    ReflexHelper.SetModelValue(nameof(IEntity<long>.Id), SnowflakeHelper.NextId, entity);
                }
            }


            return Task.FromResult(entity);
        }
        protected virtual Task MapToEntityAsync(TUpdateInput updateInput, TEntity entity)
        {
            _mapper.Map(updateInput, entity);
            return Task.CompletedTask;
        }

        protected virtual Task<TEntity> MapToEntityAsync(TUpdateInput updateInput)
        {
            var entity = _mapper.Map<TEntity>(updateInput);
            return Task.FromResult(entity);
        }

        /// <summary>
        /// 增
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<TGetOutputDto> CreateAsync(TCreateInput input)
        {
            var entity = await MapToEntityAsync(input);

            //这里还可以设置租户
            await _repository.InsertAsync(entity);

            return await MapToGetOutputDtoAsync(entity);
        }

        /// <summary>
        /// 删
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        /// <exception cref="ArgumentNullException"></exception>
        public async Task DeleteAsync(TKey id)
        {
            if (id is null)
            {
                throw new ArgumentNullException(nameof(id));
            }
            await _repository.DeleteByIdAsync(id);
        }

        /// <summary>
        /// 改
        /// </summary>
        /// <param name="id"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="ArgumentNullException"></exception>
        public virtual async Task<TGetOutputDto> UpdateAsync(TKey id, TUpdateInput input)
        {
            if (id is null)
            {
                throw new ArgumentNullException(nameof(id));
            }
            
            var entity = await MapToEntityAsync(input);
            entity.Id = id;
            await _repository.UpdateIgnoreNullAsync(entity);

            var newEntity = await _repository.GetByIdAsync(id);

            return await MapToGetOutputDtoAsync(newEntity);
        }
    }
}