Merge branch 'gez-dev' of uskycloud/usky-modules into master

新增 数据统一查询模块

service-backend/service-backend-biz/src/main/java/com/usky/backend/controller/DataQueryController.java

@@ -0,0 +1,61 @@
+package com.usky.backend.controller;
+import com.usky.backend.domain.vo.HistoryQueryVo;
+import com.usky.backend.domain.vo.HistoryResultVo;
+import com.usky.backend.domain.vo.LastQueryVo;
+import com.usky.backend.domain.vo.MetricItemVo;
+import com.usky.common.core.bean.ApiResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.stereotype.Controller;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ *  数据统一查询 前端控制器
+ * </p>
+ *
+ */
+@RestController
+@Api(tags = "数据统一查询")
+@RequestMapping("/dataQuery")
+public class DataQueryController {
+
+
+    @GetMapping("/history")
+    @ApiOperation("获取单个设备单属性历史数据")
+    public ApiResult<HistoryResultVo> history(@RequestParam("startTime") String startTime,
+                                     @RequestParam("endTime") String endTime,
+                                     @RequestParam("deviceId") String deviceId,
+                                     @RequestParam("metric") String metric ) {
+        //以下是mock模拟数据
+        List<MetricItemVo> items = new ArrayList<>();
+        items.add(new MetricItemVo(new Date(),12.3));
+        HistoryResultVo historyResultVo = new HistoryResultVo(deviceId,metric,items);
+        return ApiResult.success(historyResultVo);
+    }
+
+    @PostMapping("/history")
+    @ApiOperation("获取单个设备多属性历史数据")
+    public ApiResult<List<HistoryResultVo>> history(@RequestBody HistoryQueryVo historyQueryVo) {
+        List<HistoryResultVo> result  = new ArrayList<>();
+        List<MetricItemVo> items = new ArrayList<>();
+        items.add(new MetricItemVo(new Date(),12.3));
+        HistoryResultVo historyResultVo = new HistoryResultVo(historyQueryVo.getDeviceId(),"cpu.load",items);
+        result.add(historyResultVo);
+        return ApiResult.success(result);
+    }
+
+    @PostMapping("/last")
+    @ApiOperation("获取单个设备多指标实时数据")
+    public ApiResult<List<MetricItemVo>> last(@RequestBody LastQueryVo lastQueryVo) {
+        List<MetricItemVo>  metricItemVos = new ArrayList<>();
+        return ApiResult.success(metricItemVos);
+    }
+
+
+}
+

service-backend/service-backend-biz/src/main/java/com/usky/backend/controller/SysConfigController.java

@@ -1,21 +0,0 @@
-package com.usky.backend.controller;
-
-
-import org.springframework.web.bind.annotation.RequestMapping;
-
-import org.springframework.stereotype.Controller;
-
-/**
- * <p>
- * 参数配置表 前端控制器
- * </p>
- *
- * @author ya
- * @since 2022-04-29
- */
-@Controller
-@RequestMapping("/sysConfig")
-public class SysConfigController {
-
-}
-

service-backend/service-backend-biz/src/main/java/com/usky/backend/domain/vo/HistoryQueryVo.java

@@ -0,0 +1,46 @@
+package com.usky.backend.domain.vo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ *
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class HistoryQueryVo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+     /**
+     * 开始时间戳
+     */
+    private Integer startTime;
+
+     /**
+     * 结束时间戳
+     */
+    private Integer endTime;
+
+     /**
+     * 设备Id
+     */
+    private String  deviceId;
+
+    /**
+     * 指标名
+     */
+    private List<String>  metrics;
+
+
+
+}

service-backend/service-backend-biz/src/main/java/com/usky/backend/domain/vo/HistoryResultVo.java

@@ -0,0 +1,56 @@
+package com.usky.backend.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+@Data
+public class HistoryResultVo implements Serializable {
+
+   private static final long serialVersionUID = 8837428366010205858L;
+
+   private String deviceId;
+   private String metric;
+   private List<MetricItemVo> metricItems;
+
+   public HistoryResultVo() {
+   }
+
+   public HistoryResultVo(String deviceId, String metric, List<MetricItemVo> metricItems) {
+      this.deviceId = deviceId;
+      this.metric = metric;
+      this.metricItems = metricItems;
+   }
+
+//   public static class MetricItem implements Serializable {
+//      private static final long serialVersionUID = 6319020786538254074L;
+//      private Date timestamp;
+//      private Object value;
+//
+//      public MetricItem() {
+//      }
+//
+//      public MetricItem(Date timestamp, Object value) {
+//         this.timestamp = timestamp;
+//         this.value = value;
+//      }
+//
+//      public Date getTimestamp() {
+//         return timestamp;
+//      }
+//
+//      public void setTimestamp(Date timestamp) {
+//         this.timestamp = timestamp;
+//      }
+//
+//      public Object getValue() {
+//         return value;
+//      }
+//
+//      public void setValue(Object value) {
+//         this.value = value;
+//      }
+//   }
+}

service-backend/service-backend-biz/src/main/java/com/usky/backend/domain/vo/LastQueryVo.java

@@ -0,0 +1,31 @@
+package com.usky.backend.domain.vo;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * <p>
+ *
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class LastQueryVo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+     /**
+     * 设备Id
+     */
+    private String  deviceId;
+
+    /**
+     * 指标名
+     */
+    private List<String>  metrics;
+
+
+
+}

service-backend/service-backend-biz/src/main/java/com/usky/backend/domain/vo/MetricItemVo.java

@@ -0,0 +1,21 @@
+package com.usky.backend.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+public class MetricItemVo implements Serializable {
+
+    private Date timestamp;
+    private Object value;
+
+    public MetricItemVo() {
+    }
+
+    public MetricItemVo(Date timestamp, Object value) {
+        this.timestamp = timestamp;
+        this.value = value;
+    }
+}

service-backend/service-backend-biz/src/main/java/com/usky/backend/service/DataQueryService.java

@@ -0,0 +1,6 @@
+package com.usky.backend.service;
+
+public interface DataQueryService {
+
+
+}

service-backend/service-backend-biz/src/main/java/com/usky/backend/service/impl/DataQueryServiceImpl.java

@@ -0,0 +1,7 @@
+package com.usky.backend.service.impl;
+
+import com.usky.backend.service.DataQueryService;
+
+public class DataQueryServiceImpl implements DataQueryService {
+
+}