package service

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

type ModelObjectService interface {
    GetList(m map[string]interface{}) ([]viewmodel.ModelObjectInfo, error)
    GetPage(m map[string]interface{}) (*common.PageResult, error)
    GetById(modelId, objectId int64) (*viewmodel.ModelObjectInfo, error)
    GetListById(modelId int64) ([]viewmodel.ModelObjectInfo, error)
    Create(o *datamodel.ModelObject) error
    Update(o *datamodel.ModelObject) error
    Delete(m map[string]interface{}) error
    Select(modelId, bizId, objectId int64) ([]viewmodel.ModelObjectInfo, error)
}

type modelObjectService struct {
    modelObjectRepo     *repository.ModelObjectRepo
    modelObjectAttrRepo *repository.ModelObjectAttrRepo
}

func NewModelObjectService() ModelObjectService {
    return &modelObjectService{
        modelObjectRepo:     repository.NewModelObjectRepo(datasource.InstanceMaster()),
        modelObjectAttrRepo: repository.NewModelObjectAttrRepo(datasource.InstanceMaster()),
    }
}

func (s *modelObjectService) GetList(m map[string]interface{}) ([]viewmodel.ModelObjectInfo, error) {
    return s.modelObjectRepo.GetList(m)
}

func (s *modelObjectService) GetListById(modelId int64) ([]viewmodel.ModelObjectInfo, error) {
    return s.modelObjectRepo.GetListById(modelId)
}

func (s *modelObjectService) Select(modelId, targetBizId, targetObjectId int64) ([]viewmodel.ModelObjectInfo, error) {
    return s.modelObjectRepo.SelectForBizObjectMapping(modelId, targetBizId, targetObjectId)
}

func (s *modelObjectService) GetPage(m map[string]interface{}) (*common.PageResult, error) {
    return s.modelObjectRepo.GetPage(m)
}

func (s *modelObjectService) GetById(modelId, objectId int64) (*viewmodel.ModelObjectInfo, error) {
    return s.modelObjectRepo.GetById(modelId, objectId)
}

func (s *modelObjectService) Create(o *datamodel.ModelObject) error {
    objectId := NewID()
    o.ObjectId = objectId
    return s.modelObjectRepo.Create(o)
}

func (s *modelObjectService) Update(o *datamodel.ModelObject) error {
    return s.modelObjectRepo.Update(o)
}

func (s *modelObjectService) Delete(m map[string]interface{}) error {
    modelId  := m["modelId"].(int64)
    objectId := m["objectId"].(int64)
    err := s.modelObjectRepo.Delete(m)
    if err != nil {
        return err
    }
    return s.modelObjectAttrRepo.DeleteByObjectId(modelId, objectId)
}