From 617d9316c16cadfd6e9085582d5eb035a4bb4511 Mon Sep 17 00:00:00 2001 From: stone <827672943@qq.com> Date: Fri, 12 May 2023 18:21:21 +0800 Subject: [PATCH] 11 --- .../com/psdc/mapper/PsdcDeviceMapper.java | 6 ++++++ .../service/impl/PsdcDeviceServiceImpl.java | 15 ++----------- .../mapper/business/PsdcDeviceMapper.xml | 21 +++++++++++++++++++ 3 files changed, 29 insertions(+), 13 deletions(-) diff --git a/psdc-business/src/main/java/com/psdc/mapper/PsdcDeviceMapper.java b/psdc-business/src/main/java/com/psdc/mapper/PsdcDeviceMapper.java index 9d6b6d8..9a65c86 100644 --- a/psdc-business/src/main/java/com/psdc/mapper/PsdcDeviceMapper.java +++ b/psdc-business/src/main/java/com/psdc/mapper/PsdcDeviceMapper.java @@ -95,4 +95,10 @@ public interface PsdcDeviceMapper{ void saveDevicesData(@Param(value = "devRecord") List devRecord); + /** + * 控制页面查询设备查询可操作设备列表 + * @param userId + * @return + */ + List controlQueryByUserId(Long userId); } \ No newline at end of file diff --git a/psdc-business/src/main/java/com/psdc/service/impl/PsdcDeviceServiceImpl.java b/psdc-business/src/main/java/com/psdc/service/impl/PsdcDeviceServiceImpl.java index 1504c3c..1335765 100644 --- a/psdc-business/src/main/java/com/psdc/service/impl/PsdcDeviceServiceImpl.java +++ b/psdc-business/src/main/java/com/psdc/service/impl/PsdcDeviceServiceImpl.java @@ -49,19 +49,14 @@ public class PsdcDeviceServiceImpl implements IPsdcDeviceService { /** * 根据用户id查询设备列表 -<<<<<<< HEAD * @return 设备列表 -======= - * - * @return ->>>>>>> e7257650302fdf30d685bfae8df3cc0405bb51f6 */ public List queryByUserId() { return psdcDeviceMapper.queryByUserId(SecurityUtils.getUserId()); } public List queryDeviceStatus() { - List psdcDevices = psdcDeviceMapper.queryByUserId(SecurityUtils.getUserId()); + List psdcDevices = psdcDeviceMapper.controlQueryByUserId(SecurityUtils.getUserId()); return psdcDevices.stream().map(psdcDevice -> { DeviceStatusVo deviceStatusVo = new DeviceStatusVo(); BeanUtils.copyProperties(psdcDevice, deviceStatusVo); @@ -159,16 +154,9 @@ public class PsdcDeviceServiceImpl implements IPsdcDeviceService { /** * 控制设备启动停止 -<<<<<<< HEAD * @param deviceId 主键 * @param runStatus 状态 * @return 条数 -======= - * - * @param deviceId - * @param runStatus - * @return ->>>>>>> e7257650302fdf30d685bfae8df3cc0405bb51f6 */ @Override public int controlDeviceStartAndStop(Integer deviceId, Integer runStatus, String controlBy, Integer controlMethod) { @@ -187,6 +175,7 @@ public class PsdcDeviceServiceImpl implements IPsdcDeviceService { psdcControlLogMapper.insert(new PsdcControlLog(deviceId, null, null, "设备启停", value, controlMethod, 3, "未找到该设备", controlBy)); throw new ControlException("控制失败,未找到该设备"); } + // TODO 发送MQTT指令 // psdcControlLogMapper.insert(new PsdcControlLog(deviceId,psdcDevice.getDeviceName(),psdcDevice.getDeviceSn(),"设备启停",value,controlMethod,3,"手动控制,等待终端响应超时",controlBy)); diff --git a/psdc-business/src/main/resources/mapper/business/PsdcDeviceMapper.xml b/psdc-business/src/main/resources/mapper/business/PsdcDeviceMapper.xml index 9c642c3..4e48da9 100644 --- a/psdc-business/src/main/resources/mapper/business/PsdcDeviceMapper.xml +++ b/psdc-business/src/main/resources/mapper/business/PsdcDeviceMapper.xml @@ -298,4 +298,25 @@ select device_name from psdc_device where device_id = #{deviceId} + + \ No newline at end of file