176 lines
6.1 KiB
Text
176 lines
6.1 KiB
Text
|
import org.eclipse.smarthome.model.script.ScriptServiceUtil
|
||
|
|
// import org.eclipse.smarthome.core.library.items.StringItem
|
||
|
|
import java.util.HashMap
|
||
|
|
import java.util.HashSet
|
||
|
|
|
||
|
|
val TAG_FileName = "IFT605SmartClothes.rules"
|
||
|
|
val smartClothesID = "12345678"
|
||
|
|
|
||
|
|
var Contact currentRoom
|
||
|
|
var MQTTBroker currentMQTTBroker
|
||
|
|
|
||
|
|
// managing context
|
||
|
|
var boolean goodConditions = true // of course, only one of good/bad conditions is required
|
||
|
|
var boolean badConditions = false
|
||
|
|
var badConditionsStartTime = 0 // in milliseconds
|
||
|
|
val URGE_TO_CHANGE_ROOM_TIME_TRIGGER = 300000 // 5 minutes
|
||
|
|
|
||
|
|
// managing people in the room
|
||
|
|
var people = new HashSet<String>()
|
||
|
|
var luminanceMeasures = new HashMap<String, Integer>()
|
||
|
|
var noiseMeasures = new HashMap<String, Integer>()
|
||
|
|
|
||
|
|
// j'entre dans une pièce
|
||
|
|
val iEnter = [ ContactItem room, String smartClothesID, MQTTBroker broker |
|
||
|
|
broker.sendCommand(CONNECT);
|
||
|
|
broker.sendCommand(SUBSCRIBE, "room/1/#");
|
||
|
|
broker.sendCommand(SUBSCRIBE, "smartclothes/#");
|
||
|
|
broker.sendCommand(SUBSCRIBE, "room/1/tag/+");
|
||
|
|
broker.sendCommand(SUBSCRIBE, "smartclothes/+/sensor/luminance");
|
||
|
|
broker.sendCommand(SUBSCRIBE, "smartclothes/+/sensor/noise");
|
||
|
|
// informer que l'on vient d'entrer dans la pièce
|
||
|
|
broker.sendCommand(PUBLISH, smartClothesID+"/status", "Online")
|
||
|
|
vibrationPatch.sendCommand(OFF)
|
||
|
|
]
|
||
|
|
|
||
|
|
// je sors de une pièce
|
||
|
|
val iQuit = [ ContactItem room, String smartClothesID, MQTTBroker broker |
|
||
|
|
broker.sendCommand(UNSUBSCRIBE, "room/1/#");
|
||
|
|
broker.sendCommand(UNSUBSCRIBE, "smartclothes/#");
|
||
|
|
broker.sendCommand(UNSUBSCRIBE, "room/1/tag/+");
|
||
|
|
broker.sendCommand(UNSUBSCRIBE, "smartclothes/+/sensor/luminance");
|
||
|
|
broker.sendCommand(UNSUBSCRIBE, "smartclothes/+/sensor/noise");
|
||
|
|
// informer que l'on vient d'entrer dans la pièce
|
||
|
|
broker.sendCommand(PUBLISH, smartClothesID+"/status", "Offline")
|
||
|
|
]
|
||
|
|
// le vêtement entre dans une pièce
|
||
|
|
val someoneEnterInRoom = [ String smartClothesID |
|
||
|
|
people.add(smartClothesID)
|
||
|
|
]
|
||
|
|
|
||
|
|
val someoneQuitRoom = [ String smartClothesID |
|
||
|
|
people.remove(smartClothesID)
|
||
|
|
noiseMeasures.remove(smartClothesID)
|
||
|
|
luminanceMeasures.remove(smartClothesID)
|
||
|
|
]
|
||
|
|
|
||
|
|
// fonctions utilitaires pour la gestion du contexte
|
||
|
|
// autre solutions pour calculer les moyennes, utiliser les HashMap luminanceMeasures et noiseMeasures
|
||
|
|
val Integer averageLuminance = [ | Luminance.state
|
||
|
|
]
|
||
|
|
|
||
|
|
val Integer averagenoise = [ | Noise.state
|
||
|
|
]
|
||
|
|
|
||
|
|
val boolean checkGoodConditions = [ Integer roomLuminance, Integer roomNoise |
|
||
|
|
return (LUMINOSITE_MIN < roomLuminance || roomLuminance < LUMINOSITE_MAX)
|
||
|
|
&& (NIVEAU_SONORE_MIN < roomNoise || roomNoise < NIVEAU_SONORE_MAX)
|
||
|
|
]
|
||
|
|
|
||
|
|
val reactToNewConditions = [ |
|
||
|
|
goodConditions = checkGoodConditions(averageLuminance(), averageNoise())
|
||
|
|
badConditions = !goodConditions
|
||
|
|
if (goodConditions) {
|
||
|
|
badConditionsStartTime = 0
|
||
|
|
vibrationPatch.sendCommand(OFF)
|
||
|
|
// rapprocher l'éclairage de la valeur optimale
|
||
|
|
if (Luminance.state < LUMOINOSITE_OPTIMALE) {
|
||
|
|
stripIntensity.sendCommand(INCREASE)
|
||
|
|
} else {
|
||
|
|
stripIntensity.sendCommand(DECREASE)
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
// Éviter de rester trop longtemps dans des conditions défavorables
|
||
|
|
vibrationPatch.sendCommand(ON)
|
||
|
|
if (badConditionsStartTime == 0){
|
||
|
|
badConditionsStartTime = now.getMillis();
|
||
|
|
}
|
||
|
|
if (now.getMillis() - badConditionsStartTime > URGE_TO_CHANGE_ROOM_TIME_TRIGGER) {
|
||
|
|
vibrationPatch.sendCommand(ON)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
]
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
rule "Démarrage de openHAB"
|
||
|
|
when
|
||
|
|
System started
|
||
|
|
then
|
||
|
|
logInfo(TAG_FileName, "Rule : Démarrage de openHAB")
|
||
|
|
currentRoom = room1
|
||
|
|
currentMQTTBroker = room1MQTT
|
||
|
|
iEnter(currentRoom, smartClothesID, currentMQTTBroker)
|
||
|
|
end
|
||
|
|
|
||
|
|
// Diffuser les mesures de ses capteurs aux autres vêtements intelligents
|
||
|
|
rule "lecture d'une mesure de luminosité par le capteur du vêtement"
|
||
|
|
when
|
||
|
|
// Item luminance received update
|
||
|
|
Member of Luminance received update
|
||
|
|
then
|
||
|
|
var sensorName = triggeringItem.name
|
||
|
|
var value = triggeringItem.state
|
||
|
|
currentMQTTBroker.sendCommand(PUBLISH, "smartclothes/"+smartClothesID+"/sensor/luminance", value)
|
||
|
|
|
||
|
|
end
|
||
|
|
|
||
|
|
rule "lecture d'une mesure de bruit par le capteur du vêtement"
|
||
|
|
when
|
||
|
|
// Item noise received update
|
||
|
|
Member of Noise received update
|
||
|
|
then
|
||
|
|
var sensorName = triggeringItem.name
|
||
|
|
var value = triggeringItem.state
|
||
|
|
currentMQTTBroker.sendCommand(PUBLISH, "smartclothes/"+smartClothesID+"/sensor/noise", value)
|
||
|
|
end
|
||
|
|
|
||
|
|
// Gérer son contexte ambiant
|
||
|
|
|
||
|
|
rule "nouvelle mesure de bruit publiée par le courtier MQTT"
|
||
|
|
when currentMQTTBroker "smartclothes/+/sensor/noise" changed
|
||
|
|
then
|
||
|
|
noiseMeasures.put(extractID(triggeringItem.newState.topic), trigerringItem.newState.value)
|
||
|
|
reactToNewConditions()
|
||
|
|
end
|
||
|
|
|
||
|
|
rule "nouvelle mesure de bruit publiée par le courtier MQTT"
|
||
|
|
when currentMQTTBroker "smartclothes/+/sensor/luminance" changed
|
||
|
|
then
|
||
|
|
luminanceMeasures.put(extractID(triggeringItem.newState.topic), trigerringItem.newState.value)
|
||
|
|
reactToNewConditions()
|
||
|
|
end
|
||
|
|
|
||
|
|
// Tenir compte des arrivées et départs de personnes dans la salle
|
||
|
|
rule "arrivée d'une personne"
|
||
|
|
when
|
||
|
|
// si on n'utilise pas le mécanisme des dernières volontés de MQTT,
|
||
|
|
// il faut surveiller les éléments pertinents à la main
|
||
|
|
// currentMQTTBroker "room/+/tag" changed //lecture d'un tag RFID
|
||
|
|
// or currentMQTTBroker "smartclothes/+/sensor/luminance" changed // member of Luminance changed
|
||
|
|
// or currentMQTTBroker "smartclothes/+/sensor/noise" changed
|
||
|
|
currentMQTTBroker "+/status " changed to "Online" //lecture d'un tag RFID
|
||
|
|
|
||
|
|
then
|
||
|
|
String triggeringSmartClothesID = extractID(triggeringItem.newState.topic)
|
||
|
|
someoneEnterInRoom(triggeringSmartClothesID)
|
||
|
|
end
|
||
|
|
|
||
|
|
// Tenir compte des arrivées et départs de personnes dans la salle
|
||
|
|
rule "départ d'une personne"
|
||
|
|
when
|
||
|
|
currentMQTTBroker "+/status " changed to "Offline" //lecture d'un tag RFID
|
||
|
|
then
|
||
|
|
String triggeringSmartClothesID = extractID(triggeringItem.newState.topic)
|
||
|
|
someoneQuitRoom(triggeringSmartClothesID)
|
||
|
|
end
|
||
|
|
|
||
|
|
rule "Arrêt de openHAB"
|
||
|
|
when
|
||
|
|
System shuts down
|
||
|
|
then
|
||
|
|
logInfo(TAG_FileName, " Rule : Arrêt de openHAB")
|
||
|
|
// sauvegarder les états des items et le contexte
|
||
|
|
iQuit(currentRoom, smartClothesID, currentMQTTBroker)
|
||
|
|
end
|