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 0f44c6cf..7eeaf3d0 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 9ab461dc..fa053673 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 46fa3f44..24bd3575 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}