Sistema de gerenciamento de pedidos de hotéis/restaurantes baseado em servidor Raspberry Pi em IoT – IOT Parte 46

###



//Program to​


import paho.mqtt.client as mqtt

import paho.mqtt.publish as publish

import random

import thread

import time

import time

import RPi.GPIO as GPIO       ## Import GPIO library

import os

os.system('clear')

############################# Raspberry Pi GPIO ############################

GPIO.setwarnings(False)

GPIO.setmode(GPIO.BOARD)    ## Use board pin numbering

GPIO.setup(8, GPIO.OUT)     ## Setup GPIO Pin 8 to OUT

GPIO.setup(10, GPIO.OUT)    ## Setup GPIO Pin 10 to OUT

GPIO.setup(12, GPIO.OUT)    ## Setup GPIO Pin 12 to OUT

GPIO.setup(16, GPIO.OUT)    ## Setup GPIO Pin 16 to OUT

#declarations

broker_ip = "broker.hivemq.com"

broker_port = 1883

oldstr="0"

tim1 = '0'

abc="0"

cba="0"

order="0"

m = '0'

a = "ad"

b = "cb"

#Main Satrt

menu_items=("Coffee",

            "Tea",

            "Maxixan Rice",

            "Grilled Veggie Wich",

            "Cheese Pizza",

            "Aloo Tikki Burger",

            "French Fries",

            )

item_price=(200,130,100,400,200,55,90)

count = 0

count2 = 0

count3 = 0

# The callback for when the client receives a CONNACK response from the server.

print ("""

 __   __  _______  _______  _______  ___        ___   _______  _______ 

                                                                       

    _        _     _     _      ___                      _     _     _ 

                                ___                                    

             _                  ___      ___             _             

    _                           ___                                    

 __   __  _______    ___    _______  _______    ___   _______    ___   

""")

   

def on_connect(client, userdata, flags, rc):

    #print("Connected with result code "+str(rc))

    print("Connected!")

    # Subscribing in on_connect  means that if we lose the connection and

    # reconnect then subscriptions will be renewed.

    client.subscribe("ToServer")

    GPIO.output(16,True)   #GPIO pin will be on on the connection 

    GPIO.output(8,False)

    GPIO.output(10,False)

    GPIO.output(12,False)

# The callback for when a PUBLISH message is received from the server.

def on_message(client, userdata, msg):

    global count

    global count2

    global count3

    global order

    global abc

    global m

    message = str(msg.payload)

    #print(msg.topic+" "+str(msg.payload))

    if ('19932' in message.lower ):

        #rand1 = random.randint(0, 4)

        #publish.single("FromServer", reasponse_on_name(rand1), hostname="192.168.1.106")

        menu 

    elif ('m' in message):

        count = (count + 1)

        oldstr = message

        #print oldstr

        tim1 = oldstr.replace("m", "0")

        #print tim1

        tim1 = int(tim1)

        tim1 = tim1 +30

        m = " minutes"

        if(tim1>60):

            tim1 = (tim1/60)

            m = " hour"

        abc = str(tim1)

        #print abc

        order = ("Order will be ready in:"+abc+m)

       

    elif ('ooo' in message):

        count2 = count2 + 1

        count3 = count3 + 1

        oldstr1 = message

        #print message

        tim2 = oldstr1.replace("ooo", "0")

        #print tim2

        tim2 = int(tim2)

        #print tim2

        if(tim2>len(menu_items)):

            publish.single("FromServer", "Wrong Order! Please Select a valid menu Item", hostname=broker_ip)

            #print (" Invalid order:"+" with id:"+str(count2))

        else:

            publish.single("FromServer", order, hostname=broker_ip)

            print ("Custmor No."+ str(count) + " wil be here in "+ abc +" "+m),

            print (" With the order of:"+menu_items((tim2-1))+" with id:"+str(count2))

            print " "

            if(count3==1):

                GPIO.output(8,True)

                GPIO.output(12,False)

            if(count3==2):

                GPIO.output(10,True)

            if(count3==3):

                GPIO.output(12,True)

                GPIO.output(8,False)

                GPIO.output(10,False)

                count3 = 0   

def menu :

    for i in range(0,len(menu_items)):

        #print str(i+1) +":"+  menu_items(i)+ ":" +str(item_price(i))

        menu_send = (str(i+1) +"."+  menu_items(i)+ ":" +str(item_price(i)) + "$")

        publish.single("FromServer", menu_send, hostname=broker_ip)


       

client = mqtt.Client 

client.on_connect = on_connect

client.on_message = on_message

client.connect(broker_ip, broker_port, 60)

client.loop_forever 


###