@Description('Кол-во людей в геозоне')
create schema PersonsInZone(zoneId string, number int);
@Description('Статус устройства (вкл / выкл)')
create schema DeviceStatus(deviceId string, zoneId string, turnedOn bool);

create context TurnerOnDeviceContext
    partition by deviceId from DeviceStatus
    initiated by DeviceStatus(turnedOn = true)
    terminated by DeviceStatus(turnedOn = false);

// для выражения можно задать имя, чтобы видеть его в логах
@Name('Unattended device')
// указывая контекст, мы говорим, чтобы данное выражение
// выполнялось только для событий из контекста
context TurnerOnDeviceContext
select
    ds.zoneId,
    ds.deviceId
from
    // в качестве «источника» событий задаем шаблон,
    // который словами можно сформулировать так:
    // «Устройство включили» → потом «Все ушли» → потом («Прошло 10 минут» И «Никто не вернулся»)
    pattern [
        ds = DeviceStatus(turnedOn = true)
        -> every (
            PersonsInZone(zoneId = ds.zoneId and number = 0)
            -> (timer:interval(10 minutes)
                    and not PersonsInZone(zoneId = ds.zoneId and number > 0)
               )
        )
    ];

%esperscenario
// задаем начальное время
t = «2020-12-10 12:00:00.000»
// публикуем событие «в помещение A вошёл 1 сотрудник»
PersonsInZone = {zoneId=«room-A», number=1}
// через 1 минуту включаем генератор 1 в помещении А
t = t.plus(1 minute)
DeviceStatus = {deviceId=«generator-1», zoneId=«room-A», turnedOn=true}
// через 4 часа сотрудник вышел из помещения А, не выключив генератор
t = t.plus(4 hours)
PersonsInZone = {zoneId=«room-A», number=0}
// прошло ещё 10 минут – и должно сработать наше правило!
t = t.plus(10 minute)

Unattended device-output={ds.zoneId='room-A', ds.deviceId='generator-1'}

%esperscenario
t = «2020-12-10 12:00:00.000»
// сотрудник вошёл в помещение А
PersonsInZone = {zoneId=«room-A», number=1}
// через 1 минуту включил генератор 1
t = t.plus(1 minute)
DeviceStatus = {deviceId=«generator-1», zoneId=«room-A», turnedOn=true}
// через 30 минут вышел, не выключив генератор
t = t.plus(30 minutes)
PersonsInZone = {zoneId=«room-A», number=0}
// но через 5 минут вернулся
t = t.plus(5 minute)
PersonsInZone = {zoneId=«room-A», number=1}
// прошло ещё 5 минут – тревоги не должно быть, сотрудник ведь вернулся
t = t.plus(5 minute)
// ещё через 3 часа ушёл, а генератор всё также остался включённым
t = t.plus(3 hour)
PersonsInZone = {zoneId=«room-A», number=0}
// через 10 минут – тревога!
t = t.plus(10 minute)