M_Kececi/bssapp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
M_Kececi
2026-04-20 10:04:29 +03:00
parent 7ef12df93a
commit 8462df878f
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
svc/queries/product_pricing.go
View File

@@ -94,13 +94,19 @@ func GetProductPricingList(ctx context.Context, limit int, afterProductCode stri
for _, item := range out { for _, item := range out {
codes = append(codes, strings.TrimSpace(item.ProductCode)) codes = append(codes, strings.TrimSpace(item.ProductCode))
} }
codesCSV := strings.Join(codes, ",") valueRows := make([]string, 0, len(codes))
metricArgs := make([]any, 0, len(codes))
for i, code := range codes {
paramName := "@p" + strconv.Itoa(i+1)
valueRows = append(valueRows, "("+paramName+")")
metricArgs = append(metricArgs, code)
}
metricsQuery := ` metricsQuery := `
WITH req_codes AS ( WITH req_codes AS (
SELECT DISTINCT LTRIM(RTRIM(value)) AS ProductCode SELECT DISTINCT LTRIM(RTRIM(v.ProductCode)) AS ProductCode
FROM STRING_SPLIT(@p1, ',') FROM (VALUES ` + strings.Join(valueRows, ",") + `) v(ProductCode)
WHERE LEN(LTRIM(RTRIM(value))) > 0 WHERE LEN(LTRIM(RTRIM(v.ProductCode))) > 0
), ),
latest_base_price AS ( latest_base_price AS (
SELECT SELECT
@@ -206,7 +212,7 @@ func GetProductPricingList(ctx context.Context, limit int, afterProductCode stri
ON db.ItemCode = rc.ProductCode; ON db.ItemCode = rc.ProductCode;
` `
metricsRows, err := db.MssqlDB.QueryContext(ctx, metricsQuery, codesCSV) metricsRows, err := db.MssqlDB.QueryContext(ctx, metricsQuery, metricArgs...)
if err != nil { if err != nil {
return nil, fmt.Errorf("metrics query failed: %w", err) return nil, fmt.Errorf("metrics query failed: %w", err)
} }