diff --git a/features/cdr/cdrevent.go b/features/cdr/cdrevent.go
index 2f0efecd..02c95243 100644
--- a/features/cdr/cdrevent.go
+++ b/features/cdr/cdrevent.go
@@ -279,11 +279,7 @@ func PostCDREventFromSMF(w http.ResponseWriter, r *http.Request) {
 	}
 
 	// 推送到ws订阅组
-	// if v, ok := cdrEvent.CDR["recordType"]; ok {
-	// 	if v == "MOC" || v == "MTSM" {
-	// 		wsService.NewWSSendImpl.ByGroupID(wsService.GROUP_IMS_CDR, cdrEvent)
-	// 	}
-	// }
+	wsService.NewWSSendImpl.ByGroupID(wsService.GROUP_SMF_CDR, cdrEvent)
 
 	services.ResponseStatusOK204NoContent(w)
 }
diff --git a/src/modules/ws/service/ws_receive.impl.go b/src/modules/ws/service/ws_receive.impl.go
index 3df49304..db1d967c 100644
--- a/src/modules/ws/service/ws_receive.impl.go
+++ b/src/modules/ws/service/ws_receive.impl.go
@@ -68,10 +68,12 @@ func (s *WSReceiveImpl) AsyncReceive(client *model.WSClient, reqMsg model.WSRequ
 		resByte, err = processor.GetProcessData(reqMsg.RequestID, reqMsg.Data)
 	case "net":
 		resByte, err = processor.GetNetConnections(reqMsg.RequestID, reqMsg.Data)
-	case "cdr":
-		resByte, err = processor.GetCDRConnect(reqMsg.RequestID, reqMsg.Data)
-	case "ue":
-		resByte, err = processor.GetUEConnect(reqMsg.RequestID, reqMsg.Data)
+	case "ims_cdr":
+		resByte, err = processor.GetCDRConnectByIMS(reqMsg.RequestID, reqMsg.Data)
+	case "smf_cdr":
+		resByte, err = processor.GetCDRConnectBySMF(reqMsg.RequestID, reqMsg.Data)
+	case "amf_ue":
+		resByte, err = processor.GetUEConnectByAMF(reqMsg.RequestID, reqMsg.Data)
 	case "upf_tf":
 		resByte, err = processor.GetUPFTotalFlow(reqMsg.RequestID, reqMsg.Data)
 	case "ne_state":
diff --git a/src/modules/ws/service/ws_send.impl.go b/src/modules/ws/service/ws_send.impl.go
index 0720cc27..699961e3 100644
--- a/src/modules/ws/service/ws_send.impl.go
+++ b/src/modules/ws/service/ws_send.impl.go
@@ -18,6 +18,8 @@ const (
 	GROUP_KPI_UPF = "12"
 	// 组号-IMS_CDR会话事件
 	GROUP_IMS_CDR = "1005"
+	// 组号-SMF_CDR会话事件
+	GROUP_SMF_CDR = "1006"
 	// 组号-AMF_UE会话事件
 	GROUP_AMF_UE = "1010"
 )