|
@@ -0,0 +1,84 @@
|
|
|
|
+import json
|
|
|
|
+import requests
|
|
|
|
+import config
|
|
|
|
+from BotClass import JabberBot
|
|
|
|
+import hashlib
|
|
|
|
+from datetime import datetime
|
|
|
|
+import time
|
|
|
|
+import threading
|
|
|
|
+import jsonAndRequest as jsreq
|
|
|
|
+
|
|
|
|
+global ticketlist
|
|
|
|
+
|
|
|
|
+botname = "st_request_in_process"
|
|
|
|
+JID = botname + "@" + config.JSERVER
|
|
|
|
+PORT = config.PORT
|
|
|
|
+PASSWORD = hashlib.md5((botname + config.PASSWORD).encode('utf-8')).hexdigest()
|
|
|
|
+
|
|
|
|
+listen_to = ["st_request_wontfix@ej.sharix-app.org"]
|
|
|
|
+proceed_to = ["numbers"]
|
|
|
|
+
|
|
|
|
+# Новые параметры
|
|
|
|
+IS_INFINITE_REMINDER = False
|
|
|
|
+DEFAULT_REMINDER_INTERVAL = 30 * 60 # 30 минут в секундах
|
|
|
|
+MAX_REMINDERS = 3 # Максимальное количество напоминаний
|
|
|
|
+DEFAULT_CHECK_INTERVAL = 5 * 60 # Проверка тикетов каждые 5 минут
|
|
|
|
+
|
|
|
|
+tickets = {}
|
|
|
|
+
|
|
|
|
+def send_reminder(user, ticket):
|
|
|
|
+ message = f"Напоминание: необходимо принять решение по тикету {ticket.id}"
|
|
|
|
+
|
|
|
|
+ # Здесь должен быть код для отправки сообщения пользователю
|
|
|
|
+
|
|
|
|
+ bot.send_notification("st_request_in_process@ej.sharix-app.org", message)
|
|
|
|
+
|
|
|
|
+ print(f"Отправлено напоминание пользователю {user} о тикете {ticket.id}")
|
|
|
|
+
|
|
|
|
+def send_wontfix_notification(user, ticket):
|
|
|
|
+ message = f"Уведомление: тикет {ticket.id} был отмечен как WONTFIX из-за отсутствия действий"
|
|
|
|
+
|
|
|
|
+ # Здесь должен быть код для отправки сообщения пользователю
|
|
|
|
+
|
|
|
|
+ bot.send_notification("st_request_in_process@ej.sharix-app.org", message)
|
|
|
|
+
|
|
|
|
+ print(f"Отправлено уведомление пользователю {user} о WONTFIX для тикета {ticket.id}")
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+def process_in_progress_ticket(ticket_list, start_time):
|
|
|
|
+ tickets=jsreq.requestGetTicket_user(token, config.API_URL+f"tickets/api/ticket_list/{ticket.id}")
|
|
|
|
+ for ticket in tickets:
|
|
|
|
+ if ticket.status == 131:
|
|
|
|
+ if ticket.id in tickets:
|
|
|
|
+ tickets[ticket.id] = {
|
|
|
|
+ "reminders": 0,
|
|
|
|
+ "last_date_reminder": start_time
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if IS_INFINITE_REMINDER or tickets[ticket.id]['reminders'] < MAX_REMINDERS:
|
|
|
|
+ if (start_time - tickets[ticket.id]["last_date_reminder"]) > DEFAULT_REMINDER_INTERVAL:
|
|
|
|
+ send_reminder("st_request_in_process@ej.sharix-app.org", ticket)
|
|
|
|
+
|
|
|
|
+ tickets[ticket.id]["reminders"] += 1
|
|
|
|
+ tickets[ticket.id]["last_date_reminder"] += start_time
|
|
|
|
+ elif not IS_INFINITE_REMINDER and tickets[ticket.id]['reminders'] >= MAX_REMINDERS:
|
|
|
|
+ del tickets[ticket.id]
|
|
|
|
+ # Функция смены статуса на WONTFIX
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+def status_changer():
|
|
|
|
+ while True:
|
|
|
|
+ ticketlists = jsreq.requestGetList(token, config.API_URL + "tickets/api/ticket_list/")
|
|
|
|
+ for ticketlist in ticketlists:
|
|
|
|
+ start_time = datetime.now()
|
|
|
|
+ bot.bot_log(f"{botname} {start_time.strftime('%Y-%m-%d')} Тикет {ticket.id} в обработке\n")
|
|
|
|
+ t1 = threading.Thread(target=process_in_progress_ticket, args=(ticketlist, start_time))
|
|
|
|
+ t1.start()
|
|
|
|
+ t1.join() # Ожидаем завершения обработки тикета
|
|
|
|
+ time.sleep(DEFAULT_CHECK_INTERVAL)
|
|
|
|
+
|
|
|
|
+# Инициализация и запуск бота
|
|
|
|
+token = jsreq.requestGetToken(config.API_URL + "api/v1/auth/token/login/")
|
|
|
|
+bot = JabberBot(JID, PASSWORD, PORT)
|
|
|
|
+bot.start(status_changer)
|