OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

feat: UE/CDR查询条件imsi支持模糊匹配

Browse Source
This commit is contained in:
TsMask
2025-08-14 10:29:36 +08:00
parent c79786e1a1
commit 7783985c09
7 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
restagent/etc/restconf.yaml
View File

@@ -26,9 +26,9 @@ rest:
port: 33443
schema: https
clientAuthType: 0
caFile: ./etc/certs/omc-ca.crt
certFile: ./etc/certs/omc-server.crt
keyFile: ./etc/certs/omc-server.key
caFile: ./restagent/etc/certs/omc-ca.crt
certFile: ./restagent/etc/certs/omc-server.crt
keyFile: ./restagent/etc/certs/omc-server.key
webServer:
enabled: false

4
src/modules/network_data/repository/cdr_event_ims.go
View File

@@ -86,11 +86,11 @@ func (r *CDREventIMS) SelectPage(querys model.CDREventIMSQuery) map[string]any {
params = append(params, endTime)
}
if querys.CallerParty != "" {
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.callerParty') = ?")
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.callerParty') like concat(concat('%', ?), '%')")
params = append(params, querys.CallerParty)
}
if querys.CalledParty != "" {
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.calledParty') = ?")
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.calledParty') like concat(concat('%', ?), '%')")
params = append(params, querys.CalledParty)
}
// MySQL8支持的

4
src/modules/network_data/repository/cdr_event_sgwc.go
View File

@@ -39,10 +39,10 @@ func (r CDREventSGWC) SelectByPage(querys model.CDREventSGWCQuery) ([]model.CDRE
tx = tx.Where("timestamp <= ?", endTime)
}
if querys.IMSI != "" {
tx = tx.Where("JSON_EXTRACT(cdr_json, '$.servedIMSI') = ?", querys.IMSI)
tx = tx.Where("JSON_EXTRACT(cdr_json, '$.servedIMSI') like concat(concat('%', ?), '%')", querys.IMSI)
}
if querys.MSISDN != "" {
tx = tx.Where("JSON_EXTRACT(cdr_json, '$.servedMSISDN') = ?", querys.MSISDN)
tx = tx.Where("JSON_EXTRACT(cdr_json, '$.servedMSISDN') like concat(concat('%', ?), '%')", querys.MSISDN)
}
// 查询结果

2
src/modules/network_data/repository/cdr_event_smf.go
View File

@@ -91,7 +91,7 @@ func (r *CDREventSMF) SelectPage(querys model.CDREventSMFQuery) map[string]any {
params = append(params, querys.RecordType)
}
if querys.SubscriberID != "" {
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.subscriberIdentifier.subscriptionIDData') = ?")
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.subscriberIdentifier.subscriptionIDData') like concat(concat('%', ?), '%')")
params = append(params, querys.SubscriberID)
}
if querys.DNN != "" {

4
src/modules/network_data/repository/cdr_event_smsc.go
View File

@@ -86,11 +86,11 @@ func (r *CDREventSMSC) SelectPage(querys model.CDREventSMSCQuery) map[string]any
params = append(params, endTime)
}
if querys.CallerParty != "" {
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.callerParty') = ?")
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.callerParty') like concat(concat('%', ?), '%')")
params = append(params, querys.CallerParty)
}
if querys.CalledParty != "" {
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.calledParty') = ?")
conditions = append(conditions, "JSON_EXTRACT(cdr_json, '$.calledParty') like concat(concat('%', ?), '%')")
params = append(params, querys.CalledParty)
}
// MySQL8支持的

2
src/modules/network_data/repository/ue_event_amf.go
View File

@@ -95,7 +95,7 @@ func (r *UEEventAMF) SelectPage(querys model.UEEventAMFQuery) map[string]any {
}
}
if querys.IMSI != "" {
conditions = append(conditions, "JSON_EXTRACT(event_json, '$.imsi') = ?")
conditions = append(conditions, "JSON_EXTRACT(event_json, '$.imsi') like concat(concat('%', ?), '%')")
params = append(params, querys.IMSI)
}

2
src/modules/network_data/repository/ue_event_mme.go
View File

@@ -95,7 +95,7 @@ func (r *UEEventMME) SelectPage(querys model.UEEventMMEQuery) map[string]any {
}
}
if querys.IMSI != "" {
conditions = append(conditions, "JSON_EXTRACT(event_json, '$.imsi') = ?")
conditions = append(conditions, "JSON_EXTRACT(event_json, '$.imsi') like concat(concat('%', ?), '%')")
params = append(params, querys.IMSI)
}