Procházet zdrojové kódy

Merge remote-tracking branch 'origin/zdsz3.0' into zdsz3.0

wangtong před 1 rokem
rodič
revize
c0b52f6f6a
18 změnil soubory, kde provedl 250 přidání a 12 odebrání
  1. 5 0
      ruoyi-admin/src/main/java/com/ruoyi/web/controller/zdsz/ZEngineeringCivilController.java
  2. 2 2
      ruoyi-admin/src/main/java/com/ruoyi/web/controller/zdsz/ZEngineeringIndustryController.java
  3. 8 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/ZEngineeringIndustry.java
  4. 7 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/bo/ZEngineeringIndustryBo.java
  5. 10 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/bo/ZEngineeringInfoBo.java
  6. 1 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/vo/ZAreaVo.java
  7. 7 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/vo/ZEngineeringIndustryVo.java
  8. 9 1
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/vo/ZEngineeringPipeJackingVo.java
  9. 14 2
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/enums/photoType.java
  10. 1 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/IZEngineeringCivilService.java
  11. 1 1
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/IZEngineeringIndustryService.java
  12. 2 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/IZEngineeringNodeService.java
  13. 26 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringCivilServiceImpl.java
  14. 10 5
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringIndustryServiceImpl.java
  15. 90 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringInfoServiceImpl.java
  16. 48 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringNodeServiceImpl.java
  17. 4 0
      ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringPipeJackingServiceImpl.java
  18. 5 1
      ruoyi-zdsz/src/main/resources/mapper/zdsz/ZAreaMapper.xml

+ 5 - 0
ruoyi-admin/src/main/java/com/ruoyi/web/controller/zdsz/ZEngineeringCivilController.java

@@ -230,6 +230,11 @@ public class ZEngineeringCivilController extends BaseController {
     public R Civilinsert(@RequestBody ZEngineeringReviewBo zEngineeringReviewBo, @RequestBody infoIdList infoIdList) {
         return R.ok(iZEngineeringCivilService.Civilinsert(zEngineeringReviewBo, infoIdList));
     }
+    @Log(title = "工程审核", businessType = BusinessType.OTHER)
+    @PostMapping("/insertReview")
+    public R insertReview(@RequestBody ZEngineeringReviewBo zEngineeringReviewBo, @RequestBody infoIdList infoIdList) {
+        return R.ok(iZEngineeringCivilService.insertReview(zEngineeringReviewBo, infoIdList));
+    }
 
     /**
      * 民用获取各个节点状态

+ 2 - 2
ruoyi-admin/src/main/java/com/ruoyi/web/controller/zdsz/ZEngineeringIndustryController.java

@@ -111,8 +111,8 @@ public class ZEngineeringIndustryController extends BaseController {
      */
 //    @SaCheckPermission("zdsz:engineeringIndustry:query")
     @GetMapping("/{id}/{type}")
-    public R<ZEngineeringIndustryVo> query(@NotNull(message = "主键不能为空") @PathVariable String id) {
-        return R.ok(iZEngineeringIndustryService.query(id));
+    public R<ZEngineeringIndustryVo> query(@NotNull(message = "主键不能为空") @PathVariable String id, @PathVariable String type) {
+        return R.ok(iZEngineeringIndustryService.query(id, type));
     }
 
     /**

+ 8 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/ZEngineeringIndustry.java

@@ -83,6 +83,14 @@ public class ZEngineeringIndustry extends BaseEntity {
      * 工程分类
      */
     private String enginClassification;
+
+    /**
+     * 字典项
+     * municipal_engineering_node
+     * 市政工程节点类型(沟上施工|沟下施工)
+     */
+    private String municipalEngineeringNode;
+
     /**
      * 乐观锁
      */

+ 7 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/bo/ZEngineeringIndustryBo.java

@@ -90,6 +90,13 @@ public class ZEngineeringIndustryBo extends BaseEntity {
      */
     private String type;
 
+    /**
+     * 字典项
+     * municipal_engineering_node
+     * 市政工程节点类型(沟上施工|沟下施工)
+     */
+    private String municipalEngineeringNode;
+
     private ZEngineeringNodeBo zEngineeringNodeBo;
 
     /**

+ 10 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/bo/ZEngineeringInfoBo.java

@@ -135,6 +135,16 @@ public class ZEngineeringInfoBo extends BaseEntity {
     @NotNull(message = "沟上部分不能为空", groups = { AddGroup.class, EditGroup.class })
     public List<String> onTheDitch;
 
+    // 市政施工-沟上施工 焊接
+    public List<String> welding;
+    // 市政施工-沟上施工 防腐
+    public List<String> aczoiling;
+    // 市政施工-沟下施工 管道下沟
+    public List<String> piping;
+    // 市政施工-沟下施工 警示带铺设
+    public List<String> warning;
+    // 市政施工-沟下施工 回填
+    public List<String> backfilling;
 
     public List<String> getBeforeBottom() {
         return beforeBottom;

+ 1 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/vo/ZAreaVo.java

@@ -60,6 +60,7 @@ public class ZAreaVo implements Serializable {
     @ExcelProperty(value = "行政区", converter = ExcelDictConvert.class)
     @ExcelDictFormat(dictType = "district")
     private String district;
+    private String districtName;
 
     /**
      * 核算行政区

+ 7 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/vo/ZEngineeringIndustryVo.java

@@ -110,6 +110,13 @@ public class ZEngineeringIndustryVo extends BaseEntity {
     @ExcelProperty(value = "工程分类")
     private String enginClassification;
 
+    /**
+     * 字典项
+     * municipal_engineering_node
+     * 市政工程节点类型(沟上施工|沟下施工)
+     */
+    private String municipalEngineeringNode;
+
     @JsonProperty("zEngineeringNodeBo")
     private ZEngineeringNodeBo zEngineeringNodeBo;
 

+ 9 - 1
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/domain/vo/ZEngineeringPipeJackingVo.java

@@ -24,7 +24,7 @@ import java.util.List;
 public class ZEngineeringPipeJackingVo extends BaseEntity implements Serializable {
 
     private static final long serialVersionUID = 1L;
-
+    private Object nodeReViewStateList;
     /**
      *
      */
@@ -87,4 +87,12 @@ public class ZEngineeringPipeJackingVo extends BaseEntity implements Serializabl
     private List<ZEngiineeringPhotoVo> pics;
     @JsonProperty("zEngineeringNodeBo")
     private ZEngineeringNodeBo zEngineeringNodeBo;
+
+    public Object getNodeReViewStateList() {
+        return nodeReViewStateList;
+    }
+
+    public void setNodeReViewStateList(Object nodeReViewStateList) {
+        this.nodeReViewStateList = nodeReViewStateList;
+    }
 }

+ 14 - 2
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/enums/photoType.java

@@ -5,6 +5,8 @@ import com.ruoyi.common.utils.StringUtils;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
+import java.util.List;
+
 @Getter
 @AllArgsConstructor
 public enum photoType {
@@ -56,7 +58,17 @@ public enum photoType {
     /**
      * 沟上部分
      */
-    onTheDitch
-    ;
+    onTheDitch,
+
+    // 市政施工-沟上施工 焊接
+    welding,
+    // 市政施工-沟上施工 防腐
+    aczoiling,
+    // 市政施工-沟下施工 管道下沟
+    piping,
+    // 市政施工-沟下施工 警示带铺设
+    warning,
+    // 市政施工-沟下施工 回填
+    backfilling
 
 }

+ 1 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/IZEngineeringCivilService.java

@@ -73,6 +73,7 @@ public interface IZEngineeringCivilService {
      * @return
      */
     int Civilinsert(ZEngineeringReviewBo zEngineeringReviewBo, infoIdList infoIdList);
+    int insertReview(ZEngineeringReviewBo zEngineeringReviewBo, infoIdList infoIdList);
 
     /**
      * 根据工程id获取所有节点审核状态

+ 1 - 1
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/IZEngineeringIndustryService.java

@@ -49,7 +49,7 @@ public interface IZEngineeringIndustryService {
      */
     Boolean deleteWithValidByIds(Collection<String> ids, Boolean isValid);
 
-    ZEngineeringIndustryVo query(String id);
+    ZEngineeringIndustryVo query(String id, String type);
 
     List<ZEngineeringIndustryTypeVo> queryNameByType(ZEngineeringIndustryBo bo);
 }

+ 2 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/IZEngineeringNodeService.java

@@ -12,6 +12,7 @@ import com.ruoyi.zdsz.domain.bo.ZEngineeringReviewBo;
 import com.ruoyi.zdsz.domain.bo.switchBo;
 import com.ruoyi.zdsz.domain.vo.ZEngineeringCivilVo;
 import com.ruoyi.zdsz.domain.vo.ZEngineeringNodeVo;
+import com.ruoyi.zdsz.domain.vo.ZEngineeringPipeJackingVo;
 
 import java.util.Collection;
 import java.util.List;
@@ -86,6 +87,7 @@ public interface IZEngineeringNodeService {
     Boolean delete(ZEngineeringNodeBo bo);
     List<String> nodeTypeList(List<ZEngineeringCivil> zEngineeringCivilList,String type,String state,ZEngineeringCivilBo bo);
     Map<String,Object> ReViewList(List<ZEngineeringCivilVo> zEngineeringCivilList);
+    Map<String,Object> ReViewPipeJackingList(List<ZEngineeringPipeJackingVo> list);
 
     /**
      * 校验并批量删除工程节点信息

+ 26 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringCivilServiceImpl.java

@@ -1037,6 +1037,32 @@ public class ZEngineeringCivilServiceImpl implements IZEngineeringCivilService {
         return 0;
     }
 
+    @Override
+    @DynamicName(spel = "#zEngineeringReviewBo.createTime")
+    public int insertReview(ZEngineeringReviewBo zEngineeringReviewBo, infoIdList infoIdList) {
+        ZEngineeringNode zEngineeringNode = zEngineeringNodeMapper.selectById(zEngineeringReviewBo.getEngInfoId());
+//        if (zEngineeringReviewBo.getReviewStatus().equals("1"))
+//        {
+//        infoIdList.getDelInfoIdList().stream().forEach(item -> {
+//            ZEngineeringInfoBo zEngineeringInfoBo = new ZEngineeringInfoBo();
+//            zEngineeringInfoBo.setCreateTime(zEngineeringNode.getCreateTime());
+//            zEngineeringInfoBo.setId(item);
+//            izEngineeringInfoService.deleteByIdNoDelFiles(zEngineeringInfoBo);
+//        });
+//        }
+        infoIdList.getInfoIdList().stream().forEach(item -> {
+            item.setState(zEngineeringReviewBo.getReviewStatus());
+            SimpleDateFormat format=new SimpleDateFormat("yyyy_MM");
+            UpdateWrapper<ZEngineeringInfo> lqw = new UpdateWrapper();
+            lqw.eq("id",item.getId()).set("state",zEngineeringReviewBo.getReviewStatus());
+            MonthTableNameHandler.setData(format.format(item.getCreateTime()));
+            zEngineeringInfoMapper.update(lqw);
+            MonthTableNameHandler.removeData();
+        });
+        izEngineeringReviewService.insert(zEngineeringReviewBo);
+        return 0;
+    }
+
 
     @Override
     public List<ZEngineeringNodeBo> getRivewStatus(String Id) {

+ 10 - 5
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringIndustryServiceImpl.java

@@ -94,7 +94,7 @@ public class ZEngineeringIndustryServiceImpl implements IZEngineeringIndustrySer
         lqw.orderByDesc(ZEngineeringIndustry::getCreateTime);
         lqw.eq(StringUtils.isNotBlank(bo.getEnginType()), ZEngineeringIndustry::getEnginType, bo.getEnginType());
         lqw.like(StringUtils.isNotBlank(bo.getEnginName()), ZEngineeringIndustry::getEnginName, bo.getEnginName());
-        lqw.eq(StringUtils.isNotBlank(bo.getEnginClassification()), ZEngineeringIndustry::getEnginClassification, bo.getEnginClassification());
+        lqw.like(StringUtils.isNotBlank(bo.getEnginClassification()), ZEngineeringIndustry::getEnginClassification, bo.getEnginClassification());
         lqw.eq(StringUtils.isNotBlank(bo.getConstructUnit()), ZEngineeringIndustry::getConstructUnit, bo.getConstructUnit());
         lqw.eq(StringUtils.isNotBlank(bo.getProjectHead()), ZEngineeringIndustry::getProjectHead, bo.getProjectHead());
         lqw.eq(StringUtils.isNotBlank(bo.getSceneHead()), ZEngineeringIndustry::getSceneHead, bo.getSceneHead());
@@ -188,11 +188,12 @@ public class ZEngineeringIndustryServiceImpl implements IZEngineeringIndustrySer
             }
         }
         bo.getzEngineeringNodeBo().setCivliId(bo.getId());
-        bo.getzEngineeringNodeBo().setType(bo.getType());
+//        bo.getzEngineeringNodeBo().setType(bo.getType());
         bo.getzEngineeringNodeBo().setCreateTime(bo.getCreateTime());
         ZEngineeringNodeBo zEngineeringNodeBo = new ZEngineeringNodeBo();
         zEngineeringNodeBo.setCivliId(update.getId());
-        zEngineeringNodeBo.setType(bo.getType());
+//        zEngineeringNodeBo.setType(bo.getType());
+        zEngineeringNodeBo.setType(bo.getzEngineeringNodeBo().getType()); // zEngineeringNodeBo.setType(bo.getzEngineeringNodeBo().getType());
         zEngineeringNodeBo.setCreateTime(baseMapper.selectVoById(bo.getId()).getCreateTime());
         ZEngineeringNodeBo query = izEngineeringNodeService.query(zEngineeringNodeBo);
         if (!ObjectUtils.isEmpty(query)) {
@@ -200,6 +201,7 @@ public class ZEngineeringIndustryServiceImpl implements IZEngineeringIndustrySer
         }
         bo.getzEngineeringNodeBo().setCreateTime(zEngineeringNodeBo.getCreateTime());
         izEngineeringNodeService.insert(bo.getzEngineeringNodeBo());
+        System.out.println("izEngineeringNodeService.insert(bo.getzEngineeringNodeBo());");
         return flag;
     }
 
@@ -305,11 +307,14 @@ public class ZEngineeringIndustryServiceImpl implements IZEngineeringIndustrySer
     }
 
     @Override
-    public ZEngineeringIndustryVo query(String id) {
+    public ZEngineeringIndustryVo query(String id, String type) {
         ZEngineeringIndustryVo zEngineeringIndustryVo = baseMapper.selectVoById(id);
         ZEngineeringNodeBo zEngineeringNodeBo = new ZEngineeringNodeBo();
         zEngineeringNodeBo.setCreateTime(zEngineeringIndustryVo.getCreateTime());
         zEngineeringNodeBo.setCivliId(zEngineeringIndustryVo.getId());
+        System.out.println("type===" + type);
+        zEngineeringNodeBo.setType(type);
+//        zEngineeringNodeBo.setType("trench_construction");
         zEngineeringIndustryVo.setZEngineeringNodeBo(izEngineeringNodeService.query(zEngineeringNodeBo));
         return zEngineeringIndustryVo;
     }
@@ -330,7 +335,7 @@ public class ZEngineeringIndustryServiceImpl implements IZEngineeringIndustrySer
         queryWrapper.eq(StringUtils.isNotBlank(bo.getEnginType()), ZEngineeringIndustry::getEnginType, bo.getEnginType());
         queryWrapper.eq(StringUtils.isNotBlank(bo.getType()), ZEngineeringIndustry::getType, bo.getType());
         if (!"null".equals(bo.getEnginClassification())) {
-            queryWrapper.eq(StringUtils.isNotBlank(bo.getEnginClassification()), ZEngineeringIndustry::getEnginClassification, bo.getEnginClassification());
+            queryWrapper.like(StringUtils.isNotBlank(bo.getEnginClassification()), ZEngineeringIndustry::getEnginClassification, bo.getEnginClassification());
         }
 
         return queryWrapper;

+ 90 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringInfoServiceImpl.java

@@ -102,6 +102,25 @@ public class ZEngineeringInfoServiceImpl implements IZEngineeringInfoService {
             zEngineeringInfoBo1.setInferiorSulcus(izEngiineeringPhotoService.queryTypeList(zEngineeringInfoBo1,photoType.inferiorSulcus.name()));
             zEngineeringInfoBo1.setConstructionRecords(izEngiineeringPhotoService.queryTypeList(zEngineeringInfoBo1,photoType.constructionRecords.name()));
             zEngineeringInfoBo1.setOnTheDitch(izEngiineeringPhotoService.queryTypeList(zEngineeringInfoBo1,photoType.onTheDitch.name()));
+            // 市政施工 start
+            /*
+                // 市政施工-沟上施工 焊接
+                welding,
+                // 市政施工-沟上施工 防腐
+                aczoiling,
+                // 市政施工-沟下施工 管道下沟
+                piping,
+                // 市政施工-沟下施工 警示带铺设
+                warning,
+                // 市政施工-沟下施工 回填
+                backfilling
+            */
+            zEngineeringInfoBo1.setWelding(izEngiineeringPhotoService.queryTypeList(zEngineeringInfoBo1,photoType.welding.name()));
+            zEngineeringInfoBo1.setAczoiling(izEngiineeringPhotoService.queryTypeList(zEngineeringInfoBo1,photoType.aczoiling.name()));
+            zEngineeringInfoBo1.setPiping(izEngiineeringPhotoService.queryTypeList(zEngineeringInfoBo1,photoType.piping.name()));
+            zEngineeringInfoBo1.setWarning(izEngiineeringPhotoService.queryTypeList(zEngineeringInfoBo1,photoType.warning.name()));
+            zEngineeringInfoBo1.setBackfilling(izEngiineeringPhotoService.queryTypeList(zEngineeringInfoBo1,photoType.backfilling.name()));
+            // 市政施工 end
             // bo.setId(item.getId());
             ZEngineeringReviewBo zEngineeringReviewbo = izEngineeringReviewService.query(bo);
             zEngineeringInfoBo1.setzEngineeringReviewBo(zEngineeringReviewbo);
@@ -395,6 +414,77 @@ public class ZEngineeringInfoServiceImpl implements IZEngineeringInfoService {
             });
 
         }
+        // 市政施工 start
+        /*
+            // 市政施工-沟上施工 焊接
+            welding,
+            // 市政施工-沟上施工 防腐
+            aczoiling,
+            // 市政施工-沟下施工 管道下沟
+            piping,
+            // 市政施工-沟下施工 警示带铺设
+            warning,
+            // 市政施工-沟下施工 回填
+            backfilling
+        */
+        if (!ObjectUtils.isEmpty(bo.getWelding())) {
+            bo.getWelding().forEach(item -> {
+                ZEngiineeringPhoto zEngiineeringPhoto = new ZEngiineeringPhoto();
+                zEngiineeringPhoto.setParentId(bo.getId());
+                zEngiineeringPhoto.setPicUrl(item);
+                zEngiineeringPhoto.setCreateTime(bo.getCreateTime());
+                zEngiineeringPhoto.setUpdateTime(new Date());
+                zEngiineeringPhoto.setType(photoType.welding.name().toString());
+                photoList.add(zEngiineeringPhoto);
+            });
+        }
+        if (!ObjectUtils.isEmpty(bo.getAczoiling())) {
+            bo.getAczoiling().forEach(item -> {
+                ZEngiineeringPhoto zEngiineeringPhoto = new ZEngiineeringPhoto();
+                zEngiineeringPhoto.setParentId(bo.getId());
+                zEngiineeringPhoto.setPicUrl(item);
+                zEngiineeringPhoto.setCreateTime(bo.getCreateTime());
+                zEngiineeringPhoto.setUpdateTime(new Date());
+                zEngiineeringPhoto.setType(photoType.aczoiling.name().toString());
+                photoList.add(zEngiineeringPhoto);
+            });
+        }
+        if (!ObjectUtils.isEmpty(bo.getPiping())) {
+            bo.getPiping().forEach(item -> {
+                ZEngiineeringPhoto zEngiineeringPhoto = new ZEngiineeringPhoto();
+                zEngiineeringPhoto.setParentId(bo.getId());
+                zEngiineeringPhoto.setPicUrl(item);
+                zEngiineeringPhoto.setCreateTime(bo.getCreateTime());
+                zEngiineeringPhoto.setUpdateTime(new Date());
+                zEngiineeringPhoto.setType(photoType.piping.name().toString());
+                photoList.add(zEngiineeringPhoto);
+            });
+        }
+        if (!ObjectUtils.isEmpty(bo.getWarning())) {
+            bo.getWarning().forEach(item -> {
+                ZEngiineeringPhoto zEngiineeringPhoto = new ZEngiineeringPhoto();
+                zEngiineeringPhoto.setParentId(bo.getId());
+                zEngiineeringPhoto.setPicUrl(item);
+                zEngiineeringPhoto.setCreateTime(bo.getCreateTime());
+                zEngiineeringPhoto.setUpdateTime(new Date());
+                zEngiineeringPhoto.setType(photoType.warning.name().toString());
+                photoList.add(zEngiineeringPhoto);
+            });
+        }
+        if (!ObjectUtils.isEmpty(bo.getBackfilling())) {
+            bo.getBackfilling().forEach(item -> {
+                ZEngiineeringPhoto zEngiineeringPhoto = new ZEngiineeringPhoto();
+                zEngiineeringPhoto.setParentId(bo.getId());
+                zEngiineeringPhoto.setPicUrl(item);
+                zEngiineeringPhoto.setCreateTime(bo.getCreateTime());
+                zEngiineeringPhoto.setUpdateTime(new Date());
+                zEngiineeringPhoto.setType(photoType.backfilling.name().toString());
+                photoList.add(zEngiineeringPhoto);
+            });
+        }
+        // 市政施工 end
+
+
         if (!photoList.isEmpty()) {
             izEngiineeringPhotoService.insertBatch(photoList);
         }

+ 48 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringNodeServiceImpl.java

@@ -17,6 +17,7 @@ import com.ruoyi.zdsz.domain.*;
 import com.ruoyi.zdsz.domain.bo.*;
 import com.ruoyi.zdsz.domain.vo.ZEngineeringCivilVo;
 import com.ruoyi.zdsz.domain.vo.ZEngineeringNodeVo;
+import com.ruoyi.zdsz.domain.vo.ZEngineeringPipeJackingVo;
 import com.ruoyi.zdsz.domain.vo.areaMessageVo;
 import com.ruoyi.zdsz.mapper.*;
 import com.ruoyi.zdsz.service.IZEngiineeringPhotoService;
@@ -699,6 +700,53 @@ public class ZEngineeringNodeServiceImpl implements IZEngineeringNodeService {
     }
 
     @Override
+    public Map<String, Object> ReViewPipeJackingList(List<ZEngineeringPipeJackingVo> list) {
+        Map<String, List<SysDictData>> sysDictMap = RedisUtils.getCacheMap("sys_dict");
+        List<ZEngineeringReview> nodeTypeList=new ArrayList<>();
+        Map<String,Object> statemap=new HashMap<>();
+        AtomicReference<List<Map<String, Object>>> ReViewStateMap= new AtomicReference<>(new ArrayList<>());
+        list.stream().forEach(item->{
+            String date=  new SimpleDateFormat("yyyy_MM").format(item.getCreateTime());
+            MonthTableNameHandler.setData(date);
+            LambdaQueryWrapper<ZEngineeringNode> lqw = Wrappers.lambdaQuery();
+            lqw.eq(StringUtils.isNotBlank(item.getId()), ZEngineeringNode::getCivliId, item.getId());
+            // lqw.eq(StringUtils.isNotBlank(type), ZEngineeringNode::getType, type);
+            List <ZEngineeringNode> nodeList=baseMapper.selectList(lqw);
+            nodeList.stream().forEach(item2->{
+                LambdaQueryWrapper<ZEngineeringReview> lqw2 = Wrappers.lambdaQuery();
+                lqw2.eq(StringUtils.isNotBlank(item2.getId()), ZEngineeringReview::getEngInfoId, item2.getId()).orderByDesc(ZEngineeringReview::getReviewTime);
+                List<ZEngineeringReview> ReviewList= zEngineeringReviewMapper.selectList(lqw2);
+                if (ReviewList.size()>0)
+                {
+                    nodeTypeList.add(ReviewList.get(0));
+                }
+
+            });
+            System.out.println(nodeList.toString());
+            System.out.println(nodeTypeList.toString());
+            List stateList=new ArrayList();
+            sysDictMap.get("pipe_jack").stream().forEach(item3 -> {
+                Map<String,Object> map=new HashMap<>();
+                if (nodeList.size()>0&&nodeList.stream().anyMatch(x->x.getType().equals(item3.getDictValue()))){
+                    map.put("Type",item3.getDictValue());
+                    map.put("state",nodeTypeList.stream().anyMatch(y->y.getEngInfoId().equals(nodeList.stream().filter(x->x.getType().equals(item3.getDictValue())).collect(Collectors.toList()).get(0).getId()))?nodeTypeList.stream().filter(y->y.getEngInfoId().equals(nodeList.stream().filter(x->x.getType().equals(item3.getDictValue())).collect(Collectors.toList()).get(0).getId())).collect(Collectors.toList()).get(0).getReviewStatus():"0");
+                    map.put("content",nodeTypeList.stream().anyMatch(y->y.getEngInfoId().equals(nodeList.stream().filter(x->x.getType().equals(item3.getDictValue())).collect(Collectors.toList()).get(0).getId()))?nodeTypeList.stream().filter(y->y.getEngInfoId().equals(nodeList.stream().filter(x->x.getType().equals(item3.getDictValue())).collect(Collectors.toList()).get(0).getId())).collect(Collectors.toList()).get(0).getReviewContent():"暂未审核");
+                }else {
+                    map.put("Type",item3.getDictValue());
+                    map.put("state","0");
+                    map.put("content","暂未审核");
+                }
+                stateList.add(map);
+                ReViewStateMap.set(stateList);;
+            });
+            statemap.put(item.getId(),ReViewStateMap.get());
+
+            MonthTableNameHandler.removeData();
+        });
+        return statemap;
+    }
+
+    @Override
     public Map<String,Object> ReViewList(List<ZEngineeringCivilVo> zEngineeringCivilList) {
         Map<String, List<SysDictData>> sysDictMap = RedisUtils.getCacheMap("sys_dict");
         List<ZEngineeringReview> nodeTypeList=new ArrayList<>();

+ 4 - 0
ruoyi-zdsz/src/main/java/com/ruoyi/zdsz/service/impl/ZEngineeringPipeJackingServiceImpl.java

@@ -97,6 +97,10 @@ public class ZEngineeringPipeJackingServiceImpl implements IZEngineeringPipeJack
     public TableDataInfo<ZEngineeringPipeJackingVo> queryPageList(ZEngineeringPipeJackingBo bo, PageQuery pageQuery) {
         LambdaQueryWrapper<ZEngineeringPipeJacking> lqw = buildQueryWrapper(bo);
         Page<ZEngineeringPipeJackingVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
+        Map<String, Object> ReviewList = nodeService.ReViewPipeJackingList(result.getRecords());
+        result.getRecords().forEach(item -> {
+            item.setNodeReViewStateList(ReviewList.get(item.getId()));
+        });
         return TableDataInfo.build(result);
     }
 

+ 5 - 1
ruoyi-zdsz/src/main/resources/mapper/zdsz/ZAreaMapper.xml

@@ -33,9 +33,13 @@
         select
         a.id,
         a.name,
-        a.administrative
+        a.administrative,
+        a.district,
+        b.dict_label as districtName
         from z_area a
+        left join sys_dict_data b on a.district = b.dict_value
         where a.del_flag = '0'
+        and b.dict_type = 'district'
         <if test="district != null and district != ''">
             and a.district = #{district}
         </if>