open-st_request-assigned.py 3.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. import xmpp
  2. from xmpp import cli
  3. import config
  4. from BotClass import JabberBot
  5. import json
  6. import botrun
  7. #раскомментировать, когда перейдем на разные пароли
  8. import hashlib
  9. from datetime import datetime
  10. #В этом файле содержится только то, что запускает конкретный обработчик
  11. botname="open-st_request-assigned"
  12. JID=botname+"@"+config.JSERVER
  13. PASSWORD=config.PASSWORD
  14. #раскомментировать, когда перейдем на разные пароли
  15. #PASSWORD=hashlib.md5((botname+config.PASSWORD).encode('utf-8')).hexdigest()
  16. #таким образом хранится список jid, от которых можно получать сообщения этому боту
  17. listen_to=["test@msg.sharix-app.org", "test1@msg.sharix-app.org"]
  18. #тут хранится список jid, кому бот может отправлять сообщения в результате обработки заявки
  19. process_to=["test@msg.sharix-app.org", "test1@msg.sharix-app.org"]
  20. # обработчик входящих сообщений
  21. def message_handler(conn, mess):
  22. text = mess.getBody()#текст сообщения боту
  23. user = mess.getFrom()#отправитель сообщения
  24. #нужна проверка, данный обработчик вообще должен от данного отправителя получать сообщения или нет. Подсказка ниже
  25. if user in listen_to:
  26. print(text)
  27. print(mess)
  28. if text is not None:
  29. message = xmpp.Message()
  30. tasklist.append(message)
  31. bot_log(" ".join(datetime.now(), i, "Заказ успешно добавлен в очередь обработки"))
  32. def open-st_request-assigned(tasklist):
  33. print("Тут описывается работа со списком задач в данном статусе")
  34. for i in range(len(tasklist)):
  35. #проверяем элемент tasklist[i]
  36. bot_log(" ".join(botname, datetime.now(), i, "Заказ в очереди на обработке"))
  37. if tasklist[i]:
  38. proceed_status("test@msg.sharix-app.org", tasklist[i])
  39. del tasklist[i]
  40. bot_log(" ".join(botname, datetime.now(), i, "Заказ успешно обработан и удален из очереди"))
  41. else:
  42. bot_log(" ".join(botname, datetime.now(), i, "Заказ оставлен в очереди"))
  43. #Авторизация и запуск бота
  44. #пустой список заказов
  45. tasklist = []
  46. bot = JabberBot(JID, PASSWORD)
  47. #загружаем список заказов для обработки из базы (по идее, сюда попадаем в случае первого запуска или перезапуска)
  48. fake_api_call("Получаем список заказов по названию бота-обработчика")
  49. bot.register_handler('message', message_handler)
  50. bot.start(open-st_request-assigned, tasklist)