diff --git a/common/src/main/java/com/tencent/supersonic/common/service/impl/ChatModelServiceImpl.java b/common/src/main/java/com/tencent/supersonic/common/service/impl/ChatModelServiceImpl.java index dd289a3db..3259be432 100644 --- a/common/src/main/java/com/tencent/supersonic/common/service/impl/ChatModelServiceImpl.java +++ b/common/src/main/java/com/tencent/supersonic/common/service/impl/ChatModelServiceImpl.java @@ -57,6 +57,7 @@ public class ChatModelServiceImpl extends ServiceImpl= '2025-03-01' AND 数据日期 <= '2025-03-12' GROUP BY 用户) SELECT 用户, _总停留时长_ FROM 总停留时长"; sqlInfo.setParsedS2SQL(sql); sqlInfo.setCorrectedS2SQL(sql); semanticParseInfo.setSqlInfo(sqlInfo); corrector.correct(chatQueryContext, semanticParseInfo); Assert.assertEquals( - "WITH 总停留时长 AS (SELECT 用户名, SUM(停留时长) AS _总停留时长_ FROM 超音数数据集 WHERE 用户名 IN ('alice', 'lucy') AND 数据日期 " + - ">= '2025-03-01' AND 数据日期 <= '2025-03-12' GROUP BY 用户名) SELECT 用户名, _总停留时长_ FROM 总停留时长", + "WITH 总停留时长 AS (SELECT 用户名, SUM(停留时长) AS _总停留时长_ FROM 超音数数据集 WHERE 用户名 IN ('alice', 'lucy') AND 数据日期 " + + ">= '2025-03-01' AND 数据日期 <= '2025-03-12' GROUP BY 用户名) SELECT 用户名, _总停留时长_ FROM 总停留时长", semanticParseInfo.getSqlInfo().getCorrectedS2SQL()); } @@ -73,29 +74,17 @@ class AggCorrectorTest { dataSetSchema.setDataSet(schemaElement); Set dimensions = new HashSet<>(); - dimensions.add(SchemaElement.builder() - .dataSetId(1L) - .name("部门") - .build()); + dimensions.add(SchemaElement.builder().dataSetId(1L).name("部门").build()); - dimensions.add(SchemaElement.builder() - .dataSetId(1L) - .name("用户名") - .build()); + dimensions.add(SchemaElement.builder().dataSetId(1L).name("用户名").build()); dataSetSchema.setDimensions(dimensions); Set metrics = new HashSet<>(); - metrics.add(SchemaElement.builder() - .dataSetId(1L) - .name("访问次数") - .build()); + metrics.add(SchemaElement.builder().dataSetId(1L).name("访问次数").build()); - metrics.add(SchemaElement.builder() - .dataSetId(1L) - .name("停留时长") - .build()); + metrics.add(SchemaElement.builder().dataSetId(1L).name("停留时长").build()); dataSetSchema.setMetrics(metrics); dataSetSchemaList.add(dataSetSchema);