feat(data): 添加时间戳数据类型支持并优化维度转换逻辑

- 新增 TIMESTAMP 数据类型枚举值
- 为整型数据类型匹配添加 INT 关键字识别
- 移除维度转换中的冗余数据类型设置逻辑
- 修复数据类型转换过程中的潜在问题

common/src/main/java/com/tencent/supersonic/common/calcite/SqlDialectFactory.java

@@ -26,12 +26,10 @@ public class SqlDialectFactory {
                     .withLiteralQuoteString("'").withIdentifierQuoteString("\"")
                     .withLiteralEscapedQuoteString("''").withUnquotedCasing(Casing.UNCHANGED)
                     .withQuotedCasing(Casing.UNCHANGED).withCaseSensitive(true);
-    public static final Context PRESTO_CONTEXT =
+    public static final Context PRESTO_CONTEXT = SqlDialect.EMPTY_CONTEXT
-            SqlDialect.EMPTY_CONTEXT.withDatabaseProduct(DatabaseProduct.PRESTO)
+            .withDatabaseProduct(DatabaseProduct.PRESTO).withLiteralQuoteString("'")
-                    .withLiteralQuoteString("'")
+            .withLiteralEscapedQuoteString("''").withUnquotedCasing(Casing.UNCHANGED)
-                    .withLiteralEscapedQuoteString("''")
+            .withQuotedCasing(Casing.UNCHANGED).withCaseSensitive(true);
-                    .withUnquotedCasing(Casing.UNCHANGED)
-                    .withQuotedCasing(Casing.UNCHANGED).withCaseSensitive(true);
     public static final Context KYUUBI_CONTEXT =
             SqlDialect.EMPTY_CONTEXT.withDatabaseProduct(DatabaseProduct.BIG_QUERY)
                     .withLiteralQuoteString("'").withIdentifierQuoteString("`")

common/src/main/java/com/tencent/supersonic/common/pojo/enums/DataTypeEnums.java

@@ -11,6 +11,8 @@ public enum DataTypeEnums {
 
     DATE("DATE"),
 
+    TIMESTAMP("TIMESTAMP"),
+
     BIGINT("BIGINT"),
 
     INT("INT"),
@@ -39,6 +41,9 @@ public enum DataTypeEnums {
                 return typeEnum;
             }
         }
+        if (type != null && type.toUpperCase().contains("INT")) {
+            return DataTypeEnums.INT;
+        }
         return DataTypeEnums.UNKNOWN;
     }
 }

headless/chat/src/main/java/com/tencent/supersonic/headless/chat/ChatQueryContext.java

@@ -56,7 +56,8 @@ public class ChatQueryContext implements Serializable {
         candidateQueries = candidateQueries.stream()
                 .sorted(Comparator.comparing(
                         semanticQuery -> semanticQuery.getParseInfo().getScore(),
-                        Comparator.reverseOrder())).collect(Collectors.toList());
+                        Comparator.reverseOrder()))
+                .collect(Collectors.toList());
         return candidateQueries;
     }
 

headless/server/src/main/java/com/tencent/supersonic/headless/server/service/impl/DataSetServiceImpl.java

@@ -286,10 +286,8 @@ public class DataSetServiceImpl extends ServiceImpl<DataSetDOMapper, DataSetDO>
             return;
         }
 
-        Set<Long> includeAllModelIds = configs.stream()
+        Set<Long> includeAllModelIds = configs.stream().filter(DataSetModelConfig::getIncludesAll)
-                .filter(DataSetModelConfig::getIncludesAll)
+                .map(DataSetModelConfig::getId).collect(Collectors.toSet());
-                .map(DataSetModelConfig::getId)
-                .collect(Collectors.toSet());
 
         if (CollectionUtils.isEmpty(includeAllModelIds)) {
             return;
@@ -302,28 +300,26 @@ public class DataSetServiceImpl extends ServiceImpl<DataSetDOMapper, DataSetDO>
         List<DimensionResp> allDimensions = dimensionService.getDimensions(metaFilter);
         List<MetricResp> allMetrics = metricService.getMetrics(metaFilter);
 
-        Map<Long, List<Long>> modelDimensionMap = allDimensions.stream()
+        Map<Long, List<Long>> modelDimensionMap =
-                .collect(Collectors.groupingBy(
+                allDimensions.stream().collect(Collectors.groupingBy(DimensionResp::getModelId,
-                        DimensionResp::getModelId,
+                        Collectors.mapping(DimensionResp::getId, Collectors.toList())));
-                        Collectors.mapping(DimensionResp::getId, Collectors.toList())
-                ));
 
-        Map<Long, List<Long>> modelMetricMap = allMetrics.stream()
+        Map<Long, List<Long>> modelMetricMap =
-                .collect(Collectors.groupingBy(
+                allMetrics.stream().collect(Collectors.groupingBy(MetricResp::getModelId,
-                        MetricResp::getModelId,
+                        Collectors.mapping(MetricResp::getId, Collectors.toList())));
-                        Collectors.mapping(MetricResp::getId, Collectors.toList())
-                ));
 
         for (DataSetModelConfig config : configs) {
             if (Boolean.TRUE.equals(config.getIncludesAll())) {
                 Long modelId = config.getId();
 
-                List<Long> modelDimensions = modelDimensionMap.getOrDefault(modelId, Lists.newArrayList());
+                List<Long> modelDimensions =
+                        modelDimensionMap.getOrDefault(modelId, Lists.newArrayList());
                 Set<Long> existingDimensions = new HashSet<>(config.getDimensions());
                 existingDimensions.addAll(modelDimensions);
                 config.setDimensions(new ArrayList<>(existingDimensions));
 
-                List<Long> modelMetrics = modelMetricMap.getOrDefault(modelId, Lists.newArrayList());
+                List<Long> modelMetrics =
+                        modelMetricMap.getOrDefault(modelId, Lists.newArrayList());
                 Set<Long> existingMetrics = new HashSet<>(config.getMetrics());
                 existingMetrics.addAll(modelMetrics);
                 config.setMetrics(new ArrayList<>(existingMetrics));

headless/server/src/main/java/com/tencent/supersonic/headless/server/utils/DimensionConverter.java

@@ -73,9 +73,6 @@ public class DimensionConverter {
         if (dimensionReq.getTypeParams() != null) {
             dimensionDO.setTypeParams(JSONObject.toJSONString(dimensionReq.getTypeParams()));
         }
-        if (dimensionReq.getDataType() != null) {
-            dimensionDO.setDataType(dimensionReq.getDataType().getType());
-        }
         dimensionDO.setStatus(StatusEnum.ONLINE.getCode());
         return dimensionDO;
     }