diff --git a/fys-admin/src/main/java/com/fuyuanshen/app/controller/AppDeviceController.java b/fys-admin/src/main/java/com/fuyuanshen/app/controller/AppDeviceController.java index 945c30f..1344160 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/app/controller/AppDeviceController.java +++ b/fys-admin/src/main/java/com/fuyuanshen/app/controller/AppDeviceController.java @@ -32,7 +32,7 @@ public class AppDeviceController extends BaseController { private final APPDeviceService appDeviceService; /** - * 查询文件列表 + * 查询设备列表 */ @GetMapping("/list") public TableDataInfo list(DeviceQueryCriteria bo, PageQuery pageQuery) { diff --git a/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml b/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml index 5af643a..44aea49 100644 --- a/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml +++ b/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml @@ -5,7 +5,7 @@ - + @@ -176,6 +176,9 @@ from device d inner join device_type dt on d.device_type = dt.id where d.binding_user_id = #{criteria.bindingUserId} + + and d.device_type = #{criteria.deviceType} + diff --git a/fys-modules/fys-system/src/main/java/com/fuyuanshen/system/mqtt/config/MqttConfiguration.java b/fys-modules/fys-system/src/main/java/com/fuyuanshen/system/mqtt/config/MqttConfiguration.java index 30ffadf..002b6b5 100644 --- a/fys-modules/fys-system/src/main/java/com/fuyuanshen/system/mqtt/config/MqttConfiguration.java +++ b/fys-modules/fys-system/src/main/java/com/fuyuanshen/system/mqtt/config/MqttConfiguration.java @@ -26,6 +26,9 @@ public class MqttConfiguration { options.setUserName(mqttPropertiesConfig.getUsername()); options.setPassword(mqttPropertiesConfig.getPassword().toCharArray()); options.setServerURIs(new String[]{mqttPropertiesConfig.getUrl()}); + options.setAutomaticReconnect(true); // 启用自动重连 + options.setConnectionTimeout(10); // 设置连接超时时间 + options.setKeepAliveInterval(60); // 设置心跳间隔 factory.setConnectionOptions(options); return factory; }