open_negrequest_pending.py 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  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. import time
  10. import threading
  11. #test
  12. import jsonAndRequest as jsreq
  13. global tasklist
  14. #В этом файле содержится только то, что запускает конкретный обработчик
  15. # botname="open_strequest_assigned"
  16. botname="open_negrequest_pending"
  17. operating_status=420
  18. JID=botname+"@"+config.JSERVER
  19. PORT=config.PORT
  20. #раскомментировать, когда перейдем на разные пароли
  21. PASSWORD=hashlib.md5((botname+config.PASSWORD).encode('utf-8')).hexdigest()
  22. print(JID, PASSWORD)
  23. #таким образом хранится список jid, от которых можно получать сообщения этому боту
  24. listen_to=["open_negrequest_pending@ej.sharix-app.org"]
  25. #тут хранится список jid, кому бот может отправлять сообщения в результате обработки заявки
  26. proceed_to=["open_negrequest_pending@ej.sharix-app.org", "open_negrequest_declined@ej.sharix-app.org"]
  27. #максимальное значение попыток обработать заказ
  28. idle_value=10
  29. # обработчик входящих сообщений
  30. def message_handler(conn, mess):
  31. text = mess.getBody()#текст сообщения боту
  32. user = mess.getFrom()#отправитель сообщения
  33. #user = mess.getNode()#только jid
  34. #нужна проверка, данный обработчик вообще должен от данного отправителя получать сообщения или нет. Подсказка ниже
  35. print (str(user).split("/")[0])
  36. if (str(user).split("/")[0]) in listen_to:
  37. print(text)
  38. print(mess)
  39. if text is not None:
  40. orderObj = jsreq.jsonToOrderTicket(text)
  41. print (orderObj)
  42. tasklist.append(orderObj)
  43. bot.bot_log(str(datetime.now())+" Поступивший заказ успешно добавлен в очередь обработки\n")
  44. #TODO - для обработчиков Ticket скорее надо будет функции вынести в отдельную библиотеку, они типовые же
  45. def pending_wait(period,localtask):
  46. bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ ожидает пользовательской реакции\n")
  47. time.sleep(period)
  48. #ВАЖНО! НАДО ВСТАВИТЬ ИЗМЕНЕНИЕ СТАТУСА ЧЕРЕЗ API
  49. #обязательно данный обработчик должен заканчиваться передачей заказа куда-то на обработку дальше - обратно или другому, иначе оно потеряется
  50. bot.proceed_status(proceed_to[1],localtask)
  51. bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отклонен\n")
  52. def open_negrequest_pending():
  53. #print("Тут описывается работа со списком задач в данном статусе")
  54. while (len(tasklist)):
  55. localtask=tasklist.pop(0)
  56. bot.bot_log(botname + " " + datetime.now().strftime('%Y-%m-%d') + " "+ "Заказ в очереди на обработке\n")
  57. #если боту почему-то пришла не его заявка - это явно ошибка движения процессов и отдаем в форсмажор - этот обработчик указывать стоит всегда последним
  58. #if (localtask.status!=operating_status):
  59. # bot.proceed_status(proceed_to[-1],localtask)
  60. # bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ не по адресу, перенаправляем на форсмажор\n")
  61. # continue
  62. #TODO: send_notifications - изучить как в комнату
  63. #ЖДАТЬ НАДО ПОДОЛЬШЕ
  64. t1=threading.Thread(target=pending_wait, args=(100,localtask))
  65. t1.start()
  66. #если никакие обработчики не подошли - отправляем обратно в очередь
  67. #bot.proceed_status(proceed_to[0],localtask)
  68. #print("Заказ возвращен в очередь\n")
  69. #print (tasklist)
  70. #Авторизация и запуск бота
  71. #пустой список заказов
  72. tasklist = []
  73. #надо инициализировать tasklist при запуске из API
  74. token = jsreq.requestGetToken(botname, PASSWORD, config.API_URL+"/auth/token/login/")
  75. #ВАЖНО! Надо еще фильтровать список по статусу обработки заявки
  76. tasklist=jsreq.requestGetList(token, config.API_URL+"/tickets/api/tickets/?list_id=10")
  77. print (len(tasklist))
  78. bot = JabberBot(JID, PASSWORD, PORT)
  79. bot.register_handler('message', message_handler)
  80. bot.start(open_negrequest_pending)