diff --git a/src/main/java/com/isu/gaswellwatch/controller/DeviceController.java b/src/main/java/com/isu/gaswellwatch/controller/DeviceController.java index 79290b6..355c901 100644 --- a/src/main/java/com/isu/gaswellwatch/controller/DeviceController.java +++ b/src/main/java/com/isu/gaswellwatch/controller/DeviceController.java @@ -39,8 +39,8 @@ public class DeviceController { @RequestParam(defaultValue = "10") Integer pageSize, @RequestParam(required = false) String gasWellName, @RequestParam(required = false) String gasStationName, - @RequestParam Long deviceTypeId) { - return Response.succeed(deviceService.page(currentPage, pageSize, gasWellName,gasStationName,deviceTypeId)); + @RequestParam Long deviceTypeId,@RequestParam Long blockId) { + return Response.succeed(deviceService.page(currentPage, pageSize, gasWellName,gasStationName,deviceTypeId,blockId)); } /** diff --git a/src/main/java/com/isu/gaswellwatch/dao/DeviceDao.java b/src/main/java/com/isu/gaswellwatch/dao/DeviceDao.java index 6ad7cac..af7948d 100644 --- a/src/main/java/com/isu/gaswellwatch/dao/DeviceDao.java +++ b/src/main/java/com/isu/gaswellwatch/dao/DeviceDao.java @@ -20,7 +20,8 @@ public interface DeviceDao extends BaseMapper { Page page(Page page, @Param("gasWellName") String gasWellName, @Param("gasStationName") String gasStationName, - @Param("deviceTypeId") Long deviceTypeId); + @Param("deviceTypeId") Long deviceTypeId, + @Param("blockId") Long blockId); DeviceVO getDeviceById(@Param("id") Long id); diff --git a/src/main/java/com/isu/gaswellwatch/service/DeviceService.java b/src/main/java/com/isu/gaswellwatch/service/DeviceService.java index c834134..075d156 100644 --- a/src/main/java/com/isu/gaswellwatch/service/DeviceService.java +++ b/src/main/java/com/isu/gaswellwatch/service/DeviceService.java @@ -15,7 +15,7 @@ import java.util.Map; public interface DeviceService extends IService { - Page page(Integer currentPage, Integer pageSize, String gasWellName, String gasStationName, Long deviceTypeId); + Page page(Integer currentPage, Integer pageSize, String gasWellName, String gasStationName, Long deviceTypeId, Long blockId); void add(DeviceCreateDTO deviceCreateDTO); diff --git a/src/main/java/com/isu/gaswellwatch/service/impl/DeviceServiceImpl.java b/src/main/java/com/isu/gaswellwatch/service/impl/DeviceServiceImpl.java index cd6bde6..399492c 100644 --- a/src/main/java/com/isu/gaswellwatch/service/impl/DeviceServiceImpl.java +++ b/src/main/java/com/isu/gaswellwatch/service/impl/DeviceServiceImpl.java @@ -29,7 +29,6 @@ import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Map; -import java.util.Objects; @Service("deviceService") @@ -53,8 +52,8 @@ public class DeviceServiceImpl extends ServiceImpl implements private DynamicRabbitListener dynamicRabbitListener; @Override - public Page page(Integer currentPage, Integer pageSize, String gasWellName, String gasStationName,Long deviceTypeId){ - Page page = deviceDao.page(new Page<>(currentPage, pageSize),gasWellName,gasStationName,deviceTypeId); + public Page page(Integer currentPage, Integer pageSize, String gasWellName, String gasStationName, Long deviceTypeId, Long blockId){ + Page page = deviceDao.page(new Page<>(currentPage, pageSize),gasWellName,gasStationName,deviceTypeId,blockId); List deviceVOList = page.getRecords(); // 从Redis获取设备运行数据 if(CollectionUtil.isNotEmpty(deviceVOList)) { diff --git a/src/main/resources/mapper/DeviceDao.xml b/src/main/resources/mapper/DeviceDao.xml index 757ce90..daa621e 100644 --- a/src/main/resources/mapper/DeviceDao.xml +++ b/src/main/resources/mapper/DeviceDao.xml @@ -48,6 +48,9 @@ and u.device_type = #{deviceTypeId} + + and g.block_id = #{blockId} + order by u.id desc