C#注塑机上位机数据追溯plc-s7_1500 双重数据库 多线程 数据导出 注塑机上位机数据追溯 1，采用C#编写。 2, plc为$7 1500。 3，双重数据库，本地和远程同时存取，mssa12012。 ，同时使用OPGDA和OPCUA。 OPCDA链接 5 , 使用多线程，界面流畅有好。 ，数据查询与导出

在工业自动化领域，注塑机上位机的数据追溯至关重要。它不仅能帮助企业实时监控生产过程，还能在出现问题时快速定位根源。今天，咱们就来聊聊如何用C#打造一个这样功能强大的数据追溯系统，它与PLC - S7 1500协同工作，还有双重数据库以及多线程等“秘密武器”。

一、PLC - S7 1500的连接

我们选用的PLC是西门子S7 - 1500。要与之通信，就绕不开OPC技术，这里我们同时使用OPCDA和OPCUA。

C#注塑机上位机数据追溯plc-s7_1500 双重数据库 多线程 数据导出 注塑机上位机数据追溯 1，采用C#编写。 2, plc为$7 1500。 3，双重数据库，本地和远程同时存取，mssa12012。 ，同时使用OPGDA和OPCUA。 OPCDA链接 5 , 使用多线程，界面流畅有好。 ，数据查询与导出

先看看OPCDA的连接代码示例（这里简化示例，实际应用需更多错误处理等完善）：

using OPCAutomation;

public class OPCDALink
{
    private OPCServer server;
    private OPCGroups groups;
    private OPCGroup group;
    private OPCItems items;

    public OPCDALink()
    {
        server = new OPCServer();
        server.Connect("OPC.SimaticNET"); // 连接到对应的OPC服务器
        groups = server.OPCGroups;
        group = groups.Add("MyGroup");
        items = group.OPCItems;
    }

    public void ReadData()
    {
        object values;
        object errors;
        items.Read(1, out values, out errors); // 读取数据，这里假设只读取一个数据项
        Console.WriteLine("Read value: " + values);
    }
}

在这段代码里，首先创建了OPCServer实例并连接到指定的OPC服务器，这里是OPC.SimaticNET。接着创建了OPCGroups，并在其中添加了一个OPCGroup，最后通过OPCItems来读取数据。

二、双重数据库设计

系统采用本地和远程同时存取数据的双重数据库设计，选用的是MSSQL 2012。这样做的好处是，即使远程服务器出现短暂故障，本地数据依然能保证生产数据不丢失，并且在网络恢复后可同步到远程数据库。

本地数据库操作

using System.Data.SqlClient;

public class LocalDatabase
{
    private string connectionString = "Data Source=YOUR_LOCAL_SERVER;Initial Catalog=YourLocalDB;User ID=yourUser;Password=yourPassword";

    public void InsertData(string data)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string insertQuery = "INSERT INTO YourTable (DataColumn) VALUES (@Data)";
            using (SqlCommand command = new SqlCommand(insertQuery, connection))
            {
                command.Parameters.AddWithValue("@Data", data);
                command.ExecuteNonQuery();
            }
        }
    }
}

上述代码通过SqlConnection连接到本地数据库，然后使用SqlCommand执行插入数据的SQL语句。

远程数据库操作

using System.Data.SqlClient;

public class RemoteDatabase
{
    private string connectionString = "Data Source=YOUR_REMOTE_SERVER;Initial Catalog=YourRemoteDB;User ID=yourUser;Password=yourPassword";

    public void InsertData(string data)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string insertQuery = "INSERT INTO YourTable (DataColumn) VALUES (@Data)";
            using (SqlCommand command = new SqlCommand(insertQuery, connection))
            {
                command.Parameters.AddWithValue("@Data", data);
                command.ExecuteNonQuery();
            }
        }
    }
}

远程数据库操作与本地类似，只是连接字符串指向远程服务器。

三、多线程的运用

为了保证界面流畅友好，多线程必不可少。想象一下，如果数据采集、数据库存储等操作都在主线程进行，界面很容易出现卡顿。

using System;
using System.Threading;

public class DataWorker
{
    private Thread workerThread;

    public DataWorker()
    {
        workerThread = new Thread(DoWork);
        workerThread.Start();
    }

    private void DoWork()
    {
        while (true)
        {
            // 这里可以写数据采集，如通过OPC读取PLC数据
            string data = "Some data from PLC";
            LocalDatabase localDB = new LocalDatabase();
            localDB.InsertData(data);

            RemoteDatabase remoteDB = new RemoteDatabase();
            remoteDB.InsertData(data);

            Thread.Sleep(1000); // 每1秒执行一次
        }
    }
}

在这个例子里，创建了一个新线程workerThread，在DoWork方法中执行数据采集（这里只是简单模拟），然后分别插入本地和远程数据库，并且通过Thread.Sleep控制执行频率。

四、数据查询与导出

数据查询是为了方便用户追溯历史数据，而导出功能则能让数据在其他分析工具中进一步处理。

数据查询

using System.Data.SqlClient;
using System.Data;

public class DataQuery
{
    private string connectionString = "Data Source=YOUR_LOCAL_SERVER;Initial Catalog=YourLocalDB;User ID=yourUser;Password=yourPassword";

    public DataTable QueryData()
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string query = "SELECT * FROM YourTable";
            using (SqlDataAdapter adapter = new SqlDataAdapter(query, connection))
            {
                DataTable dataTable = new DataTable();
                adapter.Fill(dataTable);
                return dataTable;
            }
        }
    }
}

这段代码使用SqlDataAdapter填充DataTable，从而获取查询结果。

数据导出

using System.Data;
using System.IO;
using Microsoft.Office.Interop.Excel;

public class DataExport
{
    public void ExportToExcel(DataTable dataTable, string filePath)
    {
        Application excelApp = new Application();
        Workbook workbook = excelApp.Workbooks.Add(Type.Missing);
        Worksheet worksheet = (Worksheet)workbook.Sheets[1];

        for (int i = 1; i <= dataTable.Columns.Count; i++)
        {
            worksheet.Cells[1, i] = dataTable.Columns[i - 1].ColumnName;
        }

        for (int i = 0; i < dataTable.Rows.Count; i++)
        {
            for (int j = 0; j < dataTable.Columns.Count; j++)
            {
                worksheet.Cells[i + 2, j + 1] = dataTable.Rows[i][j].ToString();
            }
        }

        workbook.SaveAs(filePath, Type.Missing, Type.Missing, Type.Missing, Type.Missing, Type.Missing, XlSaveAsAccessMode.xlExclusive, Type.Missing, Type.Missing, Type.Missing, Type.Missing, Type.Missing);
        workbook.Close(true, Type.Missing, Type.Missing);
        excelApp.Quit();
    }
}

此代码借助Excel互操作库，将DataTable的数据导出到Excel文件。

通过上述几个关键部分的实现，我们就打造出了一个功能较为完备的C#注塑机上位机数据追溯系统，从与PLC的通信，到双重数据库存储，再到多线程保证性能，以及数据的查询和导出，全方位满足了生产数据追溯的需求。希望这篇博文能给各位在相关领域探索的朋友一些启发。