Domoticz

Code: Select all

/**
 *  Modbus object declaration
 *  u8id : node id = 0 for master, = 1..247 for slave
 *  u8serno : serial port (use 0 for Serial)
 *  u8txenpin : 0 for RS-232 and USB-FTDI 
 *               or any pin number > 1 for RS-485
 */
Modbus slave(1,0,0); // this is slave @1 and RS-232

Code: Select all

   instrument = minimalmodbus.Instrument('/dev/ttyAMA0',x) # port name, slave address
   instrument.serial.baudrate = 9600
   instrument.serial.timeout = 0.5
   instrument.debug = True
   print instrument
   Status = instrument.read_register(21,0) # registernumber, number of decimals

Code: Select all

#!/usr/bin/python
#   Title: modbus.coilX.py
#   Author: bobdvb original code from Chopper_Rob
#   Date: 08-11-2016
#   Info: Checks the value of a modbus register and reports that to Domoticz
#   URL :
#   Version : 0.5

import sys
import datetime
import time
import os
import subprocess
import urllib2
import json
import base64

import minimalmodbus
import serial

instrument = minimalmodbus.Instrument('/dev/ttyUSB3', 1) # port name, slave address
instrument.serial.baudrate = 38400
instrument.timeout = 1
instrument.precalculate_read_size = False
instrument.debug = False

modfunccode = 2 # This sets if it is an input or an output that we are reading.

# Settings for the domoticz server
domoticzserver="192.168.1.2:8080"
domoticzusername = "admin"
domoticzpassword = "admin"
domoticzpasscode = "passphrase"

# If enabled. The script will log to the file _.log
# Logging to file only happens after the check for other instances, before that it only prints to screen.
log_to_file = False

# The script supports two types to check if another instance of the script is running.
# One will use the ps command, but this does not work on all machine (Synology has problems)
# The other option is to create a pid file named _.pid. The script will update the timestamp
# every interval. If a new instance of the script spawns it will check the age of the pid file.
# If the file doesn't exist or it is older then 3 * Interval it will keep running, otherwise is stops.
# Please chose the option you want to use "ps" or "pid", if this option is kept empty it will not check and just run.
check_for_instances = "pid"


# DO NOT CHANGE BEYOND THIS LINE
if len(sys.argv) != 5 :
  print ("Not enough parameters. Needs %register %IDX %Interval %Cooldownperiod.")
  sys.exit(0)

device=sys.argv[1]
switchid=sys.argv[2]
interval=sys.argv[3]
cooldownperiod=sys.argv[4]
previousstate=-1
lastsuccess=datetime.datetime.now()
lastreported=-1
base64string = base64.encodestring('%s:%s' % (domoticzusername, domoticzpassword)).replace('\n', '')
domoticzurl = 'http://'+domoticzserver+'/json.htm?type=devices&filter=all&used=true&order=Name'

if check_for_instances.lower() == "pid":
  pidfile = sys.argv[0] + '_' + sys.argv[1] + '.pid'
  if os.path.isfile( pidfile ):
    print datetime.datetime.now().strftime("%H:%M:%S") + "- pid file exists"
    if (time.time() - os.path.getmtime(pidfile)) < (float(interval) * 3):
      print datetime.datetime.now().strftime("%H:%M:%S") + "- script seems to be still running, exiting"
      print datetime.datetime.now().strftime("%H:%M:%S") + "- If this is not correct, please delete file " + pidfile
      sys.exit(0)
    else:
      print datetime.datetime.now().strftime("%H:%M:%S") + "- Seems to be an old file, ignoring."
  else:
    open(pidfile, 'w').close()

if check_for_instances.lower() == "ps":
  if int(subprocess.check_output('ps x | grep \'' + sys.argv[0] + ' ' + sys.argv[1] + '\' | grep -cv grep', shell=True)) > 2 :
    print (datetime.datetime.now().strftime("%H:%M:%S") + "- script already running. exiting.")
    sys.exit(0)

def log(message):
  print message
  if log_to_file == True:
    logfile = open(sys.argv[0] + '_' + sys.argv[1] + '.log', "a")
    logfile.write(message + "\n")
    logfile.close()

def domoticzstatus ():
  json_object = json.loads(domoticzrequest(domoticzurl))
  status = 0
  switchfound = False
  if json_object["status"] == "OK":
    for i, v in enumerate(json_object["result"]):
      if json_object["result"][i]["idx"] == switchid:
        switchfound = True
        if json_object["result"][i]["Status"] == "On":
          status = 0
        if json_object["result"][i]["Status"] == "Off":
          status = 1
  if switchfound == False: print (datetime.datetime.now().strftime("%H:%M:%S") + "- Error. Could not find switch idx in Domoticz response. Defaulting to switch off.")
  return status

def domoticzrequest (url):
  request = urllib2.Request(url)
  request.add_header("Authorization", "Basic %s" % base64string)
  response = urllib2.urlopen(request)
  return response.read()

log (datetime.datetime.now().strftime("%H:%M:%S") + "- script started.")

lastreported = domoticzstatus()
if lastreported == 0 :
  log (datetime.datetime.now().strftime("%H:%M:%S") + "- according to domoticz, " + device + " is online")
if lastreported == 1 :
  log (datetime.datetime.now().strftime("%H:%M:%S") + "- according to domoticz, " + device + " is offline")

while 1==1:
#  currentstate = subprocess.call('ping -q -c1 -W 1 '+ device + ' > /dev/null', shell=True)
  errcnt = 5
  while True:
    try:
      currentstate = instrument.read_bit(int(device), modfunccode)
      break
    except IOError:
      print("Failed to read from instrument, trying again. Error count: " + str(errcnt))
      time.sleep(1)
      errcnt = errcnt - 1
      if errcnt == 0 : break
    except ValueError:
      print("Unexpected value returned, trying again. Error count: " + str(errcnt))
      time.sleep(1)
      errcnt = errcnt - 1
      if errcnt == 0 : break
#  print "Read instrument"

  if currentstate == 0 : lastsuccess=datetime.datetime.now()
  if currentstate == 0 and currentstate != previousstate and lastreported == 1 :
    log (datetime.datetime.now().strftime("%H:%M:%S") + "- " + device + " off, no need to tell domoticz")
  if currentstate == 0 and currentstate != previousstate and lastreported != 1 :
    if domoticzstatus() == 0 :
      log (datetime.datetime.now().strftime("%H:%M:%S") + "- " + device + " tell domoticz it's off")
      domoticzrequest("http://" + domoticzserver + "/json.htm?type=command&param=switchlight&idx=" + switchid + "&switchcmd=Off&level=0" + "&passcode=" + domoticzpasscode)
    else:
      log (datetime.datetime.now().strftime("%H:%M:%S") + "- " + device + " off and domoticz already knew")
    lastreported=1

  if currentstate == 1 and currentstate != previousstate :
    log (datetime.datetime.now().strftime("%H:%M:%S") + "- " + device + " on, waiting")

  if currentstate == 1 and (datetime.datetime.now()-lastsuccess).total_seconds() > float(cooldownperiod) and lastreported != 0 :
    if domoticzstatus() == 1 :
      log (datetime.datetime.now().strftime("%H:%M:%S") + "- " + device + " on, tell domoticz it's on")
      domoticzrequest("http://" + domoticzserver + "/json.htm?type=command&param=switchlight&idx=" + switchid + "&switchcmd=On&level=0" + "&passcode=" + domoticzpasscode)
    else:
      log (datetime.datetime.now().strftime("%H:%M:%S") + "- " + device + " on, but domoticz already knew")
    lastreported=0

  time.sleep (float(interval))

  previousstate=currentstate
  if check_for_instances.lower() == "pid": open(pidfile, 'w').close()

Code: Select all

#!/usr/bin/env python
import minimalmodbus
import serial
import time

inputCount = 12
outputCount = 6
regCount = 16 # Should be 256
middleCoil = 16 # Should be 256
flagCount = 32

instrument = minimalmodbus.Instrument('/dev/ttyUSB3', 1) # port name, slave address (in decimal)
instrument.serial.baudrate = 38400
instrument.timeout = 0.5
instrument.precalculate_read_size = False

#instrument.write_long(9, 12451840)

while (1):
        count = 0
        print '= Input Registers ='
        while (count < inputCount):
                coil = instrument.read_bit(count, 2) # Registernumber, number of decimals
                print 'input:', count+1, 'value:', coil
                count = count + 1
#       time.sleep(1)

        count = 0
        print '= Digital Outputs ='
        while (count < outputCount):
                coil = instrument.read_bit(count, 1) # Registernumber, number of decimals
                print 'coil:', count+1, 'value:', coil
                count = count + 1
#        time.sleep(1)

        count = 0
        print '= Middle Coil ='
        while (count < middleCoil):
                coil = instrument.read_bit((256 + count), 1) # Registernumber, number of decimals
                if (coil > 0):
                        print 'coil:', count+1, 'value:', coil
                count = count + 1

        count = 0
        print '= Digital Flag ='
        while (count < flagCount):
                coil = instrument.read_bit((768 + count), 1) # Registernumber, number of decimals
                if (coil > 0):
                        print 'value:', count+1, 'value:', coil
                count = count + 1

        count = 0

        print '= Holding Registers ='
        while (count < regCount):
                coil = instrument.read_long(count, 3) # Registernumber, number of decimals
                if (coil > 0):
                        print 'value:', count+1, 'value:', coil
                count = count + 1

        time.sleep(1)

print 'done'