From c402d106f1d5e1f300656caaad65fed976fb8e8d Mon Sep 17 00:00:00 2001 From: simonzhangsz Date: Tue, 23 Jul 2024 17:38:30 +0800 Subject: [PATCH] fix: ims CDR issue with recordType --- .../network_data/repository/cdr_event_ims.impl.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/modules/network_data/repository/cdr_event_ims.impl.go b/src/modules/network_data/repository/cdr_event_ims.impl.go index c025260d..53d017dd 100644 --- a/src/modules/network_data/repository/cdr_event_ims.impl.go +++ b/src/modules/network_data/repository/cdr_event_ims.impl.go @@ -93,11 +93,14 @@ func (r *CDREventIMSImpl) SelectPage(querys model.CDREventIMSQuery) map[string]a } if querys.RecordType != "" { recordTypes := strings.Split(querys.RecordType, ",") - placeholder := repo.KeyPlaceholderByQuery(len(recordTypes)) - conditions = append(conditions, fmt.Sprintf("JSON_EXTRACT(cdr_json, '$.recordType') in (%s)", placeholder)) + // placeholder := repo.KeyPlaceholderByQuery(len(recordTypes)) + // conditions = append(conditions, fmt.Sprintf("JSON_EXTRACT(cdr_json, '$.recordType') in (%s)", placeholder)) + var querys []string for _, recordType := range recordTypes { - params = append(params, recordType) + querys = append(querys, fmt.Sprintf("JSON_EXTRACT(cdr_json, '$.recordType') = '%s'", recordType)) + //params = append(params, recordType) } + conditions = append(conditions, "("+strings.Join(querys, " OR ")+")") } // for multi-tenancy solution