forked from brmlab/brmbar-github
Compare commits
4 commits
Author | SHA1 | Date | |
---|---|---|---|
114e67c445 | |||
1db6a32ceb | |||
4c65f70079 | |||
2ff7165bec |
5 changed files with 3 additions and 101 deletions
|
@ -168,25 +168,21 @@ class ShopAdapter(QtCore.QObject):
|
||||||
|
|
||||||
@QtCore.Slot(result='QVariant')
|
@QtCore.Slot(result='QVariant')
|
||||||
def balance_cash(self):
|
def balance_cash(self):
|
||||||
return "N/A"
|
|
||||||
balance = shop.cash.balance_str()
|
balance = shop.cash.balance_str()
|
||||||
db.commit()
|
db.commit()
|
||||||
return balance
|
return balance
|
||||||
@QtCore.Slot(result='QVariant')
|
@QtCore.Slot(result='QVariant')
|
||||||
def balance_profit(self):
|
def balance_profit(self):
|
||||||
return "N/A"
|
|
||||||
balance = shop.profits.balance_str()
|
balance = shop.profits.balance_str()
|
||||||
db.commit()
|
db.commit()
|
||||||
return balance
|
return balance
|
||||||
@QtCore.Slot(result='QVariant')
|
@QtCore.Slot(result='QVariant')
|
||||||
def balance_inventory(self):
|
def balance_inventory(self):
|
||||||
return "N/A"
|
|
||||||
balance = shop.inventory_balance_str()
|
balance = shop.inventory_balance_str()
|
||||||
db.commit()
|
db.commit()
|
||||||
return balance
|
return balance
|
||||||
@QtCore.Slot(result='QVariant')
|
@QtCore.Slot(result='QVariant')
|
||||||
def balance_credit(self):
|
def balance_credit(self):
|
||||||
return "N/A"
|
|
||||||
balance = shop.credit_negbalance_str()
|
balance = shop.credit_negbalance_str()
|
||||||
db.commit()
|
db.commit()
|
||||||
return balance
|
return balance
|
||||||
|
|
|
@ -130,5 +130,5 @@ class Currency:
|
||||||
def update_buy_rate(self, source, rate):
|
def update_buy_rate(self, source, rate):
|
||||||
self.db.execute(
|
self.db.execute(
|
||||||
"SELECT public.update_currency_buy_rate(%s, %s, %s)",
|
"SELECT public.update_currency_buy_rate(%s, %s, %s)",
|
||||||
[self.id, source.id, rate],
|
[source.id, self.id, rate],
|
||||||
)
|
)
|
||||||
|
|
|
@ -35,7 +35,6 @@ class Database:
|
||||||
def _execute(self, cur, query, attrs, level=1):
|
def _execute(self, cur, query, attrs, level=1):
|
||||||
"""execute a query, and in case of OperationalError (db restart)
|
"""execute a query, and in case of OperationalError (db restart)
|
||||||
reconnect to database. Recurses with increasig pause between tries"""
|
reconnect to database. Recurses with increasig pause between tries"""
|
||||||
logger.debug("SQL: (%s) @%s" % (query, time.strftime("%Y%m%d %a %I:%m %p")))
|
|
||||||
try:
|
try:
|
||||||
if attrs is None:
|
if attrs is None:
|
||||||
cur.execute(query)
|
cur.execute(query)
|
||||||
|
|
|
@ -198,13 +198,12 @@ class Shop:
|
||||||
"""list all accounts (people or items, as per acctype)"""
|
"""list all accounts (people or items, as per acctype)"""
|
||||||
accts = []
|
accts = []
|
||||||
cur = self.db.execute_and_fetchall(
|
cur = self.db.execute_and_fetchall(
|
||||||
"SELECT a.id, a.name aname, a.currency, a.acctype, c.name cname FROM accounts a JOIN currencies c ON c.id=a.currency WHERE a.acctype = %s AND a.name ILIKE %s ORDER BY a.name ASC",
|
"SELECT id FROM accounts WHERE acctype = %s AND name ILIKE %s ORDER BY name ASC",
|
||||||
[acctype, like_str],
|
[acctype, like_str],
|
||||||
)
|
)
|
||||||
# FIXME: sanitize input like_str ^
|
# FIXME: sanitize input like_str ^
|
||||||
for inventory in cur:
|
for inventory in cur:
|
||||||
curr = Currency(db=self.db, id=inventory[2], name=inventory[4]);
|
accts += [Account.load(self.db, id=inventory[0])]
|
||||||
accts += [Account(self.db, id=inventory[0], name=inventory[1], currency=curr, acctype=inventory[3])]
|
|
||||||
return accts
|
return accts
|
||||||
|
|
||||||
def fix_inventory(self, item, amount):
|
def fix_inventory(self, item, amount):
|
||||||
|
|
|
@ -1,92 +0,0 @@
|
||||||
--
|
|
||||||
-- 0024-find-rates-fix.sql
|
|
||||||
--
|
|
||||||
-- #23 - fix stored functions find_buy_rate and find_sell_rate
|
|
||||||
--
|
|
||||||
-- ISC License
|
|
||||||
--
|
|
||||||
-- Copyright 2023-2025 Brmlab, z.s.
|
|
||||||
-- TMA <tma+hs@jikos.cz>
|
|
||||||
--
|
|
||||||
-- Permission to use, copy, modify, and/or distribute this software
|
|
||||||
-- for any purpose with or without fee is hereby granted, provided
|
|
||||||
-- that the above copyright notice and this permission notice appear
|
|
||||||
-- in all copies.
|
|
||||||
--
|
|
||||||
-- THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL
|
|
||||||
-- WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED
|
|
||||||
-- WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE
|
|
||||||
-- AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR
|
|
||||||
-- CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
|
|
||||||
-- OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT,
|
|
||||||
-- NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
|
|
||||||
-- CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
||||||
--
|
|
||||||
|
|
||||||
-- To require fully-qualified names
|
|
||||||
SELECT pg_catalog.set_config('search_path', '', false);
|
|
||||||
|
|
||||||
DO $upgrade_block$
|
|
||||||
BEGIN
|
|
||||||
|
|
||||||
IF brmbar_privileged.has_exact_schema_version(23) THEN
|
|
||||||
|
|
||||||
DROP FUNCTION IF EXISTS public.find_buy_rate(integer,integer);
|
|
||||||
DROP FUNCTION IF EXISTS public.find_sell_rate(integer,integer);
|
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION public.find_buy_rate(
|
|
||||||
IN i_item_currency_id public.accounts.id%TYPE,
|
|
||||||
IN i_other_currency_id public.accounts.id%TYPE
|
|
||||||
) RETURNS NUMERIC
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
AS $$
|
|
||||||
DECLARE
|
|
||||||
v_rate public.exchange_rates.rate%TYPE;
|
|
||||||
v_rate_dir public.exchange_rates.rate_dir%TYPE;
|
|
||||||
BEGIN
|
|
||||||
SELECT rate, rate_dir INTO STRICT v_rate, v_rate_dir FROM public.exchange_rates WHERE target = i_item_currency_id AND source = i_other_currency_id AND valid_since <= NOW() ORDER BY valid_since DESC LIMIT 1;
|
|
||||||
IF v_rate_dir = 'target_to_source'::public.exchange_rate_direction THEN
|
|
||||||
RETURN v_rate;
|
|
||||||
ELSE
|
|
||||||
RETURN 1/v_rate;
|
|
||||||
END IF;
|
|
||||||
/* propagate error
|
|
||||||
EXCEPTION
|
|
||||||
WHEN NO_DATA_FOUND THEN
|
|
||||||
RETURN -1;
|
|
||||||
*/
|
|
||||||
END;
|
|
||||||
$$;
|
|
||||||
|
|
||||||
-- return negative number on rate not found
|
|
||||||
CREATE OR REPLACE FUNCTION public.find_sell_rate(
|
|
||||||
IN i_item_currency_id public.accounts.id%TYPE,
|
|
||||||
IN i_other_currency_id public.accounts.id%TYPE
|
|
||||||
) RETURNS NUMERIC
|
|
||||||
LANGUAGE plpgsql
|
|
||||||
AS $$
|
|
||||||
DECLARE
|
|
||||||
v_rate public.exchange_rates.rate%TYPE;
|
|
||||||
v_rate_dir public.exchange_rates.rate_dir%TYPE;
|
|
||||||
BEGIN
|
|
||||||
SELECT rate, rate_dir INTO STRICT v_rate, v_rate_dir FROM public.exchange_rates WHERE target = i_other_currency_id AND source = i_item_currency_id AND valid_since <= NOW() ORDER BY valid_since DESC LIMIT 1;
|
|
||||||
IF v_rate_dir = 'source_to_target'::public.exchange_rate_direction THEN
|
|
||||||
RETURN v_rate;
|
|
||||||
ELSE
|
|
||||||
RETURN 1/v_rate;
|
|
||||||
END IF;
|
|
||||||
/* propagate error
|
|
||||||
EXCEPTION
|
|
||||||
WHEN NO_DATA_FOUND THEN
|
|
||||||
RETURN -1;
|
|
||||||
*/
|
|
||||||
END;
|
|
||||||
$$;
|
|
||||||
|
|
||||||
PERFORM brmbar_privileged.upgrade_schema_version_to(24);
|
|
||||||
END IF;
|
|
||||||
|
|
||||||
END;
|
|
||||||
$upgrade_block$;
|
|
||||||
|
|
||||||
-- vim: set ft=plsql :
|
|
Loading…
Add table
Add a link
Reference in a new issue