From c92bc1eeeebf43743af4ec6affb82b6ed46af808 Mon Sep 17 00:00:00 2001
From: lyf66 <admin@cloudowr.com>
Date: Mon, 29 Jan 2024 15:23:52 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=B5=E5=8E=8B=E7=9B=B8=E5=85=B3=E5=BB=BA?=
 =?UTF-8?q?=E8=A1=A8=E5=BB=BA=E6=A8=A1=E5=A2=9E=E5=88=A0=E6=94=B9=E6=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../xyt/controller/StVoltageRController.java  | 62 +++++++++++++++++++
 .../gunshi/project/xyt/model/StVoltageR.java  | 35 +++++++++++
 2 files changed, 97 insertions(+)
 create mode 100644 src/main/java/com/gunshi/project/xyt/controller/StVoltageRController.java
 create mode 100644 src/main/java/com/gunshi/project/xyt/model/StVoltageR.java

diff --git a/src/main/java/com/gunshi/project/xyt/controller/StVoltageRController.java b/src/main/java/com/gunshi/project/xyt/controller/StVoltageRController.java
new file mode 100644
index 0000000..b73ef30
--- /dev/null
+++ b/src/main/java/com/gunshi/project/xyt/controller/StVoltageRController.java
@@ -0,0 +1,62 @@
+package com.gunshi.project.xyt.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.gunshi.core.result.R;
+import com.gunshi.project.xyt.model.*;
+import com.gunshi.project.xyt.model.StStbprpBAutoMapper;
+import com.gunshi.project.xyt.model.StVoltageRAutoDao;
+import com.gunshi.project.xyt.so.RtuDataSo;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 电压数据接口
+ *
+ * @author lyf
+ * @version 1.0.0
+ * @since 2024-01-26
+ */
+@RestController
+@RequestMapping("/rcv/voltager")
+@Tag(name = "统一接收-电压数据")
+public class StVoltageRController {
+
+    @Autowired
+    private StVoltageRAutoDao dao;
+
+    @Autowired
+    private StStbprpBAutoMapper stbprpDao;
+
+    @Schema(description = "分页查询")
+    @PostMapping("/page")
+    public R<Page<StVoltageR>> page(@RequestBody RtuDataSo so) {
+        List<String> stcds = new ArrayList<>();
+        if (StringUtils.isNotEmpty(so.getStcd())) {
+            stcds.add(so.getStcd());
+        } else if (StringUtils.isNotEmpty(so.getStnm())) {
+            stcds.addAll(stbprpDao.selectList(
+                    new LambdaQueryWrapper<StStbprpB>().like(StStbprpB::getStnm, so.getStnm())
+            ).stream().map(StStbprpB::getStcd).toList());
+        }
+
+        Page<StVoltageR> page;
+        if (!stcds.isEmpty()) {
+            LambdaQueryWrapper<StVoltageR> query = new LambdaQueryWrapper<StVoltageR>().in(StVoltageR::getStcd, stcds);
+            page = dao.page(so.getPageSo().toPage(), query);
+        } else {
+            page = dao.page(so.getPageSo().toPage());
+        }
+
+        return R.ok(page);
+    }
+}
diff --git a/src/main/java/com/gunshi/project/xyt/model/StVoltageR.java b/src/main/java/com/gunshi/project/xyt/model/StVoltageR.java
new file mode 100644
index 0000000..55790c2
--- /dev/null
+++ b/src/main/java/com/gunshi/project/xyt/model/StVoltageR.java
@@ -0,0 +1,35 @@
+package com.gunshi.project.xyt.model;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 电压数据
+ *
+ * @author lyf
+ * @version 1.0.0
+ * @since 2024-01-29
+ */
+@Data
+@TableName("ST_VOLTAGE_R")
+@Schema(description = "电压数据")
+public class StVoltageR {
+    @MppMultiId("STCD")
+    @Schema(description = "测站编码")
+    private String stcd;
+
+    @MppMultiId("TM")
+    @Schema(description = "采集时间")
+    private Date tm;
+
+    @TableField("VT")
+    @Schema(description = "电压值")
+    private BigDecimal vt;
+}