|
@@ -16,7 +16,7 @@ import jsonAndRequest as jsreq
|
|
|
|
|
|
global tasklist
|
|
global tasklist
|
|
|
|
|
|
-botname="open_servicerequest_accepted"
|
|
|
|
|
|
+botname="open_service_request_accepted"
|
|
|
|
|
|
operating_status='221'
|
|
operating_status='221'
|
|
JID=botname+"@"+config.JSERVER
|
|
JID=botname+"@"+config.JSERVER
|
|
@@ -27,10 +27,10 @@ PASSWORD=hashlib.md5((botname+config.PASSWORD).encode('utf-8')).hexdigest()
|
|
print(JID, PASSWORD)
|
|
print(JID, PASSWORD)
|
|
|
|
|
|
#таким образом хранится список jid, от которых можно получать сообщения этому боту
|
|
#таким образом хранится список jid, от которых можно получать сообщения этому боту
|
|
-listen_to=["open_servicerequest_assigned@ej.sharix-app.org"]
|
|
|
|
|
|
+listen_to=["open_service_request_assigned@ej.sharix-app.org"]
|
|
|
|
|
|
#тут хранится список jid, кому бот может отправлять сообщения в результате обработки заявки
|
|
#тут хранится список jid, кому бот может отправлять сообщения в результате обработки заявки
|
|
-proceed_to=[botname,"open_servicerequest_process@ej.sharix-app.org", "open_servicerequest_declined@ej.sharix-app.org", "open_servicerequest_forcemajeure@ej.sharix-app.org"]
|
|
|
|
|
|
+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
|
|
idle_value=10
|
|
@@ -54,7 +54,7 @@ def message_handler(conn, mess):
|
|
tasklist.append(orderObj)
|
|
tasklist.append(orderObj)
|
|
bot.bot_log(str(datetime.now())+" Поступивший заказ успешно добавлен в очередь обработки\n")
|
|
bot.bot_log(str(datetime.now())+" Поступивший заказ успешно добавлен в очередь обработки\n")
|
|
|
|
|
|
-def open_servicerequest_accepted_wait(period,localtask):
|
|
|
|
|
|
+def open_service_request_accepted_wait(period,localtask):
|
|
bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ ожидает\n")
|
|
bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ ожидает\n")
|
|
time.sleep(period)
|
|
time.sleep(period)
|
|
|
|
|
|
@@ -65,7 +65,7 @@ def open_servicerequest_accepted_wait(period,localtask):
|
|
bot.proceed_status(proceed_to[0],localtask)
|
|
bot.proceed_status(proceed_to[0],localtask)
|
|
bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ подождал и отправлен в очередь\n")
|
|
bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ подождал и отправлен в очередь\n")
|
|
|
|
|
|
-def open_servicerequest_accepted_process(localtask):
|
|
|
|
|
|
+def open_service_request_accepted_process(localtask):
|
|
bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ в обработчике\n")
|
|
bot.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ в обработчике\n")
|
|
|
|
|
|
# order = jsreq.jsonToOrder(localtask)
|
|
# order = jsreq.jsonToOrder(localtask)
|
|
@@ -113,13 +113,13 @@ def open_servicerequest_accepted_process(localtask):
|
|
# bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
|
|
# bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
|
|
# else:
|
|
# else:
|
|
# #Заглушка. Заказ ждет очередную итерацию обработки списка
|
|
# #Заглушка. Заказ ждет очередную итерацию обработки списка
|
|
- # open_servicerequest_accepted_process(localtask)
|
|
|
|
|
|
+ # open_service_request_accepted_process(localtask)
|
|
# else:
|
|
# else:
|
|
# bot.proceed_status(proceed_to[1],localtask)
|
|
# bot.proceed_status(proceed_to[1],localtask)
|
|
# bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
|
|
# bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ отправлен\n")
|
|
# else:
|
|
# else:
|
|
# #Заглушка. Заказ ждет очередную итерацию обработки списка
|
|
# #Заглушка. Заказ ждет очередную итерацию обработки списка
|
|
- # open_servicerequest_accepted_process(localtask)
|
|
|
|
|
|
+ # open_service_request_accepted_process(localtask)
|
|
# pass
|
|
# pass
|
|
|
|
|
|
|
|
|
|
@@ -130,7 +130,7 @@ def send_message():
|
|
def create_ticket():
|
|
def create_ticket():
|
|
pass
|
|
pass
|
|
|
|
|
|
-def open_servicerequest_accepted():
|
|
|
|
|
|
+def open_service_request_accepted():
|
|
log_thread = threading.Thread(target=log_handler)
|
|
log_thread = threading.Thread(target=log_handler)
|
|
log_thread.daemon = True
|
|
log_thread.daemon = True
|
|
log_thread.start()
|
|
log_thread.start()
|
|
@@ -146,14 +146,14 @@ def open_servicerequest_accepted():
|
|
bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ не по адресу, перенаправляем на форсмажор\n")
|
|
bot.bot_log(botname+" "+str(datetime.now())+" "+"Заказ не по адресу, перенаправляем на форсмажор\n")
|
|
continue
|
|
continue
|
|
elif True:
|
|
elif True:
|
|
- t1=threading.Thread(target=open_servicerequest_accepted_process, args=([localtask]))
|
|
|
|
|
|
+ t1=threading.Thread(target=open_service_request_accepted_process, args=([localtask]))
|
|
t1.start()
|
|
t1.start()
|
|
# if (localtask.title!="10"):
|
|
# if (localtask.title!="10"):
|
|
- # t1=threading.Thread(target=open_servicerequest_booked_wait, args=(5,localtask))
|
|
|
|
|
|
+ # t1=threading.Thread(target=open_service_request_booked_wait, args=(5,localtask))
|
|
# t1.start()
|
|
# t1.start()
|
|
|
|
|
|
# if (localtask.title=="101"):
|
|
# if (localtask.title=="101"):
|
|
- # t1=threading.Thread(target=open_servicerequest_booked_process, args=(10,localtask))
|
|
|
|
|
|
+ # t1=threading.Thread(target=open_service_request_booked_process, args=(10,localtask))
|
|
# t1.start()
|
|
# t1.start()
|
|
|
|
|
|
|
|
|
|
@@ -176,4 +176,4 @@ tasklist_dbsynce=jsreq.requestGetList(token, config.API_URL+"/dbsynce/api/orders
|
|
bot = JabberBot(JID, PASSWORD, PORT)
|
|
bot = JabberBot(JID, PASSWORD, PORT)
|
|
|
|
|
|
bot.register_handler('message', message_handler)
|
|
bot.register_handler('message', message_handler)
|
|
-bot.start(open_servicerequest_accepted)
|
|
|
|
|
|
+bot.start(open_service_request_accepted)
|