package com.zy.common.HslCommunication.ModBus;
|
|
import com.zy.common.HslCommunication.BasicFramework.SoftBasic;
|
import com.zy.common.HslCommunication.Core.Address.DeviceAddressBase;
|
import com.zy.common.HslCommunication.Utilities;
|
|
|
/**
|
* Modbus协议地址格式，可以携带站号，功能码，地址信息
|
*/
|
public class ModbusAddress extends DeviceAddressBase {
|
|
|
|
/**
|
* 实例化一个默认的对象
|
*/
|
public ModbusAddress() {
|
Station = -1;
|
Function = ModbusInfo.ReadRegister;
|
setAddress(0);
|
}
|
|
|
/**
|
* 实例化一个默认的对象，使用默认的地址初始化
|
* @param address
|
*/
|
public ModbusAddress(String address) {
|
Station = -1;
|
Function = ModbusInfo.ReadRegister;
|
setAddress(0);
|
AnalysisAddress(address);
|
}
|
|
|
/**
|
* 获取站号
|
* @return
|
*/
|
public int getStation() {
|
return Station;
|
}
|
|
/**
|
* 设置站号
|
* @param station
|
*/
|
public void setStation(int station) {
|
Station = station;
|
}
|
|
|
/**
|
* 获取功能码
|
* @return
|
*/
|
public byte getFunction() {
|
return Function;
|
}
|
|
/**
|
* 设置功能码
|
* @param function
|
*/
|
public void setFunction(byte function) {
|
Function = function;
|
}
|
|
private int Station = -1;
|
|
private byte Function = -1;
|
|
|
|
/**
|
* 解析Modbus的地址码
|
* @param address 地址
|
*/
|
@Override
|
public void AnalysisAddress(String address) {
|
if (address.indexOf(';') < 0) {
|
// 正常地址，功能码03
|
setAddress(Integer.parseInt(address));
|
} else {
|
// 带功能码的地址
|
String[] list = address.split(";");
|
for (int i = 0; i < list.length; i++) {
|
if (list[i].charAt(0) == 's' || list[i].charAt(0) == 'S') {
|
// 站号信息
|
this.Station = Integer.parseInt(list[i].substring(2));
|
} else if (list[i].charAt(0) == 'x' || list[i].charAt(0) == 'X') {
|
this.Function = (byte) Integer.parseInt(list[i].substring(2));
|
} else {
|
setAddress(Integer.parseInt(list[i]));
|
}
|
}
|
}
|
}
|
|
|
|
/**
|
* 创建一个读取线圈的字节对象
|
* @param station 读取的站号
|
* @param length 读取数据的长度
|
* @return 原始的modbus指令
|
*/
|
public byte[] CreateReadCoils(byte station, int length) {
|
byte[] buffer = new byte[6];
|
buffer[0] = this.Station < 0 ? station : (byte) this.Station;
|
buffer[1] = ModbusInfo.ReadCoil;
|
buffer[2] = Utilities.getBytes(this.getAddress())[1];
|
buffer[3] = Utilities.getBytes(this.getAddress())[0];
|
buffer[4] = Utilities.getBytes(length)[1];
|
buffer[5] = Utilities.getBytes(length)[0];
|
return buffer;
|
}
|
|
/**
|
* 创建一个读取离散输入的字节对象
|
* @param station 读取的站号
|
* @param length 读取数据的长度
|
* @return 原始的modbus指令
|
*/
|
public byte[] CreateReadDiscrete(byte station, int length) {
|
byte[] buffer = new byte[6];
|
buffer[0] = this.Station < 0 ? station : (byte) this.Station;
|
buffer[1] = ModbusInfo.ReadDiscrete;
|
buffer[2] = Utilities.getBytes(this.getAddress())[1];
|
buffer[3] = Utilities.getBytes(this.getAddress())[0];
|
buffer[4] = Utilities.getBytes(length)[1];
|
buffer[5] = Utilities.getBytes(length)[0];
|
return buffer;
|
}
|
|
|
|
/**
|
* 创建一个读取寄存器的字节对象
|
* @param station 读取的站号
|
* @param length 读取数据的长度
|
* @return 原始的modbus指令
|
*/
|
public byte[] CreateReadRegister(byte station, int length) {
|
byte[] buffer = new byte[6];
|
buffer[0] = this.Station < 0 ? station : (byte) this.Station;
|
buffer[1] = Function;
|
buffer[2] = Utilities.getBytes(this.getAddress())[1];
|
buffer[3] = Utilities.getBytes(this.getAddress())[0];
|
buffer[4] = Utilities.getBytes(length)[1];
|
buffer[5] = Utilities.getBytes(length)[0];
|
return buffer;
|
}
|
|
|
/**
|
* 创建一个写入单个线圈的指令
|
* @param station 站号
|
* @param value 值
|
* @return 原始的modbus指令
|
*/
|
public byte[] CreateWriteOneCoil(byte station, boolean value) {
|
byte[] buffer = new byte[6];
|
buffer[0] = this.Station < 0 ? station : (byte) this.Station;
|
buffer[1] = ModbusInfo.WriteOneCoil;
|
buffer[2] = Utilities.getBytes(this.getAddress())[1];
|
buffer[3] = Utilities.getBytes(this.getAddress())[0];
|
buffer[4] = (byte) (value ? 0xFF : 0x00);
|
buffer[5] = 0x00;
|
return buffer;
|
}
|
|
|
|
/**
|
* 创建一个写入单个寄存器的指令
|
* @param station 站号
|
* @param data 值
|
* @return 原始的modbus指令
|
*/
|
public byte[] CreateWriteOneRegister(byte station, byte[] data) {
|
byte[] buffer = new byte[6];
|
buffer[0] = this.Station < 0 ? station : (byte) this.Station;
|
buffer[1] = ModbusInfo.WriteOneRegister;
|
buffer[2] = Utilities.getBytes(this.getAddress())[1];
|
buffer[3] = Utilities.getBytes(this.getAddress())[0];
|
buffer[4] = data[1];
|
buffer[5] = data[0];
|
return buffer;
|
}
|
|
|
|
/**
|
* 创建一个写入批量线圈的指令
|
* @param station 站号
|
* @param values 值
|
* @return 原始的modbus指令
|
*/
|
public byte[] CreateWriteCoil(byte station, boolean[] values) {
|
byte[] data = SoftBasic.BoolArrayToByte(values);
|
byte[] buffer = new byte[7 + data.length];
|
buffer[0] = this.Station < 0 ? station : (byte) this.Station;
|
buffer[1] = ModbusInfo.WriteCoil;
|
buffer[2] = Utilities.getBytes(this.getAddress())[1];
|
buffer[3] = Utilities.getBytes(this.getAddress())[0];
|
buffer[4] = (byte) (values.length / 256);
|
buffer[5] = (byte) (values.length % 256);
|
buffer[6] = (byte) (data.length);
|
System.arraycopy(data, 0, buffer, 7, data.length);
|
return buffer;
|
}
|
|
|
|
/**
|
* 创建一个写入批量寄存器的指令
|
* @param station 站号
|
* @param values 值
|
* @return 原始的modbus指令
|
*/
|
public byte[] CreateWriteRegister(byte station, byte[] values) {
|
byte[] buffer = new byte[7 + values.length];
|
buffer[0] = this.Station < 0 ? station : (byte) this.Station;
|
buffer[1] = ModbusInfo.WriteRegister;
|
buffer[2] = Utilities.getBytes(this.getAddress())[1];
|
buffer[3] = Utilities.getBytes(this.getAddress())[0];
|
buffer[4] = (byte) (values.length / 2 / 256);
|
buffer[5] = (byte) (values.length / 2 % 256);
|
buffer[6] = (byte) (values.length);
|
System.arraycopy(values, 0, buffer, 7, values.length);
|
return buffer;
|
}
|
|
|
|
/**
|
* 地址新增指定的数
|
* @param value 地址值
|
* @return 新增后的地址信息
|
*/
|
public ModbusAddress AddressAdd(int value) {
|
ModbusAddress address = new ModbusAddress();
|
address.setAddress(getAddress() + value);
|
address.setFunction(getFunction());
|
address.setStation(getStation());
|
return address;
|
}
|
|
|
|
/**
|
* 地址新增1
|
* @return 新增后的地址信息
|
*/
|
public ModbusAddress AddressAdd() {
|
return AddressAdd(1);
|
}
|
|
|
|
/**
|
* 获取本对象的字符串表示形式
|
* @return 字符串数据
|
*/
|
@Override
|
public String toString() {
|
StringBuilder sb = new StringBuilder();
|
if (Station >= 0) sb.append("s=" + Station + ";");
|
if (Function >= 1) sb.append("x=" + Function + ";");
|
sb.append(String.valueOf(getAddress()));
|
|
return sb.toString();
|
}
|
|
}
|
