diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/xinghan/XinghanSendMsgRule.java b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/xinghan/XinghanSendMsgRule.java index 0f44c6c..7eeaf3d 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/xinghan/XinghanSendMsgRule.java +++ b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/xinghan/XinghanSendMsgRule.java @@ -17,10 +17,7 @@ import org.springframework.stereotype.Component; import java.nio.charset.Charset; import java.time.Duration; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; import static com.fuyuanshen.common.core.constant.GlobalConstants.FUNCTION_ACCESS_KEY; import static com.fuyuanshen.common.core.constant.GlobalConstants.GLOBAL_REDIS_KEY; @@ -42,6 +39,12 @@ public class XinghanSendMsgRule implements MqttMessageRule { @Override public String getCommandType() { + List list = Arrays.asList(1, 2, 3, 4, 5); + + // 三种等价的写法 + Integer[] array1 = list.toArray(new Integer[0]); + Integer[] array2 = list.toArray(size -> new Integer[size]); + return XingHanCommandTypeConstants.XingHan_ESEND_MSG; } diff --git a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceQueryCriteria.java b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceQueryCriteria.java index 9ab461d..fa05367 100644 --- a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceQueryCriteria.java +++ b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceQueryCriteria.java @@ -105,6 +105,7 @@ public class DeviceQueryCriteria extends BaseEntity { /** * 设备所属分组 + * group_id */ private Long groupId; 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 ed240a5..d4edd5a 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 @@ -140,6 +140,9 @@ and d.device_status = #{criteria.deviceStatus} + + and d.group_id = #{criteria.groupId} + and d.current_owner_id = #{criteria.currentOwnerId} @@ -475,7 +478,7 @@ d.type_name AS deviceName, COUNT(*) AS frequency FROM device_log dl - LEFT JOIN device d ON dl.device_id = d.id + INNER JOIN device d ON dl.device_id = d.id WHERE dl.create_time >= DATE_SUB(NOW(), INTERVAL #{days} DAY) GROUP BY d.device_type, d.type_name ORDER BY frequency DESC