| | |
| | | package com.mes.mechanicalMonitor.controller; |
| | | |
| | | import cn.hutool.json.JSONObject; |
| | | import com.mes.mechanicalMonitor.entity.MechanicalMonitor; |
| | | import com.mes.mechanicalMonitor.service.MechanicalMonitorService; |
| | | import com.mes.tools.WebSocketServer; |
| | | import com.mes.utils.Result; |
| | | import com.mes.websocket.WebSocketServer; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.web.bind.annotation.*; |
| | | import cn.hutool.json.JSONObject; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | @Api(tags = "设备状态监控") |
| | |
| | | @ResponseBody |
| | | public Result updateMechanicalStatus(@RequestBody JSONObject status) { |
| | | try { |
| | | ArrayList<WebSocketServer> servers = WebSocketServer.sessionMap.get("mechanicalMonitor"); |
| | | List<WebSocketServer> servers = WebSocketServer.SESSIONMAP.get("mechanicalMonitor"); |
| | | if (servers != null) { |
| | | for (WebSocketServer server : servers) { |
| | | server.sendMessage(status.toString()); |
| | | server.sendToWeb("",status.toString()); |
| | | } |
| | | } |
| | | return Result.build(200, "状态更新成功", null); |