sharix-open-backend/handlers/open_servicerequest_accepted.py

import requests
import xmpp
from xmpp import cli
import config
from BotClass import JabberBot
import json
#раскомментировать, когда перейдем на разные пароли
import hashlib
from datetime import datetime

import time
import threading

#test
import jsonAndRequest as jsreq

global tasklist

botname="open_servicerequest_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=["test@ej.sharix-app.org", "open_template_bot@ej.sharix-app.org"]

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

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

# обработчик входящих сообщений
def message_handler(conn, mess):
    text = mess.getBody()#текст сообщения боту
    user = mess.getFrom()#отправитель сообщения
   
    print (str(user).split("/")[0])
    if (str(user).split("/")[0]) in listen_to:
        print(text)
        print(mess)

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

def open_servicerequest_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_servicerequest_accepted_process(localtask):
    bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ в обработчике\n")
    
    order = jsreq.jsonToOrder(localtask)

    if order.time_start_predicted < 100:
        # Заглушка. Проверка может ли заказ быть переназначен
        if True:
            # Заглушка. Сбросить пометку предзаказа
            # ...


            bot.proceed_status(proceed_to[2],localtask)
            bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
        else:
            bot.proceed_status(proceed_to[1],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_servicerequest_accepted_process(localtask)
            else:
                bot.proceed_status(proceed_to[1],localtask)
                bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
        else:
            #Заглушка. Заказ ждет очередную итерацию обработки списка
            open_servicerequest_accepted_process(localtask)
            pass
    

def send_message():
    pass

def create_ticket():
    pass

def open_servicerequest_accepted():
    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):
            bot.proceed_status(proceed_to[-1],localtask)
            bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ не по адресу, перенаправляем на форсмажор\n")
            continue

        # if (localtask.title!="10"):
        #     t1=threading.Thread(target=open_servicerequest_booked_wait, args=(5,localtask))
        #     t1.start()

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

        t1=threading.Thread(target=open_servicerequest_accepted_process, args=(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+"/auth/token/login/")

#ВАЖНО! Надо еще фильтровать список по статусу обработки заявки
tasklist=jsreq.requestGetList(token, config.API_URL+"/tickets/api/tickets/?list_id=10")
print (len(tasklist))

bot = JabberBot(JID, PASSWORD, PORT)

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