sharix-open-webservice-running/handlers/open_service_request_accepted.py

# раскомментировать, когда перейдем на разные пароли
import hashlib
import threading
import time
from datetime import datetime

import config
# test
import jsonAndRequest as jsreq
from BotClass import JabberBot

global tasklist

botname = "open_service_request_accepted"

operating_status = '221'
JID = botname + "@" + config.JSERVER
PORT = config.PORT

PASSWORD = hashlib.md5((botname + config.PASSWORD).encode('utf-8')).hexdigest()

print(JID, PASSWORD)

# таким образом хранится список jid, от которых можно получать сообщения этому боту
listen_to = ["open_service_request_assigned@ej.sharix-app.org"]

# тут хранится список jid, кому бот может отправлять сообщения в результате обработки заявки
proceed_to = [botname, "open_service_request_process@ej.sharix-app.org",
              "open_service_request_declined@ej.sharix-app.org", "open_service_request_forcemajeure@ej.sharix-app.org"]

# максимальное значение попыток обработать заказ
idle_value = 10


def log_handler():
    while True:
        with open(f'{botname}.txt', 'a') as log_file:
            log_file.write(f"{time.strftime('%Y-%m-%d %H:%M:%S')} - {botname} is still running...\n")
        time.sleep(3600)


# обработчик входящих сообщений
def message_handler(conn, mess):
    text = mess.getBody()  # текст сообщения боту
    user = mess.getFrom()  # отправитель сообщения

    if (str(user).split("/")[0]) in listen_to:
        if text is not None:
            orderObj = jsreq.jsonToOrder(text)
            tasklist.append(orderObj)
            bot.bot_log(str(datetime.now()) + " Поступивший заказ успешно добавлен в очередь обработки\n")


def open_service_request_accepted_wait(period, localtask):
    bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ ожидает\n")
    time.sleep(period)

    # ВАЖНО! Надо скорее всего через API редактировать заказ, иначе возможна потеря данных
    localtask.title = localtask.title + "1"

    # обязательно данный обработчик должен заканчиваться передачей заказа куда-то на обработку дальше - обратно или другому, иначе оно потеряется
    bot.proceed_status(proceed_to[0], localtask)
    bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ подождал и отправлен в очередь\n")


def open_service_request_accepted_process(localtask):
    bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ в обработчике\n")

    # order = jsreq.jsonToOrder(localtask)
    localtask.status = '231'
    jsreq.change_to_task(localtask, token)
    bot.proceed_status(proceed_to[1], localtask)
    bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ отправлен\n")
    # if order.time_start_predicted < 100:
    #     # Заглушка. Проверка может ли заказ быть переназначен
    #     if True:
    #         # Заглушка. Сбросить пометку предзаказа
    #         # ...

    #         bot.proceed_status(proceed_to[1],localtask)
    #         bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
    #     else:
    #         bot.proceed_status(proceed_to[2],localtask)
    #         bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
    # else:
    #     # Заглушка. Обработана заявка на устанавление взаимоотношений?
    #     if True:
    #         # Заглушка. Взаимоотношения установлены ?
    #         if True:
    #             # Заглушка. Отобразить в предварительных заказах исполнителям.
    #             send_message()
    #             # Заглушка. Исполнитель откликнулся на заказ?
    #             if True:
    #                 # У пользователя стоит ручной выбор из нескольких исполнителей?
    #                 if True:
    #                     # Заглушка создать дочернюю локальную заявку с информацией от исполнителя
    #                     create_ticket()
    #                     # Заглушка отобразить в предварительных клиенту
    #                     send_message()

    #                     # Заглушка. Клиент выбрал конкретную заявку?
    #                     if True:
    #                         # Заглушка. обновление локальной копии. Замена основной
    #                         pass
    #                     else:
    #                         bot.proceed_status(proceed_to[3],localtask)
    #                         bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
    #                 else:
    #                     bot.proceed_status(proceed_to[3],localtask)
    #                     bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
    #             else:
    #                 #Заглушка. Заказ ждет очередную итерацию обработки списка
    #                 open_service_request_accepted_process(localtask)
    #         else:
    #             bot.proceed_status(proceed_to[1],localtask)
    #             bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
    #     else:
    #         #Заглушка. Заказ ждет очередную итерацию обработки списка
    #         open_service_request_accepted_process(localtask)
    #         pass


def send_message():
    pass


def create_ticket():
    pass


def open_service_request_accepted():
    log_thread = threading.Thread(target=log_handler)
    log_thread.daemon = True
    log_thread.start()
    while (len(tasklist)):
        localtask = tasklist.pop(0)
        bot.bot_log(botname + " " + datetime.now().strftime('%Y-%m-%d') + " " + "Заказ в очереди на обработке\n")
        print("EACH TASKLIST", tasklist)

        if (localtask.status != operating_status):
            localtask.status = 239
            jsreq.change_to_task(localtask, token)
            bot.proceed_status(proceed_to[-1], localtask)
            bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ не по адресу, перенаправляем на форсмажор\n")
            continue
        elif True:
            t1 = threading.Thread(target=open_service_request_accepted_process, args=([localtask]))
            t1.start()
        # if (localtask.title!="10"):
        #     t1=threading.Thread(target=open_service_request_booked_wait, args=(5,localtask))
        #     t1.start()

        # if (localtask.title=="101"):
        #     t1=threading.Thread(target=open_service_request_booked_process, args=(10,localtask))
        #     t1.start()

        # #если никакие обработчики не подошли - отправляем обратно в очередь
        # bot.proceed_status(proceed_to[0],localtask)
        # print("Заказ возвращен в очередь\n")
        # print(tasklist)


# Авторизация и запуск бота

# пустой список заказов
tasklist = []

# надо инициализировать tasklist при запуске из API
token = jsreq.requestGetToken(botname, PASSWORD, config.API_URL + "my/api/v1/auth/token/login/")
# ВАЖНО! Надо еще фильтровать список по статусу обработки заявки
tasklist_dbsynce = jsreq.requestGetList(token, config.API_URL + "/dbsynce/api/orders/")

bot = JabberBot(JID, PASSWORD, PORT)

bot.register_handler('message', message_handler)
bot.start(open_service_request_accepted)