Aplicativos e serviços online

	Samsung ARTIK Cloud para IoT
	Google Maps
	Arduino IDE

Sobre este projeto

Etapa 1:fazer um novo dispositivo no Artik Cloud Platform

Etapa 2:Criar regra no Artik Cloud

Etapa 3. Preparando o Arduino

Etapa 4:conexão dos sensores

Etapa 5:preparação de Raspberry Pi

  sudo apt-get updatesudo apt-get install nodejs npm  

  npm install --save ws  

  npm install serialport  

  sudo node staff-parking.js  

Etapa 6. Desenvolvimento de aplicativo da Web

Código

• Raspberry Pi (estacionamento para funcionários)
• Arduino (sonar)
• Aplicativo da web (HTML)
• Aplicativo da web (lado do cliente)

Raspberry Pi (estacionamento para funcionários) JavaScript

 // staff parking data transfervar webSocketUrl ="wss://api.artik.cloud/v1.1/websocket? Ack =true"; var device_id ="Your Device id"; // estacionamento da equipe DEVICE IDvar device_token ="Your Device Token"; // staff parking DEVICE TOKEN // requer módulo websocket para conectar // execute dois comandos a seguir para o terminal do seu pi // sudo apt-get update // npm install websocketvar WebSocket =require ('ws'); var isWebSocketReady =false; var data =""; var ws =null; // requer módulo serialport para raspberry pi // execute o seguinte comando para terminal // npm install serialportvar serialport =require ("serialport"); var SerialPort =serialport.SerialPort; var sp =new SerialPort ("/ dev / ttyACM0", {// para comunicação serial com arduino baudrate:9600, // estamos usando UNO então baudrate é 9600, você pode precisar mudar de acordo com seu analisador de modelo:serialport.parsers.readline (" \ n ")}); var parking_state =0; // variável para verificar o estacionamento state_gate / ** * Obtém a hora atual em milis * / function getTimeMillis () {return parseInt (Date.now (). toString ());} / ** * Crie uma conexão / websocket e configure o pino GPIO * / function start () {// Crie a conexão WebSocket isWebSocketReady =false; ws =novo WebSocket (webSocketUrl); // esta função invocada em uma conexão bem-sucedida ws.on ('open', function () {console.log ("a conexão WebSocket está aberta ...."); // você deve se registrar para uma transmissão de dados bem-sucedida // o registro é para autenticação ou registro de transferência segura de dados ();}); ws.on ('mensagem', função (dados) {// este loop é chamado sempre que o cliente envia alguma mensagem handleRcvMsg (dados); // dados são enviados para a função handleRcvMsg ()}); ws.on ('fechar', function () {console.log ("Conexão WebSocket fechada ....");}); } / ** * Envia uma mensagem de registro para / websocket endpoint * /// O cliente só funcionará quando o dispositivo for registrado a partir daqui função register () {console.log ("Registrando dispositivo na conexão WebSocket"); tente {var registerMessage ='{"type":"register", "sdid":"' + device_id + '", "Authorization":"bearer' + device_token + '", "cid":"' + getTimeMillis () + ' "} '; console.log ('Enviando mensagem de registro' + registerMessage + '\ n'); ws.send (registerMessage, {mask:true}); isWebSocketReady =true; } catch (e) {console.error ('Falha ao registrar mensagens. Erro ao registrar mensagem:' + e.toString ()); }} // os dados após o recebimento são enviados aqui para processamento // em nosso caso, esta função não será usada, pois não receberemos nenhuma ação // no raspberry pi. Isto é para modificações futuras. Function handleRcvMsg (msg) {// você tem que analisar a string recebida var msgObj =JSON.parse (msg); if (msgObj.type! ="ação") return; // Retorno antecipado; var ações =msgObj.data.actions; var actionName =actions [0] .name; console.log ("A ação recebida é" + actionName); // você deve saber suas ações registradas a fim de realizar o acordo if (actionName.toLowerCase () =="settext") {// fazer algo aqui após receber 'parking_state' console.log ('receber ação reconhecida' + actionName); } else {// este loop é executado se alguma ação não registrada for recebida // então você deve registrar todas as ações no console.log da nuvem ('Não fazer nada desde o recebimento da ação não reconhecida' + actionName); Retorna; }} / ** * Enviar uma mensagem para ARTIK Cloud * /// Esta função é responsável por enviar comandos para nuvem // function sendStateToArtikCloud (parking) envia número de vaga de estacionamento grátis para artik cloudfunction sendStateToArtikCloud (parking_slot) {try {ts =', "ts":' + getTimeMillis (); var data ={"parking_slot":parking_slot // definindo o valor do estacionamento do argumento para nossa variável de nuvem "parking_value"}; var payload ='{"sdid":"' + device_id + '"' + ts + ', "data":' + JSON.stringify (data) + ', "cid":"' + getTimeMillis () + '"}'; console.log ('Enviando carga útil' + carga útil + '\ n'); ws.send (carga útil, {máscara:verdadeiro}); } catch (e) {console.error ('Erro ao enviar mensagem:' + e.toString () + '\ n'); }} function exitClosePins () {console.log ('Sair e destruir todos os pinos!'); process.exit (); } start (); // executa sempre que os dados são recebidos do arduino (atraso programado de 30 segundos do arduino) sp.on ("open", function () {sp.on ('data', function (data) {console .log ("Dados recebidos da porta serial:" + dados); // sendStateToArtikCloud (dados); // vaga de estacionamento grátis var parking_slot =parseInt (data); sendStateToArtikCloud (parking_slot);});}); process.on (' SIGINT ', exitClosePins); 

Arduino (sonar) C / C ++

 #define echoPin1 2 // Pino de eco para sonar 1 # define trigPin1 3 // Pino de gatilho para sonar 1 # define echoPin2 4 // Pino de eco para sonar 2 # define trigPin2 5 // Pino de gatilho para sonar 2 # define echoPin3 6 // Pino de eco para sonar 3 # define trigPin3 7 // Pino de gatilho para sonar 3 // # define echoPin4 9 // Pino de eco para sonar 4 // # define trigPin4 8 // Pino de gatilho para sonar 4 de longa duração1, distância1; // Duração usada para calcular a distância - duração longa2, distância2; longa duração3, distância3; // longa duração4, distância4; contagem interna =0; intervalo interno livre =0; configuração vazia () {Serial.begin (9600); // inicia a comunicação serial com raspberry pi pinMode (trigPin1, OUTPUT); // aciona o pino como saída pinMode (echoPin1, INPUT); // pino de eco como entrada pinMode (trigPin2, OUTPUT); pinMode (echoPin2, INPUT); pinMode (trigPin3, OUTPUT); pinMode (echoPin3, INPUT); // pinMode (trigPin4, OUTPUT); // pinMode (echoPin4, INPUT); } void loop () {/ * O ciclo trigPin / echoPin a seguir é usado para determinar a distância do objeto mais próximo refletindo as ondas sonoras dele. * / / * É necessário um sinal de nível alto de pelo menos 10 microssegundos para acionar o * pino. * _____ * | | * -------------! ! --------- * ..... | 10us | ........ * o módulo então produz oito sinais de pulso de 40KHz e espera para receber eco * / digitalWrite (trigPin1, LOW); atrasoMicrosegundos (2); digitalWrite (trigPin1, HIGH); atrasoMicrosegundos (10); digitalWrite (trigPin1, LOW); // a função pulseIn () determina a largura do pulso no tempo // a duração do pulso é proporcional à distância do obstáculo duration1 =pulseIn (echoPin1, HIGH); digitalWrite (trigPin2, LOW); atrasoMicrosegundos (2); digitalWrite (trigPin2, HIGH); atrasoMicrosegundos (10); digitalWrite (trigPin2, LOW); duração2 =pulseIn (echoPin2, HIGH); digitalWrite (trigPin3, LOW); atrasoMicrosegundos (2); digitalWrite (trigPin3, HIGH); atrasoMicrosegundos (10); digitalWrite (trigPin3, LOW); duração3 =pulseIn (echoPin3, HIGH); // digitalWrite (trigPin4, LOW); // delayMicroseconds (2); // digitalWrite (trigPin4, HIGH); // delayMicroseconds (10); // digitalWrite (trigPin4, LOW); // duração4 =pulseIn (echoPin4, HIGH); // distância =(timevelocidade do som de alto nível (340M / S) / 2, // em centímetros =uS / 58 distância1 =duração1 / 58,2; if (distância1 <10) distância1 =1; senão distância1 =0; distância2 =duração2 /58,2; if (distance2 <10) distance2 =1; else distance2 =0; distance3 =duration3 / 58.2; if (distance3 <10) distance3 =1; else distance3 =0; // distance4 =duration4 / 58.2; // if (distância4 <10) // distância4 =1; // else distância4 =0; // adicionar o resultado de todos os sensores para contar a contagem total de carros =distância1 + distância2 + distância3;; // espaço livre =espaço total - espaço livre total do carro =3 - contagem; // número total de slots é enviado para raspberry pi usando usb Serial.println (freeSlot); // o status é atualizado a cada 30 segundos. Delay (5000); // freeSlot =0; // distance1 =0; // distância2 =0; // distância3 =0; // distância4 =0;} 

Aplicativo da Web (HTML) HTML

          
 Sistema de estacionamento inteligente baseado em nuvem ARTIK 
 
 
 
 Estacionamento para funcionários 
 
 Próximo ao Cmapus Principal 
  Recebendo dados ...  
 1 
 
 Estacionamento para alunos / visitantes 
 
 Front Gate, Near Union bank 
  Recebendo dados ...  
 
 
 
 
 
 
 
 
 
 
  Fechar conexão com o sistema de estacionamento 
 
 
 Console de saída 
 
 
     

Aplicativo da Web (lado do cliente) JavaScript

 // interações em tempo real são possíveis usando websocket // Observe o ws :. Este é o novo esquema de URL para conexões WebSocket. // Também há wss:para conexão WebSocket segura da mesma maneira // https:é usado para conexões HTTP seguras.// você pode obtê-lo na documentação da nuvem Artik pagevar wsUri ="wss://api.artik.cloud/v1 .1 / websocket? Ack =true "; var device_id =" ID do seu dispositivo "; // raspi3 DEVICE IDvar device_token ="Seu token de dispositivo"; // raspi3 DEVICE TOKENvar output; var attribute_log; var websocket; function init () {// document.getElementById () escrever algo na página html output =document.getElementById ("output"); atributos_log =document.getElementById ("atributos_log"); if (browserSupportsWebSockets () ===false) {// verifique se o navegador suporta protocolo websocket ou não writeToScreen ("Desculpe! seu navegador não suporta WebSockets. Tente usar as últimas versões do Google Chrome ou Firefox"); var element =document.getElementById ("websocketelements"); element.parentNode.removeChild (elemento); Retorna; //} // Você abre uma conexão WebSocket simplesmente chamando o construtor WebSocket websocket =new WebSocket (wsUri); // Quando a conexão é aberta, função invocada automaticamente websocket.onopen =function () {// writeAttributeValues ​​('onOpen Event Fired'); writeToScreen ("Conexão com sucesso ao sistema de estacionamento"); // após a conexão ser aberta, o registro é necessário para a transmissão segura de dados register (); }; // invocado quando uma nova mensagem é recebida websocket.onmessage =function (evt) {onMessage (evt); }; // quando o erro é recebido // Você pode lidar com quaisquer erros que ocorram ouvindo o evento de erro. websocket.onerror =function (evt) {onError (evt); };} function onClose (evt) {// Depois de terminar com seu WebSocket, você pode encerrar a conexão usando o método close (). websocket.close (); // writeAttributeValues ​​('onClose Event Fired'); writeToScreen ("DISCONNECTED");} // Quando uma mensagem é recebida, o evento de mensagem é disparado. function onMessage (evt) {writeToScreen (' RESPONSE:' + evt.data + ''); // writeAttributeValues ​​('onMessage Event Fired'); handleRcvMsg (evt.data); // os dados são enviados para a função handleRcvMsg ()} function onError (evt) {writeToScreen (' ERROR:' + evt.data); // writeAttributeValues ​​('onError Event Fired');} function doSend (message) {// Para enviar uma mensagem por meio da conexão WebSocket, você chama o método send () em sua instância WebSocket websocket.send (message); // writeAttributeValues ​​('onSend Event Fired'); writeToScreen ("SENT:" + mensagem);} função writeAttributeValues ​​(prefixo) {var pre =document.createElement ("p"); pre.style.wordWrap ="quebra de palavra"; pre.innerHTML ="INFO" + getCurrentDate () + "" + prefixo + " readyState:" + websocket.readyState + "bufferedAmount:" + websocket.bufferedAmount + "";; atributos_log.appendChild (pre);} função writeToScreen (mensagem) {var pre =document.createElement ("p"); pre.style.wordWrap ="quebra de palavra"; pre.innerHTML =mensagem; output.appendChild (pre);} function getCurrentDate () {var now =new Date (); var datetime =now.getFullYear () + '/' + (now.getMonth () + 1) + '/' + now.getDate (); datetime + ='' + now.getHours () + ':' + now.getMinutes () + ':' + now.getSeconds (); return datetime;} função browserSupportsWebSockets () {if ("WebSocket" na janela) {return true; } else {return false; }} function getTimeMillis () {return parseInt (Date.now (). toString ());} function register () {writeToScreen ("Registrando dispositivo na conexão WebSocket"); tente {var registerMessage ='{"type":"register", "sdid":"' + device_id + '", "Authorization":"bearer' + device_token + '", "cid":"' + getTimeMillis () + ' "} '; writeToScreen ('Enviando mensagem de registro' + registerMessage + '\ n'); websocket.send (registerMessage, {mask:true}); isWebSocketReady =true; //document.getElementById("rainbow").innerHTML =""; //document.getElementById("rainbow").innerHTML ="Capacity:" + ' 50 ' + "Slot livre:" + '  '+" 50 "; //document.getElementById("indigo").innerHTML ="Capacidade:60, Slot Livre:5"; } catch (e) {writeToScreen ('Falha ao registrar mensagens. Erro ao registrar mensagem:' + e.toString ()); }} // os dados após o recebimento são enviados aqui para a função de processamento handleRcvMsg (msg) {// a mensagem é recebida como a seguinte string // {"ações":[{"nome":"setText", "parâmetros":{"texto" :"4", "text2":"5"}}]} // você deve analisá-lo var msgObj =JSON.parse (msg); if (msgObj.type! ="ação") return; // Retorno antecipado; var ações =msgObj.data.actions; var rainbowData =ações [0] .parameters.text; var indigoData =ações [0] .parameters.text2; console.log ("A ação recebida é" + ações); document.getElementById ("rainbow"). innerHTML ="Capacidade:50, Slot Livre:" + rainbowData; document.getElementById ("indigo"). innerHTML ="Capacidade:60, Slot Livre:" + indigoData; } 

Código Soucre para Sistema de Estacionamento Inteligente

Esquemas