Procházet zdrojové kódy

修复mysql下无法返回同步设备数量

zhou-hao před 5 roky
rodič
revize
7293e94740

+ 2 - 1
jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/LocalDeviceInstanceService.java

@@ -399,7 +399,8 @@ public class LocalDeviceInstanceService extends GenericReactiveCrudService<Devic
                             .where()
                             .in(DeviceInstanceEntity::getId, group.getValue().stream().map(Tuple3::getT2).collect(Collectors.toList()))
                             .execute()
-                            .defaultIfEmpty(0),
+                            .thenReturn(group.getValue().size())//mysql下可能不会返回更新数量
+                        ,
                         //修改子设备状态
                         Flux.fromIterable(group.getValue())
                             .filter(Tuple3::getT3)