xps-server-g5/pkg/model/service/model_object_service.go

package service

import (
	"errors"
	cache "xps/cmd/cache/redis"
	"xps/cmd/datasource"
	"xps/pkg/base"
	"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{}) (*base.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)

	CacheModelObject(modelId, objectId int64) 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{}) (*base.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
	err := s.modelObjectRepo.Create(o)
	if err != nil {
		return err
	}

	modelId := o.ModelId
	return s.CacheModelObject(modelId, objectId)
}

func (s *modelObjectService) Update(o *datamodel.ModelObject) error {
	err := s.modelObjectRepo.Update(o)
	if err != nil {
		return err
	}

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

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)
}

func (s *modelObjectService) CacheModelObject(modelId, objectId int64) error {
	o, err1 := s.modelObjectRepo.GetById(modelId, objectId)
	if err1 != nil {
		return err1
	}

	err2 := cache.SetModelObject(o.ObjectCode, o)
	if err2 != nil {
		return errors.New("Redis缓存Biz Object数据失败")
	}
	return nil
}