open_template_bot.py 3.2 KB

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