From f973a618c2c82519397b65f50501df20fd89505f Mon Sep 17 00:00:00 2001
From: wuzeyu <1223318623@qq.com>
Date: 星期四, 28 三月 2024 16:12:18 +0800
Subject: [PATCH] 增加和修改监测站接口  代码里修改一些数据的限制

---
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrFlowMonitoring.java                            |    7 --
 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowMonitoringCtrl.java |  115 +++++++++++++++++++++-----------------
 2 files changed, 64 insertions(+), 58 deletions(-)

diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrFlowMonitoring.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrFlowMonitoring.java
index b156927..2182772 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrFlowMonitoring.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrFlowMonitoring.java
@@ -58,43 +58,36 @@
     */
     @JSONField(serializeUsing= ObjectWriterImplToString.class)
     @Schema(description = "鎵�鍦ㄦ潙ID", requiredMode = Schema.RequiredMode.REQUIRED)
-    @NotNull(message = "鎵�鍦ㄦ潙涓嶈兘涓虹┖")
     private Long villageid;
 
     /**
     * 鐩戞祴绔欏悕绉�
     */
     @Schema(description = "鐩戞祴绔欏悕绉�", requiredMode = Schema.RequiredMode.REQUIRED)
-    @NotBlank(message = "鐩戞祴绔欏悕绉颁笉鑳戒负绌�")
-    @Length(message = "鐩戞祴绔欏悕绉颁笉澶т簬{max}瀛楋紝涓嶅皬浜巤min}瀛�", min = 1, max = 25)
     private String name;
 
     /**
     * 缁忓害
     */
     @Schema(description = "缁忓害", requiredMode = Schema.RequiredMode.REQUIRED)
-    @NotNull(message = "缁忓害涓嶈兘涓虹┖")
     private Double lng;
 
     /**
     * 绾害
     */
     @Schema(description = "缁忓害", requiredMode = Schema.RequiredMode.REQUIRED)
-    @NotNull(message = "缁忓害涓嶈兘涓虹┖")
     private Double lat;
 
     /**
     * 澶囨敞淇℃伅
     */
     @Schema(description = "澶囨敞", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
-    @Length(message = "澶囨敞涓嶅ぇ浜巤max}瀛楋紝涓嶅皬浜巤min}瀛�", min = 1, max = 200)
     private String remarks;
 
     /**
     * 鎿嶄綔浜篒D
     */
     @Schema(description = "鎿嶄綔浜篒D", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
-    @NotNull(message = "鎿嶄綔浜篒D涓嶈兘涓虹┖")
     private Long operator;
 
     /**
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowMonitoringCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowMonitoringCtrl.java
index c30ad63..b58b548 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowMonitoringCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/FlowMonitoringCtrl.java
@@ -36,13 +36,14 @@
 @Slf4j
 @Tag(name = "娴侀噺鐩戞祴绔欑鐞�", description = "娴侀噺鐩戞祴绔欐搷浣�")
 @RestController
-@RequestMapping(path="flow_monitoring")
+@RequestMapping(path = "flow_monitoring")
 @RequiredArgsConstructor
 public class FlowMonitoringCtrl {
     private final FlowMonitoringSv flowMonitoringSv;
 
     /**
      * 娣诲姞绠$綉娴侀噺鐩戞祴绔�
+     *
      * @param po
      * @param bindingResult
      * @return
@@ -58,38 +59,45 @@
     })
     @PostMapping(path = "add", consumes = MediaType.APPLICATION_JSON_VALUE)
     @SsoAop()
-    public BaseResponse<Boolean> add(@RequestBody @Valid PrFlowMonitoring po, BindingResult bindingResult){
-        if(bindingResult != null && bindingResult.hasErrors()){
+    public BaseResponse<Boolean> add(@RequestBody @Valid PrFlowMonitoring po, BindingResult bindingResult) {
+        if (bindingResult != null && bindingResult.hasErrors()) {
             return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
         }
         // 鎺ユ敹鏉戠紪鍙凤紙涓婚敭锛�
         Long villageId = po.getVillageid();
-
-        /**
-         * 鑾峰彇5绾ц鏀垮尯鍒掍俊鎭�
-         */
-        Map map_districts = Optional.ofNullable(flowMonitoringSv.getDistrictsByVillageId(villageId)).orElse(new HashMap());
-        if(map_districts.size() <= 0) {
-            return BaseResponseUtils.buildFail("鍖哄垝淇℃伅鏈夎");
+        if (villageId != null) {
+            /**
+             * 鑾峰彇5绾ц鏀垮尯鍒掍俊鎭�
+             */
+            Map map_districts = Optional.ofNullable(flowMonitoringSv.getDistrictsByVillageId(villageId)).orElse(new HashMap());
+            if (map_districts.size() <= 0) {
+                return BaseResponseUtils.buildFail("鍖哄垝淇℃伅鏈夎");
+            }
+            Long countryId = Long.parseLong(map_districts.get("countryId").toString());
+            Long townId = Long.parseLong(map_districts.get("townId").toString());
+            po.setCountyid(countryId);
+            po.setTownid(townId);
         }
-
-        Long countryId = Long.parseLong(map_districts.get("countryId").toString());
-        Long townId = Long.parseLong(map_districts.get("townId").toString());
-        po.setCountyid(countryId);
-        po.setTownid(townId);
+        if (po.getName() == null){
+            return BaseResponseUtils.buildFail("鐩戞祴绔欏悕绉颁笉鑳戒负绌�");}
+        if (po.getName().length()>25||po.getName().length()<1){
+            return BaseResponseUtils.buildFail("25>鐩戞祴绔欏悕绉�>1");}
+        if (po.getLat()== null||po.getLng()== null){
+            return BaseResponseUtils.buildFail("缁忕含搴︿笉鑳戒负绌�");}
 
         Date operateTime = new Date();
         po.setOperatedt(operateTime);
-        po.setDeleted((byte)0);
+        po.setDeleted((byte) 0);
         Integer rec = Optional.ofNullable(flowMonitoringSv.addFlowMonitoring(po)).orElse(0);
-        if(rec == 0) {
+        if (rec == 0) {
             return BaseResponseUtils.buildFail(ProjectResultCode.FLOW_MONITORING_FAIL.getMessage());
         }
-        return BaseResponseUtils.buildSuccess(true) ;
+        return BaseResponseUtils.buildSuccess(true);
     }
 
     /**
      * 鍒犻櫎娴侀噺鐩戞祴绔�
+     *
      * @param map
      * @return
      */
@@ -104,21 +112,22 @@
     })
     @PostMapping(path = "delete")
     @SsoAop()
-    public BaseResponse<Boolean> delete(@RequestBody Map map){
-        if(map == null || map.size() <=0) {
+    public BaseResponse<Boolean> delete(@RequestBody Map map) {
+        if (map == null || map.size() <= 0) {
             return BaseResponseUtils.buildFail(ProjectResultCode.PLEASE_INPUT_FLOW_MONITORING_ID.getMessage());
         }
 
         Long flowMonitoringId = Long.parseLong(map.get("flowMonitoringId").toString());
         Integer recordCount = Optional.ofNullable(flowMonitoringSv.deleteFlowMonitoring(flowMonitoringId)).orElse(0);
-        if(recordCount == 0) {
+        if (recordCount == 0) {
             return BaseResponseUtils.buildFail(ProjectResultCode.DELETE_FLOW_MONITORING_FAIL.getMessage());
         }
-        return BaseResponseUtils.buildSuccess(true) ;
+        return BaseResponseUtils.buildSuccess(true);
     }
 
     /**
      * 缂栬緫淇敼鐩戞祴绔�
+     *
      * @param po 淇濆瓨鐩戞祴绔檉orm琛ㄥ崟瀵硅薄
      * @return 鏄惁鎴愬姛
      */
@@ -133,42 +142,46 @@
     })
     @PostMapping(path = "update", consumes = MediaType.APPLICATION_JSON_VALUE)
     @SsoAop()
-    public BaseResponse<Boolean> update(@RequestBody @Parameter(description = "form琛ㄥ崟json鏁版嵁", required = true) @Valid PrFlowMonitoring po, @Parameter(hidden = true) BindingResult bindingResult){
-        if(bindingResult != null && bindingResult.hasErrors()){
+    public BaseResponse<Boolean> update(@RequestBody @Parameter(description = "form琛ㄥ崟json鏁版嵁", required = true) @Valid PrFlowMonitoring po, @Parameter(hidden = true) BindingResult bindingResult) {
+        if (bindingResult != null && bindingResult.hasErrors()) {
             return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
         }
         // 鎺ユ敹鏉戠紪鍙凤紙涓婚敭锛�
         Long villageId = po.getVillageid();
-        /**
-         * 鑾峰彇5绾ц鏀垮尯鍒掍俊鎭�
-         */
-        Map map_districts = Optional.ofNullable(flowMonitoringSv.getDistrictsByVillageId(villageId)).orElse(new HashMap());
-        if(map_districts.size() <= 0) {
-            return BaseResponseUtils.buildFail("鍖哄垝淇℃伅鏈夎");
+        if (villageId != null) {
+            /**
+             * 鑾峰彇5绾ц鏀垮尯鍒掍俊鎭�
+             */
+            Map map_districts = Optional.ofNullable(flowMonitoringSv.getDistrictsByVillageId(villageId)).orElse(new HashMap());
+            if (map_districts.size() <= 0) {
+                return BaseResponseUtils.buildFail("鍖哄垝淇℃伅鏈夎");
+            }
+            Long countryId = Long.parseLong(map_districts.get("countryId").toString());
+            Long townId = Long.parseLong(map_districts.get("townId").toString());
+            po.setCountyid(countryId);
+            po.setTownid(townId);
         }
-        Long countryId = Long.parseLong(map_districts.get("countryId").toString());
-        Long townId = Long.parseLong(map_districts.get("townId").toString());
-        po.setCountyid(countryId);
-        po.setTownid(townId);
+
         int count;
         Date operateTime = new Date();
         po.setOperatedt(operateTime);
-        po.setDeleted((byte)0);
+        po.setDeleted((byte) 0);
         try {
             count = this.flowMonitoringSv.update(po);
         } catch (Exception e) {
             log.error("淇濆瓨鐩戞祴绔欏紓甯�", e);
-            return BaseResponseUtils.buildException(e.getMessage()) ;
+            return BaseResponseUtils.buildException(e.getMessage());
         }
-        if(count <= 0){
-            return BaseResponseUtils.buildFail(ProjectResultCode.UPDATE_FLOW_MONITORING_FAIL.getMessage()) ;
-        }else{
-            return BaseResponseUtils.buildSuccess(true) ;
+        if (count <= 0) {
+            return BaseResponseUtils.buildFail(ProjectResultCode.UPDATE_FLOW_MONITORING_FAIL.getMessage());
+        } else {
+            return BaseResponseUtils.buildSuccess(true);
         }
     }
 
     /**
      * 瀹㈡埛绔姹傚緱鍒版墍鏈夌洃娴嬬珯鍚嶅瓧
+     *
      * @return 鎵�鏈夌洃娴嬬珯鍚嶅瓧
      */
     @Operation(summary = "鑾峰緱鍏ㄩ儴鐩戞祴绔�", description = "杩斿洖鍏ㄩ儴鐩戞祴绔欐暟鎹�")
@@ -182,22 +195,23 @@
     })
     @GetMapping(path = "all")
     @SsoAop()
-    public BaseResponse<QueryResultVo<List<PrFlowMonitoring>>> all(){
+    public BaseResponse<QueryResultVo<List<PrFlowMonitoring>>> all() {
         try {
             QueryResultVo<List<PrFlowMonitoring>> res = this.flowMonitoringSv.selectAll();
-            if(res == null) {
+            if (res == null) {
                 return BaseResponseUtils.buildFail(ProjectResultCode.NO_FLOW_MONITORINGS.getMessage());
-            }else {
+            } else {
                 return BaseResponseUtils.buildSuccess(res);
             }
         } catch (Exception e) {
             log.error("鏌ヨ鐩戞祴绔欏紓甯�", e);
-            return BaseResponseUtils.buildException(e.getMessage()) ;
+            return BaseResponseUtils.buildException(e.getMessage());
         }
     }
 
     /**
      * 寰楀埌涓�涓洃娴嬬珯鏁版嵁
+     *
      * @return 涓�涓洃娴嬬珯鏁版嵁
      */
     @Operation(summary = "涓�涓洃娴嬬珯", description = "寰楀埌涓�涓洃娴嬬珯鏁版嵁")
@@ -211,10 +225,10 @@
     })
     @GetMapping(path = "one/{id}")
     @SsoAop()
-    public BaseResponse<PrFlowMonitoring> one(@PathVariable("id") Long id){
-        if(this.flowMonitoringSv.selectById(id) == null) {
+    public BaseResponse<PrFlowMonitoring> one(@PathVariable("id") Long id) {
+        if (this.flowMonitoringSv.selectById(id) == null) {
             return BaseResponseUtils.buildFail(ProjectResultCode.NO_FLOW_MONITORINGS.getMessage());
-        }else {
+        } else {
             return BaseResponseUtils.buildSuccess(this.flowMonitoringSv.selectById(id));
         }
     }
@@ -230,19 +244,18 @@
     })
     @GetMapping(path = "getFlowMonitoring")
     @SsoAop()
-    public BaseResponse<QueryResultVo<List<VoFlowMonitoring>>> getFlowMonitoring(QueryVo vo){
+    public BaseResponse<QueryResultVo<List<VoFlowMonitoring>>> getFlowMonitoring(QueryVo vo) {
         try {
             QueryResultVo<List<VoFlowMonitoring>> res = flowMonitoringSv.getPrFlowMonitorings(vo);
-            if(res == null) {
+            if (res == null) {
                 return BaseResponseUtils.buildFail(ProjectResultCode.NO_FLOW_MONITORINGS.getMessage());
             }
             return BaseResponseUtils.buildSuccess(res);
         } catch (Exception e) {
             log.error("鑾峰彇鐩戞祴绔欒褰曞紓甯�", e);
-            return BaseResponseUtils.buildException(e.getMessage()) ;
+            return BaseResponseUtils.buildException(e.getMessage());
         }
     }
-
 
 
 }

--
Gitblit v1.8.0