新增shapshot接口

src/main/java/com/beagle/base/bean/vo/SnapshotPutDoubleParam.java

+package com.beagle.base.bean.vo;
+
+import com.rtdb.model.DoubleData;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class SnapshotPutDoubleParam {
+    private List<DoubleData> doubleDataList;
+}

src/main/java/com/beagle/base/bean/vo/SnapshotPutIntParam.java

+package com.beagle.base.bean.vo;
+
+import com.rtdb.model.IntData;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class SnapshotPutIntParam {
+    private List<IntData> intDataList;
+}

src/main/java/com/beagle/base/common/util/SnapshotUtil.java

@@ -2,11 +2,9 @@ package com.beagle.base.common.util;
 
 import cn.hutool.core.collection.CollUtil;
 import com.alibaba.fastjson2.JSON;
-import com.beagle.base.bean.vo.SnapshotBlobParam;
-import com.beagle.base.bean.vo.SnapshotCoorParam;
-import com.beagle.base.bean.vo.SnapshotDoubleParam;
-import com.beagle.base.bean.vo.SnapshotIntParam;
+import com.beagle.base.bean.vo.*;
 import com.rtdb.model.*;
+import io.swagger.models.auth.In;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.ArrayList;
@@ -69,4 +67,26 @@ public class SnapshotUtil {
             return res;
         }
     }
+
+    public static Integer putIntSnapshots(SnapshotPutIntParam param) {
+        Integer count = 0;
+        try {
+            count = CommonUtil.getSnapshotImpl().putIntSnapshots(param.getIntDataList());
+            return count;
+        }catch (Exception e) {
+            log.error("base 获取putIntSnapshots接口异常，请求参数为：{}", JSON.toJSONString(param), e);
+            return count;
+        }
+    }
+
+    public static Integer putDoubleSnapshots(SnapshotPutDoubleParam param) {
+        Integer count = 0;
+        try {
+            count = CommonUtil.getSnapshotImpl().putDoubleSnapshots(param.getDoubleDataList());
+            return count;
+        }catch (Exception e) {
+            log.error("base 获取putDoubleSnapshots接口异常，请求参数为：{}", JSON.toJSONString(param), e);
+            return count;
+        }
+    }
 }

src/main/java/com/beagle/base/controller/SnapshotController.java

@@ -11,6 +11,7 @@ import com.rtdb.model.IntData;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
+import io.swagger.models.auth.In;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
@@ -57,4 +58,17 @@ public class SnapshotController {
         return new Response<>(snapshotService.getCoorSnapshots(param));
     }
 
+    @ApiOperationSupport(order = 5)
+    @ApiOperation(value = "批量写入开关量、模拟量快照数值")
+    @PostMapping("/putIntSnapshots")
+    public Response<Integer> putIntSnapshots(@RequestBody @ApiParam(value = "入参") @Validated SnapshotPutIntParam param) {
+        return new Response<>(snapshotService.putIntSnapshots(param));
+    }
+
+    @ApiOperationSupport(order = 6)
+    @ApiOperation(value = "批量插入标签点类型为双精度浮点型的快照值")
+    @PostMapping("/putDoubleSnapshots")
+    public Response<Integer> putDoubleSnapshots(@RequestBody @ApiParam(value = "入参") @Validated SnapshotPutDoubleParam param) {
+        return new Response<>(snapshotService.putDoubleSnapshots(param));
+    }
 }

src/main/java/com/beagle/base/service/SnapshotService.java

 package com.beagle.base.service;
 
-import com.beagle.base.bean.vo.SnapshotBlobParam;
-import com.beagle.base.bean.vo.SnapshotCoorParam;
-import com.beagle.base.bean.vo.SnapshotDoubleParam;
-import com.beagle.base.bean.vo.SnapshotIntParam;
+import com.beagle.base.bean.vo.*;
 import com.rtdb.model.BlobData;
 import com.rtdb.model.CoorData;
 import com.rtdb.model.DoubleData;
@@ -23,4 +20,9 @@ public interface SnapshotService {
     List<BlobData> getBlobSnapshots(SnapshotBlobParam param);
 
     List<CoorData> getCoorSnapshots(SnapshotCoorParam param);
+
+    Integer putIntSnapshots(SnapshotPutIntParam param);
+
+    Integer putDoubleSnapshots(SnapshotPutDoubleParam param);
+
 }

src/main/java/com/beagle/base/service/impl/SnapshotServiceImpl.java

 package com.beagle.base.service.impl;
 
 
-import com.beagle.base.bean.vo.SnapshotBlobParam;
-import com.beagle.base.bean.vo.SnapshotCoorParam;
-import com.beagle.base.bean.vo.SnapshotDoubleParam;
-import com.beagle.base.bean.vo.SnapshotIntParam;
+import com.beagle.base.bean.vo.*;
 import com.beagle.base.common.util.SnapshotUtil;
 import com.beagle.base.service.SnapshotService;
 import com.rtdb.model.BlobData;
@@ -41,6 +38,17 @@ public class SnapshotServiceImpl implements SnapshotService {
     @Override
     public List<CoorData> getCoorSnapshots(SnapshotCoorParam param) {
         return SnapshotUtil.getCoorSnapshots(param);
+    }
+
+    @Override
+    public Integer putIntSnapshots(SnapshotPutIntParam param) {
+        return SnapshotUtil.putIntSnapshots(param);
+    }
+
+    @Override
+    public Integer putDoubleSnapshots(SnapshotPutDoubleParam param) {
+        return SnapshotUtil.putDoubleSnapshots(param);
 
     }
 }
+