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;`