diff --git a/brmbar3/SQL b/brmbar3/SQL index 7e640a6..6fec1d2 100644 --- a/brmbar3/SQL +++ b/brmbar3/SQL @@ -39,7 +39,8 @@ CREATE TABLE accounts ( acctype account_type NOT NULL, - active BOOLEAN NOT NULL DEFAULT TRUE + active BOOLEAN NOT NULL DEFAULT TRUE, + crbalance DECIMAL(12,2) NOT NULL ); INSERT INTO accounts (name, currency, acctype) VALUES ('BrmBar Cash', (SELECT id FROM currencies WHERE name='Kč'), 'cash'); INSERT INTO accounts (name, currency, acctype) VALUES ('BrmBar Profits', (SELECT id FROM currencies WHERE name='Kč'), 'income'); @@ -92,12 +93,14 @@ CREATE TABLE transaction_splits ( -- Note that currency information is currently not supplied; inventory items -- have balances in stock amounts. CREATE VIEW account_balances AS - SELECT ts.account AS id, accounts.name AS name, accounts.acctype AS acctype, - -SUM(CASE WHEN ts.side = 'credit' THEN -ts.amount ELSE ts.amount END) AS crbalance - FROM transaction_splits AS ts - LEFT JOIN accounts ON accounts.id = ts.account - GROUP BY ts.account, accounts.name, accounts.acctype - ORDER BY crbalance ASC; + SELECT id, name, acctype, crbalance FROM accounts ORDER BY crbalance ASC; + +-- SELECT ts.account AS id, accounts.name AS name, accounts.acctype AS acctype, +-- -SUM(CASE WHEN ts.side = 'credit' THEN -ts.amount ELSE ts.amount END) AS crbalance +-- FROM transaction_splits AS ts +-- LEFT JOIN accounts ON accounts.id = ts.account +-- GROUP BY ts.account, accounts.name, accounts.acctype +-- ORDER BY crbalance ASC; -- Transaction splits in a form that's nicer to query during manual inspection CREATE VIEW transaction_nicesplits AS diff --git a/brmbar3/brmbar/Account.py b/brmbar3/brmbar/Account.py index 29dd79e..0c6448f 100644 --- a/brmbar3/brmbar/Account.py +++ b/brmbar3/brmbar/Account.py @@ -45,11 +45,9 @@ class Account: return cls(db, name = name, id = id, currency = currency, acctype = acctype) def balance(self): - debit = self.db.execute_and_fetch("SELECT SUM(amount) FROM transaction_splits WHERE account = %s AND side = %s", [self.id, 'debit']) - debit = debit[0] or 0 - credit = self.db.execute_and_fetch("SELECT SUM(amount) FROM transaction_splits WHERE account = %s AND side = %s", [self.id, 'credit']) - credit = credit[0] or 0 - return debit - credit + crbalance = self.db.execute_and_fetch("SELECT crbalance FROM accounts WHERE id = %s", [self.id]) + crbalance = crbalance[0] or 0 + return crbalance def balance_str(self): return self.currency.str(self.balance()) @@ -63,10 +61,13 @@ class Account: def credit(self, transaction, amount, memo): return self._transaction_split(transaction, 'credit', amount, memo) +# XXX atomicita def _transaction_split(self, transaction, side, amount, memo): """ Common part of credit() and debit(). """ self.db.execute("INSERT INTO transaction_splits (transaction, side, account, amount, memo) VALUES (%s, %s, %s, %s, %s)", [transaction, side, self.id, amount, memo]) + self.db.execute("UPDATE accounts set crbalance = crbalance + (CASE WHEN %s = 'credit' THEN -%s ELSE %s END)", [side,amount,amount]) + def add_barcode(self, barcode): self.db.execute("INSERT INTO barcodes (account, barcode) VALUES (%s, %s)", [self.id, barcode]) self.db.commit() diff --git a/brmbar3/brmbar/Shop.py b/brmbar3/brmbar/Shop.py index bf74fef..b5c61dc 100644 --- a/brmbar3/brmbar/Shop.py +++ b/brmbar3/brmbar/Shop.py @@ -105,16 +105,12 @@ class Shop: def credit_balance(self): # We assume all debt accounts share a currency sumselect = """ - SELECT SUM(ts.amount) - FROM accounts AS a - LEFT JOIN transaction_splits AS ts ON a.id = ts.account - WHERE a.acctype = %s AND ts.side = %s + SELECT SUM(crbalance) + FROM accounts WHERE acctype = %s """ - cur = self.db.execute_and_fetch(sumselect, ["debt", 'debit']) - debit = cur[0] or 0 - credit = self.db.execute_and_fetch(sumselect, ["debt", 'credit']) - credit = credit[0] or 0 - return debit - credit + cur = self.db.execute_and_fetch(sumselect, ["debt"]) + cur = cur[0] or 0 + return cur def credit_negbalance_str(self): return self.currency.str(-self.credit_balance()) @@ -139,7 +135,7 @@ class Shop: """list all accounts (people or items, as per acctype)""" accts = [] cur = self.db.execute_and_fetchall("SELECT id FROM accounts WHERE acctype = %s AND name ILIKE %s ORDER BY name ASC", [acctype, like_str]) - #FIXME: sanitize input like_str ^ + #FIXME: sanitize input like_str ^ for inventory in cur: accts += [ Account.load(self.db, id = inventory[0]) ] return accts