diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/device/controller/DeviceController.java b/src/main/java/com/zsc/edu/gateway/modules/iot/device/controller/DeviceController.java index 3315907..b17ebd4 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/iot/device/controller/DeviceController.java +++ b/src/main/java/com/zsc/edu/gateway/modules/iot/device/controller/DeviceController.java @@ -15,14 +15,11 @@ import com.zsc.edu.gateway.modules.iot.device.vo.DeviceVo; import com.zsc.edu.gateway.modules.iot.record.entity.RecordData; import com.zsc.edu.gateway.modules.iot.record.service.RecordDataService; import com.zsc.edu.gateway.modules.operationLog.entity.OperationLogAnnotation; -import jakarta.annotation.Resource; import lombok.AllArgsConstructor; import org.springframework.http.HttpStatus; -import org.springframework.http.MediaType; import org.springframework.http.ResponseEntity; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.web.bind.annotation.*; -import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; import java.util.List; diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java b/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java index c1ae71c..5b3bc70 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java +++ b/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java @@ -240,4 +240,4 @@ public class DeviceServiceImpl extends ServiceImpl imp device.setOnline(!device.getOnline()); return baseMapper.updateById(device); } -} +} \ No newline at end of file diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/record/service/impl/RecordDataServiceImpl.java b/src/main/java/com/zsc/edu/gateway/modules/iot/record/service/impl/RecordDataServiceImpl.java index f84bab7..53e9fd3 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/iot/record/service/impl/RecordDataServiceImpl.java +++ b/src/main/java/com/zsc/edu/gateway/modules/iot/record/service/impl/RecordDataServiceImpl.java @@ -1,5 +1,6 @@ package com.zsc.edu.gateway.modules.iot.record.service.impl; +import com.alibaba.fastjson2.JSONException; import com.alibaba.fastjson2.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; @@ -106,7 +107,7 @@ public class RecordDataServiceImpl extends ServiceImpl events = eventRepository.selectByProductId(device.getProductId(), true); if (events.isEmpty()) { - return; // 如果没有事件,直接返回 + throw new JSONException("该设备下事件并未启用!或者该设备下无定义事件!"); } // 遍历每个事件 diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/tsl/controller/EventController.java b/src/main/java/com/zsc/edu/gateway/modules/iot/tsl/controller/EventController.java index decaa29..4e6c09d 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/iot/tsl/controller/EventController.java +++ b/src/main/java/com/zsc/edu/gateway/modules/iot/tsl/controller/EventController.java @@ -74,12 +74,12 @@ public class EventController { * @param page 分页参数 * @return Page 事件分页数据 */ - @GetMapping("/log") + @GetMapping("/{clientId}/log") @PreAuthorize("hasAuthority('iot:event:query')") - public IPage eventLogPage(Page page, String clientId) { + public IPage eventLogPage(Page page, @PathVariable("clientId") String clientId) { return eventLogRepository.selectPage(page, new LambdaQueryWrapper().eq(EventLog::getRecordId, clientId)); } - +//TODO 详情接口 /** * 删除事件