using Infrastructure;
using OpenAuth.App.BaseApp.Base;
using OpenAuth.App.Interface;
using OpenAuth.Repository;
using OpenAuth.Repository.Domain;
using SqlSugar;

namespace OpenAuth.App.ServiceApp;

public class LasaAircraftServiceApp : SqlSugarBaseApp<LasaAircraft, SugarDbContext>
{
    public LasaAircraftServiceApp(ISugarUnitOfWork<SugarDbContext> unitWork,
        ISimpleClient<LasaAircraft> repository, IAuth auth) : base(unitWork, repository, auth)
    {
    }

    public async Task<Response<bool>> AddLasaAircraft(LasaAircraft info)
    {
        info.Id = Guid.NewGuid().ToString();
        info.CreateTime = DateTime.Now;
        if (await Repository.InsertAsync(info))
        {
            return new Response<bool>
            {
                Result = true,
                Message = "添加成功"
            };
        }

        return new Response<bool>
        {
            Result = false,
            Message = "添加失败"
        };
    }

    public async Task<Response<bool>> DeleteLasaAircraft(string id)
    {
        if (await Repository.DeleteByIdAsync(id))
        {
            return new Response<bool>
            {
                Result = true,
                Message = "删除成功"
            };
        }

        return new Response<bool>
        {
            Result = false,
            Message = "删除失败"
        };
    }

    public async Task<Response<bool>> UpdateLasaAircraft(LasaAircraft info)
    {
        info.UpdateTime = DateTime.Now;
        // 使用Updateable方法来避免空值更新问题
        using (var db = Repository.AsSugarClient())
        {
            var result = await Repository.AsSugarClient().Updateable(info).IgnoreNullColumns().ExecuteCommandAsync();
            if (result > 0)
            {
                return new Response<bool>
                {
                    Result = true,
                    Message = "修改成功"
                };
            }
        }


        return new Response<bool>
        {
            Result = false,
            Message = "修改失败"
        };
    }

    public async Task<Response<PageInfo<IEnumerable<LasaAircraft>>>> GetLasaAircraftList(string key, int page,
        int limit)
    {
        RefAsync<int> totalCount = 0;
        var pageList = await Repository.AsQueryable()
            .WhereIF(!string.IsNullOrEmpty(key), x => x.Name.Contains(key) || x.Sn.Contains(key))
            .ToPageListAsync(page, limit, totalCount);

        return new Response<PageInfo<IEnumerable<LasaAircraft>>>
        {
            Result = new PageInfo<IEnumerable<LasaAircraft>>
            {
                Items = pageList,
                Total = totalCount
            }
        };
    }

    public async Task<Response<LasaAircraft>> GetLasaAircraft(string id)
    {
        return new Response<LasaAircraft>
        {
            Result = await Repository.GetByIdAsync(id)
        };
    }
}