From 08e9685fa3f343f91c714489c9036bf5a9f8e49e Mon Sep 17 00:00:00 2001
From: Administrator <zhubaomin>
Date: 星期五, 26 一月 2024 20:26:20 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

---
 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeCtrl.java |    3 +
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrIntake.java                    |    2 
 pipIrr-platform/pipIrr-global/src/main/resources/mapper/PrDivideMapper.xml                              |    2 
 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeSv.java   |   70 +++++++++++++++++++++-------------
 pipIrr-platform/pipIrr-web/pipIrr-web-demo/src/main/java/com/dy/pipIrrDemo/demo/DemoCtrl.java           |    4 +-
 5 files changed, 49 insertions(+), 32 deletions(-)

diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrIntake.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrIntake.java
index 153c0ea..7e0fea6 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrIntake.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoPr/PrIntake.java
@@ -78,7 +78,7 @@
      */
     @JSONField(serializeUsing = ObjectWriterImplToString.class)
     @Schema(description = "鎵�鍦ㄧ墖鍖篒D", requiredMode = Schema.RequiredMode.REQUIRED)
-    @NotNull(message = "鎵�鍦ㄧ墖鍖轰笉鑳戒负绌�")
+//    @NotNull(message = "鎵�鍦ㄧ墖鍖轰笉鑳戒负绌�")
     private Long blockId;
 
     /**
diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/PrDivideMapper.xml b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/PrDivideMapper.xml
index 0d89673..00f1458 100644
--- a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/PrDivideMapper.xml
+++ b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/PrDivideMapper.xml
@@ -300,7 +300,7 @@
 
   <!--鏍规嵁鍒嗘按鎴跨紪鍙疯幏鍙栨墍灞炵墖鍖虹紪鍙�-->
   <select id="getBlockIdById" resultType="java.lang.Long">
-    SELECT blockId FROM pr_divide WHERE id = ${divideId}}
+    SELECT blockId FROM pr_divide WHERE id = ${divideId}
   </select>
 
 </mapper>
\ No newline at end of file
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-demo/src/main/java/com/dy/pipIrrDemo/demo/DemoCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-demo/src/main/java/com/dy/pipIrrDemo/demo/DemoCtrl.java
index 0d361bc..53bc971 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-demo/src/main/java/com/dy/pipIrrDemo/demo/DemoCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-demo/src/main/java/com/dy/pipIrrDemo/demo/DemoCtrl.java
@@ -116,8 +116,8 @@
     @GetMapping("test1")
     public BaseResponse<BaUser> test1(){
         BaUser po = new BaUser() ;
-        po.id = System.currentTimeMillis() ;
-        po.name = "寮犱笁" ;
+        po.userId = System.currentTimeMillis() ;
+        po.userName = "寮犱笁" ;
         po.phone = "13912345678" ;
 
         return BaseResponseUtils.buildSuccess(po);
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeCtrl.java
index 7372135..032631f 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/intake/IntakeCtrl.java
@@ -140,7 +140,7 @@
     @PostMapping(path = "add", consumes = MediaType.APPLICATION_JSON_VALUE)
     @Transactional(rollbackFor = Exception.class)
     @SsoAop()
-    public BaseResponse<Boolean> add(@RequestBody @Parameter(description = "form琛ㄥ崟json鏁版嵁", required = true) @Valid PrIntake po, @Parameter(hidden = true) BindingResult bindingResult) {
+    public BaseResponse<Boolean> add(@RequestBody  @Valid PrIntake po, @Parameter(hidden = true) BindingResult bindingResult) {
         DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
         if (bindingResult != null && bindingResult.hasErrors()) {
             return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
@@ -148,6 +148,7 @@
 
         Date operateTime = new Date();
         po.setOperateDt(operateTime);
+        po.setDeleted((byte)0);
         Integer rec = Optional.ofNullable(intakeSv.addIntake(po)).orElse(0);
         if (rec == 0) {
             return BaseResponseUtils.buildFail(ProjectResultCode.ADD_INTAKE_FAIL.getMessage());
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 b1f9cfc..7fd8e0b 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
@@ -1,6 +1,7 @@
 package com.dy.pipIrrProject.intake;
 
 import com.dy.common.webUtil.QueryResultVo;
+import com.dy.pipIrrGlobal.daoPr.PrDivideMapper;
 import com.dy.pipIrrGlobal.daoPr.PrIntakeMapper;
 import com.dy.pipIrrGlobal.pojoPr.PrIntake;
 import com.dy.pipIrrGlobal.voPr.VoIntake;
@@ -12,6 +13,7 @@
 
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 
 /**
  * @author wuzeyu
@@ -25,6 +27,8 @@
 public class IntakeSv {
     @Autowired
     private PrIntakeMapper prIntakeMapper;
+    @Autowired
+    private PrDivideMapper prDivideMapper;
 
     /**
      * 娣诲姞鍙栨按鍙�
@@ -34,41 +38,47 @@
      */
     @Transactional
     Integer addIntake(PrIntake po) {
-        if (po.getTownId()==null||po.getTownId()==0)
-        {
-            Long townId=getSupperByVillageId(po.getVillageId());
-            po.setTownId(townId);
+        Long villageId = Optional.ofNullable(po.getVillageId()).orElse(0L);
+
+        if (villageId != 0){
+            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.getCountyId()==null||po.getCountyId()==0)
-        {
-            Long countyId=getSupperByVillageId(getSupperByVillageId(po.getVillageId()));
-            po.setCountyId(countyId);
+        if (po.getBlockId() == null || po.getBlockId() == 0) {
+            Long blockId = prDivideMapper.getBlockIdById(po.getDivideId());
+            po.setBlockId(blockId);
         }
         return prIntakeMapper.insertSelective(po);
     }
-    public Long getSupperByVillageId(long vaId){
+
+    public Long getSupperByVillageId(long vaId) {
         return prIntakeMapper.getSupperByVillageId(vaId);
     }
 
 
     /**
      * 淇濆瓨淇敼瀹炰綋
+     *
      * @param po 瀹炰綋
      * @return 鏁伴噺
      */
 
-    public int update(PrIntake po){
-        if (po.getTownId()==null||po.getTownId()==0)
-        {
-            Long townId=getSupperByVillageId(po.getVillageId());
+    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()));
+        if (po.getCountyId() == null || po.getCountyId() == 0) {
+            Long countyId = getSupperByVillageId(getSupperByVillageId(po.getVillageId()));
             po.setCountyId(countyId);
         }
-        return this.prIntakeMapper.updateByPrimaryKeySelective(po) ;
+        return this.prIntakeMapper.updateByPrimaryKeySelective(po);
 //        return this.prIntakeMapper.updateByPrimaryKey(po);
     }
 
@@ -110,35 +120,39 @@
 
     /**
      * 寰楀埌鎵�鏈夊彇姘村彛
+     *
      * @return 鎵�鏈夊彇姘村彛闆嗗悎
      */
     public QueryResultVo<List<PrIntake>> selectAll() {
-        QueryResultVo<List<PrIntake>> rsVo = new QueryResultVo<>() ;
-        rsVo.obj = this.prIntakeMapper.selectAll() ;
-        return rsVo ;
+        QueryResultVo<List<PrIntake>> rsVo = new QueryResultVo<>();
+        rsVo.obj = this.prIntakeMapper.selectAll();
+        return rsVo;
     }
 
     /**
      * 寰楀埌涓�涓彇姘村彛
+     *
      * @param id 鍙栨按鍙D
      * @return 鍙栨按鍙e疄浣�
      */
     public PrIntake selectById(Long id) {
-        return this.prIntakeMapper.selectByPrimaryKey(id) ;
+        return this.prIntakeMapper.selectByPrimaryKey(id);
     }
 
     /**
      * 閫昏緫鍒犻櫎瀹炰綋
+     *
      * @param id 瀹炰綋ID
      * @return 鏁伴噺
      */
     @Transactional
-    public int delete(Long id){
-        return this.prIntakeMapper.deleteLogicById(id) ;
+    public int delete(Long id) {
+        return this.prIntakeMapper.deleteLogicById(id);
     }
 
     /**
      * 鏍规嵁鍙栨按鍙g紪鍙疯幏鍙栨湭鍒犻櫎鐨勫彇姘村彛鏁伴噺
+     *
      * @param intakeId
      * @return
      */
@@ -148,19 +162,21 @@
 
     /**
      * 鏍规嵁鏉慖d鑾峰彇鍏ㄩ儴鍦板潃
+     *
      * @param villageId 鏉慖d
-     * @return  address  鍏ㄩ儴浜旂骇鍦板潃
+     * @return address  鍏ㄩ儴浜旂骇鍦板潃
      */
-    public String getAddressByVillageId(long villageId){
+    public String getAddressByVillageId(long villageId) {
         return prIntakeMapper.getAddressByVillageId(villageId);
     }
 
     /**
      * 鏍规嵁鍖哄煙Id鑾峰彇鍖哄煙绛夌骇
+     *
      * @param regionId 鍖哄煙Id
-     * @return  Level  鍖哄煙绛夌骇
+     * @return Level  鍖哄煙绛夌骇
      */
-    public int getLevelByRegionId(long regionId){
+    public int getLevelByRegionId(long regionId) {
         return prIntakeMapper.getLevelByRegionId(regionId);
     }
 }

--
Gitblit v1.8.0