Domoticz

Code: Select all

#!/usr/bin/env python
# PIN: 23  == GPIO4 (pin 16)

#imports
import time
import RPi.GPIO as GPIO
import json
import urllib2
import base64

#vars
GET_URL = 'http://192.168.1.205:8080/json.htm?type=command&param=getuservariable&idx=1'
SET_URL = 'http://192.168.1.205:8080/json.htm?type=command&param=udevice&idx=15&svalue='
SET_VAR_URL = 'http://192.168.1.205:8080/json.htm?type=command&param=updateuservariable&idx=1&vname=Water&vtype=0&vvalue='
WATER_VALUE = 0
base64string = base64.encodestring('%s:%s' % ('username', 'password')).replace('\n', '')


# handle the trigger event
def Trigger (pin):
   if GPIO.input(23):
      global WATER_VALUE
      WATER_VALUE += 1
      # print WATER_VALUE

      POST_URL = SET_URL + str(WATER_VALUE)

      global base64string
      requestPost = urllib2.Request(POST_URL)
      requestPost.add_header("Authorization", "Basic %s " % base64string)
      resultPost = json.load(urllib2.urlopen(requestPost))
      # print resultPost

      POST_VAR = SET_VAR_URL + str(WATER_VALUE)

      requestVar = urllib2.Request(POST_VAR)
      requestVar.add_header("Authorization", "Basic %s " % base64string)
      resultVar = json.load(urllib2.urlopen(requestVar))
      # print resultVar


# main function
def main():

    GPIO.setmode(GPIO.BCM)
    GPIO.setup(23, GPIO.IN, pull_up_down=GPIO.PUD_DOWN)
    GPIO.add_event_detect(23, GPIO.RISING, callback=Trigger, bouncetime=500)

    request = urllib2.Request(GET_URL)

    global base64string
    request.add_header("Authorization", "Basic %s " % base64string)
    result = json.load(urllib2.urlopen(request))

    global WATER_VALUE
    WATER_VALUE = int( result['result'][0]['Value'])
    print WATER_VALUE

    while True:
        time.sleep(1)

   # GPIO.cleanup()

if __name__=="__main__":
    main()

Code: Select all

pi@raspberrypi ~/WORK $ sudo python ./counter.py 
Traceback (most recent call last):
  File "./counter.py", line 65, in <module>
    main()
  File "./counter.py", line 56, in main
    WATER_VALUE = int( result['result'][0]['Value'])
KeyError: 'result'

Code: Select all

#!/usr/bin/env python

#imports
import time
import RPi.GPIO as GPIO
import json
import urllib2
import threading

#vars
GET_URL = 'http://localhost:8080/json.htm?type=devices&rid=%d'
SET_URL = 'http://localhost:8080/json.htm?type=command&param=udevice&idx=%d&svalue=%d'
GAS_DELTA = 0
GAS_IDX = 3
GAS_GPIO = 26
GAS_COUNTER_LOCK = threading.Lock()
ELEC_DELTA = 0
ELEC_IDX = 4
ELEC_GPIO = 16
ELEC_COUNTER_LOCK = threading.Lock()

def gpio_intr(pin):
    if pin == GAS_GPIO:
        global GAS_DELTA
        with GAS_COUNTER_LOCK:
            GAS_DELTA += 1
        print 'Gas counter tick: %d' % GAS_DELTA

    if pin == ELEC_GPIO:
        global ELEC_DELTA
        with ELEC_COUNTER_LOCK:
            ELEC_DELTA += 1
        print 'Electricity counter tick: %d' % ELEC_DELTA

def main():
    global GAS_DELTA
    global ELEC_DELTA

    GPIO.setmode(GPIO.BCM)
    GPIO.setup(GAS_GPIO, GPIO.IN, pull_up_down=GPIO.PUD_DOWN)
    GPIO.add_event_detect(GAS_GPIO, GPIO.RISING, callback=gpio_intr, bouncetime=100)
    GPIO.setup(ELEC_GPIO, GPIO.IN, pull_up_down=GPIO.PUD_DOWN)
    GPIO.add_event_detect(ELEC_GPIO, GPIO.RISING, callback=gpio_intr, bouncetime=100)

    while True:
        time.sleep(5)

        GAS_DELTA_POST = GAS_DELTA

        if GAS_DELTA_POST != 0:
            try:
                res = json.load(urllib2.urlopen(SET_URL % (GAS_IDX, GAS_DELTA_POST)))
                if res['status'] != 'OK':
                    raise Exception('Domoticz json error')
                with GAS_COUNTER_LOCK:
                    GAS_DELTA -= GAS_DELTA_POST
            except Exception as e:
                print e

        ELEC_DELTA_POST = ELEC_DELTA

        if ELEC_DELTA_POST != 0:
            try:
                res = json.load(urllib2.urlopen(SET_URL % (ELEC_IDX, ELEC_DELTA_POST)))
                if res['status'] != 'OK':
                    raise Exception('Domoticz json error')
                with ELEC_COUNTER_LOCK:
                    ELEC_DELTA -= ELEC_DELTA_POST
            except Exception as e:
                print e

        print 'Gas delta %d; Elec delta %d' % (GAS_DELTA_POST, ELEC_DELTA_POST)

if __name__=="__main__":
    main() 

Code: Select all

@reboot sudo python /home/pi/domoticz/scripts/watermeter.py

Code: Select all

ps ax