update methods and immutable attribute added
This commit is contained in:
270
api/methods.py
270
api/methods.py
@ -5,8 +5,9 @@
|
||||
# -----------------------------------------
|
||||
|
||||
|
||||
from db import dbGetMany, dbGetOne, dbInsert
|
||||
from db import dbGetMany, dbGetOne, dbInsert, dbUpdate
|
||||
from loguru import logger
|
||||
import werkzeug
|
||||
|
||||
def get_accounts(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
@ -57,6 +58,28 @@ SELECT
|
||||
"params": (accountId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_account(user, token_info, accountId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_description = body["description"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE account_t
|
||||
SET
|
||||
description = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_description,
|
||||
accountId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_account: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_tenants(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -173,6 +196,58 @@ SELECT
|
||||
"params": (tenantId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_tenant(user, token_info, tenantId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_salutation = body["salutation"]
|
||||
v_firstname = body["firstname"]
|
||||
v_lastname = body["lastname"]
|
||||
v_address1 = body["address1"]
|
||||
v_address2 = body["address2"]
|
||||
v_address3 = body["address3"]
|
||||
v_zip = body["zip"]
|
||||
v_city = body["city"]
|
||||
v_phone1 = body["phone1"]
|
||||
v_phone2 = body["phone2"]
|
||||
v_iban = body["iban"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE tenant_t
|
||||
SET
|
||||
salutation = %s
|
||||
,firstname = %s
|
||||
,lastname = %s
|
||||
,address1 = %s
|
||||
,address2 = %s
|
||||
,address3 = %s
|
||||
,zip = %s
|
||||
,city = %s
|
||||
,phone1 = %s
|
||||
,phone2 = %s
|
||||
,iban = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_salutation,
|
||||
v_firstname,
|
||||
v_lastname,
|
||||
v_address1,
|
||||
v_address2,
|
||||
v_address3,
|
||||
v_zip,
|
||||
v_city,
|
||||
v_phone1,
|
||||
v_phone2,
|
||||
v_iban,
|
||||
tenantId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_tenant: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_premises(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -240,6 +315,37 @@ SELECT
|
||||
"params": (premiseId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_premise(user, token_info, premiseId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_description = body["description"]
|
||||
v_street = body["street"]
|
||||
v_zip = body["zip"]
|
||||
v_city = body["city"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE premise_t
|
||||
SET
|
||||
description = %s
|
||||
,street = %s
|
||||
,zip = %s
|
||||
,city = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_description,
|
||||
v_street,
|
||||
v_zip,
|
||||
v_city,
|
||||
premiseId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_premise: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_flats(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -308,6 +414,37 @@ SELECT
|
||||
"params": (flatId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_flat(user, token_info, flatId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_description = body["description"]
|
||||
v_premise = body["premise"]
|
||||
v_area = body["area"]
|
||||
v_flat_no = body["flat_no"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE flat_t
|
||||
SET
|
||||
description = %s
|
||||
,premise = %s
|
||||
,area = %s
|
||||
,flat_no = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_description,
|
||||
v_premise,
|
||||
v_area,
|
||||
v_flat_no,
|
||||
flatId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_flat: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_overhead_advances(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -376,6 +513,31 @@ SELECT
|
||||
"params": (overhead_advanceId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_overhead_advance(user, token_info, overhead_advanceId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_description = body["description"]
|
||||
v_enddate = body["enddate"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE overhead_advance_t
|
||||
SET
|
||||
description = %s
|
||||
,enddate = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_description,
|
||||
v_enddate,
|
||||
overhead_advanceId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_overhead_advance: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_overhead_advance_flat_mappings(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -432,6 +594,8 @@ SELECT
|
||||
"params": (overhead_advance_flat_mappingId, )
|
||||
}
|
||||
)
|
||||
|
||||
|
||||
def get_parkings(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -488,6 +652,31 @@ SELECT
|
||||
"params": (parkingId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_parking(user, token_info, parkingId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_description = body["description"]
|
||||
v_premise = body["premise"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE parking_t
|
||||
SET
|
||||
description = %s
|
||||
,premise = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_description,
|
||||
v_premise,
|
||||
parkingId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_parking: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_commercial_premises(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -544,6 +733,31 @@ SELECT
|
||||
"params": (commercial_premiseId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_commercial_premise(user, token_info, commercial_premiseId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_description = body["description"]
|
||||
v_premise = body["premise"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE commercial_premise_t
|
||||
SET
|
||||
description = %s
|
||||
,premise = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_description,
|
||||
v_premise,
|
||||
commercial_premiseId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_commercial_premise: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_tenancys(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -630,6 +844,31 @@ SELECT
|
||||
"params": (tenancyId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_tenancy(user, token_info, tenancyId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_description = body["description"]
|
||||
v_enddate = body["enddate"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE tenancy_t
|
||||
SET
|
||||
description = %s
|
||||
,enddate = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_description,
|
||||
v_enddate,
|
||||
tenancyId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_tenancy: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_fees(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -704,6 +943,31 @@ SELECT
|
||||
"params": (feeId, )
|
||||
}
|
||||
)
|
||||
|
||||
def update_fee(user, token_info, feeId=None, **args):
|
||||
try:
|
||||
body = args["body"]
|
||||
v_description = body["description"]
|
||||
v_enddate = body["enddate"]
|
||||
return dbUpdate(user, token_info, {
|
||||
"statement": """
|
||||
UPDATE fee_t
|
||||
SET
|
||||
description = %s
|
||||
,enddate = %s
|
||||
WHERE id = %s
|
||||
RETURNING *
|
||||
""",
|
||||
"params": [
|
||||
v_description,
|
||||
v_enddate,
|
||||
feeId
|
||||
]
|
||||
})
|
||||
except KeyError as e:
|
||||
logger.warning("update_fee: parameter missing: {}".format(e))
|
||||
raise werkzeug.exceptions.UnprocessableEntity("parameter missing: {}".format(e))
|
||||
|
||||
def get_tenancy_fee_mappings(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -757,6 +1021,8 @@ SELECT
|
||||
"params": (tenancy_fee_mappingId, )
|
||||
}
|
||||
)
|
||||
|
||||
|
||||
def get_account_entrys(user, token_info):
|
||||
return dbGetMany(user, token_info, {
|
||||
"statement": """
|
||||
@ -822,3 +1088,5 @@ SELECT
|
||||
"params": (account_entryId, )
|
||||
}
|
||||
)
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user