From 0cf21592da954beccb0d599bdbc53b38d5129f3c Mon Sep 17 00:00:00 2001
From: wuzeyu <1223318623@qq.com>
Date: 星期五, 24 五月 2024 09:29:19 +0800
Subject: [PATCH] 田间灌溉项目管理 灌溉单元  完善查询接口字段、完善删除接口关联删除

---
 pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateUnit/IrrigateUnitSv.java |   93 ++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 93 insertions(+), 0 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateUnit/IrrigateUnitSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateUnit/IrrigateUnitSv.java
index 3ce61e4..195f8cb 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateUnit/IrrigateUnitSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/irrigateUnit/IrrigateUnitSv.java
@@ -1,7 +1,24 @@
 package com.dy.pipIrrIrrigate.irrigateUnit;
 
+import com.dy.common.webUtil.QueryResultVo;
+import com.dy.pipIrrGlobal.daoIr.IrGroupUnitMapper;
+import com.dy.pipIrrGlobal.daoIr.IrIrrigateUnitMapper;
+import com.dy.pipIrrGlobal.daoIr.IrProjectMapper;
+import com.dy.pipIrrGlobal.pojoIr.IrIrrigateUnit;
+import com.dy.pipIrrGlobal.pojoIr.IrProject;
+import com.dy.pipIrrGlobal.voIr.VoProject;
+import com.dy.pipIrrGlobal.voIr.VoProjectOne;
+import com.dy.pipIrrGlobal.voIr.VoUnit;
+import com.dy.pipIrrGlobal.voIr.VoUnitOne;
+import com.dy.pipIrrIrrigate.irrigateUnit.QueryVo;
 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.Date;
+import java.util.List;
+import java.util.Map;
 
 /**
  * @author :WuZeYu
@@ -12,4 +29,80 @@
 @Slf4j
 @Service
 public class IrrigateUnitSv {
+
+    @Autowired
+    private IrIrrigateUnitMapper irIrrigateUnitMapper;
+    @Autowired
+    private IrGroupUnitMapper irGroupUnitMapper;
+
+    /**
+     * 鍒涘缓鐏屾簤鍗曞厓
+     *
+     * @param po
+     * @return
+     */
+    public Integer addIrrigateUnit(IrIrrigateUnit po) {
+        po.setOperateDt(new Date());
+        po.setDeleted((byte) 0);
+        int rows = irIrrigateUnitMapper.insertSelective(po);
+        if (rows == 0) {
+            return 0;
+        }
+        return 1;
+    }
+
+    /**
+     * 鍒犻櫎鐏屾簤鍗曞厓
+     *
+     * @param id
+     */
+    public Integer deleteUnit(Long id) {
+        int rows = irIrrigateUnitMapper.deleteLogicById(id);
+        irGroupUnitMapper.deleteByUnitId(id);
+        if (rows == 0) {
+            return 0;
+        }
+        return 1;
+    }
+
+    /**
+     * 淇敼鐏屾簤鍗曞厓
+     * @param po
+     * @return
+     */
+    public Integer updateUnit(IrIrrigateUnit po){
+        po.setOperateDt(new Date());
+        int rows = irIrrigateUnitMapper.updateByPrimaryKeySelective(po);
+        if (rows == 0){
+            return 0;
+        }
+        return 1;
+    }
+
+    /**
+     * 鑾峰彇涓�涓亴婧夊崟鍏�
+     * @param id
+     * @return
+     */
+    public VoUnitOne selectById(Long id){
+        VoUnitOne unit = irIrrigateUnitMapper.selectById(id);
+        return unit;
+    }
+
+    /**
+     * 鍒嗛〉鏌ヨ椤圭洰
+     * @param queryVo
+     * @return
+     */
+    public QueryResultVo<List<VoUnit>> getUnits(QueryVo queryVo){
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
+        Long itemTotal = irIrrigateUnitMapper.getRecordCount(params);
+
+        QueryResultVo<List<VoUnit>> rsVo = new QueryResultVo<>();
+        rsVo.pageSize = queryVo.pageSize;
+        rsVo.pageCurr = queryVo.pageCurr;
+        rsVo.calculateAndSet(itemTotal, params);
+        rsVo.obj = irIrrigateUnitMapper.getUnits(params);
+        return rsVo;
+    }
 }

--
Gitblit v1.8.0