using FreeSql;
using System.Linq.Expressions;
using Znyc.CloudCar.Auth.HttpContextUser;

namespace Znyc.CloudCar.Repository
{
    public abstract class RepositoryBase<TEntity, TKey> : BaseRepository<TEntity, TKey> where TEntity : class, new()
    {
        private readonly IHttpContextUser _user;

        protected RepositoryBase(UnitOfWorkManager uowm, IHttpContextUser user) : base(uowm.Orm, null)
        {
            uowm.Binding(this);
            _user = user;
        }

        /// <summary>
        /// 获取Dto
        /// </summary>
        /// <typeparam name="TDto"></typeparam>
        /// <param name="id"></param>
        /// <returns></returns>
        public virtual Task<TDto> GetAsync<TDto>(TKey id)
        {
            return Select.WhereDynamic(id).ToOneAsync<TDto>();
        }

        /// <summary>
        /// 根据条件获取实体
        /// </summary>
        /// <param name="exp"></param>
        /// <returns></returns>
        public virtual Task<TEntity> GetAsync(Expression<Func<TEntity, bool>> exp)
        {
            return Select.Where(exp).ToOneAsync<TEntity>();
        }

        /// <summary>
        /// 根据条件获取Dto
        /// </summary>
        /// <typeparam name="TDto"></typeparam>
        /// <param name="exp"></param>
        /// <returns></returns>
        public virtual Task<TDto> GetAsync<TDto>(Expression<Func<TEntity, bool>> exp)
        {
            return Select.Where(exp).ToOneAsync<TDto>();
        }

        /// <summary>
        /// 软删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public virtual async Task<bool> SoftDeleteAsync(TKey id)
        {
            await UpdateDiy
                .SetDto(new
                {
                    IsDeleted = true,
                    ModifiedUserId = _user.Id
                })
                .WhereDynamic(id)
                .ExecuteAffrowsAsync();
            return true;
        }

        /// <summary>
        /// 批量软删除
        /// </summary>
        /// <param name="ids"></param>
        /// <returns></returns>
        public virtual async Task<bool> SoftDeleteAsync(TKey[] ids)
        {
            await UpdateDiy
               .SetDto(new
               {
                   IsDeleted = true,
                   ModifiedUserId = _user.Id
               })
               .WhereDynamic(ids)
               .ExecuteAffrowsAsync();
            return true;
        }
    }
    public abstract class RepositoryBase<TEntity> : RepositoryBase<TEntity, long> where TEntity : class, new()
    {
        protected RepositoryBase(UnitOfWorkManager uowm, IHttpContextUser user) : base(uowm, user)
        {
        }
    }
}