C#开发注塑机上位机系统与PLC通信实践-平芜编程栈

1. 项目背景与核心需求

在工业自动化领域，注塑机作为典型的生产设备，其生产过程数据追溯一直是制造企业的核心需求。我最近完成的一个注塑机上位机系统开发项目，正是为了解决这个痛点。这个系统采用C#语言开发，与西门子S7-1500 PLC进行通信，实现了生产数据的双重数据库存储方案。

这个系统的核心价值在于：通过实时采集注塑机的工艺参数、生产数量、设备状态等关键数据，并建立完善的数据追溯机制，帮助生产企业实现质量追溯、工艺优化和设备效能分析。特别是在汽车零部件、医疗器械等对产品质量要求严格的行业，完整的数据追溯链已经成为行业标配。

2. 系统架构设计

2.1 整体技术栈选择

系统采用典型的三层架构设计：

数据采集层：基于OPC DA协议与S7-1500 PLC通信
业务逻辑层：C#开发的Windows服务程序
数据存储层：MSSQL 2012数据库集群

选择C#作为开发语言主要考虑几个因素：

对Windows平台的深度支持，便于与OPC服务器集成
强大的多线程处理能力，适合高频数据采集场景
成熟的数据库访问框架(ADO.NET/Entity Framework)
丰富的工业通信库支持

2.2 双重数据库设计方案

系统采用主备双数据库架构确保数据安全：

主数据库：存储完整生产数据，采用MSSQL 2012企业版
备份数据库：实时同步关键追溯数据，使用MSSQL 2012标准版

双重数据库的实现核心代码如下：

// 双数据库写入操作 public bool WriteToBothDB(ProductionData data) { try { // 主数据库写入 using (var conn1 = new SqlConnection(primaryConnStr)) { conn1.Open(); // 执行插入操作... } // 备份数据库写入 using (var conn2 = new SqlConnection(backupConnStr)) { conn2.Open(); // 执行简化版插入操作... } return true; } catch (Exception ex) { LogError("双数据库写入失败：" + ex.Message); return false; } }

3. 关键功能实现

3.1 PLC通信模块

与S7-1500的通信采用OPC DA协议，通过以下步骤实现：

配置OPC服务器连接参数
建立数据项订阅列表
设置数据变化回调处理

核心通信代码结构：

// OPC客户端初始化 var server = new OPCServer(); server.Connect("OPC.SimaticNET"); var groups = server.OPCGroups; var group = groups.Add("DataGroup"); group.IsActive = true; group.IsSubscribed = true; group.UpdateRate = 100; // 添加监控项 var items = group.OPCItems; var item1 = items.AddItem("S7-1500.DB1.DBD10", 1); item1.DataChange += OnDataChanged; // 数据变化处理 private void OnDataChanged(int transaction, int numItems, ref Array clientHandles, ref Array itemValues, ref Array qualities, ref Array timeStamps) { // 处理PLC数据更新... }

3.2 数据追溯功能实现

数据追溯功能主要包括：

生产批次追溯
工艺参数追溯
设备状态追溯
异常事件追溯

追溯查询的SQL示例：

-- 批次追溯查询 SELECT p.batch_no, m.machine_name, p.product_code, p.start_time, p.end_time, p.qualified_count, p.defective_count FROM production_batches p JOIN machines m ON p.machine_id = m.id WHERE p.batch_no = @batchNo ORDER BY p.start_time DESC; -- 参数历史查询 SELECT param_name, param_value, record_time FROM parameter_history WHERE machine_id = @machineId AND record_time BETWEEN @start AND @end ORDER BY record_time;

4. 系统优化与问题解决

4.1 性能优化措施

在实际运行中，我们遇到了几个性能瓶颈问题：

高频数据写入延迟：
- 问题：当注塑机以高速模式生产时，数据写入出现延迟
- 解决方案：采用批量写入代替单条写入，设置内存缓冲区

优化后的写入逻辑：

// 批量写入实现 public void BatchInsert(List<ProductionData> dataList) { using (var conn = new SqlConnection(connStr)) { conn.Open(); using (var bulkCopy = new SqlBulkCopy(conn)) { bulkCopy.DestinationTableName = "ProductionRecords"; bulkCopy.BatchSize = 1000; bulkCopy.BulkCopyTimeout = 60; using (var reader = ObjectReader.Create(dataList, "Timestamp", "MachineID", "Param1", "Param2")) { bulkCopy.WriteToServer(reader); } } } }

OPC通信不稳定：
- 问题：网络波动导致OPC连接中断
- 解决方案：实现自动重连机制，增加心跳检测

4.2 常见问题排查指南

问题现象	可能原因	解决方案
PLC数据无法读取	OPC服务器未启动	检查OPC服务状态，重启服务
数据库写入失败	连接字符串错误	检查配置文件中的连接字符串
界面数据不更新	数据绑定失效	检查INotifyPropertyChanged实现
历史查询缓慢	缺少索引	在常用查询字段上创建索引