-- ════════════════════════════════════════════════════════════════════════════
-- МИГРАЦИЯ: Автогенерация technical_number + запрет ручного редактирования
-- Формат: YYMM_<код РФ/ВСП 4 цифры><порядковый счётчик 2 цифры>
-- Пример: 2606_180801 (26 — год, 06 — месяц, 1808 — org_unit id, 01 — счётчик)
-- ════════════════════════════════════════════════════════════════════════════

-- Уникальность технического номера проекта
CREATE UNIQUE INDEX IF NOT EXISTS uq_v3_project_technical_number
    ON v3.project (technical_number);

-- add_project: генерируем technical_number автоматически при создании проекта
CREATE OR REPLACE FUNCTION v3.add_project(p_name character varying, p_year integer, p_org_unit_id integer, p_level character varying DEFAULT 'project'::character varying, p_parent_id integer DEFAULT NULL::integer, p_project_type character varying DEFAULT NULL::character varying, p_vsp_format character varying DEFAULT NULL::character varying, p_placement_type character varying DEFAULT NULL::character varying, p_object_address character varying DEFAULT NULL::character varying, p_staff_count integer DEFAULT NULL::integer, p_total_area numeric DEFAULT NULL::numeric, p_system_code character varying DEFAULT NULL::character varying)
 RETURNS TABLE(project_id integer, limit_report_id integer, current_expenses_report_id integer)
 LANGUAGE plpgsql
AS $function$
DECLARE
    v_pid INT;
    v_lim INT;
    v_cur INT;
    v_seq INT;
    v_technical_number VARCHAR;
BEGIN
    IF p_name IS NULL OR length(trim(p_name)) = 0 THEN
        RAISE EXCEPTION 'p_name обязателен';
    END IF;
    IF p_year IS NULL THEN
        RAISE EXCEPTION 'p_year обязателен';
    END IF;
    IF p_org_unit_id IS NULL THEN
        RAISE EXCEPTION 'p_org_unit_id обязателен';
    END IF;
    IF NOT EXISTS (SELECT 1 FROM v3.org_unit ou WHERE id = p_org_unit_id AND ou.is_active) THEN
        RAISE EXCEPTION 'org_unit id=% не существует', p_org_unit_id;
    END IF;
    IF p_parent_id IS NOT NULL AND
        NOT EXISTS (SELECT 1 FROM v3.project WHERE id = p_parent_id AND level = 'program') THEN
        RAISE EXCEPTION 'parent project id=% не существует или не имеет level=program', p_parent_id;
    END IF;

    -- Порядковый счётчик проекта для данного РФ/ВСП (org_unit)
    SELECT COALESCE(MAX(right(technical_number, 2)::int), 0) + 1
      INTO v_seq
      FROM v3.project
     WHERE org_unit_id = p_org_unit_id
       AND technical_number IS NOT NULL;

    v_technical_number := to_char(now(), 'YYMM') || '_'
                        || lpad(p_org_unit_id::text, 4, '0')
                        || lpad(v_seq::text, 2, '0');

    INSERT INTO v3.project (
        name, level, parent_id, org_unit_id,
        project_type, vsp_format, placement_type, object_address, staff_count, total_area,
        system_code, technical_number
    ) VALUES (
        p_name, p_level, p_parent_id, p_org_unit_id,
        p_project_type, p_vsp_format, p_placement_type, p_object_address, p_staff_count, p_total_area,
        p_system_code, v_technical_number
    ) RETURNING id INTO v_pid;

    -- Первый год: 2 отчёта (LIMIT + CURRENT_EXPENSES) + snapshot фаз + сетка статей.
    SELECT y.limit_report_id, y.current_expenses_report_id
        INTO v_lim, v_cur
        FROM v3.add_project_year(v_pid, p_year, false) y;

    -- Аудит: PROJECT_CREATE — все заполненные поля + id отчётов
    PERFORM v3.log_event(
        'PROJECT_CREATE', 'PROJECT',
        jsonb_strip_nulls(jsonb_build_object(
        'project_id',     v_pid,
        'name',           p_name,
        'year',           p_year,
        'level',          p_level,
        'parent_id',      p_parent_id,
        'org_unit_id',    p_org_unit_id,
        'project_type',   p_project_type,
        'vsp_format',     p_vsp_format,
        'placement_type', p_placement_type,
        'object_address', p_object_address,
        'system_code',    p_system_code,
        'technical_number', v_technical_number,
        'staff_count',    p_staff_count,
        'total_area',     p_total_area,
        'limit_report_id',            v_lim,
        'current_expenses_report_id', v_cur
        ))
    );

    RETURN QUERY SELECT v_pid, v_lim, v_cur;
END;
$function$
;

-- upd_project: убираем параметр technical_number (редактировать больше нельзя)
DROP FUNCTION IF EXISTS v3.upd_project(integer, varchar, varchar, varchar, varchar, varchar, varchar, varchar, integer, numeric, integer, date, date, date, date, varchar);

CREATE OR REPLACE FUNCTION v3.upd_project(
    p_project_id integer,
    p_name character varying DEFAULT NULL,
    p_status character varying DEFAULT NULL,
    p_project_type character varying DEFAULT NULL,
    p_vsp_format character varying DEFAULT NULL,
    p_placement_type character varying DEFAULT NULL,
    p_object_address character varying DEFAULT NULL,
    p_staff_count integer DEFAULT NULL,
    p_total_area numeric DEFAULT NULL,
    p_org_unit_id integer DEFAULT NULL,
    p_krf_decision_date date DEFAULT NULL,
    p_fk_decision_date date DEFAULT NULL,
    p_board_decision_date date DEFAULT NULL,
    p_open_relocate_close_date date DEFAULT NULL,
    p_funding_by_ko_decision character varying DEFAULT NULL
)
 RETURNS void
 LANGUAGE plpgsql
AS $function$
DECLARE
    v_old v3.project%ROWTYPE;
    v_changes JSONB := '{}'::jsonb;
BEGIN
    SELECT * INTO v_old FROM v3.project WHERE id = p_project_id;
    IF NOT FOUND THEN
        RAISE EXCEPTION 'project id=% не существует', p_project_id;
    END IF;

    IF p_name IS NOT NULL AND p_name IS DISTINCT FROM v_old.name THEN
        UPDATE v3.project SET name = p_name WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('name',
            jsonb_build_object('before', v3._diff_val(v_old.name), 'after', v3._diff_val(p_name)));
    END IF;

    IF p_status IS NOT NULL AND p_status IS DISTINCT FROM v_old.status THEN
        UPDATE v3.project SET status = p_status WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('status',
            jsonb_build_object('before', v3._diff_val(v_old.status), 'after', v3._diff_val(p_status)));
    END IF;

    IF p_project_type IS NOT NULL AND p_project_type IS DISTINCT FROM v_old.project_type THEN
        UPDATE v3.project SET project_type = p_project_type WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('project_type',
            jsonb_build_object('before', v3._diff_val(v_old.project_type), 'after', v3._diff_val(p_project_type)));
    END IF;

    IF p_vsp_format IS NOT NULL AND p_vsp_format IS DISTINCT FROM v_old.vsp_format THEN
        UPDATE v3.project SET vsp_format = p_vsp_format WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('vsp_format',
            jsonb_build_object('before', v3._diff_val(v_old.vsp_format), 'after', v3._diff_val(p_vsp_format)));
    END IF;

    IF p_placement_type IS NOT NULL AND p_placement_type IS DISTINCT FROM v_old.placement_type THEN
        UPDATE v3.project SET placement_type = p_placement_type WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('placement_type',
            jsonb_build_object('before', v3._diff_val(v_old.placement_type), 'after', v3._diff_val(p_placement_type)));
    END IF;

    IF p_object_address IS NOT NULL AND p_object_address IS DISTINCT FROM v_old.object_address THEN
        UPDATE v3.project SET object_address = p_object_address WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('object_address',
            jsonb_build_object('before', v3._diff_val(v_old.object_address), 'after', v3._diff_val(p_object_address)));
    END IF;

    IF p_staff_count IS NOT NULL AND p_staff_count IS DISTINCT FROM v_old.staff_count THEN
        UPDATE v3.project SET staff_count = p_staff_count WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('staff_count',
            jsonb_build_object('before', v3._diff_val(v_old.staff_count), 'after', v3._diff_val(p_staff_count)));
    END IF;

    IF p_total_area IS NOT NULL AND p_total_area IS DISTINCT FROM v_old.total_area THEN
        UPDATE v3.project SET total_area = p_total_area WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('total_area',
            jsonb_build_object('before', v3._diff_val(v_old.total_area), 'after', v3._diff_val(p_total_area)));
    END IF;

    IF p_org_unit_id IS NOT NULL AND p_org_unit_id IS DISTINCT FROM v_old.org_unit_id THEN
        IF NOT EXISTS (SELECT 1 FROM v3.org_unit WHERE id = p_org_unit_id) THEN
            RAISE EXCEPTION 'org_unit id=% не существует', p_org_unit_id;
        END IF;
        UPDATE v3.project SET org_unit_id = p_org_unit_id WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('org_unit_id',
            jsonb_build_object('before', v3._diff_val(v_old.org_unit_id), 'after', v3._diff_val(p_org_unit_id)));
    END IF;

    IF p_krf_decision_date IS NOT NULL AND p_krf_decision_date IS DISTINCT FROM v_old.krf_decision_date THEN
        UPDATE v3.project SET krf_decision_date = p_krf_decision_date WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('krf_decision_date',
            jsonb_build_object('before', v3._diff_val(v_old.krf_decision_date), 'after', v3._diff_val(p_krf_decision_date)));
    END IF;

    IF p_fk_decision_date IS NOT NULL AND p_fk_decision_date IS DISTINCT FROM v_old.fk_decision_date THEN
        UPDATE v3.project SET fk_decision_date = p_fk_decision_date WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('fk_decision_date',
            jsonb_build_object('before', v3._diff_val(v_old.fk_decision_date), 'after', v3._diff_val(p_fk_decision_date)));
    END IF;

    IF p_board_decision_date IS NOT NULL AND p_board_decision_date IS DISTINCT FROM v_old.board_decision_date THEN
        UPDATE v3.project SET board_decision_date = p_board_decision_date WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('board_decision_date',
            jsonb_build_object('before', v3._diff_val(v_old.board_decision_date), 'after', v3._diff_val(p_board_decision_date)));
    END IF;

    IF p_open_relocate_close_date IS NOT NULL AND p_open_relocate_close_date IS DISTINCT FROM v_old.open_relocate_close_date THEN
        UPDATE v3.project SET open_relocate_close_date = p_open_relocate_close_date WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('open_relocate_close_date',
            jsonb_build_object('before', v3._diff_val(v_old.open_relocate_close_date), 'after', v3._diff_val(p_open_relocate_close_date)));
    END IF;

    IF p_funding_by_ko_decision IS NOT NULL AND p_funding_by_ko_decision IS DISTINCT FROM v_old.funding_by_ko_decision THEN
        UPDATE v3.project SET funding_by_ko_decision = p_funding_by_ko_decision WHERE id = p_project_id;
        v_changes := v_changes || jsonb_build_object('funding_by_ko_decision',
            jsonb_build_object('before', v3._diff_val(v_old.funding_by_ko_decision), 'after', v3._diff_val(p_funding_by_ko_decision)));
    END IF;

    IF v_changes <> '{}'::jsonb THEN
        PERFORM v3.log_event(
            'PROJECT_UPDATE', 'PROJECT',
            jsonb_build_object(
                'project_id', p_project_id,
                'entity_id',  p_project_id,
                'changes',    v_changes
            ), null, null, COALESCE(p_org_unit_id, v_old.org_unit_id)
        );
    END IF;
END;
$function$
;


UPDATE v3.phase_template
SET column_keys = '{plan.q1,plan.q2,plan.q3,plan.q4,plan.year,plan.comment,contract_summary.total,contract_summary.reference,contract_summary.counterparty,contract_summary.deadline,contract_summary.comment,contract_summary.future_y1,contract_summary.future_y2,contract_summary.other_ssp,contract_summary.centralized_flag,allocation.contract_ref,allocation.allocation_purpose,seq_dfip.q1,seq_dfip.q2,seq_dfip.q3,seq_dfip.q4,seq_dfip.year,seq_dfip.justification,reserve.q1,reserve.q2,reserve.q3,reserve.q4,reserve.year,reserve.justification,approved.q1,approved.q2,approved.q3,approved.q4,approved.year,collegial.approved,collegial.protocol,collegial.note,ckk.ceiling,ckk.q1,ckk.q2,ckk.q3,ckk.q4,ckk.rf_schedule,ckk.deadline,ckk.proc_plan,ckk.proc_method,ckk.comment,contract.counterparty,contract.reference,contract.addenda,contract.subject,contract.currency,contract.ceiling,contract.q1,contract.q2,contract.q3,contract.q4,contract.rf_schedule,contract.vat_rate,contract.exchange_rate,contract.amount_foreign,contract.deadline,contract.scheme,contract.act,contract.comment,q1.adj_current,q1.adj_ssp,q1.adj_rf,q1.adj_reserve,q1.adj_comment,q1.corrected_plan,q1.pay_date,q1.pay_amount,q1.pay_ho,q1.pay_rf,q1.pay_comment,q1.pay_act,q1.booking,q1.actual_m1,q1.actual_m2,q1.actual_m3,q1.actual_quarter,q1.residual_after_booking,q1.residual_after_actual,q1.transfer_q2,q1.transfer_q3,q1.transfer_q4,q1.transfer_econ,q1.total,q2.target_change,q2.base_correction,q2.revision_inc,q2.revision_seq,q2.revision_comment,q2.new_plan,q2.adj_current,q2.adj_ssp,q2.adj_rf,q2.adj_reserve,q2.corrected_plan,q2.pay_date,q2.pay_amount,q2.pay_ho,q2.pay_rf,q2.pay_comment,q2.pay_act,q2.booking,q2.actual_m1,q2.actual_m2,q2.actual_m3,q2.actual_quarter,q2.residual_after_booking,q2.residual_after_actual,q2.transfer_q3,q2.transfer_q4,q2.transfer_econ,q2.total,q3.target_change,q3.base_correction,q3.revision_inc,q3.revision_seq,q3.revision_comment,q3.new_plan,q3.adj_current,q3.adj_ssp,q3.adj_rf,q3.adj_reserve,q3.corrected_plan,q3.pay_date,q3.pay_amount,q3.pay_ho,q3.pay_rf,q3.pay_comment,q3.pay_act,q3.booking,q3.actual_m1,q3.actual_m2,q3.actual_m3,q3.actual_quarter,q3.residual_after_booking,q3.residual_after_actual,q3.transfer_q4,q3.transfer_econ,q3.total,q4.target_change,q4.base_correction,q4.revision_inc,q4.revision_seq,q4.revision_comment,q4.new_plan,q4.adj_current,q4.adj_ssp,q4.adj_rf,q4.adj_reserve,q4.corrected_plan,q4.pay_date,q4.pay_amount,q4.pay_ho,q4.pay_rf,q4.pay_comment,q4.pay_act,q4.booking,q4.actual_m1,q4.actual_m2,q4.actual_m3,q4.actual_quarter,q4.actual_spod,q4.residual_after_booking,q4.residual_after_actual,q4.transfer_econ,q4.total,totals.fact_year}'
WHERE form_type = 'FORM_4';

ALTER TABLE v3.form_phase DROP CONSTRAINT chk_v4_form_phase_no_admin;