From a236d0878c1effdd328cf0abc45665097c9cfdc2 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期一, 01 九月 2025 14:22:13 +0800
Subject: [PATCH] 1、小程序后端实现作物及昨日蒸散量查询; 2、小程序后端实现查询一个作物阶段时间内的蒸散量;

---
 pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporQo.java   |   37 ++++++++++++
 pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporCtrl.java |   80 ++++++++++++++++++++++++++
 pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporSv.java   |   40 +++++++++++++
 3 files changed, 157 insertions(+), 0 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporCtrl.java
new file mode 100644
index 0000000..69ebb79
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporCtrl.java
@@ -0,0 +1,80 @@
+package com.dy.pipIrrWechat.vapor;
+
+import com.dy.common.util.DateTime;
+import com.dy.common.webUtil.BaseResponse;
+import com.dy.common.webUtil.BaseResponseUtils;
+import com.dy.pipIrrGlobal.pojoMd.MdEt0;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2025/8/19 16:21
+ * @Description
+ */
+@Slf4j
+@Tag(name = "浣滅墿鏃ヨ捀鑵鹃噺", description = "浣滅墿鏃ヨ捀鑵鹃噺鏌ヨ绛夋搷浣�")
+@RestController
+@RequestMapping(path = "mdVapor")
+public class VaporCtrl {
+
+    private VaporSv sv;
+
+    @Autowired
+    private void setSv(VaporSv sv) { this.sv = sv; }
+
+
+    /**
+     * 瀹㈡埛绔姹傚緱鍒版墍鏈変綔鐗╃殑鏄ㄦ棩钂歌吘閲�
+     * @return 鎵�鏈夋墍鏈変綔鐗╃殑鏄ㄦ棩钂歌吘閲�
+     */
+    @GetMapping(path = "allCropsWithYesterday")
+    public BaseResponse<List<MdEt0>> allYesterday(){
+        try {
+            String ymd = DateTime.yesterday_yyyy_MM_dd(
+                    Integer.parseInt(DateTime.yyyy()),
+                    Integer.parseInt(DateTime.MM()),
+                    Integer.parseInt(DateTime.dd())) ;
+            List<MdEt0> res = this.sv.selectEt0(ymd) ;
+            return BaseResponseUtils.buildSuccess(res);
+        } catch (Exception e) {
+            log.error("鏌ヨ鎵�鏈変綔鐗╃殑鏄ㄦ棩钂歌吘閲忓紓甯�", e);
+            return BaseResponseUtils.buildException(e.getMessage()) ;
+        }
+    }
+
+    /**
+     * 鏍规嵁鎸囧畾鏉′欢浣滅墿鏌ヨ涓�娈垫椂闂村唴鐨勮捀鑵鹃噺
+     * @param qo
+     * @return
+     */
+    @GetMapping(path = "oneCropsSomeEt0")
+    public BaseResponse<List<MdEt0>> oneCropsSomeEt0(VaporQo qo){
+        try {
+            if(qo.cropId == null){
+                return BaseResponseUtils.buildFail("浣滅墿id涓嶈兘涓虹┖") ;
+            }
+            if(qo.timeStop == null || qo.timeStop.trim().equals("")){
+                qo.timeStop = DateTime.yyyy_MM_dd() ;
+            }
+            if(qo.timeStart == null || qo.timeStart.trim().equals("")){
+                qo.timeStart = DateTime.lastXDay_yyyy_MM_dd(qo.timeStop, 10);
+            }
+            List<MdEt0> list = sv.oneCropsSomeEt0(qo) ;
+            if(list == null){
+                list = new ArrayList<>() ;
+            }
+            return BaseResponseUtils.buildSuccess(list);
+        } catch (Exception e) {
+            return BaseResponseUtils.buildException(e.getMessage()) ;
+        }
+    }
+
+}
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporQo.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporQo.java
new file mode 100644
index 0000000..ca9eb52
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporQo.java
@@ -0,0 +1,37 @@
+package com.dy.pipIrrWechat.vapor;
+
+import com.dy.common.webUtil.QueryConditionVo;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.*;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2025/8/19 16:21
+ * @Description
+ */
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@ToString(callSuper = true)
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class VaporQo extends QueryConditionVo {
+    /**
+     * 浣滅墿ID
+     */
+    @Schema(description = "浣滅墿ID", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    public Long cropId;
+    /**
+     * 鏌ヨ寮�濮嬫棩鏈�
+     */
+    @Schema(description = "鏌ヨ寮�濮嬫棩鏈�", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    public String timeStart;
+
+    /**
+     * 鏌ヨ缁撴潫鏃ユ湡
+     */
+    @Schema(description = "鏌ヨ缁撴潫鏃ユ湡", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    public String timeStop;
+
+}
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporSv.java
new file mode 100644
index 0000000..05a5af8
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/vapor/VaporSv.java
@@ -0,0 +1,40 @@
+package com.dy.pipIrrWechat.vapor;
+
+import com.dy.pipIrrGlobal.daoMd.MdEt0Mapper;
+import com.dy.pipIrrGlobal.pojoMd.MdEt0;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.dubbo.common.utils.PojoUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2025/8/19 16:21
+ * @Description
+ */
+
+@Slf4j
+@Service
+public class VaporSv {
+
+    private MdEt0Mapper mdEt0Dao;
+
+    @Autowired
+    private void setDao( MdEt0Mapper mdEt0Dao) {
+        this.mdEt0Dao = mdEt0Dao;
+    }
+
+    public List<MdEt0> selectEt0(String ymd){
+       return mdEt0Dao.selectEt0ByDt(ymd);
+    }
+
+    public List<MdEt0> oneCropsSomeEt0(VaporQo qo){
+       Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
+       return mdEt0Dao.selectEt0ByCropAndDt(params);
+    }
+
+
+}

--
Gitblit v1.8.0