diff --git a/src/modules/network_data/repository/cdr_event_smsc.impl.go b/src/modules/network_data/repository/cdr_event_smsc.impl.go index 8d1899ba..c8b4b6ed 100644 --- a/src/modules/network_data/repository/cdr_event_smsc.impl.go +++ b/src/modules/network_data/repository/cdr_event_smsc.impl.go @@ -83,6 +83,14 @@ func (r *CDREventSMSCImpl) SelectPage(querys model.CDREventSMSCQuery) map[string } params = append(params, querys.EndTime) } + if querys.CallerParty != "" { + conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.callerParty') = ?") + params = append(params, querys.CallerParty) + } + if querys.CalledParty != "" { + conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.calledParty') = ?") + params = append(params, querys.CalledParty) + } // MySQL8支持的 // if querys.RecordType != "" { // recordTypes := strings.Split(querys.RecordType, ",")