package com.mes.mechanicalMonitor.controller;
|
|
import com.mes.mechanicalMonitor.entity.MechanicalMonitor;
|
import com.mes.mechanicalMonitor.service.MechanicalMonitorService;
|
import com.mes.tools.WebSocketServer;
|
import com.mes.utils.Result;
|
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.Map;
|
|
@Api(tags = "设备状态监控")
|
@RestController
|
@RequestMapping("/mechanicalMonitor")
|
public class MechanicalMonitorController {
|
|
@Autowired
|
private MechanicalMonitorService mechanicalMonitorService;
|
|
@ApiOperation("获取设备监控状态")
|
@PostMapping("/getMechanicalStatus")
|
@ResponseBody
|
public Result getMechanicalStatus() {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.append("sessionMapName", "mechanicalMonitor");
|
|
// 从数据库获取设备状态列表
|
List<MechanicalMonitor> deviceList = mechanicalMonitorService.getAllDeviceStatus();
|
|
Map<String, Object> data = new HashMap<>();
|
data.put("mechanicalStatus", deviceList);
|
return Result.build(200, "获取成功", data);
|
}
|
|
@ApiOperation("更新设备状态")
|
@PostMapping("/updateMechanicalStatus")
|
@ResponseBody
|
public Result updateMechanicalStatus(@RequestBody JSONObject status) {
|
try {
|
ArrayList<WebSocketServer> servers = WebSocketServer.sessionMap.get("mechanicalMonitor");
|
if (servers != null) {
|
for (WebSocketServer server : servers) {
|
server.sendMessage(status.toString());
|
}
|
}
|
return Result.build(200, "状态更新成功", null);
|
} catch (Exception e) {
|
return Result.build(500, "状态更新失败", null);
|
}
|
}
|
}
|
