maya.public

Parameters

Name	Type	Mode
in_iddevices	ARRAY	IN
in_start_date	timestamp with time zone	IN
in_end_date	timestamp with time zone	IN
_iddevice	integer	OUT
_start_date	timestamp with time zone	OUT
_end_date	timestamp with time zone	OUT
_start_location	USER-DEFINED	OUT
_end_location	USER-DEFINED	OUT
_vms	integer	OUT
_duration_minutes	double precision	OUT
_distance_gps	double precision	OUT
_max_speed	double precision	OUT
_speed_avg	double precision	OUT

Definition

DECLARE
r0 record;
_cur_vms INTEGER;
_prev_vms INTEGER;
_start_odometer FLOAT;
_avg_numerator REAL;
_avg_denominator REAL;
BEGIN
FOR _iddevice IN select unnest(in_iddevices) LOOP
    SELECT NULL,NULL,NULL,NULL,NULL,0,0 INTO _cur_vms,_prev_vms,_start_odometer,_max_speed,_start_date,_avg_numerator,_avg_denominator;
--  FOR r0 IN (SELECT * FROM event e WHERE e.iddevice = _iddevice AND e.senddate BETWEEN in_start_date AND in_end_date AND (eventcat = 2 OR eventcat IS NULL) ORDER BY e.senddate) LOOP
    FOR r0 IN (SELECT * FROM ot_ro_event_cassandra(_iddevice,in_start_date,in_end_date) WHERE (eventcat = 2 OR eventcat IS NULL) ORDER BY senddate) LOOP
    _cur_vms := r0.otros->'vehicle_movement_status';
    _avg_numerator := _avg_numerator + r0.speed;
    _avg_denominator := _avg_denominator + 1;
    IF r0.speed > _max_speed THEN
    _max_speed := r0.speed;
    END IF;
    IF _start_date IS NULL THEN
    SELECT r0.senddate,r0.location,(r0.otros->'vehicle_movement_status')::INTEGER,r0.odometer,r0.speed INTO _start_date,_start_location,_vms,_start_odometer,_max_speed;
    END IF;
    IF _cur_vms <> _prev_vms THEN
    SELECT r0.senddate,r0.location,(EXTRACT(epoch FROM (r0.senddate - _start_date))/60.0),(r0.odometer - _start_odometer),_avg_numerator / _avg_denominator INTO _end_date, _end_location, _duration_minutes, _distance_gps, _speed_avg;
    RETURN next;
    SELECT r0.senddate,r0.location,(r0.otros->'vehicle_movement_status')::INTEGER,r0.odometer,r0.speed,0,0 INTO _start_date,_start_location,_vms,_start_odometer,_max_speed,_avg_numerator,_avg_denominator;
    END IF;
    _prev_vms := _cur_vms;
END LOOP;
END LOOP;
END;

ot_ro_report_sar_citus(integer[], timestamp with time zone, timestamp with time zone)

Parameters

Definition