feat: 环保设施点击描点默认展示有数据的年份

This commit is contained in:
tangwei 2026-07-01 17:53:01 +08:00
parent 3392474a50
commit 34be84057b
3 changed files with 52 additions and 0 deletions

View File

@ -162,4 +162,10 @@ public class EngEqDataController {
public ResponseResult getQecRateCount(@RequestBody DataSourceRequest dataSourceRequest) { public ResponseResult getQecRateCount(@RequestBody DataSourceRequest dataSourceRequest) {
return ResponseResult.successData(engEqDataService.qecRateCount(dataSourceRequest)); return ResponseResult.successData(engEqDataService.qecRateCount(dataSourceRequest));
} }
@PostMapping("/operat/default/year")
@Operation(summary = "环保设施点击描点默认展示有数据的年份,不包含过鱼设施描点")
public ResponseResult getDefaultYear(@RequestBody DataSourceRequest dataSourceRequest) {
return ResponseResult.successData(engEqDataService.getDefaultYear(dataSourceRequest));
}
} }

View File

@ -59,4 +59,6 @@ public interface EngEqDataService {
DataSourceResult<SdEqMonitorCountVo> getEvnmAutoMonitorList(DataSourceRequest dataSourceRequest); DataSourceResult<SdEqMonitorCountVo> getEvnmAutoMonitorList(DataSourceRequest dataSourceRequest);
DataSourceResult<EngEqRateCountVo> qecRateCount(DataSourceRequest dataSourceRequest); DataSourceResult<EngEqRateCountVo> qecRateCount(DataSourceRequest dataSourceRequest);
DataSourceResult<String> getDefaultYear(DataSourceRequest dataSourceRequest);
} }

View File

@ -5805,4 +5805,48 @@ public class EngEqDataServiceImpl implements EngEqDataService {
default -> null; default -> null;
}; };
} }
@Override
public DataSourceResult<String> getDefaultYear(DataSourceRequest dataSourceRequest) {
DataSourceResult<String> dataSourceResult = new DataSourceResult<>();
List<String> resultList = new ArrayList<>();
dataSourceResult.setData(resultList);
dataSourceResult.setTotal(resultList.size());
DataSourceLoadOptionsBase loadOptions = dataSourceRequest == null ? null : dataSourceRequest.toDevRequest();
String stcd = loadOptions == null ? null : QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "stcd");
String sttpCode = loadOptions == null ? null : QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "sttpCode");
if (StrUtil.isBlank(stcd) || StrUtil.isBlank(sttpCode)) {
return dataSourceResult;
}
Map<String, Object> paramMap = new HashMap<>();
paramMap.put("stcd", stcd);
String sql = switch (sttpCode) {
case "DW" -> "SELECT MAX(TM) AS TM FROM SD_DW_R WHERE STCD = #{map.stcd} AND NVL(IS_DELETED, 0) = 0";
case "EQ" -> "SELECT MAX(TM) AS TM FROM SD_EQ_R WHERE STCD = #{map.stcd} AND NVL(IS_DELETED, 0) = 0";
case "FB" -> "SELECT MAX(TM) AS TM FROM SD_ENGFR_R WHERE STCD = #{map.stcd} AND NVL(IS_DELETED, 0) = 0";
case "VA" -> "SELECT MAX(TM) AS TM FROM SD_VA_R WHERE STCD = #{map.stcd} AND NVL(IS_DELETED, 0) = 0";
case "VP" -> "SELECT MAX(TM) AS TM FROM SD_VP_R WHERE STCD = #{map.stcd} AND NVL(IS_DELETED, 0) = 0";
default -> "";
};
if (StrUtil.isBlank(sql)) {
return dataSourceResult;
}
List<Map<String, Object>> allList = microservicDynamicSQLMapper.getAllList(sql, paramMap);
if (CollUtil.isEmpty(allList)) {
return dataSourceResult;
}
Map<String, Object> map = allList.get(0);
if (map == null) {
return dataSourceResult;
}
Object tm = map.getOrDefault("TM", "");
if (tm != null && StrUtil.isNotBlank(tm.toString())) {
resultList.add(tm.toString());
}
return dataSourceResult;
}
} }