using Dlhis.Basic.Organization.Request;
using Dlhis.Basic.Organization.Response;
using Dlhis.Entity.Basic.Entity;
using Dlhis.Entity.Basic.Enums;
using Kurisu.AspNetCore.Utils.Extensions;
using Kurisu.Core.DataAccess.Dto;
using Kurisu.SqlSugar.Attributes;
using Kurisu.SqlSugar.Extensions;
using Kurisu.SqlSugar.Services;
using Mapster;

namespace Dlhis.Basic.Organization.Services.Implements;

public class GainfoService : IGainfoService
{

    private readonly IGainfoStore _gainfoStore;
    private readonly IDbContext _dbContext;

    public GainfoService(IGainfoStore gainfoStore, IDbContext dbContext)
    {
        _gainfoStore = gainfoStore;
        _dbContext = dbContext;
    }

    /// <summary>
    /// 档案分页
    /// </summary>
    /// <param name="request"></param>
    /// <returns></returns>
    public Task<Pagination<GainfoPageResponse>> GetPageAsync(GainfoPageRequest request)
    {
        var page = _gainfoStore.Queryable(request.gainfoStatus)
            .Select<GainfoPageResponse>()
           .ToPageListAsync(request);

        return page;
    }

    /// <summary>
    ///保存档案号
    /// </summary>
    /// <param name="request"></param>
    /// <returns></returns>
    public async Task SaveAsync(GainfoSaveRequest request)
    {
        var gainfos = new List<GainfoEntity>();
        GainfoEntity aginfoEntity = request.Adapt<GainfoEntity>();

        aginfoEntity.Guestno = "F" + Guid.NewGuid().ToString();
        gainfos.Add(aginfoEntity);

        await _gainfoStore.InsertAsync(GainfoStatusEnumType.Working, gainfos);
    }


    /// <summary>
    ///修改档案号
    /// </summary>
    /// <param name="request"></param>
    /// <returns></returns>
    public async Task UpdateAsync(GainfoSaveRequest request)
    {
        var gainfo = await _gainfoStore.Queryable(request.GainfoStatus).Where(x => x.Id == request.Id).FirstAsync();
        gainfo.ThrowIfNull("档案数据不存在,无法更新");

        request.Adapt(gainfo);

        var gainfos = new List<GainfoEntity>()
        {
            gainfo
        };

        await _gainfoStore.UpdateAsync(request.GainfoStatus, gainfos);
    }

    /// <summary>
    /// 正式转离职
    /// </summary>
    /// <param name="request"></param>
    /// <returns></returns>
    /// <exception cref="NotImplementedException"></exception>
    [Transactional]
    public async Task DimissionAsync(GainfoDImissionRequest request)
    {
        var gainfo = await _gainfoStore.Queryable(GainfoStatusEnumType.Working)
            .Where(x => x.Guestno == request.UserId)
            .FirstAsync();
        gainfo.ThrowIfNull($"该档案不存在");

        //添加到离职表
        var gainfos = new List<GainfoEntity>
        {
            gainfo
        };

        await _gainfoStore.InsertAsync(GainfoStatusEnumType.Leave, gainfos);

        //删除原数据
        await _gainfoStore.DeleteAsync(GainfoStatusEnumType.Working, gainfos);
    }

    /// <summary>
    /// 临时转正式
    /// </summary>
    /// <param name="request"></param>
    /// <returns></returns>
    /// <exception cref="NotImplementedException"></exception>
    public async Task OnboardingAsync(GainfoDImissionRequest request)
    {
        var gainfo = await _gainfoStore.Queryable(GainfoStatusEnumType.External)
            .Where(x => x.Guestno == request.UserId)
            .FirstAsync();
        gainfo.ThrowIfNull($"该档案不存在");

        //添加到正式表
        var gainfos = new List<GainfoEntity>
        {
            gainfo
        };

        await _gainfoStore.InsertAsync(GainfoStatusEnumType.Working, gainfos);
    }

    /// <summary>
    /// 获取所有字段
    /// </summary>
    /// <returns></returns>
    public List<string> GetAllFields()
    {
        var entityType = typeof(Gainfofields);
        var propertyNames = entityType.GetProperties().Select(p => p.Name).ToList();

        return propertyNames;

    }

    /// <summary>
    /// 获取固定字段数据
    /// </summary>
    /// <param name="fieldName"></param>
    /// <returns></returns>
    public List<string> GetAllFieldData(string fieldName)
    {
        var columnData = _dbContext.Queryable<Gainfofields>().Select<string>(fieldName).ToList();

        return columnData;
    }

    //-------------------------------------------help methods ------------------------------------------------


}