alert_users_service.go

package service

import (
	"github.com/DWHengr/aurora/internal/models"
	"github.com/DWHengr/aurora/internal/models/mysql"
	"github.com/DWHengr/aurora/internal/page"
	"github.com/DWHengr/aurora/internal/service/utils"
	"github.com/DWHengr/aurora/pkg/id"
	"gorm.io/gorm"
)

type AlertUsersService interface {
	Create(user *models.AlertUsers) (*CreateAlertUserResp, error)
	Deletes(ids []string) error
	Update(user *models.AlertUsers) (*CreateAlertUserResp, error)
	Page(page *page.ReqPage) (*page.RespPage, error)
	All() ([]*models.AlertUsers, error)
}

type alertUsersService struct {
	db             *gorm.DB
	alertUsersRepo models.AlertUsersRepo
}

func NewAlertUsersService() (AlertUsersService, error) {
	db := utils.GetMysqlInstance()

	return &alertUsersService{
		db:             db,
		alertUsersRepo: mysql.NewAlertUsersRepo(),
	}, nil
}

type CreateAlertUserResp struct {
	ID string `json:"id"`
}

func (s *alertUsersService) Create(user *models.AlertUsers) (*CreateAlertUserResp, error) {
	user.ID = "usr-" + id.ShortID(8)
	err := s.alertUsersRepo.Create(s.db, user)
	if err != nil {
		return nil, err
	}
	return &CreateAlertUserResp{
		ID: user.ID,
	}, nil
}

func (s *alertUsersService) Deletes(ids []string) error {
	err := s.alertUsersRepo.Deletes(s.db, ids)
	return err
}

func (s *alertUsersService) Update(user *models.AlertUsers) (*CreateAlertUserResp, error) {
	err := s.alertUsersRepo.Update(s.db, user)
	return &CreateAlertUserResp{
		ID: user.ID,
	}, err
}

func (s *alertUsersService) Page(page *page.ReqPage) (*page.RespPage, error) {
	return s.alertUsersRepo.Page(s.db, page)
}

func (s *alertUsersService) All() ([]*models.AlertUsers, error) {
	return s.alertUsersRepo.All(s.db)
}