alpenwerk-hr/db/migrations/20260814140000_teilzeit_gruende.sql

-- Teilzeiten sind keine Abwesenheiten.
--
-- Bildungsteilzeit, Elternteilzeit, Pflegeteilzeit und Wiedereingliederungs-
-- teilzeit standen in der Liste der Langzeitabwesenheiten. Wer so erfasst
-- wurde, galt als abwesend: die Person verschwand aus dem Bestand, ihre
-- Berichtslinie fiel an eine Vertretung, und in Auswertungen zählte sie nicht
-- mehr mit — obwohl sie jede Woche im Haus war, nur kürzer.
--
-- Sie wandern deshalb dorthin, wo sie hingehören:
--
--   * **Wiedereingliederungs- und Elternteilzeit** an die Rückkehr aus einer
--     Abwesenheit. Beide beginnen typischerweise genau dann, wenn die
--     Abwesenheit endet, und beide sind der Grund dafür, dass jemand mit
--     weniger Stunden zurückkommt.
--   * **Bildungs- und Pflegeteilzeit** an die Stundenänderung unter „Daten
--     ändern", neben der gewöhnlichen vertraglichen Änderung.
--
-- Der Grund wird **mit der Änderung** festgehalten, nicht als Zustand an der
-- Person. Ein Zustand müsste gepflegt werden — es gibt aber niemanden, der
-- nachträgt, wann eine Bildungsteilzeit endet, und ein Feld, das schleichend
-- veraltet, ist schlimmer als keines. In der Historie steht der Grund dort,
-- wo auch der geänderte Wert steht, und bleibt dort dauerhaft lesbar.
--
-- **Die Prüfbedingung auf absence_type bleibt unverändert.** Drei Personen
-- tragen die Werte gerade (Pflegeteilzeit, Wiedereingliederungsteilzeit); sie
-- zu verbieten hiesse, bestehende Zeilen ungültig zu machen. Aus der Auswahl
-- verschwinden sie, die Geschichte bleibt lesbar.

CREATE OR REPLACE FUNCTION public.record_karenz_return(payload jsonb)
 RETURNS void
 LANGUAGE plpgsql
 SET search_path TO 'public', 'pg_temp'
AS $function$
declare
  v_employee_id uuid := (payload->>'employee_id')::uuid;
  v_return_date date := (payload->>'return_date')::date;
  v_name text;
  v_employment_type employment_type;
  v_weekly_hours numeric;
  v_karenz_start date;
  v_absence_type text;
  -- Warum jemand mit weniger Stunden zurückkommt: Wiedereingliederungs-
  -- oder Elternteilzeit. Nur bedeutsam, wenn überhaupt reduziert wird.
  v_grund text := nullif(payload->>'reduction_reason', '');
begin
  perform require_hr_admin();
  select first_name || ' ' || last_name, karenz_start_date, absence_type
    into v_name, v_karenz_start, v_absence_type
    from employees where id = v_employee_id;

  if v_karenz_start is not null and v_return_date <= v_karenz_start then
    raise exception 'Das Rückkehrdatum muss nach dem Beginn der Langzeitabwesenheit (%) liegen.', v_karenz_start;
  end if;

  if payload->>'employment_mode' = 'Vollzeit' then
    v_employment_type := 'Vollzeit'; v_weekly_hours := 38.5;
  elsif payload->>'employment_mode' = 'Teilzeit' then
    v_employment_type := 'Teilzeit'; v_weekly_hours := (payload->>'weekly_hours')::numeric;
  end if;

  if v_return_date <= current_date then
    -- Keine Manager-Nachführung mehr nötig: wer aus der Abwesenheit
    -- zurückkehrt, ist wieder anwesend, und die abgeleitete Berichtslinie
    -- fällt automatisch von der Vertretung auf ihn zurück.
    update employees set
      status = 'Aktiv',
      karenz_return_date = null,
      karenz_start_date = null,
      absence_type = null,
      employment_type = coalesce(v_employment_type, employment_type),
      weekly_hours = coalesce(v_weekly_hours, weekly_hours)
    where id = v_employee_id;
  else
    update employees set karenz_return_date = v_return_date where id = v_employee_id;
    insert into pending_org_changes (employee_id, change_type, effective_date, payload)
      values (v_employee_id, 'karenz_return', v_return_date,
        jsonb_build_object('employment_type', v_employment_type, 'weekly_hours', v_weekly_hours));
  end if;

  insert into employee_history (employee_id, event_date, event_type, description)
    values (v_employee_id, v_return_date, 'Rückkehr',
      'Rückkehr aus ' || coalesce(v_absence_type, 'Langzeitabwesenheit') || ' am ' || v_return_date
      || case when payload->>'employment_mode' = 'Teilzeit'
              then ', reduziert auf ' || (payload->>'weekly_hours') || ' h'
                   || coalesce(' (' || v_grund || ')', '')
              else '' end);

  insert into audit_log (actor_user_id, actor_name, action, target_label, target_employee_id, details)
    values (app_current_user_id(), current_actor_name(), 'Rückkehr', v_name, v_employee_id, 'Rückkehr am ' || v_return_date || coalesce(' — ' || v_grund, ''));
end;
$function$;


CREATE OR REPLACE FUNCTION public.change_employee_data(payload jsonb)
 RETURNS void
 LANGUAGE plpgsql
 SET search_path TO 'public', 'pg_temp'
AS $function$
declare
  v_employee_id uuid := (payload->>'employee_id')::uuid;
  v_effective_date date := coalesce(nullif(payload->>'effective_date', '')::date, current_date);
  v_old employees%rowtype;
  v_name text;
  v_person_changes jsonb := '[]'::jsonb;
  v_contract_changes jsonb := '[]'::jsonb;
  v_person jsonb := payload->'person';
  v_contract jsonb := payload->'contract';
  v_role jsonb := payload->'role';
  v_immediate boolean;
  v_new_work_days text[];
  v_new_title_prefix text[];
  v_new_title_suffix text[];
  -- Warum sich die Stunden ändern. Kein Feld an der Person, sondern eine
  -- Eigenschaft *dieser* Änderung — es gibt niemanden, der später
  -- nachträgt, wann eine Bildungsteilzeit endet. In der Historie steht
  -- der Grund damit dort, wo auch der Wert steht.
  v_stunden_grund text := nullif(payload->>'hours_reason', '');
  v_pending_id uuid;
begin
  perform require_hr_admin();
  select * into v_old from employees where id = v_employee_id;
  v_name := v_old.first_name || ' ' || v_old.last_name;
  v_immediate := v_effective_date <= current_date;

  -- Der `?`-Test bleibt: ein fehlender Schlüssel heisst „nicht übermittelt",
  -- nicht „geleert". Ohne ihn würde jedes nicht gesendete Feld als Änderung
  -- auf null gemeldet.
  if v_person ? 'first_name' then v_person_changes := app_aenderung(v_person_changes, 'Vorname', v_old.first_name, v_person->>'first_name'); end if;
  if v_person ? 'last_name' then v_person_changes := app_aenderung(v_person_changes, 'Nachname', v_old.last_name, v_person->>'last_name'); end if;
  if v_person ? 'gender' then v_person_changes := app_aenderung(v_person_changes, 'Geschlecht', v_old.gender::text, v_person->>'gender'); end if;
  -- Datumswerte über ::date::text vergleichen, damit „2026-8-3" und
  -- „2026-08-03" nicht als Änderung gelten.
  if v_person ? 'birth_date' then v_person_changes := app_aenderung(v_person_changes, 'Geburtsdatum', v_old.birth_date::text, (nullif(v_person->>'birth_date','')::date)::text); end if;
  if v_person ? 'sv_nummer' then v_person_changes := app_aenderung(v_person_changes, 'SV-Nummer', v_old.sv_nummer, v_person->>'sv_nummer'); end if;
  if v_person ? 'nationality' then v_person_changes := app_aenderung(v_person_changes, 'Staatsbürgerschaft', v_old.nationality, v_person->>'nationality'); end if;
  if v_person ? 'address' then v_person_changes := app_aenderung(v_person_changes, 'Adresse', v_old.address, v_person->>'address'); end if;
  if v_person ? 'postal_code' then v_person_changes := app_aenderung(v_person_changes, 'Postleitzahl', v_old.postal_code, v_person->>'postal_code'); end if;
  if v_person ? 'city' then v_person_changes := app_aenderung(v_person_changes, 'Ort', v_old.city, v_person->>'city'); end if;
  if v_person ? 'address_country' then v_person_changes := app_aenderung(v_person_changes, 'Land', v_old.address_country, v_person->>'address_country'); end if;
  if v_person ? 'email' then v_person_changes := app_aenderung(v_person_changes, 'E-Mail', v_old.email, v_person->>'email'); end if;
  if v_person ? 'phone' then v_person_changes := app_aenderung(v_person_changes, 'Telefon', v_old.phone, v_person->>'phone'); end if;
  if v_person ? 'emergency_contact_name' then v_person_changes := app_aenderung(v_person_changes, 'Notfallkontakt', v_old.emergency_contact_name, v_person->>'emergency_contact_name'); end if;
  if v_person ? 'emergency_contact_phone' then v_person_changes := app_aenderung(v_person_changes, 'Notfallkontakt Telefon', v_old.emergency_contact_phone, v_person->>'emergency_contact_phone'); end if;
  if v_person ? 'emergency_contact_relation' then v_person_changes := app_aenderung(v_person_changes, 'Notfallkontakt Verhältnis', v_old.emergency_contact_relation, v_person->>'emergency_contact_relation'); end if;

  if v_person ? 'title_prefix' then
    v_new_title_prefix := coalesce((select array_agg(elem) from jsonb_array_elements_text(v_person->'title_prefix') elem), '{}');
    v_person_changes := app_aenderung(v_person_changes, 'Titel (vorangestellt)',
      array_to_string(v_old.title_prefix, ', '), array_to_string(v_new_title_prefix, ', '));
  end if;
  if v_person ? 'title_suffix' then
    v_new_title_suffix := coalesce((select array_agg(elem) from jsonb_array_elements_text(v_person->'title_suffix') elem), '{}');
    v_person_changes := app_aenderung(v_person_changes, 'Titel (nachgestellt)',
      array_to_string(v_old.title_suffix, ', '), array_to_string(v_new_title_suffix, ', '));
  end if;

  if v_contract ? 'employment_type' then v_contract_changes := app_aenderung(v_contract_changes, 'Beschäftigungsausmaß', v_old.employment_type::text, v_contract->>'employment_type'); end if;
  -- Über ::numeric::text, damit „38.50" und „38.5" gleich zählen.
  if v_contract ? 'weekly_hours' then v_contract_changes := app_aenderung(v_contract_changes, 'Wochenstunden', v_old.weekly_hours::text, (nullif(v_contract->>'weekly_hours','')::numeric)::text); end if;
  if v_contract ? 'contract_type' then v_contract_changes := app_aenderung(v_contract_changes, 'Vertragsart', v_old.contract_type::text, v_contract->>'contract_type'); end if;
  if v_contract ? 'contract_end_date' then v_contract_changes := app_aenderung(v_contract_changes, 'Befristet bis', v_old.contract_end_date::text, (nullif(v_contract->>'contract_end_date','')::date)::text); end if;

  if v_role ? 'worker_type' then v_contract_changes := app_aenderung(v_contract_changes, 'Angestellte:r/Arbeiter:in', v_old.worker_type::text, v_role->>'worker_type'); end if;
  if v_role ? 'collective_agreement' then v_contract_changes := app_aenderung(v_contract_changes, 'Kollektivvertrag', v_old.collective_agreement::text, v_role->>'collective_agreement'); end if;
  if v_role ? 'work_days' then
    v_new_work_days := coalesce((select array_agg(elem) from jsonb_array_elements_text(v_role->'work_days') elem), '{}');
    v_contract_changes := app_aenderung(v_contract_changes, 'Arbeitstage',
      array_to_string(v_old.work_days, ', '), array_to_string(v_new_work_days, ', '));
  end if;
  if v_role ? 'is_betriebsrat' then v_contract_changes := app_aenderung(v_contract_changes, 'Betriebsrat', v_old.is_betriebsrat::text, v_role->>'is_betriebsrat'); end if;
  if v_role ? 'has_dienstwagen' then v_contract_changes := app_aenderung(v_contract_changes, 'Dienstwagen', v_old.has_dienstwagen::text, v_role->>'has_dienstwagen'); end if;
  if v_role ? 'is_laterale_fuehrung' then v_contract_changes := app_aenderung(v_contract_changes, 'Laterale Führung', v_old.is_laterale_fuehrung::text, v_role->>'is_laterale_fuehrung'); end if;
  if v_role ? 'is_c_level' then v_contract_changes := app_aenderung(v_contract_changes, 'C-Level', v_old.is_c_level::text, v_role->>'is_c_level'); end if;
  if v_role ? 'has_kuendigungsschutz' then v_contract_changes := app_aenderung(v_contract_changes, 'Besonderer Kündigungsschutz', v_old.has_kuendigungsschutz::text, v_role->>'has_kuendigungsschutz'); end if;
  if v_role ? 'kuendigungsschutz_bis' then v_contract_changes := app_aenderung(v_contract_changes, 'Kündigungsschutz bis', v_old.kuendigungsschutz_bis::text, (nullif(v_role->>'kuendigungsschutz_bis','')::date)::text); end if;
  if v_role ? 'dienstwagen_art' then v_contract_changes := app_aenderung(v_contract_changes, 'Dienstwagen Antrieb', v_old.dienstwagen_art, nullif(v_role->>'dienstwagen_art', '')); end if;

  if v_immediate then
    update employees set
      first_name = coalesce(v_person->>'first_name', first_name),
      last_name = coalesce(v_person->>'last_name', last_name),
      gender = coalesce((v_person->>'gender')::gender_type, gender),
      birth_date = coalesce((v_person->>'birth_date')::date, birth_date),
      sv_nummer = coalesce(v_person->>'sv_nummer', sv_nummer),
      nationality = coalesce(v_person->>'nationality', nationality),
      address = coalesce(v_person->>'address', address),
      postal_code = coalesce(v_person->>'postal_code', postal_code),
      city = coalesce(v_person->>'city', city),
      address_country = coalesce(v_person->>'address_country', address_country),
      email = coalesce(v_person->>'email', email),
      phone = coalesce(v_person->>'phone', phone),
      emergency_contact_name = case when v_person ? 'emergency_contact_name' then nullif(v_person->>'emergency_contact_name', '') else emergency_contact_name end,
      emergency_contact_phone = case when v_person ? 'emergency_contact_phone' then nullif(v_person->>'emergency_contact_phone', '') else emergency_contact_phone end,
      emergency_contact_relation = case when v_person ? 'emergency_contact_relation' then nullif(v_person->>'emergency_contact_relation', '') else emergency_contact_relation end,
      title_prefix = case when v_person ? 'title_prefix' then v_new_title_prefix else title_prefix end,
      title_suffix = case when v_person ? 'title_suffix' then v_new_title_suffix else title_suffix end,
      employment_type = coalesce((v_contract->>'employment_type')::employment_type, employment_type),
      weekly_hours = coalesce((v_contract->>'weekly_hours')::numeric, weekly_hours),
      contract_type = coalesce((v_contract->>'contract_type')::contract_type, contract_type),
      contract_end_date = case when v_contract ? 'contract_end_date' then nullif(v_contract->>'contract_end_date','')::date else contract_end_date end,
      worker_type = coalesce((v_role->>'worker_type')::worker_type, worker_type),
      collective_agreement = coalesce((v_role->>'collective_agreement')::collective_agreement, collective_agreement),
      work_days = case when v_role ? 'work_days' then v_new_work_days else work_days end,
      is_betriebsrat = coalesce((v_role->>'is_betriebsrat')::boolean, is_betriebsrat),
      has_dienstwagen = coalesce((v_role->>'has_dienstwagen')::boolean, has_dienstwagen),
      is_laterale_fuehrung = coalesce((v_role->>'is_laterale_fuehrung')::boolean, is_laterale_fuehrung),
      is_c_level = coalesce((v_role->>'is_c_level')::boolean, is_c_level),
      has_kuendigungsschutz = coalesce((v_role->>'has_kuendigungsschutz')::boolean, has_kuendigungsschutz),
      -- Fällt der Schutz weg, fällt das Datum mit. Andernfalls bliebe ein
      -- Enddatum ohne Schutz stehen — die Bedingung verbietet das, und der
      -- Vorgang schlüge fehl, statt das Offensichtliche zu tun.
      kuendigungsschutz_bis = case
        when coalesce((v_role->>'has_kuendigungsschutz')::boolean, has_kuendigungsschutz) then
          case when v_role ? 'kuendigungsschutz_bis'
               then nullif(v_role->>'kuendigungsschutz_bis','')::date
               else kuendigungsschutz_bis end
        else null
      end,
      dienstwagen_art = case
        when coalesce((v_role->>'has_dienstwagen')::boolean, has_dienstwagen) then
          coalesce(nullif(v_role->>'dienstwagen_art', ''), dienstwagen_art, 'Verbrenner')
        else null
      end
    where id = v_employee_id;
  elsif jsonb_array_length(v_person_changes) > 0 or jsonb_array_length(v_contract_changes) > 0 then
    insert into pending_org_changes (employee_id, change_type, effective_date, payload)
      values (v_employee_id, 'contract_change', v_effective_date, payload)
      returning id into v_pending_id;
  end if;

  if jsonb_array_length(v_person_changes) > 0 then
    insert into employee_history (employee_id, event_date, event_type, description, changes, pending_id)
      values (v_employee_id, v_effective_date, 'Stammdatenänderung',
        'Geänderte Felder: ' || app_aenderungsfelder(v_person_changes) || ', wirksam ab ' || v_effective_date, v_person_changes, v_pending_id);
    insert into audit_log (actor_user_id, actor_name, action, target_label, target_employee_id, details, changes)
      values (app_current_user_id(), current_actor_name(), 'Stammdatenänderung', v_name, v_employee_id,
        app_aenderungsfelder(v_person_changes) || ', wirksam ab ' || v_effective_date, v_person_changes);
  end if;

  if jsonb_array_length(v_contract_changes) > 0 then
    insert into employee_history (employee_id, event_date, event_type, description, changes, pending_id)
      values (v_employee_id, v_effective_date, 'Vertragsänderung',
        'Geänderte Felder: ' || app_aenderungsfelder(v_contract_changes) || ', wirksam ab ' || v_effective_date
        || case when v_stunden_grund is not null and v_contract ? 'weekly_hours'
                then ' — ' || v_stunden_grund else '' end,
        v_contract_changes, v_pending_id);
    insert into audit_log (actor_user_id, actor_name, action, target_label, target_employee_id, details, changes)
      values (app_current_user_id(), current_actor_name(), 'Vertragsänderung', v_name, v_employee_id,
        app_aenderungsfelder(v_contract_changes) || ', wirksam ab ' || v_effective_date, v_contract_changes);
  end if;
end;
$function$;


-- Selbstprüfung.
do $$
declare
  v_ret text := pg_get_functiondef('public.record_karenz_return(jsonb)'::regprocedure);
  v_chg text := pg_get_functiondef('public.change_employee_data(jsonb)'::regprocedure);
begin
  if v_ret not like '%reduction_reason%' then
    raise exception 'record_karenz_return nimmt den Grund nicht entgegen';
  end if;
  if v_chg not like '%hours_reason%' then
    raise exception 'change_employee_data nimmt den Grund der Stundenänderung nicht entgegen';
  end if;
end
$$;