From e67870fff62635cd14beb0d5988f08aeef4b22fa Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期一, 07 四月 2025 21:27:06 +0800
Subject: [PATCH] 添加远程关阀式终止灌溉计划，未测试
---
pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/loss/LossSv.java | 64 ++++++++++++++++++++++++++++++++
1 files changed, 64 insertions(+), 0 deletions(-)
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/loss/LossSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/loss/LossSv.java
new file mode 100644
index 0000000..edd844a
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/loss/LossSv.java
@@ -0,0 +1,64 @@
+package com.dy.pipIrrSell.loss;
+
+import com.dy.common.webUtil.QueryResultVo;
+import com.dy.pipIrrGlobal.daoSe.SeLossMapper;
+import com.dy.pipIrrGlobal.pojoSe.SeLoss;
+import com.dy.pipIrrGlobal.voSe.VoLoss;
+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 ZhuBaoMin
+ * @date 2023/12/6 9:46
+ * @LastEditTime 2023/12/6 9:46
+ * @Description
+ */
+
+@Slf4j
+@Service
+public class LossSv {
+ @Autowired
+ private SeLossMapper seLossMapper;
+
+ public QueryResultVo<List<VoLoss>> getLosses(QueryVo queryVo) {
+ String lossTimeStart = queryVo.lossTimeStart;
+ String lossTimeStop = queryVo.lossTimeStop;
+ if(lossTimeStart != null) {
+ lossTimeStart = lossTimeStart + " 00:00:00";
+ queryVo.setLossTimeStart(lossTimeStart);
+ }
+
+ if(lossTimeStop != null) {
+ lossTimeStop = lossTimeStop + " 23:59:59";
+ queryVo.setLossTimeStop(lossTimeStop);
+ }
+
+ Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
+
+ Long itemTotal = seLossMapper.getRecordCount(params);
+
+ QueryResultVo<List<VoLoss>> rsVo = new QueryResultVo<>() ;
+ rsVo.pageSize = queryVo.pageSize ;
+ rsVo.pageCurr = queryVo.pageCurr ;
+
+ rsVo.calculateAndSet(itemTotal, params);
+ rsVo.obj = seLossMapper.getLosses(params);
+ return rsVo ;
+ }
+
+ /**
+ * 娣诲姞鎸傚け璁板綍
+ * @param po
+ * @return
+ */
+ public Long add(SeLoss po) {
+ seLossMapper.insert(po);
+ return po.getId();
+ }
+
+}
--
Gitblit v1.8.0