botrun.py 4.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. import xmpp
  2. from xmpp import cli
  3. import config
  4. from BotClass import JabberBot
  5. import json
  6. import botrun
  7. # загрузка json файла
  8. def read_inf(file_name):
  9. with open(file_name, 'r', encoding="utf-8") as file:
  10. return json.load(file)
  11. # обработчик входящих сообщений
  12. def message_handler(conn, mess):
  13. text = mess.getBody()#текст сообщения боту
  14. user = mess.getFrom()#отправитель сообщения
  15. #работа с файлом в таком виде для входящей информации не нужна, так как бот должен обрабатывать входящие сообщения, а не файлы на сервере, и не сохраняет входящие сообщения в файлы. Он должен входящее сообщение поместить в очередь (список) на обработку.
  16. # При запуске бота он инициализирует пустой список, далее делает запрос к API для выгрузки в него всех заявок с его статусом для обработки и все элементы (если они есть) добавляет с помощью append в список.
  17. #При получении сообщения от кого-нибудь он также делает в список append
  18. #Каждлый пустой (не существующий) вызов API описывается как fake_api_call
  19. #Элемент списка удаляется, если с момента timestamp внутри json прошло больше 1 часа (соответственно json должен быть такого вида, что эта информация там есть)
  20. applications = read_inf("applications.json")
  21. print(text)
  22. print(mess)
  23. if text is not None:
  24. message = xmpp.Message()
  25. applications = read_inf("applications.json")
  26. #если бот получает сообщение, соответсвующее значению id("1","2","3")
  27. #он отправит описание desc этого определенного объекта
  28. for app in applications["applications"]:
  29. if app.get("id") == text:
  30. message.setBody(app.get("desc"))
  31. # если бот получает сообщение, он отправляет такое же сообщение отправителю
  32. # message.setBody(text)
  33. message.setFrom(config.JID)
  34. message.setTo(user)
  35. message.setType('chat')
  36. conn.send(message)
  37. # пример функции, которую можно вызвать из любой части кода для отправки сообщения от бота пользователю
  38. def simple_send_message():
  39. cli.send_message(config.JID, config.PASSWORD, "test@msg.sharix-app.org", "request.data")
  40. # recipient - это конкретный jid следующего обработчика заявки, ticket - json с заявкой
  41. def proceed_status(recipient, ticket):
  42. cli.send_message(config.JID, config.PASSWORD, recipient, ticket)
  43. # в message помещается смысл и сам вызов API, который должен быть, но которого нет, а также хорошо туда добавить номер заказа (взять из json) и название бота
  44. # скорее всего эту функцию и подобные надо будет перенести в отдельный класс или библиотеку
  45. def fake_api_call(message):
  46. cli.send_message(config.JID, config.PASSWORD, "test@msg.sharix-app.org", message)
  47. def open-st_request-assigned():
  48. print("Тут описывается работа со списком задач в данном статусе")
  49. #Авторизация и запуск бота
  50. bot = JabberBot(config.JID, config.PASSWORD)
  51. bot.register_handler('message', message_handler)
  52. bot.start(open-st_request-assigned)