mirror of
https://github.com/mtan93/SmartThingsPublic.git
synced 2026-03-08 05:31:56 +00:00
MSA-1933: Power Meter
This commit is contained in:
Craig Bomben
@@ -0,0 +1,166 @@
|
||||
/**
|
||||
* Aeon HEM - Xively
|
||||
*
|
||||
* Copyright 2014 Dan Anghelescu
|
||||
*
|
||||
* 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.
|
||||
*
|
||||
*
|
||||
*
|
||||
* Genesys: Based off of Aeon Smart Meter Code sample provided by SmartThings (2013-05-30), Aeon Home Energy Meter v2 by Barry A. Burke, and Xively Logger by Patrick Stuart Built on US model
|
||||
* may also work on international versions (currently reports total values only)
|
||||
*/
|
||||
|
||||
|
||||
// Automatically generated. Make future change here.
|
||||
definition (
|
||||
name: "Aeon HEM - Xively",
|
||||
namespace: "smartthings",
|
||||
author: "Dan Anghelescu",
|
||||
description: "Aeon HEM - Xively Logger",
|
||||
category: "My Apps",
|
||||
iconUrl: "https://graph.api.smartthings.com/api/devices/icons/st.Electronics.electronics13-icn?displaySize",
|
||||
iconX2Url: "https://graph.api.smartthings.com/api/devices/icons/st.Electronics.electronics13-icn?displaySize=2x")
|
||||
|
||||
preferences {
|
||||
section("Log devices...") {
|
||||
input "energymeters", "capability.EnergyMeter", title: "Energy Meter", required: false, multiple: true
|
||||
input "thermostats", "capability.thermostat", title: "Thermostat", required: false, multiple: true
|
||||
input "weatherstations", "capability.temperatureMeasurement", title: "Outside Temperature", required: false, multiple: true
|
||||
|
||||
}
|
||||
|
||||
section ("Xively Info") {
|
||||
input "xi_apikey", "text", title: "Xively API Key"
|
||||
input "xi_feed", "number", title: "Xively Feed ID"
|
||||
}
|
||||
}
|
||||
|
||||
def installed() {
|
||||
initialize()
|
||||
}
|
||||
|
||||
def updated() {
|
||||
unsubscribe()
|
||||
|
||||
initialize()
|
||||
}
|
||||
|
||||
def initialize() {
|
||||
state.clear()
|
||||
unschedule(checkSensors)
|
||||
schedule("0 */5 * * * ?", "checkSensors")
|
||||
subscribe(app, appTouch)
|
||||
}
|
||||
|
||||
def appTouch(evt) {
|
||||
log.debug "appTouch: $evt"
|
||||
checkSensors()
|
||||
}
|
||||
|
||||
|
||||
|
||||
def checkSensors() {
|
||||
|
||||
def logitems = []
|
||||
for (t in settings.energymeters) {
|
||||
logitems.add([t.displayName, "energymeter.energy", t.latestValue("energy"), "KilowattHours", "kWh"] )
|
||||
state[t.displayName + ".energy"] = t.latestValue("energy")
|
||||
}
|
||||
for (t in settings.thermostats) {
|
||||
logitems.add([t.displayName, "inside.temperature", t.latestValue("temperature"), "Farenheight", "°F"] )
|
||||
state[t.displayName + ".temperature"] = t.latestValue("temperature")
|
||||
|
||||
/*
|
||||
if ( t.currentValue("thermostatOperatingState") == "cooling") {
|
||||
logitems.add([t.displayName, "thermostatState", 1 ])
|
||||
state[t.displayName + ".thermostatOperatingState"] = 1
|
||||
}
|
||||
if ( t.currentValue("thermostatOperatingState") == "heating") {
|
||||
logitems.add([t.displayName, "thermostatState", 2 ])
|
||||
state[t.displayName + ".thermostatOperatingState"] = 2
|
||||
}
|
||||
if ( t.currentValue("thermostatOperatingState") == "idle") {
|
||||
logitems.add([t.displayName, "thermostatState", 0 ])
|
||||
state[t.displayName + ".thermostatOperatingState"] = 0
|
||||
}
|
||||
*/
|
||||
}
|
||||
for (t in settings.energymeters) {
|
||||
logitems.add([t.displayName, "energymeter.power", t.latestValue("power"), "Watts", "W"] )
|
||||
state[t.displayName + ".power"] = t.latestValue("power")
|
||||
}
|
||||
for (t in settings.energymeters) {
|
||||
logitems.add([t.displayName, "energymeter.volts", t.latestValue("volts"), "Volts", "V"] )
|
||||
state[t.displayName + ".volts"] = t.latestValue("volts")
|
||||
}
|
||||
for (t in settings.energymeters) {
|
||||
logitems.add([t.displayName, "energymeter.amps", t.latestValue("amps"), "Amps", "A"] )
|
||||
state[t.displayName + ".amps"] = t.latestValue("amps")
|
||||
}
|
||||
for (t in settings.weatherstations) {
|
||||
logitems.add([t.displayName, "outside.temperature", t.latestValue("temperature"), "Farenheight", "°F"] )
|
||||
state[t.displayName + ".temperature"] = t.latestValue("temperature")
|
||||
}
|
||||
logField2(logitems)
|
||||
|
||||
}
|
||||
|
||||
private getFieldMap(channelInfo) {
|
||||
def fieldMap = [:]
|
||||
channelInfo?.findAll { it.key?.startsWith("field") }.each { fieldMap[it.value?.trim()] = it.key }
|
||||
return fieldMap
|
||||
}
|
||||
|
||||
|
||||
private logField2(logItems) {
|
||||
def fieldvalues = ""
|
||||
log.debug logItems
|
||||
|
||||
|
||||
def xivelyinfo = ""
|
||||
logItems.eachWithIndex() { item, i ->
|
||||
def channelname = item[0].replace(" ","_") + "_" + item[1]
|
||||
xivelyinfo += "{\"id\":\"${channelname}\",\"current_value\":\"${item[2]}\",\"unit\":{\"label\":\"${item[3]}\",\"symbol\":\"${item[4]}\"}}"
|
||||
if (i.toInteger() + 1 < logItems.size())
|
||||
{
|
||||
xivelyinfo += ","
|
||||
}
|
||||
|
||||
}
|
||||
log.debug xivelyinfo
|
||||
def uri = "https://api.xively.com/v2/feeds/${xi_feed}.json"
|
||||
def json = "{\"version\":\"1.0.0\",\"datastreams\":[${xivelyinfo} ]}"
|
||||
|
||||
def headers = [
|
||||
"X-ApiKey" : "${xi_apikey}"
|
||||
]
|
||||
|
||||
def params = [
|
||||
uri: uri,
|
||||
headers: headers,
|
||||
body: json
|
||||
]
|
||||
log.debug params.body
|
||||
httpPutJson(params) {response -> parseHttpResponse(response)}
|
||||
}
|
||||
|
||||
def parseHttpResponse(response) {
|
||||
log.debug "HTTP Response: ${response}"
|
||||
}
|
||||
|
||||
def captureState(theDevice) {
|
||||
def deviceAttrValue = [:]
|
||||
for ( attr in theDevice.supportedAttributes ) {
|
||||
def attrName = "${attr}"
|
||||
def attrValue = theDevice.currentValue(attrName)
|
||||
deviceAttrValue[attrName] = attrValue
|
||||
}
|
||||
return deviceAttrValue
|
||||
}
|
||||
166
smartapps/smartthings/aeon-hem-xively.src/aeon-hem-xively.groovy
Normal file
166
smartapps/smartthings/aeon-hem-xively.src/aeon-hem-xively.groovy
Normal file
@@ -0,0 +1,166 @@
|
||||
/**
|
||||
* Aeon HEM - Xively
|
||||
*
|
||||
* Copyright 2014 Dan Anghelescu
|
||||
*
|
||||
* 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.
|
||||
*
|
||||
*
|
||||
*
|
||||
* Genesys: Based off of Aeon Smart Meter Code sample provided by SmartThings (2013-05-30), Aeon Home Energy Meter v2 by Barry A. Burke, and Xively Logger by Patrick Stuart Built on US model
|
||||
* may also work on international versions (currently reports total values only)
|
||||
*/
|
||||
|
||||
|
||||
// Automatically generated. Make future change here.
|
||||
definition (
|
||||
name: "Aeon HEM - Xively",
|
||||
namespace: "smartthings",
|
||||
author: "Dan Anghelescu",
|
||||
description: "Aeon HEM - Xively Logger",
|
||||
category: "My Apps",
|
||||
iconUrl: "https://graph.api.smartthings.com/api/devices/icons/st.Electronics.electronics13-icn?displaySize",
|
||||
iconX2Url: "https://graph.api.smartthings.com/api/devices/icons/st.Electronics.electronics13-icn?displaySize=2x")
|
||||
|
||||
preferences {
|
||||
section("Log devices...") {
|
||||
input "energymeters", "capability.EnergyMeter", title: "Energy Meter", required: false, multiple: true
|
||||
input "thermostats", "capability.thermostat", title: "Thermostat", required: false, multiple: true
|
||||
input "weatherstations", "capability.temperatureMeasurement", title: "Outside Temperature", required: false, multiple: true
|
||||
|
||||
}
|
||||
|
||||
section ("Xively Info") {
|
||||
input "xi_apikey", "text", title: "Xively API Key"
|
||||
input "xi_feed", "number", title: "Xively Feed ID"
|
||||
}
|
||||
}
|
||||
|
||||
def installed() {
|
||||
initialize()
|
||||
}
|
||||
|
||||
def updated() {
|
||||
unsubscribe()
|
||||
|
||||
initialize()
|
||||
}
|
||||
|
||||
def initialize() {
|
||||
state.clear()
|
||||
unschedule(checkSensors)
|
||||
schedule("0 */5 * * * ?", "checkSensors")
|
||||
subscribe(app, appTouch)
|
||||
}
|
||||
|
||||
def appTouch(evt) {
|
||||
log.debug "appTouch: $evt"
|
||||
checkSensors()
|
||||
}
|
||||
|
||||
|
||||
|
||||
def checkSensors() {
|
||||
|
||||
def logitems = []
|
||||
for (t in settings.energymeters) {
|
||||
logitems.add([t.displayName, "energymeter.energy", t.latestValue("energy"), "KilowattHours", "kWh"] )
|
||||
state[t.displayName + ".energy"] = t.latestValue("energy")
|
||||
}
|
||||
for (t in settings.thermostats) {
|
||||
logitems.add([t.displayName, "inside.temperature", t.latestValue("temperature"), "Farenheight", "°F"] )
|
||||
state[t.displayName + ".temperature"] = t.latestValue("temperature")
|
||||
|
||||
/*
|
||||
if ( t.currentValue("thermostatOperatingState") == "cooling") {
|
||||
logitems.add([t.displayName, "thermostatState", 1 ])
|
||||
state[t.displayName + ".thermostatOperatingState"] = 1
|
||||
}
|
||||
if ( t.currentValue("thermostatOperatingState") == "heating") {
|
||||
logitems.add([t.displayName, "thermostatState", 2 ])
|
||||
state[t.displayName + ".thermostatOperatingState"] = 2
|
||||
}
|
||||
if ( t.currentValue("thermostatOperatingState") == "idle") {
|
||||
logitems.add([t.displayName, "thermostatState", 0 ])
|
||||
state[t.displayName + ".thermostatOperatingState"] = 0
|
||||
}
|
||||
*/
|
||||
}
|
||||
for (t in settings.energymeters) {
|
||||
logitems.add([t.displayName, "energymeter.power", t.latestValue("power"), "Watts", "W"] )
|
||||
state[t.displayName + ".power"] = t.latestValue("power")
|
||||
}
|
||||
for (t in settings.energymeters) {
|
||||
logitems.add([t.displayName, "energymeter.volts", t.latestValue("volts"), "Volts", "V"] )
|
||||
state[t.displayName + ".volts"] = t.latestValue("volts")
|
||||
}
|
||||
for (t in settings.energymeters) {
|
||||
logitems.add([t.displayName, "energymeter.amps", t.latestValue("amps"), "Amps", "A"] )
|
||||
state[t.displayName + ".amps"] = t.latestValue("amps")
|
||||
}
|
||||
for (t in settings.weatherstations) {
|
||||
logitems.add([t.displayName, "outside.temperature", t.latestValue("temperature"), "Farenheight", "°F"] )
|
||||
state[t.displayName + ".temperature"] = t.latestValue("temperature")
|
||||
}
|
||||
logField2(logitems)
|
||||
|
||||
}
|
||||
|
||||
private getFieldMap(channelInfo) {
|
||||
def fieldMap = [:]
|
||||
channelInfo?.findAll { it.key?.startsWith("field") }.each { fieldMap[it.value?.trim()] = it.key }
|
||||
return fieldMap
|
||||
}
|
||||
|
||||
|
||||
private logField2(logItems) {
|
||||
def fieldvalues = ""
|
||||
log.debug logItems
|
||||
|
||||
|
||||
def xivelyinfo = ""
|
||||
logItems.eachWithIndex() { item, i ->
|
||||
def channelname = item[0].replace(" ","_") + "_" + item[1]
|
||||
xivelyinfo += "{\"id\":\"${channelname}\",\"current_value\":\"${item[2]}\",\"unit\":{\"label\":\"${item[3]}\",\"symbol\":\"${item[4]}\"}}"
|
||||
if (i.toInteger() + 1 < logItems.size())
|
||||
{
|
||||
xivelyinfo += ","
|
||||
}
|
||||
|
||||
}
|
||||
log.debug xivelyinfo
|
||||
def uri = "https://api.xively.com/v2/feeds/${xi_feed}.json"
|
||||
def json = "{\"version\":\"1.0.0\",\"datastreams\":[${xivelyinfo} ]}"
|
||||
|
||||
def headers = [
|
||||
"X-ApiKey" : "${xi_apikey}"
|
||||
]
|
||||
|
||||
def params = [
|
||||
uri: uri,
|
||||
headers: headers,
|
||||
body: json
|
||||
]
|
||||
log.debug params.body
|
||||
httpPutJson(params) {response -> parseHttpResponse(response)}
|
||||
}
|
||||
|
||||
def parseHttpResponse(response) {
|
||||
log.debug "HTTP Response: ${response}"
|
||||
}
|
||||
|
||||
def captureState(theDevice) {
|
||||
def deviceAttrValue = [:]
|
||||
for ( attr in theDevice.supportedAttributes ) {
|
||||
def attrName = "${attr}"
|
||||
def attrValue = theDevice.currentValue(attrName)
|
||||
deviceAttrValue[attrName] = attrValue
|
||||
}
|
||||
return deviceAttrValue
|
||||
}
|
||||
Reference in New Issue
Block a user