feat: 全过程沿程鱼类变化情况
This commit is contained in:
tangwei
parent
9e62c64495
commit
fcb300f2d4
@ -143,6 +143,14 @@ public class SwaggerConfig {
|
||||
.build();
|
||||
}
|
||||
|
||||
@Bean
|
||||
public GroupedOpenApi groupEnvWteApi() {
|
||||
return GroupedOpenApi.builder()
|
||||
.group("3.9 全过程-生态环保数据服务-生态调查(wte)")
|
||||
.packagesToScan("com.yfd.platform.qgc_env.wte.controller")
|
||||
.build();
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@ -21,6 +21,7 @@ public class EngVmsstbprptVo implements Serializable {
|
||||
private String baseId;
|
||||
private String baseName;
|
||||
private String reachcdName;
|
||||
private String reachcd;
|
||||
private String hbrvcd;
|
||||
private String hbrvcdName;
|
||||
private String rvcd;
|
||||
@ -28,6 +29,8 @@ public class EngVmsstbprptVo implements Serializable {
|
||||
private String addvcdName;
|
||||
private String hynm;
|
||||
private String topHynm;
|
||||
private String hycd;
|
||||
private String topHycd;
|
||||
private String stlc;
|
||||
private Double lgtd;
|
||||
private Double lttd;
|
||||
|
||||
@ -533,6 +533,7 @@ public class SdEngInfoBHServiceImpl extends ServiceImpl<SdEngInfoBHMapper, SdEng
|
||||
"eng.ENNM AS stnm, " +
|
||||
"eng.LGTD AS lgtd, " +
|
||||
"eng.LTTD AS lttd, " +
|
||||
"eng.REACHCD AS reachcd, " +
|
||||
"eng.REACHCD_NAME AS reachcdName, " +
|
||||
"eng.ENNM AS ennm, " +
|
||||
"eng.BASE_ID AS baseId, " +
|
||||
@ -544,6 +545,8 @@ public class SdEngInfoBHServiceImpl extends ServiceImpl<SdEngInfoBHMapper, SdEng
|
||||
"addv.ADDVNM AS addvcdName, " +
|
||||
"hy.HYNM AS hynm, " +
|
||||
"topHy.HYNM AS topHynm, " +
|
||||
"hy.HYCD AS hycd, " +
|
||||
"topHy.HYCD AS topHycd, " +
|
||||
"eng.STLC AS stlc, " +
|
||||
"eng.JCDT AS jcdt, " +
|
||||
"eng.PIODT AS piodt, " +
|
||||
@ -701,6 +704,7 @@ public class SdEngInfoBHServiceImpl extends ServiceImpl<SdEngInfoBHMapper, SdEng
|
||||
columns.put("stnm", "t.stnm AS stnm");
|
||||
columns.put("ennm", "t.ennm AS ennm");
|
||||
columns.put("baseId", "t.baseId AS baseId");
|
||||
columns.put("reachcd", "t.reachcd AS reachcd");
|
||||
columns.put("reachcdName", "t.reachcdName AS reachcdName");
|
||||
columns.put("baseName", "t.baseName AS baseName");
|
||||
columns.put("hbrvcd", "t.hbrvcd AS hbrvcd");
|
||||
@ -712,6 +716,8 @@ public class SdEngInfoBHServiceImpl extends ServiceImpl<SdEngInfoBHMapper, SdEng
|
||||
columns.put("addvcdName", "t.addvcdName AS addvcdName");
|
||||
columns.put("hynm", "t.hynm AS hynm");
|
||||
columns.put("topHynm", "t.topHynm AS topHynm");
|
||||
columns.put("hycd", "t.hycd AS hycd");
|
||||
columns.put("topHycd", "t.topHycd AS topHycd");
|
||||
columns.put("stlc", "t.stlc AS stlc");
|
||||
columns.put("jcdt", "t.jcdt AS jcdt");
|
||||
columns.put("piodt", "t.piodt AS piodt");
|
||||
|
||||
@ -0,0 +1,29 @@
|
||||
package com.yfd.platform.qgc_env.wte.controller;
|
||||
|
||||
import com.yfd.platform.common.DataSourceRequest;
|
||||
import com.yfd.platform.config.ResponseResult;
|
||||
import com.yfd.platform.qgc_env.wte.service.WeFishService;
|
||||
import io.swagger.v3.oas.annotations.Operation;
|
||||
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||
import jakarta.annotation.Resource;
|
||||
import org.springframework.validation.annotation.Validated;
|
||||
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;
|
||||
|
||||
@RestController
|
||||
@RequestMapping("/wte")
|
||||
@Tag(name = "水生生态模块")
|
||||
@Validated
|
||||
public class WeFishController {
|
||||
|
||||
@Resource
|
||||
private WeFishService weFishService;
|
||||
|
||||
@PostMapping("/we/fisht/qgc/GetKendoListCust")
|
||||
@Operation(summary = "全过程沿程鱼类变化情况")
|
||||
public ResponseResult getQgcWeFishTKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) {
|
||||
return ResponseResult.successData(weFishService.getQgcWeFishTKendoListCust(dataSourceRequest));
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,134 @@
|
||||
package com.yfd.platform.qgc_env.wte.entity.vo;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
@Schema(description = "全过程沿程鱼类变化情况")
|
||||
public class WeFishTQgcVo {
|
||||
|
||||
@Schema(description = "断面编码")
|
||||
private String stcd;
|
||||
|
||||
@Schema(description = "断面名称")
|
||||
private String stnm;
|
||||
|
||||
@Schema(description = "基地编码")
|
||||
private String baseId;
|
||||
|
||||
@Schema(description = "基地名称")
|
||||
private String baseName;
|
||||
|
||||
@Schema(description = "流域编码")
|
||||
private String rvcd;
|
||||
|
||||
@Schema(description = "流域名称")
|
||||
private String rvcdName;
|
||||
|
||||
@Schema(description = "行政区编码")
|
||||
private String addvcd;
|
||||
|
||||
@Schema(description = "行政区名称")
|
||||
private String addvcdName;
|
||||
|
||||
@Schema(description = "河段编码")
|
||||
private String hbrvcd;
|
||||
|
||||
@Schema(description = "河段名称")
|
||||
private String hbrvcdName;
|
||||
|
||||
@Schema(description = "调查批次")
|
||||
private String dcpc;
|
||||
|
||||
@Schema(description = "调查时间")
|
||||
@JsonFormat(pattern = "yyyy-MM-dd")
|
||||
private Date tm;
|
||||
|
||||
@Schema(description = "调查报告")
|
||||
private String werFid;
|
||||
|
||||
@Schema(description = "调查主表ID")
|
||||
private String werId;
|
||||
|
||||
@Schema(description = "渔获物种类编码")
|
||||
private String ftp;
|
||||
|
||||
@Schema(description = "鱼类规格(cm)")
|
||||
private String fsz;
|
||||
|
||||
@Schema(description = "渔获物数量(尾)")
|
||||
private Long fcnt;
|
||||
|
||||
@Schema(description = "渔获物重量(kg)")
|
||||
private BigDecimal fwgh;
|
||||
|
||||
@Schema(description = "性腺发育期")
|
||||
private String st;
|
||||
|
||||
@Schema(description = "早期资源量和种类")
|
||||
private String ps;
|
||||
|
||||
@Schema(description = "平均重量")
|
||||
private BigDecimal avgFwgt;
|
||||
|
||||
@Schema(description = "平均体长")
|
||||
private BigDecimal avgFsz;
|
||||
|
||||
@Schema(description = "附件ID")
|
||||
private String fid;
|
||||
|
||||
@Schema(description = "现场影像ID")
|
||||
private String fileId;
|
||||
|
||||
@Schema(description = "鱼类ID")
|
||||
private String id;
|
||||
|
||||
@Schema(description = "渔获物种类")
|
||||
private String name;
|
||||
|
||||
@Schema(description = "别名")
|
||||
private String alias;
|
||||
|
||||
@Schema(description = "属")
|
||||
private String genus;
|
||||
|
||||
@Schema(description = "科")
|
||||
private String family;
|
||||
|
||||
@Schema(description = "种")
|
||||
private String species;
|
||||
|
||||
@Schema(description = "鱼类分类")
|
||||
private String type;
|
||||
|
||||
@Schema(description = "鱼类分类名称")
|
||||
private String typeName;
|
||||
|
||||
@Schema(description = "稀有程度")
|
||||
private String rare;
|
||||
|
||||
@Schema(description = "鱼类来源")
|
||||
private String specOrigin;
|
||||
|
||||
@Schema(description = "鱼类来源名称")
|
||||
private String specOriginName;
|
||||
|
||||
@Schema(description = "保护类型")
|
||||
private String ptype;
|
||||
|
||||
@Schema(description = "保护类型名称")
|
||||
private String ptypeName;
|
||||
|
||||
@Schema(description = "年份")
|
||||
private String yr;
|
||||
|
||||
@Schema(description = "鱼类类型")
|
||||
private Integer ty;
|
||||
|
||||
@Schema(description = "鱼类类型名称")
|
||||
private String tyName;
|
||||
}
|
||||
@ -0,0 +1,10 @@
|
||||
package com.yfd.platform.qgc_env.wte.service;
|
||||
|
||||
import com.yfd.platform.common.DataSourceRequest;
|
||||
import com.yfd.platform.common.DataSourceResult;
|
||||
import com.yfd.platform.qgc_env.wte.entity.vo.WeFishTQgcVo;
|
||||
|
||||
public interface WeFishService {
|
||||
|
||||
DataSourceResult<WeFishTQgcVo> getQgcWeFishTKendoListCust(DataSourceRequest dataSourceRequest);
|
||||
}
|
||||
@ -0,0 +1,499 @@
|
||||
package com.yfd.platform.qgc_env.wte.service.impl;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import cn.hutool.core.date.DateUtil;
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
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.GroupHelper;
|
||||
import com.yfd.platform.common.GroupingInfo;
|
||||
import com.yfd.platform.common.MicroservicDynamicSQLMapper;
|
||||
import com.yfd.platform.qgc_env.wte.entity.vo.WeFishTQgcVo;
|
||||
import com.yfd.platform.qgc_env.wte.service.WeFishService;
|
||||
import com.yfd.platform.utils.QgcQueryWrapperUtil;
|
||||
import jakarta.annotation.Resource;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.Date;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@Service
|
||||
public class WeFishServiceImpl implements WeFishService {
|
||||
|
||||
@Resource
|
||||
private MicroservicDynamicSQLMapper microservicDynamicSQLMapper;
|
||||
|
||||
@Override
|
||||
public DataSourceResult<WeFishTQgcVo> getQgcWeFishTKendoListCust(DataSourceRequest dataSourceRequest) {
|
||||
DataSourceLoadOptionsBase loadOptions = dataSourceRequest == null ? null : dataSourceRequest.toDevRequest();
|
||||
GroupingInfo[] groupInfos = loadOptions == null ? null : loadOptions.getGroup();
|
||||
Map<String, Object> paramMap = new HashMap<>();
|
||||
|
||||
String filterSql = buildWeFishQgcFilterCondition(
|
||||
dataSourceRequest == null ? null : dataSourceRequest.getFilter(),
|
||||
paramMap,
|
||||
new int[]{0}
|
||||
);
|
||||
|
||||
StringBuilder sql = new StringBuilder();
|
||||
sql.append("SELECT r.* FROM (")
|
||||
.append(buildWeFishQgcDetailSql())
|
||||
.append(") r WHERE 1 = 1 ");
|
||||
if (StrUtil.isNotBlank(filterSql)) {
|
||||
sql.append(" AND ").append(filterSql).append(" ");
|
||||
}
|
||||
|
||||
DataSourceResult<WeFishTQgcVo> result = new DataSourceResult<>();
|
||||
if (CollUtil.isNotEmpty(dataSourceRequest == null ? null : dataSourceRequest.getGroup())) {
|
||||
String groupedSql = buildWeFishQgcGroupSql(sql.toString(), groupInfos);
|
||||
List<Map<String, Object>> rows = microservicDynamicSQLMapper.getAllList(groupedSql, paramMap);
|
||||
if (Boolean.TRUE.equals(dataSourceRequest.getGroupResultFlat())) {
|
||||
result.setData((List<WeFishTQgcVo>) (List<?>) new GroupHelper().faltGroup(rows, Arrays.asList(groupInfos)));
|
||||
} else {
|
||||
result.setData((List<WeFishTQgcVo>) (List<?>) new GroupHelper().group(rows, Arrays.asList(groupInfos)));
|
||||
}
|
||||
result.setTotal((long) rows.size());
|
||||
result.setAggregates(new HashMap<>());
|
||||
return result;
|
||||
}
|
||||
|
||||
sql.append(buildWeFishQgcOrderBySql(dataSourceRequest == null ? null : dataSourceRequest.getSort()));
|
||||
Page<?> page = loadOptions == null ? null
|
||||
: QgcQueryWrapperUtil.buildPage(loadOptions, loadOptions.getSkip(), loadOptions.getTake());
|
||||
List<WeFishTQgcVo> list = microservicDynamicSQLMapper.pageAllListWithResultType(
|
||||
page,
|
||||
sql.toString(),
|
||||
paramMap,
|
||||
WeFishTQgcVo.class
|
||||
);
|
||||
fillWeFishDerivedFields(list);
|
||||
|
||||
result.setData(list);
|
||||
result.setTotal(page != null ? page.getTotal() : list.size());
|
||||
result.setAggregates(new HashMap<>());
|
||||
return result;
|
||||
}
|
||||
|
||||
private String buildWeFishQgcGroupSql(String baseSql, GroupingInfo[] groupInfos) {
|
||||
if (groupInfos == null || groupInfos.length == 0) {
|
||||
return baseSql;
|
||||
}
|
||||
List<String> groupFields = new ArrayList<>();
|
||||
List<String> selectItems = new ArrayList<>();
|
||||
List<String> orderByItems = new ArrayList<>();
|
||||
for (GroupingInfo item : groupInfos) {
|
||||
if (item == null || StrUtil.isBlank(item.getSelector())) {
|
||||
continue;
|
||||
}
|
||||
String selector = item.getSelector();
|
||||
String groupColumn = mapWeFishQgcGroupColumn(selector);
|
||||
if (StrUtil.isBlank(groupColumn)) {
|
||||
continue;
|
||||
}
|
||||
groupFields.add(groupColumn);
|
||||
selectItems.add(groupColumn + " AS " + selector.toUpperCase());
|
||||
boolean hasCountAlias = false;
|
||||
if (CollUtil.isNotEmpty(item.getSummaryInfos())) {
|
||||
for (com.yfd.platform.common.SummaryInfo summaryInfo : item.getSummaryInfos()) {
|
||||
if (summaryInfo == null || StrUtil.isBlank(summaryInfo.getSelector()) || StrUtil.isBlank(summaryInfo.getSummaryType())) {
|
||||
continue;
|
||||
}
|
||||
String summaryColumn = mapWeFishQgcGroupColumn(summaryInfo.getSelector());
|
||||
if (StrUtil.isBlank(summaryColumn)) {
|
||||
continue;
|
||||
}
|
||||
String summaryType = summaryInfo.getSummaryType().toUpperCase();
|
||||
String summarySelector = summaryInfo.getSelector().toUpperCase();
|
||||
switch (summaryInfo.getSummaryType().toLowerCase()) {
|
||||
case "count" -> {
|
||||
selectItems.add("COUNT(" + summaryColumn + ") AS " + summaryType + "_" + summarySelector);
|
||||
if (selector.equalsIgnoreCase(summaryInfo.getSelector())) {
|
||||
hasCountAlias = true;
|
||||
}
|
||||
}
|
||||
case "sum" -> selectItems.add("SUM(" + summaryColumn + ") AS " + summaryType + "_" + summarySelector);
|
||||
case "avg", "average" -> selectItems.add("AVG(" + summaryColumn + ") AS AVG_" + summarySelector);
|
||||
case "min" -> selectItems.add("MIN(" + summaryColumn + ") AS " + summaryType + "_" + summarySelector);
|
||||
case "max" -> selectItems.add("MAX(" + summaryColumn + ") AS " + summaryType + "_" + summarySelector);
|
||||
default -> {
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
if (!hasCountAlias) {
|
||||
selectItems.add("COUNT(*) AS COUNT_" + selector.toUpperCase());
|
||||
}
|
||||
String dir = Boolean.TRUE.equals(item.getDesc()) ? "DESC" : "ASC";
|
||||
orderByItems.add(groupColumn + " " + dir);
|
||||
}
|
||||
if (groupFields.isEmpty()) {
|
||||
return baseSql;
|
||||
}
|
||||
StringBuilder sql = new StringBuilder("SELECT ");
|
||||
sql.append(String.join(", ", selectItems))
|
||||
.append(" FROM (")
|
||||
.append(baseSql)
|
||||
.append(") T GROUP BY ")
|
||||
.append(String.join(", ", groupFields));
|
||||
if (!orderByItems.isEmpty()) {
|
||||
sql.append(" ORDER BY ").append(String.join(", ", orderByItems));
|
||||
}
|
||||
return sql.toString();
|
||||
}
|
||||
|
||||
private String buildWeFishQgcDetailSql() {
|
||||
return "SELECT " +
|
||||
"section.STCD AS stcd, " +
|
||||
"section.STNM AS stnm, " +
|
||||
"eng.BASE_ID AS baseId, " +
|
||||
"eng.BASE_NAME AS baseName, " +
|
||||
"eng.RVCD AS rvcd, " +
|
||||
"eng.RVCD_NAME AS rvcdName, " +
|
||||
"eng.ADDVCD AS addvcd, " +
|
||||
"eng.ADDVCD_NAME AS addvcdName, " +
|
||||
"eng.HBRVCD AS hbrvcd, " +
|
||||
"eng.HBRVCD_NAME AS hbrvcdName, " +
|
||||
"we.DCPC AS dcpc, " +
|
||||
"we.TM AS tm, " +
|
||||
"we.FID AS werFid, " +
|
||||
"fish.WER_ID AS werId, " +
|
||||
"fish.FTP AS ftp, " +
|
||||
"fish.FSZ AS fsz, " +
|
||||
"fish.FCNT AS fcnt, " +
|
||||
"fish.FWGH AS fwgh, " +
|
||||
"fish.ST AS st, " +
|
||||
"fish.PS AS ps, " +
|
||||
"fish.AVG_FWGT AS avgFwgt, " +
|
||||
"fish.AVG_FSZ AS avgFsz, " +
|
||||
"fish.FID AS fid, " +
|
||||
"fish.FILE_ID AS fileId, " +
|
||||
"dict.FISH_ID AS id, " +
|
||||
"dict.NAME AS name, " +
|
||||
"dict.ALIAS AS alias, " +
|
||||
"dict.GENUS AS genus, " +
|
||||
"dict.FAMILY AS family, " +
|
||||
"dict.SPECIES AS species, " +
|
||||
"dict.TYPE AS type, " +
|
||||
"dict.RARE AS rare, " +
|
||||
"dict.SPEC_ORIGIN AS specOrigin, " +
|
||||
"dict.PTYPE AS ptype, " +
|
||||
"TO_CHAR(we.TM, 'yyyy') AS yr, " +
|
||||
"CASE " +
|
||||
"WHEN dict.SPEC_ORIGIN = 2 THEN 1 " +
|
||||
"WHEN dict.SPEC_ORIGIN = 1 AND NVL(dict.PTYPE, -1) <> 6 THEN 2 " +
|
||||
"WHEN dict.SPEC_ORIGIN = 1 AND dict.PTYPE = 6 THEN 3 " +
|
||||
"END AS ty " +
|
||||
"FROM SD_WE_R we " +
|
||||
"INNER JOIN SD_WEFISH_R fish ON fish.WER_ID = we.ID " +
|
||||
" AND NVL(fish.IS_DELETED, 0) = 0 " +
|
||||
"INNER JOIN SD_WE_B_H section ON section.STCD = we.STCD " +
|
||||
" AND NVL(section.USFL, 0) = 1 " +
|
||||
"LEFT JOIN SD_ENGINFO_B_H eng ON eng.STCD = section.RSTCD " +
|
||||
" AND NVL(eng.IS_DELETED, 0) = 0 " +
|
||||
"LEFT JOIN V_SD_FISHDICTORY_B dict ON dict.FISH_ID = fish.FTP " +
|
||||
" AND (dict.RVCD = 'ZY' OR dict.RVCD = eng.HBRVCD) " +
|
||||
"WHERE NVL(we.IS_DELETED, 0) = 0 " +
|
||||
// 旧库按 TASK_STATUS=Approved/null 过滤，新库改用 STATUS=1(完成) 承接审批通过口径
|
||||
"AND NVL(we.STATUS, 1) = 1 ";
|
||||
}
|
||||
|
||||
private String buildWeFishQgcFilterCondition(DataSourceRequest.FilterDescriptor filter,
|
||||
Map<String, Object> paramMap,
|
||||
int[] indexHolder) {
|
||||
if (filter == null) {
|
||||
return "";
|
||||
}
|
||||
if (StrUtil.isNotBlank(filter.getField())) {
|
||||
return buildWeFishQgcLeafCondition(filter, paramMap, indexHolder);
|
||||
}
|
||||
if (CollUtil.isEmpty(filter.getFilters())) {
|
||||
return "";
|
||||
}
|
||||
List<String> conditions = new ArrayList<>();
|
||||
for (DataSourceRequest.FilterDescriptor child : filter.getFilters()) {
|
||||
String childSql = buildWeFishQgcFilterCondition(child, paramMap, indexHolder);
|
||||
if (StrUtil.isNotBlank(childSql)) {
|
||||
conditions.add("(" + childSql + ")");
|
||||
}
|
||||
}
|
||||
if (conditions.isEmpty()) {
|
||||
return "";
|
||||
}
|
||||
String logic = "or".equalsIgnoreCase(filter.getLogic()) ? " OR " : " AND ";
|
||||
return String.join(logic, conditions);
|
||||
}
|
||||
|
||||
private String buildWeFishQgcLeafCondition(DataSourceRequest.FilterDescriptor filter,
|
||||
Map<String, Object> paramMap,
|
||||
int[] indexHolder) {
|
||||
String column = mapWeFishQgcColumn(filter.getField());
|
||||
if (StrUtil.isBlank(column)) {
|
||||
return "";
|
||||
}
|
||||
String operator = StrUtil.blankToDefault(filter.getOperator(), "eq").toLowerCase();
|
||||
if ("isnull".equals(operator)) {
|
||||
return column + " IS NULL";
|
||||
}
|
||||
if ("isnotnull".equals(operator)) {
|
||||
return column + " IS NOT NULL";
|
||||
}
|
||||
if ("isempty".equals(operator)) {
|
||||
return "(" + column + " IS NULL OR " + column + " = '')";
|
||||
}
|
||||
if ("isnotempty".equals(operator)) {
|
||||
return "(" + column + " IS NOT NULL AND " + column + " <> '')";
|
||||
}
|
||||
if ("in".equals(operator) || "ni".equals(operator)) {
|
||||
List<Object> values = normalizeWeFishQgcValues(filter.getValue());
|
||||
if (values.isEmpty()) {
|
||||
return "";
|
||||
}
|
||||
List<String> placeholders = new ArrayList<>();
|
||||
for (Object value : values) {
|
||||
Object normalizedValue = normalizeWeFishQgcValue(filter.getField(), value);
|
||||
if (normalizedValue == null) {
|
||||
continue;
|
||||
}
|
||||
String key = "weFishQgcP" + indexHolder[0]++;
|
||||
paramMap.put(key, normalizedValue);
|
||||
placeholders.add("#{map." + key + "}");
|
||||
}
|
||||
if (placeholders.isEmpty()) {
|
||||
return "";
|
||||
}
|
||||
return column + ("ni".equals(operator) ? " NOT IN (" : " IN (") + String.join(", ", placeholders) + ")";
|
||||
}
|
||||
|
||||
Object normalizedValue = normalizeWeFishQgcValue(filter.getField(), filter.getValue());
|
||||
if (normalizedValue == null) {
|
||||
return "";
|
||||
}
|
||||
String key = "weFishQgcP" + indexHolder[0]++;
|
||||
return switch (operator) {
|
||||
case "eq" -> {
|
||||
paramMap.put(key, normalizedValue);
|
||||
yield column + " = #{map." + key + "}";
|
||||
}
|
||||
case "neq" -> {
|
||||
paramMap.put(key, normalizedValue);
|
||||
yield column + " <> #{map." + key + "}";
|
||||
}
|
||||
case "gt" -> {
|
||||
paramMap.put(key, normalizedValue);
|
||||
yield column + " > #{map." + key + "}";
|
||||
}
|
||||
case "gte" -> {
|
||||
paramMap.put(key, normalizedValue);
|
||||
yield column + " >= #{map." + key + "}";
|
||||
}
|
||||
case "lt" -> {
|
||||
paramMap.put(key, normalizedValue);
|
||||
yield column + " < #{map." + key + "}";
|
||||
}
|
||||
case "lte" -> {
|
||||
paramMap.put(key, normalizedValue);
|
||||
yield column + " <= #{map." + key + "}";
|
||||
}
|
||||
case "contains" -> {
|
||||
paramMap.put(key, "%" + String.valueOf(normalizedValue).trim() + "%");
|
||||
yield column + " LIKE #{map." + key + "}";
|
||||
}
|
||||
case "doesnotcontain" -> {
|
||||
paramMap.put(key, "%" + String.valueOf(normalizedValue).trim() + "%");
|
||||
yield column + " NOT LIKE #{map." + key + "}";
|
||||
}
|
||||
case "startswith" -> {
|
||||
paramMap.put(key, String.valueOf(normalizedValue).trim() + "%");
|
||||
yield column + " LIKE #{map." + key + "}";
|
||||
}
|
||||
case "endswith" -> {
|
||||
paramMap.put(key, "%" + String.valueOf(normalizedValue).trim());
|
||||
yield column + " LIKE #{map." + key + "}";
|
||||
}
|
||||
default -> "";
|
||||
};
|
||||
}
|
||||
|
||||
private String mapWeFishQgcColumn(String field) {
|
||||
if (StrUtil.isBlank(field)) {
|
||||
return null;
|
||||
}
|
||||
return switch (field) {
|
||||
case "stcd" -> "r.stcd";
|
||||
case "stnm" -> "r.stnm";
|
||||
case "baseId" -> "r.baseId";
|
||||
case "baseName" -> "r.baseName";
|
||||
case "rvcd" -> "r.rvcd";
|
||||
case "rvcdName" -> "r.rvcdName";
|
||||
case "addvcd" -> "r.addvcd";
|
||||
case "addvcdName" -> "r.addvcdName";
|
||||
case "hbrvcd" -> "r.hbrvcd";
|
||||
case "hbrvcdName" -> "r.hbrvcdName";
|
||||
case "dcpc" -> "r.dcpc";
|
||||
case "tm" -> "r.tm";
|
||||
case "werFid" -> "r.werFid";
|
||||
case "werId" -> "r.werId";
|
||||
case "ftp" -> "r.ftp";
|
||||
case "fsz" -> "r.fsz";
|
||||
case "fcnt" -> "r.fcnt";
|
||||
case "fwgh" -> "r.fwgh";
|
||||
case "st" -> "r.st";
|
||||
case "ps" -> "r.ps";
|
||||
case "avgFwgt" -> "r.avgFwgt";
|
||||
case "avgFsz" -> "r.avgFsz";
|
||||
case "fid" -> "r.fid";
|
||||
case "fileId" -> "r.fileId";
|
||||
case "id" -> "r.id";
|
||||
case "name" -> "r.name";
|
||||
case "alias" -> "r.alias";
|
||||
case "genus" -> "r.genus";
|
||||
case "family" -> "r.family";
|
||||
case "species" -> "r.species";
|
||||
case "type" -> "r.type";
|
||||
case "rare" -> "r.rare";
|
||||
case "specOrigin" -> "r.specOrigin";
|
||||
case "ptype" -> "r.ptype";
|
||||
case "yr" -> "r.yr";
|
||||
case "ty" -> "r.ty";
|
||||
default -> null;
|
||||
};
|
||||
}
|
||||
|
||||
private String mapWeFishQgcGroupColumn(String field) {
|
||||
String column = mapWeFishQgcColumn(field);
|
||||
if (StrUtil.isBlank(column)) {
|
||||
return null;
|
||||
}
|
||||
return column.startsWith("r.") ? column.substring(2) : column;
|
||||
}
|
||||
|
||||
private String buildWeFishQgcOrderBySql(List<DataSourceRequest.SortDescriptor> sorts) {
|
||||
if (CollUtil.isEmpty(sorts)) {
|
||||
return " ORDER BY r.tm DESC NULLS LAST, r.stcd ASC, r.name ASC";
|
||||
}
|
||||
List<String> orderByParts = new ArrayList<>();
|
||||
for (DataSourceRequest.SortDescriptor sort : sorts) {
|
||||
if (sort == null || StrUtil.isBlank(sort.getField())) {
|
||||
continue;
|
||||
}
|
||||
String column = mapWeFishQgcColumn(sort.getField());
|
||||
if (StrUtil.isBlank(column)) {
|
||||
continue;
|
||||
}
|
||||
String direction = "desc".equalsIgnoreCase(sort.getDir()) ? "DESC" : "ASC";
|
||||
orderByParts.add(column + " " + direction + " NULLS LAST");
|
||||
}
|
||||
if (orderByParts.isEmpty()) {
|
||||
return " ORDER BY r.tm DESC NULLS LAST, r.stcd ASC, r.name ASC";
|
||||
}
|
||||
return " ORDER BY " + String.join(", ", orderByParts);
|
||||
}
|
||||
|
||||
private Object normalizeWeFishQgcValue(String field, Object value) {
|
||||
if (value == null) {
|
||||
return null;
|
||||
}
|
||||
if (isWeFishIntegerField(field)) {
|
||||
try {
|
||||
return Integer.parseInt(String.valueOf(value).trim());
|
||||
} catch (Exception ex) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
if (isWeFishDecimalField(field)) {
|
||||
try {
|
||||
return new java.math.BigDecimal(String.valueOf(value).trim());
|
||||
} catch (Exception ex) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
if ("tm".equals(field)) {
|
||||
return parseDateTimeSafely(value);
|
||||
}
|
||||
return value;
|
||||
}
|
||||
|
||||
private List<Object> normalizeWeFishQgcValues(Object value) {
|
||||
List<Object> values = new ArrayList<>();
|
||||
if (value == null) {
|
||||
return values;
|
||||
}
|
||||
if (value instanceof Iterable<?> iterable) {
|
||||
for (Object item : iterable) {
|
||||
values.add(item);
|
||||
}
|
||||
return values;
|
||||
}
|
||||
if (value.getClass().isArray()) {
|
||||
Object[] array = (Object[]) value;
|
||||
values.addAll(Arrays.asList(array));
|
||||
return values;
|
||||
}
|
||||
values.add(value);
|
||||
return values;
|
||||
}
|
||||
|
||||
private boolean isWeFishIntegerField(String field) {
|
||||
return "fcnt".equals(field) || "ty".equals(field);
|
||||
}
|
||||
|
||||
private boolean isWeFishDecimalField(String field) {
|
||||
return "fwgh".equals(field) || "avgFwgt".equals(field) || "avgFsz".equals(field);
|
||||
}
|
||||
|
||||
private Date parseDateTimeSafely(Object value) {
|
||||
if (value == null) {
|
||||
return null;
|
||||
}
|
||||
if (value instanceof Date date) {
|
||||
return date;
|
||||
}
|
||||
try {
|
||||
return DateUtil.parse(String.valueOf(value).trim()).toJdkDate();
|
||||
} catch (Exception ex) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
private void fillWeFishDerivedFields(List<WeFishTQgcVo> list) {
|
||||
if (CollUtil.isEmpty(list)) {
|
||||
return;
|
||||
}
|
||||
for (WeFishTQgcVo item : list) {
|
||||
if (item == null) {
|
||||
continue;
|
||||
}
|
||||
item.setTyName(resolveTyName(item.getTy()));
|
||||
item.setSpecOriginName(resolveSpecOriginName(item.getSpecOrigin()));
|
||||
}
|
||||
}
|
||||
|
||||
private String resolveTyName(Integer ty) {
|
||||
if (ty == null) {
|
||||
return null;
|
||||
}
|
||||
return switch (ty) {
|
||||
case 1 -> "外来鱼类";
|
||||
case 2 -> "本土受威胁鱼类";
|
||||
case 3 -> "本土无危鱼类";
|
||||
default -> null;
|
||||
};
|
||||
}
|
||||
|
||||
private String resolveSpecOriginName(String specOrigin) {
|
||||
if (StrUtil.isBlank(specOrigin)) {
|
||||
return null;
|
||||
}
|
||||
return switch (specOrigin) {
|
||||
case "1" -> "本土";
|
||||
case "2" -> "外来鱼类";
|
||||
default -> null;
|
||||
};
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user