浏览代码

fix(SecondGoodsServiceImpl): 添加消息通知发送异常处理

在 sendNotice 方法中添加 try-catch 块,捕获发送消息时可能发生的异常,避免因消息发送失败导致的方法中断,并记录错误日志便于问题排查。
wxd 2 月之前
父节点
当前提交
95d261d783
共有 1 个文件被更改,包括 12 次插入8 次删除
  1. 12 8
      alien-second/src/main/java/shop/alien/second/service/impl/SecondGoodsServiceImpl.java

+ 12 - 8
alien-second/src/main/java/shop/alien/second/service/impl/SecondGoodsServiceImpl.java

@@ -975,14 +975,18 @@ public class SecondGoodsServiceImpl extends ServiceImpl<SecondGoodsMapper, Secon
     }
 
     private void sendNotice(String receiverId, LifeNotice lifeNotice) {
-        WebSocketVo webSocketVo = new WebSocketVo();
-        webSocketVo.setSenderId("system");
-        webSocketVo.setReceiverId(receiverId);
-        webSocketVo.setCategory("notice");
-        webSocketVo.setNoticeType("1");
-        webSocketVo.setIsRead(0);
-        webSocketVo.setText(JSONObject.from(lifeNotice).toJSONString());
-        alienStoreFeign.sendMsgToClientByPhoneId(receiverId, JSONObject.from(webSocketVo).toJSONString());
+        try {
+            WebSocketVo webSocketVo = new WebSocketVo();
+            webSocketVo.setSenderId("system");
+            webSocketVo.setReceiverId(receiverId);
+            webSocketVo.setCategory("notice");
+            webSocketVo.setNoticeType("1");
+            webSocketVo.setIsRead(0);
+            webSocketVo.setText(JSONObject.from(lifeNotice).toJSONString());
+            alienStoreFeign.sendMsgToClientByPhoneId(receiverId, JSONObject.from(webSocketVo).toJSONString());
+        } catch (Exception e) {
+            log.error("发送消息通知失败,receiverId: {}", receiverId, e);
+        }
     }
 
     /**