package com.mes.connect.addressparser;
|
|
import com.mes.connect.industrialinterface.AddressParser;
|
import com.mes.connect.protocol.ProtocolAddress;
|
import com.mes.connect.protocol.ProtocolType;
|
|
/**
|
* S7地址解析器
|
*
|
* @author yzx
|
* @version 1.0
|
*/
|
public class S7OldAddressParser implements AddressParser {
|
/**
|
* modbusTcp协议
|
*/
|
private final String protocolS7 = "S7";
|
/**
|
* 字符串截取
|
*/
|
private final String protocolS7_ = "S7.";
|
/**
|
* 地址类型
|
*/
|
private final String addressTypeDB = "DB";
|
/**
|
* 地址类型
|
*/
|
private final String addressTypeX = "X";
|
/**
|
* 地址类型
|
*/
|
private final String addressTypeI = "I";
|
/**
|
* 地址类型
|
*/
|
private final String addressTypeQ = "Q";
|
/**
|
* 地址类型
|
*/
|
private final String addressTypeM = "M";
|
|
/**
|
* 地址值类型
|
*/
|
private final String valueTypeDBW = "DBW";
|
|
/**
|
* 地址值类型
|
*/
|
private final String valueTypeDBX = "DBX";
|
|
/**
|
* 地址值类型
|
*/
|
private final String valueTypeDBD = "DBD";
|
|
/**
|
* 离散输入
|
*/
|
private final int functionCode0x84 = 0x84;
|
/**
|
* 读写功能码
|
*/
|
private final int functionCode4 = 4;
|
|
@Override
|
public ProtocolAddress parse(String address) {
|
// 格式示例: "S7.DB1.DBX10.2" 或 "S7.M100"
|
//位地址：S7.DB1.DBX0.0 (DB1 块中的字节 0 的位 0)
|
//字节地址：S7.DB1.DBB0 (DB1 块中的字节 0)
|
//字地址：S7.DB1.DBW0 (DB1 块中的字 0)
|
//双字地址：S7.DB1.DBD0 (DB1 块中的双字 0)
|
if (!address.startsWith(protocolS7_)) {
|
throw new IllegalArgumentException("Invalid S7 address format: " + address);
|
}
|
|
String[] parts = address.substring(3).split("\\.");
|
// parts =地址类型 字节长度>2
|
if (parts.length < 2) {
|
throw new IllegalArgumentException("Invalid S7 address format: " + address);
|
}
|
|
// 解析DB号
|
int dbNumber = 0;
|
// 默认DB区域
|
int area = 0x84;
|
if (parts[0].startsWith(addressTypeDB)) {
|
dbNumber = Integer.parseInt(parts[0].substring(2));
|
} else if (addressTypeI.equals(parts[0])) {
|
// 输入区域
|
area = 0x81;
|
} else if (addressTypeQ.equals(parts[0])) {
|
// 输出区域
|
area = 0x82;
|
} else if (addressTypeM.equals(parts[0])) {
|
// 内存区域
|
area = 0x83;
|
} else {
|
throw new IllegalArgumentException("Invalid S7 area: " + parts[0]);
|
}
|
|
// 解析地址类型和地址值
|
String addressPart = parts[1];
|
int addressValue = 0;
|
int bit = 0;
|
|
if (area == functionCode0x84) {
|
// DB区域
|
if (addressPart.startsWith(valueTypeDBX)) {
|
// 位地址
|
String[] bitParts = addressPart.substring(3).split("\\.");
|
addressValue = Integer.parseInt(bitParts[0]);
|
if (bitParts.length > 1) {
|
bit = Integer.parseInt(bitParts[1]);
|
}
|
} else if (addressPart.startsWith(valueTypeDBW)) {
|
// 字地址
|
addressValue = Integer.parseInt(addressPart.substring(3));
|
} else if (addressPart.startsWith(valueTypeDBD)) {
|
// 双字地址
|
addressValue = Integer.parseInt(addressPart.substring(3));
|
} else {
|
throw new IllegalArgumentException("Invalid S7 DB address type: " + addressPart);
|
}
|
} else {
|
// I/Q/M区域
|
if (addressPart.startsWith(addressTypeX)) {
|
// 位地址
|
String[] bitParts = addressPart.substring(1).split("\\.");
|
addressValue = Integer.parseInt(bitParts[0]);
|
if (bitParts.length > 1) {
|
bit = Integer.parseInt(bitParts[1]);
|
}
|
} else {
|
// 字地址
|
addressValue = Integer.parseInt(addressPart);
|
}
|
}
|
|
return new ProtocolAddress(ProtocolType.S7, area, dbNumber, addressValue, bit);
|
}
|
|
}
|
