[Pi IoT] -  Remote Horse Feeder System #6 : OpenHAB, Pi Face and MQTT

I just realized that the cut off time for submission is 11:59 PM GMT which is a bit sooner than I expected, so here be what I have thus far.

After getting the connections completed with the Pi Rack, I moved to working on the Automation application of the Feeder System I have been working on. This has included implementing Mosquitto, Paho, and MQTT for communication between OpenHAB and the feeder system.  With this, I can adjust the timer and setting locally on the Feeder System as well as change the Timer, Run the Feeder Manually, view the Pi CAM remotely and be notified when there is motion in the stall.

MQTT Phao and Mosquitto

Thus far in the config, I have 3 Topics that get updated at various intervals and events.

feeder/timer - Used to notify topic Subscribers that an update to the timer has been performed. This can be accomplished locally via the Pi Face Display and Control interface or remotely from open HAB.

feeder/manual - Used to Trigger the feeder system to run in Manual mode thus bypassing any timer settings

feeder/motion - Used to notify that there is moved in the Stall via a PIR sensor connected to the Pi Face Digital 2.

feeder/timer

Within OpenHAB, to handle the user input for setting the Feeder Timer remotely, the following config was implemented.

The site was very helpful in getting the Timer section completed:

https://github.com/openhab/openhab/wiki/AlarmClock

The Initial interface for the OpenHAB config displays the Feeder Timer, an option to set the Timer, Stall CAM (Both Video and Still cam options), The iLumi BLE Lights and EnOcean Energy Harvesting Switches.

From the Stall Timer, the user can Set the Timer by setting the Set_Timer switch to on.  The will grab the Timer that is site from the OpenHAB interface and send it to the feeder/timer topic which is picked up by the Feeder system. Also, the user can run the Feeder manually from the interface.  And, if there is motion, the Stall Motion indicator will be lit.

From the interface, the user selects the Time (Hour/Min) and the day to run the timer and once selected, click the Set Timer Switch.

Sitemap

sitemap home label="Smart Stall"
{
        Frame label="Stall Timer" {
                Frame label="Feeder Timer" {

                        Text label="Timer [%s]" item=timerMessage icon="clock" {
                                Frame label="Run Mode"  {
                                        Switch item=Set_Timer label="Set Timer"
                                        Switch item=Manual_Run label="Manual Run"
                                        Switch item=Motion_Alert label="Stall Motion"
                                        Text item=Motion_Detect
                                }
                                Frame label="Time"  {
                                        Setpoint item=Set_Hour minValue=0 maxValue=23 step=1
                                        Setpoint item=Set_Minute minValue=0 maxValue=55 step=5
                                }
                                Frame label="Days" {
                                        Switch item=timerMonday
                                        Switch item=timerTuesday
                                        Switch item=timerWednesday
                                        Switch item=timerThursday
                                        Switch item=timerFriday
                                        Switch item=timerSaturday
                                        Switch item=timerSunday
                                }
                        }

                }

Items

Group iLumi
Group Feeder
Group DaysOfWeek
String Feeder_Timer "Get Timer [%s]"  <clock> (Feeder, iLumi) {mqtt="<[jiot2:feeder/timer:state:default]"}
Switch Set_Timer  <switch> (Feeder, iLumi)
String  Send_Timer "[%s]" (Feeder, iLumi) { mqtt=">[jiot2:feeder/timer:command:*:default]" }
Switch Manual_Run  <switch> (Feeder, iLumi)
String  Run_Manual "[%s]" (Feeder, iLumi) { mqtt=">[jiot2:feeder/manual:command:*:default]" }
Number Set_Hour   "Hour [%d]"  <clock> (Feeder, iLumi)
Number Set_Minute   "Minute [%d]"  <clock> (Feeder, iLumi)
Dimmer Set_Day   "Day [%s %%]" (Feeder, iLumi)
String New_Day   "Day [%s]" (Feeder, iLumi)
String New_Hour   "Hour [%d]" (Feeder, iLumi)
String timerMessage "%s"
Switch Motion_Alert  <siren> (Feeder, iLumi)
String  Motion_Detect "Switch Motion[%s]"  (Feeder, iLumi) { mqtt="<[jiot2:feeder/motion:state:default]" }

Switch timerMonday      "Monday"    <switch>  (DaysOfWeek)
Switch timerTuesday     "Tuesday"    <switch>  (DaysOfWeek)
Switch timerWednesday   "Wednesday"    <switch>  (DaysOfWeek)
Switch timerThursday    "Thursday"    <switch>  (DaysOfWeek)
Switch timerFriday      "Friday"    <switch>  (DaysOfWeek)
Switch timerSaturday    "Saturday"    <switch>  (DaysOfWeek)
Switch timerSunday      "Sunday"    <switch>  (DaysOfWeek)

Timer Rules

var String timerToMQTT = ""

rule "Initialization"
when
        System started
then
        postUpdate(Set_Hour, 6)
        postUpdate(Set_Minute, 15)
        postUpdate(timerMonday, ON)
        postUpdate(timerTuesday, OFF)
        postUpdate(timerWednesday, OFF)
        postUpdate(timerThursday, OFF)
        postUpdate(timerFriday, OFF)
        postUpdate(timerSaturday, OFF)
        postUpdate(timerSunday, OFF)
        postUpdata(Manual_Run, OFF)
        postUpdata(Motion_Alert, OFF)
end
er rules

rule "Set Timer"
when
        Item Set_Hour changed or
        Item Set_Minute changed
then
        logInfo("Set Timer", "Set Timer")
        var String msg = ""
        var String day = ""
        var String ampm = ""
        var hour = Set_Hour.state as DecimalType
        var minute = Set_Minute.state as DecimalType

        if (timerMonday.state == ON) { day = "Mon" }
        if (timerTuesday.state == ON) { day = "Tue" }
        if (timerWednesday.state == ON) { day = "Wed" }
        if (timerThursday.state == ON) { day = "Thu" }
        if (timerFriday.state == ON) { day = "Fri" }
        if (timerSaturday.state == ON) { day = "Sat" }
        if (timerSunday.state == ON) { day = "Sun" }

        if (hour < 10) { msg = "0"  }
        msg = msg + Set_Hour.state.format("%d") + ":"
        if (hour >= 12) {ampm = "PM"}
        if (hour < 12) {ampm = "AM"}

        if (minute < 10) { msg + msg = "0"  }
        msg = msg + Set_Minute.state.format("%d")

        msg = day + "  " + msg + " " + ampm

        postUpdate(timerMessage, msg)

        timerToMQTT = msg
end

rule "Set Feed Timer"
when
        Item Set_Timer changed from OFF to ON
then
        var String feed_timer

        //feed_timer = "Mon  07:30 AM"

        sendCommand(Send_Timer, timerToMQTT)
end

rule "Manual Feeder Run"
when
    Item Manual_Run changed from OFF to ON
then
    var String set_manual = ""

    set_manual = "Run"

    sendCommand(Run_Manual, set_manual)
end

rule "Manual Feeder Stop"
when
    Item Manual_Run changed from ON to OFF
then
    var String set_manual = ""

    set_manual = "Stop"

    sendCommand(Run_Manual, set_manual)
end

rule "Motion Detected"
when
    Item Motion_Detect changed
then
    var String motion_message = ""
    logInfo("Motion Detected", "In Da Motion")

    motion_message = Motion_Detect.state.toString

    logInfo("Motion Detected", motion_message)
    if (motion_message == "Motion Detected") {
        sendCommand(Motion_Alert, ON)
    }
    else {
        sendCommand(Motion_Alert, OFF)
    }

end

OpenHAB.cfg

mqtt:jiot2.url=tcp://192.168.2.130:1883

# Optional. Client id (max 23 chars) to use when connecting to the broker.
# If not provided a default one is generated.
#mqtt:<broker>.clientId=<clientId>
mqtt:jiot2.clientId=FeedMQTT
mqtt-eventbus:broker=jiot2
mqtt-eventbus:commandPublishTopic=feeder/timer/${item}/command
mqtt-eventbus:commandSubscribeTopic=feeder/timer/${item}/state
mqtt-eventbus:commandPublishTopic=feeder/manual/${item}/command
mqtt-eventbus:commandSubscribeTopic=feeder/manual/${item}/state
mqtt-eventbus:commandSubscribeTopic=feeder/motion/${item}/state

Feeder System Paho config

def send_mqtt(message_dict):
    mqttc = mqtt.Client('python_publisher')
    mqttc.connect('192.168.2.130', 1883)
    #message_json2str = json.dumps(message_dict)
    hourTemp = str(timer_dict['hour']).rjust(2, '0')
    minTemp = str(timer_dict['min']).rjust(2, '0')
    message_json2str = timer_dict['day'] + " " + hourTemp + ":" + minTemp + " " + timer_dict['ampm']
    mqttc.publish('feeder/timer', message_json2str, retain=True)
    t.sleep(2)
    mqttc.disconnect()

# The callback for when the client receives a CONNACK response from the server
def on_connect(client, userdata, rc):
    print("Connected with result code "+str(rc))
    # Subscribing in on_connect() means that we lose the connect and
    # reconnect then subscriptions will be renewed
    client.subscribe([("feeder/timer", 0), ("feeder/manual", 0)])
    #client.subscribe("feeder/timer")
    #client.subscribe("feeder/manual")


# The callback forwhen a PUBLISH message is received from the server.
def on_message(client, userdata, msg):
    hourTemp = ""
    minTemo = ""
    man_run = ""
    current_timer = ""
    #msg_read =""
    msg_read = msg.payload.decode('utf-8')
    #print(msg.topic+" "+str(msg.payload))
    print(msg.topic+" "+msg_read)
    if (msg.topic == "feeder/manual"):
        man_run = msg_read
        #man_run = str(msg.payload)
        print("feeder/manual = %s" % man_run)
        if ('Run' in man_run):
            runManual()
            #client.disconnect()

    if (msg.topic == "feeder/timer"):
        timer_data = msg_read
        if os.path.isfile('timer.json'):
            with open('timer.json') as datafile:

           current_timer = json.load(datafile)
        print("New time message %s " % timer_data)
        timer_data = timer_data.split()
        print("Current Timer %s " % current_timer)
        if current_timer != timer_data:
            print("New Timer")
            with open('timer.json', 'w') as outfile:
                json.dump(timer_data, outfile)
            timer_dict['day'] = timer_data[0].strip()
            hour_min = timer_data[1].split(":")
            timer_dict['hour'] = hour_min[0]
            timer_dict['min'] = hour_min[1]
            timer_dict['ampm'] = timer_data[2]
            saveTimerData(timer_dict)
            showTimer()
        #client.disconnect()
        #hourTemp = str(timer_dict['hour']).rjust(2, '0')
        #minTemp = str(timer_dict['min']).rjust(2, '0')]
        #message_json2str = timer_dict['day'] + " " + hourTemp + ":" + minTemp + " " + timer_dict['ampm']

    client.disconnect()

def getMQTTTimer():
    mqttc = mqtt.Client()
    mqttc.on_connect = on_connect
    mqttc.on_message = on_message
    mqttc.connect('192.168.2.130', 1883, 60)
    '''
    if (mqttc.connected is not False):
        mqttc.connect('192.168.2.130', 1883, 60)
        #mqttc.loop_start()
    '''

    mqttc.loop_forever(timeout=1.0, max_packets=2, retry_first_connection=False)
    mqttc.disconnect(

Motion Sensor to Pi Face Digital 2

The sensor I used for the Motion Sensing is the Parallax PI Sensor rev B.  This is connected to the Pi Face Digital 2 Input 3, 5V and Ground. (NOTE: Since the Digital 2 Inputs are by default pulled up to 5V, I ended up having to put a 10K resistor between GND and Pin 3 to pull the pin low when the PIR sensor was on.)

PiFace Digital IO Config:

import pifacedigitalio as pdio


def detectMotion():
    MOTION = 0
    NO_MOTION = 1
    pri1 = NO_MOTION
    pdio.init()
    t.sleep(1)

    while True:
        pir1 = pdio.digital_read(3,1)
        if pir1 is MOTION:
            print ("Motion Detected!")
            send_message(topic_motion, feeder_broker, "Motion Detected")
        t.sleep(1)

This was started as a Process in Python so it would run parallel in the background to the main app:

    p = Process(target=getMQTTTimer)
    m = Process(target=detectMotion)
    p.start()
    p.join()
    m.daemon = False
    m.start()

With all of that, this is what it looks like in the raw, nothing in case at this point.

Edit media

Dimensions x Small Medium Large Custom

Subject (required) Brief Description Tags (separated by comma) Video visibility in search results Visible Hidden

Parent content

[Pi IoT] -  Remote Horse Feeder System #6 : OpenHAB, Pi Face and MQTT

Poster

Upload Preview

Ok

Cancel

This has been an awesome adventure and I appreciate the opportunity to use the tools given to create a project; I just wish I could have completed it in the time allotted.  I'll keep working on this and hopefully get something that is complete be years end.

Thanks,

Jon