MelsecA1ENet.cs
16.5 KB
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
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
using HslCommunication.Core;
using HslCommunication.Core.IMessage;
using HslCommunication.Core.Net;
using System;
using System.Linq;
namespace HslCommunication.Profinet.Melsec
{
/// <summary>
/// 三菱PLC通讯协议，采用A兼容1E帧协议实现，使用二进制码通讯，请根据实际型号来进行选取
/// </summary>
/// <remarks>
/// 本类适用于的PLC列表
/// <list type="number">
/// <item>FX3U(C) PLC 测试人sandy_liao</item>
/// </list>
/// 数据地址支持的格式如下：
/// <list type="table">
/// <listheader>
/// <term>地址名称</term>
/// <term>地址代号</term>
/// <term>示例</term>
/// <term>地址进制</term>
/// <term>字操作</term>
/// <term>位操作</term>
/// <term>备注</term>
/// </listheader>
/// <item>
/// <term>内部继电器</term>
/// <term>M</term>
/// <term>M100,M200</term>
/// <term>10</term>
/// <term>√</term>
/// <term>√</term>
/// <term></term>
/// </item>
/// <item>
/// <term>输入继电器</term>
/// <term>X</term>
/// <term>X10,X20</term>
/// <term>8</term>
/// <term>√</term>
/// <term>√</term>
/// <term></term>
/// </item>
/// <item>
/// <term>输出继电器</term>
/// <term>Y</term>
/// <term>Y10,Y20</term>
/// <term>8</term>
/// <term>√</term>
/// <term>√</term>
/// <term></term>
/// </item>
/// <item>
/// <term>步进继电器</term>
/// <term>S</term>
/// <term>S100,S200</term>
/// <term>10</term>
/// <term>√</term>
/// <term>√</term>
/// <term></term>
/// </item>
/// <item>
/// <term>数据寄存器</term>
/// <term>D</term>
/// <term>D1000,D2000</term>
/// <term>10</term>
/// <term>√</term>
/// <term>×</term>
/// <term></term>
/// </item>
/// <item>
/// <term>文件寄存器</term>
/// <term>R</term>
/// <term>R100,R200</term>
/// <term>10</term>
/// <term>√</term>
/// <term>×</term>
/// <term></term>
/// </item>
/// </list>
/// <note type="important">本通讯类由CKernal推送，感谢</note>
/// </remarks>
public class MelsecA1ENet : NetworkDeviceBase<MelsecA1EBinaryMessage, RegularByteTransform>
{
#region Constructor
/// <summary>
/// 实例化三菱的A兼容1E帧协议的通讯对象
/// </summary>
public MelsecA1ENet()
{
WordLength = 1;
}
/// <summary>
/// 实例化一个三菱的A兼容1E帧协议的通讯对象
/// </summary>
/// <param name="ipAddress">PLC的Ip地址</param>
/// <param name="port">PLC的端口</param>
public MelsecA1ENet(string ipAddress, int port)
{
WordLength = 1;
IpAddress = ipAddress;
Port = port;
}
#endregion
#region Public Member
/// <summary>
/// PLC编号
/// </summary>
public byte PLCNumber { get; set; } = 0xFF;
#endregion
#region Read Support
/// <summary>
/// 从三菱PLC中读取想要的数据，返回读取结果
/// </summary>
/// <param name="address">读取地址，格式为"M100","D100","W1A0"</param>
/// <param name="length">读取的数据长度，字最大值960，位最大值7168</param>
/// <returns>带成功标志的结果数据对象</returns>
public override OperateResult<byte[]> Read(string address, ushort length)
{
// 获取指令
var command = BuildReadCommand(address, length, false, PLCNumber);
if (!command.IsSuccess) return OperateResult.CreateFailedResult<byte[]>(command);
// 核心交互
var read = ReadFromCoreServer(command.Content);
if (!read.IsSuccess) return OperateResult.CreateFailedResult<byte[]>(read);
// 错误代码验证
if (read.Content[1] != 0) return new OperateResult<byte[]>(read.Content[1], StringResources.Language.MelsecPleaseReferToManulDocument);
// 数据解析，需要传入是否使用位的参数
return ExtractActualData(read.Content, false);
}
/// <summary>
/// 从三菱PLC中批量读取位软元件，返回读取结果
/// </summary>
/// <param name="address">起始地址</param>
/// <param name="length">读取的长度</param>
/// <returns>带成功标志的结果数据对象</returns>
public override OperateResult<bool[]> ReadBool(string address, ushort length)
{
// 获取指令
var command = BuildReadCommand(address, length, true, PLCNumber);
if (!command.IsSuccess) return OperateResult.CreateFailedResult<bool[]>(command);
// 核心交互
var read = ReadFromCoreServer(command.Content);
if (!read.IsSuccess) return OperateResult.CreateFailedResult<bool[]>(read);
// 错误代码验证
if (read.Content[1] != 0) return new OperateResult<bool[]>(read.Content[1], StringResources.Language.MelsecPleaseReferToManulDocument);
// 数据解析，需要传入是否使用位的参数
var extract = ExtractActualData(read.Content, true);
if (!extract.IsSuccess) return OperateResult.CreateFailedResult<bool[]>(extract);
// 转化bool数组
return OperateResult.CreateSuccessResult(extract.Content.Select(m => m == 0x01).Take(length).ToArray());
}
#endregion
#region Write Override
/// <summary>
/// 向PLC写入数据，数据格式为原始的字节类型
/// </summary>
/// <param name="address">初始地址</param>
/// <param name="value">原始的字节数据</param>
/// <returns>返回写入结果</returns>
public override OperateResult Write(string address, byte[] value)
{
// 解析指令
OperateResult<byte[]> command = BuildWriteCommand(address, value, PLCNumber);
if (!command.IsSuccess) return command;
// 核心交互
OperateResult<byte[]> read = ReadFromCoreServer(command.Content);
if (!read.IsSuccess) return read;
// 错误码校验 (在A兼容1E协议中，结束代码后面紧跟的是异常信息的代码)
if (read.Content[1] != 0) return new OperateResult(read.Content[1], StringResources.Language.MelsecPleaseReferToManulDocument);
// 成功
return OperateResult.CreateSuccessResult();
}
#endregion
#region Write bool[]
/// <summary>
/// 向PLC中位软元件写入bool数组，返回值说明，比如你写入M100,values[0]对应M100
/// </summary>
/// <param name="address">要写入的数据地址</param>
/// <param name="values">要写入的实际数据，可以指定任意的长度</param>
/// <returns>返回写入结果</returns>
public override OperateResult Write(string address, bool[] values)
{
return Write(address, values.Select(m => m ? (byte)0x01 : (byte)0x00).ToArray());
}
#endregion
#region Object Override
/// <summary>
/// 返回表示当前对象的字符串
/// </summary>
/// <returns>字符串信息</returns>
public override string ToString()
{
return $"MelsecA1ENet[{IpAddress}:{Port}]";
}
#endregion
#region Static Method Helper
/// <summary>
/// 根据类型地址长度确认需要读取的指令头
/// </summary>
/// <param name="address">起始地址</param>
/// <param name="length">长度</param>
/// <param name="isBit">指示是否按照位成批的读出</param>
/// <param name="plcNumber">PLC编号</param>
/// <returns>带有成功标志的指令数据</returns>
public static OperateResult<byte[]> BuildReadCommand(string address, ushort length, bool isBit, byte plcNumber)
{
var analysis = MelsecHelper.McA1EAnalysisAddress(address);
if (!analysis.IsSuccess) return OperateResult.CreateFailedResult<byte[]>(analysis);
// 默认信息----注意：高低字节交错
// byte subtitle = analysis.Content1.DataType == 0x01 ? (byte)0x00 : (byte)0x01;
byte subtitle = isBit ? (byte)0x00 : (byte)0x01;
byte[] _PLCCommand = new byte[12];
_PLCCommand[0] = subtitle; // 副标题
_PLCCommand[1] = plcNumber; // PLC号
_PLCCommand[2] = 0x0A; // CPU监视定时器（L）这里设置为0x00,0x0A，等待CPU返回的时间为10*250ms=2.5秒
_PLCCommand[3] = 0x00; // CPU监视定时器（H）
_PLCCommand[4] = (byte)(analysis.Content2 % 256); // 起始软元件（开始读取的地址）
_PLCCommand[5] = (byte)(analysis.Content2 / 256);
_PLCCommand[6] = 0x00;
_PLCCommand[7] = 0x00;
_PLCCommand[8] = analysis.Content1.DataCode[1]; // 软元件代码（L）
_PLCCommand[9] = analysis.Content1.DataCode[0]; // 软元件代码（H）
_PLCCommand[10] = (byte)(length % 256); // 软元件点数
_PLCCommand[11] = 0x00;
return OperateResult.CreateSuccessResult(_PLCCommand);
}
/// <summary>
/// 根据类型地址以及需要写入的数据来生成指令头
/// </summary>
/// <param name="address">起始地址</param>
/// <param name="value">数据值</param>
/// <param name="plcNumber">PLC编号</param>
/// <returns>带有成功标志的指令数据</returns>
public static OperateResult<byte[]> BuildWriteCommand(string address, byte[] value, byte plcNumber)
{
var analysis = MelsecHelper.McA1EAnalysisAddress(address);
if (!analysis.IsSuccess) return OperateResult.CreateFailedResult<byte[]>(analysis);
int length = -1;
if (analysis.Content1.DataType == 1)
{
// 按照位写入的操作，数据需要重新计算
length = value.Length;
value = MelsecHelper.TransBoolArrayToByteData(value);
}
// 默认信息----注意：高低字节交错
byte subtitle = analysis.Content1.DataType == 0x01 ? (byte)0x02 : (byte)0x03;
byte[] _PLCCommand = new byte[12 + value.Length];
_PLCCommand[0] = subtitle; // 副标题
_PLCCommand[1] = plcNumber; // PLC号
_PLCCommand[2] = 0x0A; // CPU监视定时器（L）这里设置为0x00,0x0A，等待CPU返回的时间为10*250ms=2.5秒
_PLCCommand[3] = 0x00; // CPU监视定时器（H）
_PLCCommand[4] = (byte)(analysis.Content2 % 256); // 起始软元件（开始读取的地址）
_PLCCommand[5] = (byte)(analysis.Content2 / 256);
_PLCCommand[6] = 0x00;
_PLCCommand[7] = 0x00;
_PLCCommand[8] = analysis.Content1.DataCode[1]; // 软元件代码（L）
_PLCCommand[9] = analysis.Content1.DataCode[0]; // 软元件代码（H）
_PLCCommand[10] = (byte)(length % 256); // 软元件点数
_PLCCommand[11] = 0x00;
// 判断是否进行位操作
if (analysis.Content1.DataType == 0x01)
{
if (length > 0)
{
_PLCCommand[10] = (byte)(length % 256); // 软元件点数
}
else
{
_PLCCommand[10] = (byte)(value.Length * 2 % 256); // 软元件点数
}
}
else
{
_PLCCommand[10] = (byte)(value.Length / 2 % 256); // 软元件点数
}
Array.Copy(value, 0, _PLCCommand, 12, value.Length); // 将具体的要写入的数据附加到写入命令后面
return OperateResult.CreateSuccessResult(_PLCCommand);
}
/// <summary>
/// 从PLC反馈的数据中提取出实际的数据内容，需要传入反馈数据，是否位读取
/// </summary>
/// <param name="response">反馈的数据内容</param>
/// <param name="isBit">是否位读取</param>
/// <returns>解析后的结果对象</returns>
public static OperateResult<byte[]> ExtractActualData(byte[] response, bool isBit)
{
if (isBit)
{
// 位读取
byte[] Content = new byte[(response.Length - 2) * 2];
for (int i = 2; i < response.Length; i++)
{
if ((response[i] & 0x10) == 0x10)
{
Content[(i - 2) * 2 + 0] = 0x01;
}
if ((response[i] & 0x01) == 0x01)
{
Content[(i - 2) * 2 + 1] = 0x01;
}
}
return OperateResult.CreateSuccessResult(Content);
}
else
{
// 字读取
byte[] Content = new byte[response.Length - 2];
Array.Copy(response, 2, Content, 0, Content.Length);
return OperateResult.CreateSuccessResult(Content);
}
}
#endregion
}
}