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-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerSv.java |  139 ++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 139 insertions(+), 0 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerSv.java
new file mode 100644
index 0000000..0a5441c
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerSv.java
@@ -0,0 +1,139 @@
+package com.dy.pipIrrProject.intakeController;
+
+import cn.hutool.core.date.DateTime;
+import com.dy.common.webUtil.QueryResultVo;
+import com.dy.pipIrrGlobal.daoPr.PrControllerTrampMapper;
+import com.dy.pipIrrGlobal.daoPr.PrIntakeControllerMapper;
+import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp;
+import com.dy.pipIrrGlobal.pojoPr.PrIntakeController;
+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.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author ZhuBaoMin
+ * @date 2024-01-02 9:19
+ * @LastEditTime 2024-01-02 9:19
+ * @Description
+ */
+
+@Slf4j
+@Service
+public class IntakeControllerSv {
+    @Autowired
+    private PrIntakeControllerMapper prIntakeControllerMapper;
+
+    @Autowired
+    private PrControllerTrampMapper prControllerTrampMapper;
+
+    /**
+     * 鏍规嵁鍙栨按鍙ｇ紪鍙枫�佹帶鍒跺櫒缂栧彿銆佹搷浣滅被鍒幏鍙栬褰曟暟閲�
+     * 閲嶅缁戝畾銆侀噸澶嶈В缁戦兘鐢ㄨ鏂规硶鍒ゆ柇
+     * @param intakeId 鍙栨按鍙D
+     * @param controllerId 鎺у埗鍣↖D
+     * @param operateType 鎿嶄綔绫诲瀷 1-鎹嗙粦锛�2-瑙ｇ粦
+     * @return 濡備綍鏉′欢璁板綍鏁�
+     */
+    Integer getBindRecordCount(Long intakeId, Long controllerId, Byte operateType) {
+        return prIntakeControllerMapper.getBindRecordCount(intakeId, controllerId, operateType);
+    }
+    /**
+     * 娣诲姞鍙栨按鍙ｃ�佹帶鍒跺櫒鎹嗙粦璁板綍锛�1-鎹嗙粦锛�2-瑙ｇ粦
+     * @param po 鍙栨按鍙�/鎺у埗鍣ㄥ疄浣撳璞�
+     * @return
+     */
+    Integer addRecord(PrIntakeController po) {
+        return prIntakeControllerMapper.insert(po);
+    }
+
+    /**
+     * 鏍规嵁鍙栨按鍙ｇ紪鍙疯幏鍙栫粦瀹氳褰曞垪琛�
+     * @param intakeId 鍙栨按鍙ｇ紪鍙�
+     * @return 鍙栨按鍙ｄ笌鎺у埗鍣ㄧ粦瀹氬垪琛�
+     */
+    List<Map<String, Object>> getBindsByIntakeId(Long intakeId) {
+        return prIntakeControllerMapper.getBindsByIntakeId(intakeId);
+    }
+
+    /**
+     * 鏍规嵁鎺у埗鍣ㄧ紪鍙疯幏鍙栫粦瀹氳褰曞垪琛�
+     * @param controllerId 鎺у埗鍣ㄧ紪鍙�
+     * @return 鍙栨按鍙ｄ笌鎺у埗鍣ㄧ粦瀹氬垪琛�
+     */
+    List<Map<String, Object>> getBindsByControllerId(Long controllerId) {
+        return prIntakeControllerMapper.getBindsByControllerId(controllerId);
+    }
+
+    /**
+     * 鏍规嵁鎺у埗鍣ㄧ紪鍙疯幏鍙栨祦娴帶鍒跺櫒鍦板潃
+     * @param controllerId 娴佹氮鎺у埗鍣ㄧ紪鍙�
+     * @return 娴佹氮鎺у埗鍣ㄥ湴鍧�
+     */
+    //public String getTrampRtuAddr(Long controllerId) {
+    //    return prControllerTrampMapper.getTrampRtuAddr(controllerId);
+    //}
+
+    /**
+     * 鏍规嵁鎺у埗鍣ㄧ紪鍙疯幏鍙栨祦娴帶鍒跺櫒淇℃伅
+     * @param controllerId
+     * @return
+     */
+    public PrControllerTramp getTrampControllerInfo(Long controllerId) {
+        return prControllerTrampMapper.getTrampControllerInfo(controllerId);
+    }
+
+    /**
+     * 鏍规嵁娴佹氮鎺у埗鍣ㄧ紪鍙峰垹闄ゆ祦娴帶鍒跺櫒璁板綍
+     * @param controllerId
+     * @return
+     */
+    public Integer deleteTrampController(Long controllerId) {
+        return prControllerTrampMapper.deleteByPrimaryKey(controllerId);
+    }
+
+    /**
+     * 娓呯┖娴佹氮鎺у埗鍣�
+     * @param
+     * @return
+     */
+    public Integer emptyTrampController() {
+        return prControllerTrampMapper.emptyTrampController();
+    }
+
+    //娴佹氮鎺у埗鍣ㄥ
+    public Integer addTrampController(PrControllerTramp record){
+        return prControllerTrampMapper.insertSelective(record);
+    }
+
+
+/*娴佹氮鎺у埗鍣ㄦ煡*/
+    public QueryResultVo<List<PrControllerTramp>> getTrampControllers(TrampControllerQueryVo queryVo){
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
+
+        Long itemTotal = prControllerTrampMapper.getTrampControllersCount(params);
+
+        QueryResultVo<List<PrControllerTramp>> rsVo = new QueryResultVo<>();
+        rsVo.pageSize = queryVo.pageSize;
+        rsVo.pageCurr = queryVo.pageCurr;
+
+        rsVo.calculateAndSet(itemTotal, params);
+        rsVo.obj = prControllerTrampMapper.getTrampControllers(params);
+
+        return rsVo;
+    }
+    /**
+     * 淇敼缁戝畾璁板綍閫氳繃鍙栨按鍙�
+     * @param record
+     * @return
+     */
+    public Integer updateBindRecord(PrIntakeController record){
+        return prIntakeControllerMapper.updateByIntakeSelective(record);
+    }
+}

--
Gitblit v1.8.0