From 7ef64ba22da75016964b47fda0a3ce5d14fdd461 Mon Sep 17 00:00:00 2001 From: fit2cloud-chenyw Date: Fri, 18 Mar 2022 16:53:01 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=8F=92=E4=BB=B6=E5=8F=8D=E5=B0=84?= =?UTF-8?q?=E5=9B=9E=E8=B0=83=E6=95=B0=E6=8D=AE=E6=BA=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/chart/ChartViewService.java | 2 +- .../chart/ViewPluginBaseServiceImpl.java | 453 +++--------------- 2 files changed, 79 insertions(+), 376 deletions(-) diff --git a/backend/src/main/java/io/dataease/service/chart/ChartViewService.java b/backend/src/main/java/io/dataease/service/chart/ChartViewService.java index b7e8457839..6e85c9d04c 100644 --- a/backend/src/main/java/io/dataease/service/chart/ChartViewService.java +++ b/backend/src/main/java/io/dataease/service/chart/ChartViewService.java @@ -495,7 +495,7 @@ public class ChartViewService { // 如果是插件视图 走插件内部的逻辑 - if (view.getIsPlugin()) { + if (ObjectUtils.isNotEmpty(view.getIsPlugin()) && view.getIsPlugin()) { Map> fieldMap = new HashMap<>(); fieldMap.put("xAxis",xAxis); fieldMap.put("yAxis",yAxis); diff --git a/backend/src/main/java/io/dataease/service/chart/ViewPluginBaseServiceImpl.java b/backend/src/main/java/io/dataease/service/chart/ViewPluginBaseServiceImpl.java index 651739ded1..5d233ec9fb 100644 --- a/backend/src/main/java/io/dataease/service/chart/ViewPluginBaseServiceImpl.java +++ b/backend/src/main/java/io/dataease/service/chart/ViewPluginBaseServiceImpl.java @@ -1,29 +1,32 @@ package io.dataease.service.chart; +import cn.hutool.core.util.ReflectUtil; import com.google.gson.Gson; -import io.dataease.base.domain.DatasetTableField; -import io.dataease.base.domain.DatasetTableFieldExample; import io.dataease.base.domain.Datasource; -import io.dataease.base.mapper.DatasetTableFieldMapper; +import io.dataease.controller.request.chart.ChartExtFilterRequest; +import io.dataease.dto.chart.ChartFieldCustomFilterDTO; +import io.dataease.dto.chart.ChartViewFieldDTO; import io.dataease.dto.dataset.DataSetTableUnionDTO; import io.dataease.dto.dataset.DataTableInfoDTO; +import io.dataease.dto.sqlObj.SQLObj; import io.dataease.plugins.common.constants.SQLConstants; import io.dataease.plugins.common.util.BeanUtils; import io.dataease.plugins.common.util.ConstantsUtil; import io.dataease.plugins.view.entity.*; import io.dataease.plugins.view.service.ViewPluginBaseService; +import io.dataease.provider.ProviderFactory; +import io.dataease.provider.QueryProvider; +import io.dataease.provider.datasource.DatasourceProvider; import io.dataease.service.dataset.DataSetTableService; import io.dataease.service.dataset.DataSetTableUnionService; -import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import javax.annotation.Resource; -import java.text.SimpleDateFormat; +import java.lang.reflect.Method; import java.util.*; -import java.util.regex.Matcher; -import java.util.regex.Pattern; +import java.util.stream.Collectors; import static io.dataease.plugins.common.constants.SQLConstants.TABLE_ALIAS_PREFIX; @@ -31,17 +34,9 @@ import static io.dataease.plugins.common.constants.SQLConstants.TABLE_ALIAS_PREF public class ViewPluginBaseServiceImpl implements ViewPluginBaseService { - private static final Integer STRING = 0; - private static final Integer TIME = 1; - private static final Integer INT = 2; - private static final Integer FLOAT = 3; - /*private static final Integer BOOLEAN = 4;*/ - @Resource private DataSetTableUnionService dataSetTableUnionService; - @Resource - private DatasetTableFieldMapper datasetTableFieldMapper; @Resource private DataSetTableService dataSetTableService; @@ -54,19 +49,14 @@ public class ViewPluginBaseServiceImpl implements ViewPluginBaseService { String originField = getOriginName(dsType, pluginViewField, tableObj); - PluginViewSQL field = null; - String where = null; + PluginViewSQL field; + String where; String alias_fix = ConstantsUtil.constantsValue(dsType, "ALIAS_FIX"); String fieldAlias = String.format(alias_fix, String.format(FIELD_ALIAS_PREFIX, index)); - if (StringUtils.equals(pluginViewField.getTypeField(), "xAxis") || StringUtils.equals(pluginViewField.getTypeField(), "extStack")) { - field = getXFields(dsType, pluginViewField, originField, fieldAlias); - }else { - field = getYFields(dsType, pluginViewField, originField, fieldAlias); - where = getYWheres(dsType, pluginViewField, fieldAlias); - } + field = getField(dsType, pluginViewField, originField, fieldAlias); + where = getWhere(dsType, pluginViewField, originField, fieldAlias); PluginViewSQL sort = addSort(pluginViewField.getSort(), originField, fieldAlias); - Optional.ofNullable(field).ifPresent(f -> result.setField(f)); Optional.ofNullable(sort).ifPresent(s -> result.setSort(s)); Optional.ofNullable(where).ifPresent(w -> result.setWhere(w)); @@ -75,12 +65,28 @@ public class ViewPluginBaseServiceImpl implements ViewPluginBaseService { @Override public String customWhere(String dsType, List list, PluginViewSQL pluginViewSQL) { - return transCustomFilterList(dsType, pluginViewSQL, list); + QueryProvider queryProvider = ProviderFactory.getQueryProvider(dsType); + String methodName = "transCustomFilterList"; + SQLObj sqlObj = BeanUtils.copyBean(SQLObj.builder().build(), pluginViewSQL); + List filters = list.stream().map(item -> BeanUtils.copyBean(new ChartFieldCustomFilterDTO(), item)).collect(Collectors.toList()); + Object o ; + if ((o = execProviderMethod(queryProvider, methodName, sqlObj, filters)) != null) { + return (String)o; + } + return null; } @Override public String panelWhere(String dsType, List list, PluginViewSQL pluginViewSQL) { - return transExtFilterList(dsType, pluginViewSQL, list); + QueryProvider queryProvider = ProviderFactory.getQueryProvider(dsType); + String methodName = "transExtFilterList"; + SQLObj sqlObj = BeanUtils.copyBean(SQLObj.builder().build(), pluginViewSQL); + List filters = list.stream().map(item -> BeanUtils.copyBean(new ChartExtFilterRequest(), item)).collect(Collectors.toList()); + Object o; + if ((o = execProviderMethod(queryProvider, methodName, sqlObj, filters)) != null) { + return (String)o; + } + return null; } @Override @@ -121,7 +127,6 @@ public class ViewPluginBaseServiceImpl implements ViewPluginBaseService { String keyword_fix = ConstantsUtil.constantsValue(dsType, "KEYWORD_FIX"); String originField; if (ObjectUtils.isNotEmpty(pluginViewField.getExtField()) && pluginViewField.getExtField() == 2) { - // 解析origin name中有关联的字段生成sql表达式 originField = calcFieldRegex(dsType,pluginViewField.getOriginName(), tableObj); } else if (ObjectUtils.isNotEmpty(pluginViewField.getExtField()) && pluginViewField.getExtField() == 1) { originField = String.format(keyword_fix, tableObj.getTableAlias(), pluginViewField.getOriginName()); @@ -131,108 +136,51 @@ public class ViewPluginBaseServiceImpl implements ViewPluginBaseService { return originField; } - private String calcFieldRegex(String dsType, String originField, PluginViewSQL tableObj) { - originField = originField.replaceAll("[\\t\\n\\r]]", ""); - // 正则提取[xxx] - String regex = "\\[(.*?)]"; - Pattern pattern = Pattern.compile(regex); - Matcher matcher = pattern.matcher(originField); - Set ids = new HashSet<>(); - while (matcher.find()) { - String id = matcher.group(1); - ids.add(id); + private String calcFieldRegex(String dsType, String originField, PluginViewSQL pluginViewSQL) { + QueryProvider queryProvider = ProviderFactory.getQueryProvider(dsType); + String methodName = "calcFieldRegex"; + SQLObj sqlObj = BeanUtils.copyBean(SQLObj.builder().build(), pluginViewSQL); + Object o ; + if ((o = execProviderMethod(queryProvider, methodName, originField, sqlObj)) != null) { + return (String)o; } - if (CollectionUtils.isEmpty(ids)) { - return originField; - } - DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample(); - datasetTableFieldExample.createCriteria().andIdIn(new ArrayList<>(ids)); - List calcFields = datasetTableFieldMapper.selectByExample(datasetTableFieldExample); - String keyword_fix = ConstantsUtil.constantsValue(dsType, "KEYWORD_FIX"); - for (DatasetTableField ele : calcFields) { - originField = originField.replaceAll("\\[" + ele.getId() + "]", String.format(keyword_fix, tableObj.getTableAlias(), ele.getOriginName())); - } - return originField; + return null; } - - private PluginViewSQL getXFields(String dsType, PluginViewField x, String originField, String fieldAlias) { - - String fieldName = ""; - String calc_sub = ConstantsUtil.constantsValue(dsType, "CALC_SUB"); - String to_date = ConstantsUtil.constantsValue(dsType, "TO_DATE"); - String default_start_date = ConstantsUtil.constantsValue(dsType, "DEFAULT_START_DATE"); - String default_date_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_DATE_FORMAT"); - String to_number = ConstantsUtil.constantsValue(dsType, "TO_NUMBER"); - String to_ms = ConstantsUtil.constantsValue(dsType, "TO_MS"); - String to_char = ConstantsUtil.constantsValue(dsType, "TO_CHAR"); - String default_start_date_c = ConstantsUtil.constantsValue(dsType, "DEFAULT_START_DATE"); - if (x.getDeExtractType() == TIME) { - if (x.getDeType() == INT || x.getDeType() == FLOAT) { //时间转数值 - if (x.getType().equalsIgnoreCase("DATE")) { - String date = String.format(calc_sub, originField, String.format(to_date, default_start_date, default_date_format)); - fieldName = String.format(to_number, date) + to_ms; - } else { - String toChar = String.format(to_char, originField, default_date_format); - String toDate = String.format(to_date, toChar, default_date_format); - String toDate1 = String.format(to_date, default_start_date_c, default_date_format); - fieldName = String.format(to_number, String.format(calc_sub, toDate, toDate1)) + to_ms; - } - } else if (x.getDeType() == TIME) { //格式化显示时间 - String format = transDateFormat(x.getDateStyle(), x.getDatePattern()); - if (x.getType().equalsIgnoreCase("DATE")) { - fieldName = String.format(to_char, originField, format); - } else { - String toChar = String.format(to_char, originField, default_date_format); - String toDate = String.format(to_date, toChar, default_date_format); - fieldName = String.format(to_char, toDate, format); - } - } else { - fieldName = originField; - } - } else { - if (x.getDeType() == TIME) { - String format = transDateFormat(x.getDateStyle(), x.getDatePattern()); - if (x.getDeExtractType() == STRING) { //字符串转时间 - String toDate = String.format(to_date, originField, default_date_format); - fieldName = String.format(to_char, toDate, format); - } else { //数值转时间 - String date = originField + "/(1000 * 60 * 60 * 24)+" + String.format(to_date, default_start_date_c, default_date_format); - fieldName = String.format(to_char, date, format); - } - } else { - fieldName = originField; - } + private PluginViewSQL getField(String dsType, PluginViewField field, String originField, String fieldAlias) { + QueryProvider queryProvider = ProviderFactory.getQueryProvider(dsType); + String methodName; + if (StringUtils.equals(field.getTypeField(), "xAxis") || StringUtils.equals(field.getTypeField(), "extStack")) { + methodName = "getXFields"; + }else { + methodName = "getYFields"; } - return PluginViewSQL.builder().fieldName(fieldName).fieldAlias(fieldAlias).build(); + ChartViewFieldDTO chartViewFieldDTO = BeanUtils.copyBean(new ChartViewFieldDTO(), field); + Object execResult; + if ((execResult = execProviderMethod(queryProvider, methodName, chartViewFieldDTO, originField, fieldAlias)) != null){ + SQLObj sqlObj = (SQLObj)execResult; + PluginViewSQL result = PluginViewSQL.builder().build(); + return BeanUtils.copyBean(result, sqlObj); + } + return null; } - private PluginViewSQL getYFields(String dsType, PluginViewField y, String originField, String fieldAlias) { - String fieldName = ""; - if (StringUtils.equalsIgnoreCase(y.getOriginName(), "*")) { - - fieldName = ConstantsUtil.constantsValue(dsType, "AGG_COUNT"); - } else if (SQLConstants.DIMENSION_TYPE.contains(y.getDeType())) { - fieldName = String.format(ConstantsUtil.constantsValue(dsType, "AGG_FIELD"), y.getSummary(), originField); - } else { - String cast_constants = ConstantsUtil.constantsValue(dsType, "CAST"); - String agg_field_constants = ConstantsUtil.constantsValue(dsType, "AGG_FIELD"); - String default_int_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_INT_FORMAT"); - String default_float_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_FLOAT_FORMAT"); - if (StringUtils.equalsIgnoreCase(y.getSummary(), "avg") || StringUtils.containsIgnoreCase(y.getSummary(), "pop")) { - String cast = String.format(cast_constants, originField, y.getDeType() == 2 ? default_int_format : default_float_format); - String agg = String.format(agg_field_constants, y.getSummary(), cast); - fieldName = String.format(cast_constants, agg, ConstantsUtil.constantsValue(dsType, "DEFAULT_FLOAT_FORMAT")); - } else { - String cast = String.format(cast_constants, originField, y.getDeType() == 2 ? default_int_format : default_float_format); - fieldName = String.format(agg_field_constants, y.getSummary(), cast); + private Object execProviderMethod(QueryProvider queryProvider, String methodName, Object... args) { + Method[] declaredMethods = queryProvider.getClass().getDeclaredMethods(); + for (int i = 0; i < declaredMethods.length; i++) { + Method method = declaredMethods[i]; + if (StringUtils.equals(method.getName(), methodName)) { + method.setAccessible(true); + return ReflectUtil.invoke(queryProvider, method, args); } } - return PluginViewSQL.builder().fieldName(fieldName).fieldAlias(fieldAlias).build(); + return null; } + + private PluginViewSQL addSort(String sort, String originField, String fieldAlias) { if (StringUtils.isNotEmpty(sort) && !StringUtils.equalsIgnoreCase(sort, "none")) { return PluginViewSQL.builder().orderField(originField).orderAlias(fieldAlias).orderDirection(sort).build(); @@ -240,267 +188,22 @@ public class ViewPluginBaseServiceImpl implements ViewPluginBaseService { return null; } - private String getYWheres(String dsType, PluginViewField y,String fieldAlias) { - List list = new ArrayList<>(); - if (CollectionUtils.isNotEmpty(y.getFilter()) && y.getFilter().size() > 0) { - y.getFilter().forEach(f -> { - String whereTerm = transMysqlFilterTerm(f.getTerm()); - String whereValue = ""; - // 原始类型不是时间，在de中被转成时间的字段做处理 - if (StringUtils.equalsIgnoreCase(f.getTerm(), "null")) { - whereValue = ""; - } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "not_null")) { - whereValue = ""; - } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "empty")) { - whereValue = "''"; - } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "not_empty")) { - whereValue = "''"; - } else if (StringUtils.containsIgnoreCase(f.getTerm(), "in")) { - whereValue = "('" + StringUtils.join(f.getValue(), "','") + "')"; - } else if (StringUtils.containsIgnoreCase(f.getTerm(), "like")) { - whereValue = "'%" + f.getValue() + "%'"; - } else { - String where_value_value = ConstantsUtil.constantsValue(dsType, "WHERE_VALUE_VALUE"); - whereValue = String.format(where_value_value, f.getValue()); - } - list.add(PluginViewSQL.builder().whereField(fieldAlias).whereAlias(fieldAlias).whereTermAndValue(whereTerm + whereValue).build()); - }); + private String getWhere(String dsType, PluginViewField field,String originField,String fieldAlias) { + QueryProvider queryProvider = ProviderFactory.getQueryProvider(dsType); + String methodName; + if (StringUtils.equals(field.getTypeField(), "xAxis") || StringUtils.equals(field.getTypeField(), "extStack")) { + return null; + + }else { + methodName = "getYWheres"; } - List strList = new ArrayList<>(); - list.forEach(ele -> strList.add(ele.getWhereField() + " " + ele.getWhereTermAndValue())); - return CollectionUtils.isNotEmpty(list) ? "(" + String.join(" " + getLogic(y.getLogic()) + " ", strList) + ")" : null; - } - - public String getLogic(String logic) { - if (logic != null) { - switch (logic) { - case "and": - return "AND"; - case "or": - return "OR"; - } + ChartViewFieldDTO chartViewFieldDTO = BeanUtils.copyBean(new ChartViewFieldDTO(), field); + Object execResult; + if ((execResult = execProviderMethod(queryProvider, methodName, chartViewFieldDTO, originField, fieldAlias)) != null){ + String where = (String)execResult; + return where; } - return "AND"; - } - - private String transDateFormat(String dateStyle, String datePattern) { - return null; } - public String transMysqlFilterTerm(String term) { - switch (term) { - case "eq": - return " = "; - case "not_eq": - return " <> "; - case "lt": - return " < "; - case "le": - return " <= "; - case "gt": - return " > "; - case "ge": - return " >= "; - case "in": - return " IN "; - case "not in": - return " NOT IN "; - case "like": - return " LIKE "; - case "not like": - return " NOT LIKE "; - case "null": - return " IS NULL "; - case "not_null": - return " IS NOT NULL "; - case "empty": - return " = "; - case "not_empty": - return " <> "; - case "between": - return " BETWEEN "; - default: - return ""; - } - } - - public String transCustomFilterList(String dsType, PluginViewSQL tableObj, List requestList) { - if (CollectionUtils.isEmpty(requestList)) { - return null; - } - List res = new ArrayList<>(); - String to_date = ConstantsUtil.constantsValue(dsType, "TO_DATE"); - String default_date_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_DATE_FORMAT"); - String cast_c = ConstantsUtil.constantsValue(dsType, "CAST"); - String default_int_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_INT_FORMAT"); - String from_unixtime = ConstantsUtil.constantsValue(dsType, "FROM_UNIXTIME"); - String default_float_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_FLOAT_FORMAT"); - String unix_timestamp = ConstantsUtil.constantsValue(dsType, "UNIX_TIMESTAMP"); - String where_value_value = ConstantsUtil.constantsValue(dsType, "WHERE_VALUE_VALUE"); - for (PluginChartFieldCustomFilter request : requestList) { - List list = new ArrayList<>(); - PluginDatasetTableField field = request.getField(); - - if (ObjectUtils.isEmpty(field)) { - continue; - } - String whereName = ""; - - PluginViewField pluginViewField = BeanUtils.copyBean(new PluginViewField(), field); - String originName = getOriginName(dsType, pluginViewField, tableObj); - - - - if (field.getDeType() == 1) { - if (field.getDeExtractType() == 0 || field.getDeExtractType() == 5) { - whereName = String.format(to_date, originName, default_date_format); - } - if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) { - String cast = String.format(cast_c, originName, default_int_format) + "/1000"; - whereName = String.format(from_unixtime, cast, default_float_format); - } - if (field.getDeExtractType() == 1) { - whereName = originName; - } - } else if (field.getDeType() == 2 || field.getDeType() == 3) { - if (field.getDeExtractType() == 0 || field.getDeExtractType() == 5) { - whereName = String.format(cast_c, originName,default_float_format); - } - if (field.getDeExtractType() == 1) { - whereName = String.format(unix_timestamp, originName) + "*1000"; - } - if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) { - whereName = originName; - } - } else { - whereName = originName; - } - - if (StringUtils.equalsIgnoreCase(request.getFilterType(), "enum")) { - if (CollectionUtils.isNotEmpty(request.getEnumCheckField())) { - res.add("(" + whereName + " IN ('" + String.join("','", request.getEnumCheckField()) + "'))"); - } - } else { - List filter = request.getFilter(); - for (PluginChartCustomFilterItem filterItemDTO : filter) { - String value = filterItemDTO.getValue(); - String whereTerm = transMysqlFilterTerm(filterItemDTO.getTerm()); - String whereValue = ""; - - if (StringUtils.equalsIgnoreCase(filterItemDTO.getTerm(), "null")) { - whereValue = ""; - } else if (StringUtils.equalsIgnoreCase(filterItemDTO.getTerm(), "not_null")) { - whereValue = ""; - } else if (StringUtils.equalsIgnoreCase(filterItemDTO.getTerm(), "empty")) { - whereValue = "''"; - } else if (StringUtils.equalsIgnoreCase(filterItemDTO.getTerm(), "not_empty")) { - whereValue = "''"; - } else if (StringUtils.containsIgnoreCase(filterItemDTO.getTerm(), "in")) { - whereValue = "('" + StringUtils.join(value, "','") + "')"; - } else if (StringUtils.containsIgnoreCase(filterItemDTO.getTerm(), "like")) { - whereValue = "'%" + value + "%'"; - } else { - if (field.getDeType() == 1) { - whereValue = String.format(to_date, "'" + value + "'", default_date_format); - } else { - whereValue = String.format(where_value_value, value); - } - } - list.add(PluginViewSQL.builder() - .whereField(whereName) - .whereTermAndValue(whereTerm + whereValue) - .build()); - } - - List strList = new ArrayList<>(); - list.forEach(ele -> strList.add(ele.getWhereField() + " " + ele.getWhereTermAndValue())); - if (CollectionUtils.isNotEmpty(list)) { - res.add("(" + String.join(" " + getLogic(request.getLogic()) + " ", strList) + ")"); - } - } - } - return CollectionUtils.isNotEmpty(res) ? "(" + String.join(" AND ", res) + ")" : null; - } - - public String transExtFilterList(String dsType, PluginViewSQL tableObj, List requestList) { - if (CollectionUtils.isEmpty(requestList)) { - return null; - } - List list = new ArrayList<>(); - String where_between = ConstantsUtil.constantsValue(dsType, "WHERE_BETWEEN"); - String default_date_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_DATE_FORMAT"); - String to_date = ConstantsUtil.constantsValue(dsType, "TO_DATE"); - String cast_c = ConstantsUtil.constantsValue(dsType, "CAST"); - String from_unixtime = ConstantsUtil.constantsValue(dsType, "FROM_UNIXTIME"); - String default_int_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_INT_FORMAT"); - String default_float_format = ConstantsUtil.constantsValue(dsType, "DEFAULT_FLOAT_FORMAT"); - String unix_timestamp = ConstantsUtil.constantsValue(dsType, "UNIX_TIMESTAMP"); - String where_value_value = ConstantsUtil.constantsValue(dsType, "WHERE_VALUE_VALUE"); - - for (PluginChartExtFilter request : requestList) { - List value = request.getValue(); - PluginDatasetTableField field = request.getDatasetTableField(); - if (CollectionUtils.isEmpty(value) || ObjectUtils.isEmpty(field)) { - continue; - } - String whereName = ""; - String whereTerm = transMysqlFilterTerm(request.getOperator()); - String whereValue = ""; - - String originName = getOriginName(dsType, BeanUtils.copyBean(new PluginViewField(), field), tableObj); - - - if (field.getDeType() == 1) { - if (field.getDeExtractType() == 0 || field.getDeExtractType() == 5) { - whereName = String.format(to_date, originName, default_date_format); - } - if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) { - String cast = String.format(cast_c, originName, default_int_format) + "/1000"; - whereName = String.format(from_unixtime, cast, default_date_format); - } - if (field.getDeExtractType() == 1) { - whereName = originName; - } - } else if (field.getDeType() == 2 || field.getDeType() == 3) { - if (field.getDeExtractType() == 0 || field.getDeExtractType() == 5) { - whereName = String.format(cast_c, originName, default_float_format); - } - if (field.getDeExtractType() == 1) { - whereName = String.format(unix_timestamp, originName) + "*1000"; - } - if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) { - whereName = originName; - } - } else { - whereName = originName; - } - - if (StringUtils.containsIgnoreCase(request.getOperator(), "in")) { - whereValue = "('" + StringUtils.join(value, "','") + "')"; - } else if (StringUtils.containsIgnoreCase(request.getOperator(), "like")) { - whereValue = "'%" + value.get(0) + "%'"; - } else if (StringUtils.containsIgnoreCase(request.getOperator(), "between")) { - if (request.getDatasetTableField().getDeType() == 1) { - SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - String startTime = simpleDateFormat.format(new Date(Long.parseLong(value.get(0)))); - String endTime = simpleDateFormat.format(new Date(Long.parseLong(value.get(1)))); - String st = String.format(to_date, "'" + startTime + "'", default_date_format); - String et = String.format(to_date, "'" + endTime + "'", default_date_format); - whereValue = st + " AND " + et; - } else { - whereValue = String.format(where_between, value.get(0), value.get(1)); - } - } else { - whereValue = String.format(where_value_value, value.get(0)); - } - list.add(PluginViewSQL.builder().whereField(whereName).whereTermAndValue(whereTerm + whereValue).build()); - - - - } - List strList = new ArrayList<>(); - list.forEach(ele -> strList.add(ele.getWhereField() + " " + ele.getWhereTermAndValue())); - return CollectionUtils.isNotEmpty(list) ? "(" + String.join(" AND ", strList) + ")" : null; - } }