websocket 接口修改 gengdidi

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

@@ -3,8 +3,6 @@ package com.zehong.web.controller.websocket;
 import com.alibaba.fastjson.JSONObject;
 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;
@@ -25,25 +23,11 @@ public class WebSocketController {
     @Autowired
     private ITDeviceAlarmService itDeviceAlarmService;
 
-    @Autowired
-    private ITDeviceInfoService itDeviceInfoService;
-
-    @Autowired
-    private ITPipeService itPipeService;
-
-    private final static String PIPE_TYPE = "0";
 
     @GetMapping("/send")
     public void send(int alarmId){
         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(JSONObject.toJSONString(alarm));
         } catch (Exception e) {
             log.error("wesocket发送失败！");