浏览代码

running schema improvements

mex3 1 年之前
父节点
当前提交
c037726e96
共有 3 个文件被更改,包括 15 次插入60 次删除
  1. 3 2
      BotClass.py
  2. 6 10
      botrun.py
  3. 6 48
      open-st_request-assigned.py

+ 3 - 2
BotClass.py

@@ -30,9 +30,10 @@ class JabberBot:
         return 1
 
 #сюда можно как параметры передавать переменную для значения Process в вызываемой функции, а также передавать информацию о том, какой из обработчиков ввызывать в бесконечном цикле
-    def start(self):
+    def start(self, handler):
         self.conn.sendInitPresence()#статус аккаунта бота (активен или нет)
         print("Bot started!")
         while self.step_on():
-#тут, по идее, надо размещать проверку элементов списка
+#это вызов конкретной функции для обработки статуса конкретным ботом
+		handler()
 		pass

+ 6 - 10
botrun.py

@@ -3,7 +3,8 @@ from xmpp import cli
 import config
 from BotClass import JabberBot
 import json
-import botrun
+
+#В этом файле описаны функции, необходимые для запуска любого произвольного бота-обработчика заявок/статусов
 
 # загрузка json файла
 def read_inf(file_name):
@@ -46,20 +47,15 @@ def message_handler(conn, mess):
 def simple_send_message():
     cli.send_message(config.JID, config.PASSWORD, "test@msg.sharix-app.org", "request.data") 
 
-# recipient - это конкретный jid следующего обработчика заявки, ticket - json с заявкой
-def proceed_status(recipient, ticket):
-    cli.send_message(config.JID, config.PASSWORD, recipient, ticket) 
+# recipient - это конкретный jid следующего обработчика заявки, ticket - json с заявкой.
+#С помощью sender мы отвязываемся от конфига на каждого обработчика и даем возможность для реализации новой схемы
+def proceed_status(recipient, ticket, sender=config.JID):
+    cli.send_message(sender, config.PASSWORD, recipient, ticket) 
 
 # в message помещается смысл и сам вызов API, который должен быть, но которого нет, а также хорошо туда добавить номер заказа (взять из json) и название бота
 # скорее всего эту функцию и подобные надо будет перенести в отдельный класс или библиотеку
 def fake_api_call(message):
     cli.send_message(config.JID, config.PASSWORD, "test@msg.sharix-app.org", message) 
 
-def open-st_request-assigned():
-    print("Тут описывается работа со списком задач в данном статусе")
 
-#Авторизация и запуск бота
-bot = JabberBot(config.JID, config.PASSWORD)
-bot.register_handler('message', message_handler)
-bot.start(open-st_request-assigned)
 

+ 6 - 48
open-st_request-assigned.py

@@ -3,57 +3,15 @@ from xmpp import cli
 import config
 from BotClass import JabberBot
 import json
+import botrun
 
-# загрузка json файла
-def read_inf(file_name):
-    with open(file_name, 'r', encoding="utf-8") as file:
-        return json.load(file)
+#В этом файле содержится только то, что запускает конкретный обработчик
 
-
-# обработчик входящих сообщений
-def message_handler(conn, mess):
-    text = mess.getBody()#текст сообщения боту
-    user = mess.getFrom()#отправитель сообщения
-#работа с файлом в таком виде для входящей информации не нужна, так как бот должен обрабатывать входящие сообщения, а не файлы на сервере, и не сохраняет входящие сообщения в файлы. Он должен входящее сообщение поместить в очередь (список) на обработку.
-# При запуске бота он инициализирует пустой список, далее делает запрос к API для выгрузки в него всех заявок с его статусом для обработки и все элементы (если они есть) добавляет с помощью append в список.
-#При получении сообщения от кого-нибудь он также делает в список append
-#Каждлый пустой (не существующий) вызов API описывается как fake_api_call
-#Элемент списка удаляется, если с момента timestamp внутри json прошло больше 1 часа (соответственно json должен быть такого вида, что эта информация там есть)
-    applications = read_inf("applications.json")
-    print(text)
-    print(mess)
-
-    if text is not None:
-        message = xmpp.Message()
-        applications = read_inf("applications.json")
-
-        #если бот получает сообщение, соответсвующее значению id("1","2","3")
-        #он отправит описание desc этого определенного объекта 
-        for app in applications["applications"]:
-            if app.get("id") == text:
-                message.setBody(app.get("desc"))
-
-        # если бот получает сообщение, он отправляет такое же сообщение отправителю
-        # message.setBody(text)
-        message.setFrom(config.JID)
-        message.setTo(user)
-        message.setType('chat')
-        
-        conn.send(message)
-
-# пример функции, которую можно вызвать из любой части кода для отправки сообщения от бота пользователю
-def simple_send_message():
-    cli.send_message(config.JID, config.PASSWORD, "test@msg.sharix-app.org", "request.data") 
-
-# recipient - это конкретный jid следующего обработчика заявки, ticket - json с заявкой
-def proceed_status(recipient, ticket):
-    cli.send_message(config.JID, config.PASSWORD, recipient, ticket) 
-
-# в message помещается смысл и сам вызов API, который должен быть, но которого нет, а также хорошо туда добавить номер заказа (взять из json) и название бота
-def fake_api_call(message):
-    cli.send_message(config.JID, config.PASSWORD, "test@msg.sharix-app.org", message) 
+def open-st_request-assigned():
+    print("Тут описывается работа со списком задач в данном статусе")
 
 #Авторизация и запуск бота
 bot = JabberBot(config.JID, config.PASSWORD)
 bot.register_handler('message', message_handler)
-bot.start()
+bot.start(open-st_request-assigned)
+