This commit is contained in:
parent
86a1ca4a1d
commit
863879c031
|
|
@ -1,7 +1,11 @@
|
|||
package com.ruoyi.device.websocket;
|
||||
|
||||
import com.alibaba.fastjson2.JSON;
|
||||
import com.ruoyi.device.service.api.IBufferDeviceService;
|
||||
import com.ruoyi.device.service.dto.DockDetailDTO;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import jakarta.websocket.*;
|
||||
|
|
@ -55,9 +59,14 @@ public class StatisticsWebSocket {
|
|||
}
|
||||
}
|
||||
|
||||
public static void broadcast(String message) {
|
||||
@Autowired
|
||||
private IBufferDeviceService bufferDeviceService;
|
||||
|
||||
|
||||
public void broadcast(String dockerId) {
|
||||
for (StatisticsWebSocket ws : sessions) {
|
||||
ws.sendMessage(message);
|
||||
DockDetailDTO dockDetailDTO = bufferDeviceService.getDockDetailById(Long.valueOf(dockerId));
|
||||
ws.sendMessage(JSON.toJSONString(dockDetailDTO));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue