diff --git a/fastbee-server/iot-server-core/src/main/java/com/fastbee/server/handler/TCPMessageAdapter.java b/fastbee-server/iot-server-core/src/main/java/com/fastbee/server/handler/TCPMessageAdapter.java index 9a078417..afe6ecce 100644 --- a/fastbee-server/iot-server-core/src/main/java/com/fastbee/server/handler/TCPMessageAdapter.java +++ b/fastbee-server/iot-server-core/src/main/java/com/fastbee/server/handler/TCPMessageAdapter.java @@ -61,7 +61,8 @@ public class TCPMessageAdapter extends ChannelInboundHandlerAdapter { session.access(); // 快速响应匹配:串行发送场景,同一时刻只有一个等待请求 - if (session.hasPendingRequest() && session.response(buf.retainedDuplicate())) { + int messageId = buf.getUnsignedByte(1); + if (messageId == 0x06 && session.hasPendingRequest() && session.response(buf.retainedDuplicate())) { log.debug("=>设备响应匹配成功,设备:{}", session.getClientId()); buf.release(); // 释放原始 ByteBuf return; // 直接返回,不传递到后续处理器 diff --git a/fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/domain/CommandPreferences.java b/fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/domain/CommandPreferences.java index 0f05b946..28b435c5 100644 --- a/fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/domain/CommandPreferences.java +++ b/fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/domain/CommandPreferences.java @@ -56,6 +56,13 @@ public class CommandPreferences { @ApiModelProperty("设备编号") private String serialNumber; + /** + * 产品ID(有值表示产品指令,为空时通过serialNumber判断为设备指令) + */ + @Excel(name = "产品ID") + @ApiModelProperty("产品ID") + private Long productId; + @Setter @TableField(exist = false) @ApiModelProperty("请求参数") diff --git a/fastbee-service/fastbee-iot-service/src/main/resources/mapper/iot/CommandPreferencesMapper.xml b/fastbee-service/fastbee-iot-service/src/main/resources/mapper/iot/CommandPreferencesMapper.xml index 84afae64..b1bcb5b4 100644 --- a/fastbee-service/fastbee-iot-service/src/main/resources/mapper/iot/CommandPreferencesMapper.xml +++ b/fastbee-service/fastbee-iot-service/src/main/resources/mapper/iot/CommandPreferencesMapper.xml @@ -9,10 +9,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + - select id, name, command, serial_number from command_preferences + select id, name, command, serial_number, product_id from command_preferences