From 77884116d97f7d611f2f4a18ea7780cfe3fb4263 Mon Sep 17 00:00:00 2001 From: wulin Date: Thu, 12 Oct 2023 16:09:19 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96MQ=E9=80=9A=E7=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/handler/BaseWebSocketProcess.java | 23 +++++++++++-------- 1 file changed, 14 insertions(+), 9 deletions(-) diff --git a/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java b/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java index 6c60c63..8f596e7 100644 --- a/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java +++ b/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java @@ -324,15 +324,20 @@ public class BaseWebSocketProcess { if(isOk.getCode().equals(RespCodeEnum.SUCESS.getCode())){ if(action.getDeviceUserBindEntity().getU3dId() != null){ log.info("通知U3DMQ"); - U3dMsg u3dMsg = new U3dMsg(); - u3dMsg.setMsgType(100); - u3dMsg.setMetaId(action.getDeviceUserBindEntity().getU3dId()); - u3dMsg.setScenceId(action.getDeviceUserBindEntity().getScenceId()); - u3dMsg.setStatusId(action.getSystemTalkAnswerConfigEntity().getU3dStatusId()); - //发送消息到MQ，通知U3D - mqService.sendMessage(YunxiRabbitConst.EXCHANGE_YUNXI_EVENT, - YunxiRabbitConst.ROUTE_KEY_YUNXI, - JSONObject.toJSONString(u3dMsg)).subscribe(); + try{ + U3dMsg u3dMsg = new U3dMsg(); + u3dMsg.setMsgType(100); + u3dMsg.setMetaId(action.getDeviceUserBindEntity().getU3dId()); + u3dMsg.setScenceId(action.getDeviceUserBindEntity().getScenceId()); + u3dMsg.setStatusId(action.getSystemTalkAnswerConfigEntity().getU3dStatusId()); + //发送消息到MQ，通知U3D + mqService.sendMessage(YunxiRabbitConst.EXCHANGE_YUNXI_EVENT, + YunxiRabbitConst.ROUTE_KEY_YUNXI, + JSONObject.toJSONString(u3dMsg)).subscribe(); + }catch (Exception e){ + log.info("通知U3D MQ异常{}", e); + } + } //通知打开灯成功