当前位置：首页 > news >正文

基于前述文章的完整MES对接代码示例，覆盖了汽车总装线场景下最常用的几种对接方式

news 2026/3/26 23:46:23

以下是基于前述文章的完整MES对接代码示例，覆盖了汽车总装线场景下最常用的几种对接方式：

REST API JSON上报（最常见，简单高效）
B2MML XML上报（严格ISA-95标准，许多合资车厂强制要求）
数据库中间表写入（部分老MES系统常用）
OPC UA 节点写入（新兴MES支持OPC UA的趋势方案）

代码全部基于 .NET 8，包含：

配置驱动（appsettings.json）
Polly重试 + 熔断
断网本地缓存 + 自动补传
批量上报优化
详细日志（Serilog）
异常安全 + 事务一致性

1. appsettings.json 配置示例

{"MesIntegration":{"Mode":"RestJson",// RestJson / B2MmlXml / DbIntermediate / OpcUa"Rest":{"BaseUrl":"https://mes.example.com/api","ApiKey":"sk-xxxxxxxxxxxxxxxxxxxx","BatchSize":100,"RetryCount":3,"RetryDelaySeconds":2},"B2MmlXml":{"Endpoint":"https://mes.example.com/b2mml","Namespace":"http://www.mesa.org/xml/B2MML-V0600"},"DbIntermediate":{"ConnectionString":"Server=192.168.1.10;Database=MesIntermediate;User Id=sa;Password=xxx;TrustServerCertificate=True;"},"OpcUa":{"EndpointUrl":"opc.tcp://192.168.1.50:4840","UserName":"mesuser","Password":"mespass","NodeIdPrefix":"ns=2;s=ProductionReport"},"OfflineCachePath":"C:\\MesCache\\offline_reports.jsonl","MaxCacheSizeMB":100}}

2. 核心模型（统一使用）

publicclassProductionReport{publicstringVin{get;set;}// 17位VIN码publicDateTimeTimestamp{get;set;}=DateTime.UtcNow;publicstringStationId{get;set;}// 工位ID，如 "ChassisAssembly_01"publicintYield{get;set;}// 本批产量publicboolIsNg{get;set;}// 本批是否NGpublicList<DefectItem>Defects{get;set;}=new();publicDictionary<string,object>Measurements{get;set;}=new();// 扭矩、压力等publicstringOperatorId{get;set;}// 操作员工号publicstringShift{get;set;}// 班次}publicclassDefectItem{publicstringType{get;set;}// 如 "TorqueLow"、"PositionDeviation"publicdoubleValue{get;set;}publicdoubleStandard{get;set;}publicintSeverity{get;set;}// 1-5级}

3. 完整MES对接服务（MesIntegrationService.cs）

usingMicrosoft.Extensions.Options;usingPolly;usingSerilog;usingSystem.Data.SqlClient;usingSystem.IO;usingSystem.Net.Http.Json;usingSystem.Xml.Serialization;publicclassMesIntegrationService:BackgroundService{privatereadonlyMesConfig_config;privatereadonlyILogger<MesIntegrationService>_logger;privatereadonlyChannelReader<ProductionReport>_reportChannel;// 从采集层传入privatereadonlyHttpClient_httpClient;publicMesIntegrationService(IOptions<MesConfig>config,ILogger<MesIntegrationService>logger,ChannelReader<ProductionReport>reportChannel){_config=config.Value;_logger=logger;_reportChannel=reportChannel;_httpClient=newHttpClient{BaseAddress=newUri(_config.Rest.BaseUrl)};_httpClient.DefaultRequestHeaders.Authorization=new("Bearer",_config.Rest.ApiKey);}protectedoverrideasyncTaskExecuteAsync(CancellationTokenstoppingToken){// 启动时先补传缓存awaitReplayOfflineCacheAsync(stoppingToken);varbuffer=newList<ProductionReport>(_config.Rest.BatchSize);while(!stoppingToken.IsCancellationRequested){try{// 从通道读取数据（采集层推送）while(await_reportChannel.WaitToReadAsync(stoppingToken)&&buffer.Count<_config.Rest.BatchSize){if(_reportChannel.TryRead(outvarreport))buffer.Add(report);}if(buffer.Count>0){awaitSendBatchAsync(buffer,stoppingToken);buffer.Clear();}}catch(Exceptionex){_logger.LogError(ex,"MES上报循环异常");awaitTask.Delay(5000,stoppingToken);}awaitTask.Delay(10000,stoppingToken);// 每10秒检查一次通道}}privateasyncTaskSendBatchAsync(List<ProductionReport>batch,CancellationTokenct){boolsuccess=false;switch(_config.Mode){case"RestJson":success=awaitSendRestJsonAsync(batch,ct);break;case"B2MmlXml":success=awaitSendB2MmlXmlAsync(batch,ct);break;case"DbIntermediate":success=awaitWriteToIntermediateDbAsync(batch,ct);break;case"OpcUa":success=awaitWriteToOpcUaAsync(batch,ct);break;default:_logger.LogError("未知MES对接模式：{Mode}",_config.Mode);return;}if(!success){awaitCacheOfflineAsync(batch);}}// 1. REST JSON 上报privateasyncTask<bool>SendRestJsonAsync(List<ProductionReport>batch,CancellationTokenct){varretryPolicy=Policy.Handle<Exception>().WaitAndRetryAsync(_config.RetryCount,i=>TimeSpan.FromSeconds(_config.RetryDelaySeconds*i));returnawaitretryPolicy.ExecuteAsync(async()=>{varresponse=await_httpClient.PostAsJsonAsync("/production/report",batch,ct);response.EnsureSuccessStatusCode();_logger.Information("REST JSON 上报成功，批次：{Count}",batch.Count);returntrue;});}// 2. B2MML XML 上报privateasyncTask<bool>SendB2MmlXmlAsync(List<ProductionReport>batch,CancellationTokenct){varxml=SerializeToB2MmlXml(batch);varcontent=newStringContent(xml,Encoding.UTF8,"application/xml");varretryPolicy=Policy.Handle<Exception>().WaitAndRetryAsync(_config.RetryCount,i=>TimeSpan.FromSeconds(_config.RetryDelaySeconds*i));returnawaitretryPolicy.ExecuteAsync(async()=>{varresponse=await_httpClient.PostAsync(_config.B2MmlXml.Endpoint,content,ct);response.EnsureSuccessStatusCode();_logger.Information("B2MML XML 上报成功，批次：{Count}",batch.Count);returntrue;});}privatestringSerializeToB2MmlXml(List<ProductionReport>batch){varserializer=newXmlSerializer(typeof(List<ProductionReport>));usingvarwriter=newStringWriter();serializer.Serialize(writer,batch);returnwriter.ToString();}// 3. 数据库中间表写入privateasyncTask<bool>WriteToIntermediateDbAsync(List<ProductionReport>batch,CancellationTokenct){try{usingvarconn=newSqlConnection(_config.DbIntermediate.ConnectionString);awaitconn.OpenAsync(ct);usingvartransaction=conn.BeginTransaction();foreach(varreportinbatch){usingvarcmd=newSqlCommand(@"INSERT INTO ProductionReports (Vin, Timestamp, StationId, Yield, IsNg, MeasurementsJson) VALUES (@Vin, @Ts, @Station, @Yield, @IsNg, @Json)",conn,transaction);cmd.Parameters.AddWithValue("@Vin",report.Vin);cmd.Parameters.AddWithValue("@Ts",report.Timestamp);cmd.Parameters.AddWithValue("@Station",report.StationId);cmd.Parameters.AddWithValue("@Yield",report.Yield);cmd.Parameters.AddWithValue("@IsNg",report.IsNg);cmd.Parameters.AddWithValue("@Json",JsonSerializer.Serialize(report.Measurements));awaitcmd.ExecuteNonQueryAsync(ct);}transaction.Commit();_logger.Information("中间表写入成功，批次：{Count}",batch.Count);returntrue;}catch(Exceptionex){_logger.Error(ex,"中间表写入失败");returnfalse;}}// 4. OPC UA 节点写入（简版）privateasyncTask<bool>WriteToOpcUaAsync(List<ProductionReport>batch,CancellationTokenct){// 这里使用 OPC UA 客户端库写入节点（参考前文OPC UA完整代码）// 实际需集成 OPC UA Session Write// 此处仅占位_logger.Information("OPC UA 写入模拟成功，批次：{Count}",batch.Count);returntrue;}// 缓存到本地文件（断网时）privateasyncTaskCacheOfflineAsync(List<ProductionReport>batch){try{varjsonLines=batch.Select(JsonSerializer.Serialize);awaitFile.AppendAllLinesAsync(_config.LocalCachePath,jsonLines);_logger.Information("断网缓存成功，批次：{Count}",batch.Count);}catch(Exceptionex){_logger.Error(ex,"本地缓存失败");}}// 补传本地缓存publicasyncTaskReplayOfflineCacheAsync(CancellationTokenct){if(!File.Exists(_config.LocalCachePath))return;varlines=awaitFile.ReadAllLinesAsync(_config.LocalCachePath,ct);varsuccessfulLines=newList<string>();foreach(varlineinlines){try{varreport=JsonSerializer.Deserialize<ProductionReport>(line);if(awaitReportBatchAsync(newList<ProductionReport>{report},ct)){successfulLines.Add(line);}}catch{/* 跳过无效行 */}}// 重写文件，只保留失败的行awaitFile.WriteAllLinesAsync(_config.LocalCachePath,lines.Except(successfulLines));_logger.Information("补传完成，剩余缓存行：{Count}",lines.Length-successfulLines.Count);}}