|
|
|
@@ -370,10 +370,10 @@ def update_user_permissions(username, preset_key, action_permissions=None, page_
|
|
|
|
|
client = MongoClient(cfg.MONGODB_HOST, cfg.MONGODB_PORT)
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
result = users.update_one({'Username': dp.encrypt_text(username)}, {'$set': update_data})
|
|
|
|
|
result = users.update_one({'Username': username}, {'$set': update_data})
|
|
|
|
|
|
|
|
|
|
if result.matched_count == 0:
|
|
|
|
|
result = users.update_one({'username': dp.encrypt_text(username)}, {'$set': update_data})
|
|
|
|
|
result = users.update_one({'username': username}, {'$set': update_data})
|
|
|
|
|
|
|
|
|
|
client.close()
|
|
|
|
|
return result.matched_count > 0
|
|
|
|
@@ -385,7 +385,7 @@ def get_favorites(username):
|
|
|
|
|
client = MongoClient(cfg.MONGODB_HOST, cfg.MONGODB_PORT)
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
user = users.find_one({'Username': dp.encrypt_text(username)}) or users.find_one({'username': dp.encrypt_text(username)})
|
|
|
|
|
user = users.find_one({'Username': username}) or users.find_one({'username': username})
|
|
|
|
|
client.close()
|
|
|
|
|
if not user:
|
|
|
|
|
return []
|
|
|
|
@@ -400,7 +400,7 @@ def add_favorite(username, item_id):
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
users.update_one(
|
|
|
|
|
{'$or': [{'Username': dp.encrypt_text(username)}, {'username': dp.encrypt_text(username)}]},
|
|
|
|
|
{'$or': [{'Username': username}, {'username': username}]},
|
|
|
|
|
{'$addToSet': {'favorites': ObjectId(item_id)}}
|
|
|
|
|
)
|
|
|
|
|
client.close()
|
|
|
|
@@ -415,7 +415,7 @@ def remove_favorite(username, item_id):
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
users.update_one(
|
|
|
|
|
{'$or': [{'Username': dp.encrypt_text(username)}, {'username': dp.encrypt_text(username)}]},
|
|
|
|
|
{'$or': [{'Username': username}, {'username': username}]},
|
|
|
|
|
{'$pull': {'favorites': ObjectId(item_id)}}
|
|
|
|
|
)
|
|
|
|
|
client.close()
|
|
|
|
@@ -497,7 +497,7 @@ def check_nm_pwd(username, password):
|
|
|
|
|
db = client[db_name]
|
|
|
|
|
users = db['users']
|
|
|
|
|
|
|
|
|
|
query = {'$or': [{'Username': dp.encrypt_text(username)}, {'username': dp.encrypt_text(username)}]}
|
|
|
|
|
query = {'$or': [{'Username': username}, {'username': username}]}
|
|
|
|
|
user_record = users.find_one(query)
|
|
|
|
|
|
|
|
|
|
if user_record is None:
|
|
|
|
@@ -508,8 +508,6 @@ def check_nm_pwd(username, password):
|
|
|
|
|
default_users = client[cfg.MONGODB_DB]['users']
|
|
|
|
|
user_record_fallback = default_users.find_one(
|
|
|
|
|
{'$or': [
|
|
|
|
|
{'Username': dp.encrypt_text(username)},
|
|
|
|
|
{'username': dp.encrypt_text(username)},
|
|
|
|
|
{'Username': username},
|
|
|
|
|
{'username': username},
|
|
|
|
|
]}
|
|
|
|
@@ -712,9 +710,9 @@ def make_admin(username):
|
|
|
|
|
client = MongoClient(cfg.MONGODB_HOST, cfg.MONGODB_PORT)
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
result = users.update_one({'Username': dp.encrypt_text(username)}, {'$set': {'Admin': True}})
|
|
|
|
|
result = users.update_one({'Username': username}, {'$set': {'Admin': True}})
|
|
|
|
|
if result.matched_count == 0:
|
|
|
|
|
result = users.update_one({'username': dp.encrypt_text(username)}, {'$set': {'Admin': True}})
|
|
|
|
|
result = users.update_one({'username': username}, {'$set': {'Admin': True}})
|
|
|
|
|
client.close()
|
|
|
|
|
return result.matched_count > 0
|
|
|
|
|
|
|
|
|
@@ -724,9 +722,9 @@ def remove_admin(username):
|
|
|
|
|
client = MongoClient(cfg.MONGODB_HOST, cfg.MONGODB_PORT)
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
result = users.update_one({'Username': dp.encrypt_text(username)}, {'$set': {'Admin': False}})
|
|
|
|
|
result = users.update_one({'Username': username}, {'$set': {'Admin': False}})
|
|
|
|
|
if result.matched_count == 0:
|
|
|
|
|
result = users.update_one({'username': dp.encrypt_text(username)}, {'$set': {'Admin': False}})
|
|
|
|
|
result = users.update_one({'username': username}, {'$set': {'Admin': False}})
|
|
|
|
|
client.close()
|
|
|
|
|
return result.matched_count > 0
|
|
|
|
|
|
|
|
|
@@ -738,7 +736,7 @@ def get_user(username):
|
|
|
|
|
def find_in_db(database_name):
|
|
|
|
|
db = client[database_name]
|
|
|
|
|
users = db['users']
|
|
|
|
|
return users.find_one({'Username': dp.encrypt_text(username)}) or users.find_one({'username': dp.encrypt_text(username)}) or users.find_one({'username': username}) or users.find_one({'Username': username})
|
|
|
|
|
return users.find_one({'Username': username}) or users.find_one({'username': username}) or users.find_one({'username': username}) or users.find_one({'Username': username})
|
|
|
|
|
|
|
|
|
|
tenant_db, tenant_id = _resolve_request_tenant_db()
|
|
|
|
|
if tenant_db:
|
|
|
|
@@ -774,12 +772,12 @@ def update_active_ausleihung(username, id_item, ausleihung):
|
|
|
|
|
users = db['users']
|
|
|
|
|
|
|
|
|
|
result = users.update_one(
|
|
|
|
|
{'Username': dp.encrypt_text(username)},
|
|
|
|
|
{'Username': username},
|
|
|
|
|
{'$set': {'active_ausleihung': {'Item': id_item, 'Ausleihung': ausleihung}}}
|
|
|
|
|
)
|
|
|
|
|
if result.matched_count == 0:
|
|
|
|
|
users.update_one(
|
|
|
|
|
{'username': dp.encrypt_text(username)},
|
|
|
|
|
{'username': username},
|
|
|
|
|
{'$set': {'active_ausleihung': {'Item': id_item, 'Ausleihung': ausleihung}}}
|
|
|
|
|
)
|
|
|
|
|
client.close()
|
|
|
|
@@ -792,7 +790,7 @@ def get_active_ausleihung(username):
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
|
|
|
|
|
user = users.find_one({'Username': dp.encrypt_text(username)}) or users.find_one({'username': dp.encrypt_text(username)})
|
|
|
|
|
user = users.find_one({'Username': username}) or users.find_one({'username': username})
|
|
|
|
|
client.close()
|
|
|
|
|
|
|
|
|
|
if not user:
|
|
|
|
@@ -807,7 +805,7 @@ def has_active_borrowing(username):
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
|
|
|
|
|
user = users.find_one({'username': dp.encrypt_text(username)}) or users.find_one({'Username': dp.encrypt_text(username)})
|
|
|
|
|
user = users.find_one({'username': username}) or users.find_one({'Username': username})
|
|
|
|
|
client.close()
|
|
|
|
|
|
|
|
|
|
if not user:
|
|
|
|
@@ -824,9 +822,9 @@ def delete_user(username):
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
|
|
|
|
|
result = users.delete_one({'username': dp.encrypt_text(username)})
|
|
|
|
|
result = users.delete_one({'username': username})
|
|
|
|
|
if result.deleted_count == 0:
|
|
|
|
|
result = users.delete_one({'Username': dp.encrypt_text(username)})
|
|
|
|
|
result = users.delete_one({'Username': username})
|
|
|
|
|
|
|
|
|
|
client.close()
|
|
|
|
|
return result.deleted_count > 0
|
|
|
|
@@ -841,9 +839,9 @@ def update_active_borrowing(username, item_id, status):
|
|
|
|
|
|
|
|
|
|
update_data = {'$set': {'active_borrowing': status, 'borrowed_item': item_id if status else None}}
|
|
|
|
|
|
|
|
|
|
result = users.update_one({'username': dp.encrypt_text(username)}, update_data)
|
|
|
|
|
result = users.update_one({'username': username}, update_data)
|
|
|
|
|
if result.matched_count == 0:
|
|
|
|
|
result = users.update_one({'Username': dp.encrypt_text(username)}, update_data)
|
|
|
|
|
result = users.update_one({'Username': username}, update_data)
|
|
|
|
|
|
|
|
|
|
client.close()
|
|
|
|
|
return result.modified_count > 0
|
|
|
|
@@ -857,7 +855,7 @@ def get_name(username):
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
|
|
|
|
|
user = users.find_one({'Username': dp.encrypt_text(username)}) or users.find_one({'username': dp.encrypt_text(username)})
|
|
|
|
|
user = users.find_one({'Username': username}) or users.find_one({'username': username})
|
|
|
|
|
client.close()
|
|
|
|
|
|
|
|
|
|
if not user or not user.get("name"):
|
|
|
|
@@ -872,7 +870,7 @@ def get_last_name(username):
|
|
|
|
|
db = _get_tenant_db(client)
|
|
|
|
|
users = db['users']
|
|
|
|
|
|
|
|
|
|
user = users.find_one({'Username': dp.encrypt_text(username)}) or users.find_one({'username': dp.encrypt_text(username)})
|
|
|
|
|
user = users.find_one({'Username': username}) or users.find_one({'username': username})
|
|
|
|
|
client.close()
|
|
|
|
|
|
|
|
|
|
if not user or not user.get("last_name"):
|
|
|
|
@@ -907,12 +905,12 @@ def update_password(username, new_password):
|
|
|
|
|
hashed_password = hashing(new_password)
|
|
|
|
|
|
|
|
|
|
result = users.update_one(
|
|
|
|
|
{'Username': dp.encrypt_text(username)},
|
|
|
|
|
{'Username': username},
|
|
|
|
|
{'$set': {'Password': hashed_password}}
|
|
|
|
|
)
|
|
|
|
|
if result.matched_count == 0:
|
|
|
|
|
result = users.update_one(
|
|
|
|
|
{'username': dp.encrypt_text(username)},
|
|
|
|
|
{'username': username},
|
|
|
|
|
{'$set': {'Password': hashed_password}}
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
@@ -934,12 +932,12 @@ def update_user_name(username, name, last_name):
|
|
|
|
|
safe_last_name = dp.encrypt_text(last_name.strip()) if last_name else ''
|
|
|
|
|
|
|
|
|
|
result = users.update_one(
|
|
|
|
|
{'Username': dp.encrypt_text(username)},
|
|
|
|
|
{'Username': username},
|
|
|
|
|
{'$set': {'name': safe_name, 'last_name': safe_last_name}}
|
|
|
|
|
)
|
|
|
|
|
if result.matched_count == 0:
|
|
|
|
|
result = users.update_one(
|
|
|
|
|
{'username': dp.encrypt_text(username)},
|
|
|
|
|
{'username': username},
|
|
|
|
|
{'$set': {'name': safe_name, 'last_name': safe_last_name}}
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|