From 95e4771b1a3dd0819ee84e9eaf1768d87cfbe2a9 Mon Sep 17 00:00:00 2001
From: bn_user <user@example.com>
Date: Thu, 13 Nov 2025 21:12:20 +0000
Subject: [PATCH] =?UTF-8?q?=D0=9E=D0=B1=D0=BD=D0=BE=D0=B2=D0=B8=D1=82?=
 =?UTF-8?q?=D1=8C=20dags/pogasheniya.py?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dags/pogasheniya.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/dags/pogasheniya.py b/dags/pogasheniya.py
index 81e7768..a329d9a 100644
--- a/dags/pogasheniya.py
+++ b/dags/pogasheniya.py
@@ -34,7 +34,7 @@ def get_db_engine():
 def pogasheniya(**kwargs):
     engine = get_db_engine()
     query = """
-    SELECT DISTINCT
+    SELECT
           osv.schet
         , osv.uid_subkonto2 uid_dogovor
         , osv.subkonto2 name
@@ -43,7 +43,7 @@ def pogasheniya(**kwargs):
         , osv.date_end
     FROM oborotno_salbdovaya_vedomostb osv
     LEFT JOIN pogasheniya p on p.uid_dogovor = osv.uid_subkonto2 and p.schet = osv.schet
-    WHERE p.uid_dogovor is null
+    WHERE p.uid_dogovor is null and osv.schet::text ~~ '%03%'::text OR osv.schet::text ~~ '%01%'::text
     UNION ALL
     SELECT 
           '76.07.1' schet