zhengsl/WholeProcessPlatform
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

feat: 新增流域、基地、电站基础表

Browse Source
This commit is contained in:
tangwei 2026-04-21 13:41:41 +08:00
parent 5f2ad094c4
commit a42677de02
43 changed files with 3571 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/main/java/com/yfd/platform/config/SwaggerConfig.java
View File

@ -46,4 +46,12 @@ public class SwaggerConfig {
.packagesToScan("com.yfd.platform.system.controller")
.build();
}
@Bean
public GroupedOpenApi groupEnvApi() {
return GroupedOpenApi.builder()
.group("4. 环境/基地/流域管理")
.packagesToScan("com.yfd.platform.env.controller")
.build();
}
}

9
backend/src/main/java/com/yfd/platform/data/domain/SysUserDataScope.java
View File

@ -33,12 +33,12 @@ public class SysUserDataScope implements Serializable {
private String userId;
/**
* 资源类型（BASIN/BASE/STATION）
* 资源类型（BASIN / BASE /COMPANY / STATION）
*/
private String orgType;
/**
* 资源编码（流域编码/基地编码/电站编码）
* 资源编码（流域编码/基地编码/公司编码/电站编码）
*/
private String orgId;
@ -115,4 +115,9 @@ public class SysUserDataScope implements Serializable {
* 备注
*/
private String remark;
/**
* 是否是全选 0：非全选 1：全选
*/
private Integer isAllChildren;
}

56
backend/src/main/java/com/yfd/platform/env/controller/SdCountryBController.java vendored Normal file
View File

@ -0,0 +1,56 @@
package com.yfd.platform.env.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdCountryB;
import com.yfd.platform.env.service.ISdCountryBService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.*;
import jakarta.annotation.Resource;
import java.util.List;
/**
* <p>
* 国家信息表 前端控制器
* </p>
*/
@RestController
@RequestMapping("/env/country")
@Tag(name = "国家管理")
public class SdCountryBController {
@Resource
private ISdCountryBService countryBService;
@GetMapping("/queryPageList")
@Operation(summary = "分页查询国家列表")
public ResponseResult queryPageList(
@RequestParam(required = false) String countryName,
@RequestParam(required = false) String continentType,
@RequestParam(defaultValue = "1") Long pageNum,
@RequestParam(defaultValue = "10") Long pageSize) {
Page<SdCountryB> page = new Page<>(pageNum, pageSize);
Page<SdCountryB> result = countryBService.queryPageList(page, countryName, continentType);
return ResponseResult.successData(result);
}
@GetMapping("/list")
@Operation(summary = "查询所有国家")
public ResponseResult list() {
return ResponseResult.successData(countryBService.list());
}
@GetMapping("/getEnabledList")
@Operation(summary = "获取所有启用的国家")
public ResponseResult getEnabledList() {
return ResponseResult.successData(countryBService.getEnabledList());
}
@GetMapping("/getById")
@Operation(summary = "根据编码查询国家")
public ResponseResult getById(@RequestParam String no) {
return ResponseResult.successData(countryBService.getById(no));
}
}

95
backend/src/main/java/com/yfd/platform/env/controller/SdEngInfoBHController.java vendored Normal file
View File

@ -0,0 +1,95 @@
package com.yfd.platform.env.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.service.ISdEngInfoBHService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.*;
import jakarta.annotation.Resource;
import java.util.List;
/**
* <p>
* 水电水利工程基础信息表 前端控制器
* </p>
*/
@RestController
@RequestMapping("/env/engInfo")
@Tag(name = "电站管理")
public class SdEngInfoBHController {
@Resource
private ISdEngInfoBHService engInfoBHService;
@GetMapping("/queryPageList")
@Operation(summary = "分页查询电站列表")
public ResponseResult queryPageList(
@RequestParam(required = false) String ennm,
@RequestParam(required = false) String rvcd,
@RequestParam(required = false) String baseId,
@RequestParam(required = false) String hycd,
@RequestParam(defaultValue = "1") Long pageNum,
@RequestParam(defaultValue = "10") Long pageSize) {
Page<SdEngInfoBH> page = new Page<>(pageNum, pageSize);
Page<SdEngInfoBH> result = engInfoBHService.queryPageList(page, ennm, rvcd, baseId, hycd);
return ResponseResult.successData(result);
}
@GetMapping("/list")
@Operation(summary = "查询所有电站")
public ResponseResult list() {
return ResponseResult.successData(engInfoBHService.list());
}
@GetMapping("/getById")
@Operation(summary = "根据编码查询电站")
public ResponseResult getById(@RequestParam String stcd) {
return ResponseResult.successData(engInfoBHService.getById(stcd));
}
@GetMapping("/getByBaseId")
@Operation(summary = "根据基地编码查询电站")
public ResponseResult getByBaseId(@RequestParam String baseId) {
return ResponseResult.successData(engInfoBHService.getByBaseId(baseId));
}
@GetMapping("/getByHycd")
@Operation(summary = "根据公司编码查询电站")
public ResponseResult getByHycd(@RequestParam String hycd) {
return ResponseResult.successData(engInfoBHService.getByHycd(hycd));
}
@GetMapping("/getByRvcd")
@Operation(summary = "根据流域编码查询电站")
public ResponseResult getByRvcd(@RequestParam String rvcd) {
return ResponseResult.successData(engInfoBHService.getByRvcd(rvcd));
}
@Log(module = "电站管理", value = "新增电站")
@PostMapping("/add")
@Operation(summary = "新增电站")
public ResponseResult add(@RequestBody SdEngInfoBH engInfo) {
boolean result = engInfoBHService.addEngInfo(engInfo);
return result ? ResponseResult.success("新增成功") : ResponseResult.error("新增失败");
}
@Log(module = "电站管理", value = "修改电站")
@PostMapping("/update")
@Operation(summary = "修改电站")
public ResponseResult update(@RequestBody SdEngInfoBH engInfo) {
boolean result = engInfoBHService.updateEngInfo(engInfo);
return result ? ResponseResult.success("修改成功") : ResponseResult.error("修改失败");
}
@Log(module = "电站管理", value = "删除电站")
@PostMapping("/delete")
@Operation(summary = "删除电站")
public ResponseResult delete(@RequestParam String stcd) {
boolean result = engInfoBHService.deleteEngInfo(stcd);
return result ? ResponseResult.success("删除成功") : ResponseResult.error("删除失败");
}
}

88
backend/src/main/java/com/yfd/platform/env/controller/SdHycdDicController.java vendored Normal file
View File

@ -0,0 +1,88 @@
package com.yfd.platform.env.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdHycdDic;
import com.yfd.platform.env.service.ISdHycdDicService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.*;
import jakarta.annotation.Resource;
import java.util.List;
/**
* <p>
* 公司字典表 前端控制器
* </p>
*/
@RestController
@RequestMapping("/env/hycd")
@Tag(name = "公司管理")
public class SdHycdDicController {
@Resource
private ISdHycdDicService hycdDicService;
@GetMapping("/queryPageList")
@Operation(summary = "分页查询公司列表")
public ResponseResult queryPageList(
@RequestParam(required = false) String hynm,
@RequestParam(required = false) String phycd,
@RequestParam(defaultValue = "1") Long pageNum,
@RequestParam(defaultValue = "10") Long pageSize) {
Page<SdHycdDic> page = new Page<>(pageNum, pageSize);
Page<SdHycdDic> result = hycdDicService.queryPageList(page, hynm, phycd);
return ResponseResult.successData(result);
}
@GetMapping("/list")
@Operation(summary = "查询所有公司")
public ResponseResult list() {
return ResponseResult.successData(hycdDicService.list());
}
@GetMapping("/getByPhycd")
@Operation(summary = "根据父公司编码查询公司")
public ResponseResult getByPhycd(@RequestParam(required = false) String phycd) {
List<SdHycdDic> list = hycdDicService.getByPhycd(phycd);
return ResponseResult.successData(list);
}
@GetMapping("/getRootList")
@Operation(summary = "查询根公司")
public ResponseResult getRootList() {
return ResponseResult.successData(hycdDicService.getRootList());
}
@GetMapping("/getById")
@Operation(summary = "根据编码查询公司")
public ResponseResult getById(@RequestParam String hycd) {
return ResponseResult.successData(hycdDicService.getById(hycd));
}
@Log(module = "公司管理", value = "新增公司")
@PostMapping("/add")
@Operation(summary = "新增公司")
public ResponseResult add(@RequestBody SdHycdDic hycdDic) {
boolean result = hycdDicService.addHycdDic(hycdDic);
return result ? ResponseResult.success("新增成功") : ResponseResult.error("新增失败");
}
@Log(module = "公司管理", value = "修改公司")
@PostMapping("/update")
@Operation(summary = "修改公司")
public ResponseResult update(@RequestBody SdHycdDic hycdDic) {
boolean result = hycdDicService.updateHycdDic(hycdDic);
return result ? ResponseResult.success("修改成功") : ResponseResult.error("修改失败");
}
@Log(module = "公司管理", value = "删除公司")
@PostMapping("/delete")
@Operation(summary = "删除公司")
public ResponseResult delete(@RequestParam String hycd) {
boolean result = hycdDicService.deleteHycdDic(hycd);
return result ? ResponseResult.success("删除成功") : ResponseResult.error("删除失败");
}
}

88
backend/src/main/java/com/yfd/platform/env/controller/SdHydrobaseController.java vendored Normal file
View File

@ -0,0 +1,88 @@
package com.yfd.platform.env.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.env.service.ISdHydrobaseService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.*;
import jakarta.annotation.Resource;
import java.util.List;
/**
* <p>
* 水电基地字典表 前端控制器
* </p>
*/
@RestController
@RequestMapping("/env/hydrobase")
@Tag(name = "基地管理")
public class SdHydrobaseController {
@Resource
private ISdHydrobaseService hydrobaseService;
@GetMapping("/queryPageList")
@Operation(summary = "分页查询基地列表")
public ResponseResult queryPageList(
@RequestParam(required = false) String basename,
@RequestParam(required = false) String pbaseid,
@RequestParam(defaultValue = "1") Long pageNum,
@RequestParam(defaultValue = "10") Long pageSize) {
Page<SdHydrobase> page = new Page<>(pageNum, pageSize);
Page<SdHydrobase> result = hydrobaseService.queryPageList(page, basename, pbaseid);
return ResponseResult.successData(result);
}
@GetMapping("/list")
@Operation(summary = "查询所有基地")
public ResponseResult list() {
return ResponseResult.successData(hydrobaseService.list());
}
@GetMapping("/getByPbaseid")
@Operation(summary = "根据父基地编码查询基地")
public ResponseResult getByPbaseid(@RequestParam(required = false) String pbaseid) {
List<SdHydrobase> list = hydrobaseService.getByPbaseid(pbaseid);
return ResponseResult.successData(list);
}
@GetMapping("/getRootList")
@Operation(summary = "查询根基地")
public ResponseResult getRootList() {
return ResponseResult.successData(hydrobaseService.getRootList());
}
@GetMapping("/getById")
@Operation(summary = "根据编码查询基地")
public ResponseResult getById(@RequestParam String baseid) {
return ResponseResult.successData(hydrobaseService.getById(baseid));
}
// @Log(module = "基地管理", value = "新增基地")
@PostMapping("/add")
@Operation(summary = "新增基地")
public ResponseResult add(@RequestBody SdHydrobase hydrobase) {
boolean result = hydrobaseService.addHydrobase(hydrobase);
return result ? ResponseResult.success("新增成功") : ResponseResult.error("新增失败");
}
@Log(module = "基地管理", value = "修改基地")
@PostMapping("/update")
@Operation(summary = "修改基地")
public ResponseResult update(@RequestBody SdHydrobase hydrobase) {
boolean result = hydrobaseService.updateHydrobase(hydrobase);
return result ? ResponseResult.success("修改成功") : ResponseResult.error("修改失败");
}
@Log(module = "基地管理", value = "删除基地")
@PostMapping("/delete")
@Operation(summary = "删除基地")
public ResponseResult delete(@RequestParam String baseid) {
boolean result = hydrobaseService.deleteHydrobase(baseid);
return result ? ResponseResult.success("删除成功") : ResponseResult.error("删除失败");
}
}

88
backend/src/main/java/com/yfd/platform/env/controller/SdRvcdDicController.java vendored Normal file
View File

@ -0,0 +1,88 @@
package com.yfd.platform.env.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdRvcdDic;
import com.yfd.platform.env.service.ISdRvcdDicService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.*;
import jakarta.annotation.Resource;
import java.util.List;
/**
* <p>
* 流域字典表 前端控制器
* </p>
*/
@RestController
@RequestMapping("/env/rvcd")
@Tag(name = "流域管理")
public class SdRvcdDicController {
@Resource
private ISdRvcdDicService rvcdDicService;
@GetMapping("/queryPageList")
@Operation(summary = "分页查询流域列表")
public ResponseResult queryPageList(
@RequestParam(required = false) String rvnm,
@RequestParam(required = false) String prvcd,
@RequestParam(defaultValue = "1") Long pageNum,
@RequestParam(defaultValue = "10") Long pageSize) {
Page<SdRvcdDic> page = new Page<>(pageNum, pageSize);
Page<SdRvcdDic> result = rvcdDicService.queryPageList(page, rvnm, prvcd);
return ResponseResult.successData(result);
}
@GetMapping("/list")
@Operation(summary = "查询所有流域")
public ResponseResult list() {
return ResponseResult.successData(rvcdDicService.list());
}
@GetMapping("/getByPrvcd")
@Operation(summary = "根据父编码查询流域")
public ResponseResult getByPrvcd(@RequestParam(required = false) String prvcd) {
List<SdRvcdDic> list = rvcdDicService.getByPrvcd(prvcd);
return ResponseResult.successData(list);
}
@GetMapping("/getRootList")
@Operation(summary = "查询根流域")
public ResponseResult getRootList() {
return ResponseResult.successData(rvcdDicService.getRootList());
}
@GetMapping("/getById")
@Operation(summary = "根据编码查询流域")
public ResponseResult getById(@RequestParam String rvcd) {
return ResponseResult.successData(rvcdDicService.getById(rvcd));
}
// @Log(module = "流域管理", value = "新增流域")
@PostMapping("/add")
@Operation(summary = "新增流域")
public ResponseResult add(@RequestBody SdRvcdDic rvcdDic) {
boolean result = rvcdDicService.addRvcdDic(rvcdDic);
return result ? ResponseResult.success("新增成功") : ResponseResult.error("新增失败");
}
// @Log(module = "流域管理", value = "修改流域")
@PostMapping("/update")
@Operation(summary = "修改流域")
public ResponseResult update(@RequestBody SdRvcdDic rvcdDic) {
boolean result = rvcdDicService.updateRvcdDic(rvcdDic);
return result ? ResponseResult.success("修改成功") : ResponseResult.error("修改失败");
}
@Log(module = "流域管理", value = "删除流域")
@PostMapping("/delete")
@Operation(summary = "删除流域")
public ResponseResult delete(@RequestParam String rvcd) {
boolean result = rvcdDicService.deleteRvcdDic(rvcd);
return result ? ResponseResult.success("删除成功") : ResponseResult.error("删除失败");
}
}

63
backend/src/main/java/com/yfd/platform/env/controller/TreeStructureController.java vendored Normal file
View File

@ -0,0 +1,63 @@
package com.yfd.platform.env.controller;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.service.ITreeStructureService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import jakarta.annotation.Resource;
import java.util.List;
import java.util.Map;
/**
* <p>
* 树形结构 前端控制器
* </p>
*/
@RestController
@RequestMapping("/env/tree")
@Tag(name = "树形结构")
public class TreeStructureController {
@Resource
private ITreeStructureService treeStructureService;
@GetMapping("/rvcdBaseEng")
@Operation(summary = "获取流域-基地-电站树形结构")
public ResponseResult getRvcdBaseEngTree(@RequestParam(required = false) String rvcd) {
List<Map<String, Object>> result = treeStructureService.getRvcdBaseEngTree(rvcd);
return ResponseResult.successData(result);
}
@GetMapping("/rvcdCompanyEng")
@Operation(summary = "获取流域-公司-电站树形结构")
public ResponseResult getRvcdCompanyEngTree(@RequestParam(required = false) String rvcd) {
List<Map<String, Object>> result = treeStructureService.getRvcdCompanyEngTree(rvcd);
return ResponseResult.successData(result);
}
@GetMapping("/rvcd")
@Operation(summary = "获取流域树")
public ResponseResult getRvcdTree(@RequestParam(required = false) String prvcd) {
List<Map<String, Object>> result = treeStructureService.getRvcdTree(prvcd);
return ResponseResult.successData(result);
}
@GetMapping("/hydrobase")
@Operation(summary = "获取基地树")
public ResponseResult getHydrobaseTree(@RequestParam(required = false) String pbaseid) {
List<Map<String, Object>> result = treeStructureService.getHydrobaseTree(pbaseid);
return ResponseResult.successData(result);
}
@GetMapping("/hycd")
@Operation(summary = "获取公司树")
public ResponseResult getHycdTree(@RequestParam(required = false) String phycd) {
List<Map<String, Object>> result = treeStructureService.getHycdTree(phycd);
return ResponseResult.successData(result);
}
}

71
backend/src/main/java/com/yfd/platform/env/domain/SdCountryB.java vendored Normal file
View File

@ -0,0 +1,71 @@
package com.yfd.platform.env.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
/**
* <p>
* 国家信息表
* </p>
*/
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("SD_COUNTRY_B")
public class SdCountryB implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@TableId(type = IdType.INPUT)
private String no;
/**
* 国家ID
*/
private String countryId;
/**
* 国家名
*/
private String countryName;
/**
* 国家名（英文）
*/
private String countryNameEn;
/**
* 洲分类
*/
private String continentType;
/**
* 洲分类（英文）
*/
private String continentTypeEn;
/**
* 固定 0=固定 1=不固定
*/
private Integer fixed;
/**
* 排序，建议业务规则"升序排序"
*/
private Integer orderIndex;
/**
* 是否启用 0=禁用 1=启用
*/
private Integer enabled;
/**
* 简称
*/
private String shortname;
}

1181
backend/src/main/java/com/yfd/platform/env/domain/SdEngInfoBH.java vendored Normal file
View File

File diff suppressed because it is too large Load Diff

86
backend/src/main/java/com/yfd/platform/env/domain/SdHycdDic.java vendored Normal file
View File

@ -0,0 +1,86 @@
package com.yfd.platform.env.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
/**
* <p>
* 公司字典表
* </p>
*/
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("SD_HYCD_DIC")
public class SdHycdDic implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 公司编码
*/
@TableId(type = IdType.INPUT)
private String hycd;
/**
* 公司名称
*/
private String hynm;
/**
* 所属公司编码，根节点为0
*/
private String phycd;
/**
* 树级别，从1开始
*/
private Integer grd;
/**
* 树全路径，中间以逗号分隔
*/
private String path;
/**
* 排序，建议业务规则"升序排序"
*/
private Integer orderIndex;
/**
* 中心经度
*/
private String lgtd;
/**
* 中心纬度
*/
private String lttd;
/**
* 所属国家，关联SD_COUNTRY_B.COUNTRY_ID
*/
private String country;
/**
* 公司Logo
*/
private String logo;
/**
* 简介
*/
private String des;
/**
* 介绍图片
*/
private String inffile;
/**
* 简称
*/
private String shortname;
}

66
backend/src/main/java/com/yfd/platform/env/domain/SdHydrobase.java vendored Normal file
View File

@ -0,0 +1,66 @@
package com.yfd.platform.env.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
/**
* <p>
* 水电基地字典表
* </p>
*/
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("SD_HYDROBASE")
public class SdHydrobase implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 基地编码
*/
@TableId(type = IdType.INPUT)
private String baseid;
/**
* 基地名称
*/
private String basename;
/**
* 所属父级基地编码，根节点为0
*/
private String pbaseid;
/**
* 树级别，从1开始
*/
private Integer grd;
/**
* 树全路径，中间以逗号分隔
*/
private String path;
/**
* 排序，建议业务规则"升序排序"
*/
private Integer orderIndex;
/**
* 备注
*/
private String rmk;
/**
* 简介
*/
private String des;
/**
* 简称
*/
private String shortname;
}

51
backend/src/main/java/com/yfd/platform/env/domain/SdPraddRltnB.java vendored Normal file
View File

@ -0,0 +1,51 @@
package com.yfd.platform.env.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.util.Date;
/**
* <p>
* 水电水利工程与行政区对应关系表
* </p>
*/
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("SD_PRADDRLTN_B")
public class SdPraddRltnB implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 水电水利工程编码：关联SD_ENGINFO_B_H.STCD
*/
private String stcd;
/**
* 所属行政区编码：关联SD_ADDVCD_DIC.ADDVCD
*/
private String addvcd;
/**
* 数据时间
*/
private Date tm;
/**
* 数据来源
*/
private String vlsr;
/**
* 所属建设阶段
*/
private Integer blprd;
/**
* 占比
*/
private Double rc;
}

46
backend/src/main/java/com/yfd/platform/env/domain/SdPrhbrltnB.java vendored Normal file
View File

@ -0,0 +1,46 @@
package com.yfd.platform.env.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.util.Date;
/**
* <p>
* 水电水利工程与电站基地关系表
* </p>
*/
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("SD_PRHBRLTN_B")
public class SdPrhbrltnB implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 水电水利工程编码：关联SD_ENGINFO_B_H.STCD
*/
private String stcd;
/**
* 所属基地编码：关联SD_HYDROBASE.BASEID
*/
private String baseid;
/**
* 数据时间
*/
private Date tm;
/**
* 数据来源
*/
private String vlsr;
/**
* 所属建设阶段：关联SD_ENGINFO_B_H.BLPRD
*/
private Integer blprd;
}

51
backend/src/main/java/com/yfd/platform/env/domain/SdPrhyrltnB.java vendored Normal file
View File

@ -0,0 +1,51 @@
package com.yfd.platform.env.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.util.Date;
/**
* <p>
* 水电水利工程与公司对应关系表
* </p>
*/
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("SD_PRHYRLTN_B")
public class SdPrhyrltnB implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 水电水利工程编码：关联SD_ENGINFO_B_H.STCD
*/
private String stcd;
/**
* 所属公司编码：关联SD_HYCD_DIC.HYCD
*/
private String hycd;
/**
* 数据时间
*/
private Date tm;
/**
* 数据来源
*/
private String vlsr;
/**
* 所属建设阶段：关联SD_ENGINFO_B_H.BLPRD
*/
private Integer blprd;
/**
* 该公司装机容量占比：工程在该公司的装机容量占总装机容量比例
*/
private Double rc;
}

117
backend/src/main/java/com/yfd/platform/env/domain/SdRvcdDic.java vendored Normal file
View File

@ -0,0 +1,117 @@
package com.yfd.platform.env.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.util.Date;
/**
* <p>
* 流域字典表
* </p>
*/
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("SD_RVCD_DIC")
public class SdRvcdDic implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 流域编码
*/
@TableId(type = IdType.INPUT)
private String rvcd;
/**
* 流域名称
*/
private String rvnm;
/**
* 父流域编码，根节点为空
*/
private String prvcd;
/**
* 树级别，从1开始 1=流域 2=水系 3=河流
*/
private Integer grd;
/**
* 树全路径，流域,水系,河流，中间以逗号分隔
*/
private String path;
/**
* 排序，建议业务规则"升序排序"
*/
private Integer orderIndex;
/**
* 经度
*/
private Double lgtd;
/**
* 纬度
*/
private Double lttd;
/**
* 面积
*/
private Double area;
/**
* 周长
*/
private Double perimeter;
/**
* 所属国家，关联SD_COUNTRY_B.COUNTRY_ID
*/
private String country;
/**
* 简介
*/
private String introduce;
/**
* 介绍图片
*/
private String inffile;
/**
* 简称
*/
private String shortname;
/**
* 气象预报 0=不支持 1=支持
*/
private Integer weatherForecast;
/**
* 气象反演 0=不支持 1=支持
*/
private Integer weatherInversion;
/**
* 范围
*/
private String sheprange;
/**
* 水电基地编码
*/
private String baseid;
/**
* 地图专题流域标识：1=是 0否
*/
private Integer ismap;
}

12
backend/src/main/java/com/yfd/platform/env/mapper/SdCountryBMapper.java vendored Normal file
View File

@ -0,0 +1,12 @@
package com.yfd.platform.env.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdCountryB;
/**
* <p>
* 国家信息表 Mapper 接口
* </p>
*/
public interface SdCountryBMapper extends BaseMapper<SdCountryB> {
}

30
backend/src/main/java/com/yfd/platform/env/mapper/SdEngInfoBHMapper.java vendored Normal file
View File

@ -0,0 +1,30 @@
package com.yfd.platform.env.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdEngInfoBH;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* <p>
* 水电水利工程基础信息表 Mapper 接口
* </p>
*/
public interface SdEngInfoBHMapper extends BaseMapper<SdEngInfoBH> {
/**
* 根据基地编码查询电站列表
*/
List<SdEngInfoBH> selectByBaseId(@Param("baseId") String baseId);
/**
* 根据公司编码查询电站列表
*/
List<SdEngInfoBH> selectByHycd(@Param("hycd") String hycd);
/**
* 根据流域编码查询电站列表（通过关联关系）
*/
List<SdEngInfoBH> selectByRvcd(@Param("rvcd") String rvcd);
}

25
backend/src/main/java/com/yfd/platform/env/mapper/SdHycdDicMapper.java vendored Normal file
View File

@ -0,0 +1,25 @@
package com.yfd.platform.env.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdHycdDic;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* <p>
* 公司字典表 Mapper 接口
* </p>
*/
public interface SdHycdDicMapper extends BaseMapper<SdHycdDic> {
/**
* 根据父公司编码查询公司列表
*/
List<SdHycdDic> selectByPhycd(@Param("phycd") String phycd);
/**
* 查询所有根公司
*/
List<SdHycdDic> selectRootList();
}

25
backend/src/main/java/com/yfd/platform/env/mapper/SdHydrobaseMapper.java vendored Normal file
View File

@ -0,0 +1,25 @@
package com.yfd.platform.env.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdHydrobase;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* <p>
* 水电基地字典表 Mapper 接口
* </p>
*/
public interface SdHydrobaseMapper extends BaseMapper<SdHydrobase> {
/**
* 根据父基地编码查询基地列表
*/
List<SdHydrobase> selectByPbaseid(@Param("pbaseid") String pbaseid);
/**
* 查询所有根基地
*/
List<SdHydrobase> selectRootList();
}

25
backend/src/main/java/com/yfd/platform/env/mapper/SdPrhbrltnBMapper.java vendored Normal file
View File

@ -0,0 +1,25 @@
package com.yfd.platform.env.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdPrhbrltnB;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* <p>
* 水电水利工程与电站基地关系表 Mapper 接口
* </p>
*/
public interface SdPrhbrltnBMapper extends BaseMapper<SdPrhbrltnB> {
/**
* 根据基地编码查询关联的电站编码列表
*/
List<String> selectStcdListByBaseId(@Param("baseid") String baseid);
/**
* 根据电站编码查询关联的基地编码
*/
List<String> selectBaseIdListByStcd(@Param("stcd") String stcd);
}

25
backend/src/main/java/com/yfd/platform/env/mapper/SdPrhyrltnBMapper.java vendored Normal file
View File

@ -0,0 +1,25 @@
package com.yfd.platform.env.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdPrhyrltnB;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* <p>
* 水电水利工程与公司对应关系表 Mapper 接口
* </p>
*/
public interface SdPrhyrltnBMapper extends BaseMapper<SdPrhyrltnB> {
/**
* 根据公司编码查询关联的电站编码列表
*/
List<String> selectStcdListByHycd(@Param("hycd") String hycd);
/**
* 根据电站编码查询关联的公司编码
*/
List<String> selectHycdListByStcd(@Param("stcd") String stcd);
}

25
backend/src/main/java/com/yfd/platform/env/mapper/SdRvcdDicMapper.java vendored Normal file
View File

@ -0,0 +1,25 @@
package com.yfd.platform.env.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdRvcdDic;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* <p>
* 流域字典表 Mapper 接口
* </p>
*/
public interface SdRvcdDicMapper extends BaseMapper<SdRvcdDic> {
/**
* 根据父编码查询流域列表
*/
List<SdRvcdDic> selectByPrvcd(@Param("prvcd") String prvcd);
/**
* 查询所有根流域
*/
List<SdRvcdDic> selectRootList();
}

25
backend/src/main/java/com/yfd/platform/env/service/ISdCountryBService.java vendored Normal file
View File

@ -0,0 +1,25 @@
package com.yfd.platform.env.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdCountryB;
import java.util.List;
/**
* <p>
* 国家信息表 服务类
* </p>
*/
public interface ISdCountryBService extends IService<SdCountryB> {
/**
* 分页查询国家列表
*/
Page<SdCountryB> queryPageList(Page<SdCountryB> page, String countryName, String continentType);
/**
* 获取所有启用的国家
*/
List<SdCountryB> getEnabledList();
}

50
backend/src/main/java/com/yfd/platform/env/service/ISdEngInfoBHService.java vendored Normal file
View File

@ -0,0 +1,50 @@
package com.yfd.platform.env.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdEngInfoBH;
import java.util.List;
/**
* <p>
* 水电水利工程基础信息表 服务类
* </p>
*/
public interface ISdEngInfoBHService extends IService<SdEngInfoBH> {
/**
* 分页查询电站列表
*/
Page<SdEngInfoBH> queryPageList(Page<SdEngInfoBH> page, String ennm, String rvcd, String baseId, String hycd);
/**
* 根据基地编码查询电站
*/
List<SdEngInfoBH> getByBaseId(String baseId);
/**
* 根据公司编码查询电站
*/
List<SdEngInfoBH> getByHycd(String hycd);
/**
* 根据流域编码查询电站
*/
List<SdEngInfoBH> getByRvcd(String rvcd);
/**
* 新增电站
*/
boolean addEngInfo(SdEngInfoBH engInfo);
/**
* 修改电站
*/
boolean updateEngInfo(SdEngInfoBH engInfo);
/**
* 删除电站
*/
boolean deleteEngInfo(String stcd);
}

45
backend/src/main/java/com/yfd/platform/env/service/ISdHycdDicService.java vendored Normal file
View File

@ -0,0 +1,45 @@
package com.yfd.platform.env.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdHycdDic;
import java.util.List;
/**
* <p>
* 公司字典表 服务类
* </p>
*/
public interface ISdHycdDicService extends IService<SdHycdDic> {
/**
* 分页查询公司列表
*/
Page<SdHycdDic> queryPageList(Page<SdHycdDic> page, String hynm, String phycd);
/**
* 根据父公司编码查询公司列表
*/
List<SdHycdDic> getByPhycd(String phycd);
/**
* 查询所有根公司
*/
List<SdHycdDic> getRootList();
/**
* 新增公司
*/
boolean addHycdDic(SdHycdDic hycdDic);
/**
* 修改公司
*/
boolean updateHycdDic(SdHycdDic hycdDic);
/**
* 删除公司
*/
boolean deleteHycdDic(String hycd);
}

45
backend/src/main/java/com/yfd/platform/env/service/ISdHydrobaseService.java vendored Normal file
View File

@ -0,0 +1,45 @@
package com.yfd.platform.env.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdHydrobase;
import java.util.List;
/**
* <p>
* 水电基地字典表 服务类
* </p>
*/
public interface ISdHydrobaseService extends IService<SdHydrobase> {
/**
* 分页查询基地列表
*/
Page<SdHydrobase> queryPageList(Page<SdHydrobase> page, String basename, String pbaseid);
/**
* 根据父基地编码查询基地列表
*/
List<SdHydrobase> getByPbaseid(String pbaseid);
/**
* 查询所有根基地
*/
List<SdHydrobase> getRootList();
/**
* 新增基地
*/
boolean addHydrobase(SdHydrobase hydrobase);
/**
* 修改基地
*/
boolean updateHydrobase(SdHydrobase hydrobase);
/**
* 删除基地
*/
boolean deleteHydrobase(String baseid);
}

45
backend/src/main/java/com/yfd/platform/env/service/ISdRvcdDicService.java vendored Normal file
View File

@ -0,0 +1,45 @@
package com.yfd.platform.env.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdRvcdDic;
import java.util.List;
/**
* <p>
* 流域字典表 服务类
* </p>
*/
public interface ISdRvcdDicService extends IService<SdRvcdDic> {
/**
* 分页查询流域列表
*/
Page<SdRvcdDic> queryPageList(Page<SdRvcdDic> page, String rvnm, String prvcd);
/**
* 根据父编码查询流域列表
*/
List<SdRvcdDic> getByPrvcd(String prvcd);
/**
* 查询所有根流域
*/
List<SdRvcdDic> getRootList();
/**
* 新增流域
*/
boolean addRvcdDic(SdRvcdDic rvcdDic);
/**
* 修改流域
*/
boolean updateRvcdDic(SdRvcdDic rvcdDic);
/**
* 删除流域
*/
boolean deleteRvcdDic(String rvcd);
}

41
backend/src/main/java/com/yfd/platform/env/service/ITreeStructureService.java vendored Normal file
View File

@ -0,0 +1,41 @@
package com.yfd.platform.env.service;
import com.yfd.platform.env.domain.SdEngInfoBH;
import java.util.List;
import java.util.Map;
/**
* <p>
* 树形结构服务类
* </p>
*/
public interface ITreeStructureService {
/**
* 获取流域-基地-电站树形结构
* @param rvcd 流域编码（可选，为空则返回全部）
*/
List<Map<String, Object>> getRvcdBaseEngTree(String rvcd);
/**
* 获取流域-公司-电站树形结构
* @param rvcd 流域编码（可选，为空则返回全部）
*/
List<Map<String, Object>> getRvcdCompanyEngTree(String rvcd);
/**
* 获取流域树（带子节点标记）
*/
List<Map<String, Object>> getRvcdTree(String prvcd);
/**
* 获取基地树（带子节点标记）
*/
List<Map<String, Object>> getHydrobaseTree(String pbaseid);
/**
* 获取公司树（带子节点标记）
*/
List<Map<String, Object>> getHycdTree(String phycd);
}

36
backend/src/main/java/com/yfd/platform/env/service/impl/SdCountryBServiceImpl.java vendored Normal file
View File

@ -0,0 +1,36 @@
package com.yfd.platform.env.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.env.domain.SdCountryB;
import com.yfd.platform.env.mapper.SdCountryBMapper;
import com.yfd.platform.env.service.ISdCountryBService;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* <p>
* 国家信息表 服务实现类
* </p>
*/
@Service
public class SdCountryBServiceImpl extends ServiceImpl<SdCountryBMapper, SdCountryB> implements ISdCountryBService {
@Override
public Page<SdCountryB> queryPageList(Page<SdCountryB> page, String countryName, String continentType) {
return this.page(page, this.lambdaQuery()
.like(countryName != null && !countryName.isEmpty(), SdCountryB::getCountryName, countryName)
.eq(continentType != null && !continentType.isEmpty(), SdCountryB::getContinentType, continentType)
.orderByAsc(SdCountryB::getOrderIndex)
.getWrapper());
}
@Override
public List<SdCountryB> getEnabledList() {
return this.lambdaQuery()
.eq(SdCountryB::getEnabled, 1)
.orderByAsc(SdCountryB::getOrderIndex)
.list();
}
}

65
backend/src/main/java/com/yfd/platform/env/service/impl/SdEngInfoBHServiceImpl.java vendored Normal file
View File

@ -0,0 +1,65 @@
package com.yfd.platform.env.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.mapper.SdEngInfoBHMapper;
import com.yfd.platform.env.service.ISdEngInfoBHService;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* <p>
* 水电水利工程基础信息表 服务实现类
* </p>
*/
@Service
public class SdEngInfoBHServiceImpl extends ServiceImpl<SdEngInfoBHMapper, SdEngInfoBH> implements ISdEngInfoBHService {
@Resource
private SdEngInfoBHMapper engInfoBHMapper;
@Override
public Page<SdEngInfoBH> queryPageList(Page<SdEngInfoBH> page, String ennm, String rvcd, String baseId, String hycd) {
return this.page(page, this.lambdaQuery()
.like(ennm != null && !ennm.isEmpty(), SdEngInfoBH::getEnnm, ennm)
.eq(rvcd != null && !rvcd.isEmpty(), SdEngInfoBH::getRvcd, rvcd)
.eq(baseId != null && !baseId.isEmpty(), SdEngInfoBH::getBaseId, baseId)
.eq(hycd != null && !hycd.isEmpty(), SdEngInfoBH::getHycd, hycd)
.orderByAsc(SdEngInfoBH::getOrderIndex)
.getWrapper());
}
@Override
public List<SdEngInfoBH> getByBaseId(String baseId) {
return engInfoBHMapper.selectByBaseId(baseId);
}
@Override
public List<SdEngInfoBH> getByHycd(String hycd) {
return engInfoBHMapper.selectByHycd(hycd);
}
@Override
public List<SdEngInfoBH> getByRvcd(String rvcd) {
return engInfoBHMapper.selectByRvcd(rvcd);
}
@Override
public boolean addEngInfo(SdEngInfoBH engInfo) {
return this.save(engInfo);
}
@Override
public boolean updateEngInfo(SdEngInfoBH engInfo) {
return this.updateById(engInfo);
}
@Override
public boolean deleteEngInfo(String stcd) {
return this.removeById(stcd);
}
}

59
backend/src/main/java/com/yfd/platform/env/service/impl/SdHycdDicServiceImpl.java vendored Normal file
View File

@ -0,0 +1,59 @@
package com.yfd.platform.env.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.env.domain.SdHycdDic;
import com.yfd.platform.env.mapper.SdHycdDicMapper;
import com.yfd.platform.env.service.ISdHycdDicService;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* <p>
* 公司字典表 服务实现类
* </p>
*/
@Service
public class SdHycdDicServiceImpl extends ServiceImpl<SdHycdDicMapper, SdHycdDic> implements ISdHycdDicService {
@Override
public Page<SdHycdDic> queryPageList(Page<SdHycdDic> page, String hynm, String phycd) {
return this.page(page, this.lambdaQuery()
.like(hynm != null && !hynm.isEmpty(), SdHycdDic::getHynm, hynm)
.eq(phycd != null && !phycd.isEmpty(), SdHycdDic::getPhycd, phycd)
.orderByAsc(SdHycdDic::getOrderIndex)
.getWrapper());
}
@Override
public List<SdHycdDic> getByPhycd(String phycd) {
return this.lambdaQuery()
.eq(SdHycdDic::getPhycd, phycd)
.orderByAsc(SdHycdDic::getOrderIndex)
.list();
}
@Override
public List<SdHycdDic> getRootList() {
return this.lambdaQuery()
.eq(SdHycdDic::getPhycd, "0")
.orderByAsc(SdHycdDic::getOrderIndex)
.list();
}
@Override
public boolean addHycdDic(SdHycdDic hycdDic) {
return this.save(hycdDic);
}
@Override
public boolean updateHycdDic(SdHycdDic hycdDic) {
return this.updateById(hycdDic);
}
@Override
public boolean deleteHycdDic(String hycd) {
return this.removeById(hycd);
}
}

59
backend/src/main/java/com/yfd/platform/env/service/impl/SdHydrobaseServiceImpl.java vendored Normal file
View File

@ -0,0 +1,59 @@
package com.yfd.platform.env.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.env.mapper.SdHydrobaseMapper;
import com.yfd.platform.env.service.ISdHydrobaseService;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* <p>
* 水电基地字典表 服务实现类
* </p>
*/
@Service
public class SdHydrobaseServiceImpl extends ServiceImpl<SdHydrobaseMapper, SdHydrobase> implements ISdHydrobaseService {
@Override
public Page<SdHydrobase> queryPageList(Page<SdHydrobase> page, String basename, String pbaseid) {
return this.page(page, this.lambdaQuery()
.like(basename != null && !basename.isEmpty(), SdHydrobase::getBasename, basename)
.eq(pbaseid != null && !pbaseid.isEmpty(), SdHydrobase::getPbaseid, pbaseid)
.orderByAsc(SdHydrobase::getOrderIndex)
.getWrapper());
}
@Override
public List<SdHydrobase> getByPbaseid(String pbaseid) {
return this.lambdaQuery()
.eq(SdHydrobase::getPbaseid, pbaseid)
.orderByAsc(SdHydrobase::getOrderIndex)
.list();
}
@Override
public List<SdHydrobase> getRootList() {
return this.lambdaQuery()
.eq(SdHydrobase::getPbaseid, "0")
.orderByAsc(SdHydrobase::getOrderIndex)
.list();
}
@Override
public boolean addHydrobase(SdHydrobase hydrobase) {
return this.save(hydrobase);
}
@Override
public boolean updateHydrobase(SdHydrobase hydrobase) {
return this.updateById(hydrobase);
}
@Override
public boolean deleteHydrobase(String baseid) {
return this.removeById(baseid);
}
}

61
backend/src/main/java/com/yfd/platform/env/service/impl/SdRvcdDicServiceImpl.java vendored Normal file
View File

@ -0,0 +1,61 @@
package com.yfd.platform.env.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.env.domain.SdRvcdDic;
import com.yfd.platform.env.mapper.SdRvcdDicMapper;
import com.yfd.platform.env.service.ISdRvcdDicService;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* <p>
* 流域字典表 服务实现类
* </p>
*/
@Service
public class SdRvcdDicServiceImpl extends ServiceImpl<SdRvcdDicMapper, SdRvcdDic> implements ISdRvcdDicService {
@Override
public Page<SdRvcdDic> queryPageList(Page<SdRvcdDic> page, String rvnm, String prvcd) {
return this.page(page, this.lambdaQuery()
.like(rvnm != null && !rvnm.isEmpty(), SdRvcdDic::getRvnm, rvnm)
.eq(prvcd != null && !prvcd.isEmpty(), SdRvcdDic::getPrvcd, prvcd)
.orderByAsc(SdRvcdDic::getOrderIndex)
.getWrapper());
}
@Override
public List<SdRvcdDic> getByPrvcd(String prvcd) {
return this.lambdaQuery()
.eq(SdRvcdDic::getPrvcd, prvcd)
.orderByAsc(SdRvcdDic::getOrderIndex)
.list();
}
@Override
public List<SdRvcdDic> getRootList() {
return this.lambdaQuery()
.isNull(SdRvcdDic::getPrvcd)
.or()
.eq(SdRvcdDic::getPrvcd, "")
.orderByAsc(SdRvcdDic::getOrderIndex)
.list();
}
@Override
public boolean addRvcdDic(SdRvcdDic rvcdDic) {
return this.save(rvcdDic);
}
@Override
public boolean updateRvcdDic(SdRvcdDic rvcdDic) {
return this.updateById(rvcdDic);
}
@Override
public boolean deleteRvcdDic(String rvcd) {
return this.removeById(rvcd);
}
}

267
backend/src/main/java/com/yfd/platform/env/service/impl/TreeStructureServiceImpl.java vendored Normal file
View File

@ -0,0 +1,267 @@
package com.yfd.platform.env.service.impl;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.env.domain.SdHycdDic;
import com.yfd.platform.env.domain.SdPrhbrltnB;
import com.yfd.platform.env.domain.SdPrhyrltnB;
import com.yfd.platform.env.domain.SdRvcdDic;
import com.yfd.platform.env.mapper.*;
import com.yfd.platform.env.service.ITreeStructureService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.*;
import java.util.stream.Collectors;
/**
* <p>
* 树形结构服务实现类
* </p>
*/
@Service
public class TreeStructureServiceImpl implements ITreeStructureService {
@Autowired
private SdRvcdDicMapper rvcdDicMapper;
@Autowired
private SdHydrobaseMapper hydrobaseMapper;
@Autowired
private SdHycdDicMapper hycdDicMapper;
@Autowired
private SdEngInfoBHMapper engInfoBHMapper;
@Autowired
private SdPrhbrltnBMapper prhbrltnBMapper;
@Autowired
private SdPrhyrltnBMapper prhyrltnBMapper;
@Override
public List<Map<String, Object>> getRvcdBaseEngTree(String rvcd) {
List<Map<String, Object>> result = new ArrayList<>();
List<SdRvcdDic> rvcdList;
if (StringUtils.hasText(rvcd)) {
rvcdList = rvcdDicMapper.selectByPrvcd(rvcd);
SdRvcdDic singleRvcd = rvcdDicMapper.selectById(rvcd);
if (singleRvcd != null && !rvcdList.contains(singleRvcd)) {
rvcdList = new ArrayList<>();
rvcdList.add(singleRvcd);
}
} else {
rvcdList = rvcdDicMapper.selectRootList();
}
Map<String, List<SdEngInfoBH>> rvcdEngMap = new HashMap<>();
for (SdRvcdDic rvcdDic : rvcdList) {
List<SdEngInfoBH> engList = engInfoBHMapper.selectByRvcd(rvcdDic.getRvcd());
if (engList != null && !engList.isEmpty()) {
rvcdEngMap.put(rvcdDic.getRvcd(), engList);
}
}
for (SdRvcdDic rvcdDic : rvcdList) {
Map<String, Object> rvcdNode = new LinkedHashMap<>();
rvcdNode.put("type", "RVCD");
rvcdNode.put("code", rvcdDic.getRvcd());
rvcdNode.put("name", rvcdDic.getRvnm());
rvcdNode.put("path", rvcdDic.getPath());
rvcdNode.put("grd", rvcdDic.getGrd());
rvcdNode.put("lgtd", rvcdDic.getLgtd());
rvcdNode.put("lttd", rvcdDic.getLttd());
List<Map<String, Object>> baseChildren = new ArrayList<>();
List<SdEngInfoBH> engList = rvcdEngMap.get(rvcdDic.getRvcd());
if (engList != null && !engList.isEmpty()) {
Map<String, List<SdEngInfoBH>> baseEngMap = engList.stream()
.filter(eng -> StringUtils.hasText(eng.getBaseId()))
.collect(Collectors.groupingBy(SdEngInfoBH::getBaseId));
for (Map.Entry<String, List<SdEngInfoBH>> entry : baseEngMap.entrySet()) {
String baseId = entry.getKey();
List<SdEngInfoBH> baseEngList = entry.getValue();
SdHydrobase base = hydrobaseMapper.selectById(baseId);
if (base == null) {
base = new SdHydrobase();
base.setBaseid(baseId);
base.setBasename("未分配基地");
base.setShortname("未分配");
}
Map<String, Object> baseNode = new LinkedHashMap<>();
baseNode.put("type", "BASE");
baseNode.put("code", base.getBaseid());
baseNode.put("name", base.getBasename());
baseNode.put("shortname", base.getShortname());
baseNode.put("grd", base.getGrd());
List<Map<String, Object>> engChildren = new ArrayList<>();
for (SdEngInfoBH eng : baseEngList) {
Map<String, Object> engNode = new LinkedHashMap<>();
engNode.put("type", "ENG");
engNode.put("code", eng.getStcd());
engNode.put("name", eng.getEnnm());
engNode.put("lgtd", eng.getLgtd());
engNode.put("lttd", eng.getLttd());
engNode.put("elev", eng.getElev());
engNode.put("usfl", eng.getUsfl());
engNode.put("bldstt", eng.getBldstt());
engNode.put("engtp", eng.getEngtp());
engChildren.add(engNode);
}
baseNode.put("children", engChildren);
baseChildren.add(baseNode);
}
}
rvcdNode.put("children", baseChildren);
result.add(rvcdNode);
}
return result;
}
@Override
public List<Map<String, Object>> getRvcdCompanyEngTree(String rvcd) {
List<Map<String, Object>> result = new ArrayList<>();
List<SdRvcdDic> rvcdList;
if (StringUtils.hasText(rvcd)) {
rvcdList = rvcdDicMapper.selectByPrvcd(rvcd);
} else {
rvcdList = rvcdDicMapper.selectRootList();
}
for (SdRvcdDic rvcdDic : rvcdList) {
Map<String, Object> rvcdNode = new LinkedHashMap<>();
rvcdNode.put("type", "RVCD");
rvcdNode.put("code", rvcdDic.getRvcd());
rvcdNode.put("name", rvcdDic.getRvnm());
rvcdNode.put("path", rvcdDic.getPath());
rvcdNode.put("grd", rvcdDic.getGrd());
List<SdHycdDic> companyList = hycdDicMapper.selectRootList();
List<Map<String, Object>> companyChildren = new ArrayList<>();
for (SdHycdDic company : companyList) {
Map<String, Object> companyNode = new LinkedHashMap<>();
companyNode.put("type", "COMPANY");
companyNode.put("code", company.getHycd());
companyNode.put("name", company.getHynm());
companyNode.put("shortname", company.getShortname());
List<String> stcdList = prhyrltnBMapper.selectStcdListByHycd(company.getHycd());
List<Map<String, Object>> engChildren = new ArrayList<>();
for (String stcd : stcdList) {
SdEngInfoBH eng = engInfoBHMapper.selectById(stcd);
if (eng != null) {
Map<String, Object> engNode = new LinkedHashMap<>();
engNode.put("type", "ENG");
engNode.put("code", eng.getStcd());
engNode.put("name", eng.getEnnm());
engNode.put("lgtd", eng.getLgtd());
engNode.put("lttd", eng.getLttd());
engChildren.add(engNode);
}
}
companyNode.put("children", engChildren);
companyChildren.add(companyNode);
}
rvcdNode.put("children", companyChildren);
result.add(rvcdNode);
}
return result;
}
@Override
public List<Map<String, Object>> getRvcdTree(String prvcd) {
List<Map<String, Object>> result = new ArrayList<>();
List<SdRvcdDic> rvcdList;
if (StringUtils.hasText(prvcd)) {
rvcdList = rvcdDicMapper.selectByPrvcd(prvcd);
} else {
rvcdList = rvcdDicMapper.selectRootList();
}
for (SdRvcdDic rvcd : rvcdList) {
Map<String, Object> node = new LinkedHashMap<>();
node.put("code", rvcd.getRvcd());
node.put("name", rvcd.getRvnm());
node.put("grd", rvcd.getGrd());
node.put("path", rvcd.getPath());
boolean hasChildren = !rvcdDicMapper.selectByPrvcd(rvcd.getRvcd()).isEmpty();
node.put("hasChildren", hasChildren);
result.add(node);
}
return result;
}
@Override
public List<Map<String, Object>> getHydrobaseTree(String pbaseid) {
List<Map<String, Object>> result = new ArrayList<>();
List<SdHydrobase> baseList;
if (StringUtils.hasText(pbaseid)) {
baseList = hydrobaseMapper.selectByPbaseid(pbaseid);
} else {
baseList = hydrobaseMapper.selectRootList();
}
for (SdHydrobase base : baseList) {
Map<String, Object> node = new LinkedHashMap<>();
node.put("code", base.getBaseid());
node.put("name", base.getBasename());
node.put("grd", base.getGrd());
node.put("shortname", base.getShortname());
boolean hasChildren = !hydrobaseMapper.selectByPbaseid(base.getBaseid()).isEmpty();
node.put("hasChildren", hasChildren);
result.add(node);
}
return result;
}
@Override
public List<Map<String, Object>> getHycdTree(String phycd) {
List<Map<String, Object>> result = new ArrayList<>();
List<SdHycdDic> hycdList;
if (StringUtils.hasText(phycd)) {
hycdList = hycdDicMapper.selectByPhycd(phycd);
} else {
hycdList = hycdDicMapper.selectRootList();
}
for (SdHycdDic hycd : hycdList) {
Map<String, Object> node = new LinkedHashMap<>();
node.put("code", hycd.getHycd());
node.put("name", hycd.getHynm());
node.put("grd", hycd.getGrd());
node.put("shortname", hycd.getShortname());
boolean hasChildren = !hycdDicMapper.selectByPhycd(hycd.getHycd()).isEmpty();
node.put("hasChildren", hasChildren);
result.add(node);
}
return result;
}
}

9
backend/src/main/resources/application-devtw.yml
View File

@ -19,6 +19,9 @@ spring:
username: "${DB_SLAVE_USERNAME:QGC_REFA}"
password: "${DB_SLAVE_PASSWORD:Y4M4K1oCkL8U}"
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
mvc:
pathmatch:
matching-strategy: ant_path_matcher
@ -53,9 +56,11 @@ mybatis-plus:
logic-not-delete-value: 0
logic-delete-field: isDeleted
configuration:
map-underscore-to-camel-case: true
# map-underscore-to-camel-case: true
cache-enabled: false
log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl
# log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
# 登录相关配置
login:

17
backend/src/main/resources/mapper/env/SdCountryBMapper.xml vendored Normal file
View File

@ -0,0 +1,17 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yfd.platform.env.mapper.SdCountryBMapper">
<resultMap id="BaseResultMap" type="com.yfd.platform.env.domain.SdCountryB">
<id column="NO" property="no"/>
<result column="COUNTRY_NAME" property="countryName"/>
<result column="COUNTRY_CODE" property="countryCode"/>
<result column="CONTINENT_CODE" property="continentCode"/>
<result column="CONTINENT_NAME" property="continentName"/>
<result column="CONTINENT_TYPE" property="continentType"/>
<result column="ENABLED" property="enabled"/>
<result column="ORDERINDEX" property="orderIndex"/>
</resultMap>
</mapper>

252
backend/src/main/resources/mapper/env/SdEngInfoBHMapper.xml vendored Normal file
View File

@ -0,0 +1,252 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yfd.platform.env.mapper.SdEngInfoBHMapper">
<resultMap id="BaseResultMap" type="com.yfd.platform.env.domain.SdEngInfoBH">
<id column="STCD" property="stcd"/>
<result column="TM" property="tm"/>
<result column="ENNM" property="ennm"/>
<result column="BLPRD" property="blprd"/>
<result column="LGTD" property="lgtd"/>
<result column="LTTD" property="lttd"/>
<result column="ELEV" property="elev"/>
<result column="STLC" property="stlc"/>
<result column="USFL" property="usfl"/>
<result column="DTIN" property="dtin"/>
<result column="DTINTM" property="dtinTm"/>
<result column="MONTHREPORT" property="monthReport"/>
<result column="ORDERINDEX" property="orderIndex"/>
<result column="BASE_ID" property="baseId"/>
<result column="HBRVCD" property="hbrvcd"/>
<result column="RVCD" property="rvcd"/>
<result column="ADDVCD" property="addvcd"/>
<result column="COUNTRY" property="country"/>
<result column="REACHCD" property="reachcd"/>
<result column="REACHCDNAME" property="reachcdName"/>
<result column="HYCD" property="hycd"/>
<result column="TOPHYCD" property="topHycd"/>
<result column="STDSET" property="stdsdt"/>
<result column="PSTSTDT" property="pststdt"/>
<result column="PESSTDT" property="pesstdt"/>
<result column="SWDT" property="swdt"/>
<result column="JCDT" property="jcdt"/>
<result column="WDDT" property="wddt"/>
<result column="JLDT" property="jldt"/>
<result column="INTRODUCE" property="introduce"/>
<result column="LOGO" property="logo"/>
<result column="INFFILE" property="inffile"/>
<result column="TBWAY" property="tbWay"/>
<result column="TBFREQUENCY" property="tbFrequency"/>
<result column="BLDSTT" property="bldstt"/>
<result column="BLDSTTCODE" property="bldsttCode"/>
<result column="ENGTP" property="engtp"/>
<result column="PRSC" property="prsc"/>
<result column="SCRSC" property="scrsc"/>
<result column="PRGR" property="prgr"/>
<result column="FN" property="fn"/>
<result column="BSSSIN" property="bsssin"/>
<result column="FRSSIN" property="frssin"/>
<result column="ADJUSTENG" property="adjustEng"/>
<result column="ISHVRGRG" property="ishvrgrg"/>
<result column="RGCP" property="rgcp"/>
<result column="DMAT" property="dmat"/>
<result column="DMTP" property="dmtp"/>
<result column="DVTP" property="dvtp"/>
<result column="CNTP" property="cntp"/>
<result column="MNUN" property="mnun"/>
<result column="CMUN" property="cmun"/>
<result column="BLSYS" property="blsys"/>
<result column="ROLL" property="roll"/>
<result column="PITCH" property="pitch"/>
<result column="HEADING" property="heading"/>
<result column="SCALE" property="scale"/>
<result column="IMPDSTRZ" property="impdstrz"/>
<result column="PROV" property="prov"/>
<result column="ESTRYDIS" property="estrydis"/>
<result column="THRSMDAYS" property="thrsmdays"/>
<result column="ZJXYDZ" property="zjxydz"/>
<result column="EDTUN" property="edtun"/>
<result column="EDTTM" property="edttm"/>
<result column="DSNSTT" property="dsnstt"/>
<result column="YSDLEN" property="ysdlen"/>
<result column="DMRKTP" property="dmrktp"/>
<result column="HNTJZL" property="hntjzl"/>
<result column="GNTP" property="gntp"/>
<result column="CNTRAR" property="cntrar"/>
<result column="CNTRSC" property="cntrsc"/>
<result column="AVYRP" property="avyrp"/>
<result column="AVQ" property="avq"/>
<result column="DSAVQ" property="dsavq"/>
<result column="DSMXQ" property="dsmxq"/>
<result column="CHMXQ" property="chmxq"/>
<result column="RVLN" property="rvlen"/>
<result column="RVGR" property="rvgr"/>
<result column="AVW" property="avw"/>
<result column="AVYRQ" property="avyrq"/>
<result column="AVSD" property="avsd"/>
<result column="AVS" property="avs"/>
<result column="MYAVMNAT" property="myavmnat"/>
<result column="DSW1" property="dsw1"/>
<result column="DSW3" property="dsw3"/>
<result column="CHFCDR" property="chfldr"/>
<result column="CHFLW" property="chflw"/>
<result column="CPSC" property="cpsc"/>
<result column="NRZAR" property="nrzar"/>
<result column="BCKLEN" property="bcklen"/>
<result column="NRAVWT" property="nravwt"/>
<result column="NRMXAVWT" property="nrmxavwt"/>
<result column="NRMNAVT" property="nrmnavwt"/>
<result column="DNAVWT" property="dnavwt"/>
<result column="DNMXAVWT" property="dnmxavwt"/>
<result column="DNMNAVT" property="dnmnavwt"/>
<result column="NRUPAR" property="nrupar"/>
<result column="NRAVZ" property="nravz"/>
<result column="NRAVH" property="nravh"/>
<result column="DSNFQFRQ" property="dsnfqfrq"/>
<result column="CKFQFQR" property="ckfqfqr"/>
<result column="OBMXW3" property="obmxw3"/>
<result column="FDCZ" property="fdcz"/>
<result column="FDQT" property="fdqt"/>
<result column="DSTCRVR" property="dstcrvr"/>
<result column="CKW3" property="ckw3"/>
<result column="FSLTDZ" property="fsltdz"/>
<result column="RSTP" property="rstp"/>
<result column="ADJCPS" property="adjcps"/>
<result column="ADJCPM" property="adjcpm"/>
<result column="YRGEB" property="yrgeb"/>
<result column="TTPWRB" property="ttpwrb"/>
<result column="DMCREL" property="dmcrel"/>
<result column="WSC" property="wsc"/>
<result column="MXDMHG" property="mxdmhg"/>
<result column="MXDMHGL" property="mxdmhgl"/>
<result column="MXDMHGR" property="mxdmhgr"/>
<result column="WVTPEL" property="wvtpel"/>
<result column="DMLEN" property="dmlen"/>
<result column="XSWTP" property="xswtp"/>
<result column="XNTP" property="xntp"/>
<result column="JSKTP" property="jsktp"/>
<result column="JSKGC" property="jskgc"/>
<result column="CFTP" property="cftp"/>
<result column="WSCHGC" property="wschgc"/>
<result column="THTP" property="thtp"/>
<result column="THGM" property="thgm"/>
<result column="THNL" property="thnl"/>
<result column="GAP" property="gap"/>
<result column="MXGAP" property="mxgap"/>
<result column="MNGAP" property="mngap"/>
<result column="GAPM" property="gapm"/>
<result column="HLSTP" property="hlstp"/>
<result column="HLSCONST" property="hlsconst"/>
<result column="HLSDCOEF" property="hlscoef"/>
<result column="MXHLS" property="mxhls"/>
<result column="GAPS" property="gaps"/>
<result column="DSIMEL" property="dsimel"/>
<result column="ACIMEL" property="acimel"/>
<result column="YMBQRK" property="ymbqrk"/>
<result column="YMSCRK" property="ymscrk"/>
<result column="YMBQXZ" property="ymbqxz"/>
<result column="FDAR" property="fdar"/>
<result column="FDXS" property="fdxs"/>
<result column="FDZS" property="fdzs"/>
<result column="FDGD" property="fdgd"/>
<result column="FDLD" property="fdld"/>
<result column="FDRK" property="fdrk"/>
<result column="FDFW" property="fdfw"/>
<result column="FDGL" property="fdgl"/>
<result column="CANED" property="caned"/>
<result column="YMBQRKNC" property="ymbqrknc"/>
<result column="FDYD" property="fdyd"/>
<result column="SSWDT" property="sswdt"/>
<result column="PIODT" property="piodt"/>
<result column="AIODT" property="aiodt"/>
<result column="APTL" property="aptl"/>
<result column="MXSN" property="mxsn"/>
<result column="CLO" property="clo"/>
<result column="PREN" property="pren"/>
<result column="OPRTNUN" property="oprtnun"/>
<result column="DSUN" property="dsun"/>
<result column="SPUN" property="spun"/>
<result column="CNUN" property="cnun"/>
<result column="JTZ" property="jtz"/>
<result column="ZTZ" property="ztz"/>
<result column="HTZ" property="htz"/>
<result column="DTZ" property="dtz"/>
<result column="DYNTZ" property="dyntz"/>
<result column="STYPHPSP" property="styphpsp"/>
<result column="XSJDHBYS" property="xsjdhbys"/>
<result column="SBFASCRQ" property="sbfascrq"/>
<result column="XSJDSBYS" property="xsjdsbys"/>
<result column="HPSPRQ" property="hpsprq"/>
<result column="JGHBYSCRQ" property="jghbysrq"/>
<result column="JLJDSBYS" property="jljdsbys"/>
<result column="JGJDSBYS" property="jgjdsbys"/>
<result column="ZTGCSJDW" property="ztgcsjdw"/>
<result column="ZTGCSDGW" property="ztgcsgdw"/>
<result column="HPDW" property="hpdw"/>
<result column="HJJLDW" property="hjjldw"/>
<result column="SKYMBCTZ" property="skymbctz"/>
<result column="CHNGRD" property="chngrd"/>
<result column="CHNLNTH" property="chnlnth"/>
<result column="MXSHPTN" property="mxshptn"/>
<result column="YRCPCTY" property="yrcpcty"/>
<result column="WSPPLY" property="wspply"/>
<result column="WIRRG" property="wirrg"/>
<result column="ARIRRG" property="arirrg"/>
<result column="ZVARIATIONDMAX" property="zVariationDmax"/>
<result column="ZVARIATIONHMAX" property="zVariationHmax"/>
<result column="EQRATIO" property="eqrRatio"/>
<result column="AVQ01" property="avq01"/>
<result column="AVQ02" property="avq02"/>
<result column="AVQ03" property="avq03"/>
<result column="AVQ04" property="avq04"/>
<result column="AVQ05" property="avq05"/>
<result column="AVQ06" property="avq06"/>
<result column="AVQ07" property="avq07"/>
<result column="AVQ08" property="avq08"/>
<result column="AVQ09" property="avq09"/>
<result column="AVQ10" property="avq10"/>
<result column="AVQ11" property="avq11"/>
<result column="AVQ12" property="avq12"/>
<result column="DSRCIN" property="dsrcin"/>
<result column="CHRCIN" property="chrcin"/>
<result column="DSHL" property="dshl"/>
<result column="SGQ" property="sgq"/>
<result column="RCFFR" property="rcffr"/>
<result column="YDOWNZ" property="ydownz"/>
<result column="GEMAXRQ" property="gemaxrq"/>
<result column="LAGTIME" property="lagTime"/>
<result column="AVGDVLSR" property="avgdvlsr"/>
<result column="AVGDES" property="avgdes"/>
<result column="AVQSRC" property="avqSrc"/>
<result column="WRAVG" property="wrAvg"/>
<result column="CHIEFBASINENG" property="chiefbasineng"/>
<result column="SWSDT" property="swsdt"/>
<result column="UPHYDLIST" property="uphydlist"/>
<result column="CASHYDSORT" property="cashydsort"/>
<result column="ESMX" property="esmx"/>
<result column="ESCCDMX" property="esccdmx"/>
<result column="REMARK" property="remark"/>
<result column="VLSR" property="vlsr"/>
<result column="VLSRTM" property="vlsrTm"/>
</resultMap>
<select id="selectByBaseId" resultMap="BaseResultMap">
SELECT * FROM SD_ENGINFO_B_H
WHERE BASEID = #{baseId}
ORDER BY ORDER_INDEX ASC
</select>
<select id="selectByHycd" resultMap="BaseResultMap">
SELECT * FROM SD_ENGINFO_B_H
WHERE HYCD = #{hycd}
ORDER BY ORDER_INDEX ASC
</select>
<select id="selectByRvcd" resultMap="BaseResultMap">
SELECT * FROM SD_ENGINFO_B_H
WHERE RVCD = #{rvcd}
ORDER BY ORDER_INDEX ASC
</select>
</mapper>

40
backend/src/main/resources/mapper/env/SdHycdDicMapper.xml vendored Normal file
View File

@ -0,0 +1,40 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yfd.platform.env.mapper.SdHycdDicMapper">
<resultMap id="BaseResultMap" type="com.yfd.platform.env.domain.SdHycdDic">
<id column="HYCD" property="hycd"/>
<result column="HYNM" property="hynm"/>
<result column="SHORTNAME" property="shortname"/>
<result column="PHYCD" property="phycd"/>
<result column="GRD" property="grd"/>
<result column="PATH" property="path"/>
<result column="LGTD" property="lgtd"/>
<result column="LTTD" property="lttd"/>
<result column="COUNTRY" property="country"/>
<result column="LOGO" property="logo"/>
<result column="DES" property="des"/>
<result column="INFFILE" property="inffile"/>
<result column="ORDERINDEX" property="orderIndex"/>
</resultMap>
<select id="selectByPhycd" resultMap="BaseResultMap">
SELECT * FROM SD_HYCD_DIC
WHERE 1=1
<if test="phycd != null and phycd != ''">
AND PHYCD = #{phycd}
</if>
<if test="phycd == null or phycd == ''">
AND (PHYCD IS NULL OR PHYCD = '' OR PHYCD = '0')
</if>
ORDER BY ORDER_INDEX ASC
</select>
<select id="selectRootList" resultMap="BaseResultMap">
SELECT * FROM SD_HYCD_DIC
WHERE PHYCD IS NULL OR PHYCD = '' OR PHYCD = '0'
ORDER BY ORDER_INDEX ASC
</select>
</mapper>

36
backend/src/main/resources/mapper/env/SdHydrobaseMapper.xml vendored Normal file
View File

@ -0,0 +1,36 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yfd.platform.env.mapper.SdHydrobaseMapper">
<resultMap id="BaseResultMap" type="com.yfd.platform.env.domain.SdHydrobase">
<id column="BASEID" property="baseid"/>
<result column="BASENAME" property="basename"/>
<result column="SHORTNAME" property="shortname"/>
<result column="PBASEID" property="pbaseid"/>
<result column="GRD" property="grd"/>
<result column="PATH" property="path"/>
<result column="ORDERINDEX" property="orderIndex"/>
<result column="RMK" property="rmk"/>
<result column="DES" property="des"/>
</resultMap>
<select id="selectByPbaseid" resultMap="BaseResultMap">
SELECT * FROM SD_HYDROBASE
WHERE 1=1
<if test="pbaseid != null and pbaseid != ''">
AND PBASEID = #{pbaseid}
</if>
<if test="pbaseid == null or pbaseid == ''">
AND (PBASEID IS NULL OR PBASEID = '' OR PBASEID = '0')
</if>
ORDER BY ORDER_INDEX ASC
</select>
<select id="selectRootList" resultMap="BaseResultMap">
SELECT * FROM SD_HYDROBASE
WHERE PBASEID IS NULL OR PBASEID = '' OR PBASEID = '0'
ORDER BY ORDER_INDEX ASC
</select>
</mapper>

23
backend/src/main/resources/mapper/env/SdPrhbrltnBMapper.xml vendored Normal file
View File

@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yfd.platform.env.mapper.SdPrhbrltnBMapper">
<resultMap id="BaseResultMap" type="com.yfd.platform.env.domain.SdPrhbrltnB">
<id column="STCD" property="stcd"/>
<result column="BASEID" property="baseid"/>
<result column="TM" property="tm"/>
<result column="BLPRD" property="blprd"/>
</resultMap>
<select id="selectStcdListByBaseId" resultType="java.lang.String">
SELECT DISTINCT STCD FROM SD_PRHBRLTN_B
WHERE BASEID = #{baseid}
</select>
<select id="selectBaseIdListByStcd" resultType="java.lang.String">
SELECT DISTINCT BASEID FROM SD_PRHBRLTN_B
WHERE STCD = #{stcd}
</select>
</mapper>

23
backend/src/main/resources/mapper/env/SdPrhyrltnBMapper.xml vendored Normal file
View File

@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yfd.platform.env.mapper.SdPrhyrltnBMapper">
<resultMap id="BaseResultMap" type="com.yfd.platform.env.domain.SdPrhyrltnB">
<id column="STCD" property="stcd"/>
<result column="HYCD" property="hycd"/>
<result column="TM" property="tm"/>
<result column="RC" property="rc"/>
</resultMap>
<select id="selectStcdListByHycd" resultType="java.lang.String">
SELECT DISTINCT STCD FROM SD_PRHYRLTN_B
WHERE HYCD = #{hycd}
</select>
<select id="selectHycdListByStcd" resultType="java.lang.String">
SELECT DISTINCT HYCD FROM SD_PRHYRLTN_B
WHERE STCD = #{stcd}
</select>
</mapper>

46
backend/src/main/resources/mapper/env/SdRvcdDicMapper.xml vendored Normal file
View File

@ -0,0 +1,46 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yfd.platform.env.mapper.SdRvcdDicMapper">
<resultMap id="BaseResultMap" type="com.yfd.platform.env.domain.SdRvcdDic">
<id column="RVCD" property="rvcd"/>
<result column="RVNM" property="rvnm"/>
<result column="PRVCD" property="prvcd"/>
<result column="GRD" property="grd"/>
<result column="PATH" property="path"/>
<result column="ORDER_INDEX" property="orderIndex"/>
<result column="LGTD" property="lgtd"/>
<result column="LTTD" property="lttd"/>
<result column="AREA" property="area"/>
<result column="PERIMETER" property="perimeter"/>
<result column="COUNTRY" property="country"/>
<result column="INTRODUCE" property="introduce"/>
<result column="INFFILE" property="inffile"/>
<result column="SHORTNAME" property="shortname"/>
<result column="WEATHER_FORECAST" property="weatherForecast"/>
<result column="WEATHER_INVERSION" property="weatherInversion"/>
<result column="SHEPRANGE" property="sheprange"/>
<result column="BASEID" property="baseid"/>
<result column="ISMAP" property="ismap"/>
</resultMap>
<select id="selectByPrvcd" resultMap="BaseResultMap">
SELECT * FROM SD_RVCD_DIC
WHERE 1=1
<if test="prvcd != null and prvcd != ''">
AND PRVCD = #{prvcd}
</if>
<if test="prvcd == null or prvcd == ''">
AND (PRVCD IS NULL OR PRVCD = '')
</if>
ORDER BY ORDER_INDEX ASC
</select>
<select id="selectRootList" resultMap="BaseResultMap">
SELECT * FROM SD_RVCD_DIC
WHERE PRVCD IS NULL OR PRVCD = '' OR PRVCD = '0'
ORDER BY ORDER_INDEX ASC
</select>
</mapper>