core_api/subscribe.php at master · comuREDE/core_api · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
<?php
require 'init.php';

$mqtt = new phpMQTT("10.62.63.50", 1883, "phpMQTT"); //Change client name to something unique
if(!$mqtt->connect()){
    echo "Erro ao conectar MQTT";die;
}
$topics['AGUA'] = array("qos"=>0, "function"=>"procmsg_agua");
$topics['LUZ'] = array("qos"=>0, "function"=>"procmsg_luz");

$mqtt->subscribe($topics,0);

while($mqtt->proc()){

	#if($mqtt->delay > 10 ){
	#	sms();
	#}

}
$mqtt->close();


function processaTopico($topic){
	# $topic AGUA LUZ
	#1 $msg (L/D)__12345-Y
	#2 $msg (L/D)__12345789-XXXX
	if(preg_match("/^(L|D)__(\d{8})-(\d{1,2})$/",$topic,$matches)){
		$estado = $matches[1];
		$cep = $matches[2];
		$sensor = (int) $matches[3];
		return compact("estado","cep","sensor");
	}
	return null;
}

function procmsg_luz($topic,$msg){

    echo "Msg Recebida: ".date("r")."\nTopic:{$topic}\n$msg\n";
    $data = date("Y-m-d H:i:s");
	$dados = processaTopico($msg);#"estado","cep","sensor"
	extract($dados);#$estado $cep $sensor
	$info = ['dia_hora'=>$data,'estado'=>$estado,'cep'=>$cep,'sensor'=>$sensor,];

	$res = (new Model())->setTable('sensores_luz')->save($info);

	var_dump($res);
}

function procmsg_agua($topic,$msg){
    echo "Msg Recebida: ".date("r")."\nTopic:{$topic}\n$msg\n";
    $data = date("Y-m-d H:i:s");
	$dados = processaTopico($msg);#"estado","cep","sensor"
	extract($dados);#$estado $cep $sensor
	$info = ['dia_hora'=>$data,'estado'=>$estado,'cep'=>$cep,'sensor'=>$sensor,];

	$res = (new Model())->setTable('sensores_agua')->save($info);

	var_dump($res);
}