优化

alielie

2026-03-02 12e606635c42ea20f4b7c2bdda5204237a4b4c96

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
using HslCommunication;
using HslCommunication.ModBus;
using PLCHelper.Entity;
using System;
using System.Collections.Concurrent;
 
namespace PLCHelper
{
    public class ModbusHelper
    {
        private static ConcurrentDictionary<string, ModbusTcpNet> cache = new ConcurrentDictionary<string, ModbusTcpNet>();
 
        internal static ModbusTcpNet GetClient(string ip, int port)
        {
            string key = $"{ip}:{port};";
            if (!cache.ContainsKey(key))
            {
                var client = new ModbusTcpNet(ip, port);
                cache[key] = client;
                client.ConnectServer();
            }
            return cache[key];
        }
 
        internal static bool ParseConfig(string address, out string ip, out int port, out string index)
        {
            try
            {
                var arr = address.Split(',');
                ip = arr[0];
                port = int.Parse(arr[1]);
                index = arr[2];
                return true;
            }
            catch
            {
                ip = null;
                port = -1;
                index = null;
                return false;
            }
        }
 
        internal static void Release()
        {
            foreach (var client in cache.Values)
            {
                client.Dispose();
            }
            cache.Clear();
        }
 
        internal static bool ReadData(PLCTagData data, out object val, out string errMsg)
        {
            val = null;
            try
            {
                string address = data.Address;
                if (!ModbusHelper.ParseConfig(address, out string ip, out int port, out string index))
                {
                    errMsg = "解析配置失败";
                    return false;
                }
                var api = ModbusHelper.GetClient(ip, port);
                if (data.Type == PLCTagType.BOOL)
                {
                    var res = api.ReadBool(index);
                    val = res.Content;
                    errMsg = res.Message;
                    return res.IsSuccess;
                }
                else if (data.Type == PLCTagType.SHORT)
                {
                    var res = api.ReadInt16(index);
                    val = res.Content;
                    errMsg = res.Message;
                    return res.IsSuccess;
                }
                else if (data.Type == PLCTagType.USHORT)
                {
                    var res = api.ReadUInt16(index);
                    val = res.Content;
                    errMsg = res.Message;
                    return res.IsSuccess;
                }
                else if (data.Type == PLCTagType.INT)
                {
                    var res = api.ReadInt32(index);
                    val = res.Content;
                    errMsg = res.Message;
                    return res.IsSuccess;
                }
                else if (data.Type == PLCTagType.FLOAT)
                {
                    var res = api.ReadFloat(index);
                    val = res.Content;
                    errMsg = res.Message;
                    return res.IsSuccess;
                }
                errMsg = "类型不支持";
                return false;
            }
            catch (Exception ex)
            {
                errMsg = ex.Message;
                return false;
            }
        }
 
        internal static bool WriteData(PLCTagData data, object val, out string msg)
        {
            try
            {
                string address = data.Address;
                if (!ParseConfig(address, out string ip, out int port, out string index))
                {
                    msg = "解析配置失败";
                    return false;
                }
                var api = GetClient(ip, port);
                OperateResult res;
                switch (data.Type)
                {
                    case PLCTagType.BOOL:
                        res = api.Write(index, bool.Parse(val.ToString()));
                        break;
                    case PLCTagType.SHORT:
                        res = api.Write(index, short.Parse(val.ToString()));
                        break;
                    case PLCTagType.USHORT:
                        res = api.Write(index, ushort.Parse(val.ToString()));
                        break;
                    case PLCTagType.INT:
                        res = api.Write(index, int.Parse(val.ToString()));
                        break;
                    case PLCTagType.FLOAT:
                        res = api.Write(index, float.Parse(val.ToString()));
                        break;
                    default:
                        msg = "类型不支持";
                        return false;
                }
                msg = res.Message;
                return res.IsSuccess;
            }
            catch (Exception ex)
            {
                msg = ex.Message;
                return false;
            }
        }
    }
}