using Furion.DependencyInjection;
using Myshipping.Core.Entity;
using Mapster;

using SqlSugar;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace Myshipping.Core.Service;

/// <summary>
/// 员工服务
/// </summary>
public class SysEmpService : ISysEmpService, ITransient
{
    private readonly SqlSugarRepository<SysEmp> _sysEmpRep;  // 员工表仓储  

    private readonly ISysEmpExtOrgPosService _sysEmpExtOrgPosService;
    private readonly ISysEmpPosService _sysEmpPosService;
    private readonly ISysCacheService _sysCache;//缓存
    public SysEmpService(SqlSugarRepository<SysEmp> sysEmpRep, ISysCacheService sysCache,
                         ISysEmpExtOrgPosService sysEmpExtOrgPosService,
                         ISysEmpPosService sysEmpPosService)
    {
        _sysEmpRep = sysEmpRep;
        _sysEmpExtOrgPosService = sysEmpExtOrgPosService;
        _sysEmpPosService = sysEmpPosService;
        _sysCache = sysCache;
    }

    /// <summary>
    /// 获取用户员工相关信息（包括登录）
    /// </summary>
    /// <param name="empId"></param>
    /// <returns></returns>
    public async Task<EmpOutput> GetEmpInfo(long empId)
    {
        var empInfoOutput = new EmpOutput();
        var sysEmp = await _sysEmpRep.FirstOrDefaultAsync(u => u.Id == empId);
        if (sysEmp == null) return empInfoOutput;

        empInfoOutput = sysEmp.Adapt<EmpOutput>();
        empInfoOutput.ExtOrgPos = await _sysEmpExtOrgPosService.GetEmpExtOrgPosList(empId);
        empInfoOutput.Positions = await _sysEmpPosService.GetEmpPosList(empId);
        return empInfoOutput;
    }

    /// <summary>
    /// 获取用户员工相关信息
    /// </summary>
    /// <param name="empIds"></param>
    /// <returns></returns>
    public async Task<List<EmpOutput>> GetEmpInfo(List<long> empIds)
    {
        List<EmpOutput> empInfoOutputs = new List<EmpOutput>();
        List<SysEmp> sysEmps=await _sysEmpRep.Where(m=>empIds.Contains(m.Id)).ToListAsync();
        if (sysEmps == null || !sysEmps.Any()) return empInfoOutputs;
        empInfoOutputs = sysEmps.Adapt<List<EmpOutput>>();

        var extOrgPoses = await _sysEmpExtOrgPosService.GetEmpExtOrgPosList(empIds);
        var positions = await _sysEmpPosService.GetEmpPosList(empIds);

        foreach (var empInfoOutput in empInfoOutputs)
        {
            empInfoOutput.ExtOrgPos = extOrgPoses.Where(m => m.SysEmpId == empInfoOutput.Id).ToList();
            empInfoOutput.Positions = positions.Where(m => m.SysEmpId == empInfoOutput.Id).ToList();
        }
        return empInfoOutputs;
    }

    /// <summary>
    /// 增加或编辑员工相关信息
    /// </summary>
    /// <returns></returns>
    public async Task AddOrUpdate(EmpOutput2 sysEmpParam)
    {
        try
        {
            _sysEmpRep.CurrentBeginTran();
            // 先删除员工信息
            await _sysEmpRep.DeleteAsync(u => u.Id == long.Parse(sysEmpParam.Id));

            // 再新增新员工信息
            var emp = sysEmpParam.Adapt<SysEmp>();
            await _sysEmpRep.InsertAsync(emp);

            // 更新附属机构职位信息
            await _sysEmpExtOrgPosService.AddOrUpdate(emp.Id, sysEmpParam.ExtIds);

            // 更新职位信息
            await _sysEmpPosService.AddOrUpdate(emp.Id, sysEmpParam.PosIdList);
            var Emp  = await _sysEmpRep.AsQueryable().ToListAsync();
            _sysCache.Set(CommonConst.CACHE_KEY_SysEmp, Emp);
            _sysEmpRep.CurrentCommitTran();
        }
        catch (System.Exception)
        {
            _sysEmpRep.CurrentRollbackTran();
            throw;
        }
       
    }

    /// <summary>
    /// 修改员工相关机构信息
    /// </summary>
    /// <param name="orgId"></param>
    /// <param name="orgName"></param>
    /// <returns></returns>
    public async Task UpdateEmpOrgInfo(long orgId, string orgName)
    {
        var emps = await _sysEmpRep.Where(u => u.OrgId == orgId).ToListAsync();
        emps.ForEach(u =>
        {
            u.OrgName = orgName;
        });
        await _sysEmpRep.UpdateAsync(emps);
        var Emp = await _sysEmpRep.AsQueryable().ToListAsync();
        _sysCache.Set(CommonConst.CACHE_KEY_SysEmp, Emp);
    }

    /// <summary>
    /// 根据机构Id判断该机构下是否有员工
    /// </summary>
    /// <param name="orgId"></param>
    /// <returns></returns>
    public async Task<bool> HasOrgEmp(long orgId)
    {
        return await _sysEmpRep.AnyAsync(u => u.OrgId == orgId);
    }

    /// <summary>
    /// 根据员工Id删除对应的员工表信息
    /// </summary>
    /// <param name="empId"></param>
    /// <returns></returns>
    public async Task DeleteEmpInfoByUserId(long empId)
    {
        try
        {
            _sysEmpRep.CurrentBeginTran();

            var emp = await _sysEmpRep.FirstOrDefaultAsync(u => u.Id == empId);
            // 级联删除对应的员工-附属信息
            await _sysEmpExtOrgPosService.DeleteEmpExtInfoByUserId(empId);

            // 级联删除对用的员工-职位信息
            await _sysEmpPosService.DeleteEmpPosInfoByUserId(empId);
            // 删除员工信息
            await _sysEmpRep.DeleteAsync(emp);
            var Emp = await _sysEmpRep.AsQueryable().ToListAsync();
            _sysCache.Set(CommonConst.CACHE_KEY_SysEmp, Emp);
            _sysEmpRep.CurrentCommitTran();
        }
        catch (System.Exception)
        {
            _sysEmpRep.CurrentRollbackTran();
            throw;
        }
       
    }

    /// <summary>
    /// 获取员工机构Id
    /// </summary>
    /// <param name="empId"></param>
    /// <returns></returns>
    public async Task<long> GetEmpOrgId(long empId)
    {
        return (await _sysEmpRep.FirstOrDefaultAsync(u => u.Id == empId)).OrgId;
    }

    /// <summary>
    /// 获取子机构用户
    /// </summary>
    /// <param name="orgIds"></param>
    /// <returns></returns>
    public async Task<List<SysEmp>> HasOrgEmp(List<long> orgIds)
    {
        return await _sysEmpRep.Where(u => orgIds.Contains(u.OrgId)).ToListAsync();
    }
}