You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
61 lines
2.8 KiB
61 lines
2.8 KiB
# -*- coding: utf8 -*- |
|
# Общественное достояние 2023, Алексей Безбородов (Alexei Bezborodov) <AlexeiBv+mirocod_platform_bot@narod.ru> |
|
|
|
# Работа с элементом в БД |
|
|
|
from bot_sys import user_access, bot_bd |
|
from bot_modules import groups |
|
|
|
from aiogram import types |
|
|
|
''' |
|
class TableListParam(): |
|
def __init__(self, a_TableName : str, a_KeyName : str, a_GetButtonNameAndKeyValueAndAccessFunc): |
|
self.table_name = a_TableName |
|
self.key_name = a_KeyName |
|
self.get_bname_and_key_value_func = a_GetButtonNameAndKeyValueAndAccessFunc |
|
''' |
|
|
|
item_not_found = 'Элемент {item_id} не найден в таблице {a_TableName}' |
|
|
|
def GetAllItemsTemplate(a_TableName): |
|
def GetAllItems(): |
|
return bot_bd.SelectBDTemplate(a_TableName)() |
|
return GetAllItems |
|
|
|
def GetBDItemsTemplate(a_TableName : str, a_KeyName : str): |
|
def GetBDItem(a_KeyValue): |
|
return bot_bd.SQLRequestToBD(f'SELECT * FROM {a_TableName} WHERE {a_KeyName} = ?', param = ([a_KeyValue])) |
|
return GetBDItem |
|
|
|
def DeleteBDItemInTableTemplate(a_TableName : str, a_KeyName : str): |
|
def DeleteBDItem(a_KeyValue): |
|
return bot_bd.SQLRequestToBD(f'DELETE FROM {a_TableName} WHERE {a_KeyName} = ?', commit = True, return_error = True, param = ([a_KeyValue])) |
|
return DeleteBDItem |
|
|
|
def EditBDItemInTableTemplate(a_TableName : str, a_KeyName : str, a_FieldName : str): |
|
def EditBDItemInTable(a_KeyValue, a_FieldValue): |
|
return bot_bd.SQLRequestToBD(f'UPDATE {a_TableName} SET {a_FieldName}=? WHERE {a_KeyName} = ?', commit = True, return_error = True, param = ([a_FieldValue, a_KeyValue])) |
|
return EditBDItemInTable |
|
|
|
def CheckAccessBDItemTemplate(a_TableName, a_KeyName, a_KeyValue, a_WorkFunc, a_AccessMode : user_access.AccessMode): |
|
async def CheckAccessBDItem(a_CallbackQuery : types.CallbackQuery, a_ResultWorkFunc): |
|
user_id = str(a_CallbackQuery.from_user.id) |
|
user_groups = groups.GetUserGroupData(user_id) |
|
item_id = a_KeyValue |
|
item = GetBDItemsTemplate(a_TableName, a_KeyName)(item_id) |
|
if len(item) < 1: |
|
msg = item_not_found.replace('{item_id}', str(item_id)).replace('{a_TableName}', a_TableName) |
|
log.Error(msg) |
|
return simple_message.WorkFuncResult(msg) |
|
|
|
a_ResultWorkFunc = await a_WorkFunc(a_CallbackQuery, item[0]) |
|
if a_ResultWorkFunc is None or a_ResultWorkFunc.string_message is None: |
|
print('a_ResultWorkFunc', a_ResultWorkFunc) |
|
return a_ResultWorkFunc |
|
|
|
if not a_ResultWorkFunc.item_access is None and not user_access.CheckAccessString(a_ResultWorkFunc.item_access, user_groups, a_AccessMode): |
|
return simple_message.WorkFuncResult(access.access_denied_message) |
|
|
|
return None |
|
return CheckAccessBDItem
|
|
|