mirror of
https://github.com/mtan93/SmartThingsPublic.git
synced 2026-03-19 13:20:53 +00:00
Compare commits
5 Commits
PROD_2017.
...
MSA-1965-8
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0725580dae | ||
|
|
68f5cda945 | ||
|
|
da42ee63fb | ||
|
|
c58132a69e | ||
|
|
f069ea3087 |
@@ -103,7 +103,7 @@ metadata {
|
|||||||
}
|
}
|
||||||
|
|
||||||
valueTile("illuminance", "device.illuminance", inactiveLabel: false, width: 2, height: 2) {
|
valueTile("illuminance", "device.illuminance", inactiveLabel: false, width: 2, height: 2) {
|
||||||
state "illuminance", label:'${currentValue} ${unit}', unit:"lux"
|
state "illuminance", label:'${currentValue} lux', unit:""
|
||||||
}
|
}
|
||||||
|
|
||||||
valueTile("ultravioletIndex", "device.ultravioletIndex", inactiveLabel: false, width: 2, height: 2) {
|
valueTile("ultravioletIndex", "device.ultravioletIndex", inactiveLabel: false, width: 2, height: 2) {
|
||||||
@@ -410,4 +410,4 @@ private command(physicalgraph.zwave.Command cmd) {
|
|||||||
private commands(commands, delay=200) {
|
private commands(commands, delay=200) {
|
||||||
log.info "sending commands: ${commands}"
|
log.info "sending commands: ${commands}"
|
||||||
delayBetween(commands.collect{ command(it) }, delay)
|
delayBetween(commands.collect{ command(it) }, delay)
|
||||||
}
|
}
|
||||||
@@ -86,7 +86,7 @@ metadata {
|
|||||||
state "humidity", label:'${currentValue}% humidity', unit:""
|
state "humidity", label:'${currentValue}% humidity', unit:""
|
||||||
}
|
}
|
||||||
valueTile("illuminance", "device.illuminance", inactiveLabel: false, width: 2, height: 2) {
|
valueTile("illuminance", "device.illuminance", inactiveLabel: false, width: 2, height: 2) {
|
||||||
state "luminosity", label:'${currentValue} ${unit}', unit:"lux"
|
state "luminosity", label:'${currentValue} lux', unit:""
|
||||||
}
|
}
|
||||||
valueTile("battery", "device.battery", inactiveLabel: false, decoration: "flat", width: 2, height: 2) {
|
valueTile("battery", "device.battery", inactiveLabel: false, decoration: "flat", width: 2, height: 2) {
|
||||||
state "battery", label:'${currentValue}% battery', unit:""
|
state "battery", label:'${currentValue}% battery', unit:""
|
||||||
@@ -282,5 +282,4 @@ private secure(physicalgraph.zwave.Command cmd) {
|
|||||||
|
|
||||||
private secureSequence(commands, delay=200) {
|
private secureSequence(commands, delay=200) {
|
||||||
delayBetween(commands.collect{ secure(it) }, delay)
|
delayBetween(commands.collect{ secure(it) }, delay)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -79,7 +79,7 @@ metadata {
|
|||||||
state "humidity", label:'${currentValue}% humidity', unit:""
|
state "humidity", label:'${currentValue}% humidity', unit:""
|
||||||
}
|
}
|
||||||
valueTile("illuminance", "device.illuminance", inactiveLabel: false, width: 2, height: 2) {
|
valueTile("illuminance", "device.illuminance", inactiveLabel: false, width: 2, height: 2) {
|
||||||
state "luminosity", label:'${currentValue} ${unit}', unit:"lux"
|
state "luminosity", label:'${currentValue} lux', unit:""
|
||||||
}
|
}
|
||||||
valueTile("battery", "device.battery", inactiveLabel: false, decoration: "flat", width: 2, height: 2) {
|
valueTile("battery", "device.battery", inactiveLabel: false, decoration: "flat", width: 2, height: 2) {
|
||||||
state "battery", label:'${currentValue}% battery', unit:""
|
state "battery", label:'${currentValue}% battery', unit:""
|
||||||
@@ -193,4 +193,4 @@ def configure() {
|
|||||||
// set data reporting period to 5 minutes
|
// set data reporting period to 5 minutes
|
||||||
zwave.configurationV1.configurationSet(parameterNumber: 111, size: 4, scaledConfigurationValue: 300).format()
|
zwave.configurationV1.configurationSet(parameterNumber: 111, size: 4, scaledConfigurationValue: 300).format()
|
||||||
])
|
])
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,663 @@
|
|||||||
|
/**
|
||||||
|
* Copyright 2017 Stelpro
|
||||||
|
*
|
||||||
|
* 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.
|
||||||
|
*
|
||||||
|
* Stelpro Ki ZigBee Thermostat
|
||||||
|
*
|
||||||
|
* Author: Stelpro
|
||||||
|
*
|
||||||
|
* Date: 2017-05-08
|
||||||
|
*/
|
||||||
|
|
||||||
|
preferences {
|
||||||
|
section {
|
||||||
|
input("unitformat", "enum", title: "What unit format do you want your thermostat to display temperature?", options: ["Celsius", "Fahrenheit"], defaultValue: "Celsius", required: false, displayDuringSetup: false)
|
||||||
|
input("lock", "enum", title: "Do you want to lock your thermostat's physical keypad?", options: ["No", "Yes"], defaultValue: "No", required: false, displayDuringSetup: false)
|
||||||
|
input("heatdetails", "enum", title: "Do you want a detailed operating state notification?", options: ["No", "Yes"], defaultValue: "No", required: false, displayDuringSetup: true)
|
||||||
|
input("zipcode", "text", title: "ZipCode (Outdoor Temperature)", description: "[Do not use space](Blank = No Forecast)")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
metadata {
|
||||||
|
definition (name: "Stelpro Ki ZigBee Thermostat", namespace: "Stelpro", author: "Stelpro") {
|
||||||
|
capability "Thermostat"
|
||||||
|
capability "Temperature Measurement"
|
||||||
|
capability "Actuator"
|
||||||
|
capability "Polling"
|
||||||
|
capability "Refresh"
|
||||||
|
capability "Sensor"
|
||||||
|
capability "Configuration"
|
||||||
|
|
||||||
|
command "switchMode"
|
||||||
|
command "quickSetHeat"
|
||||||
|
command "quickSetOutTemp"
|
||||||
|
command "increaseHeatSetpoint"
|
||||||
|
command "decreaseHeatSetpoint"
|
||||||
|
command "parameterSetting"
|
||||||
|
|
||||||
|
fingerprint profileId: "0104", endpointId: "19", inClusters: " 0000,0003,0201,0204", outClusters: "0402"
|
||||||
|
}
|
||||||
|
|
||||||
|
// simulator metadata
|
||||||
|
simulator { }
|
||||||
|
|
||||||
|
tiles {
|
||||||
|
multiAttributeTile(name:"thermostatMulti", type:"thermostat", width:6, height:4) {
|
||||||
|
tileAttribute("device.temperature", key: "PRIMARY_CONTROL") {
|
||||||
|
attributeState("temp", label:'${currentValue}')
|
||||||
|
attributeState("high", label:'HIGH')
|
||||||
|
attributeState("low", label:'LOW')
|
||||||
|
attributeState("--", label:'--')
|
||||||
|
}
|
||||||
|
tileAttribute("device.heatingSetpoint", key: "VALUE_CONTROL") {
|
||||||
|
attributeState("VALUE_UP", action: "increaseHeatSetpoint")
|
||||||
|
attributeState("VALUE_DOWN", action: "decreaseHeatSetpoint")
|
||||||
|
}
|
||||||
|
tileAttribute("device.thermostatOperatingState", key: "OPERATING_STATE") {
|
||||||
|
attributeState("idle", backgroundColor:"#44b621")
|
||||||
|
attributeState("heating", backgroundColor:"#ffa81e")
|
||||||
|
}
|
||||||
|
tileAttribute("device.thermostatMode", key: "THERMOSTAT_MODE") {
|
||||||
|
attributeState("off", label:'Off')
|
||||||
|
attributeState("comfort", label:'Comfort')
|
||||||
|
attributeState("eco", label:'Eco')
|
||||||
|
}
|
||||||
|
tileAttribute("device.heatingSetpoint", key: "HEATING_SETPOINT")
|
||||||
|
{
|
||||||
|
attributeState("heatingSetpoint", label:'${currentValue}')
|
||||||
|
}
|
||||||
|
}
|
||||||
|
standardTile("mode", "device.thermostatMode", width: 2, height: 2) {
|
||||||
|
state "off", label:'Off', action:"switchMode", nextState:"comfort", icon:"st.thermostat.off"
|
||||||
|
state "comfort", label:'Comfort', action:"switchMode", nextState:"eco", icon:"http://cdn.device-icons.smartthings.com/Home/home29-icn@2x.png"
|
||||||
|
state "eco", label:'Eco', action:"switchMode", nextState:"off", icon:"http://cdn.device-icons.smartthings.com/Outdoor/outdoor3-icn@2x.png"
|
||||||
|
}
|
||||||
|
valueTile("heatingSetpoint", "device.heatingSetpoint", width: 2, height: 2) {
|
||||||
|
state "temperature", label:'Setpoint\n${currentValue}°', backgroundColors:[
|
||||||
|
[value: 31, color: "#153591"],
|
||||||
|
[value: 44, color: "#1e9cbb"],
|
||||||
|
[value: 59, color: "#90d2a7"],
|
||||||
|
[value: 74, color: "#44b621"],
|
||||||
|
[value: 84, color: "#f1d801"],
|
||||||
|
[value: 95, color: "#d04e00"],
|
||||||
|
[value: 96, color: "#bc2323"]
|
||||||
|
]
|
||||||
|
state "--", label:'--', backgroundColor:"#bdbdbd"
|
||||||
|
}
|
||||||
|
standardTile("refresh", "device.refresh", decoration: "flat", width: 2, height: 2) {
|
||||||
|
state "default", action:"poll", icon:"st.secondary.refresh"
|
||||||
|
}
|
||||||
|
standardTile("configure", "device.configure", inactiveLabel: false, decoration: "flat", width: 2, height: 2) {
|
||||||
|
state "configure", label:'', action:"configuration.configure", icon:"st.secondary.configure"
|
||||||
|
}
|
||||||
|
|
||||||
|
main ("thermostatMulti")
|
||||||
|
details(["thermostatMulti", "mode", "heatingSetpoint", "refresh", "configure"])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// parse events into attributes
|
||||||
|
def parse(String description) {
|
||||||
|
log.debug "Parse description $description"
|
||||||
|
def map = [:]
|
||||||
|
if (description?.startsWith("read attr -")) {
|
||||||
|
def descMap = parseDescriptionAsMap(description)
|
||||||
|
log.debug "Desc Map: $descMap"
|
||||||
|
if (descMap.cluster == "0201" && descMap.attrId == "0000")
|
||||||
|
{
|
||||||
|
log.debug "TEMP"
|
||||||
|
map.name = "temperature"
|
||||||
|
map.value = getTemperature(descMap.value)
|
||||||
|
if (descMap.value == "7ffd") //0x7FFD
|
||||||
|
{
|
||||||
|
map.value = "low"
|
||||||
|
}
|
||||||
|
else if (descMap.value == "7fff") //0x7FFF
|
||||||
|
{
|
||||||
|
map.value = "high"
|
||||||
|
}
|
||||||
|
else if (descMap.value == "8000") //0x8000
|
||||||
|
{
|
||||||
|
map.value = "--"
|
||||||
|
}
|
||||||
|
sendEvent(name:"temperature", value:map.value)
|
||||||
|
}
|
||||||
|
else if (descMap.cluster == "0201" && descMap.attrId == "0012")
|
||||||
|
{
|
||||||
|
log.debug "HEATING SETPOINT"
|
||||||
|
map.name = "heatingSetpoint"
|
||||||
|
map.value = getTemperature(descMap.value)
|
||||||
|
if (descMap.value == "8000") //0x8000
|
||||||
|
{
|
||||||
|
map.value = "--"
|
||||||
|
}
|
||||||
|
sendEvent(name:"heatingSetpoint", value:map.value)
|
||||||
|
}
|
||||||
|
else if (descMap.cluster == "0201" && descMap.attrId == "001c")
|
||||||
|
{
|
||||||
|
if (descMap.value.size() == 8)
|
||||||
|
{
|
||||||
|
log.debug "MODE"
|
||||||
|
map.name = "thermostatMode"
|
||||||
|
map.value = getModeMap()[descMap.value]
|
||||||
|
sendEvent(name:"thermostatMode", value:map.value)
|
||||||
|
}
|
||||||
|
else if (descMap.value.size() == 10)
|
||||||
|
{
|
||||||
|
log.debug "MODE & SETPOINT MODE"
|
||||||
|
def twoModesAttributes = descMap.value[0..-9]
|
||||||
|
map.name = "thermostatMode"
|
||||||
|
map.value = getModeMap()[twoModesAttributes]
|
||||||
|
sendEvent(name:"thermostatMode", value:map.value)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (descMap.cluster == "0201" && descMap.attrId == "401c")
|
||||||
|
{
|
||||||
|
log.debug "SETPOINT MODE"
|
||||||
|
log.debug "descMap.value $descMap.value"
|
||||||
|
map.name = "thermostatMode"
|
||||||
|
map.value = getModeMap()[descMap.value]
|
||||||
|
sendEvent(name:"thermostatMode", value:map.value)
|
||||||
|
}
|
||||||
|
else if (descMap.cluster == "0201" && descMap.attrId == "0008")
|
||||||
|
{
|
||||||
|
log.debug "HEAT DEMAND"
|
||||||
|
map.name = "thermostatOperatingState"
|
||||||
|
map.value = getModeMap()[descMap.value]
|
||||||
|
if (map.value == "off")
|
||||||
|
{
|
||||||
|
map.value = "idle"
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
map.value = "heating"
|
||||||
|
}
|
||||||
|
sendEvent(name:"thermostatOperatingState", value:map.value)
|
||||||
|
if (settings.heatdetails == "No")
|
||||||
|
{
|
||||||
|
map.displayed = false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def result = null
|
||||||
|
if (map) {
|
||||||
|
result = createEvent(map)
|
||||||
|
}
|
||||||
|
log.debug "Parse returned $map"
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
|
||||||
|
def parseDescriptionAsMap(description) {
|
||||||
|
(description - "read attr - ").split(",").inject([:]) { map, param ->
|
||||||
|
def nameAndValue = param.split(":")
|
||||||
|
map += [(nameAndValue[0].trim()):nameAndValue[1].trim()]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def getModeMap() { [
|
||||||
|
"00":"off",
|
||||||
|
"04":"comfort",
|
||||||
|
"05":"eco"
|
||||||
|
]}
|
||||||
|
|
||||||
|
def getFanModeMap() { [
|
||||||
|
"04":"fanOn",
|
||||||
|
"05":"fanAuto"
|
||||||
|
]}
|
||||||
|
|
||||||
|
def poll() {
|
||||||
|
def weather
|
||||||
|
// If there is a zipcode defined, weather forecast will be sent. Otherwise, no weather forecast.
|
||||||
|
if (settings.zipcode) {
|
||||||
|
log.debug "ZipCode: ${settings.zipcode}"
|
||||||
|
weather = getWeatherFeature( "conditions", settings.zipcode )
|
||||||
|
|
||||||
|
// Check if the variable is populated, otherwise return.
|
||||||
|
if (!weather) {
|
||||||
|
log.debug( "Something went wrong, no data found." )
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
// Set the tiles
|
||||||
|
def locationScale = getTemperatureScale()
|
||||||
|
def tempToSend
|
||||||
|
log.debug( "Outdoor Temperature: ${weather.current_observation.temp_c}ºC" )
|
||||||
|
sendEvent( name: 'outsideTemp', value: weather.current_observation.temp_c )
|
||||||
|
tempToSend = weather.current_observation.temp_c
|
||||||
|
|
||||||
|
delayBetween([
|
||||||
|
quickSetOutTemp(tempToSend),
|
||||||
|
zigbee.readAttribute(0x201, 0x0000), //Read Local Temperature
|
||||||
|
zigbee.readAttribute(0x201, 0x0008), //Read PI Heating State
|
||||||
|
zigbee.readAttribute(0x201, 0x0012), //Read Heat Setpoint
|
||||||
|
zigbee.readAttribute(0x201, 0x001C), //Read System Mode
|
||||||
|
my_readAttribute(0x201, 0x401C, ["mfgCode": "0x1185"]), //Read Manufacturer Specific Setpoint Mode
|
||||||
|
zigbee.readAttribute(0x204, 0x0000), //Read Temperature Display Mode
|
||||||
|
zigbee.readAttribute(0x204, 0x0001), //Read Keypad Lockout
|
||||||
|
sendEvent( name: 'change', value: 0 )
|
||||||
|
], 200)
|
||||||
|
} else {
|
||||||
|
delayBetween([
|
||||||
|
zigbee.readAttribute(0x201, 0x0000), //Read Local Temperature
|
||||||
|
zigbee.readAttribute(0x201, 0x0008), //Read PI Heating State
|
||||||
|
zigbee.readAttribute(0x201, 0x0012), //Read Heat Setpoint
|
||||||
|
zigbee.readAttribute(0x201, 0x001C), //Read System Mode
|
||||||
|
my_readAttribute(0x201, 0x401C, ["mfgCode": "0x1185"]), //Read Manufacturer Specific Setpoint Mode
|
||||||
|
zigbee.readAttribute(0x204, 0x0000), //Read Temperature Display Mode
|
||||||
|
zigbee.readAttribute(0x204, 0x0001), //Read Keypad Lockout
|
||||||
|
sendEvent( name: 'change', value: 0 )
|
||||||
|
], 200)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def getTemperature(value) {
|
||||||
|
if (value != null) {
|
||||||
|
log.debug("value $value")
|
||||||
|
def celsius = Integer.parseInt(value, 16) / 100
|
||||||
|
if (getTemperatureScale() == "C") {
|
||||||
|
return celsius
|
||||||
|
} else {
|
||||||
|
return Math.round(celsiusToFahrenheit(celsius))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def quickSetHeat(degrees) {
|
||||||
|
sendEvent( name: 'change', value: 1 )
|
||||||
|
setHeatingSetpoint(degrees)
|
||||||
|
}
|
||||||
|
|
||||||
|
def setHeatingSetpoint(degrees) {
|
||||||
|
if (degrees != null) {
|
||||||
|
def temperatureScale = getTemperatureScale()
|
||||||
|
def degreesInteger = Math.round(degrees)
|
||||||
|
float tempfloat;
|
||||||
|
tempfloat = (Math.round(degrees.toFloat() * 2)) / 2
|
||||||
|
|
||||||
|
log.debug "setHeatingSetpoint({$tempfloat} ${temperatureScale})"
|
||||||
|
sendEvent("name": "heatingSetpoint", "value": tempfloat)
|
||||||
|
def celsius = (getTemperatureScale() == "C") ? tempfloat : (fahrenheitToCelsius(tempfloat) as Float).round(2)
|
||||||
|
delayBetween([
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 0x19 0x201 0x12 0x29 {" + hex(celsius * 100) + "}",
|
||||||
|
zigbee.readAttribute(0x201, 0x12), //Read Heat Setpoint
|
||||||
|
], 100)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def setCoolingSetpoint(degrees) {
|
||||||
|
if (degrees != null) {
|
||||||
|
def degreesInteger = Math.round(degrees)
|
||||||
|
log.debug "setCoolingSetpoint({$degreesInteger} ${temperatureScale})"
|
||||||
|
sendEvent("name": "coolingSetpoint", "value": degreesInteger)
|
||||||
|
def celsius = (getTemperatureScale() == "C") ? degreesInteger : (fahrenheitToCelsius(degreesInteger) as Double).round(2)
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 0x19 0x201 0x11 0x29 {" + hex(celsius * 100) + "}"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def quickSetOutTemp(degrees) {
|
||||||
|
setOutdoorTemperature(degrees, 0)
|
||||||
|
}
|
||||||
|
|
||||||
|
def setOutdoorTemperature(degrees, delay = 0) {
|
||||||
|
setOutdoorTemperature(degrees.toDouble(), delay)
|
||||||
|
}
|
||||||
|
|
||||||
|
def setOutdoorTemperature(Double degrees, Integer delay = 0) {
|
||||||
|
def deviceScale
|
||||||
|
def locationScale = getTemperatureScale()
|
||||||
|
def p = (state.precision == null) ? 1 : state.precision
|
||||||
|
Integer tempToSend
|
||||||
|
def tempToSendInString
|
||||||
|
|
||||||
|
if (locationScale == "C")
|
||||||
|
{
|
||||||
|
deviceScale = 0
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
deviceScale = 1
|
||||||
|
}
|
||||||
|
|
||||||
|
if (degrees < 0)
|
||||||
|
{
|
||||||
|
tempToSend = -degrees*100 - 65536
|
||||||
|
tempToSend = -tempToSend
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
tempToSend = (degrees*100)
|
||||||
|
}
|
||||||
|
|
||||||
|
tempToSendInString = zigbee.convertToHexString(tempToSend, 4)
|
||||||
|
my_writeAttribute(0x201, 0x4001, 0x29, tempToSendInString, ["mfgCode": "0x1185"])
|
||||||
|
}
|
||||||
|
|
||||||
|
def increaseHeatSetpoint()
|
||||||
|
{
|
||||||
|
def currentMode = device.currentState("thermostatMode")?.value
|
||||||
|
if (currentMode != "off")
|
||||||
|
{
|
||||||
|
float currentSetpoint = device.currentValue("heatingSetpoint")
|
||||||
|
def locationScale = getTemperatureScale()
|
||||||
|
float maxSetpoint
|
||||||
|
float step
|
||||||
|
|
||||||
|
if (locationScale == "C")
|
||||||
|
{
|
||||||
|
maxSetpoint = 30;
|
||||||
|
step = 0.5
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
maxSetpoint = 86
|
||||||
|
step = 1
|
||||||
|
}
|
||||||
|
|
||||||
|
if (currentSetpoint < maxSetpoint)
|
||||||
|
{
|
||||||
|
currentSetpoint = currentSetpoint + step
|
||||||
|
quickSetHeat(currentSetpoint)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def decreaseHeatSetpoint()
|
||||||
|
{
|
||||||
|
def currentMode = device.currentState("thermostatMode")?.value
|
||||||
|
if (currentMode != "off")
|
||||||
|
{
|
||||||
|
float currentSetpoint = device.currentValue("heatingSetpoint")
|
||||||
|
def locationScale = getTemperatureScale()
|
||||||
|
float minSetpoint
|
||||||
|
float step
|
||||||
|
|
||||||
|
if (locationScale == "C")
|
||||||
|
{
|
||||||
|
minSetpoint = 5;
|
||||||
|
step = 0.5
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
minSetpoint = 41
|
||||||
|
step = 1
|
||||||
|
}
|
||||||
|
|
||||||
|
if (currentSetpoint > minSetpoint)
|
||||||
|
{
|
||||||
|
currentSetpoint = currentSetpoint - step
|
||||||
|
quickSetHeat(currentSetpoint)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def modes() {
|
||||||
|
["comfort", "eco", "off"]
|
||||||
|
}
|
||||||
|
|
||||||
|
def switchMode() {
|
||||||
|
def currentMode = device.currentState("thermostatMode")?.value
|
||||||
|
def lastTriedMode = state.lastTriedMode ?: currentMode ?: "comfort"
|
||||||
|
def modeOrder = modes()
|
||||||
|
def next = { modeOrder[modeOrder.indexOf(it) + 1] ?: modeOrder[0] }
|
||||||
|
def nextMode = next(currentMode)
|
||||||
|
def modeNumber;
|
||||||
|
Integer setpointModeNumber;
|
||||||
|
def modeToSendInString;
|
||||||
|
|
||||||
|
if (nextMode == "comfort")
|
||||||
|
{
|
||||||
|
modeNumber = 04
|
||||||
|
setpointModeNumber = 04
|
||||||
|
}
|
||||||
|
else if (nextMode == "eco")
|
||||||
|
{
|
||||||
|
modeNumber = 04
|
||||||
|
setpointModeNumber = 05
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
modeNumber = 00
|
||||||
|
setpointModeNumber = 00
|
||||||
|
}
|
||||||
|
if (supportedModes?.contains(currentMode)) {
|
||||||
|
while (!supportedModes.contains(nextMode) && nextMode != "comfort") {
|
||||||
|
nextMode = next(nextMode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
state.lastTriedMode = nextMode
|
||||||
|
modeToSendInString = zigbee.convertToHexString(setpointModeNumber, 2)
|
||||||
|
delayBetween([
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 0x19 0x201 0x001C 0x30 {$modeNumber}",
|
||||||
|
my_writeAttribute(0x201, 0x401C, 0x30, modeToSendInString, ["mfgCode": "0x1185"]),
|
||||||
|
poll()
|
||||||
|
], 1000)
|
||||||
|
}
|
||||||
|
|
||||||
|
def setThermostatMode() {
|
||||||
|
log.debug "switching thermostatMode"
|
||||||
|
def currentMode = device.currentState("thermostatMode")?.value
|
||||||
|
def modeOrder = modes()
|
||||||
|
def index = modeOrder.indexOf(currentMode)
|
||||||
|
def next = index >= 0 && index < modeOrder.size() - 1 ? modeOrder[index + 1] : modeOrder[0]
|
||||||
|
log.debug "switching mode from $currentMode to $next"
|
||||||
|
"$next"()
|
||||||
|
}
|
||||||
|
|
||||||
|
def setThermostatFanMode() {
|
||||||
|
log.debug "Switching fan mode"
|
||||||
|
def currentFanMode = device.currentState("thermostatFanMode")?.value
|
||||||
|
log.debug "switching fan from current mode: $currentFanMode"
|
||||||
|
def returnCommand
|
||||||
|
|
||||||
|
switch (currentFanMode) {
|
||||||
|
case "fanAuto":
|
||||||
|
returnCommand = fanOn()
|
||||||
|
break
|
||||||
|
case "fanOn":
|
||||||
|
returnCommand = fanAuto()
|
||||||
|
break
|
||||||
|
}
|
||||||
|
if(!currentFanMode) { returnCommand = fanAuto() }
|
||||||
|
returnCommand
|
||||||
|
}
|
||||||
|
|
||||||
|
def setThermostatMode(String value) {
|
||||||
|
log.debug "setThermostatMode({$value})"
|
||||||
|
"$value"()
|
||||||
|
}
|
||||||
|
|
||||||
|
def setThermostatFanMode(String value) {
|
||||||
|
log.debug "setThermostatFanMode({$value})"
|
||||||
|
"$value"()
|
||||||
|
}
|
||||||
|
|
||||||
|
def off() {
|
||||||
|
log.debug "off"
|
||||||
|
sendEvent("name":"thermostatMode", "value":"off")
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 0x19 0x201 0x1C 0x30 {00}"
|
||||||
|
}
|
||||||
|
|
||||||
|
def cool() {
|
||||||
|
log.debug "cool"
|
||||||
|
sendEvent("name":"thermostatMode", "value":"cool")
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 0x19 0x201 0x1C 0x30 {03}"
|
||||||
|
}
|
||||||
|
|
||||||
|
def heat() {
|
||||||
|
log.debug "heat"
|
||||||
|
sendEvent("name":"thermostatMode", "value":"heat")
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 0x19 0x201 0x1C 0x30 {04}"
|
||||||
|
}
|
||||||
|
|
||||||
|
def emergencyHeat() {
|
||||||
|
log.debug "emergencyHeat"
|
||||||
|
sendEvent("name":"thermostatMode", "value":"emergency heat")
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 0x19 0x201 0x1C 0x30 {05}"
|
||||||
|
}
|
||||||
|
|
||||||
|
def on() {
|
||||||
|
fanOn()
|
||||||
|
}
|
||||||
|
|
||||||
|
def fanOn() {
|
||||||
|
log.debug "fanOn"
|
||||||
|
sendEvent("name":"thermostatFanMode", "value":"fanOn")
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 0x19 0x202 0 0x30 {04}"
|
||||||
|
}
|
||||||
|
|
||||||
|
def auto() {
|
||||||
|
fanAuto()
|
||||||
|
}
|
||||||
|
|
||||||
|
def fanAuto() {
|
||||||
|
log.debug "fanAuto"
|
||||||
|
sendEvent("name":"thermostatFanMode", "value":"fanAuto")
|
||||||
|
"st wattr 0x${device.deviceNetworkId} 1 0x202 0 0x30 {05}"
|
||||||
|
}
|
||||||
|
|
||||||
|
def configure() {
|
||||||
|
log.debug "binding to Thermostat cluster"
|
||||||
|
delayBetween([
|
||||||
|
"zdo bind 0x${device.deviceNetworkId} 1 0x19 0x201 {${device.zigbeeId}} {}",
|
||||||
|
//Cluster ID (0x0201 = Thermostat Cluster), Attribute ID, Data Type, Payload (Min report, Max report, On change trigger)
|
||||||
|
zigbee.configureReporting(0x0201, 0x0000, 0x29, 10, 60, 50), //Attribute ID 0x0000 = local temperature, Data Type: S16BIT
|
||||||
|
zigbee.configureReporting(0x0201, 0x0012, 0x29, 1, 0, 50), //Attribute ID 0x0012 = occupied heat setpoint, Data Type: S16BIT
|
||||||
|
zigbee.configureReporting(0x0201, 0x001C, 0x30, 1, 0, 1), //Attribute ID 0x001C = system mode, Data Type: 8 bits enum
|
||||||
|
zigbee.configureReporting(0x0201, 0x401C, 0x30, 1, 0, 1), //Attribute ID 0x401C = manufacturer specific setpoint mode, Data Type: 8 bits enum
|
||||||
|
zigbee.configureReporting(0x0201, 0x0008, 0x20, 300, 900, 5), //Attribute ID 0x0008 = pi heating demand, Data Type: U8BIT
|
||||||
|
|
||||||
|
//Cluster ID (0x0204 = Thermostat Ui Conf Cluster), Attribute ID, Data Type, Payload (Min report, Max report, On change trigger)
|
||||||
|
zigbee.configureReporting(0x0204, 0x0000, 0x30, 1, 0, 1), //Attribute ID 0x0000 = temperature display mode, Data Type: 8 bits enum
|
||||||
|
zigbee.configureReporting(0x0204, 0x0001, 0x30, 1, 0, 1), //Attribute ID 0x0001 = keypad lockout, Data Type: 8 bits enum
|
||||||
|
|
||||||
|
//Read the configured variables
|
||||||
|
zigbee.readAttribute(0x201, 0x0000), //Read Local Temperature
|
||||||
|
zigbee.readAttribute(0x201, 0x0012), //Read Heat Setpoint
|
||||||
|
zigbee.readAttribute(0x201, 0x001C), //Read System Mode
|
||||||
|
my_readAttribute(0x201, 0x401C, ["mfgCode": "0x1185"]), //Read Manufacturer Specific Setpoint Mode
|
||||||
|
zigbee.readAttribute(0x201, 0x0008), //Read PI Heating State
|
||||||
|
zigbee.readAttribute(0x204, 0x0000), //Read Temperature Display Mode
|
||||||
|
zigbee.readAttribute(0x204, 0x0001), //Read Keypad Lockout
|
||||||
|
], 200)
|
||||||
|
}
|
||||||
|
|
||||||
|
def updated() {
|
||||||
|
log.debug "updated called"
|
||||||
|
response(parameterSetting())
|
||||||
|
}
|
||||||
|
|
||||||
|
def parameterSetting() {
|
||||||
|
def format = null
|
||||||
|
def lockmode = null
|
||||||
|
def valid_format = 0
|
||||||
|
def valid_lock = 0
|
||||||
|
|
||||||
|
log.info "unitformat : $settings.unitformat"
|
||||||
|
if (settings.unitformat == "Celsius") {
|
||||||
|
format = 0x00
|
||||||
|
valid_format = 1
|
||||||
|
}
|
||||||
|
else if (settings.unitformat == "Fahrenheit") {
|
||||||
|
format = 0x01
|
||||||
|
valid_format = 1
|
||||||
|
}
|
||||||
|
|
||||||
|
log.info "lock : $settings.lock"
|
||||||
|
if (settings.lock == "Yes") {
|
||||||
|
lockmode = 0x01
|
||||||
|
valid_lock = 1
|
||||||
|
}
|
||||||
|
else if (settings.lock == "No") {
|
||||||
|
lockmode = 0x00
|
||||||
|
valid_lock = 1
|
||||||
|
}
|
||||||
|
if ((valid_format == 1) && (valid_lock == 1))
|
||||||
|
{
|
||||||
|
log.info "both valid"
|
||||||
|
delayBetween([
|
||||||
|
zigbee.writeAttribute(0x204, 0x00, 0x30, format), //Write Unit Format Mode
|
||||||
|
zigbee.writeAttribute(0x204, 0x01, 0x30, lockmode), //Write Lock Mode
|
||||||
|
poll(),
|
||||||
|
], 200)
|
||||||
|
}
|
||||||
|
else if (valid_format == 1)
|
||||||
|
{
|
||||||
|
log.info "format valid"
|
||||||
|
delayBetween([
|
||||||
|
zigbee.writeAttribute(0x204, 0x00, 0x30, format), //Write Unit Format Mode
|
||||||
|
poll(),
|
||||||
|
], 200)
|
||||||
|
}
|
||||||
|
else if (valid_lock == 1)
|
||||||
|
{
|
||||||
|
log.info "lock valid"
|
||||||
|
delayBetween([
|
||||||
|
zigbee.writeAttribute(0x204, 0x01, 0x30, lockmode), //Write Lock Mode
|
||||||
|
poll(),
|
||||||
|
], 200)
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
log.info "nothing valid"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private hex(value) {
|
||||||
|
new BigInteger(Math.round(value).toString()).toString(16)
|
||||||
|
}
|
||||||
|
|
||||||
|
private getEndpointId() {
|
||||||
|
new BigInteger(device.endpointId, 16).toString()
|
||||||
|
}
|
||||||
|
|
||||||
|
private String swapEndianHex(String hex) {
|
||||||
|
reverseArray(hex.decodeHex()).encodeHex()
|
||||||
|
}
|
||||||
|
|
||||||
|
private byte[] reverseArray(byte[] array) {
|
||||||
|
int i = 0;
|
||||||
|
int j = array.length - 1;
|
||||||
|
byte tmp;
|
||||||
|
while (j > i) {
|
||||||
|
tmp = array[j];
|
||||||
|
array[j] = array[i];
|
||||||
|
array[i] = tmp;
|
||||||
|
j--;
|
||||||
|
i++;
|
||||||
|
}
|
||||||
|
return array
|
||||||
|
}
|
||||||
|
|
||||||
|
def my_readAttribute(cluster, attributeId, Map additional=null)
|
||||||
|
{
|
||||||
|
if (additional?.get("mfgCode")) {
|
||||||
|
[ "zcl mfg-code ${additional['mfgCode']}", "delay 200",
|
||||||
|
"zcl global read ${cluster} ${attributeId}", "delay 200",
|
||||||
|
"send 0x${device.deviceNetworkId} 1 ${endpointId}" ]
|
||||||
|
} else {
|
||||||
|
zigbee.readAttribute(cluster, attributeId)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
def my_writeAttribute(cluster, attributeId, dataType, value, Map additional=null)
|
||||||
|
{
|
||||||
|
value = swapEndianHex(value)
|
||||||
|
if (additional ?.get("mfgCode")) {
|
||||||
|
[ "zcl mfg-code ${additional['mfgCode']}", "delay 200",
|
||||||
|
"zcl global write ${cluster} ${attributeId} ${dataType} {${value}}", "delay 200",
|
||||||
|
"send 0x${device.deviceNetworkId} 1 ${endpointId}" ]
|
||||||
|
} else {
|
||||||
|
zigbee.writeAttribute(cluster, attributeId, dataType, value)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@@ -1,7 +1,3 @@
|
|||||||
import javax.crypto.Mac;
|
|
||||||
import javax.crypto.spec.SecretKeySpec;
|
|
||||||
import java.security.InvalidKeyException;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* OpenT2T SmartApp Test
|
* OpenT2T SmartApp Test
|
||||||
*
|
*
|
||||||
@@ -43,7 +39,7 @@ definition(
|
|||||||
* garageDoors | door | open, close | unknown, closed, open, closing, opening
|
* garageDoors | door | open, close | unknown, closed, open, closing, opening
|
||||||
* cameras | image | take | <String>
|
* cameras | image | take | <String>
|
||||||
* thermostats | thermostat | setHeatingSetpoint, | temperature, heatingSetpoint, coolingSetpoint,
|
* thermostats | thermostat | setHeatingSetpoint, | temperature, heatingSetpoint, coolingSetpoint,
|
||||||
* | | setCoolingSetpoint, | thermostatSetpoint, thermostatMode,
|
* | | setCoolingSetpoint, | thermostatSetpoint, thermostatMode,
|
||||||
* | | off, heat, cool, auto,| thermostatFanMode, thermostatOperatingState
|
* | | off, heat, cool, auto,| thermostatFanMode, thermostatOperatingState
|
||||||
* | | emergencyHeat, |
|
* | | emergencyHeat, |
|
||||||
* | | setThermostatMode, |
|
* | | setThermostatMode, |
|
||||||
@@ -59,7 +55,7 @@ preferences {
|
|||||||
input "contactSensors", "capability.contactSensor", title: "Which Contact Sensors", multiple: true, required: false, hideWhenEmpty: true
|
input "contactSensors", "capability.contactSensor", title: "Which Contact Sensors", multiple: true, required: false, hideWhenEmpty: true
|
||||||
input "garageDoors", "capability.garageDoorControl", title: "Which Garage Doors?", multiple: true, required: false, hideWhenEmpty: true
|
input "garageDoors", "capability.garageDoorControl", title: "Which Garage Doors?", multiple: true, required: false, hideWhenEmpty: true
|
||||||
input "locks", "capability.lock", title: "Which Locks?", multiple: true, required: false, hideWhenEmpty: true
|
input "locks", "capability.lock", title: "Which Locks?", multiple: true, required: false, hideWhenEmpty: true
|
||||||
input "cameras", "capability.videoCapture", title: "Which Cameras?", multiple: true, required: false, hideWhenEmpty: true
|
input "cameras", "capability.videoCapture", title: "Which Cameras?", multiple: true, required: false, hideWhenEmpty: true
|
||||||
input "motionSensors", "capability.motionSensor", title: "Which Motion Sensors?", multiple: true, required: false, hideWhenEmpty: true
|
input "motionSensors", "capability.motionSensor", title: "Which Motion Sensors?", multiple: true, required: false, hideWhenEmpty: true
|
||||||
input "presenceSensors", "capability.presenceSensor", title: "Which Presence Sensors", multiple: true, required: false, hideWhenEmpty: true
|
input "presenceSensors", "capability.presenceSensor", title: "Which Presence Sensors", multiple: true, required: false, hideWhenEmpty: true
|
||||||
input "switches", "capability.switch", title: "Which Switches and Lights?", multiple: true, required: false, hideWhenEmpty: true
|
input "switches", "capability.switch", title: "Which Switches and Lights?", multiple: true, required: false, hideWhenEmpty: true
|
||||||
@@ -70,49 +66,44 @@ preferences {
|
|||||||
|
|
||||||
def getInputs() {
|
def getInputs() {
|
||||||
def inputList = []
|
def inputList = []
|
||||||
inputList += contactSensors ?: []
|
inputList += contactSensors?: []
|
||||||
inputList += garageDoors ?: []
|
inputList += garageDoors?: []
|
||||||
inputList += locks ?: []
|
inputList += locks?: []
|
||||||
inputList += cameras ?: []
|
inputList += cameras?: []
|
||||||
inputList += motionSensors ?: []
|
inputList += motionSensors?: []
|
||||||
inputList += presenceSensors ?: []
|
inputList += presenceSensors?: []
|
||||||
inputList += switches ?: []
|
inputList += switches?: []
|
||||||
inputList += thermostats ?: []
|
inputList += thermostats?: []
|
||||||
inputList += waterSensors ?: []
|
inputList += waterSensors?: []
|
||||||
return inputList
|
return inputList
|
||||||
}
|
}
|
||||||
|
|
||||||
//API external Endpoints
|
//API external Endpoints
|
||||||
mappings {
|
mappings {
|
||||||
path("/devices") {
|
path("/devices") {
|
||||||
action:
|
action: [
|
||||||
[
|
|
||||||
GET: "getDevices"
|
GET: "getDevices"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
path("/devices/:id") {
|
path("/devices/:id") {
|
||||||
action:
|
action: [
|
||||||
[
|
|
||||||
GET: "getDevice"
|
GET: "getDevice"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
path("/update/:id") {
|
path("/update/:id") {
|
||||||
action:
|
action: [
|
||||||
[
|
|
||||||
PUT: "updateDevice"
|
PUT: "updateDevice"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
path("/deviceSubscription") {
|
path("/deviceSubscription") {
|
||||||
action:
|
action: [
|
||||||
[
|
POST: "registerDeviceChange",
|
||||||
POST : "registerDeviceChange",
|
|
||||||
DELETE: "unregisterDeviceChange"
|
DELETE: "unregisterDeviceChange"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
path("/locationSubscription") {
|
path("/locationSubscription") {
|
||||||
action:
|
action: [
|
||||||
[
|
POST: "registerDeviceGraph",
|
||||||
POST : "registerDeviceGraph",
|
|
||||||
DELETE: "unregisterDeviceGraph"
|
DELETE: "unregisterDeviceGraph"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
@@ -125,21 +116,14 @@ def installed() {
|
|||||||
|
|
||||||
def updated() {
|
def updated() {
|
||||||
log.debug "Updating with settings: ${settings}"
|
log.debug "Updating with settings: ${settings}"
|
||||||
|
if(state.deviceSubscriptionMap == null){
|
||||||
//Initialize state variables if didn't exist.
|
|
||||||
if (state.deviceSubscriptionMap == null) {
|
|
||||||
state.deviceSubscriptionMap = [:]
|
state.deviceSubscriptionMap = [:]
|
||||||
log.debug "deviceSubscriptionMap created."
|
log.debug "deviceSubscriptionMap created."
|
||||||
}
|
}
|
||||||
if (state.locationSubscriptionMap == null) {
|
if( state.locationSubscriptionMap == null){
|
||||||
state.locationSubscriptionMap = [:]
|
state.locationSubscriptionMap = [:]
|
||||||
log.debug "locationSubscriptionMap created."
|
log.debug "locationSubscriptionMap created."
|
||||||
}
|
}
|
||||||
if (state.verificationKeyMap == null) {
|
|
||||||
state.verificationKeyMap = [:]
|
|
||||||
log.debug "verificationKeyMap created."
|
|
||||||
}
|
|
||||||
|
|
||||||
unsubscribe()
|
unsubscribe()
|
||||||
registerAllDeviceSubscriptions()
|
registerAllDeviceSubscriptions()
|
||||||
}
|
}
|
||||||
@@ -148,11 +132,9 @@ def initialize() {
|
|||||||
log.debug "Initializing with settings: ${settings}"
|
log.debug "Initializing with settings: ${settings}"
|
||||||
state.deviceSubscriptionMap = [:]
|
state.deviceSubscriptionMap = [:]
|
||||||
log.debug "deviceSubscriptionMap created."
|
log.debug "deviceSubscriptionMap created."
|
||||||
|
registerAllDeviceSubscriptions()
|
||||||
state.locationSubscriptionMap = [:]
|
state.locationSubscriptionMap = [:]
|
||||||
log.debug "locationSubscriptionMap created."
|
log.debug "locationSubscriptionMap created."
|
||||||
state.verificationKeyMap = [:]
|
|
||||||
log.debug "verificationKeyMap created."
|
|
||||||
registerAllDeviceSubscriptions()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/*** Subscription Functions ***/
|
/*** Subscription Functions ***/
|
||||||
@@ -162,43 +144,47 @@ def registerAllDeviceSubscriptions() {
|
|||||||
registerChangeHandler(inputs)
|
registerChangeHandler(inputs)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//Subscribe to events from a list of devices
|
||||||
|
def registerChangeHandler(myList) {
|
||||||
|
myList.each { myDevice ->
|
||||||
|
def theAtts = myDevice.supportedAttributes
|
||||||
|
theAtts.each {att ->
|
||||||
|
subscribe(myDevice, att.name, deviceEventHandler)
|
||||||
|
log.info "Registering for ${myDevice.displayName}.${att.name}"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
//Endpoints function: Subscribe to events from a specific device
|
//Endpoints function: Subscribe to events from a specific device
|
||||||
def registerDeviceChange() {
|
def registerDeviceChange() {
|
||||||
def subscriptionEndpt = params.subscriptionURL
|
def subscriptionEndpt = params.subscriptionURL
|
||||||
def deviceId = params.deviceId
|
def deviceId = params.deviceId
|
||||||
def myDevice = findDevice(deviceId)
|
def myDevice = findDevice(deviceId)
|
||||||
|
if( myDevice == null ){
|
||||||
if (myDevice == null) {
|
|
||||||
httpError(404, "Cannot find device with device ID ${deviceId}.")
|
httpError(404, "Cannot find device with device ID ${deviceId}.")
|
||||||
}
|
}
|
||||||
|
|
||||||
def theAtts = myDevice.supportedAttributes
|
def theAtts = myDevice.supportedAttributes
|
||||||
try {
|
try {
|
||||||
theAtts.each { att ->
|
theAtts.each {att ->
|
||||||
subscribe(myDevice, att.name, deviceEventHandler)
|
subscribe(myDevice, att.name, deviceEventHandler)
|
||||||
}
|
}
|
||||||
log.info "Subscribing for ${myDevice.displayName}"
|
log.info "Subscribing for ${myDevice.displayName}"
|
||||||
|
|
||||||
if (subscriptionEndpt != null) {
|
if(subscriptionEndpt != null){
|
||||||
if (state.deviceSubscriptionMap[deviceId] == null) {
|
if(state.deviceSubscriptionMap[deviceId] == null){
|
||||||
state.deviceSubscriptionMap.put(deviceId, [subscriptionEndpt])
|
state.deviceSubscriptionMap.put(deviceId, [subscriptionEndpt])
|
||||||
log.info "Added subscription URL: ${subscriptionEndpt} for ${myDevice.displayName}"
|
log.info "Added subscription URL: ${subscriptionEndpt} for ${myDevice.displayName}"
|
||||||
} else if (!state.deviceSubscriptionMap[deviceId].contains(subscriptionEndpt)) {
|
} else if (!state.deviceSubscriptionMap[deviceId].contains(subscriptionEndpt)){
|
||||||
state.deviceSubscriptionMap[deviceId] << subscriptionEndpt
|
state.deviceSubscriptionMap[deviceId] << subscriptionEndpt
|
||||||
log.info "Added subscription URL: ${subscriptionEndpt} for ${myDevice.displayName}"
|
log.info "Added subscription URL: ${subscriptionEndpt} for ${myDevice.displayName}"
|
||||||
}
|
}
|
||||||
|
|
||||||
if (params.key != null) {
|
|
||||||
state.verificationKeyMap[subscriptionEndpt] = params.key
|
|
||||||
log.info "Added verification key: ${params.key} for ${subscriptionEndpt}"
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
httpError(500, "something went wrong: $e")
|
httpError(500, "something went wrong: $e")
|
||||||
}
|
}
|
||||||
|
|
||||||
log.info "Current subscription map is ${state.deviceSubscriptionMap}"
|
log.info "Current subscription map is ${state.deviceSubscriptionMap}"
|
||||||
log.info "Current verification key map is ${state.verificationKeyMap}"
|
|
||||||
return ["succeed"]
|
return ["succeed"]
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -208,19 +194,18 @@ def unregisterDeviceChange() {
|
|||||||
def deviceId = params.deviceId
|
def deviceId = params.deviceId
|
||||||
def myDevice = findDevice(deviceId)
|
def myDevice = findDevice(deviceId)
|
||||||
|
|
||||||
if (myDevice == null) {
|
if( myDevice == null ){
|
||||||
httpError(404, "Cannot find device with device ID ${deviceId}.")
|
httpError(404, "Cannot find device with device ID ${deviceId}.")
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if (subscriptionEndpt != null && subscriptionEndpt != "undefined") {
|
if(subscriptionEndpt != null && subscriptionEndpt != "undefined"){
|
||||||
if (state.deviceSubscriptionMap[deviceId]?.contains(subscriptionEndpt)) {
|
if (state.deviceSubscriptionMap[deviceId]?.contains(subscriptionEndpt)){
|
||||||
if (state.deviceSubscriptionMap[deviceId].size() == 1) {
|
if(state.deviceSubscriptionMap[deviceId].size() == 1){
|
||||||
state.deviceSubscriptionMap.remove(deviceId)
|
state.deviceSubscriptionMap.remove(deviceId)
|
||||||
} else {
|
} else {
|
||||||
state.deviceSubscriptionMap[deviceId].remove(subscriptionEndpt)
|
state.deviceSubscriptionMap[deviceId].remove(subscriptionEndpt)
|
||||||
}
|
}
|
||||||
state.verificationKeyMap.remove(subscriptionEndpt)
|
|
||||||
log.info "Removed subscription URL: ${subscriptionEndpt} for ${myDevice.displayName}"
|
log.info "Removed subscription URL: ${subscriptionEndpt} for ${myDevice.displayName}"
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
@@ -232,33 +217,25 @@ def unregisterDeviceChange() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
log.info "Current subscription map is ${state.deviceSubscriptionMap}"
|
log.info "Current subscription map is ${state.deviceSubscriptionMap}"
|
||||||
log.info "Current verification key map is ${state.verificationKeyMap}"
|
|
||||||
}
|
}
|
||||||
|
|
||||||
//Endpoints function: Subscribe to device additiona/removal updated in a location
|
//Endpoints function: Subscribe to device additiona/removal updated in a location
|
||||||
def registerDeviceGraph() {
|
def registerDeviceGraph() {
|
||||||
def subscriptionEndpt = params.subscriptionURL
|
def subscriptionEndpt = params.subscriptionURL
|
||||||
|
|
||||||
if (subscriptionEndpt != null && subscriptionEndpt != "undefined") {
|
if (subscriptionEndpt != null && subscriptionEndpt != "undefined"){
|
||||||
subscribe(location, "DeviceCreated", locationEventHandler, [filterEvents: false])
|
subscribe(location, "DeviceCreated", locationEventHandler, [filterEvents: false])
|
||||||
subscribe(location, "DeviceUpdated", locationEventHandler, [filterEvents: false])
|
subscribe(location, "DeviceUpdated", locationEventHandler, [filterEvents: false])
|
||||||
subscribe(location, "DeviceDeleted", locationEventHandler, [filterEvents: false])
|
subscribe(location, "DeviceDeleted", locationEventHandler, [filterEvents: false])
|
||||||
|
|
||||||
if (state.locationSubscriptionMap[location.id] == null) {
|
if(state.locationSubscriptionMap[location.id] == null){
|
||||||
state.locationSubscriptionMap.put(location.id, [subscriptionEndpt])
|
state.locationSubscriptionMap.put(location.id, [subscriptionEndpt])
|
||||||
log.info "Added subscription URL: ${subscriptionEndpt} for Location ${location.name}"
|
log.info "Added subscription URL: ${subscriptionEndpt} for Location ${location.name}"
|
||||||
} else if (!state.locationSubscriptionMap[location.id].contains(subscriptionEndpt)) {
|
} else if (!state.locationSubscriptionMap[location.id].contains(subscriptionEndpt)){
|
||||||
state.locationSubscriptionMap[location.id] << subscriptionEndpt
|
state.locationSubscriptionMap[location.id] << subscriptionEndpt
|
||||||
log.info "Added subscription URL: ${subscriptionEndpt} for Location ${location.name}"
|
log.info "Added subscription URL: ${subscriptionEndpt} for Location ${location.name}"
|
||||||
}
|
}
|
||||||
|
|
||||||
if (params.key != null) {
|
|
||||||
state.verificationKeyMap[subscriptionEndpt] = params.key
|
|
||||||
log.info "Added verification key: ${params.key} for ${subscriptionEndpt}"
|
|
||||||
}
|
|
||||||
|
|
||||||
log.info "Current location subscription map is ${state.locationSubscriptionMap}"
|
log.info "Current location subscription map is ${state.locationSubscriptionMap}"
|
||||||
log.info "Current verification key map is ${state.verificationKeyMap}"
|
|
||||||
return ["succeed"]
|
return ["succeed"]
|
||||||
} else {
|
} else {
|
||||||
httpError(400, "missing input parameter: subscriptionURL")
|
httpError(400, "missing input parameter: subscriptionURL")
|
||||||
@@ -270,17 +247,16 @@ def unregisterDeviceGraph() {
|
|||||||
def subscriptionEndpt = params.subscriptionURL
|
def subscriptionEndpt = params.subscriptionURL
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if (subscriptionEndpt != null && subscriptionEndpt != "undefined") {
|
if(subscriptionEndpt != null && subscriptionEndpt != "undefined"){
|
||||||
if (state.locationSubscriptionMap[location.id]?.contains(subscriptionEndpt)) {
|
if (state.locationSubscriptionMap[location.id]?.contains(subscriptionEndpt)){
|
||||||
if (state.locationSubscriptionMap[location.id].size() == 1) {
|
if(state.locationSubscriptionMap[location.id].size() == 1){
|
||||||
state.locationSubscriptionMap.remove(location.id)
|
state.locationSubscriptionMap.remove(location.id)
|
||||||
} else {
|
} else {
|
||||||
state.locationSubscriptionMap[location.id].remove(subscriptionEndpt)
|
state.locationSubscriptionMap[location.id].remove(subscriptionEndpt)
|
||||||
}
|
}
|
||||||
state.verificationKeyMap.remove(subscriptionEndpt)
|
|
||||||
log.info "Removed subscription URL: ${subscriptionEndpt} for Location ${location.name}"
|
log.info "Removed subscription URL: ${subscriptionEndpt} for Location ${location.name}"
|
||||||
}
|
}
|
||||||
} else {
|
}else{
|
||||||
httpError(400, "missing input parameter: subscriptionURL")
|
httpError(400, "missing input parameter: subscriptionURL")
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
@@ -288,40 +264,28 @@ def unregisterDeviceGraph() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
log.info "Current location subscription map is ${state.locationSubscriptionMap}"
|
log.info "Current location subscription map is ${state.locationSubscriptionMap}"
|
||||||
log.info "Current verification key map is ${state.verificationKeyMap}"
|
|
||||||
}
|
}
|
||||||
|
|
||||||
//When events are triggered, send HTTP post to web socket servers
|
//When events are triggered, send HTTP post to web socket servers
|
||||||
def deviceEventHandler(evt) {
|
def deviceEventHandler(evt) {
|
||||||
def evtDevice = evt.device
|
def evt_device = evt.device
|
||||||
def evtDeviceType = getDeviceType(evtDevice)
|
def evt_deviceType = getDeviceType(evt_device)
|
||||||
def deviceData = [];
|
def deviceInfo
|
||||||
|
|
||||||
if (evt.data != null) {
|
def params = [ body: [deviceName: evt_device.displayName, deviceId: evt_device.id, locationId: location.id] ]
|
||||||
|
|
||||||
|
if(evt.data != null){
|
||||||
def evtData = parseJson(evt.data)
|
def evtData = parseJson(evt.data)
|
||||||
log.info "Received event for ${evtDevice.displayName}, data: ${evtData}, description: ${evt.descriptionText}"
|
log.info "Received event for ${evt_device.displayName}, data: ${evtData}, description: ${evt.descriptionText}"
|
||||||
}
|
}
|
||||||
|
|
||||||
if (evtDeviceType == "thermostat") {
|
|
||||||
deviceData = [name: evtDevice.displayName, id: evtDevice.id, status: evtDevice.status, deviceType: evtDeviceType, manufacturer: evtDevice.manufacturerName, model: evtDevice.modelName, attributes: deviceAttributeList(evtDevice, evtDeviceType), locationMode: getLocationModeInfo(), locationId: location.id]
|
|
||||||
} else {
|
|
||||||
deviceData = [name: evtDevice.displayName, id: evtDevice.id, status: evtDevice.status, deviceType: evtDeviceType, manufacturer: evtDevice.manufacturerName, model: evtDevice.modelName, attributes: deviceAttributeList(evtDevice, evtDeviceType), locationId: location.id]
|
|
||||||
}
|
|
||||||
|
|
||||||
def params = [body: deviceData]
|
|
||||||
|
|
||||||
//send event to all subscriptions urls
|
//send event to all subscriptions urls
|
||||||
log.debug "Current subscription urls for ${evtDevice.displayName} is ${state.deviceSubscriptionMap[evtDevice.id]}"
|
log.debug "Current subscription urls for ${evt_device.displayName} is ${state.deviceSubscriptionMap[evt_device.id]}"
|
||||||
state.deviceSubscriptionMap[evtDevice.id].each {
|
state.deviceSubscriptionMap[evt_device.id].each {
|
||||||
params.uri = "${it}"
|
params.uri = "${it}"
|
||||||
if (state.verificationKeyMap[it] != null) {
|
|
||||||
def key = state.verificationKeyMap[it]
|
|
||||||
params.header = [Signature: ComputHMACValue(key, groovy.json.JsonOutput.toJson(params.body))]
|
|
||||||
}
|
|
||||||
log.trace "POST URI: ${params.uri}"
|
log.trace "POST URI: ${params.uri}"
|
||||||
log.trace "Header: ${params.header}"
|
|
||||||
log.trace "Payload: ${params.body}"
|
log.trace "Payload: ${params.body}"
|
||||||
try {
|
try{
|
||||||
httpPostJson(params) { resp ->
|
httpPostJson(params) { resp ->
|
||||||
log.trace "response status code: ${resp.status}"
|
log.trace "response status code: ${resp.status}"
|
||||||
log.trace "response data: ${resp.data}"
|
log.trace "response data: ${resp.data}"
|
||||||
@@ -334,27 +298,20 @@ def deviceEventHandler(evt) {
|
|||||||
|
|
||||||
def locationEventHandler(evt) {
|
def locationEventHandler(evt) {
|
||||||
log.info "Received event for location ${location.name}/${location.id}, Event: ${evt.name}, description: ${evt.descriptionText}, apiServerUrl: ${apiServerUrl("")}"
|
log.info "Received event for location ${location.name}/${location.id}, Event: ${evt.name}, description: ${evt.descriptionText}, apiServerUrl: ${apiServerUrl("")}"
|
||||||
switch (evt.name) {
|
switch(evt.name){
|
||||||
case "DeviceCreated":
|
case "DeviceCreated":
|
||||||
case "DeviceDeleted":
|
case "DeviceDeleted":
|
||||||
def evtDevice = evt.device
|
def evt_device = evt.device
|
||||||
def evtDeviceType = getDeviceType(evtDevice)
|
def evt_deviceType = getDeviceType(evt_device)
|
||||||
def params = [body: [eventType: evt.name, deviceId: evtDevice.id, locationId: location.id]]
|
log.info "DeviceName: ${evt_device.displayName}, DeviceID: ${evt_device.id}, deviceType: ${evt_deviceType}"
|
||||||
|
|
||||||
if (evt.name == "DeviceDeleted" && state.deviceSubscriptionMap[deviceId] != null) {
|
def params = [ body: [ eventType:evt.name, deviceId: evt_device.id, locationId: location.id ] ]
|
||||||
state.deviceSubscriptionMap.remove(evtDevice.id)
|
|
||||||
}
|
|
||||||
|
|
||||||
state.locationSubscriptionMap[location.id].each {
|
state.locationSubscriptionMap[location.id].each {
|
||||||
params.uri = "${it}"
|
params.uri = "${it}"
|
||||||
if (state.verificationKeyMap[it] != null) {
|
|
||||||
def key = state.verificationKeyMap[it]
|
|
||||||
params.header = [Signature: ComputHMACValue(key, groovy.json.JsonOutput.toJson(params.body))]
|
|
||||||
}
|
|
||||||
log.trace "POST URI: ${params.uri}"
|
log.trace "POST URI: ${params.uri}"
|
||||||
log.trace "Header: ${params.header}"
|
|
||||||
log.trace "Payload: ${params.body}"
|
log.trace "Payload: ${params.body}"
|
||||||
try {
|
try{
|
||||||
httpPostJson(params) { resp ->
|
httpPostJson(params) { resp ->
|
||||||
log.trace "response status code: ${resp.status}"
|
log.trace "response status code: ${resp.status}"
|
||||||
log.trace "response data: ${resp.data}"
|
log.trace "response data: ${resp.data}"
|
||||||
@@ -369,23 +326,6 @@ def locationEventHandler(evt) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private ComputHMACValue(key, data) {
|
|
||||||
try {
|
|
||||||
SecretKeySpec secretKeySpec = new SecretKeySpec(key.getBytes("UTF-8"), "HmacSHA1")
|
|
||||||
Mac mac = Mac.getInstance("HmacSHA1")
|
|
||||||
mac.init(secretKeySpec)
|
|
||||||
byte[] digest = mac.doFinal(data.getBytes("UTF-8"))
|
|
||||||
return byteArrayToString(digest)
|
|
||||||
} catch (InvalidKeyException e) {
|
|
||||||
log.error "Invalid key exception while converting to HMac SHA1"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private def byteArrayToString(byte[] data) {
|
|
||||||
BigInteger bigInteger = new BigInteger(1, data)
|
|
||||||
String hash = bigInteger.toString(16)
|
|
||||||
return hash
|
|
||||||
}
|
|
||||||
|
|
||||||
/*** Device Query/Update Functions ***/
|
/*** Device Query/Update Functions ***/
|
||||||
|
|
||||||
@@ -394,10 +334,10 @@ def getDevices() {
|
|||||||
def deviceData = []
|
def deviceData = []
|
||||||
inputs?.each {
|
inputs?.each {
|
||||||
def deviceType = getDeviceType(it)
|
def deviceType = getDeviceType(it)
|
||||||
if (deviceType == "thermostat") {
|
if(deviceType == "thermostat") {
|
||||||
deviceData << [name: it.displayName, id: it.id, status: it.status, deviceType: deviceType, manufacturer: it.manufacturerName, model: it.modelName, attributes: deviceAttributeList(it, deviceType), locationMode: getLocationModeInfo()]
|
deviceData << [name: it.displayName, id: it.id, status:it.status, deviceType:deviceType, manufacturer:it.manufacturerName, model:it.modelName, attributes: deviceAttributeList(it, deviceType), locationMode: getLocationModeInfo()]
|
||||||
} else {
|
} else {
|
||||||
deviceData << [name: it.displayName, id: it.id, status: it.status, deviceType: deviceType, manufacturer: it.manufacturerName, model: it.modelName, attributes: deviceAttributeList(it, deviceType)]
|
deviceData << [name: it.displayName, id: it.id, status:it.status, deviceType:deviceType, manufacturer:it.manufacturerName, model:it.modelName, attributes: deviceAttributeList(it, deviceType)]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -410,10 +350,10 @@ def getDevice() {
|
|||||||
def it = findDevice(params.id)
|
def it = findDevice(params.id)
|
||||||
def deviceType = getDeviceType(it)
|
def deviceType = getDeviceType(it)
|
||||||
def device
|
def device
|
||||||
if (deviceType == "thermostat") {
|
if(deviceType == "thermostat") {
|
||||||
device = [name: it.displayName, id: it.id, status: it.status, deviceType: deviceType, manufacturer: it.manufacturerName, model: it.modelName, attributes: deviceAttributeList(it, deviceType), locationMode: getLocationModeInfo()]
|
device = [name: it.displayName, id: it.id, status:it.status, deviceType:deviceType, manufacturer:it.manufacturerName, model:it.modelName, attributes: deviceAttributeList(it,deviceType), locationMode: getLocationModeInfo()]
|
||||||
} else {
|
} else {
|
||||||
device = [name: it.displayName, id: it.id, status: it.status, deviceType: deviceType, manufacturer: it.manufacturerName, model: it.modelName, attributes: deviceAttributeList(it, deviceType)]
|
device = [name: it.displayName, id: it.id, status:it.status, deviceType:deviceType, manufacturer:it.manufacturerName, model:it.modelName, attributes: deviceAttributeList(it, deviceType)]
|
||||||
}
|
}
|
||||||
|
|
||||||
log.debug "getDevice, return: ${device}"
|
log.debug "getDevice, return: ${device}"
|
||||||
@@ -426,18 +366,18 @@ void updateDevice() {
|
|||||||
request.JSON.each {
|
request.JSON.each {
|
||||||
def command = it.key
|
def command = it.key
|
||||||
def value = it.value
|
def value = it.value
|
||||||
if (command) {
|
if (command){
|
||||||
def commandList = mapDeviceCommands(command, value)
|
def commandList = mapDeviceCommands(command, value)
|
||||||
command = commandList[0]
|
command = commandList[0]
|
||||||
value = commandList[1]
|
value = commandList[1]
|
||||||
|
|
||||||
if (command == "setAwayMode") {
|
if (command == "setAwayMode") {
|
||||||
log.info "Setting away mode to ${value}"
|
log.info "Setting away mode to ${value}"
|
||||||
if (location.modes?.find { it.name == value }) {
|
if (location.modes?.find {it.name == value}) {
|
||||||
location.setMode(value)
|
location.setMode(value)
|
||||||
}
|
}
|
||||||
} else if (command == "thermostatSetpoint") {
|
}else if (command == "thermostatSetpoint"){
|
||||||
switch (device.currentThermostatMode) {
|
switch(device.currentThermostatMode){
|
||||||
case "cool":
|
case "cool":
|
||||||
log.info "Update: ${device.displayName}, [${command}, ${value}]"
|
log.info "Update: ${device.displayName}, [${command}, ${value}]"
|
||||||
device.setCoolingSetpoint(value)
|
device.setCoolingSetpoint(value)
|
||||||
@@ -451,7 +391,7 @@ void updateDevice() {
|
|||||||
httpError(501, "this mode: ${device.currentThermostatMode} does not allow changing thermostat setpoint.")
|
httpError(501, "this mode: ${device.currentThermostatMode} does not allow changing thermostat setpoint.")
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
} else if (!device) {
|
}else if (!device) {
|
||||||
log.error "updateDevice, Device not found"
|
log.error "updateDevice, Device not found"
|
||||||
httpError(404, "Device not found")
|
httpError(404, "Device not found")
|
||||||
} else if (!device.hasCommand(command)) {
|
} else if (!device.hasCommand(command)) {
|
||||||
@@ -461,11 +401,11 @@ void updateDevice() {
|
|||||||
if (command == "setColor") {
|
if (command == "setColor") {
|
||||||
log.info "Update: ${device.displayName}, [${command}, ${value}]"
|
log.info "Update: ${device.displayName}, [${command}, ${value}]"
|
||||||
device."$command"(hex: value)
|
device."$command"(hex: value)
|
||||||
} else if (value.isNumber()) {
|
} else if(value.isNumber()) {
|
||||||
def intValue = value as Integer
|
def intValue = value as Integer
|
||||||
log.info "Update: ${device.displayName}, [${command}, ${intValue}(int)]"
|
log.info "Update: ${device.displayName}, [${command}, ${intValue}(int)]"
|
||||||
device."$command"(intValue)
|
device."$command"(intValue)
|
||||||
} else if (value) {
|
} else if (value){
|
||||||
log.info "Update: ${device.displayName}, [${command}, ${value}]"
|
log.info "Update: ${device.displayName}, [${command}, ${value}]"
|
||||||
device."$command"(value)
|
device."$command"(value)
|
||||||
} else {
|
} else {
|
||||||
@@ -492,16 +432,17 @@ private getDeviceType(device) {
|
|||||||
log.debug "supported commands: [${device}, ${device.supportedCommands}]"
|
log.debug "supported commands: [${device}, ${device.supportedCommands}]"
|
||||||
|
|
||||||
//Loop through the device capability list to determine the device type.
|
//Loop through the device capability list to determine the device type.
|
||||||
capabilities.each { capability ->
|
capabilities.each {capability ->
|
||||||
switch (capability.name.toLowerCase()) {
|
switch(capability.name.toLowerCase())
|
||||||
|
{
|
||||||
case "switch":
|
case "switch":
|
||||||
deviceType = "switch"
|
deviceType = "switch"
|
||||||
|
|
||||||
//If the device also contains "Switch Level" capability, identify it as a "light" device.
|
//If the device also contains "Switch Level" capability, identify it as a "light" device.
|
||||||
if (capabilities.any { it.name.toLowerCase() == "switch level" }) {
|
if (capabilities.any{it.name.toLowerCase() == "switch level"}){
|
||||||
|
|
||||||
//If the device also contains "Power Meter" capability, identify it as a "dimmerSwitch" device.
|
//If the device also contains "Power Meter" capability, identify it as a "dimmerSwitch" device.
|
||||||
if (capabilities.any { it.name.toLowerCase() == "power meter" }) {
|
if (capabilities.any{it.name.toLowerCase() == "power meter"}){
|
||||||
deviceType = "dimmerSwitch"
|
deviceType = "dimmerSwitch"
|
||||||
return deviceType
|
return deviceType
|
||||||
} else {
|
} else {
|
||||||
@@ -548,24 +489,24 @@ private deviceAttributeList(device, deviceType) {
|
|||||||
allAttributes.each { attribute ->
|
allAttributes.each { attribute ->
|
||||||
try {
|
try {
|
||||||
def currentState = device.currentState(attribute.name)
|
def currentState = device.currentState(attribute.name)
|
||||||
if (currentState != null) {
|
if(currentState != null ){
|
||||||
switch (attribute.name) {
|
switch(attribute.name){
|
||||||
case 'temperature':
|
case 'temperature':
|
||||||
attributeList.putAll([(attribute.name): currentState.value, 'temperatureScale': location.temperatureScale])
|
attributeList.putAll([ (attribute.name): currentState.value, 'temperatureScale':location.temperatureScale ])
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
attributeList.putAll([(attribute.name): currentState.value])
|
attributeList.putAll([(attribute.name): currentState.value ])
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
if (deviceType == "genericSensor") {
|
if( deviceType == "genericSensor" ){
|
||||||
def key = attribute.name + "_lastUpdated"
|
def key = attribute.name + "_lastUpdated"
|
||||||
attributeList.putAll([(key): currentState.isoDate])
|
attributeList.putAll([ (key): currentState.isoDate ])
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
attributeList.putAll([(attribute.name): null]);
|
attributeList.putAll([ (attribute.name): null ]);
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch(e) {
|
||||||
attributeList.putAll([(attribute.name): null]);
|
attributeList.putAll([ (attribute.name): null ]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return attributeList
|
return attributeList
|
||||||
@@ -638,7 +579,8 @@ private mapDeviceCommands(command, value) {
|
|||||||
if (value == 1 || value == "1" || value == "lock") {
|
if (value == 1 || value == "1" || value == "lock") {
|
||||||
resultCommand = "lock"
|
resultCommand = "lock"
|
||||||
resultValue = ""
|
resultValue = ""
|
||||||
} else if (value == 0 || value == "0" || value == "unlock") {
|
}
|
||||||
|
else if (value == 0 || value == "0" || value == "unlock") {
|
||||||
resultCommand = "unlock"
|
resultCommand = "unlock"
|
||||||
resultValue = ""
|
resultValue = ""
|
||||||
}
|
}
|
||||||
@@ -647,5 +589,5 @@ private mapDeviceCommands(command, value) {
|
|||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
return [resultCommand, resultValue]
|
return [resultCommand,resultValue]
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user