AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Service/S8/S8MasterDataAdapter.cs

using Admin.NET.Plugin.AiDOP.Entity.S0.Manufacturing;
using Admin.NET.Plugin.AiDOP.Entity.S0.Warehouse;

namespace Admin.NET.Plugin.AiDOP.Service.S8;

public class S8MasterDataAdapter : ITransient
{
    private readonly SqlSugarRepository<AdoS0DepartmentMaster> _deptRep;
    private readonly SqlSugarRepository<AdoS0EmployeeMaster> _empRep;
    private readonly SqlSugarRepository<AdoS0LineMaster> _lineRep;
    private readonly SqlSugarRepository<SysUser> _sysUserRep;

    public S8MasterDataAdapter(
        SqlSugarRepository<AdoS0DepartmentMaster> deptRep,
        SqlSugarRepository<AdoS0EmployeeMaster> empRep,
        SqlSugarRepository<AdoS0LineMaster> lineRep,
        SqlSugarRepository<SysUser> sysUserRep)
    {
        _deptRep = deptRep;
        _empRep = empRep;
        _lineRep = lineRep;
        _sysUserRep = sysUserRep;
    }

    public async Task<object> GetDepartmentsAsync(long? factoryRefId) =>
        await _deptRep.AsQueryable()
            .WhereIF(factoryRefId.HasValue, x => x.FactoryRefId == factoryRefId!.Value)
            .Take(500)
            .Select(x => new { id = x.Id, code = x.Department, name = x.Descr ?? x.Department })
            .ToListAsync();

    public async Task<object> GetEmployeesAsync(long? factoryRefId)
    {
        // S8 选员工下拉：EmployeeMaster.tenant_id 与 SysUser.TenantId 历史错位（业务租户 ≠ 系统租户），
        // 走全局 multi-tenant filter 会全过滤为空。本接口仅作 S8 处理人/检验人下拉，必须强约束 factoryRefId
        // 边界 + IsActive，避免越界；不依赖 token tenant 做隔离。
        if (!factoryRefId.HasValue || factoryRefId.Value <= 0)
            return new List<object>();

        var emps = await _empRep.AsQueryable().ClearFilter()
            .Where(x => x.FactoryRefId == factoryRefId!.Value && x.IsActive)
            .Take(500)
            .Select(x => new { x.Id, x.Name, x.Employee, x.SysUserId })
            .ToListAsync();

        var sysUserIds = emps.Where(e => e.SysUserId.HasValue && e.SysUserId.Value > 0)
            .Select(e => e.SysUserId!.Value).Distinct().ToList();

        Dictionary<long, (string? RealName, string? Account)> userMap = new();
        if (sysUserIds.Count > 0)
        {
            var users = await _sysUserRep.AsQueryable().ClearFilter()
                .Where(u => sysUserIds.Contains(u.Id))
                .Select(u => new { u.Id, u.RealName, u.Account })
                .ToListAsync();
            userMap = users.ToDictionary(u => u.Id, u => ((string?)u.RealName, (string?)u.Account));
        }

        return emps.Select(e =>
        {
            var bound = e.SysUserId.HasValue && e.SysUserId.Value > 0 && userMap.ContainsKey(e.SysUserId.Value);
            string? sysUserName = null;
            if (bound)
            {
                var (realName, account) = userMap[e.SysUserId!.Value];
                sysUserName = !string.IsNullOrWhiteSpace(realName) ? realName : account;
            }
            return new
            {
                id = e.Id,
                name = e.Name ?? e.Employee,
                empCode = e.Employee,
                sysUserId = e.SysUserId,
                sysUserName,
                bindStatus = bound ? "BOUND" : "UNBOUND"
            };
        }).ToList();
    }

    public async Task<object> GetLinesAsync(long? factoryRefId) =>
        await _lineRep.AsQueryable()
            .WhereIF(factoryRefId.HasValue, x => x.FactoryRefId == factoryRefId!.Value)
            .Take(500)
            .Select(x => new { id = x.Id, code = x.Line, name = x.Describe ?? x.Line })
            .ToListAsync();
}