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 af1abdf..00d4a4a 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 @@ -17,6 +17,7 @@ import com.zsc.edu.gateway.modules.iot.device.vo.DeviceVo; import com.zsc.edu.gateway.modules.iot.record.entity.DataWarningVo; import com.zsc.edu.gateway.modules.iot.record.entity.RecordData; import com.zsc.edu.gateway.modules.iot.record.entity.RecordDataStatusVo; +import com.zsc.edu.gateway.modules.iot.record.repo.RecordDataRepository; import com.zsc.edu.gateway.modules.iot.record.service.RecordDataService; import lombok.AllArgsConstructor; import org.springframework.http.HttpStatus; @@ -34,6 +35,7 @@ import java.util.List; @RequestMapping("api/rest/device") public class DeviceController { + private final RecordDataRepository recordDataRepository; DeviceService service; RecordDataService recordService; @@ -114,12 +116,11 @@ public class DeviceController { /** * 查询设备上报记录 */ - @GetMapping("record/data") + @GetMapping("record/data/list") @PreAuthorize("hasAuthority('iot:device:query')") - public Page recordData(Page page, String clientId) { - return recordService.page(page, new LambdaQueryWrapper().eq(RecordData::getClientId, clientId)); + public IPage recordData(Page page, String clientId) { + return recordService.query(page, clientId); } - /** * 查询设备信息数量 */ diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/record/repo/RecordDataRepository.java b/src/main/java/com/zsc/edu/gateway/modules/iot/record/repo/RecordDataRepository.java index 52d57b3..473704a 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/iot/record/repo/RecordDataRepository.java +++ b/src/main/java/com/zsc/edu/gateway/modules/iot/record/repo/RecordDataRepository.java @@ -20,4 +20,6 @@ public interface RecordDataRepository extends BaseMapper { @Select("SELECT COUNT(*) FROM iot_record_data WHERE content->>'warning' IS NOT NULL AND (content->>'warning')::int & #{bitPosition} = #{bitPosition}") long countWarningsByBit(@Param("bitPosition") int bitPosition); + + List selectByClientId(@Param("clientId") String clientId); } diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/record/service/RecordDataService.java b/src/main/java/com/zsc/edu/gateway/modules/iot/record/service/RecordDataService.java index 53b003a..9054a04 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/iot/record/service/RecordDataService.java +++ b/src/main/java/com/zsc/edu/gateway/modules/iot/record/service/RecordDataService.java @@ -1,6 +1,8 @@ package com.zsc.edu.gateway.modules.iot.record.service; import com.alibaba.fastjson2.JSONObject; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; import com.zsc.edu.gateway.modules.iot.record.entity.DataWarningVo; import com.zsc.edu.gateway.modules.iot.record.entity.RecordData; @@ -18,4 +20,6 @@ public interface RecordDataService extends IService { RecordDataStatusVo recordDataStatus(); DataWarningVo dataWarning(); + + IPage query(Page page, String clientId); } \ 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 a39467d..dbdbb77 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 @@ -2,6 +2,8 @@ package com.zsc.edu.gateway.modules.iot.record.service.impl; import com.alibaba.fastjson2.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.zsc.edu.gateway.modules.iot.record.entity.DataWarningVo; import com.zsc.edu.gateway.modules.iot.record.entity.RecordData; @@ -21,6 +23,8 @@ import java.util.List; @Service public class RecordDataServiceImpl extends ServiceImpl implements RecordDataService { + private final RecordDataRepository recordDataRepository; + @Override public RecordData recordData(String clientId, JSONObject data) { RecordData recordData = new RecordData(); @@ -56,4 +60,12 @@ public class RecordDataServiceImpl extends ServiceImpl query(Page page, String clientId) { + List recordDataList = recordDataRepository.selectByClientId(clientId); + page.setRecords(recordDataList); + page.setTotal(recordDataList.size()); + return page; + } + } diff --git a/src/main/java/com/zsc/edu/gateway/modules/system/entity/Dept.java b/src/main/java/com/zsc/edu/gateway/modules/system/entity/Dept.java index 5dfca83..c1cef42 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/system/entity/Dept.java +++ b/src/main/java/com/zsc/edu/gateway/modules/system/entity/Dept.java @@ -2,14 +2,10 @@ package com.zsc.edu.gateway.modules.system.entity; import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; -import com.zsc.edu.gateway.modules.system.vo.UserVo; import lombok.Getter; import lombok.Setter; -import java.util.ArrayList; -import java.util.HashSet; import java.util.List; -import java.util.Set; /** * 部门 diff --git a/src/main/resources/mappers/iot/RecordDataMapper.xml b/src/main/resources/mappers/iot/RecordDataMapper.xml new file mode 100644 index 0000000..eb66bda --- /dev/null +++ b/src/main/resources/mappers/iot/RecordDataMapper.xml @@ -0,0 +1,18 @@ + + + + + + + + + + + + \ No newline at end of file