申报管理代码生成

shuili-system/src/main/java/com/kms/yg/sz/controller/BsSgcSzFzrController.java

@@ -1,14 +1,24 @@
 package com.kms.yg.sz.controller;
 
+import java.math.BigDecimal;
 import java.util.Arrays;
 import java.util.List;
+import java.util.stream.Collectors;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.kms.common.utils.UserUtils;
+import com.kms.system.domain.SysXzqh;
 import com.kms.system.service.SysDeptService;
 import com.kms.system.service.SysXzqhService;
 import com.kms.yg.sz.domain.BsSgcSzFzr;
+import com.kms.yg.sz.domain.BsSgcSzSafeJbxx;
+import com.kms.yg.sz.domain.dto.FzrDto;
 import com.kms.yg.sz.service.BsSgcSzFzrService;
 import com.shuili.common.core.controller.BaseController;
 import com.shuili.common.core.domain.SearchParam;
+import com.shuili.common.core.domain.entity.SysDept;
+import com.shuili.common.core.domain.entity.SysUser;
 import com.shuili.common.utils.poi.ExcelUtil;
 import com.kms.common.utils.BaseEntityUtils;
 
@@ -54,6 +64,27 @@ public class BsSgcSzFzrController extends BaseController
     @Autowired
     private SysDeptService sysDeptService;
 
+
+    /**
+     * 根据水闸id查询责任人
+     * @param sluiceId
+     * @return
+     */
+    @GetMapping("/{sluiceId}")
+    private AjaxResult getById(@PathVariable("sluiceId") String sluiceId) {
+
+        List<BsSgcSzFzr> list = bsSgcSzFzrService.list(Wrappers.lambdaQuery(BsSgcSzFzr.class).eq(BsSgcSzFzr::getSluiceId, sluiceId));
+        List<BsSgcSzFzr> collect = list.stream().filter(x -> x.getResponsibility() == "0").collect(Collectors.toList());
+        List<BsSgcSzFzr> collect1 = list.stream().filter(x -> x.getResponsibility() == "1").collect(Collectors.toList());
+
+        FzrDto fzrDto = new FzrDto();
+        fzrDto.setFxzzList(collect);
+        fzrDto.setFzrList(collect1);
+        return AjaxResult.success(fzrDto);
+    }
+
+
+
     /**
      * 查询水闸负责人列表
      */
@@ -61,7 +92,71 @@ public class BsSgcSzFzrController extends BaseController
     @ApiOperation("水闸负责人列表")
     public IPage list(@RequestBody SearchParam<BsSgcSzFzr> sp)
     {
-        return bsSgcSzFzrService.selectPage(sp);
+        BsSgcSzFzr projectInfo = sp.getData();
+        String adcd = null;
+        if (projectInfo != null) {
+            adcd = projectInfo.getAdcd();
+        }
+
+        SysUser sysUser = UserUtils.getUser();
+        if (sysUser.getUserName().equals("admin")) {
+            if (projectInfo != null && projectInfo.getAdcd() != null) {
+                String infoAdcd = projectInfo.getAdcd();
+                QueryWrapper<SysXzqh> sysXzqhQueryWrapper = new QueryWrapper<>();
+                sysXzqhQueryWrapper.eq("XZQHDM", infoAdcd);
+                SysXzqh xzqh = sysXzqhService.getOne(sysXzqhQueryWrapper);
+                if (xzqh.getLayer().compareTo(BigDecimal.valueOf(1.000000000000000000000000000000)) == 0) {
+                    infoAdcd = xzqh.getXzqhdm().substring(0, 2);
+
+                } else if (xzqh.getLayer().compareTo(BigDecimal.valueOf(2.000000000000000000000000000000)) == 0) {
+                    infoAdcd = xzqh.getXzqhdm().substring(0, 4);
+
+                }else {
+                    infoAdcd = xzqh.getXzqhdm();
+                }
+                return bsSgcSzFzrService.selectPage(sp,infoAdcd);
+            }else {
+                return bsSgcSzFzrService.selectPage(sp,null);
+            }
+
+        }else if (adcd == null) {
+            SysUser user = UserUtils.getUser();
+            String deptId = user.getDeptId();
+            SysDept sysDept = sysDeptService.get(deptId);
+            String xzqhId = sysDept.getXzqhId();
+            SysXzqh xzqh = sysXzqhService.getById(xzqhId);
+            String substring = "";
+            if (xzqh.getLayer().compareTo(BigDecimal.valueOf(1.000000000000000000000000000000)) == 0) {
+                substring = xzqh.getXzqhdm().substring(0, 2);
+
+            } else if (xzqh.getLayer().compareTo(BigDecimal.valueOf(2.000000000000000000000000000000)) == 0) {
+                substring = xzqh.getXzqhdm().substring(0, 4);
+
+            }else {
+                substring = xzqh.getXzqhdm();
+            }
+
+            return bsSgcSzFzrService.selectPage(sp,substring);
+        }else {
+
+            QueryWrapper<SysXzqh> sysXzqhQueryWrapper = new QueryWrapper<>();
+            sysXzqhQueryWrapper.eq("XZQHDM", adcd);
+
+            SysXzqh xzqh = sysXzqhService.getOne(sysXzqhQueryWrapper);
+            if (xzqh.getLayer().compareTo(BigDecimal.valueOf(1.000000000000000000000000000000)) == 0) {
+                adcd = xzqh.getXzqhdm().substring(0, 2);
+
+            } else if (xzqh.getLayer().compareTo(BigDecimal.valueOf(2.000000000000000000000000000000)) == 0) {
+                adcd = xzqh.getXzqhdm().substring(0, 4);
+
+            }else {
+                adcd = xzqh.getXzqhdm();
+            }
+            return bsSgcSzFzrService.selectPage(sp, adcd);
+        }
+
+
+
     }
 
     /**

shuili-system/src/main/java/com/kms/yg/sz/controller/BsSgcSzHzxxController.java

@@ -6,7 +6,9 @@ import java.util.List;
 import com.kms.system.service.SysDeptService;
 import com.kms.system.service.SysXzqhService;
 import com.kms.yg.sz.domain.BsSgcSzHzxx;
+import com.kms.yg.sz.domain.BsSgcSzSafeJbxx;
 import com.kms.yg.sz.service.BsSgcSzHzxxService;
+import com.kms.yg.sz.service.BsSgcSzSafeJbxxService;
 import com.shuili.common.core.controller.BaseController;
 import com.shuili.common.core.domain.SearchParam;
 import com.shuili.common.utils.poi.ExcelUtil;
@@ -54,6 +56,9 @@ public class BsSgcSzHzxxController extends BaseController
     @Autowired
     private SysDeptService sysDeptService;
 
+    @Autowired
+    private BsSgcSzSafeJbxxService bsSgcSzSafeJbxxService;
+
     /**
      * 查询水闸换证信息列表
      */
@@ -96,6 +101,9 @@ public class BsSgcSzHzxxController extends BaseController
     public AjaxResult add(@RequestBody BsSgcSzHzxx bsSgcSzHzxx)
     {
         BaseEntityUtils.preInsert(bsSgcSzHzxx);
+        BsSgcSzSafeJbxx byId = bsSgcSzSafeJbxxService.getById(bsSgcSzHzxx.getSluiceId());
+        byId.setHzStatus("0");//同上
+        bsSgcSzSafeJbxxService.updateById(byId);
         return toAjax(bsSgcSzHzxxService.save(bsSgcSzHzxx));
     }
 

shuili-system/src/main/java/com/kms/yg/sz/controller/BsSgcSzSafeJbxxController.java

@@ -1,14 +1,21 @@
 package com.kms.yg.sz.controller;
 
+import java.math.BigDecimal;
 import java.util.Arrays;
 import java.util.List;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.kms.common.utils.UserUtils;
+import com.kms.system.domain.SysXzqh;
 import com.kms.system.service.SysDeptService;
 import com.kms.system.service.SysXzqhService;
+import com.kms.yg.sz.domain.BsSgcSzBzbp;
 import com.kms.yg.sz.domain.BsSgcSzSafeJbxx;
 import com.kms.yg.sz.service.BsSgcSzSafeJbxxService;
 import com.shuili.common.core.controller.BaseController;
 import com.shuili.common.core.domain.SearchParam;
+import com.shuili.common.core.domain.entity.SysDept;
+import com.shuili.common.core.domain.entity.SysUser;
 import com.shuili.common.utils.poi.ExcelUtil;
 import com.kms.common.utils.BaseEntityUtils;
 
@@ -60,7 +67,69 @@ public class BsSgcSzSafeJbxxController extends BaseController
     @ApiOperation("水闸安全管理基本信息列表")
     public IPage list(@RequestBody SearchParam<BsSgcSzSafeJbxx> sp)
     {
-        return bsSgcSzSafeJbxxService.selectPage(sp);
+        BsSgcSzSafeJbxx projectInfo = sp.getData();
+        String adcd = null;
+        if (projectInfo != null) {
+            adcd = projectInfo.getAdcd();
+        }
+
+        SysUser sysUser = UserUtils.getUser();
+        if (sysUser.getUserName().equals("admin")) {
+            if (projectInfo != null && projectInfo.getAdcd() != null) {
+                String infoAdcd = projectInfo.getAdcd();
+                QueryWrapper<SysXzqh> sysXzqhQueryWrapper = new QueryWrapper<>();
+                sysXzqhQueryWrapper.eq("XZQHDM", infoAdcd);
+                SysXzqh xzqh = sysXzqhService.getOne(sysXzqhQueryWrapper);
+                if (xzqh.getLayer().compareTo(BigDecimal.valueOf(1.000000000000000000000000000000)) == 0) {
+                    infoAdcd = xzqh.getXzqhdm().substring(0, 2);
+
+                } else if (xzqh.getLayer().compareTo(BigDecimal.valueOf(2.000000000000000000000000000000)) == 0) {
+                    infoAdcd = xzqh.getXzqhdm().substring(0, 4);
+
+                }else {
+                    infoAdcd = xzqh.getXzqhdm();
+                }
+                return bsSgcSzSafeJbxxService.selectPage(sp,infoAdcd);
+            }else {
+                return bsSgcSzSafeJbxxService.selectPage(sp,null);
+            }
+
+        }else if (adcd == null) {
+            SysUser user = UserUtils.getUser();
+            String deptId = user.getDeptId();
+            SysDept sysDept = sysDeptService.get(deptId);
+            String xzqhId = sysDept.getXzqhId();
+            SysXzqh xzqh = sysXzqhService.getById(xzqhId);
+            String substring = "";
+            if (xzqh.getLayer().compareTo(BigDecimal.valueOf(1.000000000000000000000000000000)) == 0) {
+                substring = xzqh.getXzqhdm().substring(0, 2);
+
+            } else if (xzqh.getLayer().compareTo(BigDecimal.valueOf(2.000000000000000000000000000000)) == 0) {
+                substring = xzqh.getXzqhdm().substring(0, 4);
+
+            }else {
+                substring = xzqh.getXzqhdm();
+            }
+
+            return bsSgcSzSafeJbxxService.selectPage(sp,substring);
+        }else {
+
+            QueryWrapper<SysXzqh> sysXzqhQueryWrapper = new QueryWrapper<>();
+            sysXzqhQueryWrapper.eq("XZQHDM", adcd);
+
+            SysXzqh xzqh = sysXzqhService.getOne(sysXzqhQueryWrapper);
+            if (xzqh.getLayer().compareTo(BigDecimal.valueOf(1.000000000000000000000000000000)) == 0) {
+                adcd = xzqh.getXzqhdm().substring(0, 2);
+
+            } else if (xzqh.getLayer().compareTo(BigDecimal.valueOf(2.000000000000000000000000000000)) == 0) {
+                adcd = xzqh.getXzqhdm().substring(0, 4);
+
+            }else {
+                adcd = xzqh.getXzqhdm();
+            }
+            return bsSgcSzSafeJbxxService.selectPage(sp, adcd);
+        }
+
     }
 
     /**
@@ -95,6 +164,7 @@ public class BsSgcSzSafeJbxxController extends BaseController
     public AjaxResult add(@RequestBody BsSgcSzSafeJbxx bsSgcSzSafeJbxx)
     {
         BaseEntityUtils.preInsert(bsSgcSzSafeJbxx);
+        bsSgcSzSafeJbxx.setStatus("0"); //状态：0已填报 1审核通过 2审核不通过
         return toAjax(bsSgcSzSafeJbxxService.save(bsSgcSzSafeJbxx));
     }
 

shuili-system/src/main/java/com/kms/yg/sz/controller/BsSgcSzZxxxController.java

@@ -3,6 +3,8 @@ package com.kms.yg.sz.controller;
 import java.util.Arrays;
 import java.util.List;
 
+import com.kms.yg.sz.domain.BsSgcSzSafeJbxx;
+import com.kms.yg.sz.service.BsSgcSzSafeJbxxService;
 import com.shuili.common.core.controller.BaseController;
 import com.shuili.common.core.domain.SearchParam;
 import com.shuili.common.utils.poi.ExcelUtil;
@@ -52,6 +54,9 @@ public class BsSgcSzZxxxController extends BaseController
     @Autowired
     private SysDeptService sysDeptService;
 
+    @Autowired
+    private BsSgcSzSafeJbxxService bsSgcSzSafeJbxxService;
+
     /**
      * 查询水闸注销信息列表
      */
@@ -94,6 +99,9 @@ public class BsSgcSzZxxxController extends BaseController
     public AjaxResult add(@RequestBody BsSgcSzZxxx bsSgcSzZxxx)
     {
         BaseEntityUtils.preInsert(bsSgcSzZxxx);
+        BsSgcSzSafeJbxx byId = bsSgcSzSafeJbxxService.getById(bsSgcSzZxxx.getSluiceId());
+        byId.setZxStatus("0");
+        bsSgcSzSafeJbxxService.updateById(byId);
         return toAjax(bsSgcSzZxxxService.save(bsSgcSzZxxx));
     }
 

shuili-system/src/main/java/com/kms/yg/sz/domain/BsSgcSzFxzz.java

@@ -88,4 +88,11 @@ public class BsSgcSzFxzz extends BaseEntity
     @ApiModelProperty("成员")
     private String relation;
 
+    private String responsibility;
+
+    private String sluiceName;
+
+    private String sluiceType;
+
+
 }

shuili-system/src/main/java/com/kms/yg/sz/domain/BsSgcSzFzr.java

@@ -101,4 +101,46 @@ public class BsSgcSzFzr extends BaseEntity
     @ApiModelProperty("类型")
     private String type;
 
+    private String responsibility;
+
+    private String sluiceName;
+
+    private String sluiceType;
+
+    private String sluiceId;
+
+    private String adcd;
+
+
+    /** 组织名称 */
+    @Excel(name = "组织名称")
+    @ApiModelProperty("组织名称")
+    private String organizationName;
+
+
+
+    /** 负责人名称 */
+    @Excel(name = "负责人名称")
+    @ApiModelProperty("负责人名称")
+    private String chargePersonName;
+
+    /** 负责人电话 */
+    @Excel(name = "负责人电话")
+    @ApiModelProperty("负责人电话")
+    private String chargePersonPhone;
+
+    /** 负责人职务 */
+    @Excel(name = "负责人职务")
+    @ApiModelProperty("负责人职务")
+    private String chargePersonDuites;
+
+    /** 负责人类型 */
+    @Excel(name = "负责人类型")
+    @ApiModelProperty("负责人类型")
+    private String chargePersonType;
+
+    /** 成员 */
+    @Excel(name = "成员")
+    @ApiModelProperty("成员")
+    private String member;
 }

shuili-system/src/main/java/com/kms/yg/sz/domain/BsSgcSzGcxy.java

@@ -28,6 +28,8 @@ public class BsSgcSzGcxy extends BaseEntity
     @ApiModelProperty("设计灌溉面积")
     private String designedIrrigationArea;
 
+    private String sluiceId;
+
     /** 实际灌溉面积 */
     @Excel(name = "实际灌溉面积")
     @ApiModelProperty("实际灌溉面积")

shuili-system/src/main/java/com/kms/yg/sz/domain/BsSgcSzJdsb.java

@@ -28,6 +28,7 @@ public class BsSgcSzJdsb extends BaseEntity
     @ApiModelProperty("启闭设备")
     private String openingClosingEquipment;
 
+    private String sluiceId;
     /** 启闭机数量 */
     @Excel(name = "启闭机数量")
     @ApiModelProperty("启闭机数量")

shuili-system/src/main/java/com/kms/yg/sz/domain/BsSgcSzSafeJbxx.java

@@ -179,4 +179,10 @@ public class BsSgcSzSafeJbxx extends BaseEntity
     @ApiModelProperty("安全鉴定状态")
     private String securityStatus;
 
+    private String hzStatus;
+
+    private String zxStatus;
+
+    private String adcd;
+
 }

shuili-system/src/main/java/com/kms/yg/sz/domain/BsSgcSzSjcs.java

@@ -28,6 +28,8 @@ public class BsSgcSzSjcs extends BaseEntity
     @ApiModelProperty("闸基地质条件")
     private String gateFoundationCondition;
 
+    private String sluiceId;
+
     /** 近闸边坡稳定性 */
     @Excel(name = "近闸边坡稳定性")
     @ApiModelProperty("近闸边坡稳定性")

shuili-system/src/main/java/com/kms/yg/sz/domain/BsSgcSzSwtz.java

@@ -38,6 +38,8 @@ public class BsSgcSzSwtz extends BaseEntity
     @ApiModelProperty("多年平均径流量")
     private String annualAverageRunoff;
 
+    private String sluiceId;
+
     /** 多年平均输沙量 */
     @Excel(name = "多年平均输沙量")
     @ApiModelProperty("多年平均输沙量")

shuili-system/src/main/java/com/kms/yg/sz/domain/BsSgcSzXlnl.java

@@ -30,6 +30,7 @@ public class BsSgcSzXlnl extends BaseEntity
     @ApiModelProperty("闸上水位")
     private String waterLevelAboveGate;
 
+    private String sluiceId;
     /** 闸下水位 */
     @Excel(name = "闸下水位")
     @ApiModelProperty("闸下水位")

shuili-system/src/main/java/com/kms/yg/sz/domain/dto/FzrDto.java

@@ -0,0 +1,15 @@
+package com.kms.yg.sz.domain.dto;
+
+import com.kms.yg.sz.domain.BsSgcSzFzr;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class FzrDto {
+
+    private List<BsSgcSzFzr> fzrList;
+
+    private List<BsSgcSzFzr> fxzzList;
+
+}

shuili-system/src/main/java/com/kms/yg/sz/service/BsSgcSzFzrService.java

@@ -1,10 +1,21 @@
 package com.kms.yg.sz.service;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.kms.yg.sz.domain.BsSgcSzFxzz;
 import com.kms.yg.sz.domain.BsSgcSzFzr;
+import com.kms.yg.sz.domain.BsSgcSzSafeJbxx;
+import com.kms.yg.sz.mapper.BsSgcSzFxzzMapper;
 import com.kms.yg.sz.mapper.BsSgcSzFzrMapper;
+import com.shuili.common.core.domain.SearchParam;
 import com.shuili.common.core.service.BaseService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+import java.util.Map;
+
 
 /**
  * 水闸负责人Service接口
@@ -15,4 +26,45 @@ import org.springframework.stereotype.Service;
 @Service
 public class BsSgcSzFzrService extends BaseService<BsSgcSzFzrMapper, BsSgcSzFzr>{
 
+    @Autowired
+    private BsSgcSzFzrMapper bsSgcSzFzrMapper;
+
+    @Autowired
+    private BsSgcSzFxzzMapper bsSgcSzFxzzMapper;
+
+
+    public IPage selectPage(SearchParam<BsSgcSzFzr> sp, String adcd) {
+
+        QueryWrapper<BsSgcSzFzr> queryWrapper = new QueryWrapper<>();
+        BsSgcSzFzr projectInfo = sp.getData();
+
+        if (projectInfo != null) {
+            String projectName = projectInfo.getSluiceName();
+            String projectType = projectInfo.getSluiceType();
+
+            queryWrapper.eq(projectInfo.getId()!=null,"id", projectInfo.getId());
+            queryWrapper.like(projectName != null, "sluice_name", projectName);
+            queryWrapper.like(projectType != null, "sluice_type", projectType);
+            queryWrapper.likeRight(adcd != null, "ADCD", adcd);
+
+        }
+
+
+        Map<String, Object> params = sp.getParams();
+        if (params!=null) {
+            //create_time
+            if (params.get("orderBy") != null) {
+                String orderBy = (String) params.get("orderBy");
+                queryWrapper.orderByDesc(orderBy != null, orderBy);
+            }
+        }
+
+
+        Page<BsSgcSzFzr> page = new Page<>(sp.getPageNum(),sp.getPageSize());
+        Page<BsSgcSzFzr> infoPage = bsSgcSzFzrMapper.selectPage(page, queryWrapper);
+
+        return infoPage;
+    }
+
+
 }

shuili-system/src/main/java/com/kms/yg/sz/service/BsSgcSzSafeJbxxService.java

@@ -1,10 +1,20 @@
 package com.kms.yg.sz.service;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.kms.yg.sz.domain.BsSgcSzBzbp;
+import com.kms.yg.sz.domain.BsSgcSzGcda;
 import com.kms.yg.sz.domain.BsSgcSzSafeJbxx;
 import com.kms.yg.sz.mapper.BsSgcSzSafeJbxxMapper;
+import com.shuili.common.core.domain.SearchParam;
 import com.shuili.common.core.service.BaseService;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+
 
 /**
  * 水闸安全管理基本信息Service接口
@@ -15,4 +25,40 @@ import org.springframework.stereotype.Service;
 @Service
 public class BsSgcSzSafeJbxxService extends BaseService<BsSgcSzSafeJbxxMapper, BsSgcSzSafeJbxx>{
 
+    @Resource
+    private BsSgcSzSafeJbxxMapper bsSgcSzSafeJbxxMapper;
+
+
+    public IPage selectPage(SearchParam<BsSgcSzSafeJbxx> sp, String adcd) {
+
+        QueryWrapper<BsSgcSzSafeJbxx> queryWrapper = new QueryWrapper<>();
+        BsSgcSzSafeJbxx projectInfo = sp.getData();
+
+        if (projectInfo != null) {
+            String projectName = projectInfo.getSluiceName();
+            String projectType = projectInfo.getSluiceType();
+
+            queryWrapper.eq(projectInfo.getId()!=null,"id", projectInfo.getId());
+            queryWrapper.like(projectName != null, "sluice_name", projectName);
+            queryWrapper.like(projectType != null, "sluice_type", projectType);
+            queryWrapper.likeRight(adcd != null, "ADCD", adcd);
+
+        }
+
+
+        Map<String, Object> params = sp.getParams();
+        if (params!=null) {
+            //create_time
+            if (params.get("orderBy") != null) {
+                String orderBy = (String) params.get("orderBy");
+                queryWrapper.orderByDesc(orderBy != null, orderBy);
+            }
+        }
+
+
+        Page<BsSgcSzSafeJbxx> page = new Page<>(sp.getPageNum(),sp.getPageSize());
+        Page<BsSgcSzSafeJbxx> infoPage = bsSgcSzSafeJbxxMapper.selectPage(page, queryWrapper);
+        return infoPage;
+    }
+
 }