From c6beb89b7170115eada78526f87406381c931229 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期四, 03 四月 2025 10:37:51 +0800
Subject: [PATCH] 灌溉计划发布时仅发布灌溉时长大于0的

---
 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeSv.java |   53 +++++++++++++++++++++++++++++++++++------------------
 1 files changed, 35 insertions(+), 18 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeSv.java
index e5c9295..caa9e6d 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeSv.java
@@ -6,11 +6,14 @@
 import com.dy.common.multiDataSource.DataSourceContext;
 import com.dy.common.mw.protocol.Command;
 import com.dy.common.webUtil.BaseResponse;
+import com.dy.common.webUtil.BaseResponseUtils;
 import com.dy.common.webUtil.QueryResultVo;
 import com.dy.pipIrrGlobal.config.DingTalk;
 import com.dy.pipIrrGlobal.daoPr.PrDivideMapper;
 import com.dy.pipIrrGlobal.daoPr.PrIntakeMapper;
 import com.dy.pipIrrGlobal.pojoPr.PrIntake;
+import com.dy.pipIrrGlobal.voPr.IntakeUpdateLngLat;
+import com.dy.pipIrrGlobal.voPr.VoAllIntake;
 import com.dy.pipIrrGlobal.voPr.VoIntake;
 import com.dy.pipIrrGlobal.voPr.VoOnLineIntake;
 import lombok.extern.slf4j.Slf4j;
@@ -26,7 +29,9 @@
 import org.springframework.web.client.RestTemplate;
 import org.springframework.web.util.UriComponentsBuilder;
 
-import java.util.*;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
 
 /**
  * @author wuzeyu
@@ -114,14 +119,14 @@
      */
 
     public int update(PrIntake po) {
-        if (po.getTownId() == null || po.getTownId() == 0) {
-            Long townId = getSupperByVillageId(po.getVillageId());
-            po.setTownId(townId);
-        }
-        if (po.getCountyId() == null || po.getCountyId() == 0) {
-            Long countyId = getSupperByVillageId(getSupperByVillageId(po.getVillageId()));
-            po.setCountyId(countyId);
-        }
+//        if (po.getTownId() == null || po.getTownId() == 0) {
+//            Long townId = getSupperByVillageId(po.getVillageId());
+//            po.setTownId(townId);
+//        }
+//        if (po.getCountyId() == null || po.getCountyId() == 0) {
+//            Long countyId = getSupperByVillageId(getSupperByVillageId(po.getVillageId()));
+//            po.setCountyId(countyId);
+//        }
         return this.prIntakeMapper.updateByPrimaryKeySelective(po);
 //        return this.prIntakeMapper.updateByPrimaryKey(po);
     }
@@ -161,8 +166,8 @@
      *
      * @return 鎵�鏈夊彇姘村彛闆嗗悎
      */
-    public QueryResultVo<List<PrIntake>> selectAll() {
-        QueryResultVo<List<PrIntake>> rsVo = new QueryResultVo<>();
+    public QueryResultVo<List<VoAllIntake>> selectAll() {
+        QueryResultVo<List<VoAllIntake>> rsVo = new QueryResultVo<>();
         rsVo.obj = this.prIntakeMapper.selectAll();
         return rsVo;
     }
@@ -173,7 +178,7 @@
      * @param id 鍙栨按鍙D
      * @return 鍙栨按鍙ｅ疄浣�
      */
-    public PrIntake selectById(Long id) {
+    public VoAllIntake selectById(Long id) {
         return this.prIntakeMapper.selectByPrimaryKey(id);
     }
 
@@ -272,23 +277,22 @@
         com.code = "LCD0001";
         com.type = "innerCommand";
         JSONObject response = (JSONObject) JSON.toJSON(sendCom2Mw(com));
+
+        JSONArray jsonArray = new JSONArray();
         if (response != null && response.getString("code").equals("0001")) {
             JSONObject attachment = response.getJSONObject("content").getJSONObject("attachment");
-
-            JSONArray jsonArray = new JSONArray();
             if(attachment != null) {
                 attachment.forEach((key, value) -> {
                     JSONObject jsonObject = new JSONObject();
                     jsonObject.put("rtuAddr", key);
                     jsonObject.put("isOnLine", value);
                     jsonArray.add(jsonObject);
-
                 });
             }
-            return prIntakeMapper.getUsedIntakes(jsonArray.toJSONString(), operator);
-        } else {
-            return new ArrayList<>();
+        //} else {
+        //    return new ArrayList<>();
         }
+        return prIntakeMapper.getUsedIntakes(jsonArray.toJSONString(), operator);
     }
 
     /**
@@ -309,6 +313,11 @@
         } catch (Exception e) {
             e.printStackTrace();
         }
+
+        if(response == null) {
+            return BaseResponseUtils.buildErrorMsg("涓棿浠惰皟鐢ㄥけ璐�");
+        }
+
         return response.getBody();
     }
 
@@ -334,4 +343,12 @@
     }
 
 
+    /**
+     * app淇敼鍙栨按鍙ｇ粡绾害
+     * @param po
+     * @return
+     */
+    public int updateIntakeLngLat(IntakeUpdateLngLat po) {
+        return prIntakeMapper.updateByPrimaryKeySelective1(po);
+    }
 }

--
Gitblit v1.8.0