|
@@ -27,15 +27,16 @@ PASSWORD=hashlib.md5((botname+config.PASSWORD).encode('utf-8')).hexdigest()
|
|
|
print(JID, PASSWORD)
|
|
|
|
|
|
#таким образом хранится список jid, от которых можно получать сообщения этому боту
|
|
|
-listen_to=["test@msg.sharix-app.org", "test1@msg.sharix-app.org"]
|
|
|
+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@msg.sharix-app.org", "test1@msg.sharix-app.org"]
|
|
|
+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
|
|
@@ -48,35 +49,34 @@ def message_handler(conn, mess):
|
|
|
}
|
|
|
}
|
|
|
"""
|
|
|
- userObj = jsreq.jsonToUser(text)
|
|
|
- print(userObj.name)
|
|
|
- print(userObj.address.street)
|
|
|
#HTTP запрос
|
|
|
- jsreq.requestGetListUser()
|
|
|
- #нужна проверка, данный обработчик вообще должен от данного отправителя получать сообщения или нет. Подсказка ниже
|
|
|
+ #jsreq.requestGetListUser()
|
|
|
+
|
|
|
+ #нужна проверка, данный обработчик вообще должен от данного отправителя получать сообщения или нет. Подсказка ниже
|
|
|
+ print (user)
|
|
|
if user in listen_to:
|
|
|
print(text)
|
|
|
print(mess)
|
|
|
|
|
|
if text is not None:
|
|
|
- message = xmpp.Message()
|
|
|
-
|
|
|
- tasklist.append(message)
|
|
|
- bot.bot_log(" ".join(str(datetime.now()), str(i), "Заказ успешно добавлен в очередь обработки"))
|
|
|
-
|
|
|
+ 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) + " " + "Заказ в очереди на обработке")
|
|
|
+ bot.bot_log(botname + " " + datetime.now().strftime('%Y-%m-%d') + " " + str(i) + " " + "Заказ в очереди на обработке\n")
|
|
|
+ print ("TASKLIST", tasklist[i])
|
|
|
if tasklist[i]:
|
|
|
- proceed_status("test@msg.sharix-app.org"+" "+tasklist[i])
|
|
|
- del tasklist[i]
|
|
|
- bot.bot_log(botname+" "+str(datetime.now())+" "+str(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)+" "+"Заказ оставлен в очереди")
|
|
|
+ bot.bot_log(botname+" "+str(datetime.now())+" "+str(i)+" "+"Заказ оставлен в очереди\n")
|
|
|
|
|
|
#Авторизация и запуск бота
|
|
|
|