From c3ae430369cf68a762a9809bf7132bfad6e730bd Mon Sep 17 00:00:00 2001 From: dzq Date: Tue, 29 Apr 2025 16:43:29 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E7=9F=AD=E4=BF=A1?= =?UTF-8?q?=E5=8F=91=E9=80=81=E5=BC=82=E5=B8=B8=E5=A4=84=E7=90=86=E5=92=8C?= =?UTF-8?q?MQTT=E4=B8=BB=E9=A2=98=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 在WxLoginController中,捕获所有异常并记录错误日志,避免敏感信息泄露 - 更新MqttService中的MQTT主题和认证信息,确保与最新配置一致 --- .../com/agileboot/api/controller/WxLoginController.java | 5 +++-- .../main/java/com/agileboot/domain/mqtt/MqttService.java | 8 ++++++-- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/agileboot-api/src/main/java/com/agileboot/api/controller/WxLoginController.java b/agileboot-api/src/main/java/com/agileboot/api/controller/WxLoginController.java index 33c997d..19b50fa 100644 --- a/agileboot-api/src/main/java/com/agileboot/api/controller/WxLoginController.java +++ b/agileboot-api/src/main/java/com/agileboot/api/controller/WxLoginController.java @@ -69,8 +69,9 @@ public class WxLoginController { @RequestParam String tel) { try { return ResponseDTO.ok(Ab98ApiUtil.sendLoginSms(token, tel).getOutputData()); - } catch (ApiException e) { - return ResponseDTO.fail(e); + } catch (Exception e) { + log.error("短信发送失败: ", e); + return ResponseDTO.fail(); } } diff --git a/agileboot-domain/src/main/java/com/agileboot/domain/mqtt/MqttService.java b/agileboot-domain/src/main/java/com/agileboot/domain/mqtt/MqttService.java index 99f1911..3f5289f 100644 --- a/agileboot-domain/src/main/java/com/agileboot/domain/mqtt/MqttService.java +++ b/agileboot-domain/src/main/java/com/agileboot/domain/mqtt/MqttService.java @@ -19,8 +19,12 @@ public class MqttService implements MqttCallback { // private static final String TOPIC = "lock/down/S4202414S"; private static final String USERNAME = "sell"; private static final String PASSWORD = "sell@ys#6785$"; - private static final String TOPIC_FILTER = "lock/up/S5200184S"; - private static final String TOPIC = "lock/down/S5200184S"; +// private static final String TOPIC_FILTER = "lock/up/S5200184S"; +// private static final String TOPIC = "lock/down/S5200184S"; +// private static final String USERNAME = "iot"; +// private static final String PASSWORD = "iot@ys#9963$"; + private static final String TOPIC_FILTER = "hongfa/2401310026C50D24FE/upload/"; + private static final String TOPIC = "hongfa/2401310026C50D24FE/download/"; private MqttClient client; // 设置自定义消息处理器