Engineered for Zero‑Defect Scale.

1-- 0007_tally_sync.sql · stock pushed from TallyPrime via TDL
2create or replace function public.tally_stock_webhook(payload jsonb)
3returns void language plpgsql security definer as $$
4begin
5  insert into tally_inventory (barcode, name, hsn, mrp, godown, closing_stock)
6  select i->>'barcode', i->>'name', i->>'hsn',
7         (i->>'mrp')::numeric, i->>'godown', (i->>'qty')::numeric
8  from jsonb_array_elements(payload->'items') as i
9  on conflict (barcode, godown) do update
10    set closing_stock = excluded.closing_stock,
11        updated_at    = now();
12 
13  -- low and negative stock feed the alert tray
14  perform notify_stock_thresholds(now() - interval '5 minutes');
15  update sync_status set last_push = now() where source = 'tallyprime';
16end;
17$$;