From b181d08b9c8c4f3f4d8c475a60506ba4d93c8382 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期三, 09 四月 2025 11:38:23 +0800
Subject: [PATCH] 灌溉计划详情页，包含计划信息、轮灌组信息、取水口命令发布员结果信息

---
 pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/rtuUpgrade/task/UgRtuControllerSv.java |   98 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 98 insertions(+), 0 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/rtuUpgrade/task/UgRtuControllerSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/rtuUpgrade/task/UgRtuControllerSv.java
new file mode 100644
index 0000000..573f9fc
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/rtuUpgrade/task/UgRtuControllerSv.java
@@ -0,0 +1,98 @@
+package com.dy.pipIrrBase.rtuUpgrade.task;
+
+import com.dy.common.webUtil.QueryResultVo;
+import com.dy.pipIrrGlobal.daoRm.UgRtuControllerMapper;
+import com.dy.pipIrrGlobal.pojoUg.UgRtuController;
+import com.dy.pipIrrGlobal.voPr.VoController;
+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 org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2024/11/7 14:50
+ * @Description
+ */
+@Slf4j
+@Service
+public class UgRtuControllerSv {
+
+    @Autowired
+    private UgRtuControllerMapper dao ;
+
+
+    /**
+     * 鍒嗛〉鏌ヨ涓�涓崌绾т换鍔＄殑鎵�鏈夋帶鍒跺櫒
+     * @return 涓�浜涙帶鍒跺櫒淇℃伅
+     */
+    public QueryResultVo<List<VoController>> selectSome(QueryControllerVo queryVo){
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo) ;
+        Long itemTotal = this.dao.selectRecordCount(params) ;
+
+        QueryResultVo<List<VoController>> rsVo = new QueryResultVo<>() ;
+        rsVo.pageSize = queryVo.pageSize ;
+        rsVo.pageCurr = queryVo.pageCurr ;
+        rsVo.calculateAndSet(itemTotal, params);
+        rsVo.obj = this.dao.selectControllers(params) ;
+
+        return rsVo ;
+    }
+
+    /**
+     * 鏌ヨ涓�涓崌绾т换鍔℃墍鏈夋帶鍒跺櫒
+     * @return 涓�浜涗竴浜涙帶鍒跺櫒淇℃伅
+     */
+    public List<UgRtuController> selectAllConByTask(Long taskId){
+        List<UgRtuController> list = this.dao.selectAllConByTask(taskId) ;
+        return list ;
+    }
+
+    /**
+     * 鍒ゆ柇鏄惁瀛樺湪
+     * @param taskId 浠诲姟id
+     * @param controllerId 鎺у埗鍣↖D
+     * @return 瀛樺湪鍚�
+     */
+    public boolean exist(Long taskId, Long controllerId){
+        Long count = this.dao.selectCountByTaskAndCon(taskId, controllerId) ;
+        if(count== null || count == 0){
+            return false ;
+        }else{
+            return true ;
+        }
+    }
+
+    /**
+     * 鏂板
+     * @param po 瀹炰綋
+     * @return 鏁伴噺
+     */
+    @Transactional
+    public int save(UgRtuController po){
+        return this.dao.insertSelective(po) ;
+    }
+
+    /**
+     * 鍒犻櫎鎵�鏈�
+     * @param taskId 浠诲姟涓婚敭
+     * @return 鏁伴噺
+     */
+    @Transactional
+    public int deleteAll(Long taskId){
+        return this.dao.deleteByTaskId(taskId) ;
+    }
+    /**
+     * 鍒犻櫎
+     * @param id 涓婚敭
+     * @return 鏁伴噺
+     */
+    @Transactional
+    public int deleteOne(Long id){
+        return this.dao.deleteByPrimaryKey(id) ;
+    }
+}

--
Gitblit v1.8.0