- 微信
- 微博
  
  分享文章到微博
- 复制链接
  
  复制链接到剪贴板

2021-09-05 WPF数据采集与监控系统开发实战-设备数据采集

愚公搬代码发表于 2021/10/18 23:37:02 2021/10/18

【摘要】窗口配置信息 <configuration> <startup> <supportedRuntime version="v4.0" sku=".N...

窗口配置信息

<configuration>
    <startup> 
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.6.1"/>
    </startup>
	<connectionStrings>
		<add name="db_config" connectionString="Server=localhost;DataBase=zx_scada_data;Uid=sa;Pwd=aaa111"/>
	</connectionStrings>
	<appSettings>
		<!--端口号-->
		<add key="port" value="COM1"/>
		<!--波特率-->
		<add key="baud" value="9600"/>
		<!--数据位-->
		<add key="data_bit" value="8"/>
		<!--校验位-->
		<add key="parity" value="None"/>
		<!--停止位-->
		<add key="stop_bit" value="One"/>
	</appSettings>
</configuration>

  
 
  1
  2
  3
  4
  5
  6
  7
  8
  9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20

全局数据采集

/// <summary>
/// App.xaml 的交互逻辑
/// </summary>
public partial class App : Application
{
    protected override void OnStartup(StartupEventArgs e)
    {
        base.OnStartup(e);

        GlobalMonitor.Start(
            () =>
            {
                Application.Current.Dispatcher.Invoke(() =>
                {
                    new MainWindow().Show();
                });
            },
            (msg) =>
            {
                Application.Current.Dispatcher.Invoke(() =>
                {
                    MessageBox.Show(msg, "系统启动失败");
                    Application.Current.Shutdown();
                });
            });
    }

    protected override void OnExit(ExitEventArgs e)
    {
        GlobalMonitor.Dispose();

        base.OnExit(e);
    }
}

  
 
  1
  2
  3
  4
  5
  6
  7
  8
  9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20
  21
  22
  23
  24
  25
  26
  27
  28
  29
  30
  31
  32
  33
  34

/// <summary>
/// 串口通讯相关类
/// </summary>
public class RTU
{
    public Action<int, List<byte>> ResponseData;

    private static RTU _instance;
    private static SerialInfo _serialInfo;

    SerialPort _serialPort;
    bool _isBusing = false;

    int _currentSlave;
    int _funcCode;
    int _wordLen;
    int _startAddr;

    private RTU(SerialInfo serialInfo)
    {
        _serialPort = new SerialPort();
        _serialInfo = serialInfo;
    }

    public static RTU GetInstance(SerialInfo serialInfo)
    {
        lock ("rtu")
        {
            if (_instance == null)
                _instance = new RTU(serialInfo);
            return _instance;
        }
    }


    public bool Connection()
    {
        try
        {
            if (_serialPort.IsOpen)
                _serialPort.Close();

            _serialPort.PortName = _serialInfo.PortName;
            _serialPort.BaudRate = _serialInfo.BaudRate;
            _serialPort.DataBits = _serialInfo.DataBit;
            _serialPort.Parity = _serialInfo.Parity;
            _serialPort.StopBits = _serialInfo.StopBits;

            _serialPort.ReceivedBytesThreshold = 1;
            _serialPort.DataReceived += _serialPort_DataReceived;

            _serialPort.Open();
        }
        catch
        {
            return false;
        }

        return true;
    }

    public void Dispose()
    {
        if (_serialPort.IsOpen)
        {
            _serialPort.Close();
            _serialPort.Dispose();
            _serialPort = null;
        }
    }

    int _receiveByteCount = 0;
    byte[] _byteBuffer = new byte[512];
    private void _serialPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
    {
        byte _receiveBytes;
        while (_serialPort.BytesToRead > 0)
        {
            _receiveBytes = (byte)_serialPort.ReadByte();
            _byteBuffer[_receiveByteCount] = _receiveBytes;
            _receiveByteCount++;
            if (_receiveByteCount >= 512)
            {
                _receiveByteCount = 0;
                //清除输入缓冲区
                _serialPort.DiscardInBuffer();
                return;
            }
        }

        if (_byteBuffer[0] == (byte)_currentSlave && _byteBuffer[1] == _funcCode && _receiveByteCount >= _wordLen + 5)
        {
            // 检查crc
            // ...........
            // 返回数据
            ResponseData?.Invoke(_startAddr, new List<byte>(SubByteArray(_byteBuffer, 0, _wordLen + 3)));
            _serialPort.DiscardInBuffer();
        }
    }

    public async Task<bool> Send(int slaveAddr, byte funcCode, int startAddr, int len)
    {
        _currentSlave = slaveAddr;
        _funcCode = funcCode;
        _startAddr = startAddr;

        if (funcCode == 0x01)
            _wordLen = len / 8 + ((len % 8 > 0) ? 1 : 0);
        if (funcCode == 0x03)
            _wordLen = len * 2;

        List<byte> sendBuffer = new List<byte>();
        sendBuffer.Add((byte)slaveAddr);
        sendBuffer.Add(funcCode);
        sendBuffer.Add((byte)(startAddr / 256));
        sendBuffer.Add((byte)(startAddr % 256));
        sendBuffer.Add((byte)(len / 256));
        sendBuffer.Add((byte)(len % 256));

        byte[] crc = Crc16(sendBuffer.ToArray(), 6);
        sendBuffer.AddRange(crc);

        try
        {
            while (_isBusing) { }

            _isBusing = true;
            _serialPort.Write(sendBuffer.ToArray(), 0, 8);
            _isBusing = false;

            await Task.Delay(1000);
        }
        catch
        {
            return false;
        }
            _receiveByteCount = 0;
        return true;
    }

    private byte[] SubByteArray(byte[] byteArr, int start, int len)
    {
        byte[] Res = new byte[len];
        if (byteArr != null && byteArr.Length > len)
        {
            for (int i = 0; i < len; i++)
            {
                Res[i] = byteArr[i + start];
            }
        }
        return Res;
    }

    #region  CRC校验
    private static readonly byte[] aucCRCHi = {
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
         0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
         0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
         0x00, 0xC1, 0x81, 0x40
     };
    private static readonly byte[] aucCRCLo = {
         0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06, 0x07, 0xC7,
         0x05, 0xC5, 0xC4, 0x04, 0xCC, 0x0C, 0x0D, 0xCD, 0x0F, 0xCF, 0xCE, 0x0E,
         0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09, 0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9,
         0x1B, 0xDB, 0xDA, 0x1A, 0x1E, 0xDE, 0xDF, 0x1F, 0xDD, 0x1D, 0x1C, 0xDC,
         0x14, 0xD4, 0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3,
         0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3, 0xF2, 0x32,
         0x36, 0xF6, 0xF7, 0x37, 0xF5, 0x35, 0x34, 0xF4, 0x3C, 0xFC, 0xFD, 0x3D,
         0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A, 0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38,
         0x28, 0xE8, 0xE9, 0x29, 0xEB, 0x2B, 0x2A, 0xEA, 0xEE, 0x2E, 0x2F, 0xEF,
         0x2D, 0xED, 0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
         0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60, 0x61, 0xA1,
         0x63, 0xA3, 0xA2, 0x62, 0x66, 0xA6, 0xA7, 0x67, 0xA5, 0x65, 0x64, 0xA4,
         0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F, 0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB,
         0x69, 0xA9, 0xA8, 0x68, 0x78, 0xB8, 0xB9, 0x79, 0xBB, 0x7B, 0x7A, 0xBA,
         0xBE, 0x7E, 0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5,
         0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71, 0x70, 0xB0,
         0x50, 0x90, 0x91, 0x51, 0x93, 0x53, 0x52, 0x92, 0x96, 0x56, 0x57, 0x97,
         0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C, 0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E,
         0x5A, 0x9A, 0x9B, 0x5B, 0x99, 0x59, 0x58, 0x98, 0x88, 0x48, 0x49, 0x89,
         0x4B, 0x8B, 0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
         0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42, 0x43, 0x83,
         0x41, 0x81, 0x80, 0x40
     };
    private byte[] Crc16(byte[] pucFrame, int usLen)
    {
        int i = 0;
        byte crcHi = 0xFF;
        byte crcLo = 0xFF;
        UInt16 iIndex = 0x0000;

        while (usLen-- > 0)
        {
            iIndex = (UInt16)(crcLo ^ pucFrame[i++]);
            crcLo = (byte)(crcHi ^ aucCRCHi[iIndex]);
            crcHi = aucCRCLo[iIndex];
        }

        return new byte[] { crcLo, crcHi };
    }


    #endregion
}

  
 
  1
  2
  3
  4
  5
  6
  7
  8
  9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20
  21
  22
  23
  24
  25
  26
  27
  28
  29
  30
  31
  32
  33
  34
  35
  36
  37
  38
  39
  40
  41
  42
  43
  44
  45
  46
  47
  48
  49
  50
  51
  52
  53
  54
  55
  56
  57
  58
  59
  60
  61
  62
  63
  64
  65
  66
  67
  68
  69
  70
  71
  72
  73
  74
  75
  76
  77
  78
  79
  80
  81
  82
  83
  84
  85
  86
  87
  88
  89
  90
  91
  92
  93
  94
  95
  96
  97
  98
  99
  100
  101
  102
  103
  104
  105
  106
  107
  108
  109
  110
  111
  112
  113
  114
  115
  116
  117
  118
  119
  120
  121
  122
  123
  124
  125
  126
  127
  128
  129
  130
  131
  132
  133
  134
  135
  136
  137
  138
  139
  140
  141
  142
  143
  144
  145
  146
  147
  148
  149
  150
  151
  152
  153
  154
  155
  156
  157
  158
  159
  160
  161
  162
  163
  164
  165
  166
  167
  168
  169
  170
  171
  172
  173
  174
  175
  176
  177
  178
  179
  180
  181
  182
  183
  184
  185
  186
  187
  188
  189
  190
  191
  192
  193
  194
  195
  196
  197
  198
  199
  200
  201
  202
  203
  204
  205
  206
  207
  208
  209
  210
  211
  212
  213
  214
  215
  216
  217
  218
  219
  220
  221
  222

public class GlobalMonitor
{
    //存储区域
    public static List<StorageModel> StorageList { get; set; }
    //设备列表
    public static List<DeviceModel> DeviceList { get; set; }
    //配置信息
    public static SerialInfo SerialInfo { get; set; }
    //是否运行
    static bool isRunning = true;
    //主任务
    static Task mainTask = null;
    //串口实例
    static RTU rtuInstance = null;
    /// <summary>
    /// 开始运行
    /// </summary>
    /// <param name="sucessAction">成功回调</param>
    /// <param name="faultAction">失败回调</param>
    public static void Start(Action sucessAction, Action<string> faultAction)
    {
        mainTask = Task.Run(async () =>
         {
             //业务层
             IndustrialBLL bll = new IndustrialBLL();
             #region 获取串口配置信息
             var si = bll.InitSerialInfo();
             if (si.State)
                 SerialInfo = si.Data;
             else
             {
                 faultAction(si.Message); return;
             }
             #endregion
             #region 获取存储区信息
             var sa = bll.InitStorageArea();
             if (sa.State)
                 StorageList = sa.Data;
             else
             {
                 faultAction(sa.Message); return;
             }
             #endregion
             #region 初始化设备变量集合及警戒值
             var dr = bll.InitDevices();
             if (dr.State)
                 DeviceList = dr.Data;
             else
             {
                 faultAction(dr.Message); return;
             }
             #endregion
             #region 初始化串口通信
             rtuInstance = RTU.GetInstance(SerialInfo);
             rtuInstance.ResponseData = new Action<int, List<byte>>(ParsingData);

             if (rtuInstance.Connection())
             {
                 sucessAction();

                 int startAddr = 0;
                 while (isRunning)
                 {
                     foreach (var item in StorageList)
                     {
                         if (item.Length > 100)
                         {
                             startAddr = item.StartAddress;
                             int readCount = item.Length / 100;
                             for (int i = 0; i < readCount; i++)
                             {
                                 int readLen = i == readCount ? item.Length - 100 * i : 100;
                                 await rtuInstance.Send(item.SlaveAddress, (byte)int.Parse(item.FuncCode), startAddr + 100 * i, readLen);
                             }
                         }
                         if (item.Length % 100 > 0)
                         {
                             await rtuInstance.Send(item.SlaveAddress, (byte)int.Parse(item.FuncCode), startAddr + 100 * (item.Length / 100), item.Length % 100);
                         }
                     }
                 }
             }
             else
             {
                 faultAction("程序无法启动，串口连接初始化失败！请检查设备是否连接正常。");
             }
             #endregion
         });
    }
    /// <summary>
    /// 查找设备监控点位与当前返回报文相关的监控数据列表
    /// </summary>
    /// <param name="start_addr"></param>
    /// <param name="byteList"></param>
    private static void ParsingData(int start_addr, List<byte> byteList)
    {
        if (byteList != null && byteList.Count > 0)
        {
            // 查找设备监控点位与当前返回报文相关的监控数据列表
            // 根据从站地址、功能码、起始地址
            var mvl = (from q in DeviceList
                       from m in q.MonitorValueList
                       where m.StorageAreaId == (byteList[0].ToString() + byteList[1].ToString("00") + start_addr.ToString())
                       select m
                     ).ToList();

            int startByte;
            byte[] res = null;
            foreach (var item in mvl)
            {
                switch (item.DataType)
                {
                    case "Float":
                        startByte = item.StartAddress * 2 + 3;
                        if (startByte < start_addr + byteList.Count)
                        {
                            res = new byte[4] { byteList[startByte], byteList[startByte + 1], byteList[startByte + 2], byteList[startByte + 3] };
                            item.CurrentValue = Convert.ToDouble(res.ByteArrsyToFloat());
                        }
                        break;
                    case "Bool":
                        break;
                }
            }
        }
    }
    /// <summary>
    /// 销毁时触发
    /// </summary>
    public static void Dispose()
    {
        isRunning = false;

        if (rtuInstance != null)
            rtuInstance.Dispose();

        if (mainTask != null)
            mainTask.Wait();
    }
}

  
 
  1
  2
  3
  4
  5
  6
  7
  8
  9
  10
  11
  12
  13
  14
  15
  16
  17
  18
  19
  20
  21
  22
  23
  24
  25
  26
  27
  28
  29
  30
  31
  32
  33
  34
  35
  36
  37
  38
  39
  40
  41
  42
  43
  44
  45
  46
  47
  48
  49
  50
  51
  52
  53
  54
  55
  56
  57
  58
  59
  60
  61
  62
  63
  64
  65
  66
  67
  68
  69
  70
  71
  72
  73
  74
  75
  76
  77
  78
  79
  80
  81
  82
  83
  84
  85
  86
  87
  88
  89
  90
  91
  92
  93
  94
  95
  96
  97
  98
  99
  100
  101
  102
  103
  104
  105
  106
  107
  108
  109
  110
  111
  112
  113
  114
  115
  116
  117
  118
  119
  120
  121
  122
  123
  124
  125
  126
  127
  128
  129
  130
  131
  132
  133
  134
  135
  136
  137
  138
  139
  140

文章来源: codeboy.blog.csdn.net，作者：愚公搬代码，版权归原作者所有，如需转载，请联系作者。

原文链接：codeboy.blog.csdn.net/article/details/120108805

点赞
收藏
关注作者

0/1000

抱歉，系统识别当前为高风险访问，暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称，即可参与社区互动！

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

确认取消

加入云驻计划，成为创作者

华为云周边好礼
免费体验产品
特殊身份标识
线下官方门票
内部专家零距离
与10000+优质创作者共同成长

立即加入

2021-09-05 WPF数据采集与监控系统开发实战-设备数据采集

窗口配置信息

全部回复

设置昵称

关于作者

目录

加入云驻计划，成为创作者

2021-09-05 WPF数据采集与监控系统开发实战-设备数据采集

窗口配置信息

全部回复

设置昵称

关于作者

目录

加入云驻计划，成为创作者

推荐阅读

相关产品