H6N/account
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

init socle

Browse source 
Signed-off-by: GnomeZworc <nicolas.boufidjeline@g3e.fr>
This commit is contained in:
GnomeZworc 2026-06-13 11:40:06 +02:00
commit 599479d746
Signed by: nicolas.boufideline
GPG key ID: 4406BBBF8845D632
12 changed files with 400 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

133
migrations/000001_init_schema.up.sql Normal file
View file

@ -0,0 +1,133 @@
CREATE EXTENSION IF NOT EXISTS timescaledb CASCADE;
-- Instruments : tout actif coté, y compris les devises (EUR prix = 1)
CREATE TABLE instrument (
id SERIAL PRIMARY KEY,
type TEXT NOT NULL, -- devise, action, etf, crypto
code TEXT NOT NULL UNIQUE, -- EUR, ISIN, ticker
name TEXT NOT NULL,
devise_cotation TEXT NOT NULL DEFAULT 'EUR'
);
-- Historique de prix (hypertable TimescaleDB)
CREATE TABLE price_history (
instrument_id INTEGER NOT NULL REFERENCES instrument(id),
date DATE NOT NULL,
prix NUMERIC(24, 8) NOT NULL,
PRIMARY KEY (instrument_id, date)
);
SELECT create_hypertable('price_history', by_range('date'));
-- Comptes : conteneurs de positions, aucun solde stocké
CREATE TABLE account (
id SERIAL PRIMARY KEY,
nom TEXT NOT NULL,
type TEXT NOT NULL, -- courant, livret, pea, cto, crypto, ...
devise_reference TEXT NOT NULL DEFAULT 'EUR',
plafond NUMERIC(24, 8),
taux NUMERIC(10, 6)
);
-- Enveloppes : ventilation logique EUR d'un compte (strictement monétaire)
CREATE TABLE envelope (
id SERIAL PRIMARY KEY,
account_id INTEGER NOT NULL REFERENCES account(id) ON DELETE CASCADE,
nom TEXT NOT NULL,
objectif TEXT,
montant_alloue NUMERIC(24, 8) NOT NULL DEFAULT 0
);
-- Règles de récurrence
CREATE TABLE recurring_rule (
id SERIAL PRIMARY KEY,
account_source_id INTEGER REFERENCES account(id),
instrument_source_id INTEGER REFERENCES instrument(id),
quantite_source NUMERIC(30, 18),
account_dest_id INTEGER REFERENCES account(id),
instrument_dest_id INTEGER REFERENCES instrument(id),
quantite_dest NUMERIC(30, 18),
tiers TEXT,
label TEXT NOT NULL,
categorie TEXT,
envelope_id INTEGER REFERENCES envelope(id),
frequence TEXT NOT NULL, -- RRULE string (RFC 5545)
date_debut DATE NOT NULL,
date_fin DATE,
generated_until DATE -- curseur d'idempotence
);
-- Transactions : échange atomique source/dest généralisé aux instruments
CREATE TABLE transaction (
id BIGSERIAL PRIMARY KEY,
date DATE NOT NULL,
account_source_id INTEGER REFERENCES account(id),
instrument_source_id INTEGER REFERENCES instrument(id),
quantite_source NUMERIC(30, 18),
account_dest_id INTEGER REFERENCES account(id),
instrument_dest_id INTEGER REFERENCES instrument(id),
quantite_dest NUMERIC(30, 18),
tiers TEXT,
label TEXT NOT NULL,
categorie TEXT,
envelope_id INTEGER REFERENCES envelope(id),
validated BOOLEAN NOT NULL DEFAULT FALSE,
recurring_rule_id INTEGER REFERENCES recurring_rule(id),
-- Chaque côté est soit entièrement renseigné soit entièrement null
-- Au moins un côté doit exister
CONSTRAINT chk_transaction_sides CHECK (
(
account_source_id IS NOT NULL AND
instrument_source_id IS NOT NULL AND
quantite_source IS NOT NULL
OR
account_source_id IS NULL AND
instrument_source_id IS NULL AND
quantite_source IS NULL
)
AND
(
account_dest_id IS NOT NULL AND
instrument_dest_id IS NOT NULL AND
quantite_dest IS NOT NULL
OR
account_dest_id IS NULL AND
instrument_dest_id IS NULL AND
quantite_dest IS NULL
)
AND
(account_source_id IS NOT NULL OR account_dest_id IS NOT NULL)
)
);
CREATE INDEX idx_transaction_date ON transaction(date);
CREATE INDEX idx_transaction_account_source ON transaction(account_source_id) WHERE account_source_id IS NOT NULL;
CREATE INDEX idx_transaction_account_dest ON transaction(account_dest_id) WHERE account_dest_id IS NOT NULL;
CREATE INDEX idx_transaction_unvalidated ON transaction(date) WHERE validated = FALSE;
-- Snapshots de position (hypertable TimescaleDB)
CREATE TABLE position_snapshot (
date DATE NOT NULL,
account_id INTEGER NOT NULL REFERENCES account(id),
instrument_id INTEGER NOT NULL REFERENCES instrument(id),
quantite NUMERIC(30, 18) NOT NULL,
pru NUMERIC(24, 8),
prix_cloture NUMERIC(24, 8),
valeur NUMERIC(24, 8),
PRIMARY KEY (date, account_id, instrument_id)
);
SELECT create_hypertable('position_snapshot', by_range('date'));
CREATE INDEX idx_position_snapshot_lookup ON position_snapshot(account_id, instrument_id, date DESC);
-- Snapshots de compte agrégés (hypertable TimescaleDB)
CREATE TABLE account_snapshot (
date DATE NOT NULL,
account_id INTEGER NOT NULL REFERENCES account(id),
valeur NUMERIC(24, 8) NOT NULL,
PRIMARY KEY (date, account_id)
);
SELECT create_hypertable('account_snapshot', by_range('date'));
CREATE INDEX idx_account_snapshot_lookup ON account_snapshot(account_id, date DESC);
-- EUR : instrument de base, prix toujours = 1
INSERT INTO instrument (type, code, name, devise_cotation) VALUES ('devise', 'EUR', 'Euro', 'EUR');