1. 项目背景与核心需求

在注塑成型生产线上，数据追溯系统就像给机器装上了"黑匣子"。每次合模压力、熔胶温度、保压时间等200+参数都被完整记录，当出现产品毛边、尺寸偏差等问题时，能快速定位到具体是哪一模次参数异常。我们这套系统采用C# WinForm开发，与西门子S7-1500 PLC协同工作，通过OPC UA/DA双协议确保通信可靠性，配合本地+云端双数据库架构，即使突发断网也能保证8小时以上的数据缓存能力。

关键指标：系统需支持每秒50次的数据采集频率，200台设备并发接入，查询10万条记录响应时间<3秒

2. 硬件通信层实现

2.1 S7-1500 PLC通信配置

西门子S7-1500的PROFINET接口默认IP段为192.168.0.1/24，在TIA Portal中需要：

1. 启用OPC UA服务器功能
2. 配置证书策略为"SignAndEncrypt"
3. 添加需要暴露的DB块地址范围

// OPC UA连接示例 var endpoint = "opc.tcp://192.168.0.100:4840"; var certificate = new X509Certificate2("client.pfx", "password"); var application = new ApplicationInstance { ApplicationName = "InjectionMoldingMonitor", ApplicationType = ApplicationType.Client }; var session = await application.CreateSession(endpoint, certificate);

2.2 通信异常处理机制

我们采用三级重试策略：

• 首次失败：等待100ms重试
• 二次失败：切换备用通信协议（DA转UA）
• 三次失败：启动本地模拟数据生成模式

graph TD A[首次连接] -->|成功| B[正常采集] A -->|失败| C[100ms后重试] C -->|成功| B C -->|失败| D[切换协议] D -->|成功| B D -->|失败| E[模拟模式]

3. 数据存储架构设计

3.1 双数据库同步方案

本地采用SQLite实现高频写入（实测可达1500次/秒），远程使用SQL Server集群。同步服务通过WAL(Write-Ahead Logging)机制保证数据一致性：

// 双库同步核心逻辑 public async Task SyncData() { var localChanges = _liteDb.GetPendingSyncRecords(); foreach(var record in localChanges) { try { await _cloudDb.InsertAsync(record); _liteDb.MarkAsSynced(record.Id); } catch(Exception ex) { _logger.LogError($"同步失败:{record.Id}", ex); break; // 保留未同步记录 } } }

3.2 数据压缩算法

针对温度曲线等时序数据，采用SWING算法压缩：

1. 原始数据：100,102,105,107,106,105...
2. 压缩后：100@0,102@1,105@2,107@3,106@4... 存储空间节省达70%

4. 多线程优化实践

4.1 采集线程管理

采用生产者-消费者模式，三个独立线程池分别处理：

• 实时采集（最高优先级）
• 数据持久化
• 界面更新

var cts = new CancellationTokenSource(); var options = new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount - 1, CancellationToken = cts.Token }; Parallel.ForEach(plcList, options, plc => { var data = plc.ReadCurrentValues(); _dataQueue.Enqueue(data); // 线程安全队列 });

4.2 界面防卡顿技巧

1. 使用BackgroundWorker处理耗时操作
2. 数据绑定采用BindingList而非List
3. 图表更新使用双缓冲技术

踩坑记录：直接跨线程更新UI会导致随机性崩溃，必须通过Invoke委托

5. 数据追溯功能实现

5.1 快速查询优化

针对模号、时间范围、异常类型建立组合索引：

CREATE INDEX idx_trace_search ON ProductionData (MoldNumber, RecordTime DESC, Status) INCLUDE (Parameters)

5.2 导出功能增强

支持三种导出格式：

1. Excel（兼容老旧MES系统）
2. JSON（用于第三方分析）
3. 自定义二进制格式（快速导入还原）

public void Export(ExportFormat format) { var exporter = format switch { ExportFormat.Excel => new ExcelExporter(), ExportFormat.Json => new JsonExporter(), _ => new BinaryExporter() }; exporter.Export(_currentData); }

6. 部署与运维要点

6.1 安装包定制

使用Inno Setup制作安装包时：

1. 自动检测并安装.NET 6运行时
2. 注册OPC核心组件
3. 配置Windows防火墙规则

6.2 远程诊断方案

内置WebSocket服务，通过8085端口提供：

• 实时通信状态看板
• 内存dump捕获
• 日志级别动态调整

7. 性能优化实战记录

通过ANTS Performance Profiler发现：

1. 频繁的GC操作源于过度使用LINQ
2. 改进方案：预编译表达式树+数组池

优化前后对比：

8. 异常处理经验

8.1 PLC通信常见故障

1. 证书过期：每月自动检查更新
2. 网络闪断：TCP KeepAlive设置15秒
3. 数据溢出：DB块地址校验机制

8.2 数据库恢复策略

每日凌晨3点自动：

1. 验证本地/云端数据一致性
2. 压缩备份历史数据
3. 重建索引优化查询

这套系统在注塑车间连续运行12个月后，产品不良率追溯效率提升80%，平均故障排查时间从4小时缩短至30分钟。最让我意外的是，通过历史数据分析优化工艺参数，居然帮助客户提升了7%的良品率。