Compare commits
1 Commits
MSA-2429-1
...
MSA-2411-2
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f5664ff0e8 |
@@ -0,0 +1,434 @@
|
||||
/**
|
||||
* ControlAny-Support
|
||||
*
|
||||
* Copyright 2017 Venkata Kishore Chilakala
|
||||
*
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
definition(
|
||||
name: "ControlAny-Support",
|
||||
namespace: "controlany-support",
|
||||
author: "Venkata Kishore Chilakala",
|
||||
description: "ControlAny-Support",
|
||||
category: "My Apps",
|
||||
iconUrl: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience.png",
|
||||
iconX2Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience@2x.png",
|
||||
iconX3Url: "https://s3.amazonaws.com/smartapp-icons/Convenience/Cat-Convenience@2x.png")
|
||||
|
||||
|
||||
|
||||
preferences {
|
||||
section("Allow External Service to Control These Things...")
|
||||
{
|
||||
input "motions", "capability.motionSensor", title: "Motion Sensors", multiple: true, required: false
|
||||
input "contacts", "capability.contactSensor",title: "Contact Sensors", multiple: true, required: false
|
||||
input "presences", "capability.presenceSensor",title: "Presence Sensors", multiple: true, required: false
|
||||
input "switches", "capability.switch", title: "Switches ", multiple: true, required: false
|
||||
input "levelSwitches","capability.switchLevel",title: "Level Switches",multiple: true, required:false
|
||||
input "relativeHumidity","capability.relativeHumidityMeasurement",title: "Humidity",multiple:true,required:false
|
||||
input "temperatures","capability.temperatureMeasurement",title: "Temperature Measurement",multiple:true,required:false
|
||||
input "batteries","capability.battery",title:"Battery",multiple:true,required:false
|
||||
input "waters","capability.waterSensor",title:"Water Sensors",multiple:true,required:false
|
||||
input "locks","capability.lock",title: "Door Lock", multiple:true,required:false
|
||||
input "hubs",title: "Hubs",multiple:false,required:false
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
def installed() {
|
||||
initialize()
|
||||
subscribeToEvents()
|
||||
}
|
||||
|
||||
def updated() {
|
||||
//unsubscribe()
|
||||
initialize()
|
||||
unsubscribe()
|
||||
subscribeToEvents()
|
||||
}
|
||||
|
||||
|
||||
def subscribeToEvents() {
|
||||
subscribe(contacts, "contact", sendEvent)
|
||||
subscribe(motions, "motion", sendEvent)
|
||||
subscribe(switches, "switch", sendEvent)
|
||||
subscribe(presences, "presence", sendEvent)
|
||||
subscribe(temperatures, "temperature", sendEvent)
|
||||
subscribe(batteries, "battery", sendEvent)
|
||||
subscribe(waters, "water", sendEvent)
|
||||
|
||||
}
|
||||
|
||||
String toQueryString(Map m) {
|
||||
return m.collect { k, v -> "${k}=${URLEncoder.encode(v.toString())}" }.sort().join("&")
|
||||
}
|
||||
|
||||
def sendEvent(evt)
|
||||
{
|
||||
log.debug "Notify got evt ${evt.device}"
|
||||
log.debug "Device Id is $evt.deviceId"
|
||||
log.debug "Device displayName is $evt.displayName"
|
||||
log.debug "Device Name is $evt.name"
|
||||
log.debug "Device Value is $evt.value"
|
||||
// log.debug "The jsonValue of this event is $evt.jsonValue"
|
||||
def postParams = [
|
||||
deviceId: evt.deviceId,
|
||||
value : evt.value,
|
||||
displayName :evt.displayName,
|
||||
isStateChange:evt.isStateChange,
|
||||
deviceTypeId:evt.deviceTypeId,
|
||||
description:evt.description,
|
||||
displayed:evt.displayed,
|
||||
hubId:evt.hubId,
|
||||
name:evt.name
|
||||
]
|
||||
// This URL will be defined by the third party in their API documentation
|
||||
def tokenUrl = "http://35.154.110.174/share/smarttest.php?params=${toQueryString(postParams)}"
|
||||
|
||||
httpPost(uri: tokenUrl) { resp ->
|
||||
log.debug resp
|
||||
}
|
||||
log.debug "updated"
|
||||
|
||||
|
||||
}
|
||||
|
||||
|
||||
mappings {
|
||||
|
||||
path("/devices")
|
||||
{
|
||||
action:[
|
||||
GET:"listDevices"
|
||||
]
|
||||
}
|
||||
path("/relativeHumidity")
|
||||
{
|
||||
action:[
|
||||
GET:"listHumidity"
|
||||
]
|
||||
}
|
||||
path("/hubs") {
|
||||
action: [
|
||||
GET: "listAll"
|
||||
]
|
||||
}
|
||||
|
||||
path("/temperatures") {
|
||||
action: [
|
||||
GET:"listTemperature"
|
||||
]
|
||||
}
|
||||
path("/switches") {
|
||||
action: [
|
||||
GET:"listSwitches",
|
||||
PUT:"updateSwitches"
|
||||
]
|
||||
}
|
||||
|
||||
path("/switches/:id") {
|
||||
action: [
|
||||
GET:"showSwitch",
|
||||
]
|
||||
}
|
||||
|
||||
path("/switches/:id/:command") {
|
||||
action: [
|
||||
PUT:"updateSwitch"
|
||||
]
|
||||
}
|
||||
path("/levelSwitches") {
|
||||
action: [
|
||||
GET:"listLevelSwitches",
|
||||
PUT:"updateLevelSwitches"
|
||||
]
|
||||
}
|
||||
path("/levelSwitches/:id") {
|
||||
action: [
|
||||
GET:"showLevelSwitch",
|
||||
PUT:"updateLevelSwitch"
|
||||
]
|
||||
}
|
||||
path("/motions") {
|
||||
|
||||
action: [
|
||||
GET:"listMotions",
|
||||
PUT:"updateMotions"
|
||||
]
|
||||
}
|
||||
path("/motions/:id"){
|
||||
action:[
|
||||
GET:"showMotion",
|
||||
PUT:"updateMotion"
|
||||
]
|
||||
}
|
||||
path("/presences")
|
||||
{
|
||||
action:[
|
||||
GET:"listPresenceSensor",
|
||||
PUT:"updatePresenceSensor"
|
||||
]
|
||||
}
|
||||
path("/presences/:id")
|
||||
{
|
||||
action:[
|
||||
GET:"showPresence",
|
||||
PUT:"updatePresence"
|
||||
]
|
||||
}
|
||||
path("/locks") {
|
||||
action: [
|
||||
GET:"listLocks",
|
||||
PUT:"updateLocks"
|
||||
]
|
||||
}
|
||||
|
||||
path("/waters") {
|
||||
action: [
|
||||
GET:"listWaters",
|
||||
PUT:"updateLocks"
|
||||
]
|
||||
}
|
||||
|
||||
|
||||
path("/locks/:id") {
|
||||
action: [
|
||||
GET:"showLock",
|
||||
PUT:"updateLock"
|
||||
]
|
||||
}
|
||||
path("/contacts")
|
||||
{
|
||||
action: [
|
||||
GET: "listContacts",
|
||||
PUP: "updateContacts"
|
||||
]
|
||||
}
|
||||
path ("/contacts/:id")
|
||||
{
|
||||
action:[
|
||||
GET:"showContact",
|
||||
PUT:"updateContact"
|
||||
]
|
||||
}
|
||||
}
|
||||
|
||||
def listAll()
|
||||
{
|
||||
[location_id :location.id,hub_id:location.hubs*.id,hub_type:location.hubs*.type,hub_name:location.hubs*.name,hub_firm_ver:location.hubs*.firmwareVersionString,hub_ip:location.hubs*.localIP,hub_port:location.hubs*.localSrvPortTCP]
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
def listSwitches() {
|
||||
switches.collect { device(it,"switch") }
|
||||
}
|
||||
def listTemperature() {
|
||||
temperatures.collect { device(it,"temperature") }
|
||||
}
|
||||
def listContacts(){
|
||||
contacts.collect{device(it,"contact")}
|
||||
}
|
||||
|
||||
|
||||
def listWaters()
|
||||
{
|
||||
waters.collect { device(it,"water") }
|
||||
}
|
||||
def listLevelSwitches() {
|
||||
levelSwitches.collect { device(it,"level") }
|
||||
}
|
||||
def listLocks() {
|
||||
locks.collect { device(it,"lock") }
|
||||
}
|
||||
def listMotions() {
|
||||
motions.collect { device(it,"motion") }
|
||||
}
|
||||
def listPresenceSensor(){
|
||||
presences.collect{device(it,"presence")}
|
||||
}
|
||||
def listHumidity(){
|
||||
relativeHumidity.collect{device(it,"relativeHumidity")}
|
||||
}
|
||||
|
||||
|
||||
void updateSwitches() {
|
||||
updateAll(switches)
|
||||
}
|
||||
|
||||
def showSwitch() {
|
||||
show(switches, "switch")
|
||||
}
|
||||
def updateSwitch() {
|
||||
|
||||
log.debug "testing"
|
||||
def device = switches.find { it.id == params.id }
|
||||
def id = params.id
|
||||
def command = params.command
|
||||
log.debug " sid :: ${params.id}"
|
||||
log.debug " scommand :: ${params.command}"
|
||||
// all switches have the command
|
||||
// execute the command on all switches
|
||||
// (note we can do this on the array - the command will be invoked on every element
|
||||
if (!device) {
|
||||
httpError(404, "Device not found")
|
||||
} else {
|
||||
|
||||
switch(command) {
|
||||
case "on":
|
||||
device."$command"()
|
||||
break
|
||||
case "off":
|
||||
device."$command"()
|
||||
break
|
||||
default:
|
||||
httpError(400, "$command is not a valid command for all switches specified")
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
def showLevelSwitch() {
|
||||
update(switches)
|
||||
}
|
||||
|
||||
void updateLevelSwitches() {
|
||||
show(levelSwitches, "level")
|
||||
}
|
||||
void updateLevelSwitch() {
|
||||
update(levelSwitches)
|
||||
}
|
||||
|
||||
void updateLocks() {
|
||||
updateAll(lock)
|
||||
}
|
||||
def showLock() {
|
||||
show(lock, "lock")
|
||||
}
|
||||
void updateLock() {
|
||||
update(lock)
|
||||
}
|
||||
|
||||
void updateMotions()
|
||||
{
|
||||
updateAll(motions)
|
||||
}
|
||||
def showMotion()
|
||||
{
|
||||
show(motions, "motion")
|
||||
}
|
||||
void updateMotion()
|
||||
{
|
||||
update(motions)
|
||||
}
|
||||
|
||||
|
||||
void updatePresenceSensor()
|
||||
{
|
||||
updateAll(presences)
|
||||
}
|
||||
def showPresence()
|
||||
{
|
||||
show(presences,"presence")
|
||||
}
|
||||
void updatePresence()
|
||||
{
|
||||
update(presences)
|
||||
}
|
||||
|
||||
|
||||
void updateContacts()
|
||||
{
|
||||
updateAll(contacts)
|
||||
}
|
||||
def showContact()
|
||||
{
|
||||
show(contacts,"contact")
|
||||
}
|
||||
void updateContact()
|
||||
{
|
||||
update(contacts)
|
||||
}
|
||||
|
||||
|
||||
|
||||
private device(it, name) {
|
||||
if (it) {
|
||||
def s = it.currentState(name)
|
||||
[
|
||||
id: it.id,
|
||||
name: it.displayName,
|
||||
label: it.displayName,
|
||||
hub_name: it.hub.name,
|
||||
hub_id: it.hub.id,
|
||||
hub_ip: it.hub.localIP,
|
||||
hub_port: it.hub.localSrvPortTCP,
|
||||
state: s
|
||||
]
|
||||
}
|
||||
}
|
||||
private void updateAll(devices) {
|
||||
def command = request.JSON?.command
|
||||
if (command) {
|
||||
devices."$command"()
|
||||
}
|
||||
}
|
||||
|
||||
private show(devices, name) {
|
||||
def device = devices.find { it.id == params.id }
|
||||
if (!device) {
|
||||
httpError(404, "Device not found")
|
||||
}
|
||||
else {
|
||||
log.debug " state s :: ${s}"
|
||||
log.debug "devices :: ${devices}"
|
||||
log.debug "name :: ${name}"
|
||||
def s = device.currentState(name)
|
||||
[id: device.id, label: device.displayName, name: device.displayName,state:s]
|
||||
}
|
||||
}
|
||||
|
||||
private void update(devices) {
|
||||
log.debug "update, request: ${request.JSON}, params: ${params}, devices: $devices.id"
|
||||
def command = request.JSON?.command
|
||||
def value = request.JSON?.value
|
||||
|
||||
log.debug "$value"
|
||||
log.debug "$command"
|
||||
|
||||
if (command) {
|
||||
def device = devices.find { it.id == params.id }
|
||||
if (!device) {
|
||||
httpError(404, "Device not found")
|
||||
} else {
|
||||
|
||||
if("$command"=="on")
|
||||
{
|
||||
device."$command"()
|
||||
}else if("$command"=="off")
|
||||
{
|
||||
device."$command"()
|
||||
}else if("$command"=="lock")
|
||||
{
|
||||
device."$command"()
|
||||
}else if("$command"=="unlock")
|
||||
{
|
||||
device."$command"()
|
||||
}else
|
||||
{
|
||||
device.setLevel("$command")
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
def initialize() {
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user