open_template_bot.py 3.2 KB

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