1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495 |
- import xmpp
- from xmpp import cli
- import config
- from BotClass import JabberBot
- import json
- #раскомментировать, когда перейдем на разные пароли
- import hashlib
- from datetime import datetime
- #test
- import jsonAndRequest as jsreq
- #В этом файле содержится только то, что запускает конкретный обработчик
- # botname="open_strequest_assigned"
- botname="open_template_bot"
- #botname="test"
- JID=botname+"@"+config.JSERVER
- #JID=f"{botname}@msg.sharix-app.org"
- #PASSWORD=config.PASSWORD
- PORT=config.PORT
- #раскомментировать, когда перейдем на разные пароли
- PASSWORD=hashlib.md5((botname+config.PASSWORD).encode('utf-8')).hexdigest()
- #PASSWORD="test1234@"
- print(JID, PASSWORD)
- #таким образом хранится список jid, от которых можно получать сообщения этому боту
- listen_to=["test@ej.sharix-app.org", "test1@ej.sharix-app.org", "test@ej.sharix-app.org/converse.js-11058227", "test1"]
- #тут хранится список jid, кому бот может отправлять сообщения в результате обработки заявки
- process_to=["test@ej.sharix-app.org", "test1@ej.sharix-app.org"]
- # обработчик входящих сообщений
- def message_handler(conn, mess):
- text = mess.getBody()#текст сообщения боту
- user = mess.getFrom()#отправитель сообщения
- #user = mess.getNode()#только jid
- #example json to object user
- if text is not None:
- """ example json
- {
- "name":"Cristian",
- "address":
- {
- "street":"Sesame",
- "number":122
- }
- }
- """
- #HTTP запрос
- #jsreq.requestGetListUser()
-
- #нужна проверка, данный обработчик вообще должен от данного отправителя получать сообщения или нет. Подсказка ниже
- print (user)
- if user in listen_to:
- print(text)
- print(mess)
- if text is not None:
- orderObj = jsreq.jsonToUser(text)
- tasklist.append(orderObj)
- bot.bot_log(str(datetime.now())+" Поступивший заказ успешно добавлен в очередь обработки\n")
- def open_bot_template(tasklist):
- #print("Тут описывается работа со списком задач в данном статусе")
- for i in range(len(tasklist)):
- #проверяем элемент tasklist[i]
- bot.bot_log(botname + " " + datetime.now().strftime('%Y-%m-%d') + " " + str(i) + " " + "Заказ в очереди на обработке\n")
- print ("TASKLIST", tasklist[i])
- if tasklist[i]:
- bot.proceed_status("test1@ej.sharix-app.org",tasklist[i])
- #TODO - разобраться, почему оно вдруг становится tuple
- #tasklist.pop(i)
- bot.bot_log(botname+" "+str(datetime.now())+" "+str(i)+" "+"Заказ успешно обработан и удален из очереди\n")
- else:
- bot.bot_log(botname+" "+str(datetime.now())+" "+str(i)+" "+"Заказ оставлен в очереди\n")
- #Авторизация и запуск бота
- #пустой список заказов
- tasklist = []
- bot = JabberBot(JID, PASSWORD, PORT)
- #загружаем список заказов для обработки из базы (по идее, сюда попадаем в случае первого запуска или перезапуска)
- bot.fake_api_call("Получаем список заказов по названию бота-обработчика")
- bot.register_handler('message', message_handler)
- bot.start(open_bot_template, tasklist)
|