AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Controllers/S0/Manufacturing/AdoS0MfgProductionLinesController.cs

using Admin.NET.Plugin.AiDOP.Dto.S0.Manufacturing;
using Admin.NET.Plugin.AiDOP.Dto.S0.Sales;
using Admin.NET.Plugin.AiDOP.Entity.S0.Manufacturing;
using Admin.NET.Plugin.AiDOP.Infrastructure;

namespace Admin.NET.Plugin.AiDOP.Controllers.S0.Manufacturing;

/// <summary>
/// 生产线维护（LineMaster 语义，表 ado_s0_mfg_line_master）。
/// </summary>
[ApiController]
[Route("api/s0/manufacturing/production-lines")]
[NonUnify]
public class AdoS0MfgProductionLinesController : ControllerBase
{
    private readonly SqlSugarRepository<AdoS0LineMaster> _rep;
    private readonly AdoS0ReferenceChecker _refChecker;

    public AdoS0MfgProductionLinesController(SqlSugarRepository<AdoS0LineMaster> rep, AdoS0ReferenceChecker refChecker)
    {
        _rep = rep;
        _refChecker = refChecker;
    }

    /// <summary>
    /// B1-9：LineMaster 6 个 Location 变体的统一 existence check。
    /// 全部复用 AdoS0ReferenceChecker.LocationExistsAsync，空值放行。
    ///
    /// LEGACY REFERENCE PRESERVATION（与 D-03 并列的独立兼容合同，不改 D-03 语义）：
    ///   UPDATE 时，若某个库位字段的值与库中原值**完全未变化**，且该引用的校验作用域
    ///   （LocationExistsAsync 只取 tenantId，UPDATE 中租户不可变）也未变化，
    ///   则允许原值 preserve，跳过这一个字段的存在性校验。
    ///   任何被**修改过**的值仍走严格校验；CREATE 传 existing = null，永远严格。
    ///
    ///   动机：T01 的主库位是历史描述文本「脱包车间周转仓」，不在 LocationMaster 中。
    ///   在此之前，用户即使什么都不改也无法保存该行。
    ///   本豁免只允许「旧值 → 同一个旧值」，绝不放行任何新的非法值。
    /// </summary>
    private async Task<IActionResult?> ValidateLocationReferencesAsync(
        AdoS0LineMasterUpsertDto dto, long tenantId, AdoS0LineMaster? existing = null)
    {
        var checks = new (string? Value, string? Original, string Label)[]
        {
            (dto.Location, existing?.Location, "主库位"),
            (dto.VLocation, existing?.VLocation, "虚拟库位"),
            (dto.Location2, existing?.Location2, "辅助库位2"),
            (dto.Location3, existing?.Location3, "辅助库位3"),
            (dto.PickingLocation, existing?.PickingLocation, "拣料库位"),
            (dto.MidLocation, existing?.MidLocation, "中间库位"),
        };
        // 与落库归一化保持一致（Trim + 空串视为 null），避免仅因空白差异被判为「已修改」
        static string? Normalize(string? v) => string.IsNullOrWhiteSpace(v) ? null : v.Trim();

        foreach (var (value, original, label) in checks)
        {
            // 值未变化（UPDATE 且与原值逐字相同）→ preserve，不重新校验
            if (existing != null && string.Equals(Normalize(value), Normalize(original), StringComparison.Ordinal))
                continue;

            if (!await _refChecker.LocationExistsAsync(tenantId, value))
                return AdoS0ApiErrors.InvalidReference(AdoS0ErrorCodes.ReferenceNotFound,
                    $"{label}编码 '{value}' 不存在于库位主数据");
        }
        return null;
    }

    [HttpGet]
    public async Task<IActionResult> GetPagedAsync([FromQuery] AdoS0LineMasterQueryDto q)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var page = q.EffectivePage;
        var pageSize = q.PageSize;
        (page, pageSize) = PagingGuard.Normalize(page, pageSize);

        var query = _rep.ScopedTo(tenantId)
            .WhereIF(q.CompanyRefId.HasValue, x => x.CompanyRefId == q.CompanyRefId!.Value)
            .WhereIF(q.FactoryRefId.HasValue, x => x.FactoryRefId == q.FactoryRefId!.Value)
            .WhereIF(!string.IsNullOrWhiteSpace(q.Keyword),
                x => x.Line.Contains(q.Keyword!) || (x.Describe != null && x.Describe.Contains(q.Keyword!)))
            .WhereIF(!string.IsNullOrWhiteSpace(q.Line), x => x.Line.Contains(q.Line!))
            .WhereIF(!string.IsNullOrWhiteSpace(q.Workshop),
                x => x.Workshop != null && x.Workshop.Contains(q.Workshop!))
            .WhereIF(q.IsEnabled.HasValue, x => x.IsActive == q.IsEnabled!.Value);

        var total = await query.CountAsync();
        var entities = await query
            .OrderByDescending(x => x.Id)
            .Skip((page - 1) * pageSize)
            .Take(pageSize)
            .ToListAsync();

        // GeneralizedCodeMaster 中文说明：当前库无码表实体，占位供列表展示；后续可 JOIN 补全。
        var list = entities.Select(x => new
        {
            x.Id,
            x.CompanyRefId,
            x.FactoryRefId,
            x.Domain,
            x.Line,
            describe = x.Describe,
            x.LineType,
            x.LineCategory,
            x.Location,
            x.Workshop,
            vLocation = x.VLocation,
            x.Location2,
            x.Location3,
            pickingLocation = x.PickingLocation,
            midLocation = x.MidLocation,
            isActive = x.IsActive,
            x.CreateUser,
            x.CreateTime,
            x.UpdateUser,
            x.UpdateTime,
            lineCategoryComments = (string?)null,
            workshopComments = (string?)null
        }).ToList();

        return Ok(new { total, page, pageSize, list });
    }

    [HttpGet("{id:long}")]
    public async Task<IActionResult> GetAsync(long id)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var item = await _rep.ByIdScopedAsync(id, tenantId);
        return item == null ? NotFound() : Ok(item);
    }

    [HttpPost]
    public async Task<IActionResult> CreateAsync([FromBody] AdoS0LineMasterUpsertDto dto)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var locErr = await ValidateLocationReferencesAsync(dto, tenantId);
        if (locErr != null) return locErr;

        var now = DateTime.Now;
        var entity = new AdoS0LineMaster
        {
            TenantId = tenantId,
            CompanyRefId = dto.CompanyRefId,
            FactoryRefId = dto.FactoryRefId,
            Domain = dto.Domain.Trim(),
            Line = dto.Line.Trim(),
            Describe = string.IsNullOrWhiteSpace(dto.Describe) ? null : dto.Describe.Trim(),
            LineType = string.IsNullOrWhiteSpace(dto.LineType) ? null : dto.LineType.Trim(),
            LineCategory = string.IsNullOrWhiteSpace(dto.LineCategory) ? null : dto.LineCategory.Trim(),
            Location = string.IsNullOrWhiteSpace(dto.Location) ? null : dto.Location.Trim(),
            Workshop = string.IsNullOrWhiteSpace(dto.Workshop) ? null : dto.Workshop.Trim(),
            VLocation = string.IsNullOrWhiteSpace(dto.VLocation) ? null : dto.VLocation.Trim(),
            Location2 = string.IsNullOrWhiteSpace(dto.Location2) ? null : dto.Location2.Trim(),
            Location3 = string.IsNullOrWhiteSpace(dto.Location3) ? null : dto.Location3.Trim(),
            PickingLocation = string.IsNullOrWhiteSpace(dto.PickingLocation) ? null : dto.PickingLocation.Trim(),
            MidLocation = string.IsNullOrWhiteSpace(dto.MidLocation) ? null : dto.MidLocation.Trim(),
            IsActive = dto.IsActive,
            CreateUser = dto.CreateUser,
            CreateTime = now,
            UpdateUser = null,
            UpdateTime = null
        };
        await _rep.AsInsertable(entity).ExecuteReturnEntityAsync();
        return Ok(entity);
    }

    [HttpPut("{id:long}")]
    public async Task<IActionResult> UpdateAsync(long id, [FromBody] AdoS0LineMasterUpsertDto dto)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var entity = await _rep.ByIdScopedAsync(id, tenantId);
        if (entity == null) return NotFound();

        // 传入库中原记录 → 未变化的历史库位值可 preserve；被修改的值仍严格校验
        var locErr = await ValidateLocationReferencesAsync(dto, tenantId, entity);
        if (locErr != null) return locErr;

        entity.CompanyRefId = dto.CompanyRefId;
        entity.FactoryRefId = dto.FactoryRefId;
        entity.Domain = dto.Domain.Trim();
        entity.Line = dto.Line.Trim();
        entity.Describe = string.IsNullOrWhiteSpace(dto.Describe) ? null : dto.Describe.Trim();
        entity.LineType = string.IsNullOrWhiteSpace(dto.LineType) ? null : dto.LineType.Trim();
        entity.LineCategory = string.IsNullOrWhiteSpace(dto.LineCategory) ? null : dto.LineCategory.Trim();
        entity.Location = string.IsNullOrWhiteSpace(dto.Location) ? null : dto.Location.Trim();
        entity.Workshop = string.IsNullOrWhiteSpace(dto.Workshop) ? null : dto.Workshop.Trim();
        entity.VLocation = string.IsNullOrWhiteSpace(dto.VLocation) ? null : dto.VLocation.Trim();
        entity.Location2 = string.IsNullOrWhiteSpace(dto.Location2) ? null : dto.Location2.Trim();
        entity.Location3 = string.IsNullOrWhiteSpace(dto.Location3) ? null : dto.Location3.Trim();
        entity.PickingLocation = string.IsNullOrWhiteSpace(dto.PickingLocation) ? null : dto.PickingLocation.Trim();
        entity.MidLocation = string.IsNullOrWhiteSpace(dto.MidLocation) ? null : dto.MidLocation.Trim();
        entity.IsActive = dto.IsActive;
        entity.UpdateUser = dto.UpdateUser;
        entity.UpdateTime = DateTime.Now;

        await _rep.AsUpdateable(entity).ExecuteCommandAsync();
        return Ok(entity);
    }

    [HttpPatch("{id:long}/toggle-enabled")]
    public async Task<IActionResult> ToggleEnabledAsync(long id, [FromBody] AdoS0ToggleEnabledDto dto)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var entity = await _rep.ByIdScopedAsync(id, tenantId);
        if (entity == null) return NotFound();

        entity.IsActive = dto.IsEnabled;
        entity.UpdateTime = DateTime.Now;
        await _rep.AsUpdateable(entity).ExecuteCommandAsync();
        return Ok(new { entity.Id, isActive = entity.IsActive, entity.UpdateTime });
    }

    [HttpDelete("{id:long}")]
    public async Task<IActionResult> DeleteAsync(long id)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var item = await _rep.ByIdScopedAsync(id, tenantId);
        if (item == null) return NotFound();

        var refInfo = await _refChecker.ProductionLineReferencesAsync(tenantId, item.Id, item.Line);
        if (refInfo is { } r)
            return AdoS0ApiErrors.Conflict(AdoS0ErrorCodes.DeleteBlocked,
                $"存在 {r.Count} 条 {r.Table} 引用该生产线，无法删除");

        await _rep.DeleteAsync(item);
        return Ok(new { message = "删除成功" });
    }
}