From d8202e11413702752ac7081ac96801744fa1b7ca Mon Sep 17 00:00:00 2001 From: Artem Tsyrulnikov Date: Sun, 18 Jan 2026 13:38:25 +0300 Subject: [PATCH] =?UTF-8?q?fix=20parser=20=D0=B0=D0=B4=D0=B0=D0=BF=D1=82?= =?UTF-8?q?=D0=B5=D1=80=D0=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adapter/database/get_channels_with_tracked_posts.go | 6 +++--- tg_parser/internal/adapter/database/get_tracked_posts.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/tg_parser/internal/adapter/database/get_channels_with_tracked_posts.go b/tg_parser/internal/adapter/database/get_channels_with_tracked_posts.go index 6b7fdc8..7162f2d 100644 --- a/tg_parser/internal/adapter/database/get_channels_with_tracked_posts.go +++ b/tg_parser/internal/adapter/database/get_channels_with_tracked_posts.go @@ -19,9 +19,9 @@ func (d *Database) GetChannelsWithTrackedPosts(ctx context.Context) ([]domain.Ch c.access_hash, c.pts FROM channel c -INNER JOIN purchase_channel pc ON pc.channel_id = c.id -INNER JOIN placement p ON p.purchase_channel_id = pc.id -INNER JOIN post po ON po.id = p.post_id +INNER JOIN placement p ON p.channel_id = c.id +INNER JOIN placement_post pp ON pp.placement_id = p.id +INNER JOIN post po ON po.id = pp.post_id WHERE po.deleted_from_channel_at IS NULL;` txOrPool := transaction.TryExtractTX(ctx) diff --git a/tg_parser/internal/adapter/database/get_tracked_posts.go b/tg_parser/internal/adapter/database/get_tracked_posts.go index 815f528..4ba766e 100644 --- a/tg_parser/internal/adapter/database/get_tracked_posts.go +++ b/tg_parser/internal/adapter/database/get_tracked_posts.go @@ -30,7 +30,7 @@ func (d *Database) GetTrackedPosts(ctx context.Context, channel domain.Channel) ) as views FROM post p INNER JOIN channel c ON c.id = p.channel_id -INNER JOIN placement pl ON pl.post_id = p.id +INNER JOIN placement_post pp ON pp.post_id = p.id WHERE p.channel_id = $1 AND p.deleted_from_channel_at IS NULL;`