package org.yzh.protocol.t808;
|
|
import io.github.yezhihao.protostar.annotation.Field;
|
import io.github.yezhihao.protostar.annotation.Message;
|
import io.github.yezhihao.protostar.util.KeyValuePair;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
import lombok.Data;
|
import lombok.ToString;
|
import lombok.experimental.Accessors;
|
import org.yzh.protocol.basics.JTMessage;
|
import org.yzh.protocol.commons.JT808;
|
import org.yzh.protocol.commons.transform.PassthroughConverter;
|
import org.yzh.protocol.commons.transform.passthrough.PeripheralStatus;
|
import org.yzh.protocol.commons.transform.passthrough.PeripheralSystem;
|
import org.yzh.protocol.t808.T8900Lock.*;
|
|
import java.nio.ByteBuffer;
|
|
/**
|
* @author yezhihao
|
* https://gitee.com/yezhihao/jt808-server
|
*/
|
@ToString
|
@Data
|
@Accessors(chain = true)
|
@Message(JT808.数据下行透传)
|
public class T8900 extends JTMessage {
|
|
/** GNSS模块详细定位数据 */
|
public static final int GNSSLocation = 0x00;
|
/** 道路运输证IC卡信息上传消息为64Byte,下传消息为24Byte,道路运输证IC卡认证透传超时时间为30s.超时后,不重发 */
|
public static final int ICCardInfo = 0x0B;
|
/** 串口1透传消息 */
|
public static final int SerialPortOne = 0x41;
|
/** 串口2透传消息 */
|
public static final int SerialPortTow = 0x42;
|
/** 用户自定义透传 0xF0~0xFF */
|
public static final int Custom = 0xF0;
|
|
@Field(desc = "透传消息", converter = PassthroughConverter.class)
|
private KeyValuePair<Integer, Object> message;
|
|
@Schema(description = "状态查询(外设状态信息：外设工作状态、设备报警信息)")
|
private PeripheralStatus peripheralStatus;
|
|
@Schema(description = "信息查询(外设传感器的基本信息：公司信息、产品代码、版本号、外设ID、客户代码)")
|
private PeripheralSystem peripheralSystem;
|
|
// 新增：蝶阀锁协议字段
|
@Schema(description = "蝶阀锁控制消息")
|
private ValveLockProtocol valveLockProtocol;
|
// 新增：蝶阀锁状态协议字段
|
@Schema(description = "蝶阀锁状态消息")
|
private T8900State t8900State;
|
// 新增：蝶阀锁读设备号字段
|
@Schema(description = "蝶阀锁读设备号协议")
|
private T8900ReadDeviceID readDeviceID;
|
// 新增：蝶阀锁设置设备号
|
@Schema(description = "蝶阀锁设置设备号")
|
private T8900SetDeviceID setDeviceID;
|
// 新增：蝶阀锁读所有信息
|
@Schema(description = "蝶阀锁读所有信息")
|
private T8900ReadAllInformation readAllInformation;
|
// 新增：蝶阀锁设置离线开锁密码
|
@Schema(description = "蝶阀锁设置离线开锁密码")
|
private T8900SetPassword setPassword;
|
|
public T8900 build() {
|
KeyValuePair<Integer, Object> message = new KeyValuePair<>();
|
|
/*2025-05-24 zwy新增*/
|
if (valveLockProtocol != null) {
|
// 计算蝶阀锁协议的校验和（修正为求和取低8位）
|
valveLockProtocol.calculateChecksum();
|
//VALVE_LOCK_MESSAGE_TYPE
|
message.setKey(SerialPortOne);
|
//****组建蝶阀消息体****
|
// 锁芯状态
|
byte statusByte = valveLockProtocol.getStatus();
|
// 计算校验和 (前4个字节的和)
|
byte checksum = valveLockProtocol.getChecksum();
|
// 构建完整消息
|
ByteBuffer buffer = ByteBuffer.allocate(5);
|
buffer.put(valveLockProtocol.getLockId()); // AA AA
|
buffer.put(valveLockProtocol.getFixedValue()); // 固定值02
|
buffer.put(statusByte); // CC
|
buffer.put(checksum); // BB
|
|
message.setValue(buffer.array());
|
} else if (t8900State != null) {
|
//查询碟阀锁状态
|
byte checksum = t8900State.calculateChecksum();
|
ByteBuffer buffer = ByteBuffer.allocate(4);
|
buffer.put(t8900State.getLockId());
|
buffer.put(t8900State.getCommandType());
|
buffer.put(checksum);
|
message.setKey(SerialPortOne);
|
message.setValue(buffer.array());
|
} else if(readDeviceID != null){
|
//读设备号
|
byte checksum = readDeviceID.calculateChecksum();
|
ByteBuffer buffer = ByteBuffer.allocate(4);
|
buffer.put(readDeviceID.getLockId());
|
buffer.put(readDeviceID.getCommandType());
|
buffer.put(checksum);
|
message.setKey(SerialPortOne);
|
message.setValue(buffer.array());
|
} else if(setDeviceID != null){
|
//设置设备号
|
byte checksum = setDeviceID.calculateChecksum();
|
ByteBuffer buffer = ByteBuffer.allocate(6);
|
buffer.put(setDeviceID.getLockId());
|
buffer.put(setDeviceID.getCommandType());
|
buffer.put(setDeviceID.getNewlockId());
|
buffer.put(checksum);
|
message.setKey(SerialPortOne);
|
message.setValue(buffer.array());
|
} else if (readAllInformation != null ){
|
// 读所有信息
|
byte checksum = readAllInformation.calculateChecksum();
|
ByteBuffer buffer = ByteBuffer.allocate(10);
|
buffer.put(readAllInformation.getLockId());
|
buffer.put(readAllInformation.getCommandType());
|
buffer.put(readAllInformation.getYear());
|
buffer.put(readAllInformation.getMonth());
|
buffer.put(readAllInformation.getDay());
|
buffer.put(readAllInformation.getHour());
|
buffer.put(readAllInformation.getMinute());
|
buffer.put(readAllInformation.getSecond());
|
buffer.put(checksum);
|
message.setKey(SerialPortOne);
|
message.setValue(buffer.array());
|
} else if(setPassword != null){
|
//设置蝶阀锁离线开锁密码
|
ByteBuffer buffer = ByteBuffer.allocate(64);
|
buffer.put(setPassword.getLockId());
|
buffer.put(setPassword.getCommandType());
|
buffer.put(setPassword.getPassword1());
|
buffer.put(setPassword.getPassword2());
|
buffer.put(setPassword.getPassword3());
|
buffer.put(setPassword.getPassword4());
|
buffer.put(setPassword.getPassword5());
|
buffer.put(setPassword.getPassword6());
|
buffer.put(setPassword.getPassword7());
|
buffer.put(setPassword.getPassword8());
|
buffer.put(setPassword.getPassword9());
|
buffer.put(setPassword.getPassword10());
|
byte checksum =setPassword.calculateSUMChecksum(buffer.array());
|
buffer.put(checksum);
|
message.setKey(SerialPortOne);
|
message.setValue(buffer.array());
|
} else if (peripheralStatus != null) {
|
message.setKey(PeripheralStatus.key);
|
message.setValue(peripheralStatus);
|
|
} else if (peripheralSystem != null) {
|
message.setKey(PeripheralSystem.key);
|
message.setValue(peripheralSystem);
|
}
|
this.message = message;
|
return this;
|
}
|
}
|
