mirror of
https://github.com/mtan93/SmartThingsPublic.git
synced 2026-03-20 05:10:51 +00:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
fc99c1c3ee |
@@ -1,254 +0,0 @@
|
|||||||
/**
|
|
||||||
* Fibaro Wall Plug ZW5
|
|
||||||
*
|
|
||||||
* Copyright 2016 Fibar Group S.A.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
|
|
||||||
* in compliance with the License. You may obtain a copy of the License at:
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed
|
|
||||||
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License
|
|
||||||
* for the specific language governing permissions and limitations under the License.
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
metadata {
|
|
||||||
definition (name: "Fibaro Wall Plug ZW5", namespace: "fibargroup", author: "Fibar Group S.A.") {
|
|
||||||
capability "Actuator"
|
|
||||||
capability "Configuration"
|
|
||||||
capability "Energy Meter"
|
|
||||||
capability "Power Meter"
|
|
||||||
capability "Refresh"
|
|
||||||
capability "Sensor"
|
|
||||||
capability "Switch"
|
|
||||||
|
|
||||||
command "reset"
|
|
||||||
|
|
||||||
fingerprint deviceId: "0x1001", inClusters: "0x5E, 0x22, 0x85, 0x59, 0x70, 0x56, 0x5A, 0x7A, 0x72, 0x32, 0x8E, 0x71, 0x73, 0x98, 0x31, 0x25, 0x86", outClusters: ""
|
|
||||||
}
|
|
||||||
|
|
||||||
simulator {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
tiles(scale: 2) {
|
|
||||||
multiAttributeTile(name:"FGWP", type:"lighting", width:6, height:4) {//with generic type secondary control text is not displayed in Android app
|
|
||||||
tileAttribute("device.switch", key:"PRIMARY_CONTROL") {
|
|
||||||
attributeState("on", label: '${name}', action: "switch.off", icon:"st.switches.switch.on", backgroundColor:"#79b821")
|
|
||||||
attributeState("off", label: '${name}', action: "switch.on", icon:"st.switches.switch.off", backgroundColor:"#ffffff")
|
|
||||||
}
|
|
||||||
|
|
||||||
tileAttribute("device.power", key:"SECONDARY_CONTROL") {
|
|
||||||
attributeState("default", label:'${currentValue} W', backgroundColor:"#ffffff")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
valueTile("energy", "device.energy", width: 2, height: 2) {
|
|
||||||
state "default", label:'${currentValue} kWh'
|
|
||||||
}
|
|
||||||
standardTile("reset", "device.energy", inactiveLabel: false, decoration: "flat", width: 2, height: 2) {
|
|
||||||
state "default", label:'reset kWh', action:"reset"
|
|
||||||
}
|
|
||||||
standardTile("refresh", "device.power", inactiveLabel: false, decoration: "flat", width: 2, height: 2) {
|
|
||||||
state "default", label:'', action:"refresh.refresh", icon:"st.secondary.refresh"
|
|
||||||
}
|
|
||||||
|
|
||||||
main "FGWP"
|
|
||||||
details(["FGWP", "energy", "reset", "refresh"])
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// parse events into attributes
|
|
||||||
def parse(String description) {
|
|
||||||
log.debug "Parsing '${description}'"
|
|
||||||
|
|
||||||
if (description.startsWith("Err 106")) {
|
|
||||||
if (state.sec) {
|
|
||||||
result = createEvent(descriptionText:description, displayed:false)
|
|
||||||
} else {
|
|
||||||
result = createEvent(
|
|
||||||
descriptionText: "FGK failed to complete the network security key exchange. If you are unable to receive data from it, you must remove it from your network and add it again.",
|
|
||||||
eventType: "ALERT",
|
|
||||||
name: "secureInclusion",
|
|
||||||
value: "failed",
|
|
||||||
displayed: true,
|
|
||||||
)
|
|
||||||
}
|
|
||||||
} else if (description == "updated") {
|
|
||||||
return null
|
|
||||||
} else {
|
|
||||||
def cmd = zwave.parse(description, [0x25: 1, 0x31: 5, 0x32: 1, 0x5A: 1, 0x71: 3, 0x72: 2, 0x86: 1])
|
|
||||||
|
|
||||||
if (cmd) {
|
|
||||||
log.debug "Parsed '${cmd}'"
|
|
||||||
zwaveEvent(cmd)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//security
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.securityv1.SecurityMessageEncapsulation cmd) {
|
|
||||||
def encapsulatedCommand = cmd.encapsulatedCommand([0x25: 1, 0x5A: 1])
|
|
||||||
if (encapsulatedCommand) {
|
|
||||||
return zwaveEvent(encapsulatedCommand)
|
|
||||||
} else {
|
|
||||||
log.warn "Unable to extract encapsulated cmd from $cmd"
|
|
||||||
createEvent(descriptionText: cmd.toString())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//crc16
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.crc16encapv1.Crc16Encap cmd)
|
|
||||||
{
|
|
||||||
def versions = [0x31: 5, 0x32: 1, 0x71: 3, 0x72: 2, 0x86: 1]
|
|
||||||
def version = versions[cmd.commandClass as Integer]
|
|
||||||
def ccObj = version ? zwave.commandClass(cmd.commandClass, version) : zwave.commandClass(cmd.commandClass)
|
|
||||||
def encapsulatedCommand = ccObj?.command(cmd.command)?.parse(cmd.data)
|
|
||||||
if (!encapsulatedCommand) {
|
|
||||||
log.debug "Could not extract command from $cmd"
|
|
||||||
} else {
|
|
||||||
zwaveEvent(encapsulatedCommand)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.meterv1.MeterReport cmd) {
|
|
||||||
if (cmd.scale == 0) {
|
|
||||||
createEvent(name: "energy", value: cmd.scaledMeterValue, unit: "kWh")
|
|
||||||
} else if (cmd.scale == 2) {
|
|
||||||
createEvent(name: "power", value: Math.round(cmd.scaledMeterValue), unit: "W")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.manufacturerspecificv2.ManufacturerSpecificReport cmd) {
|
|
||||||
log.debug "manufacturerId: ${cmd.manufacturerId}"
|
|
||||||
log.debug "manufacturerName: ${cmd.manufacturerName}"
|
|
||||||
log.debug "productId: ${cmd.productId}"
|
|
||||||
log.debug "productTypeId: ${cmd.productTypeId}"
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.manufacturerspecificv2.DeviceSpecificReport cmd) {
|
|
||||||
log.debug "deviceIdData: ${cmd.deviceIdData}"
|
|
||||||
log.debug "deviceIdDataFormat: ${cmd.deviceIdDataFormat}"
|
|
||||||
log.debug "deviceIdDataLengthIndicator: ${cmd.deviceIdDataLengthIndicator}"
|
|
||||||
log.debug "deviceIdType: ${cmd.deviceIdType}"
|
|
||||||
|
|
||||||
if (cmd.deviceIdType == 1 && cmd.deviceIdDataFormat == 1) {//serial number in binary format
|
|
||||||
String serialNumber = "h'"
|
|
||||||
|
|
||||||
cmd.deviceIdData.each{ data ->
|
|
||||||
serialNumber += "${String.format("%02X", data)}"
|
|
||||||
}
|
|
||||||
|
|
||||||
updateDataValue("serialNumber", serialNumber)
|
|
||||||
log.debug "${device.displayName} - serial number: ${serialNumber}"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.versionv1.VersionReport cmd) {
|
|
||||||
updateDataValue("version", "${cmd.applicationVersion}.${cmd.applicationSubVersion}")
|
|
||||||
log.debug "applicationVersion: ${cmd.applicationVersion}"
|
|
||||||
log.debug "applicationSubVersion: ${cmd.applicationSubVersion}"
|
|
||||||
log.debug "zWaveLibraryType: ${cmd.zWaveLibraryType}"
|
|
||||||
log.debug "zWaveProtocolVersion: ${cmd.zWaveProtocolVersion}"
|
|
||||||
log.debug "zWaveProtocolSubVersion: ${cmd.zWaveProtocolSubVersion}"
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.sensormultilevelv5.SensorMultilevelReport cmd) {
|
|
||||||
def map = [ displayed: true ]
|
|
||||||
if (cmd.sensorType == 4) {
|
|
||||||
createEvent(name: "power", value: Math.round(cmd.scaledSensorValue), unit: "W")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.switchbinaryv1.SwitchBinaryReport cmd) {
|
|
||||||
createEvent(name: "switch", value: cmd.value ? "on" : "off", type: "digital")
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.deviceresetlocallyv1.DeviceResetLocallyNotification cmd) {
|
|
||||||
log.info "${device.displayName}: received command: $cmd - device has reset itself"
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.commands.notificationv3.NotificationReport cmd)
|
|
||||||
{
|
|
||||||
if (cmd.notificationType == 0x08) {
|
|
||||||
if (cmd.event == 0x06) {
|
|
||||||
createEvent(descriptionText: "Warning: $device.displayName detected over-current", isStateChange: true)
|
|
||||||
} else if (cmd.event == 0x08) {
|
|
||||||
createEvent(descriptionText: "Warning: $device.displayName detected over-load", isStateChange: true)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
def zwaveEvent(physicalgraph.zwave.Command cmd) {
|
|
||||||
log.debug "$device.displayName: Unhandled: $cmd"
|
|
||||||
[:]
|
|
||||||
}
|
|
||||||
|
|
||||||
// handle commands
|
|
||||||
def configure() {
|
|
||||||
log.debug "Executing 'configure'"
|
|
||||||
|
|
||||||
def cmds = []
|
|
||||||
|
|
||||||
cmds += zwave.manufacturerSpecificV1.manufacturerSpecificGet()
|
|
||||||
cmds += zwave.manufacturerSpecificV2.deviceSpecificGet()
|
|
||||||
cmds += zwave.versionV1.versionGet()
|
|
||||||
cmds += zwave.associationV2.associationSet(groupingIdentifier:1, nodeId:[zwaveHubNodeId])
|
|
||||||
cmds += zwave.meterV2.meterGet(scale:0)
|
|
||||||
cmds += zwave.meterV2.meterGet(scale:2)
|
|
||||||
cmds += zwave.switchBinaryV1.switchBinaryGet()
|
|
||||||
|
|
||||||
encapSequence(cmds, 500)
|
|
||||||
}
|
|
||||||
|
|
||||||
def refresh() {
|
|
||||||
log.debug "Executing 'refresh'"
|
|
||||||
|
|
||||||
def cmds = []
|
|
||||||
cmds += zwave.meterV2.meterGet(scale:0)
|
|
||||||
cmds += zwave.meterV2.meterGet(scale:2)
|
|
||||||
cmds += zwave.switchBinaryV1.switchBinaryGet()
|
|
||||||
|
|
||||||
encapSequence(cmds, 500)
|
|
||||||
}
|
|
||||||
|
|
||||||
def on() {
|
|
||||||
log.debug "Executing 'on'"
|
|
||||||
encap(zwave.switchBinaryV1.switchBinarySet(switchValue: 0xFF))
|
|
||||||
}
|
|
||||||
|
|
||||||
def off() {
|
|
||||||
log.debug "Executing 'off'"
|
|
||||||
encap(zwave.switchBinaryV1.switchBinarySet(switchValue: 0x00))
|
|
||||||
}
|
|
||||||
|
|
||||||
def reset() {
|
|
||||||
log.debug "Executing 'reset'"
|
|
||||||
encap(zwave.meterV2.meterReset())
|
|
||||||
}
|
|
||||||
|
|
||||||
private secure(physicalgraph.zwave.Command cmd) {
|
|
||||||
zwave.securityV1.securityMessageEncapsulation().encapsulate(cmd).format()
|
|
||||||
}
|
|
||||||
|
|
||||||
private crc16(physicalgraph.zwave.Command cmd) {
|
|
||||||
//zwave.crc16encapV1.crc16Encap().encapsulate(cmd).format()
|
|
||||||
"5601${cmd.format()}0000"
|
|
||||||
}
|
|
||||||
|
|
||||||
private encapSequence(commands, delay=200) {
|
|
||||||
delayBetween(commands.collect{ encap(it) }, delay)
|
|
||||||
}
|
|
||||||
|
|
||||||
private encap(physicalgraph.zwave.Command cmd) {
|
|
||||||
def secureClasses = [0x25, 0x5A, 0x70, 0x85, 0x8E]
|
|
||||||
|
|
||||||
//todo: check if secure inclusion was successful
|
|
||||||
//if not do not send security-encapsulated command
|
|
||||||
if (secureClasses.find{ it == cmd.commandClassId }) {
|
|
||||||
secure(cmd)
|
|
||||||
} else {
|
|
||||||
crc16(cmd)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
159
smartapps/prune/influxdbshipper.src/influxdbshipper.groovy
Normal file
159
smartapps/prune/influxdbshipper.src/influxdbshipper.groovy
Normal file
@@ -0,0 +1,159 @@
|
|||||||
|
/**
|
||||||
|
* InfluxdbShipper
|
||||||
|
*
|
||||||
|
* Copyright 2016 Prune - prune@lecentre.net
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
|
||||||
|
* in compliance with the License. You may obtain a copy of the License at:
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed
|
||||||
|
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License
|
||||||
|
* for the specific language governing permissions and limitations under the License.
|
||||||
|
*
|
||||||
|
* Description :
|
||||||
|
* This application listen to sensors and send the result metric to an Influxdb 0.9.x or newer server.
|
||||||
|
* It is NOT compatible with Influxdb 0.8.x
|
||||||
|
*
|
||||||
|
* Check Influxdb docs at
|
||||||
|
* https://docs.influxdata.com/influxdb/v0.10/introduction/
|
||||||
|
*
|
||||||
|
* Usage :
|
||||||
|
* select sensors you want to monitor
|
||||||
|
* enter your InfluxDB URL with full informations :
|
||||||
|
*
|
||||||
|
* <host>:<port>
|
||||||
|
*
|
||||||
|
* Ex : www.myserver.ca:8086/write
|
||||||
|
*
|
||||||
|
* It is strongly encouraged to use HTTPS and a login/password as your Influxdb server need to be open to the world
|
||||||
|
*/
|
||||||
|
definition(
|
||||||
|
name: "InfluxdbShipper",
|
||||||
|
namespace: "Prune",
|
||||||
|
author: "Prune",
|
||||||
|
description: "stream metrics to Influxdb",
|
||||||
|
category: "My Apps",
|
||||||
|
iconUrl: "http://lkhill.com/wp/wp-content/uploads/2015/10/influxdb-logo.png",
|
||||||
|
iconX2Url: "http://lkhill.com/wp/wp-content/uploads/2015/10/influxdb-logo.png",
|
||||||
|
iconX3Url: "http://lkhill.com/wp/wp-content/uploads/2015/10/influxdb-logo.png")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
preferences {
|
||||||
|
section("Log devices...") {
|
||||||
|
input "temperatures", "capability.temperatureMeasurement", title: "Temperatures", required:false, multiple: true
|
||||||
|
input "humidity", "capability.relativeHumidityMeasurement", title: "Humidity", required:false, multiple: true
|
||||||
|
input "contacts", "capability.contactSensor", title: "Doors open/close", required: false, multiple: true
|
||||||
|
input "motions", "capability.motionSensor", title: "Motions", required: false, multiple: true
|
||||||
|
input "presence", "capability.presenceSensor", title: "Presence", required: false, multiple: true
|
||||||
|
input "switches", "capability.switch", title: "Switches", required: false, multiple: true
|
||||||
|
input "energy", "capability.energyMeter", title: "Energy", required: false, multiple: true
|
||||||
|
input "smoke", "capability.smokeDetector", title: "Smoke", required: false, multiple: true
|
||||||
|
}
|
||||||
|
|
||||||
|
section ("Influxdb URL...") {
|
||||||
|
input "influxdb_url", "text", title: "Influxdb URL"
|
||||||
|
input "influxdb_proto", "enum", title: "Protocol (http or https)", options: ["HTTP", "HTTPS"]
|
||||||
|
input "influxdb_db", "text", title: "Influxdb DB"
|
||||||
|
input "influxdb_login", "text", title: "Influxdb Login"
|
||||||
|
input "influxdb_password", "password", title: "Influxdb Password"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def installed() {
|
||||||
|
initialize()
|
||||||
|
}
|
||||||
|
|
||||||
|
def updated() {
|
||||||
|
unsubscribe()
|
||||||
|
initialize()
|
||||||
|
}
|
||||||
|
|
||||||
|
def initialize() {
|
||||||
|
/*subscribe(temperatures, "temperature", handleTemperatureEvent)
|
||||||
|
subscribe(contacts, "contact", handleContactEvent)
|
||||||
|
subscribe(accelerations, "acceleration", handleAccelerationEvent)
|
||||||
|
subscribe(motions, "motion", handleMotionEvent)
|
||||||
|
subscribe(presence, "presence", handlePresenceEvent)
|
||||||
|
subscribe(switches, "switch", handleSwitchEvent)
|
||||||
|
log.debug "Done subscribing to events"
|
||||||
|
*/
|
||||||
|
//log.debug "temperatures: ${temperatures[0].name} = ${temperatures[0].currentState("temperature").value}"
|
||||||
|
// Send data every 5 mins
|
||||||
|
runEvery5Minutes(updateCurrentStats)
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/*
|
||||||
|
Push data to Influx
|
||||||
|
*/
|
||||||
|
def updateCurrentStats() {
|
||||||
|
|
||||||
|
//log.debug "Logging to Influxdb ${influxdb_url}"
|
||||||
|
// Builds the URL that will be sent to Influxdb
|
||||||
|
def full_url = "${influxdb_proto}://${influxdb_url}/write?db=${influxdb_db}"
|
||||||
|
if (influxdb_login != "") {
|
||||||
|
full_url += "&u=${influxdb_login}&p=${influxdb_password}"
|
||||||
|
}
|
||||||
|
|
||||||
|
def full_body=""
|
||||||
|
temperatures.eachWithIndex{ val, idx ->
|
||||||
|
def sensorName = val.displayName.replaceAll(" ",'\\\\ ')
|
||||||
|
full_body += "temp,sensor=${sensorName} value=${val.currentState("temperature").value} \n"
|
||||||
|
}
|
||||||
|
contacts.eachWithIndex{ val, idx ->
|
||||||
|
def sensorName = val.displayName.replaceAll(" ",'\\\\ ')
|
||||||
|
// 0=closed, 1=open
|
||||||
|
def contactState = val.currentState("contact").value == "open" ? 1 : 0
|
||||||
|
full_body += "contact,sensor=${sensorName} value=${contactState} \n"
|
||||||
|
}
|
||||||
|
humidity.eachWithIndex{ val, idx ->
|
||||||
|
def sensorName = val.displayName.replaceAll(" ",'\\\\ ')
|
||||||
|
full_body += "humidity,sensor=${sensorName} value=${val.currentState("humidity").value} \n"
|
||||||
|
}
|
||||||
|
motions.eachWithIndex{ val, idx ->
|
||||||
|
def sensorName = val.displayName.replaceAll(" ",'\\\\ ')
|
||||||
|
// 0=no motion, 1=motion detected
|
||||||
|
def motionState = val.currentState("motion").value == "active" ? 1 : 0
|
||||||
|
full_body += "motion,sensor=${sensorName} value=${motionState} \n"
|
||||||
|
}
|
||||||
|
presence.eachWithIndex{ val, idx ->
|
||||||
|
def sensorName = val.displayName.replaceAll(" ",'\\\\ ')
|
||||||
|
// 0=no presence, 1=present
|
||||||
|
def presenceState = val.currentState("presence").value == "present" ? 1 : 0
|
||||||
|
full_body += "presence,sensor=${sensorName} value=${presenceState} \n"
|
||||||
|
}
|
||||||
|
switches.eachWithIndex{ val, idx ->
|
||||||
|
def sensorName = val.displayName.replaceAll(" ",'\\\\ ')
|
||||||
|
// 0=off, 1=on
|
||||||
|
def switchState = val.currentState("switch").value == "on" ? 1 : 0
|
||||||
|
full_body += "switch,sensor=${sensorName} value=${switchState} \n"
|
||||||
|
}
|
||||||
|
energy.eachWithIndex{ val, idx ->
|
||||||
|
def sensorName = val.displayName.replaceAll(" ",'\\\\ ')
|
||||||
|
full_body += "energy,sensor=${sensorName} value=${val.currentState("energy").value} \n"
|
||||||
|
}
|
||||||
|
smoke.eachWithIndex{ val, idx ->
|
||||||
|
def sensorName = val.displayName.replaceAll(" ",'\\\\ ')
|
||||||
|
// 0="clear" 1="detected" 2="tested"
|
||||||
|
def smokeState = val.currentState("smoke").value == "detected" ? 1 : 0
|
||||||
|
full_body += "smoke,sensor=${sensorName} value=${smokeState} \n"
|
||||||
|
}
|
||||||
|
def params = [
|
||||||
|
uri: full_url,
|
||||||
|
body: full_body
|
||||||
|
]
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Make the HTTP request using httpGet()
|
||||||
|
log.debug "Calling $params"
|
||||||
|
httpPost(params) { resp -> // This is how we define the "return data". Can also use $it.
|
||||||
|
log.debug "response data: ${resp.data}"
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
log.error "something went wrong: $e"
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user