From 6fd14264034c7105b832b3e6774aa01dfa66f94b Mon Sep 17 00:00:00 2001
From: wuzeyu <1223318623@qq.com>
Date: 星期五, 07 六月 2024 14:06:30 +0800
Subject: [PATCH] 修改 取水口绑定控制器  取水口解绑控制器接口

---
 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/controller/ControllerSv.java               |   20 ++++++++++
 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/DtoIntakeController.java  |    2 
 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerCtrl.java |   37 ++++++++++++------
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrControllerTramp.java                               |    2 -
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrController.java                                    |    2 -
 5 files changed, 45 insertions(+), 18 deletions(-)

diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrController.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrController.java
index 0000ebb..a16b166 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrController.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrController.java
@@ -55,7 +55,6 @@
      */
     @Schema(description = "鎺у埗鍣ㄥ湴鍧�", requiredMode = Schema.RequiredMode.REQUIRED)
     @NotBlank(message = "鎺у埗鍣ㄥ湴鍧�涓嶈兘涓虹┖")
-    @Length(message = "鎺у埗鍣ㄥ湴鍧�涓嶅ぇ浜巤max}瀛�",max = 11)
     private String rtuAddr;
 
     /**
@@ -63,7 +62,6 @@
      */
     @Schema(description = "閫氳鍗忚", requiredMode = Schema.RequiredMode.REQUIRED)
     @NotBlank(message = "閫氳鍗忚涓嶈兘涓虹┖")
-    @Length(message = "閫氳鍗忚涓嶅ぇ浜巤max}瀛�",max = 25)
     private String protocol;
 
     /**
diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrControllerTramp.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrControllerTramp.java
index b133303..22a5e73 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrControllerTramp.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrControllerTramp.java
@@ -46,7 +46,6 @@
      */
     @Schema(description = "鎺у埗鍣ㄥ湴鍧�", requiredMode = Schema.RequiredMode.REQUIRED)
     @NotBlank(message = "鎺у埗鍣ㄥ湴鍧�涓嶈兘涓虹┖")
-    @Length(message = "鎺у埗鍣ㄥ湴鍧�蹇呴』{max}浣�",min = 11, max = 11)
     public String rtuAddr;
 
     /**
@@ -54,7 +53,6 @@
      */
     @Schema(description = "閫氳鍗忚", requiredMode = Schema.RequiredMode.REQUIRED)
     @NotBlank(message = "閫氳鍗忚涓嶈兘涓虹┖")
-    @Length(message = "閫氳鍗忚涓嶅ぇ浜巤max}瀛�",max = 25)
     public String protocol;
 
     /**
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/controller/ControllerSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/controller/ControllerSv.java
index 32ae257..90767c5 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/controller/ControllerSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/controller/ControllerSv.java
@@ -165,4 +165,24 @@
         }
         return array;
     }
+
+    /**
+     * 鏍规嵁鎺у埗鍣ㄧ紪鍙风墿鐞嗗垹闄ゆ帶鍒�
+     *2024-6-7
+     * @param controllerId
+     * @return
+     */
+    public Integer deleteControllerByIdTwo(Long controllerId) {
+        return prControllerMapper.deleteByPrimaryKey(controllerId);
+    }
+
+    /**
+     * 鏍规嵁涓婚敭鏌ヨ鎺у埗鍣ㄥ垪琛�
+     *2024-6-7
+     * @param controllerId
+     * @return
+     */
+    public PrController getByControllerId(Long controllerId) {
+        return prControllerMapper.selectByPrimaryKey(controllerId);
+    }
 }
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/DtoIntakeController.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/DtoIntakeController.java
index c49197c..570adb8 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/DtoIntakeController.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/DtoIntakeController.java
@@ -36,7 +36,7 @@
      * 澶囨敞淇℃伅
      */
     @Schema(description = "澶囨敞", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
-    @Length(message = "澶囨敞闀垮害灏忎簬{max}瀛�", min = 1, max = 200)
+    @Length(message = "澶囨敞闀垮害灏忎簬{max}瀛�", max = 200)
     private String remarks;
 
     /**
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerCtrl.java
index 252376c..fe3ca1a 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intakeController/IntakeControllerCtrl.java
@@ -113,17 +113,18 @@
         if (rec_addController == 0) {
             return BaseResponseUtils.buildFail(ProjectResultCode.BIND_FAIL.getMessage());
         }
+//        if (remarks != null || remarks !=""){
+//            // 淇敼缁戝畾璁板綍
+//            PrIntakeController prIntakeController = new PrIntakeController();
+//            prIntakeController.setRemarks(remarks);
+//            prIntakeController.setIntakeid(intakeId);
+//
+//            Integer rec = Optional.ofNullable(intakeControllerSv.updateBindRecord(prIntakeController)).orElse(0);
+//            if (rec == 0) {
+//                return BaseResponseUtils.buildFail(ProjectResultCode.BIND_FAIL.getMessage());
+//            }
+//        }
 
-
-        // 淇敼缁戝畾璁板綍
-        PrIntakeController prIntakeController = new PrIntakeController();
-        prIntakeController.setRemarks(remarks);
-        prIntakeController.setIntakeid(intakeId);
-
-        Integer rec = Optional.ofNullable(intakeControllerSv.updateBindRecord(prIntakeController)).orElse(0);
-        if (rec == 0) {
-            return BaseResponseUtils.buildFail(ProjectResultCode.BIND_FAIL.getMessage());
-        }
 
         // 鏍规嵁娴佹氮鎺у埗鍣ㄧ紪鍙峰垹闄ゆ祦娴帶鍒跺櫒璁板綍
         intakeControllerSv.deleteTrampController(trampControllerId);
@@ -176,13 +177,23 @@
         Date operateTime = new Date();
         prIntakeController.setOperatedt(operateTime);
         prIntakeController.setOperatetype((byte) 2);
+        prIntakeController.setRemarks("瑙g粦");
         Integer rec = Optional.ofNullable(intakeControllerSv.addRecord(prIntakeController)).orElse(0);
         if (rec == 0) {
             return BaseResponseUtils.buildFail(ProjectResultCode.BIND_FAIL.getMessage());
         }
-
-        // 鍒犻櫎鎺у埗鍣ㄥ閿�
-        Integer rec_deleteIntakeId = Optional.ofNullable(controllerSv.deleteIntakeId(po.getControllerId())).orElse(0);
+        //娣诲姞鍒版祦娴帶鍒跺櫒
+        PrController ControllerList = controllerSv.getByControllerId(po.getControllerId());
+        PrControllerTramp prControllerTramp = new PrControllerTramp();
+        prControllerTramp.setRtuAddr(ControllerList.getRtuAddr());
+        prControllerTramp.setProtocol(ControllerList.getProtocol());
+        prControllerTramp.setFindDt(new Date());
+        Integer rec_addControllerTramp = Optional.ofNullable(intakeControllerSv.addTrampController(prControllerTramp)).orElse(0);
+        if (rec_addControllerTramp == 0) {
+            return BaseResponseUtils.buildFail(ProjectResultCode.ADD_TRAMP_CONTROLLER_FAIL.getMessage());
+        }
+        // 鍒犻櫎鎺у埗鍣�
+        Integer rec_deleteIntakeId = Optional.ofNullable(controllerSv.deleteControllerByIdTwo(po.getControllerId())).orElse(0);
         if (rec_deleteIntakeId == 0) {
             return BaseResponseUtils.buildFail(ProjectResultCode.BIND_FAIL.getMessage());
         }

--
Gitblit v1.8.0