open_servicerequest_declined.py 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129
  1. import requests
  2. import xmpp
  3. from xmpp import cli
  4. import config
  5. from BotClass import JabberBot
  6. import json
  7. #раскомментировать, когда перейдем на разные пароли
  8. import hashlib
  9. from datetime import datetime
  10. import time
  11. import threading
  12. #test
  13. import jsonAndRequest as jsreq
  14. global tasklist
  15. botname="open_servicerequest_declined"
  16. operating_status=229
  17. JID=botname+"@"+config.JSERVER
  18. PORT=config.PORT
  19. PASSWORD=hashlib.md5((botname+config.PASSWORD).encode('utf-8')).hexdigest()
  20. print(JID, PASSWORD)
  21. #таким образом хранится список jid, от которых можно получать сообщения этому боту
  22. listen_to=["test@ej.sharix-app.org", "open_template_bot@ej.sharix-app.org"]
  23. #тут хранится список jid, кому бот может отправлять сообщения в результате обработки заявки
  24. proceed_to=[botname, "open_servicerequest_cancelled@ej.sharix-app.org", "open_servicerequest_booked@ej.sharix-app.org", "open_servicerequest_forcemajeure@ej.sharix-app.org"]
  25. #максимальное значение попыток обработать заказ
  26. idle_value=10
  27. # обработчик входящих сообщений
  28. def message_handler(conn, mess):
  29. text = mess.getBody()#текст сообщения боту
  30. user = mess.getFrom()#отправитель сообщения
  31. print (str(user).split("/")[0])
  32. if (str(user).split("/")[0]) in listen_to:
  33. print(text)
  34. print(mess)
  35. if text is not None:
  36. orderObj = jsreq.jsonToOrderTicket(text)
  37. print (orderObj)
  38. tasklist.append(orderObj)
  39. bot.bot_log(str(datetime.now())+" Поступивший заказ успешно добавлен в очередь обработки\n")
  40. def open_servicerequest_declined_wait(period,localtask):
  41. bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ ожидает\n")
  42. time.sleep(period)
  43. #ВАЖНО! Надо скорее всего через API редактировать заказ, иначе возможна потеря данных
  44. localtask.title=localtask.title+"1"
  45. #обязательно данный обработчик должен заканчиваться передачей заказа куда-то на обработку дальше - обратно или другому, иначе оно потеряется
  46. bot.proceed_status(proceed_to[0],localtask)
  47. bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ подождал и отправлен в очередь\n")
  48. def open_servicerequest_declined_process(localtask):
  49. bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ в обработчике\n")
  50. order = jsreq.jsonToOrder(localtask)
  51. # Заглушка с счетчиком
  52. # Заказ может быть выполнен другим
  53. if True:
  54. bot.proceed_status(proceed_to[1],localtask)
  55. bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
  56. else:
  57. # Заглушка. Сброс пометки что заказ на основного водителя
  58. bot.proceed_status(proceed_to[2],localtask)
  59. bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
  60. def send_message():
  61. pass
  62. def create_ticket():
  63. pass
  64. def open_servicerequest_declined():
  65. while (len(tasklist)):
  66. localtask=tasklist.pop(0)
  67. bot.bot_log(botname + " " + datetime.now().strftime('%Y-%m-%d') + " "+ "Заказ в очереди на обработке\n")
  68. print("EACH TASKLIST", tasklist)
  69. if (localtask.status!=operating_status):
  70. bot.proceed_status(proceed_to[-1],localtask)
  71. bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ не по адресу, перенаправляем на форсмажор\n")
  72. continue
  73. # if (localtask.title!="10"):
  74. # t1=threading.Thread(target=open_servicerequest_booked_wait, args=(5,localtask))
  75. # t1.start()
  76. # if (localtask.title=="101"):
  77. # t1=threading.Thread(target=open_servicerequest_booked_process, args=(10,localtask))
  78. # t1.start()
  79. t1=threading.Thread(target=open_servicerequest_declined_process, args=(localtask))
  80. t1.start()
  81. #если никакие обработчики не подошли - отправляем обратно в очередь
  82. bot.proceed_status(proceed_to[0],localtask)
  83. print("Заказ возвращен в очередь\n")
  84. print(tasklist)
  85. #Авторизация и запуск бота
  86. #пустой список заказов
  87. tasklist = []
  88. #надо инициализировать tasklist при запуске из API
  89. token = jsreq.requestGetToken(botname, PASSWORD, config.API_URL+"/auth/token/login/")
  90. #ВАЖНО! Надо еще фильтровать список по статусу обработки заявки
  91. tasklist=jsreq.requestGetList(token, config.API_URL+"/tickets/api/tickets/?list_id=10")
  92. print (len(tasklist))
  93. bot = JabberBot(JID, PASSWORD, PORT)
  94. bot.register_handler('message', message_handler)
  95. bot.start(open_servicerequest_declined)