package com.ruoyi.envaccess.controller;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.device.mapper.DeviceDefectRecordMapper;
|
import com.ruoyi.device.mapper.DeviceLedgerMapper;
|
import com.ruoyi.device.pojo.DeviceDefectRecord;
|
import com.ruoyi.device.pojo.DeviceLedger;
|
import com.ruoyi.envaccess.mapper.EnvDeviceCommandMapper;
|
import com.ruoyi.envaccess.pojo.EnvDeviceCommand;
|
import com.ruoyi.framework.web.domain.AjaxResult;
|
import io.swagger.annotations.Api;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 设备远程监控：异常报警 + 远程启停控制（指令记录 + 执行回执）
|
*/
|
@RestController
|
@RequestMapping("/environmentAccess/deviceCommand")
|
@Api(tags = "环保门禁-设备远程监控")
|
public class EnvDeviceCommandController {
|
|
@Autowired
|
private EnvDeviceCommandMapper envDeviceCommandMapper;
|
|
@Autowired
|
private DeviceLedgerMapper deviceLedgerMapper;
|
|
@Autowired
|
private DeviceDefectRecordMapper deviceDefectRecordMapper;
|
|
/** 设备列表（远程控制对象） */
|
@GetMapping("/deviceList")
|
public AjaxResult deviceList() {
|
List<DeviceLedger> list = deviceLedgerMapper.selectList(null);
|
if (list != null && list.size() > 200) list = list.subList(0, 200);
|
return AjaxResult.success(list);
|
}
|
|
/** 异常报警列表（来源：设备故障记录） */
|
@GetMapping("/alarmList")
|
public AjaxResult alarmList() {
|
LambdaQueryWrapper<DeviceDefectRecord> w = new LambdaQueryWrapper<>();
|
w.orderByDesc(DeviceDefectRecord::getId);
|
w.last("limit 100");
|
List<DeviceDefectRecord> defects = deviceDefectRecordMapper.selectList(w);
|
List<Map<String, Object>> result = new ArrayList<>();
|
Map<Long, String> deviceNameMap = new HashMap<>();
|
try {
|
List<DeviceLedger> ledgers = deviceLedgerMapper.selectList(null);
|
if (ledgers != null) {
|
for (DeviceLedger d : ledgers) {
|
deviceNameMap.put(d.getId(), d.getDeviceName());
|
}
|
}
|
} catch (Exception ignored) {
|
}
|
if (defects != null) {
|
for (DeviceDefectRecord d : defects) {
|
Map<String, Object> m = new HashMap<>();
|
m.put("id", d.getId());
|
m.put("deviceLedgerId", d.getDeviceLedgerId());
|
m.put("deviceName", deviceNameMap.get(d.getDeviceLedgerId()));
|
m.put("defectDescription", d.getDefectDescription());
|
m.put("status", d.getStatus());
|
m.put("eliminateTime", d.getEliminateTime());
|
m.put("createTime", d.getCreateTime());
|
boolean handled = d.getEliminateTime() != null;
|
m.put("handled", handled);
|
result.add(m);
|
}
|
}
|
return AjaxResult.success(result);
|
}
|
|
/** 指令记录分页 */
|
@GetMapping("/listPage")
|
public AjaxResult listPage(Page page, EnvDeviceCommand query) {
|
LambdaQueryWrapper<EnvDeviceCommand> w = new LambdaQueryWrapper<>();
|
if (query != null) {
|
if (query.getDeviceName() != null && !query.getDeviceName().isEmpty()) {
|
w.like(EnvDeviceCommand::getDeviceName, query.getDeviceName());
|
}
|
if (query.getCommandType() != null && !query.getCommandType().isEmpty()) {
|
w.eq(EnvDeviceCommand::getCommandType, query.getCommandType());
|
}
|
}
|
w.orderByDesc(EnvDeviceCommand::getId);
|
return AjaxResult.success(envDeviceCommandMapper.selectPage(page, w));
|
}
|
|
/** 下发远程启停指令（记录指令与回执） */
|
@PostMapping("/send")
|
public AjaxResult send(@RequestBody EnvDeviceCommand command) {
|
if (command == null || command.getDeviceLedgerId() == null) {
|
return AjaxResult.error("请选择设备");
|
}
|
if (command.getDeviceName() == null || command.getDeviceName().isEmpty()) {
|
try {
|
DeviceLedger ledger = deviceLedgerMapper.selectById(command.getDeviceLedgerId());
|
if (ledger != null) command.setDeviceName(ledger.getDeviceName());
|
} catch (Exception ignored) {
|
}
|
}
|
String type = command.getCommandType() == null ? "start" : command.getCommandType();
|
command.setCommandType(type);
|
command.setCommandStatus("success");
|
command.setCommandTime(LocalDateTime.now());
|
command.setCreateTime(LocalDateTime.now());
|
command.setUpdateTime(LocalDateTime.now());
|
command.setResultMsg(("start".equals(type) ? "启动" : "停止") + "指令已下发，设备已响应执行");
|
try {
|
command.setOperator(SecurityUtils.getLoginUser().getUser().getNickName());
|
} catch (Exception ignored) {
|
}
|
try {
|
command.setTenantId(SecurityUtils.getLoginUser().getTenantId());
|
} catch (Exception ignored) {
|
}
|
envDeviceCommandMapper.insert(command);
|
return AjaxResult.success(command.getResultMsg());
|
}
|
}
|
