AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/WorkOrder/MaterialRequirementGenerationService.cs

using Admin.NET.Plugin.AiDOP.Infrastructure;
using Admin.NET.Plugin.AiDOP.Supply;

namespace Admin.NET.Plugin.AiDOP.WorkOrder;

/// <summary>物料需求生成（MRP 入口，对接 S4 采购执行闭环）。</summary>
[ApiDescriptionSettings(Order = 261, Description = "物料需求生成")]
[Route("api/WorkOrder")]
[AllowAnonymous]
[NonUnify]
public class MaterialRequirementGenerationService : IDynamicApiController, ITransient
{
    private readonly UserManager _userManager;
    private readonly ProcurementPipelineService _pipeline;
    private readonly AidopActionRunLogWriter _runLog;

    public MaterialRequirementGenerationService(
        UserManager userManager,
        ProcurementPipelineService pipeline,
        AidopActionRunLogWriter runLog)
    {
        _userManager = userManager;
        _pipeline = pipeline;
        _runLog = runLog;
    }

    /// <summary>同步/生成物料需求并执行采购闭环。</summary>
    [DisplayName("生成物料需求")]
    [HttpPost("material-requirement/generate")]
    public async Task<ProcurementPipelineResult> Generate([FromQuery] string domain)
    {
        var tenantId = ResolveTenantId(domain);
        var account = _userManager.Account ?? "system";
        var logId = await _runLog.StartAsync("S4_MRP_GENERATE", tenantId, "tenant", tenantId, domain ?? tenantId.ToString());

        try
        {
            var result = await _pipeline.ExecuteCoreAsync(tenantId, account, createFromShortage: true);
            await _runLog.SuccessAsync(logId, result.Message, result);
            return result;
        }
        catch (Exception ex)
        {
            await _runLog.FailedAsync(logId, ex.Message);
            throw Oops.Oh(ex.Message);
        }
    }

    private long ResolveTenantId(string? domain)
    {
        if (!string.IsNullOrWhiteSpace(domain) && long.TryParse(domain.Trim(), out var tid) && tid > 0)
            return tid;
        return AidopTenantHelper.Resolve(App.HttpContext);
    }
}