AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Controllers/S0/Sales/AdoS0MaterialsController.cs

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

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

/// <summary>
/// S0 物料主数据（ItemMaster 语义）
/// </summary>
[ApiController]
[Route("api/s0/sales/materials")]
[NonUnify]
public class AdoS0MaterialsController : ControllerBase
{
    private readonly SqlSugarRepository<AdoS0ItemMaster> _rep;
    private readonly AdoS0ReferenceChecker _refChecker;

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

    [HttpGet]
    public async Task<IActionResult> GetPagedAsync([FromQuery] AdoS0ItemMasterQueryDto q)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        (q.Page, q.PageSize) = PagingGuard.Normalize(q.Page, q.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.DomainCode), x => x.DomainCode == q.DomainCode)
            .WhereIF(!string.IsNullOrWhiteSpace(q.ItemNum), x => x.ItemNum.Contains(q.ItemNum!))
            .WhereIF(!string.IsNullOrWhiteSpace(q.Descr), x => x.Descr.Contains(q.Descr!))
            .WhereIF(!string.IsNullOrWhiteSpace(q.Descr1), x => x.Descr1 != null && x.Descr1.Contains(q.Descr1!))
            .WhereIF(!string.IsNullOrWhiteSpace(q.ItemType), x => x.ItemType == q.ItemType)
            .WhereIF(!string.IsNullOrWhiteSpace(q.PurMfg), x => x.PurMfg == q.PurMfg)
            .WhereIF(!string.IsNullOrWhiteSpace(q.Location), x => x.Location != null && x.Location.Contains(q.Location!))
            .WhereIF(!string.IsNullOrWhiteSpace(q.Status), x => x.Status == q.Status)
            .WhereIF(q.IsActive.HasValue, x => x.IsActive == q.IsActive.Value)
            .WhereIF(q.IsConfirm.HasValue, x => x.IsConfirm == q.IsConfirm.Value)
            .WhereIF(
                !string.IsNullOrWhiteSpace(q.Keyword),
                x => x.ItemNum.Contains(q.Keyword!) || x.Descr.Contains(q.Keyword!));

        var total = await query.CountAsync();
        var list = await query
            .OrderByDescending(x => x.CreateTime)
            .Skip((q.Page - 1) * q.PageSize)
            .Take(q.PageSize)
            .ToListAsync();

        foreach (var x in list)
            x.LocationDescr = FormatLocationDescr(x.Location, null);

        return Ok(new { total, page = q.Page, pageSize = q.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);
        if (item == null) return NotFound();
        item.LocationDescr = FormatLocationDescr(item.Location, null);
        return Ok(item);
    }

    [HttpPost]
    public async Task<IActionResult> CreateAsync([FromBody] AdoS0ItemMasterUpsertDto dto)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;

        var (companyId, factoryId) = await AdoS0OrgScope.ResolveAsync(_rep.Context, tenantId);
        if (companyId <= 0 || factoryId <= 0) return AdoS0OrgScope.NotConfiguredError("物料");
        if (await _rep.IsAnyAsync(x =>
                x.TenantId == tenantId &&
                x.CompanyRefId == dto.CompanyRefId &&
                x.FactoryRefId == dto.FactoryRefId &&
                x.ItemNum == dto.ItemNum))
        {
            return AdoS0ApiErrors.Conflict(AdoS0ErrorCodes.MaterialCodeExists, "物料编码已存在");
        }

        var now = DateTime.Now;
        var entity = MapDtoToNewEntity(dto, now);
        // 租户只由后端可信上下文赋值，忽略 DTO 中任何 tenant 相关入参。
        entity.TenantId = tenantId;
        entity.Status = ResolveStatus(dto);

        await _rep.AsInsertable(entity).ExecuteReturnEntityAsync();
        return Ok(entity);
    }

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

        if (await _rep.IsAnyAsync(x =>
                x.TenantId == tenantId &&
                x.Id != id &&
                x.CompanyRefId == dto.CompanyRefId &&
                x.FactoryRefId == dto.FactoryRefId &&
                x.ItemNum == dto.ItemNum))
        {
            return AdoS0ApiErrors.Conflict(AdoS0ErrorCodes.MaterialCodeExists, "物料编码已存在");
        }

        ApplyDtoToEntity(entity, dto);
        entity.Status = ResolveStatus(dto);
        entity.UpdateTime = DateTime.Now;

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

    [HttpPatch("{id:long}/toggle-enabled")]
    public async Task<IActionResult> ToggleActiveAsync(long id, [FromBody] AdoS0ItemMasterToggleActiveDto 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.IsActive;
        entity.Status = AdoS0SalesRules.ForbidStatusFromIsEnabled(dto.IsActive);
        entity.UpdateTime = DateTime.Now;

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

    [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.MaterialReferencesAsync(tenantId, item.ItemNum);
        if (refInfo is { } r)
            return AdoS0ApiErrors.Conflict(AdoS0ErrorCodes.DeleteBlocked,
                $"存在 {r.Count} 条 {r.Table} 引用该物料，无法删除");

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

    private static string ResolveStatus(AdoS0ItemMasterUpsertDto dto) =>
        string.IsNullOrWhiteSpace(dto.Status)
            ? AdoS0SalesRules.ForbidStatusFromIsEnabled(dto.IsActive)
            : dto.Status!;

    private static string FormatLocationDescr(string? location, string? locationMasterDescr)
    {
        var a = location?.Trim();
        var b = locationMasterDescr?.Trim();
        if (string.IsNullOrEmpty(a)) return b ?? string.Empty;
        if (string.IsNullOrEmpty(b)) return a;
        return $"{a} {b}".Trim();
    }

    private static AdoS0ItemMaster MapDtoToNewEntity(AdoS0ItemMasterUpsertDto dto, DateTime now) => new()
    {
        // 组织字段由 CreateAsync stamp 解析值覆盖（不读 payload）。
        DomainCode = dto.DomainCode,
        ItemNum = dto.ItemNum,
        Descr = dto.Descr,
        Descr1 = dto.Descr1,
        PkgCode = dto.PkgCode,
        UM = dto.UM,
        PurMfg = dto.PurMfg,
        Drawing = dto.Drawing,
        ItemType = dto.ItemType,
        Location = dto.Location,
        DefaultShelf = dto.DefaultShelf,
        KeyItem = dto.KeyItem,
        NetWeight = dto.NetWeight,
        NetWeightUM = dto.NetWeightUM,
        Inspect = dto.Inspect,
        PurLT = dto.PurLT.GetValueOrDefault(),
        InsLT = dto.InsLT.GetValueOrDefault(),
        MfgLT = dto.MfgLT,
        Length = dto.Length,
        Size = dto.Size,
        SizeUM = dto.SizeUM,
        IssuePolicy = dto.IssuePolicy,
        MfgMttr = dto.MfgMttr,
        LocationType = dto.LocationType,
        CommodityCode = dto.CommodityCode,
        Rev = dto.Rev,
        MaxOrd = dto.MaxOrd.GetValueOrDefault(),
        MinOrd = dto.MinOrd.GetValueOrDefault(),
        OrdMult = dto.OrdMult.GetValueOrDefault(),
        MinOrdSales = dto.MinOrdSales.GetValueOrDefault(),
        AutoLotNums = dto.AutoLotNums,
        Install = dto.Install,
        SafetyStk = dto.SafetyStk.GetValueOrDefault(),
        DaysBetweenPM = dto.DaysBetweenPM,
        ExpireAlarmDay = dto.ExpireAlarmDay,
        StockTurnOver = dto.StockTurnOver.GetValueOrDefault(),
        LotSerialControl = dto.LotSerialControl,
        AllocateSingleLot = dto.AllocateSingleLot,
        Planner = dto.Planner,
        TraceDetail = dto.TraceDetail,
        IsMainMas = dto.IsMainMas,
        Remark = dto.Remark,
        EMTType = dto.EMTType,
        OwnerApplication = dto.OwnerApplication,
        BomVersion = dto.BomVersion,
        EnableBomVersion = dto.EnableBomVersion,
        BOMDesign = dto.BOMDesign,
        RoutingDes = dto.RoutingDes,
        CustSupplied = dto.CustSupplied,
        DrawingDesign = dto.DrawingDesign,
        DesignOwner = dto.DesignOwner,
        IsActive = dto.IsActive,
        IsConfirm = dto.IsConfirm,
        MRPRequired = dto.MRPRequired,
        CreateUser = dto.CreateUser,
        CreateTime = now,
        UpdateUser = dto.UpdateUser,
        UpdateTime = null
    };

    private static void ApplyDtoToEntity(AdoS0ItemMaster entity, AdoS0ItemMasterUpsertDto dto)
    {
        // 组织字段 pin 到既有原值，忽略 payload 组织值：既杜绝篡改成他租户组织，
        // 也不因一次普通编辑就顺手迁移历史 CROSS-TENANT 存量。
        entity.DomainCode = dto.DomainCode;
        entity.ItemNum = dto.ItemNum;
        entity.Descr = dto.Descr;
        entity.Descr1 = dto.Descr1;
        entity.PkgCode = dto.PkgCode;
        entity.UM = dto.UM;
        entity.PurMfg = dto.PurMfg;
        entity.Drawing = dto.Drawing;
        entity.ItemType = dto.ItemType;
        entity.Location = dto.Location;
        entity.DefaultShelf = dto.DefaultShelf;
        entity.KeyItem = dto.KeyItem;
        entity.NetWeight = dto.NetWeight;
        entity.NetWeightUM = dto.NetWeightUM;
        entity.Inspect = dto.Inspect;
        entity.PurLT = dto.PurLT.GetValueOrDefault();
        entity.InsLT = dto.InsLT.GetValueOrDefault();
        entity.MfgLT = dto.MfgLT;
        entity.Length = dto.Length;
        entity.Size = dto.Size;
        entity.SizeUM = dto.SizeUM;
        entity.IssuePolicy = dto.IssuePolicy;
        entity.MfgMttr = dto.MfgMttr;
        entity.LocationType = dto.LocationType;
        entity.CommodityCode = dto.CommodityCode;
        entity.Rev = dto.Rev;
        entity.MaxOrd = dto.MaxOrd.GetValueOrDefault();
        entity.MinOrd = dto.MinOrd.GetValueOrDefault();
        entity.OrdMult = dto.OrdMult.GetValueOrDefault();
        entity.MinOrdSales = dto.MinOrdSales.GetValueOrDefault();
        entity.AutoLotNums = dto.AutoLotNums;
        entity.Install = dto.Install;
        entity.SafetyStk = dto.SafetyStk.GetValueOrDefault();
        entity.DaysBetweenPM = dto.DaysBetweenPM;
        entity.ExpireAlarmDay = dto.ExpireAlarmDay;
        entity.StockTurnOver = dto.StockTurnOver.GetValueOrDefault();
        entity.LotSerialControl = dto.LotSerialControl;
        entity.AllocateSingleLot = dto.AllocateSingleLot;
        entity.Planner = dto.Planner;
        entity.TraceDetail = dto.TraceDetail;
        entity.IsMainMas = dto.IsMainMas;
        entity.Remark = dto.Remark;
        entity.EMTType = dto.EMTType;
        entity.OwnerApplication = dto.OwnerApplication;
        entity.BomVersion = dto.BomVersion;
        entity.EnableBomVersion = dto.EnableBomVersion;
        entity.BOMDesign = dto.BOMDesign;
        entity.RoutingDes = dto.RoutingDes;
        entity.CustSupplied = dto.CustSupplied;
        entity.DrawingDesign = dto.DrawingDesign;
        entity.DesignOwner = dto.DesignOwner;
        entity.IsActive = dto.IsActive;
        entity.IsConfirm = dto.IsConfirm;
        entity.MRPRequired = dto.MRPRequired;
        entity.UpdateUser = dto.UpdateUser;
    }
}