update 电单车协议

This commit is contained in:
Guoqs
2024-08-29 14:43:47 +08:00
parent 3b4604b6d4
commit 45ff60f052

View File

@@ -33,14 +33,14 @@ public class EBikeBusinessServiceImpl implements EBikeBusinessService {
@Override
public byte[] process(byte[] msg, ChannelHandlerContext ctx) {
EBikeDataProtocol ykcDataProtocol = new EBikeDataProtocol(msg);
EBikeDataProtocol eBikeDataProtocol = new EBikeDataProtocol(msg);
// 获取帧类型
String command = BytesUtil.bin2HexStr(ykcDataProtocol.getCommand());
log.info("收到消息, channelId:{}, msg:{}", ctx.channel().id().toString(), BytesUtil.binary(msg, 16));
String command = BytesUtil.bin2HexStr(eBikeDataProtocol.getCommand());
log.info("收到消息, channelId:{}, 指令:{}, msg:{}", ctx.channel().id().toString(), command, BytesUtil.binary(msg, 16));
// 获取业务处理handler
AbstractEBikeHandler invokeStrategy = EBikeOperateFactory.getInvokeStrategy(command);
if (invokeStrategy != null) {
return invokeStrategy.supplyProcess(ykcDataProtocol, ctx);
return invokeStrategy.supplyProcess(eBikeDataProtocol, ctx);
}
return null;
}