Code

• Raspberry Pi (personeelsparking)
• Arduino (sonar)
• Web-app (HTML)
• Web-app (clientzijde)

Raspberry Pi (personeel parkeren)JavaScript

//personeel parkeergegevens transfervar webSocketUrl ="wss://api.artik.cloud/v1.1/websocket?ack=true";var device_id ="Uw apparaat-ID"; // personeel parkeren DEVICE IDvar device_token ="Your Device Token"; //personeel parkeren DEVICE TOKEN// vereist websocket-module om verbinding te maken // voer de volgende twee opdrachten uit naar de terminal van uw pi // sudo apt-get update// npm install websocketvar WebSocket =required('ws');var isWebSocketReady =false;var data="";var ws =null;// vereisen seriële poortmodule voor raspberry pi // voer het volgende commando uit naar terminal// npm install serialportvar serialport =required("serialport");var SerialPort =serialport.SerialPort;var sp =nieuw SerialPort ("/dev/ttyACM0", { //voor seriële communicatie met arduino-baudrate:9600, // we gebruiken UNO, dus de baudrate is 9600, mogelijk moet u deze wijzigen volgens uw modelparser:serialport.parsers.readline(" \n")});var parking_state=0;// variabele om te controleren op parking state_gate/** * Haalt de huidige tijd op in millis */function getTimeMillis(){ return parseInt(Date.now().toString());}/** * Maak een /websocket-verbinding en stel GPIO-pin in */function start() { //Maak de WebSocket-verbinding isWebSocketReady =false; ws =nieuwe WebSocket(webSocketUrl); // deze functie is aangeroepen bij succesvolle verbinding ws.on('open', function() { console.log("WebSocket-verbinding is open ...."); // u moet zich registreren voor succesvolle gegevensoverdracht // registratie is voor authenticatie of beveiligde gegevensoverdracht register(); }); ws.on('message', function(data) {//deze lus wordt aangeroepen wanneer de client een bericht verzendt handleRcvMsg(data); //data wordt verzonden naar de functie handleRcvMsg()}); ws.on('close', function() { console.log("WebSocket-verbinding is gesloten ..."); }); }/** * Stuurt een registratiebericht naar /websocket-eindpunt *///Client werkt alleen wanneer het apparaat wordt geregistreerd vanuit herefunction register(){ console.log("Apparaat registreren op de WebSocket-verbinding"); try{ var registerMessage ='{"type":"register", "sdid":"'+device_id+'", "Authorization":"bearer '+device_token+'", "cid":"'+getTimeMillis()+' "}'; console.log('Registerbericht wordt verzonden' + registerMessage + '\n'); ws.send(registerMessage, {mask:true}); isWebSocketReady =waar; } catch (e) { console.error('Kan berichten niet registreren. Fout bij het registreren van bericht:' + e.toString()); } }//data na ontvangst wordt hierheen gestuurd voor verwerking// in ons geval zal deze functie niet worden gebruikt omdat we geen actie zullen ontvangen// in raspberry pi. Dit is voor toekomstige modificatie. function handleRcvMsg (msg) {// je moet de ontvangen string ontleden var msgObj =JSON.parse (msg); if (msgObj.type !="action") return; //Vroege terugkeer; var acties =msgObj.data.actions; var actionName =acties[0].name; console.log("De ontvangen actie is " + actionName); // je moet je geregistreerde acties kennen om te kunnen uitvoeren volgens if (actionName.toLowerCase() =="settext") { // doe hier iets na ontvangst van 'parking_state' console.log ('receving erkende actie' + actionName); } else { //deze lus wordt uitgevoerd als een niet-geregistreerde actie wordt ontvangen // dus je moet elke actie registreren in cloud console.log ('Niets doen sinds het ontvangen van niet-herkende actie' + actionName); opbrengst; } }/** * Stuur één bericht naar ARTIK Cloud *///Deze functie is verantwoordelijk voor het verzenden van commando's naar cloud//functie sendStateToArtikCloud(parkeren) stuurt aantal vrije parkeerplaatsen naar artik cloudfunctie sendStateToArtikCloud(parking_slot){ try{ ts =', "ts":'+getTimeMillis(); var data ={ "parking_slot":parking_slot // instellen van de parkeerwaarde van argument naar onze cloudvariabele "parking_waarde"}; var payload ='{"sdid":"'+device_id+'"'+ts+', "data":'+JSON.stringify(data)+', "cid":"'+getTimeMillis()+'"}'; console.log('Belasting wordt verzonden' + lading + '\n'); ws.send(payload, {masker:true}); } catch (e) { console.error('Fout bij het verzenden van een bericht:' + e.toString() +'\n'); } }function exitClosePins() { console.log('Verlaat en vernietig alle pinnen!'); proces.exit(); }start();//executes elke keer wanneer gegevens worden ontvangen van arduino (30 sec geprogrammeerde vertraging van arduino)sp.on("open", functie () { sp.on('data', functie(data) { console .log("Seriële poort ontvangen data:" + data); //sendStateToArtikCloud(data);//free parking slot var parking_slot =parseInt(data); sendStateToArtikCloud(parking_slot); });});process.on(' SIGINT', exitClosePins);

Arduino (sonar)C/C++

#define echoPin1 2 // Echo Pin voor sonar 1#define trigPin1 3 // Triggerpin voor sonar 1#define echoPin2 4 // Echo Pin voor sonar 2 #define trigPin2 5 // Triggerpin voor sonar 2#define echoPin3 6 // Echopin voor sonar 3#define trigPin3 7 // Triggerpin voor sonar 3//#define echoPin4 9 // Echopin voor sonar 4//#define trigPin4 8 // Triggerpin voor sonar 4lange duur1, afstand1; // Duur die wordt gebruikt om afstand te berekenenlange duur2, afstand2;lange duur3, afstand3;//lange duur4, afstand4; int count=0;int freeSlot =0;void setup() {Serial.begin (9600); // initieer seriële communicatie naar raspberry pi pinMode (trigPin1, OUTPUT); // trigger pin als output pinMode (echoPin1, INPUT); // echo pin als input pinMode (trigPin2, OUTPUT); pinMode (echoPin2, INPUT); pinMode (trigPin3, UITGANG); pinMode (echoPin3, INPUT); //pinMode (trigPin4, UITGANG); //pinMode (echoPin4, INPUT); }void loop() {/* De volgende trigPin/echoPin-cyclus wordt gebruikt om de afstand van het dichtstbijzijnde object te bepalen door er geluidsgolven vanaf te laten stuiteren. */ /* Ten minste 10 microseconden hoog niveau signaal is vereist om * pin te activeren. * _____ * | | * -------------! !--------- * .....|10us |........ * de module produceert dan acht 40KHz pulssignalen en wacht op echo */digitalWrite(trigPin1, LOW); vertragingMicroseconden(2); digitalWrite(trigPin1, HIGH); vertraging Microseconden (10); digitalWrite(trigPin1, LAAG); // pulseIn() functie bepaalt een pulsduur in de tijd // duur van de puls is evenredig met de afstand van het obstakel duur1 =pulseIn(echoPin1, HIGH); digitalWrite(trigPin2, LAAG); vertragingMicroseconden(2); digitalWrite(trigPin2, HOOG); vertraging Microseconden (10); digitalWrite(trigPin2, LAAG); duur2 =pulseIn(echoPin2, HOOG); digitalWrite(trigPin3, LAAG); vertragingMicroseconden(2); digitalWrite(trigPin3, HOOG); vertraging Microseconden (10); digitalWrite(trigPin3, LAAG); duur3 =pulseIn(echoPin3, HOOG); //digitalWrite (trigPin4, LAAG); //vertraging Microseconden (2); //digitalWrite(trigPin4, HOOG); //vertraging Microseconden (10); //digitalWrite (trigPin4, LAAG); // duur4 =pulseIn (echoPin4, HOOG); // afstand =(hoge tijdsnelheid van geluid (340M/S) / 2, // in centimeter =uS/58 afstand1 =duur1/58,2; if(distance1<10) distance1 =1; else distance1 =0; distance2 =duration2 /58.2; if(distance2<10) distance2 =1; else distance2 =0; distance3 =duur3/58,2; if(distance3<10) distance3 =1; else distance3 =0; //distance4 =duur4/58,2; //if (distance4<10) //distance4 =1; //else distance4 =0; // voeg het resultaat van alle sensoren toe om het totale aantal auto's te tellen =afstand1 + afstand2 + afstand3;; // vrij slot =totaal slot - totaal autovrij slot =3 - count; // het totale aantal slots wordt naar de raspberry pi gestuurd met behulp van usb Serial.println (freeSlot); // de status wordt elke 30 seconden bijgewerkt. delay (5000); //freeSlot =0; //distance1 =0; //distance2 =0;// distance3 =0;//distance4 =0;}

Web-app (HTML)HTML

        
ARTIK Cloudgebaseerd slim parkeersysteem
 
 
 
Personeel parkeren
 
In de buurt van Main Cmapus
 Gegevens ontvangen... 
1
 
Studenten-/gastenparkeerplaats 
 
Voorpoort, nabij Union bank
 Gegevens ontvangen... 
 
 
 
 
 
 
 
 
 
 
 Verbinding met parkeersysteem sluiten
 
 
Uitvoerconsole
 

   

Web-app (clientzijde)JavaScript

// real-time interacties zijn mogelijk met websocket// Let op de ws:. Dit is het nieuwe URL-schema voor WebSocket-verbindingen. // Er is ook wss:voor een veilige WebSocket-verbinding op dezelfde manier // https:wordt gebruikt voor veilige HTTP-verbindingen.// je kunt het krijgen van de Artik-clouddocumentatie pagevar wsUri ="wss://api.artik.cloud/v1 .1/websocket?ack=true";var device_id ="Uw apparaat-ID"; // raspi3 DEVICE IDvar device_token ="Uw apparaattoken"; //raspi3 DEVICE TOKENvar output;var attributes_log;var websocket;function init() {// document.getElementById() schrijf iets naar html pagina output =document.getElementById("output"); attributes_log =document.getElementById("attributes_log"); if (browserSupportsWebSockets() ===false) { // controleer browserondersteuning websocket-protocol of niet writeToScreen("Sorry! uw webbrowser ondersteunt WebSockets niet. Probeer Google Chrome of Firefox nieuwste versies te gebruiken"); var element =document.getElementById("websocketelements"); element.parentNode.removeChild(element); opbrengst; // } //U opent een WebSocket-verbinding door simpelweg de WebSocket-constructor websocket =new WebSocket(wsUri) aan te roepen; // Wanneer de verbinding open is, wordt de functie automatisch aangeroepen websocket.onopen =function() { //writeAttributeValues('onOpen Event Fired'); writeToScreen("Succesvol verbonden met parkeersysteem"); // nadat de verbinding is geopend, is registratie vereist voor beveiligde gegevensoverdracht register(); }; // aangeroepen wanneer een nieuw bericht is ontvangen websocket.onmessage =function(evt) {onMessage(evt); }; // wanneer een fout wordt ontvangen // U kunt eventuele fouten afhandelen door te luisteren naar de foutgebeurtenis. websocket.onerror =function(evt) { onError(evt); };}function onClose(evt) { // Als u klaar bent met uw WebSocket, kunt u de verbinding beëindigen met de methode close(). websocket.close(); //writeAttributeValues('onClose Event Fired'); writeToScreen("DISCONNECTED");}// Wanneer een bericht wordt ontvangen, wordt de berichtgebeurtenis geactiveerd. function onMessage(evt) {writeToScreen('RESPONSE:' + evt.data + ''); //writeAttributeValues('onMessage Event Fired'); handleRcvMsg(evt.data); // data wordt verzonden naar de functie handleRcvMsg()}function onError(evt) {writeToScreen('ERROR: ' + evt.data); //writeAttributeValues('onError Event Fired');}function doSend(message) { // Om een ​​bericht via de WebSocket-verbinding te verzenden, roept u de methode send() aan op uw WebSocket-instantie websocket.send(message); //writeAttributeValues('onSend Event Fired'); writeToScreen("SENT:" + bericht);}functie writeAttributeValues(prefix) { var pre =document.createElement("p"); pre.style.wordWrap ="breekwoord"; pre.innerHTML ="INFO " + getCurrentDate() + " " + prefix + " readyState:" + websocket.readyState + " bufferedAmount:" + websocket.bufferedAmount + "";; attributes_log.appendChild(pre);}function writeToScreen(message) { var pre =document.createElement("p"); pre.style.wordWrap ="breekwoord"; pre.innerHTML =bericht; output.appendChild(pre);}functie getCurrentDate() { var now =new Date(); var datetime =now.getFullYear() + '/' + (now.getMonth() + 1) + '/' + now.getDate(); datetime +=' ' + now.getHours() + ':' + now.getMinutes() + ':' + now.getSeconds(); return datetime;}function browserSupportsWebSockets() { if ("WebSocket" in venster) { return true; } else { return false; }}function getTimeMillis(){ return parseInt(Date.now().toString());}function register(){ writeToScreen("Apparaat registreren op de WebSocket-verbinding"); try{ var registerMessage ='{"type":"register", "sdid":"'+device_id+'", "Authorization":"bearer '+device_token+'", "cid":"'+getTimeMillis()+' "}'; writeToScreen('Registerbericht wordt verzonden' + registerMessage + '\n'); websocket.send(registerMessage, {mask:true}); isWebSocketReady =waar; //document.getElementById("regenboog").innerHTML =""; //document.getElementById("rainbow").innerHTML ="Capaciteit:"+'50 '+"Gratis slot:"+''+"50"; //document.getElementById("indigo").innerHTML ="Capaciteit:60, vrij slot:5"; } catch (e) { writeToScreen('Kan berichten niet registreren. Fout bij het registreren van bericht:' + e.toString()); } }//data na ontvangst wordt hierheen gestuurd voor verwerkingsfunctie handleRcvMsg(msg){ // bericht wordt ontvangen als volgende string // {"actions":[{"name":"setText","parameters":{"text" :"4", "text2":"5"}}]} // je moet het ontleden var msgObj =JSON.parse(msg); if (msgObj.type !="action") return; //Vroege terugkeer; var acties =msgObj.data.actions; var regenboogData =acties[0].parameters.tekst; var indigoData =acties[0].parameters.text2; console.log("De ontvangen actie is " + acties); document.getElementById("rainbow").innerHTML ="Capaciteit:50, vrij slot:"+rainbowData; document.getElementById("indigo").innerHTML ="Capaciteit:60, gratis slot:"+indigoData; }

Sucre-code voor slim parkeersysteem

Schema's