--psql -U postgres -d dwh -h localhost -p 5432 -f D:/backup/dwh_part.20250730.sql --сначала очистить, но схема должна быть /* расчет актуальной версии непонятен почему у меня в рабочей весии только завершенные сделки? проверить для незавершенных почему у меня все версии имеют допник? Если дата НОП не указана, игнорируем полностью проблема подбора тестовых данных например, сделка на какой-то момент в статусе 4, потом продвигается - мы должны это видеть сделать селект, который показывает историю строки. Должна ли история сделки быть видима в истории прогноза? но если у нас siv.is_actual, мы уже не имеем дело с историей, а смотрим текущее состояние? */ with dayscale as (SELECT dd::date as dt , DATE_PART('days', DATE_TRUNC('month', dd) + '1 MONTH'::INTERVAL - '1 DAY'::INTERVAL) monthdays FROM generate_series( '2025-01-01'::timestamp ,'2025-01-02'::timestamp ,'1 day'::interval) dd ), status(status, status_id, probability_pc) as (VALUES ('Закрыта неуспешно',7,0),('Закрыта успешно',6,100),('Договор подписан',5,100),('Договор на подписании',15,90),('Договор на согласовании',12,70), ('Тестирование',8,50),('Отправлено ТКП',10,20),('Внутреннее согласование',37,10),('Проработка решения',4,10),('Сбор потребностей',1,0) ), line as ( select siv.__id as siv_uid, siv.discount, siv.type as line_pricing_model_id, siv.params ,siv.hash as line_key, siv.user_description, siv.is_actual as siv_is_actual ,siv.version as line_version ,a.index as agreement_version, GREATEST(siv.date_nop,d."_plannedDueDate")::date as dt_from, siv.date_end::date as dt_to ,siv.is_easy as is_simple, siv.cnt as quantity -- maybe should mutliply , a.__id as agreement_uid, a.contract_uid, a.is_actual as agreement_is_actual, a.deal_uid ,d."_plannedDueDate", d.__name as deal, d.__status_status as deal_status_id ,c.__name as contract ,s.probability_pc from elma.deals_services siv left outer join elma.additional_agreements a on (a.__id = ANY(siv.additional_agreement)) /*это только потому, что массив'*/ left outer join elma.deals d on (d.__id = ANY(siv.deal)) left outer join elma.aggrements c on (a.contract_uid = c.__id) left outer join status s on (d.__status_status=s.status_id) ), component as ( select line.siv_uid ,p.__id as component_uid ,p.code, p.price, p.cnt as param_quantity, p.discount as param_discount, p.name as sku ,p.price*p.cnt*(100-p.discount)/100 as cost from line join elma.service_parametrs p on (p.__id = ANY (line.params)) ) select dayscale.dt, siv.* from -- свежая рабочая версия на каждую дату dayscale left outer join elma.deals_services siv on (1=1) --(select siv_uid from line i where i.line_key = w.line_key AND dayscale.dt >= i.dt_from order by line_version desc, agreement_version desc limit 1) left outer join elma.additional_agreements a on (a.__id = ANY(siv.additional_agreement) /*это только потому, что массив'*/ ) left outer join elma.deals d on (d.__id = ANY(siv.deal) AND dayscale.dt >= GREATEST(siv.date_nop,d."_plannedDueDate") AND siv.__id=( select i.__id from elma.deals_services i join elma.deals ideal on (ideal.__id = ANY(i.deal)) join elma.additional_agreements ia on (ia.__id = ANY(i.additional_agreement)) where i.hash = siv.hash AND dayscale.dt >= GREATEST(i.date_nop, d."_plannedDueDate") order by i.version desc, ia.index desc limit 1 ) ) left outer join elma.aggrements c on (a.contract_uid = c.__id) left outer join status s on (d.__status_status=s.status_id) --left outer join elma.service_parametrs p on (p.__id = ANY (siv.params)) --join component c on (w.siv_uid=c.siv_uid) -- базовая версия --left outer join line b on (w.line_key = b.line_key AND dayscale.dt >= b.dt_from --AND b.agreement_version = (select max(agreement_version) from line i where i.line_key = w.line_key AND dayscale.dt >= i.dt_from AND (w.agreement_version>i.agreement_version OR w.agreement_version IS NULL))) where --c.agreement_uid='0198183f-6dbc-73f7-914a-ce1347aea1a6' --c.contract_uid='0194a838-0351-7fea-b722-4289dfb4f240' 1=1 --AND b.deal_status_id IN ('5','6') /*нет уверенности, что наличие допсоглашения гарантирует валидность записи*/ AND siv.type in (2,3) -- на уровне компонента --AND c.code='iaas.ngc.i31.ssd-f' --group by dayscale.dt --, mv.version, mv.line_key --AND siv.hash='5f74c32f-25d9-4b2c-8689-3345e5f4cfbf' order by dayscale.dt