| | |
| | | package com.mes.mechanicalMonitor.service.impl; |
| | | |
| | | import cn.hutool.json.JSONObject; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.mes.mechanicalMonitor.entity.MechanicalMonitor; |
| | | import com.mes.mechanicalMonitor.mapper.MechanicalMonitorMapper; |
| | | import com.mes.mechanicalMonitor.service.MechanicalMonitorService; |
| | | import com.mes.tools.WebSocketServer; |
| | | import cn.hutool.json.JSONObject; |
| | | import com.mes.websocket.WebSocketServer; |
| | | import org.springframework.stereotype.Service; |
| | | import java.util.List; |
| | | |
| | | import java.util.Date; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | | @Service |
| | | public class MechanicalMonitorServiceImpl extends ServiceImpl<MechanicalMonitorMapper, MechanicalMonitor> |
| | |
| | | message.set("type", "status_change"); |
| | | message.set("data", monitor); |
| | | |
| | | ArrayList<WebSocketServer> servers = WebSocketServer.sessionMap.get("mechanicalMonitor"); |
| | | List<WebSocketServer> servers = WebSocketServer.SESSIONMAP.get("mechanicalMonitor"); |
| | | if (servers != null) { |
| | | for (WebSocketServer server : servers) { |
| | | server.sendMessage(message.toString()); |
| | | server.sendToWeb("",message.toString()); |
| | | } |
| | | } |
| | | } |