1. 增加协议编码异常日志
This commit is contained in:
黄昕
parent
a6a55309e2
commit
cf4eb120f7
|
|
@ -6,7 +6,6 @@ import com.zjyr.beidouservice.pojo.vo.binary.BaseBinaryProtocol;
|
|||
import com.zjyr.beidouservice.pojo.vo.binary.HeartProtocol;
|
||||
import com.zjyr.beidouservice.pojo.vo.binary.QuerySensorProtocol;
|
||||
import com.zjyr.beidouservice.pojo.vo.binary.SensorControlProtocol;
|
||||
import com.zjyr.beidouservice.pojo.vo.binary.SensorId;
|
||||
import io.netty.buffer.ByteBuf;
|
||||
import io.netty.buffer.ByteBufUtil;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
|
|
@ -31,85 +30,86 @@ public class YuanRongProtocolEncode<T> extends MessageToByteEncoder<BaseBinaryPr
|
|||
return;
|
||||
}
|
||||
|
||||
T msgBody = baseBinaryProtocol.getMsgContent().getMsgBody();
|
||||
try {
|
||||
T msgBody = baseBinaryProtocol.getMsgContent().getMsgBody();
|
||||
|
||||
byteBuf.writeByte(BaseBinaryProtocol.VERSIN & 0xFF); // 协议版本号
|
||||
byteBuf.writeByte(baseBinaryProtocol.getCryptoType()); // 协议加密选项
|
||||
byteBuf.writeInt((int) (System.currentTimeMillis() / 1000)); // UTC时间戳，单位秒，协议发送时的UTC时间
|
||||
byteBuf.writeInt(baseBinaryProtocol.getStatusCode()); // 消息状态码
|
||||
byteBuf.writeByte(BaseBinaryProtocol.VERSIN & 0xFF); // 协议版本号
|
||||
byteBuf.writeByte(baseBinaryProtocol.getCryptoType()); // 协议加密选项
|
||||
byteBuf.writeInt((int) (System.currentTimeMillis() / 1000)); // UTC时间戳，单位秒，协议发送时的UTC时间
|
||||
byteBuf.writeInt(baseBinaryProtocol.getStatusCode()); // 消息状态码
|
||||
|
||||
if (msgBody instanceof HeartProtocol heartProtocol) {
|
||||
byteBuf.writeByte(ControlCommandName.COMMAND_HEART.getValue().byteValue()); // 消息类型
|
||||
byteBuf.writeShort(4); // 消息内容长度
|
||||
byteBuf.writeInt(heartProtocol.getSeqId());
|
||||
} else if (msgBody instanceof SensorControlProtocol msg) {
|
||||
int ttsSize;
|
||||
byte[] ttsArray = new byte[0];
|
||||
if (msgBody instanceof HeartProtocol heartProtocol) {
|
||||
byteBuf.writeByte(ControlCommandName.COMMAND_HEART.getValue().byteValue()); // 消息类型
|
||||
byteBuf.writeShort(4); // 消息内容长度
|
||||
byteBuf.writeInt(heartProtocol.getSeqId());
|
||||
} else if (msgBody instanceof SensorControlProtocol msg) {
|
||||
int ttsSize;
|
||||
byte[] ttsArray = new byte[0];
|
||||
|
||||
if (msg.getTtsContent() != null && !msg.getTtsContent().isEmpty()) {
|
||||
//ttsArray = msg.getTtsContent().getBytes(StandardCharsets.UTF_16BE);
|
||||
ttsArray = HelperUtils.convertStringToGB2312(msg.getTtsContent());
|
||||
ttsSize = ttsArray.length;
|
||||
} else {
|
||||
ttsSize = 0;
|
||||
}
|
||||
|
||||
byteBuf.writeByte(ControlCommandName.COMMAND_SENSOR.getValue().byteValue()); // 消息类型
|
||||
// 消息内容长度
|
||||
byteBuf.writeShort(27 + ttsSize + msg.getCityCode().size() + msg.getDistrictsCode().size() + msg.getSensorId().size() * 2);
|
||||
// 任务ID, 当前长度 4
|
||||
byteBuf.writeInt(msg.getTaskId());
|
||||
// 警报控制, 当前长度 5
|
||||
byteBuf.writeByte(msg.getAlarmMode().getValue().byteValue());
|
||||
// 警报模式, 当前长度 6
|
||||
byteBuf.writeByte(msg.getAlarmControlType().getValue().byteValue());
|
||||
// 警报类型, 当前长度 7
|
||||
byteBuf.writeByte(msg.getAlarmType().getValue().byteValue());
|
||||
// 警报通道, 当前长度 8
|
||||
byteBuf.writeByte(msg.getControlTunnel().byteValue());
|
||||
// 警报时间, 当前长度 12
|
||||
byteBuf.writeInt(msg.getTimeStamp());
|
||||
// 警报重复次数, 当前长度 13
|
||||
byteBuf.writeByte(msg.getRepeatTimes().byteValue());
|
||||
// 北斗ID, 当前长度 21
|
||||
byteBuf.writeLong(msg.getBeidouCommunicationId());
|
||||
// 省ID, 当前长度 22(不含可变内容长度)
|
||||
byteBuf.writeByte(msg.getProviceCode().byteValue());
|
||||
// TTS 内容长度, 当前长度 24
|
||||
byteBuf.writeShort((short) ttsSize);
|
||||
if (ttsSize > 0) {
|
||||
byteBuf.writeBytes(ttsArray);
|
||||
}
|
||||
|
||||
if (msg.getCityCode().isEmpty()) {
|
||||
byteBuf.writeByte(0);
|
||||
} else {
|
||||
byteBuf.writeByte(msg.getCityCode().size());
|
||||
for (var c : msg.getCityCode()) {
|
||||
byteBuf.writeByte(c.byteValue());
|
||||
if (msg.getTtsContent() != null && !msg.getTtsContent().isEmpty()) {
|
||||
//ttsArray = msg.getTtsContent().getBytes(StandardCharsets.UTF_16BE);
|
||||
ttsArray = HelperUtils.convertStringToGB2312(msg.getTtsContent());
|
||||
ttsSize = ttsArray.length;
|
||||
} else {
|
||||
ttsSize = 0;
|
||||
}
|
||||
}
|
||||
|
||||
if (msg.getDistrictsCode().isEmpty()) {
|
||||
byteBuf.writeByte(0);
|
||||
} else {
|
||||
byteBuf.writeByte(msg.getDistrictsCode().size());
|
||||
for (var c : msg.getDistrictsCode()) {
|
||||
byteBuf.writeByte(c.byteValue());
|
||||
byteBuf.writeByte(ControlCommandName.COMMAND_SENSOR.getValue().byteValue()); // 消息类型
|
||||
// 消息内容长度
|
||||
byteBuf.writeShort(27 + ttsSize + msg.getCityCode().size() + msg.getDistrictsCode().size() + msg.getSensorId().size() * 2);
|
||||
// 任务ID, 当前长度 4
|
||||
byteBuf.writeInt(msg.getTaskId());
|
||||
// 警报控制, 当前长度 5
|
||||
byteBuf.writeByte(msg.getAlarmMode().getValue().byteValue());
|
||||
// 警报模式, 当前长度 6
|
||||
byteBuf.writeByte(msg.getAlarmControlType().getValue().byteValue());
|
||||
// 警报类型, 当前长度 7
|
||||
byteBuf.writeByte(msg.getAlarmType().getValue().byteValue());
|
||||
// 警报通道, 当前长度 8
|
||||
byteBuf.writeByte(msg.getControlTunnel().byteValue());
|
||||
// 警报时间, 当前长度 12
|
||||
byteBuf.writeInt(msg.getTimeStamp());
|
||||
// 警报重复次数, 当前长度 13
|
||||
byteBuf.writeByte(msg.getRepeatTimes().byteValue());
|
||||
// 北斗ID, 当前长度 21
|
||||
byteBuf.writeLong(msg.getBeidouCommunicationId());
|
||||
// 省ID, 当前长度 22(不含可变内容长度)
|
||||
byteBuf.writeByte(msg.getProviceCode().byteValue());
|
||||
// TTS 内容长度, 当前长度 24
|
||||
byteBuf.writeShort((short) ttsSize);
|
||||
if (ttsSize > 0) {
|
||||
byteBuf.writeBytes(ttsArray);
|
||||
}
|
||||
}
|
||||
|
||||
if (msg.getSensorId().isEmpty()) {
|
||||
byteBuf.writeByte(0);
|
||||
} else {
|
||||
byteBuf.writeByte(msg.getSensorId().size());
|
||||
for (var c : msg.getSensorId()) {
|
||||
byteBuf.writeByte(c.getCountyId());
|
||||
byteBuf.writeByte(c.getSeqId());
|
||||
if (msg.getCityCode().isEmpty()) {
|
||||
byteBuf.writeByte(0);
|
||||
} else {
|
||||
byteBuf.writeByte(msg.getCityCode().size());
|
||||
for (var c : msg.getCityCode()) {
|
||||
byteBuf.writeByte(c.byteValue());
|
||||
}
|
||||
}
|
||||
}
|
||||
} else if (msgBody instanceof QuerySensorProtocol msg) {
|
||||
byteBuf.writeByte(ControlCommandName.COMMAND_QUERY_SENSOR.getValue().byteValue()); // 消息类型
|
||||
|
||||
if (msg.getDistrictsCode().isEmpty()) {
|
||||
byteBuf.writeByte(0);
|
||||
} else {
|
||||
byteBuf.writeByte(msg.getDistrictsCode().size());
|
||||
for (var c : msg.getDistrictsCode()) {
|
||||
byteBuf.writeByte(c.byteValue());
|
||||
}
|
||||
}
|
||||
|
||||
if (msg.getSensorId().isEmpty()) {
|
||||
byteBuf.writeByte(0);
|
||||
} else {
|
||||
byteBuf.writeByte(msg.getSensorId().size());
|
||||
for (var c : msg.getSensorId()) {
|
||||
byteBuf.writeByte(c.getCountyId());
|
||||
byteBuf.writeByte(c.getSeqId());
|
||||
}
|
||||
}
|
||||
} else if (msgBody instanceof QuerySensorProtocol msg) {
|
||||
byteBuf.writeByte(ControlCommandName.COMMAND_QUERY_SENSOR.getValue().byteValue()); // 消息类型
|
||||
|
||||
// if (!msg.getControllContents().isEmpty()) {
|
||||
// byteBuf.writeShort(2 + 4 * msg.getControllContents().size()); // 消息内容长度
|
||||
|
|
@ -122,10 +122,13 @@ public class YuanRongProtocolEncode<T> extends MessageToByteEncoder<BaseBinaryPr
|
|||
// byteBuf.writeShort(c.getSensorId());
|
||||
// }
|
||||
// }
|
||||
} else {
|
||||
log.info("XXXXX Encode: {}", baseBinaryProtocol.getMsgContent().getMsgBody().getClass());
|
||||
}
|
||||
} else {
|
||||
log.info("XXXXX Encode: {}", baseBinaryProtocol.getMsgContent().getMsgBody().getClass());
|
||||
}
|
||||
|
||||
log.info("\n{}", ByteBufUtil.prettyHexDump(byteBuf));
|
||||
log.info("\n{}", ByteBufUtil.prettyHexDump(byteBuf));
|
||||
} catch (Exception e) {
|
||||
log.error("Protocol Encode Exception: {}", e.getMessage());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue