123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123 |
- import hashlib
- import threading
- import time
- from datetime import datetime
- import config
- import jsonAndRequest as jsreq
- from BotClass import JabberBot
- global tasklist
- botname = "open_template_bot"
- operating_status = 210
- JID = botname + "@" + config.JSERVER
- PORT = config.PORT
- PASSWORD = hashlib.md5((botname + config.PASSWORD).encode('utf-8')).hexdigest()
- listen_to = ["test@ej.sharix-app.org", "open_template_bot@ej.sharix-app.org"]
- proceed_to = ["open_template_bot@ej.sharix-app.org", "test@ej.sharix-app.org", "test1@ej.sharix-app.org",
- "open_service_request_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_bot_template_wait(period, localtask):
- bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ ожидает\n")
- time.sleep(period)
-
- localtask.title = localtask.title + "1"
-
- bot.proceed_status(proceed_to[0], localtask)
- bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ подождал и возвращен в очередь\n")
- def open_bot_template_process(localtask):
- bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ в обработчике\n")
-
-
- bot.proceed_status(proceed_to[1], localtask)
- bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ успешно обработан\n")
- def open_bot_template():
-
- while (len(tasklist)):
-
-
-
- localtask = tasklist.pop(0)
- bot.bot_log(botname + " " + datetime.now().strftime('%Y-%m-%d') + " " + "Заказ в очереди на обработке\n")
-
-
-
-
- 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_bot_template_wait, args=(5, localtask))
- t1.start()
- if (localtask.title == "101"):
- t1 = threading.Thread(target=open_bot_template_process, args=(10, localtask))
- t1.start()
-
- bot.proceed_status(proceed_to[0], localtask)
- print("Заказ возвращен в очередь\n")
- print(tasklist)
- tasklist = []
- token = jsreq.requestGetToken(botname, PASSWORD, config.API_URL + "/base/auth/token/login/")
- tasklist = jsreq.requestGetList(token, config.API_URL + "/webservice/api/webservice/")
- print(JID, PASSWORD, PORT)
- bot = JabberBot(JID, PASSWORD, PORT)
- bot.register_handler('message', message_handler)
- bot.start(open_bot_template)
|