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-app/src/main/java/com/dy/pipIrrApp/inspect/InspectSv.java |  143 +++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 143 insertions(+), 0 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/inspect/InspectSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/inspect/InspectSv.java
new file mode 100644
index 0000000..bbe60a5
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/inspect/InspectSv.java
@@ -0,0 +1,143 @@
+package com.dy.pipIrrApp.inspect;
+
+import com.dy.common.webUtil.QueryResultVo;
+import com.dy.pipIrrApp.inspect.qo.QoInspect;
+import com.dy.pipIrrGlobal.daoOp.OpeInspectMapper;
+import com.dy.pipIrrGlobal.daoOp.OpeTrackMapper;
+import com.dy.pipIrrGlobal.pojoOp.OpeInspect;
+import com.dy.pipIrrGlobal.pojoOp.OpeTrack;
+import com.dy.pipIrrGlobal.voOp.VoInspect;
+import com.dy.pipIrrGlobal.voOp.VoTrackPoint;
+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 2024-09-24 10:21
+ * @LastEditTime 2024-09-24 10:21
+ * @Description
+ */
+
+@Slf4j
+@Service
+public class InspectSv {
+    @Autowired
+    private OpeInspectMapper opeInspectMapper;
+
+    @Autowired
+    private OpeTrackMapper opeTrackMapper;
+
+    /**
+     * 娣诲姞宸℃璁板綍
+     *
+     * @param po
+     * @return
+     */
+    public Long addInspect(OpeInspect po) {
+        opeInspectMapper.insert(po);
+        return po.getId();
+    }
+
+    /**
+     * 淇敼宸℃璁板綍
+     *
+     * @param po
+     * @return
+     */
+    public Integer updateInspect(OpeInspect po) {
+        return opeInspectMapper.updateByPrimaryKeySelective(po);
+    }
+
+    /**
+     * 鎵归噺娣诲姞宸℃杞ㄨ抗
+     *
+     * @param list
+     * @return
+     */
+    public Integer insertTracks(List<OpeTrack> list) {
+        return opeTrackMapper.insertTracks(list);
+    }
+
+    /**
+     * 宸℃鏌ヨ
+     *
+     * @param queryVo
+     * @return
+     */
+    public QueryResultVo<List<VoInspect>> getInspects(QoInspect queryVo) {
+        //瀹屽杽鏌ヨ鍏呭�艰褰曠殑璧锋鏃堕棿
+        String timeStart = queryVo.getTimeStart();
+        String timeStop = queryVo.getTimeStop();
+
+        if (timeStart == null || timeStart == "" || timeStop == null || timeStop == "") {
+            queryVo.setTimeStart(null);
+            queryVo.setTimeStop(null);
+        } else {
+            timeStart = timeStart + " 00:00:00";
+            queryVo.setTimeStart(timeStart);
+            timeStop = timeStop + " 23:59:59";
+            queryVo.setTimeStop(timeStop);
+        }
+
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
+
+        Long itemTotal = opeInspectMapper.getInspectsCount(params);
+        QueryResultVo<List<VoInspect>> rsVo = new QueryResultVo<>();
+
+        rsVo.pageSize = queryVo.pageSize;
+        rsVo.pageCurr = queryVo.pageCurr;
+
+        rsVo.calculateAndSet(itemTotal, params);
+
+        List<VoInspect> inspects = opeInspectMapper.getInspects(params);
+        for (int i = 0; i < inspects.size(); i++) {
+            List<OpeTrack> tracks = opeTrackMapper.selectByInspectId(inspects.get(i).getInspectId());
+            inspects.get(i).setTracks(tracks);
+        }
+        rsVo.obj = inspects;
+        return rsVo;
+    }
+
+    /**
+     * 鑾峰彇鎸囧畾宸℃ID涓嬬殑鍏ㄩ儴杞ㄨ抗鐐�
+     * @param inspectId
+     * @return
+     */
+    public List<VoTrackPoint> getTrackPointsById(Long inspectId) {
+        return opeTrackMapper.getTrackPointsById(inspectId);
+    }
+
+    /**
+     * 鏇存柊鎸囧畾宸℃璁板綍鐨勫贰妫�璺濈
+     * @param inspectId
+     * @param distance
+     * @return
+     */
+    public int updateInspectDistance(Long inspectId, double distance ) {
+        return opeInspectMapper.updateInspectDistance(inspectId, distance);
+    }
+
+    /**
+     * 鏍规嵁宸℃鍛業D鑾峰彇宸℃鍒楄〃
+     * @param queryVo
+     * @return
+     */
+    public QueryResultVo<List<VoInspect>> getInstectsByInspectorId(QoInspect queryVo) {
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
+
+        Long itemTotal = opeInspectMapper.getInstectsCountByInspectorId(params);
+
+        QueryResultVo<List<VoInspect>> rsVo = new QueryResultVo<>();
+        rsVo.pageSize = queryVo.pageSize;
+        rsVo.pageCurr = queryVo.pageCurr;
+
+        rsVo.calculateAndSet(itemTotal, params);
+        rsVo.obj = opeInspectMapper.getInstectsByInspectorId(params);
+        return rsVo;
+    }
+}

--
Gitblit v1.8.0