异常问题修改 gengdidi

gassafety-admin/src/main/java/com/zehong/web/controller/websocket/WebSocketController.java

 package com.zehong.web.controller.websocket;
 
-import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
-import com.zehong.system.domain.TDeviceAlarm;
+import com.zehong.system.domain.vo.DeviceAlarmVo;
 import com.zehong.system.service.ITDeviceAlarmService;
 import com.zehong.system.service.ITDeviceInfoService;
 import com.zehong.system.service.ITPipeService;
 import com.zehong.system.service.WebSocketServer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.List;
-
 @RestController
 @RequestMapping("/websocket")
 public class WebSocketController {
 
+    private static final Logger log = LoggerFactory.getLogger(WebSocketController.class);
+
     @Autowired
     private WebSocketServer webSocketServer;
 
@@ -34,14 +35,19 @@ public class WebSocketController {
 
     @GetMapping("/send")
     public void send(int alarmId){
-        TDeviceAlarm alarm = itDeviceAlarmService.selectTDeviceAlarmById(alarmId);
-        JSONObject json = new JSONObject();
-        json.put("alarmInfo",alarm);
-        if(PIPE_TYPE.equals(alarm.getAlarmType())){
-            json.put("deviceInfo",itPipeService.selectTPipeById(alarm.getDeviceId()));
-        }else{
-            json.put("deviceInfo",itDeviceInfoService.selectTDeviceInfoById(alarm.getDeviceId()));
+        try {
+            DeviceAlarmVo alarm = itDeviceAlarmService.selectTDeviceAlarmById(alarmId);
+            JSONObject json = new JSONObject();
+            json.put("alarmInfo",alarm);
+            if(PIPE_TYPE.equals(alarm.getAlarmType())){
+                json.put("deviceInfo",itPipeService.selectTPipeById(alarm.getDeviceId()));
+            }else{
+                json.put("deviceInfo",itDeviceInfoService.selectTDeviceInfoById(alarm.getDeviceId()));
+            }
+            webSocketServer.batchSendMessage(alarm.toString());
+        } catch (Exception e) {
+            log.error("wesocket发送失败！");
         }
-        webSocketServer.batchSendMessage(alarm.toString());
+
     }
 }