Alarmanlage und Anwesenheitssimulator mit OpenHAB

Group:Switch:OR(ON, OFF)	gWatchdog				
Switch						WatchdogManual			"Watchdog"	(fgPersist,gWatchdog,tgWatchdogEvents)		{ alexa="Switch" }
Switch						WatchdogNightshift					(fgPersist,gWatchdog)
DateTime					WatchdogTimestamp

Switch						TestDummy

import java.util.Map
import java.util.List
import org.openhab.core.model.script.ScriptServiceUtil

var Map<String, Timer> timers = newHashMap

rule "Watchdog Leuchtsimulation"
when
	Item WatchdogManual changed to ON
	or Time cron "0 0 6 ? * * *" 
then {
	if(WatchdogManual.state == ON){
		//Optische Bestätigung: Watchdog ist an!
		Everywhere_Interface.sendCommand('{"effect": "blink"}')
	
	
		val java.util.Random rand = new java.util.Random()
		var sunset = (LokaleSonnendaten_Set_Startzeit.state as DateTimeType).getZonedDateTime()
		var randMinutes = 0
		
		//if(sunset.isBefore( now )){ sunset = now; }

		//Büro Alex
		//von (Dunkel) bis (23:00 - 01:00) : Licht
		timers.put('begin_BueroAlex',createTimer(sunset, [ |
			logInfo("Watchdog", "Büro Alex: An")
			BueroAlex_Helligkeit.sendCommand(100)
			
			val endMinutes = 23*60 + rand.nextInt(120)
			timers.put('end_BueroAlex',createTimer(now.truncatedTo(java.time.temporal.ChronoUnit.DAYS).plusMinutes(endMinutes), [ |
				logInfo("Watchdog", "Büro Alex: Aus")
				BueroAlex_Helligkeit.sendCommand(0)
			]))
		]))
		
		//Küche
		//	von (Dunkel + (30 - 180min)) bis (45 - 90min lang) : Licht + Ton
		randMinutes = 30 + rand.nextInt(150)
		timers.put('begin_Kueche',createTimer(sunset.plusMinutes(randMinutes), [ |
			logInfo("Watchdog", "Küche: An")
			//TODO: Licht
			
			val endMinutes = 45 + rand.nextInt(45)
			timers.put('end_Kueche',createTimer(now.plusMinutes(endMinutes), [ |
				logInfo("Watchdog", "Küche: Aus")
				//TODO: Licht aus
			]))
		]))

		//Wohnzimmer
		//	von (Dunkel + (30 - 90min)) bis (22:30 - 00:30) : TV-Simulation + Ton
		randMinutes = 30 + rand.nextInt(60)
		timers.put('begin_Wohnzimmer',createTimer(sunset.plusMinutes(randMinutes), [ |
			//Licht
			logInfo("Watchdog", "Wohnzimmer Tisch: An")
			WzTisch_Helligkeit.sendCommand(100)
			
			logInfo("Watchdog", "Wohnzimmer Couch: TV-Simulation")
			WzCouch_Lightshow.sendCommand("TV-Simulation") //TV-Simluation
			
			//Ton
			logInfo("Watchdog", "Wohnzimmer Echo: Musik")
			Echo_Wohnzimmer_TextCommand.sendCommand("echo spiele Robin Schulz")
			
			val endMinutes = 22*60 + 30 + rand.nextInt(120)
			timers.put('end_Wohnzimmer',createTimer(now.truncatedTo(java.time.temporal.ChronoUnit.DAYS).plusMinutes(endMinutes), [ |
				//TODO: Licht und Ton aus
				logInfo("Watchdog", "Wohnzimmer (Tisch, Couch, Echo): Aus")
				WzTisch_Helligkeit.sendCommand(0)
				WzCouch_Helligkeit.sendCommand(0) //TV-Simluation
				Echo_Wohnzimmer_TextCommand.sendCommand("echo stop")
			]))
		]))

		//Schlafzimmer
		//	von (21:00 - 23:30) bis (23:35 - 00:30) : Licht
		randMinutes = 21*60 + rand.nextInt(150)
		timers.put('begin_Schlafzimmer',createTimer(now.truncatedTo(java.time.temporal.ChronoUnit.DAYS).plusMinutes(randMinutes), [ |
			//Licht
			logInfo("Watchdog", "Schlafzimmer : An")
			SchlafzimmerRoom_Helligkeit.sendCommand(100)
			
			val endMinutes = 5 + rand.nextInt(60)
			timers.put('end_Schlafzimmer',createTimer(now.plusMinutes(endMinutes), [ |
				//Licht aus
				logInfo("Watchdog", "Schlafzimmer : Aus")
				SchlafzimmerRoom_Helligkeit.sendCommand(0)
			]))
		]))
		
		
		//Musiksimulation
		//createTimer(now, [ |
		//	Echo_BueroAlex_TextCommand.sendCommand("echo spiele Robin Schulz")
		//	while(gWatchdog.state == ON){
		//		Thread::sleep(500)
		//	}
		//	Echo_BueroAlex_TextCommand.sendCommand("echo stop")
		//])
	}
}
end

//Verzögerung, bis Alarm tatsächlich scharf: 5min
rule "Watchdog changed Timestamp"
when
	Item gWatchdog changed to ON
then {
	WatchdogTimestamp.postUpdate(new DateTimeType)
}
end

rule "Fault and disturbance detection"
when
	Time cron "0 * * ? * * *" 
then {
	//if 5min nothing received: ask
	if(now.minusMinutes(5).isAfter((fgFaultDetection.state as DateTimeType).getZonedDateTime())){
		val GenericItem faultItem = fgFaultDetection.members.findFirst [ GenericItem i | now.minusMinutes(5).isAfter((i.state as DateTimeType).getZonedDateTime()) ]
		val String faultIGName = faultItem.getGroupNames.findFirst[ String groupName | groupName.startsWith("ig") ]
		val GroupItem faultIG = ScriptServiceUtil.getItemRegistry.getItem(faultIGName) as GroupItem
		val SwitchItem switchItem = faultIG.members.findFirst[ a | a.tags.contains("Switch") && a.tags.contains("Power")]
		switchItem.sendCommand(switchItem.state)
	}
	
	//if 8min nothing received: alert
	if(now.minusMinutes(8).isAfter((fgFaultDetection.state as DateTimeType).getZonedDateTime())){
		val GenericItem faultItem = fgFaultDetection.members.findFirst [ GenericItem i | now.minusMinutes(8).isAfter((i.state as DateTimeType).getZonedDateTime()) ]
		//TODO: WatchdogDummyAlertContact.sendCommand(ON)
		if(gWatchdog.state != ON){
			getActions("telegram","telegram:telegramBot:home_Bot").sendTelegram(-000000000L,
				"Wartung nötig: %s hat sich länger als 8min nicht gemeldet!",
				faultItem.name
			)
		}
	}
}
end	

//To end an Alarm, but also just to end the Night
rule "End Watchdog Alarm"
when
	Item gWatchdog changed to OFF
then {
	if(Everywhere_Lightshow.state.toString == "Alarm"){
		Everywhere_Farbtemperatur.sendCommand(67)
	}
	
	//Everywhere_Helligkeit.sendCommand(0)
	gAlexa_PlayAlarmSound.members.forEach[ StringItem item |
		item.sendCommand('') //...PlayAlarmSound wird mit '' unterbrochen
	]
	gAlexa_Volume.members.forEach[ DimmerItem item |
		item.sendCommand(20)
	]
	
	timers.keySet().forEach[String key |
		if(key.startsWith("begin")){
			timers.get(key).cancel()
		}
		if(key.startsWith("end")){
			timers.get(key).reschedule(now)
		}
	]
}
end

rule "Test Alarm start"
when
	Item TestDummy changed to ON
then {
	//Everywhere_Lightshow.sendCommand("Alarm")
	BueroAlex_Lightshow.sendCommand("Alarm")
}
end	

rule "Test Alarm end"
when
	Item TestDummy changed to OFF
then {
	//if(Everywhere_Lightshow.state.toString == "Alarm"){
	//	Everywhere_Farbtemperatur.sendCommand(67)
	//}
	if(BueroAlex_Lightshow.state.toString == "Alarm"){
		BueroAlex_Farbtemperatur.sendCommand(67)
	}
}
end

rule "Smart Button - Start Nightshift"
when
	//Channel "mqtt:topic:99a3e7ba:SmartButton1:action" triggered
	Item SmartButton1_DimmerSwitch changed
then {
	if(
		KalenderWecken_CurrentEventPresence.state == OFF
		|| SmartButton1_DimmerSwitch == NULL
	){
		WatchdogNightshift.sendCommand(ON)
	}
}
end

rule "End Nightshift"
when
	Item KalenderWatchdog_CurrentEventPresence changed to OFF
then {
	WatchdogNightshift.sendCommand(OFF)
}
end

rule "Watchdog Alarm"
when
	Item gCamAlert changed
	or Item fgIntrusion changed
then {
	if( gWatchdog.state == ON && now.minusMinutes(5).isAfter((WatchdogTimestamp.state as DateTimeType).getZonedDateTime())){
		
		logInfo("Test", "triggeringItemName: {}", triggeringItemName)
		//Licht-Alarm
		Everywhere_Lightshow.sendCommand("Alarm")
		
		//Alexa-Warnrufe
		createTimer(now, [ |
			gAlexa_PlayAlarmSound.members.forEach[ StringItem item |
				item.sendCommand('ECHO:system_alerts_rhythmic_02')
			]
			
			Thread::sleep(10000)
			
			gAlexa_PlayAlarmSound.members.forEach[ StringItem item |
				item.sendCommand('')
			]
			
			if(gWatchdog.state == ON){
				gAlexa_Volume.members.forEach[ DimmerItem item |
					item.sendCommand(80)
				]
				gAlexa_TTS.members.forEach[ StringItem item |
					item.sendCommand("Eindringling entdeckt! Notruf wurde abgesetzt. Polizei ist unterwegs.")
				]
			
				Thread::sleep(4000)
			}
			
			if(gWatchdog.state == ON){
				gAlexa_PlayAlarmSound.members.forEach[ StringItem item |
					item.sendCommand('ECHO:system_alerts_rhythmic_02')
				]
			}
		])
		
		//Telegram-Meldungen
		fgIntrusion.members.forEach[ GenericItem item |
			if(item.state == OFF){
				var groupLabels = ""
				item.groupNames.forEach[ String groupName |
					var groupLabel = ScriptServiceUtil.getItemRegistry.getItem(groupName).label
					groupLabels = groupLabels + " " + groupLabel
				]
				getActions("telegram","telegram:telegramBot:home_Bot").sendTelegram(-000000000L,
					"Eindringling-Alarm wurde ausgelöst!: %s - %s",
					groupLabels,
					item.label
				)
			}
		]
	}
}
end

// --- TensorPi ---
rule "Send telegram on object sighted (Vordertuer)"
when
	Item Tensorpi_Vordertuer_time changed
then
	getActions("telegram","telegram:telegramBot:home_Bot").sendTelegramPhoto(-000000000L,
		Tensorpi_Vordertuer_last_img.state.toString,
		Tensorpi_Vordertuer_object.state.toString)
end

// --- TensorPi2 ---
rule "Send telegram on object sighted (Hintertuer)"
when
	Item Tensorpi_Hintertuer_time changed
then
	if(gWatchdog.state == ON){
		getActions("telegram","telegram:telegramBot:home_Bot").sendTelegramPhoto(-000000000L,
			Tensorpi_Hintertuer_last_img.state.toString,
			Tensorpi_Hintertuer_object.state.toString)
	}
end