|
@@ -0,0 +1,123 @@
|
|
|
|
+package org.jetlinks.community.device.service.data;
|
|
|
|
+
|
|
|
|
+import org.hswebframework.web.api.crud.entity.PagerResult;
|
|
|
|
+import org.hswebframework.web.api.crud.entity.QueryParamEntity;
|
|
|
|
+import org.jetlinks.core.message.DeviceMessage;
|
|
|
|
+import org.jetlinks.core.metadata.ConfigMetadata;
|
|
|
|
+import org.jetlinks.core.metadata.DeviceMetadata;
|
|
|
|
+import org.jetlinks.community.device.entity.DeviceEvent;
|
|
|
|
+import org.jetlinks.community.device.entity.DeviceOperationLogEntity;
|
|
|
|
+import org.jetlinks.community.device.entity.DeviceProperty;
|
|
|
|
+import org.jetlinks.community.timeseries.query.AggregationData;
|
|
|
|
+import org.reactivestreams.Publisher;
|
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
|
+import reactor.core.publisher.Flux;
|
|
|
|
+import reactor.core.publisher.Mono;
|
|
|
|
+
|
|
|
|
+import javax.annotation.Nonnull;
|
|
|
|
+
|
|
|
|
+@Component
|
|
|
|
+public class NoneDeviceDataStoragePolicy implements DeviceDataStoragePolicy {
|
|
|
|
+ @Override
|
|
|
|
+ public String getId() {
|
|
|
|
+ return "none";
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public String getName() {
|
|
|
|
+ return "不存储";
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public String getDescription() {
|
|
|
|
+ return "不存储设备相关数据";
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Mono<Void> saveDeviceMessage(@Nonnull DeviceMessage message) {
|
|
|
|
+ return Mono.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Mono<Void> saveDeviceMessage(@Nonnull Publisher<DeviceMessage> message) {
|
|
|
|
+ return Mono.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Mono<ConfigMetadata> getConfigMetadata() {
|
|
|
|
+ return Mono.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Mono<Void> registerMetadata(@Nonnull String productId, @Nonnull DeviceMetadata metadata) {
|
|
|
|
+ return Mono.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Flux<DeviceProperty> queryEachOneProperties(@Nonnull String deviceId,
|
|
|
|
+ @Nonnull QueryParamEntity query,
|
|
|
|
+ @Nonnull String... properties) {
|
|
|
|
+ return Flux.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Flux<DeviceEvent> queryEvent(@Nonnull String deviceId,
|
|
|
|
+ @Nonnull String event,
|
|
|
|
+ @Nonnull QueryParamEntity query, boolean format) {
|
|
|
|
+ return Flux.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Mono<PagerResult<DeviceEvent>> queryEventPage(@Nonnull String deviceId,
|
|
|
|
+ @Nonnull String event,
|
|
|
|
+ @Nonnull QueryParamEntity query, boolean format) {
|
|
|
|
+ return Mono.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Flux<DeviceProperty> queryEachProperties(@Nonnull String deviceId,
|
|
|
|
+ @Nonnull QueryParamEntity query) {
|
|
|
|
+ return Flux.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Flux<DeviceProperty> queryProperty(@Nonnull String deviceId,
|
|
|
|
+ @Nonnull QueryParamEntity query,
|
|
|
|
+ @Nonnull String... property) {
|
|
|
|
+ return Flux.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public Flux<AggregationData> aggregationPropertiesByProduct(@Nonnull String productId,
|
|
|
|
+ @Nonnull DeviceDataService.AggregationRequest request, @Nonnull DeviceDataService.DevicePropertyAggregation... properties) {
|
|
|
|
+ return Flux.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public Flux<AggregationData> aggregationPropertiesByDevice(@Nonnull String deviceId,
|
|
|
|
+ @Nonnull DeviceDataService.AggregationRequest request, @Nonnull DeviceDataService.DevicePropertyAggregation... properties) {
|
|
|
|
+ return Flux.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Nonnull
|
|
|
|
+ @Override
|
|
|
|
+ public Mono<PagerResult<DeviceProperty>> queryPropertyPage(@Nonnull String deviceId,
|
|
|
|
+ @Nonnull String property, @Nonnull QueryParamEntity query) {
|
|
|
|
+ return Mono.empty();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public Mono<PagerResult<DeviceOperationLogEntity>> queryDeviceMessageLog(@Nonnull String deviceId,
|
|
|
|
+ @Nonnull QueryParamEntity query) {
|
|
|
|
+ return Mono.empty();
|
|
|
|
+ }
|
|
|
|
+}
|