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

package service

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

type BizObjectAttrService interface {
	GetList(m map[string]interface{}) ([]viewmodel.BizObjectAttrInfo, error)
	GetPage(m map[string]interface{}) (*base.PageResult, error)
	GetById(bizId, objectId, attrId int64) (*viewmodel.BizObjectAttrInfo, error)
	GetListById(bizId, objectId int64) ([]viewmodel.BizObjectAttrInfo, error)
	Create(d *datamodel.BizObjectAttr) error
	Update(d *datamodel.BizObjectAttr) error
	Delete(m map[string]interface{}) error

	CacheBizObjectAttrs(bizId, objectId int64) error
}

type bizObjectAttrService struct {
	repo *repository.BizObjectAttrRepo
}

func NewBizObjectAttrService() BizObjectAttrService {
	return &bizObjectAttrService{
		repo: repository.NewBizObjectAttrRepo(datasource.InstanceMaster()),
	}
}

func (s *bizObjectAttrService) GetListById(bizId, objectId int64) ([]viewmodel.BizObjectAttrInfo, error) {
	return s.repo.GetListById(bizId, objectId)
}

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

func (s *bizObjectAttrService) GetPage(m map[string]interface{}) (*base.PageResult, error) {
	return s.repo.GetPage(m)
}

func (s *bizObjectAttrService) GetById(bizId, objectId, attrId int64) (*viewmodel.BizObjectAttrInfo, error) {
	return s.repo.GetById(bizId, objectId, attrId)
}

func (s *bizObjectAttrService) Create(attr *datamodel.BizObjectAttr) error {
	attr.AttrId = NewID()
	err := s.repo.Create(attr)
	if err != nil {
		return nil
	}

	bizId := attr.BizId
	objectId := attr.ObjectId
	return s.CacheBizObjectAttrs(bizId, objectId)
}

func (s *bizObjectAttrService) Update(attr *datamodel.BizObjectAttr) error {
	err := s.repo.Update(attr)
	if err != nil {
		return nil
	}

	bizId := attr.BizId
	objectId := attr.ObjectId
	return s.CacheBizObjectAttrs(bizId, objectId)
}

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

func (s *bizObjectAttrService) CacheBizObjectAttrs(bizId, objectId int64) error {
	attrList, err1 := s.repo.GetListById(bizId, objectId)
	if err1 != nil {
		return err1
	}

	if len(attrList) <= 0 {
		return errors.New("biz Object Attrs Not Exist")
	}
	objectCode := attrList[0].ObjectCode
	err2 := cache.SetBizObjectAttrs(objectCode, attrList)
	if err2 != nil {
		return errors.New("Redis缓存Model数据失败")
	}
	return nil
}