feat(数据集): 数据集增加分组字段功能

This commit is contained in:
junjun
2025-02-11 10:39:42 +08:00
committed by Junjun
parent aab018cf36
commit 52c97e4a81

View File

@@ -510,9 +510,10 @@ public class Utils {
}
StringBuilder exp = new StringBuilder();
exp.append(" (CASE WHEN ");
exp.append(" (CASE ");
if (originField.getDeType() == 0) {
for (FieldGroupDTO fieldGroupDTO : dto.getGroupList()) {
exp.append(" WHEN ");
for (int i = 0; i < fieldGroupDTO.getText().size(); i++) {
String value = fieldGroupDTO.getText().get(i);
exp.append(originField.getDataeaseName()).append(" = ").append("'").append(value).append("'");
@@ -524,6 +525,7 @@ public class Utils {
}
} else if (originField.getDeType() == 1) {
for (FieldGroupDTO fieldGroupDTO : dto.getGroupList()) {
exp.append(" WHEN ");
exp.append(originField.getDataeaseName()).append(" >= ").append("'").append(fieldGroupDTO.getStartTime()).append("'");
exp.append(" AND ");
exp.append(originField.getDataeaseName()).append(" <= ").append("'").append(fieldGroupDTO.getEndTime()).append("'");
@@ -531,6 +533,7 @@ public class Utils {
}
} else if (originField.getDeType() == 2 || originField.getDeType() == 3 || originField.getDeType() == 4) {
for (FieldGroupDTO fieldGroupDTO : dto.getGroupList()) {
exp.append(" WHEN ");
exp.append(originField.getDataeaseName()).append(StringUtils.equalsIgnoreCase(fieldGroupDTO.getMinTerm(), "le") ? " >= " : " > ").append(fieldGroupDTO.getMin());
exp.append(" AND ");
exp.append(originField.getDataeaseName()).append(StringUtils.equalsIgnoreCase(fieldGroupDTO.getMaxTerm(), "le") ? " <= " : " < ").append(fieldGroupDTO.getMax());