-- Imported history must preserve unknown or partial payments.
create or replace function public.sun_process_due_orders_internal(p_workspace uuid,p_now timestamptz default now())
returns jsonb
language plpgsql
security definer
set search_path='public' as $$
declare v_tz text; v_changed integer:=0; v_ids text[]:=array[]::text[]; r record; v_total numeric; v_iso text; v_orders jsonb;
begin
  select timezone into v_tz from public.sun_workspaces where id=p_workspace;
  if v_tz is null then return jsonb_build_object('changed',0,'ids','[]'::jsonb); end if;
  v_iso:=to_char(p_now at time zone 'UTC','YYYY-MM-DD"T"HH24:MI:SS.MS"Z"');
  for r in
    select order_id,data,version from public.sun_v17_orders
    where workspace_id=p_workspace
      and lower(coalesce(data->>'status','')) not in ('отменён','отменен','отдан заказчику','завершён','завершен')
      and coalesce(data->>'sunAutoCompletedAt','')=''
      and coalesce(data->>'autoCompletionDisabled','false') <> 'true'
      and public.sun_order_due_at(data,v_tz) is not null
      and public.sun_order_due_at(data,v_tz) <= p_now
    for update
  loop
    v_total:=case when coalesce(r.data->>'total','') ~ '^-?\d+(\.\d+)?$' then greatest(0,(r.data->>'total')::numeric) else 0 end;
    update public.sun_v17_orders
    set data=r.data||jsonb_build_object('prepayment',v_total,'balance',0,'status','Отдан заказчику','paymentStatus','paid','completedAt',coalesce(nullif(r.data->>'completedAt',''),v_iso),'paymentCompletedAt',coalesce(nullif(r.data->>'paymentCompletedAt',''),v_iso),'sunAutoCompletedAt',v_iso,'sunAutoCompletedV1770',true,'sunAutoCompletedVersion','17.7.0'),version=version+1,updated_at=p_now,updated_by=null
    where workspace_id=p_workspace and order_id=r.order_id;
    insert into public.sun_v17_change_events(workspace_id,entity,entity_key,operation,version,client_id,created_by)
    values(p_workspace,'order',r.order_id,'upsert',r.version+1,'server:auto-complete',null);
    v_changed:=v_changed+1;v_ids:=array_append(v_ids,r.order_id);
  end loop;
  if v_changed>0 then
    select coalesce(jsonb_agg(o.data order by case when o.order_id ~ '^\d+$' then o.order_id::bigint else null end,o.order_id),'[]'::jsonb) into v_orders from public.sun_v17_orders o where o.workspace_id=p_workspace;
    update public.sun_app_state s set payload=jsonb_set(coalesce(s.payload,'{}'::jsonb),'{storage,sunOrders}',jsonb_build_object('t','j','v',v_orders),true),revision=s.revision+1,updated_at=p_now,client_id='server:auto-complete' where s.workspace_id=p_workspace;
    if not found then insert into public.sun_app_state(workspace_id,payload,revision,updated_at,client_id) values(p_workspace,jsonb_build_object('format','sun-cloud-v2','version',2,'storage',jsonb_build_object('sunOrders',jsonb_build_object('t','j','v',v_orders))),1,p_now,'server:auto-complete'); end if;
  end if;
  return jsonb_build_object('changed',v_changed,'ids',to_jsonb(v_ids),'workspace',p_workspace,'timezone',v_tz,'processed_at',v_iso);
end;$$;

-- The archive contains both order and customer data.
do $migration$
declare definition text;
begin
 definition:=pg_get_functiondef('public.sun_can_read_storage_key(uuid,text)'::regprocedure);
 definition:=replace(definition, 'when p_key=''sunOrders'' then', 'when p_key=''sunTelegramImportArchiveV1'' then public.sun_has_permission(p_workspace,''orders.view'') and public.sun_has_permission(p_workspace,''clients.view'')
    when p_key=''sunOrders'' then');
 execute definition;
end $migration$;