package service

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

type ModelObjectOAMService interface {
	GetList(m map[string]interface{}) ([]viewmodel.ModelObjectOAMInfo, error)
	GetListById(modelId, objectId int64) ([]viewmodel.ModelObjectOAMInfo, error)
	GetById(modelId, objectId, oamId int64) (*viewmodel.ModelObjectOAMInfo, error)
	Create(d *datamodel.ModelObjectOAM) error
	Update(d *datamodel.ModelObjectOAM) error
	Delete(m map[string]interface{}) error

	CacheModelObjectOAM(modelId, objectId, oamId int64) error
}

type modelObjectOAMService struct {
	repo *repository.ModelObjectOAMRepo
}

func NewModelObjectOAMService() ModelObjectOAMService {
	return &modelObjectOAMService{
		repo: repository.NewModelObjectOAMRepo(datasource.InstanceMaster()),
	}
}

func (s *modelObjectOAMService) GetList(m map[string]interface{}) ([]viewmodel.ModelObjectOAMInfo, error) {
	return s.repo.GetList(m)
}

func (s *modelObjectOAMService) GetListById(modelId, objectId int64) ([]viewmodel.ModelObjectOAMInfo, error) {
	return s.repo.GetListById(modelId, objectId)
}

func (s *modelObjectOAMService) GetById(modelId, objectId, oamId int64) (*viewmodel.ModelObjectOAMInfo, error) {
	return s.repo.GetById(modelId, objectId, oamId)
}

func (s *modelObjectOAMService) Create(o *datamodel.ModelObjectOAM) error {
	oamId := NewID()

	o.OamId = oamId
	err := s.repo.Create(o)
	if err != nil {
		return err
	}

	modelId := o.ModelId
	objectId := o.ObjectId
	return s.CacheModelObjectOAM(modelId, objectId, oamId)
}

func (s *modelObjectOAMService) Update(o *datamodel.ModelObjectOAM) error {
	err := s.repo.Update(o)
	if err != nil {
		return err
	}

	modelId := o.ModelId
	objectId := o.ObjectId
	oamId := o.OamId
	return s.CacheModelObjectOAM(modelId, objectId, oamId)
}

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

func (s *modelObjectOAMService) CacheModelObjectOAM(modelId, objectId, oamId int64) error {
	oam, err1 := s.repo.GetById(modelId, objectId, oamId)
	if err1 != nil {
		return err1
	}

	err3 := cache.SetModelObjectOAM(oam.ObjectCode, oam.OamCode, oam)
	if err3 != nil {
		return errors.New("Redis缓存Model数据失败")
	}
	return nil
}