物料管理系统与 ERP / 生产系统对接：数据打通要点 + 接口配置（实现信息同步）

// 物料同步API控制器示例
[ApiController]
[Route("api/[controller]")]
public class MaterialSyncController : ControllerBase
{
    private readonly IMaterialService _materialService;
    
    public MaterialSyncController(IMaterialService materialService)
    {
        _materialService = materialService;
    }
    
    // 获取物料信息接口
    [HttpGet("{materialCode}")]
    public async Task GetMaterial(string materialCode)
    {
        var material = await _materialService.GetByCodeAsync(materialCode);
        if (material == null)
            return NotFound();
            
        return Ok(material);
    }
    
    // 更新库存接口
    [HttpPost("inventory")]
    public async Task UpdateInventory([FromBody] InventoryUpdateRequest request)
    {
        var result = await _materialService.UpdateInventoryAsync(request);
        return Ok(result);
    }
}

// 物料变更消息生产者
public class MaterialChangeProducer
{
    private readonly IMessageQueueService _queueService;
    
    public MaterialChangeProducer(IMessageQueueService queueService)
    {
        _queueService = queueService;
    }
    
    public async Task PublishMaterialChangeEvent(MaterialChangeEvent changeEvent)
    {
        var message = new QueueMessage
        {
            MessageType = "MaterialChange",
            Body = JsonSerializer.Serialize(changeEvent),
            Timestamp = DateTime.UtcNow
        };
        
        await _queueService.PublishAsync("material-changes", message);
    }
}

// 物料变更消息消费者
public class MaterialChangeConsumer : BackgroundService
{
    private readonly IMessageQueueService _queueService;
    private readonly IERPIntegrationService _erpService;
    
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        await _queueService.ConsumeAsync("material-changes", async message =>
        {
            var changeEvent = JsonSerializer.Deserialize(message.Body);
            await _erpService.SyncMaterialChangeAsync(changeEvent);
        }, stoppingToken);
    }
}

// 物料数据模型
public class Material
{
    public string Code { get; set; }        // 物料编码
    public string Name { get; set; }        // 物料名称
    public string Specification { get; set; } // 规格型号
    public string Unit { get; set; }        // 单位
    public string Category { get; set; }    // 物料分类
    public decimal CurrentStock { get; set; } // 当前库存
    public decimal SafetyStock { get; set; } // 安全库存
    public DateTime LastUpdated { get; set; } // 最后更新时间
}

// 库存变更记录模型
public class InventoryChangeRecord
{
    public string MaterialCode { get; set; }
    public decimal ChangeQuantity { get; set; }
    public string ChangeType { get; set; } // 入库/出库/调整
    public string ReferenceNumber { get; set; } // 相关单号
    public DateTime ChangeTime { get; set; }
    public string Operator { get; set; }
}

// 带重试机制的接口调用服务
public class RetryableApiService
{
    private readonly IHttpClientFactory _httpClientFactory;
    private readonly ILogger _logger;
    
    public async Task PostWithRetryAsync(string url, object data, int maxRetries = 3)
    {
        var retryCount = 0;
        while (true)
        {
            try
            {
                using var client = _httpClientFactory.CreateClient();
                var response = await client.PostAsJsonAsync(url, data);
                response.EnsureSuccessStatusCode();
                return await response.Content.ReadFromJsonAsync();
            }
            catch (Exception ex) when (retryCount < maxRetries)
            {
                retryCount++;
                _logger.LogWarning(ex, "API调用失败，正在进行第{RetryCount}次重试", retryCount);
                await Task.Delay(1000 * retryCount); // 指数退避
            }
        }
    }
}