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

feat: IMS的CDR数据导出

Browse Source
This commit is contained in:
TsMask
2024-06-07 19:45:21 +08:00
parent a57799c470
commit e6ae018f44
11 changed files with 400 additions and 484 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -10,17 +10,17 @@ import (
neDataService "be.ems/src/modules/network_data/service"
)
// GetCDRConnect 获取CDR会话事件-IMS
func GetCDRConnect(requestID string, data any) ([]byte, error) {
// GetCDRConnectByIMS 获取CDR会话事件-IMS
func GetCDRConnectByIMS(requestID string, data any) ([]byte, error) {
msgByte, _ := json.Marshal(data)
var query neDataModel.CDREventQuery
var query neDataModel.CDREventIMSQuery
err := json.Unmarshal(msgByte, &query)
if err != nil {
logger.Warnf("ws processor GetCDRConnect err: %s", err.Error())
return nil, fmt.Errorf("query data structure error")
}
dataMap := neDataService.NewCDREventImpl.SelectPage(query)
dataMap := neDataService.NewCDREventIMSImpl.SelectPage(query)
resultByte, err := json.Marshal(result.Ok(map[string]any{
"requestId": requestID,
"data": dataMap,
@@ -28,17 +28,17 @@ func GetCDRConnect(requestID string, data any) ([]byte, error) {
return resultByte, err
}
// GetCDRConnect 获取CDR会话事件-SMF
func GetSMFCDRConnect(requestID string, data any) ([]byte, error) {
// GetCDRConnectBySMF 获取CDR会话事件-SMF
func GetCDRConnectBySMF(requestID string, data any) ([]byte, error) {
msgByte, _ := json.Marshal(data)
var query neDataModel.SMFCDREventQuery
var query neDataModel.CDREventSMFQuery
err := json.Unmarshal(msgByte, &query)
if err != nil {
logger.Warnf("ws processor GetCDRConnect err: %s", err.Error())
return nil, fmt.Errorf("query data structure error")
}
dataMap := neDataService.NewSMFCDREventImpl.SelectPage(query)
dataMap := neDataService.NewCDREventSMFImpl.SelectPage(query)
resultByte, err := json.Marshal(result.Ok(map[string]any{
"requestId": requestID,
"data": dataMap,