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

Merge branch 'dev-tw'

Browse Source
This commit is contained in:
tangwei 2026-06-04 09:01:49 +08:00
commit 485a7b1adf
259 changed files with 11323 additions and 2537 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
backend/src/main/java/com/yfd/platform/config/SecurityConfig.java
View File

@ -58,9 +58,12 @@ public class SecurityConfig {
.requestMatchers("/tempFile/**").permitAll()
.requestMatchers("/system/user/auditUser").permitAll()
.requestMatchers("/eng/**").permitAll()
.requestMatchers("/eq/**").permitAll()
.requestMatchers("/env/**").permitAll()
.requestMatchers("/wt/**").permitAll()
.requestMatchers("/zq/**").permitAll()
.requestMatchers("/wq/**").permitAll()
.requestMatchers("/vd/**").permitAll()
.requestMatchers("/fp/**").permitAll()
.requestMatchers("/fh/**").permitAll()
.requestMatchers("/data/**").permitAll()

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

@ -49,15 +49,15 @@ public class SwaggerConfig {
public GroupedOpenApi groupDataEnvApi() {
return GroupedOpenApi.builder()
.group("2. 过鱼数据模块")
.packagesToScan("com.yfd.platform.data.controller")
.packagesToScan("com.yfd.platform.qgc_data.controller")
.build();
}
@Bean
public GroupedOpenApi groupEnvApi() {
public GroupedOpenApi groupQgcBaseApi() {
return GroupedOpenApi.builder()
.group("3全过程-生态环保数据服务")
.packagesToScan("com.yfd.platform.env.controller")
.packagesToScan("com.yfd.platform.qgc_base.controller")
.build();
}
@ -65,14 +65,14 @@ public class SwaggerConfig {
public GroupedOpenApi groupEnvWTApi() {
return GroupedOpenApi.builder()
.group("3.1 全过程-生态环保数据服务-水温监测")
.packagesToScan("com.yfd.platform.env.wt.controller")
.packagesToScan("com.yfd.platform.qgc_env.wt.controller")
.build();
}
@Bean
public GroupedOpenApi groupEnvWQApi() {
return GroupedOpenApi.builder()
.group("3.2 全过程-生态环保数据服务-水质监测")
.packagesToScan("com.yfd.platform.env.wq.controller")
.packagesToScan("com.yfd.platform.qgc_env.wq.controller")
.build();
}
@ -80,7 +80,15 @@ public class SwaggerConfig {
public GroupedOpenApi groupEnvFPApi() {
return GroupedOpenApi.builder()
.group("3.3 全过程-生态环保数据服务-过鱼设施")
.packagesToScan("com.yfd.platform.env.fp.controller")
.packagesToScan("com.yfd.platform.qgc_env.fp.controller")
.build();
}
@Bean
public GroupedOpenApi groupEnvVDApi() {
return GroupedOpenApi.builder()
.group("3.3.1 全过程-生态环保数据服务-过鱼设施-过鱼监测")
.packagesToScan("com.yfd.platform.qgc_env.vd.controller")
.build();
}
@ -88,7 +96,15 @@ public class SwaggerConfig {
public GroupedOpenApi groupEnvFHApi() {
return GroupedOpenApi.builder()
.group("3.4 全过程-生态环保数据服务-栖息地")
.packagesToScan("com.yfd.platform.env.fh.controller")
.packagesToScan("com.yfd.platform.qgc_env.fh.controller")
.build();
}
@Bean
public GroupedOpenApi groupEnvZQApi() {
return GroupedOpenApi.builder()
.group("3.4.1 全过程-生态环保数据服务-栖息地-水文模块")
.packagesToScan("com.yfd.platform.qgc_env.zq.controller")
.build();
}
@ -99,7 +115,15 @@ public class SwaggerConfig {
public GroupedOpenApi groupEngApi() {
return GroupedOpenApi.builder()
.group("4. 全过程-常规水电数据服务")
.packagesToScan("com.yfd.platform.eng.controller")
.packagesToScan("com.yfd.platform.qgc_eng.controller")
.build();
}
@Bean
public GroupedOpenApi groupEngEqApi() {
return GroupedOpenApi.builder()
.group("4.1. 全过程-常规水电数据服务-生态流量")
.packagesToScan("com.yfd.platform.qgc_eng.eq.controller")
.build();
}
}

54
backend/src/main/java/com/yfd/platform/eng/controller/AlarmPointController.java
View File

@ -1,54 +0,0 @@
package com.yfd.platform.eng.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.eng.entity.vo.AlarmStcdCountVo;
import com.yfd.platform.eng.service.AlarmPointService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import jakarta.annotation.Resource;
import java.util.Map;
/**
* 运行告警锚点控制器
*/
@RestController
@RequestMapping("/eng/alarmPoint")
@Tag(name = "运行告警锚点控制器")
public class AlarmPointController {
/**
* 服务对象
*/
@Resource
private AlarmPointService alarmPointService;
@PostMapping({"/GetKendoListCust"})
@Operation(summary = "条件过滤数据列表定制")
public ResponseResult getKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
DataSourceResult<AlarmStcdCountVo> dataSourceResult = alarmPointService.processKendoList(dataSourceRequest, filterResult, page);
alarmPointService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
/**
* 获取警报统计数据
* @param stcd 电站ID
* @return 响应结果
*/
@PostMapping({"/getAlarmCount"})
@Operation(summary = "获取警报统计数据")
public ResponseResult getAlarmCount(String stcd) {
AlarmStcdCountVo vo = alarmPointService.getAlarmCount(stcd);
return ResponseResult.successData(vo);
}
}

121
backend/src/main/java/com/yfd/platform/eng/controller/EngEqController.java
View File

@ -1,121 +0,0 @@
package com.yfd.platform.eng.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.common.GroupResult;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.eng.service.EngEqService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletResponse;
import java.util.Map;
/**
* 电站生态流量统计查询
*/
@RestController
@RequestMapping("/eng/eq/")
@Tag(name = "电站生态流量统计查询")
public class EngEqController {
/**
* 服务对象
*/
@Resource
private EngEqService msEngEqService;
@PostMapping({"/GetKendoListCust"})
@Operation(summary = "条件过滤数据列表定制")
public ResponseResult getKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, GroupResult> filterResult = null; // 实际应该根据业务需求处理筛选
DataSourceResult dataSourceResult = msEngEqService.processKendoList(dataSourceRequest, filterResult, page);
msEngEqService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
/**
* 导出
* @param dataSourceRequest 数据源请求
* @param response 响应
*/
@PostMapping({"/export"})
@Operation(summary = "导出")
public void export(@RequestBody DataSourceRequest dataSourceRequest, HttpServletResponse response) {
// 实际应该实现导出逻辑
}
/**
* 月统计数据有数据的电站
* @param dataSourceRequest 数据源请求
* @return 响应结果
*/
@PostMapping("/lastEngDataSite")
@Operation(summary = "查询指定时间有数据的站点")
public ResponseResult lastEngDataSite(@RequestBody DataSourceRequest dataSourceRequest) {
DataSourceResult result = msEngEqService.lastEngDataSite(dataSourceRequest);
return ResponseResult.successData(result);
}
@PostMapping("/default/stcd")
@Operation(summary = "获取生态流量默认有数据的电站")
public ResponseResult getDefaultStcd(@RequestBody DataSourceRequest dataSourceRequest) {
DataSourceResult result = msEngEqService.getDefaultStcd(dataSourceRequest);
return ResponseResult.successData(result);
}
@PostMapping("/getSfdbInfo")
@Operation(summary = "获取不达标详情数据")
public ResponseResult getSfdbInfo(@RequestBody DataSourceRequest dataSourceRequest) {
DataSourceResult result = msEngEqService.getSfdbInfo(dataSourceRequest);
return ResponseResult.successData(result);
}
@PostMapping({"/qecSfdbCountByStcd"})
@Operation(summary = "生态流量不达标测站数")
public ResponseResult qecSfdbCountByStcd(@RequestBody DataSourceRequest dataSourceRequest) {
DataSourceResult result = msEngEqService.qecSfdbCountByStcd(dataSourceRequest);
return ResponseResult.successData(result);
}
/**
* 生态流量达标率计算（基地维度、不达标原因维度）
* @param dataSourceRequest 数据源请求
* @return 响应结果
*/
@PostMapping({"/qecRateCount"})
@Operation(summary = "生态流量达标率计算（基地维度、不达标原因维度）")
public ResponseResult qecRateCount(@RequestBody DataSourceRequest dataSourceRequest) {
DataSourceResult result = msEngEqService.qecRateCount(dataSourceRequest);
return ResponseResult.successData(result);
}
/**
* 生态流量不达标数量计算（电站维度、不达标原因维度）
* @param dataSourceRequest 数据源请求
* @return 响应结果
*/
@PostMapping({"/qecSfdbCount"})
@Operation(summary = "生态流量不达标数量计算（电站维度、不达标原因维度）")
public ResponseResult qecSfdbCount(@RequestBody DataSourceRequest dataSourceRequest) {
DataSourceResult result = msEngEqService.qecSfdbCount(dataSourceRequest);
return ResponseResult.successData(result);
}
@PostMapping({"/group/GetKendoListCust"})
public ResponseResult getGroupKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, GroupResult> filterResult = null; // 实际应该根据业务需求处理筛选
DataSourceResult dataSourceResult = msEngEqService.processKendoList(dataSourceRequest, filterResult, page);
msEngEqService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
}

108
backend/src/main/java/com/yfd/platform/eng/controller/EngEqDataController.java
View File

@ -1,108 +0,0 @@
package com.yfd.platform.eng.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.eng.service.EngEqDataService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Map;
/**
* 电站实时数据查询
*/
@RestController
@RequestMapping("/eng/eq/data")
@Tag(name = "电站实时数据查询")
public class EngEqDataController {
/**
* 服务对象
*/
@Resource
private EngEqDataService engEqDataService;
@PostMapping({"/GetKendoListCust"})
@Operation(summary = "生态流量沿程变化-小时")
public ResponseResult getKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
DataSourceResult dataSourceResult = engEqDataService.processKendoList(dataSourceRequest, filterResult, page);
engEqDataService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
/**
* 导出
* @param dataSourceRequest 数据源请求
* @param response 响应
*/
@PostMapping({"/export"})
@Operation(summary = "导出")
public void export(@RequestBody DataSourceRequest dataSourceRequest, HttpServletResponse response) {
// 实际应该实现导出逻辑
}
@PostMapping({"/day/GetKendoListCust"})
@Operation(summary = "查询生态流量 日 数据")
public ResponseResult getKendoDayListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
String groupBy = ""; // 实际应该根据业务需求处理分组
DataSourceResult dataSourceResult = engEqDataService.processDayKendoList(dataSourceRequest, filterResult, page, groupBy);
engEqDataService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
@PostMapping({"/drtp/GetKendoListCust"})
@Operation(summary = "查询生态流量 周旬月季年 数据")
public ResponseResult getKendoDrtpListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
String groupBy = ""; // 实际应该根据业务需求处理分组
DataSourceResult dataSourceResult = engEqDataService.processKendoDrtpList(dataSourceRequest, filterResult, page, groupBy);
engEqDataService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
@PostMapping({"/fastSiteLastData/GetKendoListCust"})
@Operation(summary = "查询沿程第一个电站的生态流量数据时间")
public ResponseResult getFastSiteLastData(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
String groupBy = ""; // 实际应该根据业务需求处理分组
DataSourceResult dataSourceResult = engEqDataService.getFastSiteLastData(dataSourceRequest, filterResult, page, groupBy);
engEqDataService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
/**
* 生态流量沿程变化（面板）
* @param dataSourceRequest 数据源请求
* @return 响应结果
*/
@PostMapping({"/along/GetKendoListCust"})
@Operation(summary = "查询生态流量(沿程数据)")
public ResponseResult getKendoAlongListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
DataSourceResult dataSourceResult = engEqDataService.processKendoList(dataSourceRequest, filterResult, page);
engEqDataService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
@PostMapping({"/getEngLimit"})
@Operation(summary = "根据时间范围查询电站生态流量限值及来源")
public ResponseResult getEngLimit(@RequestBody DataSourceRequest dataSourceRequest) {
Object result = engEqDataService.getEngLimit(dataSourceRequest);
return ResponseResult.successData(result);
}
}

131
backend/src/main/java/com/yfd/platform/eng/controller/EngEqIntervalController.java
View File

@ -1,131 +0,0 @@
package com.yfd.platform.eng.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log;
import com.yfd.platform.common.DataSourceLoadOptionsBase;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.eng.domain.MsEngEq;
import com.yfd.platform.eng.service.EngEqIntervalService;
import com.yfd.platform.eng.service.EngEqService;
import com.yfd.platform.utils.KendoUtil;
import com.yfd.platform.utils.QgcQueryWrapperUtil;
import com.yfd.platform.utils.QueryWrapperUtil;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Map;
/**
* 生态流量区间统计控制器
*/
@RestController
@RequestMapping("/eng/eq/interval")
@Tag(name = "电站生态流量区间统计查询")
public class EngEqIntervalController {
/**
* 服务对象
*/
@Resource
private EngEqIntervalService eqIntervalService;
@Resource
private EngEqService engEqService;
/**
* 生态流量达标情况
* @param dataSourceRequest 数据源请求
* @return 响应结果
*/
@PostMapping({"/GetKendoListCust"})
@Operation(summary = "生态流量达标情况")
public ResponseResult getKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page<MsEngEq> page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
DataSourceResult result = eqIntervalService.processKendoList(dataSourceRequest, filterResult, page);
eqIntervalService.processKendoGetListLoadResult(dataSourceRequest, result);
return ResponseResult.successData(result);
}
/**
* 导出
* @param dataSourceRequest 数据源请求
* @param response 响应
*/
@PostMapping({"/export"})
@Operation(summary = "导出")
@Log(module = "生态流量", value = "导出生态流量数据")
public void export(@RequestBody DataSourceRequest dataSourceRequest, HttpServletResponse response) {
// 实际应该实现导出逻辑
}
/**
* 生态流量达标率 小时统计(二级页面)
* @param dataSourceRequest 数据源请求
* @return 响应结果
*/
@PostMapping({"/qgc/hour/GetKendoListCust"})
@Operation(summary = "生态流量达标率 小时统计(二级页面)")
public ResponseResult getQgcHourKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
String kendoGroupCode = "EngEqHour";
// Map<String, GroupResult> filterResult = KendoUtil.getGroupResultMap(dataSourceRequest, null, EngEqIntervalController.class);
// String groupBy = KendoUtil.getGroupBy(dataSourceRequest);
Page page = KendoUtil.getPage(dataSourceRequest);
DataSourceResult result = eqIntervalService.getQgcHourKendoListCust(dataSourceRequest, null, page, null);
// eqIntervalService.processKendoGetListLoadResult(dataSourceRequest, result);
return ResponseResult.successData(result);
}
/**
* 生态流量达标率 日统计(二级页面)
* @param dataSourceRequest 数据源请求
* @return 响应结果
*/
@PostMapping({"/qgc/day/GetKendoListCust"})
@Operation(summary = "生态流量达标率 日统计(二级页面)")
public ResponseResult getQgcDayKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page<MsEngEq> page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
String groupBy = ""; // 实际应该根据业务需求处理分组
DataSourceResult result = eqIntervalService.getQgcDayKendoListCust(dataSourceRequest, filterResult, page, groupBy);
eqIntervalService.processKendoGetListLoadResult(dataSourceRequest, result);
return ResponseResult.successData(result);
}
/**
* 生态流量达标率 区间范围统计(一级页面)
* @param dataSourceRequest 数据源请求
* @return 响应结果
*/
@PostMapping({"/qgc/getQgcStaticData"})
@Operation(summary = "生态流量达标率 区间范围统计(一级页面)")
// @Log(module = "生态流量", value = "生态流量达标率统计")
public ResponseResult getQgcStaticData(@RequestBody DataSourceRequest dataSourceRequest) {
DataSourceLoadOptionsBase loadOptionsBase = dataSourceRequest.toDevRequest();
String type = QgcQueryWrapperUtil.getFilterFieldValue(loadOptionsBase, "type");
ResponseResult r;
if("hour".equals(type)){
r = this.getQgcHourKendoListCust(dataSourceRequest);
}else if("day".equals(type)){
r = this.getQgcDayKendoListCust(dataSourceRequest);
}else{
return ResponseResult.error("请选择生态流量达标率统计类型(小时还是天统计)");
}
if(r != null && r.get("code").equals("0") && r.get("data") != null){
DataSourceResult dataSourceResult = (DataSourceResult) r.get("data");
if(dataSourceResult != null && dataSourceResult.getData() != null){
Map<String, Object> staticData = eqIntervalService.getQgcQecStaticData(dataSourceResult.getData(), type);
return ResponseResult.successData(staticData);
}
}
return ResponseResult.success();
}
}

54
backend/src/main/java/com/yfd/platform/eng/controller/EngEqStatController.java
View File

@ -1,54 +0,0 @@
package com.yfd.platform.eng.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.common.GroupResult;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.eng.service.EngEqService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Map;
/**
* 电站生态流量统计结果查询
*/
@RestController
@RequestMapping("/eng/eq/stat")
@Tag(name = "电站生态流量统计结果查询")
public class EngEqStatController {
/**
* 服务对象
*/
@Resource
private EngEqService msEngEqService;
@PostMapping({"/GetKendoListCust"})
@Operation(summary = "条件过滤数据列表定制")
public ResponseResult getKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, GroupResult> filterResult = null; // 实际应该根据业务需求处理筛选
DataSourceResult dataSourceResult = msEngEqService.processKendoList(dataSourceRequest, filterResult, page);
msEngEqService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
/**
* 导出
* @param dataSourceRequest 数据源请求
* @param response 响应
*/
@PostMapping({"/export"})
@Operation(summary = "导出")
public void export(@RequestBody DataSourceRequest dataSourceRequest, HttpServletResponse response) {
// 实际应该实现导出逻辑
}
}

42
backend/src/main/java/com/yfd/platform/eng/controller/EngSpecialController.java
View File

@ -1,42 +0,0 @@
package com.yfd.platform.eng.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.eng.entity.EqSpecial;
import com.yfd.platform.eng.service.EngSpecialService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Map;
/**
* 电站专题-环保设施运行情况
*/
@RestController
@RequestMapping("/eng/special")
@Tag(name = "电站专题-环保设施运行情况")
public class EngSpecialController {
/**
* 服务对象
*/
@Resource
private EngSpecialService engSpecialService;
@PostMapping({"/GetKendoListCust"})
@Operation(summary = "条件过滤数据列表定制")
public ResponseResult getKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
Page page = new Page<>(dataSourceRequest.getPage(), dataSourceRequest.getPageSize());
Map<String, Object> filterResult = null; // 实际应该根据业务需求处理筛选
DataSourceResult<EqSpecial> dataSourceResult = engSpecialService.processKendoList(dataSourceRequest, filterResult, page);
engSpecialService.processKendoGetListLoadResult(dataSourceRequest, dataSourceResult);
return ResponseResult.successData(dataSourceResult);
}
}

61
backend/src/main/java/com/yfd/platform/eng/domain/MsEngEq.java
View File

@ -1,61 +0,0 @@
package com.yfd.platform.eng.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
* 生态流量实体类
*/
@Data
@TableName("ms_eng_eq")
public class MsEngEq implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
private String id;
/**
* 电站ID
*/
private String stationId;
/**
* 电站名称
*/
private String stationName;
/**
* 时间
*/
private Date time;
/**
* 生态流量值
*/
private Double eqValue;
/**
* 达标状态
*/
private String status;
/**
* 统计类型（hour/day）
*/
private String type;
/**
* 创建时间
*/
private Date createTime;
/**
* 更新时间
*/
private Date updateTime;
}

54
backend/src/main/java/com/yfd/platform/eng/entity/EqSpecial.java
View File

@ -1,54 +0,0 @@
package com.yfd.platform.eng.entity;
import lombok.Data;
/**
* 电站专题-环保设施运行情况
*/
@Data
public class EqSpecial {
/**
* 主键
*/
private String id;
/**
* 电站ID
*/
private String stcd;
/**
* 电站名称
*/
private String stnm;
/**
* 环保设施类型
*/
private String eqType;
/**
* 设施名称
*/
private String eqName;
/**
* 运行状态
*/
private String status;
/**
* 检查时间
*/
private String checkTime;
/**
* 检查人
*/
private String checker;
/**
* 备注
*/
private String remark;
}

39
backend/src/main/java/com/yfd/platform/eng/entity/vo/AlarmStcdCountVo.java
View File

@ -1,39 +0,0 @@
package com.yfd.platform.eng.entity.vo;
import lombok.Data;
/**
* 警报锚点统计VO
*/
@Data
public class AlarmStcdCountVo {
/**
* 电站ID
*/
private String stcd;
/**
* 电站名称
*/
private String stnm;
/**
* 警报数量
*/
private Integer alarmCount;
/**
* 未处理数量
*/
private Integer unhandledCount;
/**
* 处理中数量
*/
private Integer handlingCount;
/**
* 已处理数量
*/
private Integer handledCount;
}

54
backend/src/main/java/com/yfd/platform/eng/entity/vo/EngEqDataVo.java
View File

@ -1,54 +0,0 @@
package com.yfd.platform.eng.entity.vo;
import lombok.Data;
/**
* 生态流量小时数据VO
*/
@Data
public class EngEqDataVo {
/**
* 电站ID
*/
private String stcd;
/**
* 电站名称
*/
private String stnm;
/**
* 时间
*/
private String tm;
/**
* 生态流量值
*/
private Double eqValue;
/**
* 状态
*/
private String status;
/**
* 不达标原因
*/
private String reason;
/**
* 限值
*/
private Double limitValue;
/**
* 限值来源
*/
private String limitSource;
/**
* 是否左边界
*/
private Integer isLeft;
}

59
backend/src/main/java/com/yfd/platform/eng/entity/vo/EngEqDayDataVo.java
View File

@ -1,59 +0,0 @@
package com.yfd.platform.eng.entity.vo;
import lombok.Data;
/**
* 生态流量日数据VO
*/
@Data
public class EngEqDayDataVo {
/**
* 电站ID
*/
private String stcd;
/**
* 电站名称
*/
private String stnm;
/**
* 日期
*/
private String tm;
/**
* 日平均生态流量
*/
private Double avgValue;
/**
* 日最小生态流量
*/
private Double minValue;
/**
* 日最大生态流量
*/
private Double maxValue;
/**
* 状态
*/
private String status;
/**
* 不达标原因
*/
private String reason;
/**
* 限值
*/
private Double limitValue;
/**
* 限值来源
*/
private String limitSource;
}

59
backend/src/main/java/com/yfd/platform/eng/entity/vo/EngEqDrtpDataVo.java
View File

@ -1,59 +0,0 @@
package com.yfd.platform.eng.entity.vo;
import lombok.Data;
/**
* 生态流量周旬月季年数据VO
*/
@Data
public class EngEqDrtpDataVo {
/**
* 电站ID
*/
private String stcd;
/**
* 电站名称
*/
private String stnm;
/**
* 时间
*/
private String tm;
/**
* 平均生态流量
*/
private Double avgValue;
/**
* 最小生态流量
*/
private Double minValue;
/**
* 最大生态流量
*/
private Double maxValue;
/**
* 状态
*/
private String status;
/**
* 不达标原因
*/
private String reason;
/**
* 限值
*/
private Double limitValue;
/**
* 限值来源
*/
private String limitSource;
}

21
backend/src/main/java/com/yfd/platform/eng/mapper/EngEqMapper.java
View File

@ -1,21 +0,0 @@
package com.yfd.platform.eng.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.eng.domain.MsEngEq;
import org.apache.ibatis.annotations.Select;
import java.util.Map;
/**
* 生态流量Mapper
*/
public interface EngEqMapper extends BaseMapper<MsEngEq> {
/**
* 根据条件查询生态流量数据
* @param params 查询参数
* @return 生态流量列表
*/
@Select("select * from ms_eng_eq where 1=1")
Object queryList(Map<String, Object> params);
}

37
backend/src/main/java/com/yfd/platform/eng/service/AlarmPointService.java
View File

@ -1,37 +0,0 @@
package com.yfd.platform.eng.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.eng.entity.vo.AlarmStcdCountVo;
import java.util.Map;
/**
* 警报锚点服务
*/
public interface AlarmPointService {
/**
* 处理kendo列表
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @return 数据源结果
*/
DataSourceResult<AlarmStcdCountVo> processKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page);
/**
* 处理kendo返回列表字典匹配
* @param dataSourceRequest 数据源请求
* @param dataSourceResult 数据源结果
*/
void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult<AlarmStcdCountVo> dataSourceResult);
/**
* 获取警报统计数据
* @param stcd 电站ID
* @return 统计结果
*/
AlarmStcdCountVo getAlarmCount(String stcd);
}

74
backend/src/main/java/com/yfd/platform/eng/service/EngEqDataService.java
View File

@ -1,74 +0,0 @@
package com.yfd.platform.eng.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import java.util.Map;
/**
* 生态流量数据服务
*/
public interface EngEqDataService {
/**
* 处理kendo列表
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @return 数据源结果
*/
DataSourceResult processKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page);
/**
* 处理kendo返回列表字典匹配
* @param dataSourceRequest 数据源请求
* @param dataSourceResult 数据源结果
*/
void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult dataSourceResult);
/**
* 处理分组条件SQL
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @return SQL条件
*/
String processGroupConditionSql(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult);
/**
* 处理日数据kendo列表
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @param groupBy 分组
* @return 数据源结果
*/
DataSourceResult processDayKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page, String groupBy);
/**
* 处理周旬月季年数据kendo列表
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @param groupBy 分组
* @return 数据源结果
*/
DataSourceResult processKendoDrtpList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page, String groupBy);
/**
* 查询沿程第一个电站的生态流量数据时间
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @param groupBy 分组
* @return 数据源结果
*/
DataSourceResult getFastSiteLastData(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page, String groupBy);
/**
* 根据时间范围查询电站生态流量限值及来源
* @param dataSourceRequest 数据源请求
* @return 生态流量限值VO
*/
Object getEngLimit(DataSourceRequest dataSourceRequest);
}

59
backend/src/main/java/com/yfd/platform/eng/service/EngEqIntervalService.java
View File

@ -1,59 +0,0 @@
package com.yfd.platform.eng.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.common.GroupResult;
import com.yfd.platform.eng.domain.MsEngEq;
import java.util.Map;
/**
* 生态流量区间统计服务
*/
public interface EngEqIntervalService {
/**
* 处理kendo列表
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @return 数据源结果
*/
DataSourceResult processKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page<MsEngEq> page);
/**
* 处理kendo返回列表字典匹配
* @param dataSourceRequest 数据源请求
* @param dataSourceResult 数据源结果
*/
void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult dataSourceResult);
/**
* 生态流量达标率 小时统计
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @param groupBy 分组
* @return 数据源结果
*/
DataSourceResult getQgcHourKendoListCust(DataSourceRequest dataSourceRequest, Map<String, GroupResult> filterResult, Page<MsEngEq> page, String groupBy);
/**
* 生态流量达标率 日统计
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @param groupBy 分组
* @return 数据源结果
*/
DataSourceResult getQgcDayKendoListCust(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page<MsEngEq> page, String groupBy);
/**
* 生态流量达标率 区间范围统计
* @param dataList 数据列表
* @param type 类型（hour/day）
* @return 统计结果
*/
Map<String, Object> getQgcQecStaticData(Object dataList, String type);
}

83
backend/src/main/java/com/yfd/platform/eng/service/EngEqService.java
View File

@ -1,83 +0,0 @@
package com.yfd.platform.eng.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.common.GroupResult;
import com.yfd.platform.eng.domain.MsEngEq;
import java.util.Map;
/**
* 生态流量服务
*/
public interface EngEqService extends IService<MsEngEq> {
/**
* 处理kendo列表
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @return 数据源结果
*/
DataSourceResult processKendoList(DataSourceRequest dataSourceRequest, Map<String, GroupResult> filterResult, Page page);
/**
* 处理kendo返回列表字典匹配
* @param dataSourceRequest 数据源请求
* @param dataSourceResult 数据源结果
*/
void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult dataSourceResult);
/**
* 处理分组条件SQL
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @return SQL条件
*/
String processGroupConditionSql(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult);
/**
* 月统计数据有数据的电站
* @param dataSourceRequest 数据源请求
* @return 数据源结果
*/
DataSourceResult lastEngDataSite(DataSourceRequest dataSourceRequest);
/**
* 获取生态流量默认有数据的电站
* @param dataSourceRequest 数据源请求
* @return 数据源结果
*/
DataSourceResult getDefaultStcd(DataSourceRequest dataSourceRequest);
/**
* 获取不达标详情数据
* @param dataSourceRequest 数据源请求
* @return 数据源结果
*/
DataSourceResult getSfdbInfo(DataSourceRequest dataSourceRequest);
/**
* 生态流量不达标测站数
* @param dataSourceRequest 数据源请求
* @return 数据源结果
*/
DataSourceResult qecSfdbCountByStcd(DataSourceRequest dataSourceRequest);
/**
* 生态流量达标率计算（基地维度、不达标原因维度）
* @param dataSourceRequest 数据源请求
* @return 数据源结果
*/
DataSourceResult qecRateCount(DataSourceRequest dataSourceRequest);
/**
* 生态流量不达标数量计算（电站维度、不达标原因维度）
* @param dataSourceRequest 数据源请求
* @return 数据源结果
*/
DataSourceResult qecSfdbCount(DataSourceRequest dataSourceRequest);
}

30
backend/src/main/java/com/yfd/platform/eng/service/EngSpecialService.java
View File

@ -1,30 +0,0 @@
package com.yfd.platform.eng.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.eng.entity.EqSpecial;
import java.util.Map;
/**
* 电站专题-环保设施运行情况服务
*/
public interface EngSpecialService {
/**
* 处理kendo列表
* @param dataSourceRequest 数据源请求
* @param filterResult 筛选结果
* @param page 分页
* @return 数据源结果
*/
DataSourceResult<EqSpecial> processKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page);
/**
* 处理kendo返回列表字典匹配
* @param dataSourceRequest 数据源请求
* @param dataSourceResult 数据源结果
*/
void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult<EqSpecial> dataSourceResult);
}

66
backend/src/main/java/com/yfd/platform/eng/service/impl/AlarmPointServiceImpl.java
View File

@ -1,66 +0,0 @@
package com.yfd.platform.eng.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.eng.entity.vo.AlarmStcdCountVo;
import com.yfd.platform.eng.service.AlarmPointService;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* 警报锚点服务实现
*/
@Service
public class AlarmPointServiceImpl implements AlarmPointService {
@Override
public DataSourceResult<AlarmStcdCountVo> processKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page) {
// 模拟数据，实际应该从数据库查询
List<AlarmStcdCountVo> dataList = new ArrayList<>();
// 模拟添加一些数据
AlarmStcdCountVo vo1 = new AlarmStcdCountVo();
vo1.setStcd("ST001");
vo1.setStnm("电站1");
vo1.setAlarmCount(10);
vo1.setUnhandledCount(3);
vo1.setHandlingCount(2);
vo1.setHandledCount(5);
dataList.add(vo1);
AlarmStcdCountVo vo2 = new AlarmStcdCountVo();
vo2.setStcd("ST002");
vo2.setStnm("电站2");
vo2.setAlarmCount(8);
vo2.setUnhandledCount(2);
vo2.setHandlingCount(1);
vo2.setHandledCount(5);
dataList.add(vo2);
DataSourceResult<AlarmStcdCountVo> result = new DataSourceResult<>();
result.setData(dataList);
result.setTotal(dataList.size());
return result;
}
@Override
public void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult<AlarmStcdCountVo> dataSourceResult) {
// 处理字典匹配，实际应该根据业务需求实现
}
@Override
public AlarmStcdCountVo getAlarmCount(String stcd) {
// 模拟数据，实际应该从数据库查询
AlarmStcdCountVo vo = new AlarmStcdCountVo();
vo.setStcd(stcd);
vo.setStnm("电站" + stcd);
vo.setAlarmCount(5);
vo.setUnhandledCount(1);
vo.setHandlingCount(1);
vo.setHandledCount(3);
return vo;
}
}

71
backend/src/main/java/com/yfd/platform/eng/service/impl/EngEqDataServiceImpl.java
View File

@ -1,71 +0,0 @@
package com.yfd.platform.eng.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.eng.service.EngEqDataService;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Map;
/**
* 生态流量数据服务实现
*/
@Service
public class EngEqDataServiceImpl implements EngEqDataService {
@Override
public DataSourceResult processKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult dataSourceResult) {
// 处理字典匹配，实际应该根据业务需求实现
}
@Override
public String processGroupConditionSql(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult) {
// 模拟SQL条件，实际应该根据业务需求实现
return "1=1";
}
@Override
public DataSourceResult processDayKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page, String groupBy) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public DataSourceResult processKendoDrtpList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page, String groupBy) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public DataSourceResult getFastSiteLastData(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page, String groupBy) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public Object getEngLimit(DataSourceRequest dataSourceRequest) {
// 模拟数据，实际应该从数据库查询
return null;
}
}

169
backend/src/main/java/com/yfd/platform/eng/service/impl/EngEqIntervalServiceImpl.java
View File

File diff suppressed because one or more lines are too long

158
backend/src/main/java/com/yfd/platform/eng/service/impl/EngEqServiceImpl.java
View File

@ -1,158 +0,0 @@
package com.yfd.platform.eng.service.impl;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.common.*;
import com.yfd.platform.eng.domain.MsEngEq;
import com.yfd.platform.eng.mapper.EngEqMapper;
import com.yfd.platform.eng.service.EngEqService;
import com.yfd.platform.utils.KendoUtil;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import java.util.*;
/**
* 生态流量服务实现
*/
@Service
public class EngEqServiceImpl extends ServiceImpl<EngEqMapper, MsEngEq> implements EngEqService {
@Resource
MicroservicDynamicSQLMapper microservicDynamicSQLMapper;
@Override
public DataSourceResult processKendoList(DataSourceRequest dataSourceRequest, Map<String, GroupResult> filterResult, Page page) {
DataSourceResult dataSourceResult = new DataSourceResult<>();
StringBuilder sql = new StringBuilder();
String kendoGroupCode = "default";
String kendoGroupCode2 = "TM";
if (filterResult.get(kendoGroupCode) !=null && StrUtil.isNotBlank(filterResult.get(kendoGroupCode).getSelectSql())) {
sql.append(filterResult.get("default").getSelectSql());
if (filterResult.get(kendoGroupCode2) !=null && StrUtil.isNotBlank(filterResult.get(kendoGroupCode2).getSelectSql())) {
sql.append(StrUtil.replace(filterResult.get(kendoGroupCode2).getSelectSql(),"select",","));
}
sql.append(",MET1.QEC beforeQec FROM ");
sql.append(" MS_ENG_T MET left join MS_ENG_T MET1 on MET1.stcd=MET.stcd and MET1.TYPE=met.type and add_months(MET1.TM,12)=met.tm inner join V_MS_STBPRP_T MSB on MSB.STCD=MET.STCD where MSB.STTP_CODE = 'ENG' and MSB.BLDSTT_CCODE = 2 ");//去掉大中型电站过滤条件
}
if (filterResult.get(kendoGroupCode) !=null && StrUtil.isNotBlank(filterResult.get(kendoGroupCode).getGroupSql())) {
sql.append(" and ").append(filterResult.get(kendoGroupCode).getGroupSql());
}
if (filterResult.get(kendoGroupCode2) != null && StrUtil.isNotBlank(filterResult.get(kendoGroupCode2).getGroupSql())) {
sql.append(" and ").append(filterResult.get(kendoGroupCode2).getGroupSql());
}
if (filterResult.get(kendoGroupCode2) !=null && StrUtil.isNotBlank(filterResult.get(kendoGroupCode2).getOrderBySql())) {
sql.append(" ").append(filterResult.get(kendoGroupCode2).getOrderBySql());
}
//组装分组条件
String groupBy = KendoUtil.getGroupBy(dataSourceRequest);
GroupingInfo[] group = dataSourceRequest.toDevRequest().getGroup();
if (StrUtil.isNotBlank(groupBy)) {
StringBuilder temp = new StringBuilder("select ");
List<String> groupFields = new ArrayList<>();
for (GroupingInfo item : group) {
groupFields.add(item.getSelector());
}
temp.append(StrUtil.join(",",groupFields));
for (GroupingInfo item : group) {
groupFields.add(item.getSelector());
temp.append(",").append("count(*) as count_").append(item.getSelector());
}
sql = temp.append(" from ( ").append(sql).append(" ) ").append(groupBy);
}
if (filterResult.get(kendoGroupCode) !=null && StrUtil.isNotBlank(filterResult.get(kendoGroupCode).getOrderBySql())) {
sql.append(" ").append(filterResult.get(kendoGroupCode).getOrderBySql());
}
//组装map参数
Map<String, Object> map = new HashMap<>();
for (String key : filterResult.keySet()) {
map.putAll(filterResult.get(key).getParamMap());
}
if (StrUtil.isNotBlank(groupBy)) {
List<Map<String, Object>> list = microservicDynamicSQLMapper.pageAllList(page, sql.toString(), map);
//是否扁平化分组
if (null != dataSourceRequest.getGroupResultFlat() && dataSourceRequest.getGroupResultFlat()) {
dataSourceResult.setData((new GroupHelper()).faltGroup(list, Arrays.asList(group)));
} else {
dataSourceResult.setData((new GroupHelper()).group(list, Arrays.asList(group)));
}
dataSourceResult.setTotal(0);
return dataSourceResult;
}
List<MsEngEq> list = microservicDynamicSQLMapper.pageAllListWithResultType(page, sql.toString(), map,MsEngEq.class);
dataSourceResult.setData(list);
dataSourceResult.setTotal(ObjectUtil.isNotEmpty(page) ? page.getTotal() : (long) list.size());
return dataSourceResult;
}
@Override
public void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult dataSourceResult) {
// 处理字典匹配，实际应该根据业务需求实现
}
@Override
public String processGroupConditionSql(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult) {
// 模拟SQL条件，实际应该根据业务需求实现
return "1=1";
}
@Override
public DataSourceResult lastEngDataSite(DataSourceRequest dataSourceRequest) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public DataSourceResult getDefaultStcd(DataSourceRequest dataSourceRequest) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public DataSourceResult getSfdbInfo(DataSourceRequest dataSourceRequest) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public DataSourceResult qecSfdbCountByStcd(DataSourceRequest dataSourceRequest) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public DataSourceResult qecRateCount(DataSourceRequest dataSourceRequest) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
@Override
public DataSourceResult qecSfdbCount(DataSourceRequest dataSourceRequest) {
// 模拟数据，实际应该从数据库查询
DataSourceResult result = new DataSourceResult();
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
}

59
backend/src/main/java/com/yfd/platform/eng/service/impl/EngSpecialServiceImpl.java
View File

@ -1,59 +0,0 @@
package com.yfd.platform.eng.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.eng.entity.EqSpecial;
import com.yfd.platform.eng.service.EngSpecialService;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* 电站专题-环保设施运行情况服务实现
*/
@Service
public class EngSpecialServiceImpl implements EngSpecialService {
@Override
public DataSourceResult<EqSpecial> processKendoList(DataSourceRequest dataSourceRequest, Map<String, Object> filterResult, Page page) {
// 模拟数据，实际应该从数据库查询
List<EqSpecial> dataList = new ArrayList<>();
// 模拟添加一些数据
EqSpecial special1 = new EqSpecial();
special1.setId("1");
special1.setStcd("ST001");
special1.setStnm("电站1");
special1.setEqType("生态流量监测设施");
special1.setEqName("流量监测仪");
special1.setStatus("正常运行");
special1.setCheckTime("2023-04-14");
special1.setChecker("张三");
special1.setRemark("无");
dataList.add(special1);
EqSpecial special2 = new EqSpecial();
special2.setId("2");
special2.setStcd("ST002");
special2.setStnm("电站2");
special2.setEqType("水质监测设施");
special2.setEqName("水质分析仪");
special2.setStatus("正常运行");
special2.setCheckTime("2023-04-15");
special2.setChecker("李四");
special2.setRemark("无");
dataList.add(special2);
DataSourceResult<EqSpecial> result = new DataSourceResult<>();
result.setData(dataList);
result.setTotal(dataList.size());
return result;
}
@Override
public void processKendoGetListLoadResult(DataSourceRequest dataSourceRequest, DataSourceResult<EqSpecial> dataSourceResult) {
// 处理字典匹配，实际应该根据业务需求实现
}
}

10
backend/src/main/java/com/yfd/platform/env/fp/service/FpBuildService.java vendored
View File

@ -1,10 +0,0 @@
package com.yfd.platform.env.fp.service;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.env.fp.entity.vo.FpConstructionSituationVo;
public interface FpBuildService {
DataSourceResult<FpConstructionSituationVo> processKendoList(DataSourceRequest dataSourceRequest);
}

54
backend/src/main/java/com/yfd/platform/env/fp/service/impl/FpBuildServiceImpl.java vendored
View File

@ -1,54 +0,0 @@
package com.yfd.platform.env.fp.service.impl;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceLoadOptionsBase;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.common.MicroservicDynamicSQLMapper;
import com.yfd.platform.common.PageInfo;
import com.yfd.platform.env.fp.entity.vo.FpConstructionSituationVo;
import com.yfd.platform.env.fp.service.FpBuildService;
import com.yfd.platform.utils.QgcQueryWrapperUtil;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
@Service
public class FpBuildServiceImpl implements FpBuildService {
@Resource
private MicroservicDynamicSQLMapper microservicDynamicSQLMapper;
@Override
public DataSourceResult<FpConstructionSituationVo> processKendoList(DataSourceRequest dataSourceRequest) {
DataSourceLoadOptionsBase loadOptions = dataSourceRequest.toDevRequest();
PageInfo pageInfo = QgcQueryWrapperUtil.getPageInfo(loadOptions);
Page<?> page = pageInfo.getHasPageInfo() ? pageInfo.getPage() : null;
String sql = "SELECT t.STTP AS sttpCode, " +
" SUM(CASE WHEN t.DTIN = 1 THEN 1 ELSE 0 END) AS bonusing, " +
" SUM(CASE WHEN t.DTIN = 1 AND t.BLDSTT_CODE = 2 THEN 1 ELSE 0 END) AS builtConnected, " +
" SUM(CASE WHEN t.BLDSTT_CODE = 2 THEN 1 ELSE 0 END) AS built, " +
" SUM(CASE WHEN t.DTIN = 1 AND t.BLDSTT_CODE = 1 THEN 1 ELSE 0 END) AS buildingConnected, " +
" SUM(CASE WHEN t.BLDSTT_CODE = 1 THEN 1 ELSE 0 END) AS building, " +
" SUM(CASE WHEN NVL(t.BLDSTT_CODE, 0) = 0 THEN 1 ELSE 0 END) AS noBuilt " +
"FROM SD_FPSS_B_H t " +
"GROUP BY t.STTP " +
"ORDER BY t.STTP";
List<FpConstructionSituationVo> list = microservicDynamicSQLMapper.pageAllListWithResultType(
page,
sql,
new HashMap<>(),
FpConstructionSituationVo.class
);
DataSourceResult<FpConstructionSituationVo> result = new DataSourceResult<>();
result.setData(list);
result.setTotal(page != null ? page.getTotal() : list.size());
result.setAggregates(new HashMap<>());
return result;
}
}

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

@ -1,197 +0,0 @@
package com.yfd.platform.env.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.data.domain.SysUserDataScope;
import com.yfd.platform.data.mapper.SysUserDataScopeMapper;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.domain.SdEngInfoBHRequest;
import com.yfd.platform.env.mapper.SdEngInfoBHMapper;
import com.yfd.platform.env.service.ISdEngInfoBHService;
import com.yfd.platform.utils.SecurityUtils;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
/**
* <p>
* 水电水利工程基础信息表 服务实现类
* </p>
*/
@Service
public class SdEngInfoBHServiceImpl extends ServiceImpl<SdEngInfoBHMapper, SdEngInfoBH> implements ISdEngInfoBHService {
@Resource
private SdEngInfoBHMapper engInfoBHMapper;
@Resource
private SysUserDataScopeMapper sysUserDataScopeMapper;
@Override
public Page<SdEngInfoBH> queryPageList(Page<SdEngInfoBH> page, String ennm, String rvcd, String baseId, String hycd) {
LambdaQueryWrapper<SdEngInfoBH> wrapper = new LambdaQueryWrapper<>();
wrapper .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);
Set<String> authorizedStations = getUserAuthorizedStationCodes();
if (authorizedStations != null && !authorizedStations.isEmpty()) {
wrapper.in(SdEngInfoBH::getStcd, authorizedStations);
}else if (!"admin".equals(SecurityUtils.getCurrentUsername())){
return page;
}
return this.page(page, wrapper);
}
@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 List<SdEngInfoBH> selectForDropdown(SdEngInfoBHRequest sdEngInfoBHRequest) {
String baseId = sdEngInfoBHRequest.getBaseId();
String hbrvcd = sdEngInfoBHRequest.getHbrvcd();
String ennm = sdEngInfoBHRequest.getEnnm();
List<String> rvcds = sdEngInfoBHRequest.getRvcds();
List<String> hbrvcds = sdEngInfoBHRequest.getHbrvcds();
LambdaQueryWrapper<SdEngInfoBH> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(StringUtils.hasText(baseId), SdEngInfoBH::getBaseId, baseId)
.eq(StringUtils.hasText(hbrvcd), SdEngInfoBH::getHbrvcd, hbrvcd)
.in(rvcds != null && !rvcds.isEmpty(), SdEngInfoBH::getRvcd, rvcds)
.in(hbrvcds != null && !hbrvcds.isEmpty(), SdEngInfoBH::getHbrvcd, hbrvcds)
.like(StringUtils.hasText(ennm), SdEngInfoBH::getEnnm, ennm)
.select(SdEngInfoBH::getStcd, SdEngInfoBH::getEnnm, SdEngInfoBH::getBaseId)
.orderByAsc(SdEngInfoBH::getOrderIndex);
if("admin".equals(SecurityUtils.getCurrentUsername())){
return this.list(wrapper);
}
Set<String> authorizedStations = getUserAuthorizedStationCodes();
if (authorizedStations != null && !authorizedStations.isEmpty()) {
List<SdEngInfoBH> list = this.list(wrapper);
return list.stream()
.filter(item -> authorizedStations.contains(item.getStcd()))
.collect(Collectors.toList());
}else{
return new ArrayList<>();
}
}
@Override
public Set<String> getUserAuthorizedStationCodes() {
String userId = SecurityUtils.getUserId();
List<SysUserDataScope> sysUserDataScopes = sysUserDataScopeMapper.selectList(
new LambdaQueryWrapper<SysUserDataScope>()
.eq(SysUserDataScope::getUserId, userId)
.select(SysUserDataScope::getOrgId, SysUserDataScope::getOrgType)
);
if (sysUserDataScopes == null || sysUserDataScopes.isEmpty()) {
return new HashSet<>();
}
Set<String> stationCodes = new HashSet<>();
Set<String> basinCodes = new HashSet<>();
for (SysUserDataScope scope : sysUserDataScopes) {
String orgType = scope.getOrgType();
String orgId = scope.getOrgId();
if ("STATION".equals(orgType)) {
SdEngInfoBH station = engInfoBHMapper.selectById(orgId);
if (station != null) {
if (station.getHbrvcd() != null) {
basinCodes.add(station.getHbrvcd());
}
if (station.getStcd() != null) {
stationCodes.add(station.getStcd());
}
}
} else if ("HBRVCD".equals(orgType)) {
List<SdEngInfoBH> stationList = engInfoBHMapper.selectByHbrvcd(orgId);
if (stationList != null) {
for (SdEngInfoBH station : stationList) {
if (station.getStcd() != null) {
stationCodes.add(station.getStcd());
}
if (station.getEnnm() != null) {
basinCodes.add(station.getHbrvcd());
}
}
}
}
}
if (!stationCodes.isEmpty()) {
return stationCodes;
}
if (!basinCodes.isEmpty()) {
List<SdEngInfoBH> engInfos = this.lambdaQuery()
.select(SdEngInfoBH::getStcd)
.in(SdEngInfoBH::getHbrvcd, basinCodes)
.list();
return engInfos.stream()
.map(SdEngInfoBH::getStcd)
.collect(Collectors.toSet());
}
return stationCodes;
}
@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);
}
@Override
public List<SdEngInfoBH> selectRegDropdown(SdEngInfoBHRequest sdEngInfoBHRequest) {
String baseId = sdEngInfoBHRequest.getBaseId();
String ennm = sdEngInfoBHRequest.getEnnm();
String hbrvcd = sdEngInfoBHRequest.getHbrvcd();
List<String> rvcds = sdEngInfoBHRequest.getRvcds();
List<String> hbrvcds = sdEngInfoBHRequest.getHbrvcds();
LambdaQueryWrapper<SdEngInfoBH> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(StringUtils.hasText(baseId), SdEngInfoBH::getBaseId, baseId)
.eq(StringUtils.hasText(hbrvcd), SdEngInfoBH::getHbrvcd, hbrvcd)
.in(rvcds != null && !rvcds.isEmpty(), SdEngInfoBH::getRvcd, rvcds)
.in(hbrvcds != null && !hbrvcds.isEmpty(), SdEngInfoBH::getHbrvcd, hbrvcds)
.like(StringUtils.hasText(ennm), SdEngInfoBH::getEnnm, ennm)
.select(SdEngInfoBH::getStcd, SdEngInfoBH::getEnnm, SdEngInfoBH::getBaseId)
.orderByAsc(SdEngInfoBH::getOrderIndex);
return this.list(wrapper);
}
}

6
backend/src/main/java/com/yfd/platform/env/controller/FpssRController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/FpssRController.java
View File

@ -1,9 +1,9 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdFpssR;
import com.yfd.platform.env.service.ISdFpssRService;
import com.yfd.platform.qgc_base.domain.SdFpssR;
import com.yfd.platform.qgc_base.service.ISdFpssRService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;

7
backend/src/main/java/com/yfd/platform/env/controller/SdCountryBController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/SdCountryBController.java
View File

@ -1,15 +1,14 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.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 com.yfd.platform.qgc_base.domain.SdCountryB;
import com.yfd.platform.qgc_base.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>

9
backend/src/main/java/com/yfd/platform/env/controller/SdEngInfoBHController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/SdEngInfoBHController.java
View File

@ -1,17 +1,16 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.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.domain.SdEngInfoBHRequest;
import com.yfd.platform.env.service.ISdEngInfoBHService;
import com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import com.yfd.platform.qgc_base.domain.SdEngInfoBHRequest;
import com.yfd.platform.qgc_base.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>

35
backend/src/main/java/com/yfd/platform/qgc_base/controller/SdEngMonitorController.java Normal file
View File

@ -0,0 +1,35 @@
package com.yfd.platform.qgc_base.controller;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.qgc_base.service.ISdEngInfoBHService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/eng/base")
@Tag(name = "电站基础监测")
public class SdEngMonitorController {
@Resource
private ISdEngInfoBHService engInfoBHService;
@GetMapping("/msstbprpt/getStInfoByStcd")
@Operation(summary = "根据站码查询单条电站基础数据")
public ResponseResult getStInfoByStcd(@RequestParam String stcd) {
return ResponseResult.successData(engInfoBHService.getStInfoByStcd(stcd));
}
@PostMapping("/eiaapproval/GetKendoList")
@Operation(summary = "查询生态环保批复文件列表")
public ResponseResult getEiaapprovalKendoList(@RequestBody DataSourceRequest dataSourceRequest) {
return ResponseResult.successData(engInfoBHService.getEiaapprovalKendoList(dataSourceRequest));
}
}

7
backend/src/main/java/com/yfd/platform/env/controller/SdFishDictoryBController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/SdFishDictoryBController.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.controller;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@ -6,15 +6,14 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdFishDictoryB;
import com.yfd.platform.env.service.ISdFishDictoryBService;
import com.yfd.platform.qgc_base.domain.SdFishDictoryB;
import com.yfd.platform.qgc_base.service.ISdFishDictoryBService;
import com.yfd.platform.utils.DataSourceRequestUtil;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.springframework.web.bind.annotation.*;
import java.util.Arrays;
import java.util.List;
/**

8
backend/src/main/java/com/yfd/platform/env/controller/SdFpssBHController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/SdFpssBHController.java
View File

@ -1,17 +1,15 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.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.SdFpssBH;
import com.yfd.platform.env.service.ISdFpssBHService;
import com.yfd.platform.qgc_base.domain.SdFpssBH;
import com.yfd.platform.qgc_base.service.ISdFpssBHService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* <p>
* 过鱼设施表 前端控制器

6
backend/src/main/java/com/yfd/platform/env/controller/SdHbrvDicController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/SdHbrvDicController.java
View File

@ -1,10 +1,10 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.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.SdHbrvDic;
import com.yfd.platform.env.service.ISdHbrvDicService;
import com.yfd.platform.qgc_base.domain.SdHbrvDic;
import com.yfd.platform.qgc_base.service.ISdHbrvDicService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.*;

6
backend/src/main/java/com/yfd/platform/env/controller/SdHycdDicController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/SdHycdDicController.java
View File

@ -1,10 +1,10 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.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 com.yfd.platform.qgc_base.domain.SdHycdDic;
import com.yfd.platform.qgc_base.service.ISdHycdDicService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.*;

6
backend/src/main/java/com/yfd/platform/env/controller/SdHydrobaseController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/SdHydrobaseController.java
View File

@ -1,11 +1,11 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.env.service.ISdHydrobaseService;
import com.yfd.platform.qgc_base.domain.SdHydrobase;
import com.yfd.platform.qgc_base.service.ISdHydrobaseService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;

6
backend/src/main/java/com/yfd/platform/env/controller/SdRvcdDicController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/SdRvcdDicController.java
View File

@ -1,11 +1,11 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.domain.SdRvcdDic;
import com.yfd.platform.env.service.ISdRvcdDicService;
import com.yfd.platform.qgc_base.domain.SdRvcdDic;
import com.yfd.platform.qgc_base.service.ISdRvcdDicService;
import com.yfd.platform.utils.DataSourceRequestUtil;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;

4
backend/src/main/java/com/yfd/platform/env/controller/TreeStructureController.java → backend/src/main/java/com/yfd/platform/qgc_base/controller/TreeStructureController.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.controller;
package com.yfd.platform.qgc_base.controller;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.env.service.ITreeStructureService;
import com.yfd.platform.qgc_base.service.ITreeStructureService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.GetMapping;

2
backend/src/main/java/com/yfd/platform/env/domain/SdCountryB.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdCountryB.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdEngInfoBH.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdEngInfoBH.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdEngInfoBHRequest.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdEngInfoBHRequest.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import lombok.AllArgsConstructor;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdFishDictoryB.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdFishDictoryB.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdFpssBH.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdFpssBH.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;

2
backend/src/main/java/com/yfd/platform/env/domain/SdFpssR.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdFpssR.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;

2
backend/src/main/java/com/yfd/platform/env/domain/SdHbrvDic.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdHbrvDic.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdHycdDic.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdHycdDic.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdHydrobase.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdHydrobase.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdPraddRltnB.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdPraddRltnB.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdPrhbrltnB.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdPrhbrltnB.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/domain/SdPrhyrltnB.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdPrhyrltnB.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

3
backend/src/main/java/com/yfd/platform/env/domain/SdRvcdDic.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/SdRvcdDic.java
View File

@ -1,11 +1,10 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
/**

2
backend/src/main/java/com/yfd/platform/env/domain/StationBasinInfo.java → backend/src/main/java/com/yfd/platform/qgc_base/domain/StationBasinInfo.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.domain;
package com.yfd.platform.qgc_base.domain;
import lombok.Data;

103
backend/src/main/java/com/yfd/platform/qgc_base/domain/vo/EngBaseInfoVo.java Normal file
View File

@ -0,0 +1,103 @@
package com.yfd.platform.qgc_base.domain.vo;
import com.baomidou.mybatisplus.annotation.TableField;
import com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import lombok.EqualsAndHashCode;
@Data
@EqualsAndHashCode(callSuper = true)
@Schema(description = "电站基础详情")
public class EngBaseInfoVo extends SdEngInfoBH {
@Schema(description = "主键ID")
private String id;
@Schema(description = "站名")
private String stnm;
@Schema(description = "站类主键")
private String sttp;
@Schema(description = "站类编码")
private String sttpCode;
@Schema(description = "站类名称")
private String sttpName;
@Schema(description = "站类全路径")
private String sttpFullPath;
@Schema(description = "站类层级")
private Integer sttpTreeLevel;
@Schema(description = "建设阶段编码")
private String blprdCode;
@Schema(description = "建设阶段名称")
private String blprdName;
@Schema(description = "建设阶段分类编码")
private String blprdCcode;
@Schema(description = "建设阶段分类名称")
private String blprdCname;
@Schema(description = "基地名称")
private String baseName;
@Schema(description = "基地流域名称")
private String hbrvcdName;
@Schema(description = "流域名称")
private String rvcdName;
@Schema(description = "流域全路径")
private String rvcdFullPath;
@Schema(description = "行政区名称")
private String addvcdName;
@Schema(description = "行政区全路径")
private String addvcdFullPath;
@Schema(description = "国家名称")
private String countryName;
@Schema(description = "公司名称")
private String hynm;
@Schema(description = "集团名称")
private String topHynm;
@Schema(description = "数据接入中文")
private String dtinName;
@Schema(description = "建设状态名称")
private String bldsttName;
@Schema(description = "建设状态分类编码")
private String bldsttCcode;
@Schema(description = "建设状态分类名称")
private String bldsttCcodeName;
@Schema(description = "开发方式名称")
private String dvtpName;
@Schema(description = "调节性能名称")
private String rgcpName;
@Schema(description = "工程类别名称")
private String engtpName;
@Schema(description = "工程规模名称")
private String prscName;
@Schema(description = "工程规模库容名称")
private String scrscName;
@Schema(description = "工程等别名称")
private String prgrName;
}

125
backend/src/main/java/com/yfd/platform/qgc_base/domain/vo/EngEiaapprovalVo.java Normal file
View File

@ -0,0 +1,125 @@
package com.yfd.platform.qgc_base.domain.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.util.Date;
@Data
@Schema(description = "生态环保批复文件列表")
public class EngEiaapprovalVo {
@Schema(description = "主键ID")
private String id;
@Schema(description = "流域")
private String basin;
@Schema(description = "河流")
private String river;
@Schema(description = "电站")
private String hydropowerStation;
@Schema(description = "电站建设状态中文")
private String bldsttCName;
@Schema(description = "批复文号")
private String approvalFileNo;
@Schema(description = "批复文件标题")
private String approvalFileTitle;
@Schema(description = "文件名")
private String fileName;
@Schema(description = "附件路径")
private String flpath;
@Schema(description = "生态流量")
private String ecologicalFlow;
@Schema(description = "水环境保护措施")
private String waterEnvProtection;
@Schema(description = "低温水减缓措施")
private String coldWaterMitigation;
@Schema(description = "栖息地保护")
private String habitatProtection;
@Schema(description = "过鱼措施")
private String fishPassageMeasures;
@Schema(description = "鱼类增殖放流")
private String fishStocking;
@Schema(description = "陆生生态保护/水土保持措施")
private String terrestrialEcoSoilCons;
@Schema(description = "珍稀植物保护措施")
private String rarePlantProtection;
@Schema(description = "动物救助")
private String animalRescue;
@Schema(description = "移民安置")
private String resettlementMeasures;
@Schema(description = "施工期防治措施或其他环境保护措施")
private String constructionPollutionCtrl;
@Schema(description = "地下水及地质环境保护措施")
private String groundwaterGeoProtect;
@Schema(description = "风景名胜区保护措施")
private String scenicAreaProtection;
@Schema(description = "环境监测要求")
private String envMonitoringRequire;
@Schema(description = "基地编码")
private String baseid;
@Schema(description = "基地流域编码")
private String hbrvcd;
@Schema(description = "环评表中的电站编码")
private String eiaStcd;
@Schema(description = "电站编码")
private String stcd;
@Schema(description = "电站名称")
private String stnm;
@Schema(description = "电站类型")
private String sttp;
@Schema(description = "电站类型名称")
private String sttpName;
@Schema(description = "电站建设状态代码")
private String bldsttCcode;
@Schema(description = "电站建设状态")
private String bldstt;
@Schema(description = "经度")
private String lgtd;
@Schema(description = "纬度")
private String lttd;
@Schema(description = "基地排序")
private Integer baseStepSort;
@Schema(description = "流域排序")
private Integer rvcdStepSort;
@Schema(description = "电站排序")
private Integer rstcdStepSort;
@Schema(description = "站点排序")
private Integer siteStepSort;
}

2
backend/src/main/java/com/yfd/platform/env/entity/vo/BatchDeleteAo.java → backend/src/main/java/com/yfd/platform/qgc_base/entity/vo/BatchDeleteAo.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.entity.vo;
package com.yfd.platform.qgc_base.entity.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/entity/vo/DataParam.java → backend/src/main/java/com/yfd/platform/qgc_base/entity/vo/DataParam.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.entity.vo;
package com.yfd.platform.qgc_base.entity.vo;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/env/entity/vo/HydrobaseWbsVo.java → backend/src/main/java/com/yfd/platform/qgc_base/entity/vo/HydrobaseWbsVo.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.env.entity.vo;
package com.yfd.platform.qgc_base.entity.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

4
backend/src/main/java/com/yfd/platform/env/mapper/SdCountryBMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdCountryBMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdCountryB;
import com.yfd.platform.qgc_base.domain.SdCountryB;
/**
* <p>

6
backend/src/main/java/com/yfd/platform/env/mapper/SdEngInfoBHMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdEngInfoBHMapper.java
View File

@ -1,8 +1,8 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.domain.StationBasinInfo;
import com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import com.yfd.platform.qgc_base.domain.StationBasinInfo;
import org.apache.ibatis.annotations.Param;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/mapper/SdFishDictoryBMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdFishDictoryBMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdFishDictoryB;
import com.yfd.platform.qgc_base.domain.SdFishDictoryB;
import org.apache.ibatis.annotations.Mapper;
@Mapper

4
backend/src/main/java/com/yfd/platform/env/mapper/SdFpssBHMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdFpssBHMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdFpssBH;
import com.yfd.platform.qgc_base.domain.SdFpssBH;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;

4
backend/src/main/java/com/yfd/platform/env/mapper/SdFpssRMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdFpssRMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdFpssR;
import com.yfd.platform.qgc_base.domain.SdFpssR;
import org.apache.ibatis.annotations.Mapper;
/**

4
backend/src/main/java/com/yfd/platform/env/mapper/SdHbrvDicMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdHbrvDicMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdHbrvDic;
import com.yfd.platform.qgc_base.domain.SdHbrvDic;
import org.apache.ibatis.annotations.Param;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/mapper/SdHycdDicMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdHycdDicMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdHycdDic;
import com.yfd.platform.qgc_base.domain.SdHycdDic;
import org.apache.ibatis.annotations.Param;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/mapper/SdHydrobaseMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdHydrobaseMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.qgc_base.domain.SdHydrobase;
import org.apache.ibatis.annotations.Param;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/mapper/SdPrhbrltnBMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdPrhbrltnBMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdPrhbrltnB;
import com.yfd.platform.qgc_base.domain.SdPrhbrltnB;
import org.apache.ibatis.annotations.Param;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/mapper/SdPrhyrltnBMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdPrhyrltnBMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdPrhyrltnB;
import com.yfd.platform.qgc_base.domain.SdPrhyrltnB;
import org.apache.ibatis.annotations.Param;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/mapper/SdRvcdDicMapper.java → backend/src/main/java/com/yfd/platform/qgc_base/mapper/SdRvcdDicMapper.java
View File

@ -1,7 +1,7 @@
package com.yfd.platform.env.mapper;
package com.yfd.platform.qgc_base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yfd.platform.env.domain.SdRvcdDic;
import com.yfd.platform.qgc_base.domain.SdRvcdDic;
import org.apache.ibatis.annotations.Param;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/service/ISdCountryBService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdCountryBService.java
View File

@ -1,8 +1,8 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdCountryB;
import com.yfd.platform.qgc_base.domain.SdCountryB;
import java.util.List;

16
backend/src/main/java/com/yfd/platform/env/service/ISdEngInfoBHService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdEngInfoBHService.java
View File

@ -1,9 +1,13 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.domain.SdEngInfoBHRequest;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import com.yfd.platform.qgc_base.domain.SdEngInfoBHRequest;
import com.yfd.platform.qgc_base.domain.vo.EngBaseInfoVo;
import com.yfd.platform.qgc_base.domain.vo.EngEiaapprovalVo;
import java.util.List;
import java.util.Set;
@ -58,4 +62,8 @@ public interface ISdEngInfoBHService extends IService<SdEngInfoBH> {
boolean deleteEngInfo(String stcd);
List<SdEngInfoBH> selectRegDropdown(SdEngInfoBHRequest sdEngInfoBHRequest);
}
EngBaseInfoVo getStInfoByStcd(String stcd);
DataSourceResult<EngEiaapprovalVo> getEiaapprovalKendoList(DataSourceRequest dataSourceRequest);
}

4
backend/src/main/java/com/yfd/platform/env/service/ISdFishDictoryBService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdFishDictoryBService.java
View File

@ -1,8 +1,8 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdFishDictoryB;
import com.yfd.platform.qgc_base.domain.SdFishDictoryB;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/service/ISdFpssBHService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdFpssBHService.java
View File

@ -1,8 +1,8 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdFpssBH;
import com.yfd.platform.qgc_base.domain.SdFpssBH;
import java.util.List;
import java.util.Set;

4
backend/src/main/java/com/yfd/platform/env/service/ISdFpssRService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdFpssRService.java
View File

@ -1,8 +1,8 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdFpssR;
import com.yfd.platform.qgc_base.domain.SdFpssR;
/**
* <p>

4
backend/src/main/java/com/yfd/platform/env/service/ISdHbrvDicService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdHbrvDicService.java
View File

@ -1,8 +1,8 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdHbrvDic;
import com.yfd.platform.qgc_base.domain.SdHbrvDic;
import java.util.List;
import java.util.Set;

4
backend/src/main/java/com/yfd/platform/env/service/ISdHycdDicService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdHycdDicService.java
View File

@ -1,8 +1,8 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdHycdDic;
import com.yfd.platform.qgc_base.domain.SdHycdDic;
import java.util.List;

6
backend/src/main/java/com/yfd/platform/env/service/ISdHydrobaseService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdHydrobaseService.java
View File

@ -1,11 +1,11 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.env.entity.vo.HydrobaseWbsVo;
import com.yfd.platform.qgc_base.domain.SdHydrobase;
import com.yfd.platform.qgc_base.entity.vo.HydrobaseWbsVo;
import java.util.List;
import java.util.Set;

4
backend/src/main/java/com/yfd/platform/env/service/ISdRvcdDicService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ISdRvcdDicService.java
View File

@ -1,8 +1,8 @@
package com.yfd.platform.env.service;
package com.yfd.platform.qgc_base.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yfd.platform.env.domain.SdRvcdDic;
import com.yfd.platform.qgc_base.domain.SdRvcdDic;
import java.util.List;

4
backend/src/main/java/com/yfd/platform/env/service/ITreeStructureService.java → backend/src/main/java/com/yfd/platform/qgc_base/service/ITreeStructureService.java
View File

@ -1,6 +1,4 @@
package com.yfd.platform.env.service;
import com.yfd.platform.env.domain.SdEngInfoBH;
package com.yfd.platform.qgc_base.service;
import java.util.List;
import java.util.Map;

8
backend/src/main/java/com/yfd/platform/env/service/impl/SdCountryBServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdCountryBServiceImpl.java
View File

@ -1,10 +1,10 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.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 com.yfd.platform.qgc_base.domain.SdCountryB;
import com.yfd.platform.qgc_base.mapper.SdCountryBMapper;
import com.yfd.platform.qgc_base.service.ISdCountryBService;
import org.springframework.stereotype.Service;
import java.util.List;

731
backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdEngInfoBHServiceImpl.java Normal file
View File

@ -0,0 +1,731 @@
package com.yfd.platform.qgc_base.service.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.common.MicroservicDynamicSQLMapper;
import com.yfd.platform.qgc_data.domain.SysUserDataScope;
import com.yfd.platform.qgc_data.mapper.SysUserDataScopeMapper;
import com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import com.yfd.platform.qgc_base.domain.SdEngInfoBHRequest;
import com.yfd.platform.qgc_base.domain.vo.EngBaseInfoVo;
import com.yfd.platform.qgc_base.domain.vo.EngEiaapprovalVo;
import com.yfd.platform.qgc_base.mapper.SdEngInfoBHMapper;
import com.yfd.platform.qgc_base.service.ISdEngInfoBHService;
import com.yfd.platform.utils.SecurityUtils;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
/**
* <p>
* 水电水利工程基础信息表 服务实现类
* </p>
*/
@Service
public class SdEngInfoBHServiceImpl extends ServiceImpl<SdEngInfoBHMapper, SdEngInfoBH> implements ISdEngInfoBHService {
@Resource
private SdEngInfoBHMapper engInfoBHMapper;
@Resource
private MicroservicDynamicSQLMapper<?> microservicDynamicSQLMapper;
@Resource
private SysUserDataScopeMapper sysUserDataScopeMapper;
@Override
public Page<SdEngInfoBH> queryPageList(Page<SdEngInfoBH> page, String ennm, String rvcd, String baseId, String hycd) {
LambdaQueryWrapper<SdEngInfoBH> wrapper = new LambdaQueryWrapper<>();
wrapper .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);
Set<String> authorizedStations = getUserAuthorizedStationCodes();
if (authorizedStations != null && !authorizedStations.isEmpty()) {
wrapper.in(SdEngInfoBH::getStcd, authorizedStations);
}else if (!"admin".equals(SecurityUtils.getCurrentUsername())){
return page;
}
return this.page(page, wrapper);
}
@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 List<SdEngInfoBH> selectForDropdown(SdEngInfoBHRequest sdEngInfoBHRequest) {
String baseId = sdEngInfoBHRequest.getBaseId();
String hbrvcd = sdEngInfoBHRequest.getHbrvcd();
String ennm = sdEngInfoBHRequest.getEnnm();
List<String> rvcds = sdEngInfoBHRequest.getRvcds();
List<String> hbrvcds = sdEngInfoBHRequest.getHbrvcds();
LambdaQueryWrapper<SdEngInfoBH> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(StringUtils.hasText(baseId), SdEngInfoBH::getBaseId, baseId)
.eq(StringUtils.hasText(hbrvcd), SdEngInfoBH::getHbrvcd, hbrvcd)
.in(rvcds != null && !rvcds.isEmpty(), SdEngInfoBH::getRvcd, rvcds)
.in(hbrvcds != null && !hbrvcds.isEmpty(), SdEngInfoBH::getHbrvcd, hbrvcds)
.like(StringUtils.hasText(ennm), SdEngInfoBH::getEnnm, ennm)
.select(SdEngInfoBH::getStcd, SdEngInfoBH::getEnnm, SdEngInfoBH::getBaseId)
.orderByAsc(SdEngInfoBH::getOrderIndex);
if("admin".equals(SecurityUtils.getCurrentUsername())){
return this.list(wrapper);
}
Set<String> authorizedStations = getUserAuthorizedStationCodes();
if (authorizedStations != null && !authorizedStations.isEmpty()) {
List<SdEngInfoBH> list = this.list(wrapper);
return list.stream()
.filter(item -> authorizedStations.contains(item.getStcd()))
.collect(Collectors.toList());
}else{
return new ArrayList<>();
}
}
@Override
public Set<String> getUserAuthorizedStationCodes() {
String userId = SecurityUtils.getUserId();
List<SysUserDataScope> sysUserDataScopes = sysUserDataScopeMapper.selectList(
new LambdaQueryWrapper<SysUserDataScope>()
.eq(SysUserDataScope::getUserId, userId)
.select(SysUserDataScope::getOrgId, SysUserDataScope::getOrgType)
);
if (sysUserDataScopes == null || sysUserDataScopes.isEmpty()) {
return new HashSet<>();
}
Set<String> stationCodes = new HashSet<>();
Set<String> basinCodes = new HashSet<>();
for (SysUserDataScope scope : sysUserDataScopes) {
String orgType = scope.getOrgType();
String orgId = scope.getOrgId();
if ("STATION".equals(orgType)) {
SdEngInfoBH station = engInfoBHMapper.selectById(orgId);
if (station != null) {
if (station.getHbrvcd() != null) {
basinCodes.add(station.getHbrvcd());
}
if (station.getStcd() != null) {
stationCodes.add(station.getStcd());
}
}
} else if ("HBRVCD".equals(orgType)) {
List<SdEngInfoBH> stationList = engInfoBHMapper.selectByHbrvcd(orgId);
if (stationList != null) {
for (SdEngInfoBH station : stationList) {
if (station.getStcd() != null) {
stationCodes.add(station.getStcd());
}
if (station.getEnnm() != null) {
basinCodes.add(station.getHbrvcd());
}
}
}
}
}
if (!stationCodes.isEmpty()) {
return stationCodes;
}
if (!basinCodes.isEmpty()) {
List<SdEngInfoBH> engInfos = this.lambdaQuery()
.select(SdEngInfoBH::getStcd)
.in(SdEngInfoBH::getHbrvcd, basinCodes)
.list();
return engInfos.stream()
.map(SdEngInfoBH::getStcd)
.collect(Collectors.toSet());
}
return stationCodes;
}
@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);
}
@Override
public List<SdEngInfoBH> selectRegDropdown(SdEngInfoBHRequest sdEngInfoBHRequest) {
String baseId = sdEngInfoBHRequest.getBaseId();
String ennm = sdEngInfoBHRequest.getEnnm();
String hbrvcd = sdEngInfoBHRequest.getHbrvcd();
List<String> rvcds = sdEngInfoBHRequest.getRvcds();
List<String> hbrvcds = sdEngInfoBHRequest.getHbrvcds();
LambdaQueryWrapper<SdEngInfoBH> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(StringUtils.hasText(baseId), SdEngInfoBH::getBaseId, baseId)
.eq(StringUtils.hasText(hbrvcd), SdEngInfoBH::getHbrvcd, hbrvcd)
.in(rvcds != null && !rvcds.isEmpty(), SdEngInfoBH::getRvcd, rvcds)
.in(hbrvcds != null && !hbrvcds.isEmpty(), SdEngInfoBH::getHbrvcd, hbrvcds)
.like(StringUtils.hasText(ennm), SdEngInfoBH::getEnnm, ennm)
.select(SdEngInfoBH::getStcd, SdEngInfoBH::getEnnm, SdEngInfoBH::getBaseId)
.orderByAsc(SdEngInfoBH::getOrderIndex);
return this.list(wrapper);
}
@Override
public DataSourceResult<EngEiaapprovalVo> getEiaapprovalKendoList(DataSourceRequest dataSourceRequest) {
DataSourceResult<EngEiaapprovalVo> result = new DataSourceResult<>();
result.setAggregates(new HashMap<>());
if (dataSourceRequest == null) {
result.setData(new ArrayList<>());
result.setTotal(0L);
return result;
}
// if (!"admin".equals(SecurityUtils.getCurrentUsername())) {
// Set<String> authorizedStations = getUserAuthorizedStationCodes();
// if (authorizedStations == null || authorizedStations.isEmpty()) {
// result.setData(new ArrayList<>());
// result.setTotal(0L);
// return result;
// }
// }
Page<?> page = null;
if (dataSourceRequest.getTake() > 0) {
page = new Page<>(dataSourceRequest.getSkip() / dataSourceRequest.getTake() + 1,
dataSourceRequest.getTake());
}
Map<String, Object> paramMap = new HashMap<>();
StringBuilder sql = new StringBuilder(buildEiaapprovalBaseSql());
// if (!"admin".equals(SecurityUtils.getCurrentUsername())) {
// appendAuthorizedStations(sql, paramMap, getUserAuthorizedStationCodes());
// }
String filterSql = buildEiaapprovalFilterCondition(dataSourceRequest.getFilter(), paramMap, new int[]{0});
if (StringUtils.hasText(filterSql)) {
sql.append(" AND ").append(filterSql);
}
sql.append(buildEiaapprovalOrderBySql(dataSourceRequest.getSort()));
List<EngEiaapprovalVo> list = microservicDynamicSQLMapper.pageAllListWithResultType(
page, sql.toString(), paramMap, EngEiaapprovalVo.class);
result.setData(list);
result.setTotal(page == null ? list.size() : page.getTotal());
return result;
}
@Override
public EngBaseInfoVo getStInfoByStcd(String stcd) {
SdEngInfoBH entity = this.getById(stcd);
if (entity == null) {
return null;
}
EngBaseInfoVo vo = new EngBaseInfoVo();
BeanUtil.copyProperties(entity, vo);
vo.setId(entity.getStcd());
vo.setStnm(entity.getEnnm());
String sql = "SELECT " +
"sttp.ID AS sttp, " +
"sttp.STTP_CODE AS sttpCode, " +
"sttp.STTP_NAME AS sttpName, " +
"sttp.FULL_PATH AS sttpFullPath, " +
"sttp.TREE_LEVEL AS sttpTreeLevel, " +
"hb.BASENAME AS baseName, " +
"hbrv.HBRVNM AS hbrvcdName, " +
"rv.RVNM AS rvcdName, " +
"rv.PATH AS rvcdFullPath, " +
"addv.ADDVNM AS addvcdName, " +
"addv.PATH AS addvcdFullPath, " +
"country.COUNTRY_NAME AS countryName, " +
"hy.HYNM AS hynm, " +
"topHy.HYNM AS topHynm " +
"FROM SD_ENGINFO_B_H eng " +
"LEFT JOIN SD_STTP_B sttp ON sttp.STTP_CODE = 'ENG' " +
" AND NVL(sttp.IS_DELETED, 0) = 0 " +
" AND NVL(sttp.ENABLE, 1) = 1 " +
"LEFT JOIN SD_HYDROBASE hb ON hb.BASEID = eng.BASE_ID " +
"LEFT JOIN SD_HBRV_DIC hbrv ON hbrv.HBRVCD = eng.HBRVCD AND hbrv.BASEID = eng.BASE_ID " +
" AND NVL(hbrv.ENABLED, 1) = 1 " +
"LEFT JOIN SD_RVCD_DIC rv ON rv.RVCD = eng.RVCD " +
"LEFT JOIN SD_ADDVCD_DIC addv ON addv.ADDVCD = eng.ADDVCD " +
"LEFT JOIN SD_COUNTRY_B country ON country.COUNTRY_ID = eng.COUNTRY AND NVL(country.ENABLED, 1) = 1 " +
"LEFT JOIN SD_HYCD_DIC hy ON hy.HYCD = eng.HYCD " +
"LEFT JOIN SD_HYCD_DIC topHy ON topHy.HYCD = eng.TOP_HYCD " +
"WHERE eng.STCD = #{map.stcd}";
EngBaseInfoVo extra = microservicDynamicSQLMapper.getOneBySqlWithResultType(
sql, java.util.Collections.singletonMap("stcd", stcd), EngBaseInfoVo.class);
if (extra != null) {
BeanUtil.copyProperties(extra, vo, CopyOptions.create().setIgnoreNullValue(true));
}
vo.setSttpCode("ENG");
vo.setBlprdCode(entity.getBlprd() == null ? null : String.valueOf(entity.getBlprd()));
vo.setBlprdCcode(entity.getBlprd() == null ? null : String.valueOf(entity.getBlprd()));
vo.setBlprdName(resolveBlprdName(entity.getBlprd()));
vo.setBlprdCname(vo.getBlprdName());
vo.setDtinName(resolveDtinName(entity.getDtin()));
vo.setBldsttName(resolveBldsttName(entity.getBldstt()));
vo.setBldsttCcode(entity.getBldsttCode() == null ? null : String.valueOf(entity.getBldsttCode()));
vo.setBldsttCcodeName(resolveBldsttCodeName(entity.getBldsttCode()));
vo.setDvtpName(resolveDvtpName(entity.getDvtp()));
vo.setRgcpName(resolveRgcpName(entity.getRgcp()));
vo.setEngtpName(resolveEngtpName(entity.getEngtp()));
vo.setPrscName(resolvePrscName(entity.getPrsc()));
vo.setScrscName(resolveScrscName(entity.getScrsc()));
vo.setPrgrName(resolvePrgrName(entity.getPrgr()));
return vo;
}
private String buildEiaapprovalBaseSql() {
return "SELECT " +
"e.ID AS id, " +
"e.BASIN AS basin, " +
"e.RIVER AS river, " +
"e.ENNM AS hydropowerStation, " +
"e.APPROVAL_FILE_NO AS approvalFileNo, " +
"e.APPROVAL_FILE_TITLE AS approvalFileTitle, " +
"e.FILE_NAME AS fileName, " +
"e.FLPATH AS flpath, " +
"e.ECOLOGICAL_FLOW AS ecologicalFlow, " +
"e.WATER_ENV_PROTECTION AS waterEnvProtection, " +
"e.COLD_WATER_MITIGATION AS coldWaterMitigation, " +
"e.HABITAT_PROTECTION AS habitatProtection, " +
"e.FISH_PASSAGE_MEASURES AS fishPassageMeasures, " +
"e.FISH_STOCKING AS fishStocking, " +
"e.TERRESTRIAL_ECO_SOIL_CONS AS terrestrialEcoSoilCons, " +
"e.RARE_PLANT_PROTECTION AS rarePlantProtection, " +
"e.ANIMAL_RESCUE AS animalRescue, " +
"e.RESETTLEMENT_MEASURES AS resettlementMeasures, " +
"e.CONSTRUCTION_POLLUTION_CTRL AS constructionPollutionCtrl, " +
"e.GROUNDWATER_GEO_PROTECT AS groundwaterGeoProtect, " +
"e.SCENIC_AREA_PROTECTION AS scenicAreaProtection, " +
"e.ENV_MONITORING_REQUIRE AS envMonitoringRequire, " +
"e.BASEID AS baseid, " +
"e.HBRVCD AS hbrvcd, " +
"e.STCD AS eiaStcd, " +
"s.STCD AS stcd, " +
"s.ENNM AS stnm, " +
"sttp.ID AS sttp, " +
"sttp.STTP_NAME AS sttpName, " +
"TO_CHAR(s.BLDSTT_CODE) AS bldsttCcode, " +
"s.BLDSTT AS bldstt, " +
"TO_CHAR(s.LGTD) AS lgtd, " +
"TO_CHAR(s.LTTD) AS lttd, " +
"CASE " +
"WHEN s.BLDSTT_CODE = 0 OR s.BLDSTT_CODE IS NULL THEN '未建/规划' " +
"WHEN s.BLDSTT_CODE = 1 THEN '在建' " +
"WHEN s.BLDSTT_CODE = 2 THEN '已建' " +
"ELSE NULL END AS bldsttCName, " +
"NVL(hb.ORDER_INDEX, 999999) AS baseStepSort, " +
"NVL(along.ORDER_INDEX, 999999) AS rvcdStepSort, " +
"NVL(rstSort.SORT, 999999) AS rstcdStepSort, " +
"NVL(siteSort.SORT, 999999) AS siteStepSort " +
"FROM MS_EIAAPPROVAL_B e " +
"LEFT JOIN SD_ENGINFO_B_H s ON e.STCD = s.STCD AND NVL(s.IS_DELETED, 0) = 0 " +
"LEFT JOIN SD_STTP_B sttp ON sttp.STTP_CODE = 'ENG' AND NVL(sttp.IS_DELETED, 0) = 0 AND NVL(sttp.ENABLE, 1) = 1 " +
"LEFT JOIN SD_HYDROBASE hb ON hb.BASEID = s.BASE_ID AND NVL(hb.IS_DELETED, 0) = 0 " +
"LEFT JOIN MS_ALONG_B along ON along.RVCD = s.HBRVCD AND along.CODE = 'common' AND NVL(along.IS_DELETED, 0) = 0 " +
"LEFT JOIN ( " +
" SELECT det.SORT, cfg.RVCD, det.STCD " +
" FROM MS_ALONGDET_B det " +
" INNER JOIN MS_ALONG_B cfg ON det.ALONG_ID = cfg.ID " +
" WHERE NVL(det.IS_DELETED, 0) = 0 AND NVL(cfg.IS_DELETED, 0) = 0 AND cfg.CODE = 'common' " +
") rstSort ON rstSort.RVCD = s.HBRVCD AND rstSort.STCD = s.STCD " +
"LEFT JOIN ( " +
" SELECT det.SORT, cfg.RVCD, det.STCD " +
" FROM MS_ALONGDET_B det " +
" INNER JOIN MS_ALONG_B cfg ON det.ALONG_ID = cfg.ID " +
" WHERE NVL(det.IS_DELETED, 0) = 0 AND NVL(cfg.IS_DELETED, 0) = 0 AND cfg.CODE = 'common' " +
") siteSort ON siteSort.RVCD = s.HBRVCD AND siteSort.STCD = s.STCD " +
"WHERE NVL(e.IS_DELETED, 0) = 0";
}
private void appendAuthorizedStations(StringBuilder sql, Map<String, Object> paramMap, Set<String> authorizedStations) {
if (authorizedStations == null || authorizedStations.isEmpty()) {
return;
}
List<String> placeholders = new ArrayList<>();
int index = 0;
for (String stcd : authorizedStations) {
String key = "authStcd" + index++;
paramMap.put(key, stcd);
placeholders.add("#{map." + key + "}");
}
sql.append(" AND e.STCD IN (").append(String.join(", ", placeholders)).append(")");
}
private String buildEiaapprovalFilterCondition(DataSourceRequest.FilterDescriptor filter,
Map<String, Object> paramMap,
int[] indexHolder) {
if (filter == null) {
return "";
}
if (StringUtils.hasText(filter.getField())) {
return buildEiaapprovalLeafCondition(filter, paramMap, indexHolder);
}
if (filter.getFilters() == null || filter.getFilters().isEmpty()) {
return "";
}
List<String> childConditions = new ArrayList<>();
for (DataSourceRequest.FilterDescriptor child : filter.getFilters()) {
String childSql = buildEiaapprovalFilterCondition(child, paramMap, indexHolder);
if (StringUtils.hasText(childSql)) {
childConditions.add("(" + childSql + ")");
}
}
if (childConditions.isEmpty()) {
return "";
}
String logic = "or".equalsIgnoreCase(filter.getLogic()) ? " OR " : " AND ";
return String.join(logic, childConditions);
}
private String buildEiaapprovalLeafCondition(DataSourceRequest.FilterDescriptor filter,
Map<String, Object> paramMap,
int[] indexHolder) {
String column = mapEiaapprovalColumn(filter.getField());
if (!StringUtils.hasText(column)) {
return "";
}
String operator = filter.getOperator() == null ? "eq" : filter.getOperator().toLowerCase();
Object value = filter.getValue();
if ("isnull".equals(operator)) {
return column + " IS NULL";
}
if ("isnotnull".equals(operator)) {
return column + " IS NOT NULL";
}
if ("in".equals(operator)) {
List<Object> values = normalizeFilterValues(value);
if (values.isEmpty()) {
return "";
}
List<String> placeholders = new ArrayList<>();
for (Object item : values) {
String key = "eiaParam" + indexHolder[0]++;
paramMap.put(key, item);
placeholders.add("#{map." + key + "}");
}
return column + " IN (" + String.join(", ", placeholders) + ")";
}
if (value == null) {
return "";
}
String key = "eiaParam" + indexHolder[0]++;
return switch (operator) {
case "eq" -> {
paramMap.put(key, value);
yield column + " = #{map." + key + "}";
}
case "neq" -> {
paramMap.put(key, value);
yield column + " <> #{map." + key + "}";
}
case "contains" -> {
paramMap.put(key, "%" + value + "%");
yield column + " LIKE #{map." + key + "}";
}
case "startswith" -> {
paramMap.put(key, value + "%");
yield column + " LIKE #{map." + key + "}";
}
case "endswith" -> {
paramMap.put(key, "%" + value);
yield column + " LIKE #{map." + key + "}";
}
case "gt" -> {
paramMap.put(key, value);
yield column + " > #{map." + key + "}";
}
case "gte" -> {
paramMap.put(key, value);
yield column + " >= #{map." + key + "}";
}
case "lt" -> {
paramMap.put(key, value);
yield column + " < #{map." + key + "}";
}
case "lte" -> {
paramMap.put(key, value);
yield column + " <= #{map." + key + "}";
}
default -> "";
};
}
private List<Object> normalizeFilterValues(Object value) {
List<Object> values = new ArrayList<>();
if (value instanceof List<?> list) {
for (Object item : list) {
if (item != null) {
values.add(item);
}
}
return values;
}
if (value instanceof Object[] array) {
for (Object item : array) {
if (item != null) {
values.add(item);
}
}
return values;
}
if (value != null) {
values.add(value);
}
return values;
}
private String mapEiaapprovalColumn(String field) {
if (!StringUtils.hasText(field)) {
return null;
}
return switch (field) {
case "stcd", "eiaStcd" -> "e.STCD";
case "hydropowerStation" -> "e.ENNM";
case "baseId", "baseid" -> "e.BASEID";
case "hbrvcd" -> "e.HBRVCD";
case "envMonitoringRequire" -> "e.ENV_MONITORING_REQUIRE";
case "ecologicalFlow" -> "e.ECOLOGICAL_FLOW";
case "approvalFileNo" -> "e.APPROVAL_FILE_NO";
case "approvalFileTitle" -> "e.APPROVAL_FILE_TITLE";
case "fishPassageMeasures" -> "e.FISH_PASSAGE_MEASURES";
case "bldsttCcode" -> "s.BLDSTT_CODE";
case "bldsttCName" -> "CASE WHEN s.BLDSTT_CODE = 0 OR s.BLDSTT_CODE IS NULL THEN '未建/规划' WHEN s.BLDSTT_CODE = 1 THEN '在建' WHEN s.BLDSTT_CODE = 2 THEN '已建' ELSE NULL END";
case "basin" -> "e.BASIN";
case "river" -> "e.RIVER";
case "stnm" -> "s.ENNM";
default -> null;
};
}
private String buildEiaapprovalOrderBySql(List<DataSourceRequest.SortDescriptor> sortList) {
if (sortList == null || sortList.isEmpty()) {
return " ORDER BY baseStepSort ASC, rvcdStepSort ASC, rstcdStepSort ASC, siteStepSort ASC, stnm ASC";
}
List<String> orderItems = new ArrayList<>();
for (DataSourceRequest.SortDescriptor sortDescriptor : sortList) {
if (sortDescriptor == null || !StringUtils.hasText(sortDescriptor.getField())) {
continue;
}
String column = switch (sortDescriptor.getField()) {
case "baseStepSort" -> "baseStepSort";
case "rvcdStepSort" -> "rvcdStepSort";
case "rstcdStepSort" -> "rstcdStepSort";
case "siteStepSort" -> "siteStepSort";
case "stnm" -> "stnm";
case "hydropowerStation" -> "e.HYDROPOWER_STATION";
case "approvalFileNo" -> "e.APPROVAL_FILE_NO";
case "recordTime" -> "e.RECORD_TIME";
case "bldsttCcode" -> "s.BLDSTT_CODE";
default -> null;
};
if (!StringUtils.hasText(column)) {
continue;
}
String dir = "desc".equalsIgnoreCase(sortDescriptor.getDir()) ? "DESC" : "ASC";
orderItems.add(column + " " + dir);
}
if (orderItems.isEmpty()) {
return " ORDER BY baseStepSort ASC, rvcdStepSort ASC, rstcdStepSort ASC, siteStepSort ASC, stnm ASC";
}
return " ORDER BY " + String.join(", ", orderItems);
}
private String resolveBlprdName(Integer blprd) {
if (blprd == null) {
return null;
}
return switch (blprd) {
case 1001000 -> "规划";
case 1002000 -> "预可研";
case 1003000 -> "环评";
case 1004000 -> "可研";
case 1005000 -> "在建";
case 1006000 -> "招标设计";
case 1007000 -> "施工详图";
case 1009000 -> "建设";
case 1010000 -> "蓄水阶段环保验收";
case 1011000 -> "竣工";
case 1012000 -> "竣工环保验收";
case 1013000 -> "环境影响后评价";
default -> null;
};
}
private String resolveDtinName(Integer dtin) {
if (dtin == null) {
return null;
}
return dtin == 1 ? "已接入" : "未接入";
}
private String resolveBldsttName(String bldstt) {
if (!StringUtils.hasText(bldstt)) {
return null;
}
return switch (bldstt) {
case "1" -> "已建成未验收";
case "2" -> "在建";
case "3", "32", "64" -> "可研";
case "4", "61" -> "规划";
case "5", "63" -> "预可研";
case "6", "65" -> "已核准";
case "7", "67" -> "招标设计";
case "8", "69" -> "施工详图";
case "9", "40", "74" -> "其他";
case "10" -> "已建成已验收";
case "11" -> "已开展后评价";
case "31", "62" -> "项目建议书";
case "33" -> "已审批";
case "34", "66" -> "初步设计";
case "35" -> "技施设计";
case "36", "70" -> "在建";
case "37", "71" -> "已建成未验收";
case "38", "72" -> "已建成已验收";
case "39", "73" -> "已开展后评价";
case "68" -> "技施设计";
case "91" -> "拆除";
default -> null;
};
}
private String resolveBldsttCodeName(Integer bldsttCode) {
if (bldsttCode == null) {
return null;
}
return switch (bldsttCode) {
case 0 -> "未建/规划";
case 1 -> "在建";
case 2 -> "已建";
default -> null;
};
}
private String resolveDvtpName(String dvtp) {
if (!StringUtils.hasText(dvtp)) {
return null;
}
return switch (dvtp) {
case "1" -> "堤坝式";
case "2" -> "引水式";
case "3" -> "混合式";
default -> null;
};
}
private String resolveRgcpName(String rgcp) {
if (!StringUtils.hasText(rgcp)) {
return null;
}
return switch (rgcp) {
case "1" -> "多年调节";
case "2" -> "年调节";
case "3" -> "不完全年调节";
case "4" -> "径流式（无调节）";
case "5" -> "季调节";
case "6" -> "月调节";
case "7" -> "周调节";
case "8" -> "日调节";
case "9" -> "其他";
default -> null;
};
}
private String resolveEngtpName(Integer engtp) {
if (engtp == null) {
return null;
}
return switch (engtp) {
case 1 -> "水电站";
case 2 -> "水利工程";
case 3 -> "航电枢纽";
default -> null;
};
}
private String resolvePrscName(Integer prsc) {
if (prsc == null) {
return null;
}
return switch (prsc) {
case 1 -> "大型1";
case 2 -> "大型2";
case 3 -> "中型";
case 4 -> "小型";
default -> null;
};
}
private String resolveScrscName(Integer scrsc) {
if (scrsc == null) {
return null;
}
return switch (scrsc) {
case 1 -> "大型1";
case 2 -> "大型2";
case 3 -> "中型";
case 4 -> "小型1";
case 5 -> "小型2";
default -> null;
};
}
private String resolvePrgrName(String prgr) {
if (!StringUtils.hasText(prgr)) {
return null;
}
return switch (prgr) {
case "1" -> "Ⅰ";
case "2" -> "Ⅱ";
case "3" -> "Ⅲ";
case "4" -> "Ⅳ";
case "5" -> "Ⅴ";
default -> null;
};
}
}

8
backend/src/main/java/com/yfd/platform/env/service/impl/SdFishDictoryBServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdFishDictoryBServiceImpl.java
View File

@ -1,12 +1,12 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.service.impl;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.env.domain.SdFishDictoryB;
import com.yfd.platform.env.mapper.SdFishDictoryBMapper;
import com.yfd.platform.env.service.ISdFishDictoryBService;
import com.yfd.platform.qgc_base.domain.SdFishDictoryB;
import com.yfd.platform.qgc_base.mapper.SdFishDictoryBMapper;
import com.yfd.platform.qgc_base.service.ISdFishDictoryBService;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

16
backend/src/main/java/com/yfd/platform/env/service/impl/SdFpssBHServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdFpssBHServiceImpl.java
View File

@ -1,15 +1,15 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.data.domain.SysUserDataScope;
import com.yfd.platform.data.mapper.SysUserDataScopeMapper;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.domain.SdFpssBH;
import com.yfd.platform.env.mapper.SdEngInfoBHMapper;
import com.yfd.platform.env.mapper.SdFpssBHMapper;
import com.yfd.platform.env.service.ISdFpssBHService;
import com.yfd.platform.qgc_data.domain.SysUserDataScope;
import com.yfd.platform.qgc_data.mapper.SysUserDataScopeMapper;
import com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import com.yfd.platform.qgc_base.domain.SdFpssBH;
import com.yfd.platform.qgc_base.mapper.SdEngInfoBHMapper;
import com.yfd.platform.qgc_base.mapper.SdFpssBHMapper;
import com.yfd.platform.qgc_base.service.ISdFpssBHService;
import com.yfd.platform.utils.SecurityUtils;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;

8
backend/src/main/java/com/yfd/platform/env/service/impl/SdFpssRServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdFpssRServiceImpl.java
View File

@ -1,11 +1,11 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.env.domain.SdFpssR;
import com.yfd.platform.env.mapper.SdFpssRMapper;
import com.yfd.platform.env.service.ISdFpssRService;
import com.yfd.platform.qgc_base.domain.SdFpssR;
import com.yfd.platform.qgc_base.mapper.SdFpssRMapper;
import com.yfd.platform.qgc_base.service.ISdFpssRService;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

17
backend/src/main/java/com/yfd/platform/env/service/impl/SdHbrvDicServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdHbrvDicServiceImpl.java
View File

@ -1,16 +1,15 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.data.domain.SysUserDataScope;
import com.yfd.platform.data.mapper.SysUserDataScopeMapper;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.domain.SdHbrvDic;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.env.mapper.SdEngInfoBHMapper;
import com.yfd.platform.env.mapper.SdHbrvDicMapper;
import com.yfd.platform.env.service.ISdHbrvDicService;
import com.yfd.platform.qgc_data.domain.SysUserDataScope;
import com.yfd.platform.qgc_data.mapper.SysUserDataScopeMapper;
import com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import com.yfd.platform.qgc_base.domain.SdHbrvDic;
import com.yfd.platform.qgc_base.mapper.SdEngInfoBHMapper;
import com.yfd.platform.qgc_base.mapper.SdHbrvDicMapper;
import com.yfd.platform.qgc_base.service.ISdHbrvDicService;
import com.yfd.platform.utils.SecurityUtils;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;

8
backend/src/main/java/com/yfd/platform/env/service/impl/SdHycdDicServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdHycdDicServiceImpl.java
View File

@ -1,10 +1,10 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.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 com.yfd.platform.qgc_base.domain.SdHycdDic;
import com.yfd.platform.qgc_base.mapper.SdHycdDicMapper;
import com.yfd.platform.qgc_base.service.ISdHycdDicService;
import org.springframework.stereotype.Service;
import java.util.List;

19
backend/src/main/java/com/yfd/platform/env/service/impl/SdHydrobaseServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdHydrobaseServiceImpl.java
View File

@ -1,18 +1,18 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.DataSourceResult;
import com.yfd.platform.data.domain.SysUserDataScope;
import com.yfd.platform.data.mapper.SysUserDataScopeMapper;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.env.entity.vo.HydrobaseWbsVo;
import com.yfd.platform.env.mapper.SdEngInfoBHMapper;
import com.yfd.platform.env.mapper.SdHydrobaseMapper;
import com.yfd.platform.env.service.ISdHydrobaseService;
import com.yfd.platform.qgc_data.domain.SysUserDataScope;
import com.yfd.platform.qgc_data.mapper.SysUserDataScopeMapper;
import com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import com.yfd.platform.qgc_base.domain.SdHydrobase;
import com.yfd.platform.qgc_base.entity.vo.HydrobaseWbsVo;
import com.yfd.platform.qgc_base.mapper.SdEngInfoBHMapper;
import com.yfd.platform.qgc_base.mapper.SdHydrobaseMapper;
import com.yfd.platform.qgc_base.service.ISdHydrobaseService;
import com.yfd.platform.utils.SecurityUtils;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
@ -22,7 +22,6 @@ import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;

8
backend/src/main/java/com/yfd/platform/env/service/impl/SdRvcdDicServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/SdRvcdDicServiceImpl.java
View File

@ -1,10 +1,10 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.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 com.yfd.platform.qgc_base.domain.SdRvcdDic;
import com.yfd.platform.qgc_base.mapper.SdRvcdDicMapper;
import com.yfd.platform.qgc_base.service.ISdRvcdDicService;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

18
backend/src/main/java/com/yfd/platform/env/service/impl/TreeStructureServiceImpl.java → backend/src/main/java/com/yfd/platform/qgc_base/service/impl/TreeStructureServiceImpl.java
View File

@ -1,14 +1,12 @@
package com.yfd.platform.env.service.impl;
package com.yfd.platform.qgc_base.service.impl;
import com.yfd.platform.env.domain.SdEngInfoBH;
import com.yfd.platform.env.domain.SdHydrobase;
import com.yfd.platform.env.domain.SdHbrvDic;
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 com.yfd.platform.qgc_base.domain.SdEngInfoBH;
import com.yfd.platform.qgc_base.domain.SdHydrobase;
import com.yfd.platform.qgc_base.domain.SdHbrvDic;
import com.yfd.platform.qgc_base.domain.SdHycdDic;
import com.yfd.platform.qgc_base.domain.SdRvcdDic;
import com.yfd.platform.qgc_base.mapper.*;
import com.yfd.platform.qgc_base.service.ITreeStructureService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

7
backend/src/main/java/com/yfd/platform/data/controller/ApprovalChangeLogController.java → backend/src/main/java/com/yfd/platform/qgc_data/controller/ApprovalChangeLogController.java
View File

@ -1,12 +1,11 @@
package com.yfd.platform.data.controller;
package com.yfd.platform.qgc_data.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.common.utils.UserNameFillHelper;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.data.domain.ApprovalChangeLog;
import com.yfd.platform.data.domain.ApprovalLog;
import com.yfd.platform.data.service.IApprovalChangeLogService;
import com.yfd.platform.qgc_data.domain.ApprovalChangeLog;
import com.yfd.platform.qgc_data.service.IApprovalChangeLogService;
import com.yfd.platform.utils.DataSourceRequestUtil;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;

7
backend/src/main/java/com/yfd/platform/data/controller/ApprovalLogController.java → backend/src/main/java/com/yfd/platform/qgc_data/controller/ApprovalLogController.java
View File

@ -1,11 +1,10 @@
package com.yfd.platform.data.controller;
package com.yfd.platform.qgc_data.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.data.domain.ApprovalLog;
import com.yfd.platform.data.domain.ApprovalMain;
import com.yfd.platform.data.service.IApprovalLogService;
import com.yfd.platform.qgc_data.domain.ApprovalLog;
import com.yfd.platform.qgc_data.service.IApprovalLogService;
import com.yfd.platform.utils.DataSourceRequestUtil;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;

8
backend/src/main/java/com/yfd/platform/data/controller/ApprovalMainController.java → backend/src/main/java/com/yfd/platform/qgc_data/controller/ApprovalMainController.java
View File

@ -1,11 +1,11 @@
package com.yfd.platform.data.controller;
package com.yfd.platform.qgc_data.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.data.domain.ApprovalMain;
import com.yfd.platform.data.service.IApprovalMainService;
import com.yfd.platform.data.service.IFishDraftDataService;
import com.yfd.platform.qgc_data.domain.ApprovalMain;
import com.yfd.platform.qgc_data.service.IApprovalMainService;
import com.yfd.platform.qgc_data.service.IFishDraftDataService;
import com.yfd.platform.utils.DataSourceRequestUtil;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;

25
backend/src/main/java/com/yfd/platform/data/controller/FishDraftDataController.java → backend/src/main/java/com/yfd/platform/qgc_data/controller/FishDraftDataController.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.data.controller;
package com.yfd.platform.qgc_data.controller;
import java.io.File;
import java.io.FileInputStream;
@ -17,23 +17,21 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.data.domain.*;
import com.yfd.platform.data.domain.vo.FishDraftDataVO;
import com.yfd.platform.data.domain.vo.FishStatisticsVO;
import com.yfd.platform.data.service.AttachmentUploadService;
import com.yfd.platform.data.service.IFishDraftDataService;
import com.yfd.platform.data.service.IFishImportService;
import com.yfd.platform.data.service.IFishStatisticsService;
import com.yfd.platform.data.service.IImportTaskService;
import com.yfd.platform.data.utils.ZipFileUtil;
import com.yfd.platform.utils.KendoUtil;
import com.yfd.platform.qgc_data.domain.*;
import com.yfd.platform.qgc_data.domain.vo.FishDraftDataVO;
import com.yfd.platform.qgc_data.domain.vo.FishStatisticsVO;
import com.yfd.platform.qgc_data.service.AttachmentUploadService;
import com.yfd.platform.qgc_data.service.IFishDraftDataService;
import com.yfd.platform.qgc_data.service.IFishImportService;
import com.yfd.platform.qgc_data.service.IFishStatisticsService;
import com.yfd.platform.qgc_data.service.IImportTaskService;
import com.yfd.platform.qgc_data.utils.ZipFileUtil;
import com.yfd.platform.utils.MultipartStreamParser;
import com.yfd.platform.utils.SecurityUtils;
import io.swagger.v3.oas.annotations.Operation;
@ -49,7 +47,6 @@ import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;
import java.io.IOException;
import java.util.*;
/**
@ -937,7 +934,7 @@ public class FishDraftDataController {
@Operation(summary = "清理临时文件")
public ResponseResult cleanupTemp(@RequestParam String tempDir) {
try {
com.yfd.platform.data.utils.ZipFileUtil.cleanupTempDir(tempDir);
com.yfd.platform.qgc_data.utils.ZipFileUtil.cleanupTempDir(tempDir);
return ResponseResult.success("清理成功");
} catch (Exception e) {
return ResponseResult.error("清理失败: " + e.getMessage());

8
backend/src/main/java/com/yfd/platform/data/controller/ImportTaskController.java → backend/src/main/java/com/yfd/platform/qgc_data/controller/ImportTaskController.java
View File

@ -1,12 +1,12 @@
package com.yfd.platform.data.controller;
package com.yfd.platform.qgc_data.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.common.DataSourceLoadOptionsBase;
import com.yfd.platform.common.DataSourceRequest;
import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.data.domain.ImportTask;
import com.yfd.platform.data.domain.ImportTaskRequest;
import com.yfd.platform.data.service.IImportTaskService;
import com.yfd.platform.qgc_data.domain.ImportTask;
import com.yfd.platform.qgc_data.domain.ImportTaskRequest;
import com.yfd.platform.qgc_data.service.IImportTaskService;
import com.yfd.platform.utils.KendoUtil;
import com.yfd.platform.utils.QgcQueryWrapperUtil;
import io.swagger.v3.oas.annotations.Operation;

10
backend/src/main/java/com/yfd/platform/data/controller/SysUserDataScopeController.java → backend/src/main/java/com/yfd/platform/qgc_data/controller/SysUserDataScopeController.java
View File

@ -1,12 +1,12 @@
package com.yfd.platform.data.controller;
package com.yfd.platform.qgc_data.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.data.domain.SysUserDataScope;
import com.yfd.platform.data.domain.bo.EditUserDataScopeBo;
import com.yfd.platform.data.domain.vo.SysUserDataScopeVO;
import com.yfd.platform.data.service.ISysUserDataScopeService;
import com.yfd.platform.qgc_data.domain.SysUserDataScope;
import com.yfd.platform.qgc_data.domain.bo.EditUserDataScopeBo;
import com.yfd.platform.qgc_data.domain.vo.SysUserDataScopeVO;
import com.yfd.platform.qgc_data.service.ISysUserDataScopeService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.*;

2
backend/src/main/java/com/yfd/platform/data/domain/ApprovalChangeLog.java → backend/src/main/java/com/yfd/platform/qgc_data/domain/ApprovalChangeLog.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.data.domain;
package com.yfd.platform.qgc_data.domain;
import com.baomidou.mybatisplus.annotation.*;
import com.yfd.platform.annotation.UserIdField;

2
backend/src/main/java/com/yfd/platform/data/domain/ApprovalLog.java → backend/src/main/java/com/yfd/platform/qgc_data/domain/ApprovalLog.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.data.domain;
package com.yfd.platform.qgc_data.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/data/domain/ApprovalMain.java → backend/src/main/java/com/yfd/platform/qgc_data/domain/ApprovalMain.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.data.domain;
package com.yfd.platform.qgc_data.domain;
import com.baomidou.mybatisplus.annotation.*;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/data/domain/BatchApproveRequest.java → backend/src/main/java/com/yfd/platform/qgc_data/domain/BatchApproveRequest.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.data.domain;
package com.yfd.platform.qgc_data.domain;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

2
backend/src/main/java/com/yfd/platform/data/domain/BatchRejectRequest.java → backend/src/main/java/com/yfd/platform/qgc_data/domain/BatchRejectRequest.java
View File

@ -1,4 +1,4 @@
package com.yfd.platform.data.domain;
package com.yfd.platform.qgc_data.domain;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

Some files were not shown because too many files have changed in this diff Show More