From aef24057513ce1d0587761276d10e0b76fa57465 Mon Sep 17 00:00:00 2001 From: lzh Date: Mon, 19 Jan 2026 17:28:17 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E6=94=B9=E9=89=B4=E6=9D=83?= =?UTF-8?q?=E7=A0=81=E4=B8=BAtesttoken?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/terminal/RegisterHandler.java | 47 ++++++++++--------- 1 file changed, 24 insertions(+), 23 deletions(-) diff --git a/src/main/java/com/iot/transport/jt808/service/handler/terminal/RegisterHandler.java b/src/main/java/com/iot/transport/jt808/service/handler/terminal/RegisterHandler.java index c648c0d..dea1bbd 100644 --- a/src/main/java/com/iot/transport/jt808/service/handler/terminal/RegisterHandler.java +++ b/src/main/java/com/iot/transport/jt808/service/handler/terminal/RegisterHandler.java @@ -12,50 +12,51 @@ import com.iot.transport.jt808.service.handler.MessageHandler; /** * 终端注册 ==> 终端注册应答 + * * @author huaxl */ public class RegisterHandler extends MessageHandler { private final Logger logger = LoggerFactory.getLogger(getClass()); - + public RegisterHandler() { super(); } @Override public void process(DataPack packageData) { - + PackHead header = packageData.getPackHead(); - logger.info("[终端注册],msgid={}, phone={},flowid={}", header.getId(), header.getTerminalPhone(), header.getFlowId()); + logger.info("[终端注册],msgid={}, phone={},flowid={}", header.getId(), header.getTerminalPhone(), + header.getFlowId()); try { - + RegisterPack msg = this.decoder.toTerminalRegisterMsg(packageData); log.debug("终端注册:{}", msg); - - final String sessionId = Session.buildId(msg.getChannel()); - Session session = sessionManager.findBySessionId(sessionId); - if (session == null) { - session = Session.buildSession(msg.getChannel(), msg.getPackHead().getTerminalPhone()); - } - session.setAuthenticated(true); - session.setTerminalPhone(msg.getPackHead().getTerminalPhone()); - sessionManager.put(session.getId(), session); - RegisterBodyPack respMsgBody = new RegisterBodyPack(); - respMsgBody.setReplyCode(RegisterBodyPack.success); - respMsgBody.setReplyFlowId(msg.getPackHead().getFlowId()); - // 使用手机号作为鉴权码 - respMsgBody.setReplyToken(msg.getPackHead().getTerminalPhone()); - - int flowId = super.getFlowId(msg.getChannel()); - byte[] bs = this.msgEncoder.encode4TerminalRegisterResp(msg, respMsgBody, flowId); + final String sessionId = Session.buildId(msg.getChannel()); + Session session = sessionManager.findBySessionId(sessionId); + if (session == null) { + session = Session.buildSession(msg.getChannel(), msg.getPackHead().getTerminalPhone()); + } + session.setAuthenticated(true); + session.setTerminalPhone(msg.getPackHead().getTerminalPhone()); + sessionManager.put(session.getId(), session); - super.send2Client(msg.getChannel(), bs); + RegisterBodyPack respMsgBody = new RegisterBodyPack(); + respMsgBody.setReplyCode(RegisterBodyPack.success); + respMsgBody.setReplyFlowId(msg.getPackHead().getFlowId()); + // 使用固定鉴权码 + respMsgBody.setReplyToken("testtoken"); + + int flowId = super.getFlowId(msg.getChannel()); + byte[] bs = this.msgEncoder.encode4TerminalRegisterResp(msg, respMsgBody, flowId); + + super.send2Client(msg.getChannel(), bs); } catch (Exception e) { logger.error("<<<<