donat-widget/internal/model/sql/query.go

package sql

import (
	"donat-widget/internal/model"
	"fmt"
)

var CreateWidget = `
INSERT INTO widgets (streamer_id, template_id, image, audio, duration, min_amount, max_amount name)
VALUES (@streamer_id, @template_id, @image, @audio, @duration, @min_amount, @max_amount, @name)
RETURNING id;
`

var GetWidgetByStreamerID = `
SELECT * FROM widgets
WHERE streamer_id = (@streamer_id);
`
var GetWidgetByID = `
SELECT * FROM widgets
WHERE id = (@id);
`

func UpdateMediaUrl(mediaType model.MediaType) string {
	query := fmt.Sprintf(`
		UPDATE widgets 
		SET %s = (@%s)
		WHERE id = (@id)
	`, mediaType, mediaType)
	return query
}

var GetAllWidget = `
SELECT * FROM widgets
WHERE streamer_id = (@streamer_id);
`

func GetMediaUrl(mediaType model.MediaType) string {
	query := fmt.Sprintf(`
		SELECT %s
		FROM widgets
		WHERE id = (@id)
	`, mediaType)
	return query
}

var CreateDonat = `
INSERT INTO donats (streamer_id, widget_id, text, amount, donat_user, order_id, target_id)
VALUES (@streamer_id, @widget_id, @text, @amount, @donat_user, @order_id, @target_id)
RETURNING id;
`
var MarkDonatView = `
UPDATE donats
SET view = (@view)
WHERE id = (@id);
`
var MarkDonatPaid = `
UPDATE donats
SET paid = (@paid)
WHERE order_id = (@order_id);
`
var GetDonatByStreamerID = `
SELECT * FROM donats
WHERE streamer_id = (@streamer_id) AND paid = (@paid) AND view = (@view);
`
var GetDonatByOrderID = `
SELECT * FROM donats
WHERE order_id = (@order_id);
`

var CreateTarget = `
INSERT INTO targets (streamer_id, text, amount)
VALUES (@streamer_id, @text, @amount)
RETURNING id;
`

var GetAllTarget = `
SELECT * FROM targets
WHERE streamer_id = (@streamer_id);
`
var AddAmountToTarget = `
UPDATE targets
SET collected = collected + (@amount)
WHERE id = (@target_id);
`

var GetDonationPage = `
SELECT 
    dp.id,
    dp.streamer_id,
    dp.description,
    dp.text_after_donat,
    dp.streamer_login,

    -- Поля для хед-изображения
    head_img.id AS head_img_id,
    head_img.file_name AS head_img_file_name,
    head_img.file_type AS head_img_type,
    head_img.size AS head_img_size,

    -- Поля для аватара
    avatar.id AS avatar_id,
    avatar.file_name AS avatar_file_name,
    avatar.file_type AS avatar_type,
    avatar.size AS avatar_img_size,

    -- Поля для фона
    background_img.id AS background_img_id,
    background_img.file_name AS background_img_file_name,
    background_img.file_type AS background_img_type,
    background_img.size AS background_img_size

FROM donate_pages dp
LEFT JOIN files head_img ON dp.head_img = head_img.id
LEFT JOIN files avatar ON dp.avatar = avatar.id
LEFT JOIN files background_img ON dp.background_img = background_img.id
WHERE dp.streamer_id = (@streamer_id);
`

var GetDonationPageByLogin = `
SELECT 
    dp.id,
    dp.streamer_id,
    dp.description,
    dp.text_after_donat,
    dp.streamer_login,

    -- Поля для хед-изображения
    head_img.id AS head_img_id,
    head_img.file_name AS head_img_file_name,
    head_img.file_type AS head_img_type,
    head_img.size AS head_img_size,

    -- Поля для аватара
    avatar.id AS avatar_id,
    avatar.file_name AS avatar_file_name,
    avatar.file_type AS avatar_type,
    avatar.size AS avatar_img_size,

    -- Поля для фона
    background_img.id AS background_img_id,
    background_img.file_name AS background_img_file_name,
    background_img.file_type AS background_img_type,
    background_img.size AS background_img_size

FROM donate_pages dp
LEFT JOIN files head_img ON dp.head_img = head_img.id
LEFT JOIN files avatar ON dp.avatar = avatar.id
LEFT JOIN files background_img ON dp.background_img = background_img.id
WHERE dp.streamer_login = (@streamer_login);
`

var GetWidgetsByStreamerID = `
SELECT 
	w.id, 
	w.streamer_id, 
	w.template_id, 
	img.id AS image_id,
	img.file_name AS image_file_name,
	img.file_type AS image_type,
    audio.id AS audio_id,
	audio.file_name AS audio_file_name,
	audio.file_type AS audio_type,
	w.duration, 
	w.min_amount, 
	w.created_at, 
	w.updated_at
FROM widgets w
LEFT JOIN files img ON w.image = img.id
LEFT JOIN files audio ON w.audio = audio.id
WHERE w.streamer_id = (@streamer_id);
`

var AddNewFile = `
INSERT INTO files (streamer_id, file_name, file_type, extension, entity, size) 
VALUES 
(@streamer_id, @file_name, @file_type, @extension, @entity, @size)
RETURNING id;
`

var GetWidgetByName = `SELECT id FROM widgets WHERE (
    streamer_id = @streamer_id AND 
    name = @name);
`

var FileById = `SELECT file_name, streamer_id, file_type FROM files WHERE id = (@id);`

var AudioFilesWidgets = `
SELECT * 
FROM files
WHERE streamer_id = @streamer_id
  AND entity = @entity
  AND file_type LIKE 'audio%';
`

var ImageFilesWidgets = `
SELECT * 
FROM files
WHERE streamer_id = @streamer_id
  AND entity = @entity
  AND file_type LIKE 'image%';
`
var UpdateWidget = `
UPDATE widgets
SET
    duration = COALESCE(@duration, duration),
    min_amount = COALESCE(@min_amount, min_amount),
    max_amount = COALESCE(@max_amount, max_amount),
    is_active = COALESCE(@is_active, is_active),
    image = COALESCE(@image, image),
    audio = COALESCE(@audio, audio),
    name = COALESCE(@name, name)
WHERE id = @id;
`

var GetWidgetById = `
SELECT id FROM widgets WHERE id = (@widget_id) AND streamer_id = (@streamer_id);
`

var UpdateDonatePage = `
UPDATE donate_pages
SET
    background_img = COALESCE(@background_img, background_img),
    head_img = COALESCE(@head_img, head_img),
    description = COALESCE(@description, description),
    text_after_donat = COALESCE(@text_after_donation, text_after_donat)
WHERE streamer_id = @streamer_id
RETURNING *;
`