open_template_bot.py 3.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  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. #test
  10. import jsonAndRequest as jsreq
  11. #В этом файле содержится только то, что запускает конкретный обработчик
  12. # botname="open_strequest_assigned"
  13. botname="open_template_bot"
  14. #botname="test"
  15. JID=botname+"@"+config.JSERVER
  16. #JID=f"{botname}@msg.sharix-app.org"
  17. #PASSWORD=config.PASSWORD
  18. PORT=config.PORT
  19. #раскомментировать, когда перейдем на разные пароли
  20. PASSWORD=hashlib.md5((botname+config.PASSWORD).encode('utf-8')).hexdigest()
  21. #PASSWORD="test1234@"
  22. print(JID, PASSWORD)
  23. #таким образом хранится список jid, от которых можно получать сообщения этому боту
  24. listen_to=["test@ej.sharix-app.org", "test1@ej.sharix-app.org", "test@ej.sharix-app.org/converse.js-11058227", "test1"]
  25. #тут хранится список jid, кому бот может отправлять сообщения в результате обработки заявки
  26. process_to=["test@ej.sharix-app.org", "test1@ej.sharix-app.org"]
  27. # обработчик входящих сообщений
  28. def message_handler(conn, mess):
  29. text = mess.getBody()#текст сообщения боту
  30. user = mess.getFrom()#отправитель сообщения
  31. #user = mess.getNode()#только jid
  32. #example json to object user
  33. if text is not None:
  34. """ example json
  35. {
  36. "name":"Cristian",
  37. "address":
  38. {
  39. "street":"Sesame",
  40. "number":122
  41. }
  42. }
  43. """
  44. #HTTP запрос
  45. #jsreq.requestGetListUser()
  46. #нужна проверка, данный обработчик вообще должен от данного отправителя получать сообщения или нет. Подсказка ниже
  47. print (user)
  48. if user in listen_to:
  49. print(text)
  50. print(mess)
  51. if text is not None:
  52. orderObj = jsreq.jsonToUser(text)
  53. tasklist.append(orderObj)
  54. bot.bot_log(str(datetime.now())+" Поступивший заказ успешно добавлен в очередь обработки\n")
  55. def open_bot_template(tasklist):
  56. #print("Тут описывается работа со списком задач в данном статусе")
  57. for i in range(len(tasklist)):
  58. #проверяем элемент tasklist[i]
  59. bot.bot_log(botname + " " + datetime.now().strftime('%Y-%m-%d') + " " + str(i) + " " + "Заказ в очереди на обработке\n")
  60. print ("TASKLIST", tasklist[i])
  61. if tasklist[i]:
  62. bot.proceed_status("test1@ej.sharix-app.org",tasklist[i])
  63. #TODO - разобраться, почему оно вдруг становится tuple
  64. #tasklist.pop(i)
  65. bot.bot_log(botname+" "+str(datetime.now())+" "+str(i)+" "+"Заказ успешно обработан и удален из очереди\n")
  66. else:
  67. bot.bot_log(botname+" "+str(datetime.now())+" "+str(i)+" "+"Заказ оставлен в очереди\n")
  68. #Авторизация и запуск бота
  69. #пустой список заказов
  70. tasklist = []
  71. bot = JabberBot(JID, PASSWORD, PORT)
  72. #загружаем список заказов для обработки из базы (по идее, сюда попадаем в случае первого запуска или перезапуска)
  73. bot.fake_api_call("Получаем список заказов по названию бота-обработчика")
  74. bot.register_handler('message', message_handler)
  75. bot.start(open_bot_template, tasklist)