fix(iot): 使用复合主键修复设备消息日志同毫秒覆盖问题

- 将 device_message 改为 ts + id 复合主键，保留同毫秒的不同消息 - 消息 id 为空时生成 UUID，并补充兜底单测 - 查询按 ts、id 倒序排序，保证同毫秒数据分页稳定验证：消息服务 14 个单测通过，真实 TDengine 3.3.8.4 集成验证通过注意：已有消息表需单独迁移，服务端需支持 VARCHAR 复合键相关讨论：https://t.zsxq.com/YP2ao 相关 PR：https://gitee.com/zhijiantianya/ruoyi-vue-pro/pulls/1598

fix(iot): 使用复合主键修复设备消息日志同毫秒覆盖问题
- 将 device_message 改为 ts + id 复合主键，保留同毫秒的不同消息 - 消息 id 为空时生成 UUID，并补充兜底单测 - 查询按 ts、id 倒序排序，保证同毫秒数据分页稳定验证：消息服务 14 个单测通过，真实 TDengine 3.3.8.4 集成验证通过注意：已有消息表需单独迁移，服务端需支持 VARCHAR 复合键相关讨论：https://t.zsxq.com/YP2ao 相关 PR：https://gitee.com/zhijiantianya/ruoyi-vue-pro/pulls/1598
YunaiV
1 parent 50adebd1
Showing 3 changed files with 22 additions and 4 deletions
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/device/message/IotDeviceMessageServiceImpl.java
yudao-module-iot/yudao-module-iot-biz/src/main/resources/mapper/device/IotDeviceMessageMapper.xml
yudao-module-iot/yudao-module-iot-biz/src/test/java/cn/iocoder/yudao/module/iot/service/device/message/IotDeviceMessageServiceImplTest.java
@@ -95,6 +95,9 @@ public class IotDeviceMessageServiceImpl implements IotDeviceMessageService {
         if (messageDO.getData() != null) {
             messageDO.setData(JsonUtils.toJsonString(messageDO.getData()));
         }
+        if (StrUtil.isEmpty(messageDO.getId())) {
+            messageDO.setId(IotDeviceMessageUtils.generateMessageId());
+        }
         if (messageDO.getTs() == null) {
             messageDO.setTs(System.currentTimeMillis());
         }
@@ -7,7 +7,7 @@
     <update id="createSTable">
         CREATE STABLE IF NOT EXISTS device_message (
             ts TIMESTAMP,
-            id NCHAR(50),
+            id VARCHAR(50) COMPOSITE KEY,
             report_time TIMESTAMP,
             tenant_id BIGINT,
             server_id NCHAR(50),
@@ -63,7 +63,7 @@
                 AND identifier = #{reqVO.identifier}
             </if>
         </where>
-        ORDER BY ts DESC
+        ORDER BY ts DESC, id DESC
     </select>
     <select id="selectListByRequestIdsAndReply" resultType="cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceMessageDO">
@@ -76,7 +76,7 @@
         <foreach collection="requestIds" item="requestId" open="(" close=")" separator=",">
             #{requestId}
         </foreach>
-        ORDER BY ts DESC
+        ORDER BY ts DESC, id DESC
     </select>
     <select id="selectCountByCreateTime" resultType="Long">
@@ -106,4 +106,4 @@
         GROUP BY TIMETRUNCATE(ts, 1h)
     </select>
-</mapper>
 \ No newline at end of file
+</mapper>
@@ -104,6 +104,21 @@ public class IotDeviceMessageServiceImplTest extends BaseMockitoUnitTest {
     }
     @Test
+    public void testCreateDeviceLogAsync_idFallback_whenBlank() {
+        // 准备：构造一条 id 为空的消息，复合主键字段不能为 null
+        IotDeviceMessage message = buildMessage(IotDeviceMessageMethodEnum.PROPERTY_POST.getMethod())
+                .setId(null);
+
+        // 调用
+        service.createDeviceLogAsync(message);
+
+        // 断言：mapper.insert 接收到的 messageDO 已补充 id
+        ArgumentCaptor<IotDeviceMessageDO> captor = ArgumentCaptor.forClass(IotDeviceMessageDO.class);
+        verify(deviceMessageMapper).insert(captor.capture());
+        assertNotNull(captor.getValue().getId(), "id 不应为空");
+    }
+
+    @Test
     public void testCreateDeviceLogAsync_swallowMapperException() {
         // 准备：mapper.insert 抛异常，验证 @Async 方法内部 try/catch 兜底，不向上抛
         IotDeviceMessage message = buildMessage(IotDeviceMessageMethodEnum.PROPERTY_POST.getMethod());