OA2023/OASystem/OASystem.Infrastructure/Repositories/PersonnelModule/CompanyDailyKpiRepository.cs

using AutoMapper;
using OASystem.Domain.Entities.PersonnelModule;
using OASystem.Domain.ViewModels.PersonnelModule;
using OASystem.Infrastructure.Repositories.System;

namespace OASystem.Infrastructure.Repositories.PersonnelModule
{
    /// <summary>
    /// 公司日常KPI考核仓储
    /// </summary>
    public class CompanyDailyKpiRepository : BaseRepository<Pm_CompanyDailyKpi, Pm_CompanyDailyKpi>
    {
        private readonly IMapper _mapper;
        private JsonView _jv;
        public CompanyDailyKpiRepository(SqlSugarClient sqlSugar,
            IMapper mapper,
            ApprovalProcessRepository approvalProcessRep)
            : base(sqlSugar)
        {
            _mapper = mapper;
            _jv = new JsonView() { Code = StatusCodes.Status400BadRequest, Msg = "操作失败!" };

        }

        /// <summary>
        /// 绩效模板数据（保持原方法签名）
        /// </summary>
        public async Task<(bool isSuccess, string msg, List<KpiTempTypeInfo> data)> KpiTemplateDataAsync(string depName, string jobName)
        {
            var result = new List<KpiTempTypeInfo>();
            // 获取配置
            var config = await _sqlSugar.Queryable<Sys_SetDataType>()
                .Where(x => x.IsDel == 0 && x.Id == 132)
                .FirstAsync();

            if (config?.Remark == null)
                return (false, "绩效考核-数据类型ID存储为空", result);

            var typeIds = JsonSerializer.Deserialize<List<int>>(config.Remark);
            if (typeIds?.Any() != true)
                return (false, "绩效考核-数据类型ID存储为空", result);

            // 构建查询
            var query = _sqlSugar.Queryable<Sys_SetData>()
                .LeftJoin<Sys_SetDataType>((sd, sdt) => sd.STid == sdt.Id)
                .Where((sd, sdt) => sd.IsDel == 0 && typeIds.Contains(sd.STid));

            // 条件过滤
            if (!string.IsNullOrWhiteSpace(depName))
                query = query.Where((sd, sdt) => sdt.Name.Contains(depName));

            if (!string.IsNullOrWhiteSpace(jobName))
                query = query.Where((sd, sdt) => sdt.Name.Contains(jobName));

            // 查询数据
            var data = await query
                .Select((sd, sdt) => new
                {
                    KpiTypeId = sd.STid,
                    KpiTypeName = sdt.Name,
                    KpiId = sd.Id,
                    KpiContent = sd.Remark,
                    KpiSort = sd.Name
                })
                .ToListAsync();

            if (data?.Any() != true)
                return (false, "绩效考核模板信息为空", result);

            // 分组处理
            result = data
                .GroupBy(x => new { x.KpiTypeId, x.KpiTypeName })
                .Select(g => new KpiTempTypeInfo()
                {
                    TypeId = g.Key.KpiTypeId,
                    TypeName = g.Key.KpiTypeName,
                    Contents = g
                        .OrderBy(x => int.TryParse(x.KpiSort, out int s) ? s : int.MaxValue)
                        .ThenBy(x => x.KpiSort)
                        .Select(x => new KpiTempContentInfo(x.KpiId, x.KpiContent, x.KpiSort))
                        .ToList()
                })
                .Where(g => g.Contents.Any())
                .OrderBy(g => g.TypeId)
                .ToList();

            return (true, "操作成功", result);
        }

        /// <summary>
        /// 获取部门和岗位
        /// </summary>
        public async Task<object> KpiDepartmentsAndJobs()
        {
            var config = await _sqlSugar.Queryable<Sys_SetDataType>()
                .Where(x => x.IsDel == 0 && x.Id == 132)
                .FirstAsync();

            if (config == null) return new { Success = false, Message = "配置为空" };

            var typeIds = JsonSerializer.Deserialize<List<int>>(config.Remark ?? "[]");
            if (typeIds == null || typeIds.Count < 1)
                return new { Success = false, Message = "类型ID为空" };

            var names = await _sqlSugar.Queryable<Sys_SetData>()
                .LeftJoin<Sys_SetDataType>((sd, sdt) => sd.STid == sdt.Id)
                .Where((sd, sdt) => sd.IsDel == 0 && typeIds.Contains(sd.STid))
                .Select((sd, sdt) => sdt.Name)
                .Distinct()
                .ToListAsync();

            // 解析部门和岗位
            var deptJobList = names
                .Select(name =>
                {
                    var clean = name.Split('（')[0].Trim();
                    string dept, job;

                    if (clean.Contains(" - "))
                    {
                        var parts = clean.Split(" - ");
                        dept = parts[0].EndsWith("部") ? parts[0] : parts[0] + "部";
                        job = parts.Length > 1 ? parts[1] : "通用";
                    }
                    else if (clean.Contains("-"))
                    {
                        var parts = clean.Split('-');
                        dept = parts[0].EndsWith("部") ? parts[0] : parts[0] + "部";
                        job = parts.Length > 1 ? parts[1] : "通用";
                    }
                    else
                    {
                        dept = clean.EndsWith("部") ? clean : "未分类";
                        job = clean.EndsWith("部") ? "通用" : clean;
                    }

                    return new { Department = dept, Job = job };
                })
                .Where(x => x.Department != "未分类")
                .GroupBy(x => x.Department)
                .Select(g => new
                {
                    Department = g.Key,
                    Jobs = g.Select(x => x.Job).Distinct().Where(j => j != "通用").OrderBy(j => j).ToList()
                })
                .OrderBy(g => g.Department)
                .ToList();

            return new
            {
                Success = true,
                Departments = deptJobList.Select(g => g.Department).ToList(),
                DepartmentsWithJobs = deptJobList
            };
        }


        #region 财务部日常绩效
        /// <summary>
        /// 基础数据
        /// </summary>
        /// <returns></returns>
        public async Task<JsonView> FinanceInit()
        {
            var userInfos = await _sqlSugar.Queryable<Sys_Users>()
                .LeftJoin<Sys_JobPost>((u, jp) => u.JobPostId == jp.Id)
                .LeftJoin<Sys_Department>((u, jp, d) => u.DepId == d.Id)
                .LeftJoin<Sys_Company>((u, jp, d, c) => u.CompanyId == c.Id)
                .Where((u, jp, d, c) => u.IsDel == 0)
                .Select((u, jp, d, c) => new
                {
                    UserId = u.Id,
                    u.CompanyId,
                    c.CompanyName,
                    u.DepId,
                    d.DepName,
                    u.JobPostId,
                    jp.JobName,
                    UserName = u.CnName
                })
                .OrderBy(u => u.CompanyId)
                .ToListAsync();

            if (userInfos?.Any() != true)
            {
                _jv.Code = StatusCodes.Status200OK;
                _jv.Msg = $"暂无人员数据";
                return _jv;
            }

            //转换为层级结构
            #region 层级转换 公司 -> 部门 -> 岗位 -> 人员
            //var result = userInfos
            //    .GroupBy(u => new { u.CompanyId, u.CompanyName })
            //    .Select(companyGroup => new
            //    {
            //        CompanyId = companyGroup.Key.CompanyId,
            //        CompanyName = companyGroup.Key.CompanyName,
            //        Departments = companyGroup
            //            .GroupBy(u => new { u.DepId, u.DepName })
            //            .Select(departmentGroup => new
            //            {
            //                DepId = departmentGroup.Key.DepId,
            //                DepartmentName = departmentGroup.Key.DepName,
            //                JobPosts = departmentGroup
            //                    .GroupBy(u => new { u.JobPostId, u.JobName })
            //                    .Select(jobGroup => new
            //                    {
            //                        JobPostId = jobGroup.Key.JobPostId,
            //                        JobName = jobGroup.Key.JobName,
            //                        Employees = jobGroup
            //                            .Select(u => new
            //                            {
            //                                Id = u.UserId,
            //                                UserName = u.UserName,
            //                            })
            //                            .OrderBy(e => e.UserName)
            //                            .ToList()
            //                    })
            //                    .OrderBy(j => j.JobName)
            //                    .ToList()
            //            })
            //            .OrderBy(d => d.DepartmentName)
            //            .ToList()
            //    })
            //    .OrderBy(c => c.CompanyName)
            //    .ToList();
            #endregion

            //转换为层级结构
            #region 层级转换 公司 -> 部门 -> 人员
            // 构建树形结构
            var result = userInfos
                .GroupBy(u => new { u.CompanyId, u.CompanyName })
                .Select(companyGroup => new
                {
                    CompanyId = companyGroup.Key.CompanyId,
                    CompanyName = companyGroup.Key.CompanyName,
                    Departments = companyGroup
                        .GroupBy(u => new { u.DepId, u.DepName })
                        .Where(deptGroup => deptGroup.Key.DepId > 0) // 过滤掉无部门的人员
                        .Select(deptGroup => new
                        {
                            DepartmentId = deptGroup.Key.DepId,
                            DepartmentName = deptGroup.Key.DepName,
                            Users = deptGroup
                                .Select(u => new
                                {
                                    u.UserId,
                                    u.UserName,
                                    u.JobPostId,
                                    u.JobName
                                })
                                .OrderBy(u => u.UserName)
                                .ToList()
                        })
                        .Where(dept => dept.Users.Any())
                        .OrderBy(dept => dept.DepartmentName)
                        .ToList(),
                    // 无部门的人员（直接挂载到公司下）
                    NoDepartmentUsers = companyGroup
                        .Where(u => u.DepId <= 0)
                        .Select(u => new
                        {
                            u.UserId,
                            u.UserName,
                            u.JobPostId,
                            u.JobName
                        })
                        .OrderBy(u => u.UserName)
                        .ToList()
                })
                .OrderBy(c => c.CompanyName)
                .ToList();
            #endregion

            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = result;
            _jv.Msg = $"操作成功";
            return _jv;
        }

        /// <summary>
        /// 日常考勤详情
        /// </summary>
        /// <param name="month">月份 2025-12</param>
        /// <param name="userId">考核人</param>
        /// <returns></returns>
        public async Task<JsonView> FinanceInfo(string month, int evaluator)
        {
            if (string.IsNullOrEmpty(month))
            {
                _jv.Msg = $"请选择月份！";
                return _jv;
            }

            // 格式：2025-11
            const string pattern = @"^(\d{4})-(0[1-9]|1[0-2])$";
            if (!Regex.IsMatch(month, pattern))
            {
                _jv.Msg = $"请选择正确的月份！格式：2025-12";
                return _jv;
            }
            var evaluatorInfo = await _sqlSugar.Queryable<Sys_Users>()
                .LeftJoin<Sys_Company>((u, c) => u.CompanyId == c.Id)
                .LeftJoin<Sys_Department>((u, c, d) => u.DepId == d.Id)
                .LeftJoin<Sys_JobPost>((u, c, d, jp) => u.JobPostId == d.Id)
                .Where((u, c, d, jp) => u.IsDel == 0)
                .Select((u, c, d, jp) => new
                {
                    UserId = u.Id,
                    u.CompanyId,
                    c.CompanyName,
                    u.DepId,
                    d.DepName,
                    u.JobPostId,
                    jp.JobName,
                    UserName = u.CnName
                })
                .FirstAsync();
            if (evaluatorInfo == null)
            {
                _jv.Msg = $"请选择有效的考核人！";
                return _jv;
            }

            var info = await _sqlSugar
                .Queryable<Pm_CompanyDailyKpi>()
                .LeftJoin<Sys_SetData>((cdk, sd) => cdk.EvalContent == sd.Id)
                .LeftJoin<Sys_Users>((cdk, sd, u) => cdk.Evaluator == u.Id)
                .Where((cdk, sd, u) => cdk.IsDel == 0 && cdk.Evaluator == evaluator && cdk.Month.Equals(month))
                .Select((cdk, sd, u) => new CompanyDailyKpiView()
                {
                    Id = cdk.Id,
                    Month = cdk.Month,
                    EvaluatorId = cdk.Evaluator,
                    Evaluator = u.CnName,
                    EvalContentId = cdk.EvalContent,
                    EvalContent = sd.Remark,
                    IsMistake = cdk.IsMistake,
                    MistakeReason = cdk.MistakeReason
                })
                .ToListAsync();

            if (!info.Any())
            {
                var tempInfo = await KpiTemplateDataAsync(evaluatorInfo.DepName, evaluatorInfo.JobName);
                if (!tempInfo.isSuccess)
                {
                    _jv.Msg = $"{evaluatorInfo.DepName} - {evaluatorInfo.JobName},未配置日常绩效考核。";
                    return _jv;
                }

                tempInfo.data.ForEach(t =>
                {
                    t.Contents.ForEach(c =>
                    {
                        info.Add(new CompanyDailyKpiView()
                        {
                            Month = month,
                            EvaluatorId = evaluatorInfo.UserId,
                            Evaluator = evaluatorInfo.UserName,
                            EvalContentId = c.KpiId,
                            EvalContent = c.KpiContent,
                            IsMistake = false,
                            MistakeReason = string.Empty
                        });
                    });
                });

            }
            _jv.Code = StatusCodes.Status200OK;
            _jv.Data = info;
            _jv.Msg = $"操作成功";
            return _jv;
        }

        #endregion

    }
}