xps-server-g5/pkg/biz/service/biz_object_oam_mapping_service.go

package service

import (
    "xps/cmd/datasource"
    "xps/pkg/biz/datamodel"
    "xps/pkg/biz/repository"
    "xps/pkg/biz/viewmodel"
)

type BizObjectOAMMappingService interface {
    GetList(m map[string]interface{}) ([]viewmodel.BizObjectOAMMappingInfo, error)
    GetById(bizId, objectId, oamId, mappingId int64) (*viewmodel.BizObjectOAMMappingInfo, error)
    Create(param *datamodel.BizObjectOAMMapping) error
    Update(param *datamodel.BizObjectOAMMapping) error
    Delete(m map[string]interface{}) error
}

type bizObjectOAMMappingService struct {
    oamRepo        *repository.BizObjectOAMRepo
    oamMappingRepo *repository.BizObjectOAMMappingRepo
}

func NewBizObjectOAMMappingService() BizObjectOAMMappingService {
    return &bizObjectOAMMappingService{
        oamRepo:        repository.NewBizObjectOAMRepo(datasource.InstanceMaster()),
        oamMappingRepo: repository.NewBizObjectOAMMappingRepo(datasource.InstanceMaster()),
    }
}

func (s *bizObjectOAMMappingService) GetList(m map[string]interface{}) ([]viewmodel.BizObjectOAMMappingInfo, error) {
    return s.oamMappingRepo.GetList(m)
}

func (s *bizObjectOAMMappingService) GetById(bizId, objectId, oamId, mappingId int64) (*viewmodel.BizObjectOAMMappingInfo, error) {
    return s.oamMappingRepo.GetById(bizId, objectId, oamId, mappingId)
}

func (s *bizObjectOAMMappingService) Create(m *datamodel.BizObjectOAMMapping) error {
    mappingId := NewID()
    m.MappingId = mappingId
    return s.oamMappingRepo.Create(m)
}

func (s *bizObjectOAMMappingService) Update(param *datamodel.BizObjectOAMMapping) error {
    return s.oamMappingRepo.Update(param)
}

func (s *bizObjectOAMMappingService) Delete(m map[string]interface{}) error {
    return s.oamMappingRepo.Delete(m)
}