No - Номер строки (ПК)

TgID - Идентификатор пользователя в Телеграмм

NickName - Логин пользователя в Steam

KZ - Баланс тенге

Logined - Флаг указывающий на выбраны в данный момент аккаунт Steam

No - номер заказа (ПК)

NickName - целевой аккаунт (внешний ключ к customers)

RU - Количество рублей прошедших через заказ

KZ - Количество тенге прошедших через заказ

Status - Статус заказа

Url - ссылка на форму оплаты

CreateDateTime - Дата и Время создания

PiadDateTime - дата и Время исполнения

commission - комиссия за выполнение (в основном использовалась как поправочный коэффициент покрывающий комиссию QIWI за переводы и конвертацию валют)

Name - имя QIWI кошелька (ПК)

Is_default - Выбранный кошелек для операций

# Пустой набор
Delete_markup = types.ReplyKeyboardRemove()
# Регистрация 
Regestration_markup = types.ReplyKeyboardMarkup(resize_keyboard = True)
Regestration_markup.add(types.KeyboardButton("Вход"))
# Главное меню
Main_menu_markup = types.ReplyKeyboardMarkup(resize_keyboard = True)
Main_menu_markup.add(types.KeyboardButton("Создать ссылку на пополнение Steam"))
Main_menu_markup.add(types.KeyboardButton("Подтвердить статус оплаты"))
Main_menu_markup.add(types.KeyboardButton("Менеджер акаунтов"))
# Менеждер акаунтов
Nick_Name_menu_markup = types.ReplyKeyboardMarkup(resize_keyboard = True)
Nick_Name_menu_markup.add(types.KeyboardButton("Добавить новый акаунт Steam"))
Nick_Name_menu_markup.add(types.KeyboardButton("Сменить Steam акаунт"))
Nick_Name_menu_markup.add(types.KeyboardButton("Назад"))
# Заказы, предпологал возможность расширения опций
Order_menu_markup = types.ReplyKeyboardMarkup(resize_keyboard = True)
Order_menu_markup.add(types.KeyboardButton("Назад"))

@Bot.message_handler(content_types=['text'])
def main(message):
  if "Создать ссылку на пополнение Steam" == message.text:               
      Bot.send_message(message.chat.id, 'Введите сумму на котору пополнить акаунт\n'+nick_name+'\nМинимум 85 (требование QIWI)',reply_markup = Order_menu_markup)
      Bot.register_next_step_handler(message,createpayment)
      
  if "Подтвердить статус оплаты" == message.text:
          Bot.send_message(message.chat.id, 'Подтверждено пополнений '+0+'\nЗаказов отправлено на Steam '+0+'\nБудем рады если вы оставите отзыв от том какая сумма пришла на Steam\nЭто поможет нам улучшить сервис\nhttps://t.me/ander_kot_1',reply_markup= Main_menu_markup)
          Bot.register_next_step_handler(message,main)
      else:
          Bot.send_message(message.chat.id, 'Оплат по ссылкам не найдено !\nЕсли вы производили оплату свяжитесь с подержкой!\nhttps://t.me/ander_kot_1',reply_markup= Main_menu_markup)
          Bot.register_next_step_handler(message,main)
      
  if "Менеджер акаунтов" == message.text:
      Bot.send_message(message.chat.id, 'Ваш текущий ник: '+ 'Ander_kot',reply_markup= Nick_Name_menu_markup)
      Bot.register_next_step_handler(message,NickNameMenu)

# Создание заказа в QIWI API
url = "https://api.qiwi.com/partner/bill/v1/bills/"+str(order_ID)
end_datetime = datetime.date.today() + datetime.timedelta(1) # Дата и время когда QIWI поститает заказ просроченым
# Заголовок
headers_API = CaseInsensitiveDict()
headers_API["content-type"] = "application/json"
headers_API["accept"] = "application/json"
headers_API["Authorization"] = "Bearer " + api_secret_token # Ваш P2P кльч https://qiwi.com/p2p-admin/api
# Данные
post_json = {"amount": {"currency": "RUB","value": ""},"comment": "","expirationDateTime": "","customer": {"phone": "","email": "","account": ""},"customFields" : {"paySourcesFilter":"","themeCode": "","yourParam1": "","yourParam2": ""}}
post_json["amount"]["value"] = amount_str
post_json["comment"] = comment+': '+str(nick_name)
post_json["expirationDateTime"] = str(end_datetime.isoformat())+'T12:00:00+03:00'
post_json["customer"]["account"] = str(nick_name)
# Запрос
respons = requests.put(url, headers=headers_API, json=post_json)
if respons.ok:
  # Получение ссылки на оплату
  respons_Json = respons.json()
  url = str(respons_Json['payUrl'])
  print(url)
  return {'successfully':True, 'data':url}
else:
  return {'successfully':False, 'data':''}

# Перевод на стим
def Send_To_Steam(api_access_token, nickName, amount_KZT, order_ID):
    amount_KZT_str = str(amount_KZT)
    url = "https://edge.qiwi.com/sinap/api/v2/terms/31212/payments"
    # Заголовок
    headers_API = CaseInsensitiveDict()
    headers_API["content-type"] = "application/json"
    headers_API["accept"] = "application/json"
    headers_API["Authorization"] = "Bearer " + api_access_token
    # Данные
    json_API = {"id":"","sum": {"amount":"","currency":"398"},"paymentMethod": {"type":"Account","accountId":"398"},"fields": {"account":""}}
    json_API['id'] = str(order_ID)
    json_API['sum']['amount'] = amount_KZT_str
    json_API['fields']['account'] = nickName
    # Запрос
    respons = requests.post(url, headers=headers_API, json=json_API)
    if respons.ok:
        return {'successfully':True, 'data':''}
    else:
        return {'successfully':False, 'data':respons.text} # тест ошибки

# Подключение к серверу SQL --
def Create_SQL_connection(host_name, user_name, user_password, db_name):
    connection = None
    try:
        connection = mysql.connector.connect(
            host=host_name,
            user=user_name,
            passwd=user_password,
            database=db_name    
        )
    except Error as e:
        print(f"Ошибка подключения к MySQL '{e}'")
    return connection

# Отправка запроса SQL
def execute_query(query, tip='не определено'):
    connection = Create_SQL_connection(SQLHostName,SQLUserName,SQLRassword,SQLBaseName)
    cursor = connection.cursor()
    try:
        cursor.execute(query)
        result = cursor.fetchall()
        connection.commit()
        print('Запрос на '+tip+' отправлен')
        return {'successfully':True, 'data':result}
    except Error as e:
        print(f"Ошибка в запросе '{e}'")
        return {'successfully':False, 'data':''}
  
# Создание заказа  
def Create_order(api_secret_token, amount, comment, nick_name):
    datetime_str = str(datetime.datetime.today().replace(microsecond=0).isoformat())
    print(datetime_str)
    print(api_secret_token)
    # Запрос коммиссии
    respons_SQL = Get_Commission()
    if respons_SQL['successfully'] and respons_SQL['data']:
      # Расчет стоимости заказа
      commission = respons_SQL['data']
      amount_decimal = Decimal(amount)
      commission_decimal = Decimal(commission)/Decimal(100)+Decimal(1)
      amount_str = str(round(amount_decimal*commission_decimal,2))
      # Создание заказа в QSL
      query = "SELECT MAX(No) FROM orders;"
      respons_SQL = execute_query(query,'Сбор ID заказа')
      order_ID = respons_SQL['data'][0][0]+5 # отстум в 5 ID из-за того самого "прикола"
      query = "INSERT INTO orders(No,NickName,RU,CreateDateTime) VALUES ("+str(order_ID)+",'"+nick_name+"',"+amount_str+",'"+datetime_str+"');"
      respons_SQL = execute_query(query,'Создание pаказа для '+nick_name)
      return respons_SQL
    else:
      return {'successfully':False, 'data':''}  
    
# Добавить Url к заказу
def Add_URL(order_URL,order_ID):
    order_ID_str = str(order_ID)
    query = "UPDATE orders SET Url = '"+order_URL+"' WHERE No = "+order_ID_str+";"
    respons_SQL = execute_query(query,'Установка URL заказу '+str(order_ID)+': '+str(order_URL))
    if respons_SQL['successfully']:
        return {'successfully':True, 'data':''}
    else:
        return {'successfully':False, 'data':''}

# Обновление статуса заказа
def Check_Oreder(api_secret_token, order_ID):
    # API ---
    url = "https://api.qiwi.com/partner/bill/v1/bills/"+str(order_ID)
    headers_API = CaseInsensitiveDict()
    headers_API["content-type"] = "application/json"
    headers_API["accept"] = "application/json"
    headers_API["Authorization"] = "Bearer " + api_secret_token
    respons = requests.get(url, headers=headers_API)
    if respons.ok:
        respons_Json = respons.json()
        status = str(respons_Json['status']['value'])
        # SQL ---
        query = "UPDATE orders SET Status = '"+status+"' WHERE No = '"+str(order_ID)+"';"
        if execute_query(query,'Обновление pаказа '+status+'|'+str(order_ID)):
            return {'successfully':True, 'data':status}
        else:
            return {'successfully':False, 'data':''}
    return {'successfully':False, 'data':''}

# Пользователь нажал на "Создать ссылку на пополнение Steam"
# Предыдущий обработчик попросил пользователя ввечсти желаемую сумму и перевел управление сюда
def createpayment(message):
    # Возврат в главное меню
    if("Назад" == message.text):
        Bot.send_message(message.chat.id, 'Выберите действие',reply_markup= Main_menu_markup)
        Bot.register_next_step_handler(message,main)
    else:   
        # Проверка на "число"
        if message.text.isdigit():
            amount_Dec = round(Decimal(message.text),2)
            # Для перевода на стим есть минимальный лимит
            # Если пользователь попытается сделать заказ меньше он просто не пройдет
            # Поэтму заранее отсекаем такие заказы
            if amount_Dec >= round(Decimal('85'),2):
                # Если введенная сумма верна создаем заказ, это может занять время
                # Оповещаем пользователя что процесс пошел
                Bot.send_message(message.chat.id, 'Создание ссылки для оплаты')
                # Получаем целевой ник Steam
                respons_SQL = QIWI_API.Check_Customer(message.chat.id)
                if respons_SQL['successfully'] and respons_SQL['data']:
                    nick_name = respons_SQL['data'][0][0]
                    # Создаем заказ
                    respons_SQL = QIWI_API.Create_order( QIWI_API.SecretKey,message.text,'Account replenishment',nick_name)
                    if respons_SQL['successfully'] and respons_SQL['data']:
                        # Если все Ок отдаем ссылку пользователю и возвращаем к меню, где он может проверить статус заказа
                        order_URL = respons_SQL['data']
                        Bot.send_message(message.chat.id, 'После оплаты нажмите на "Подтвердить статус оплаты"\nВаша ссылка для оплаты:\n'+order_URL,reply_markup= Main_menu_markup)
                        Bot.register_next_step_handler(message,main)
                    else:
                        print('У клиента ошибка ! '+str(message.chat.id)+'\nСсылка на заказ не создана')
                        Bot.send_message(message.chat.id, 'Ошибка!\nСсылка не создана\nПовторите попытку или свяжитесь с подержкой!\nhttps://t.me/ander_kot_1',reply_markup= Main_menu_markup)
                        Bot.register_next_step_handler(message,main)
                else:
                    print('У клиента ошибка ! '+str(message.chat.id)+'\nНе найден ник при создании заказа')
                    Bot.send_message(message.chat.id, 'Ошибка!\nВаш ник не найден\nПовторите попытку или свяжитесь с подержкой!\nhttps://t.me/ander_kot_1',reply_markup = Main_menu_markup)
                    Bot.register_next_step_handler(message,main)
            else:
                Bot.send_message(message.chat.id, 'Платеж должен составлять минимум 85 (требование QIWI)',reply_markup = Order_menu_markup)
                Bot.register_next_step_handler(message,createpayment)
        else:
            Bot.send_message(message.chat.id, 'Используйте только цифры',reply_markup = Order_menu_markup)
            Bot.register_next_step_handler(message,createpayment)