134 lines
3.2 KiB
Go
134 lines
3.2 KiB
Go
package repositories
|
|
|
|
import (
|
|
"gorm.io/gorm"
|
|
"strconv"
|
|
|
|
"git.dynamicdiscord.de/kalipso/zineshop/models"
|
|
)
|
|
|
|
type ShopItemRepository interface {
|
|
Create(models.ShopItem) (models.ShopItem, error)
|
|
GetAll() ([]models.ShopItem, error)
|
|
GetAllPublic() ([]models.ShopItem, error)
|
|
GetById(string) (models.ShopItem, error)
|
|
GetByTagId(string) ([]models.ShopItem, error)
|
|
GetVariantById(string) (models.ItemVariant, error)
|
|
Update(models.ShopItem) (models.ShopItem, error)
|
|
DeleteById(string) error
|
|
}
|
|
|
|
type GORMShopItemRepository struct {
|
|
DB *gorm.DB
|
|
}
|
|
|
|
func NewGORMShopItemRepository(db *gorm.DB) ShopItemRepository {
|
|
return &GORMShopItemRepository{
|
|
DB: db,
|
|
}
|
|
}
|
|
|
|
func (r *GORMShopItemRepository) Create(shopItem models.ShopItem) (models.ShopItem, error) {
|
|
result := r.DB.Create(&shopItem)
|
|
if result.Error != nil {
|
|
return models.ShopItem{}, result.Error
|
|
}
|
|
|
|
return shopItem, nil
|
|
}
|
|
|
|
func (r *GORMShopItemRepository) GetAll() ([]models.ShopItem, error) {
|
|
var shopItems []models.ShopItem
|
|
result := r.DB.Preload("Tags").Preload("Variants").Find(&shopItems)
|
|
|
|
return shopItems, result.Error
|
|
}
|
|
|
|
func (r *GORMShopItemRepository) GetAllPublic() ([]models.ShopItem, error) {
|
|
var shopItems []models.ShopItem
|
|
result := r.DB.Preload("Tags").Preload("Variants").Where("is_public = 1").Find(&shopItems)
|
|
|
|
return shopItems, result.Error
|
|
}
|
|
|
|
func (r *GORMShopItemRepository) GetById(id string) (models.ShopItem, error) {
|
|
shopItemId, err := strconv.Atoi(id)
|
|
|
|
if err != nil {
|
|
return models.ShopItem{}, err
|
|
}
|
|
|
|
var shopItem models.ShopItem
|
|
result := r.DB.Preload("Tags").Preload("Variants").First(&shopItem, uint(shopItemId))
|
|
|
|
if result.Error != nil {
|
|
return models.ShopItem{}, result.Error
|
|
}
|
|
|
|
return shopItem, nil
|
|
}
|
|
|
|
func (r *GORMShopItemRepository) GetByTagId(id string) ([]models.ShopItem, error) {
|
|
tagId, err := strconv.Atoi(id)
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var shopItems []models.ShopItem
|
|
result := r.DB.Joins("JOIN item_tags ON item_tags.shop_item_id = shop_items.id").Where("item_tags.tag_id = ?", tagId).Preload("Tags").Preload("Variants").Find(&shopItems)
|
|
|
|
if result.Error != nil {
|
|
return nil, result.Error
|
|
}
|
|
|
|
return shopItems, nil
|
|
}
|
|
|
|
func (r *GORMShopItemRepository) GetVariantById(id string) (models.ItemVariant, error) {
|
|
itemVariantId, err := strconv.Atoi(id)
|
|
|
|
if err != nil {
|
|
return models.ItemVariant{}, err
|
|
}
|
|
|
|
var itemVariant models.ItemVariant
|
|
result := r.DB.First(&itemVariant, uint(itemVariantId))
|
|
|
|
if result.Error != nil {
|
|
return models.ItemVariant{}, result.Error
|
|
}
|
|
|
|
return itemVariant, nil
|
|
}
|
|
|
|
func (r *GORMShopItemRepository) Update(shopItem models.ShopItem) (models.ShopItem, error) {
|
|
err := r.DB.Model(&shopItem).Association("Tags").Replace(shopItem.Tags)
|
|
if err != nil {
|
|
return models.ShopItem{}, err
|
|
}
|
|
|
|
err = r.DB.Model(&shopItem).Association("Variants").Replace(shopItem.Variants)
|
|
if err != nil {
|
|
return models.ShopItem{}, err
|
|
}
|
|
|
|
result := r.DB.Save(&shopItem)
|
|
if result.Error != nil {
|
|
return models.ShopItem{}, result.Error
|
|
}
|
|
|
|
return shopItem, nil
|
|
}
|
|
|
|
func (r *GORMShopItemRepository) DeleteById(id string) error {
|
|
shopItemId, err := strconv.Atoi(id)
|
|
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
result := r.DB.Delete(&models.ShopItem{}, shopItemId)
|
|
return result.Error
|
|
}
|