123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051 |
- import json
- import time
- from datetime import datetime
- import xmpp
- import jsonAndRequest as jsreq
- def proceed_status(self, recipient, ticket):
-
- jsonTicket = json.dumps(ticket.__dict__)
- self.conn.send(xmpp.Message(recipient, jsonTicket))
- self.bot_log("Message sent successfully" + " " + recipient + " " + jsonTicket)
- def message_handler(self, 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)
- self.bot_log(str(datetime.now()) + " Поступивший заказ успешно добавлен в очередь обработки\n")
- def pending_wait(self, period, localtask, proceed_to):
- self.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ ожидает пользовательской реакции\n")
- time.sleep(period)
-
-
- self.proceed_status(proceed_to, localtask)
- self.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ отправлен в очередь " + proceed_to + "\n")
- def order_close(self, localtask):
-
- self.bot_log(botname + " " + str(datetime.now()) + " " + "Заказ удален\n")
|