feat: ISMF的CDR数据接口代码整理

src/modules/network_data/service/cdr_event_smf.go

@@ -0,0 +1,12 @@
+package service
+
+import "be.ems/src/modules/network_data/model"
+
+// CDR会话事件SMF 服务层接口
+type ICDREventSMF interface {
+	// SelectPage 根据条件分页查询
+	SelectPage(querys model.CDREventSMFQuery) map[string]any
+
+	// DeleteByIds 批量删除信息
+	DeleteByIds(cdrIds []string) (int64, error)
+}

src/modules/network_data/service/cdr_event_smf.impl.go

@@ -0,0 +1,37 @@
+package service
+
+import (
+	"fmt"
+
+	"be.ems/src/modules/network_data/model"
+	"be.ems/src/modules/network_data/repository"
+)
+
+var NewCDREventSMFImpl = &CDREventSMFImpl{
+	cdrEventRepository: repository.NewCDREventSMFImpl,
+}
+
+type CDREventSMFImpl struct {
+	// CDR会话事件数据信息
+	cdrEventRepository repository.ICDREventSMF
+}
+
+func (r *CDREventSMFImpl) SelectPage(querys model.CDREventSMFQuery) map[string]any {
+	return r.cdrEventRepository.SelectPage(querys)
+}
+
+// DeleteByIds 批量删除信息
+func (r *CDREventSMFImpl) DeleteByIds(cdrIds []string) (int64, error) {
+	// 检查是否存在
+	ids := r.cdrEventRepository.SelectByIds(cdrIds)
+	if len(ids) <= 0 {
+		return 0, fmt.Errorf("not data")
+	}
+
+	if len(ids) == len(cdrIds) {
+		rows := r.cdrEventRepository.DeleteByIds(cdrIds)
+		return rows, nil
+	}
+	// 删除信息失败！
+	return 0, fmt.Errorf("delete fail")
+}