Răsfoiți Sursa

添加测试mqtt消费者

李进 2 ani în urmă
părinte
comite
d922e2192e

+ 2 - 1
device-api-service/src/main/java/com/xy/service/impl/DeviceCreateIdsServiceImpl.java

@@ -70,6 +70,7 @@ public class DeviceCreateIdsServiceImpl extends ServiceImpl<DeviceCreateIdsMappe
         QueryWrapper<DeviceCreateIds> queryWrapper = new QueryWrapper<DeviceCreateIds>().select(String.format("max(%s) as %s", StringTools.humpToLine(property), property));
         DeviceCreateIds deviceCreateIds = getOne(queryWrapper);
         JList<DeviceCreateIds> deviceCreateIdss = new JArrayList<>(save.getNum());
+        Long loginId = AuthorizeUtils.getLoginId(Long.class);
         for (int i = 0; i < save.getNum(); i++) {
             String tail = null;
             if (deviceCreateIds != null) {
@@ -88,7 +89,7 @@ public class DeviceCreateIdsServiceImpl extends ServiceImpl<DeviceCreateIdsMappe
             Long deviceId = Long.valueOf(yearMonth + tail);
             DeviceCreateIds deviceCreateIdsInfo = copy(DeviceCreateIds.class, save)
                     .setDeviceId(deviceId)
-                    .setCreateUserId(AuthorizeUtils.getLoginId(Long.class))
+                    .setCreateUserId(loginId)
                     .setCreateTime(LocalDateTime.now());
             deviceCreateIdss.add(deviceCreateIdsInfo);
         }