|
@@ -69,14 +69,15 @@ public class ForecastOrderTagHandler extends AbstractTagHandler {
|
|
|
for(ForecastParam param : paramList) {
|
|
|
String columnName = param.getEnglishName().toUpperCase(),
|
|
|
columnNameC = columnName+"_C", columnNameV = columnName+"_V";
|
|
|
- sqlBuilder.appendLn(String.format("%s.%s as %s,", param.getTableAlias(), columnName, columnName));
|
|
|
- sqlBuilder.appendLn(String.format("%s.%s as %s,", param.getTableAlias(), columnNameC, columnNameC));
|
|
|
- sqlBuilder.appendLn(String.format("%s.%s as %s,", param.getTableAlias(), columnNameV, columnNameV));
|
|
|
+ sqlBuilder.appendLn(String.format("max(%s.%s) as %s,", param.getTableAlias(), columnName, columnName));
|
|
|
+ sqlBuilder.appendLn(String.format("max(%s.%s) as %s,", param.getTableAlias(), columnNameC, columnNameC));
|
|
|
+ sqlBuilder.appendLn(String.format("max(%s.%s) as %s,", param.getTableAlias(), columnNameV, columnNameV));
|
|
|
}
|
|
|
sqlBuilder.deleteLastChar().deleteLastChar().appendLn("").appendLn("from");
|
|
|
for(ForecastParam param : paramList) {
|
|
|
sqlBuilder.appendLn(_genOrderPreferenceSql(param, tagListMap));
|
|
|
}
|
|
|
+ sqlBuilder.appendLn(" group by USERID_PRE");
|
|
|
log.info("\n" + sqlBuilder.toString());
|
|
|
dynamicExecuteService.execute(DsEnum.clickhouse, sqlBuilder.toString(), "订购偏好预测[临时表]生成");
|
|
|
}
|