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

fix: common去除Impi层

Browse Source
This commit is contained in:
TsMask
2024-12-20 16:35:32 +08:00
parent 4c57fe2c85
commit 6bfdef3ea5
4 changed files with 88 additions and 101 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/modules/ws/processor/cdr_connect.go
View File

@@ -28,10 +28,10 @@ func GetCDRConnectByIMS(requestID string, data any) ([]byte, error) {
}
query.RmUID = neInfo.RmUID
dataMap := neDataService.NewCDREventIMS.SelectPage(query)
rows, total := neDataService.NewCDREventIMS.SelectPage(query)
resultByte, err := json.Marshal(result.Ok(map[string]any{
"requestId": requestID,
"data": dataMap,
"data": map[string]any{"rows": rows, "total": total},
}))
return resultByte, err
}
@@ -53,10 +53,10 @@ func GetCDRConnectBySMF(requestID string, data any) ([]byte, error) {
}
query.RmUID = neInfo.RmUID
dataMap := neDataService.NewCDREventSMF.SelectPage(query)
rows, total := neDataService.NewCDREventSMF.SelectPage(query)
resultByte, err := json.Marshal(result.Ok(map[string]any{
"requestId": requestID,
"data": dataMap,
"data": map[string]any{"rows": rows, "total": total},
}))
return resultByte, err
}
@@ -78,10 +78,10 @@ func GetCDRConnectBySMSC(requestID string, data any) ([]byte, error) {
}
query.RmUID = neInfo.RmUID
dataMap := neDataService.NewCDREventSMSC.SelectPage(query)
rows, total := neDataService.NewCDREventSMSC.SelectPage(query)
resultByte, err := json.Marshal(result.Ok(map[string]any{
"requestId": requestID,
"data": dataMap,
"data": map[string]any{"rows": rows, "total": total},
}))
return resultByte, err
}