Système d'information sur les feux de circulation

Code

• Code du transmetteur Arduino
• Récepteur Arduino et MySQLdb
• MySQL_UpdateTrafficLData.php
• MySQL_UpdateDistance.php
• EchoJSON
• ActivitéMain.java
• AndroidManifest.xml
• chaînes.xml
• activity_main.xml

Code du transmetteur ArduinoArduino

/* IOTOPIA - 2016-2017 - Traffic Light Information System (Transmitter) * par Pieter Luyten &Joppe Smeets * * Envoyer la distance à un autre arduino via des modules RF 433MHz * * Module RF 433MHz :* tx_pin --> broche 3 * * Module HC-SR04 :* trig_pin --> pin 5 * echo_pin --> pin 6 * */#define tx_pin 3#define trig_pin 5#define echo_pin 6#include  // Bibliothèque pour modules RF 433 MHz #include "HCSR04.h" // Bibliothèque pour le module HC-SR04 HCSR04 ultrasonic(trig_pin,echo_pin); int distance;char CharMsg[21];void setup() { Serial.begin(9600); vw_setup(2000); // Bits par seconde vw_set_tx_pin(tx_pin);}void loop() { distance =ultrasonic.Ranging(CM); // Mesurer la distance en cm while(distance <0){ // Eviter les fausses lectures, mesurer à nouveau la distance distance =ultrasonic.Ranging(CM); } sprintf(CharMsg, "%d,", distance); vw_send((uint8_t *)CharMsg, strlen(CharMsg)); // Envoie la distance vw_wait_tx(); // Attendez que tout le message disparaisse Serial.print("Distance (cm):"); Serial.println(distance); retard (250);}

Récepteur Arduino &MySQLdbArduino

/* IOTOPIA - 2016-2017 - Traffic Light Information System (Receiver + Upload to MySQLdb) * par Pieter Luyten &Joppe Smeets * * Recevoir la distance d'un autre arduino via RF * Charger les données des feux de circulation et la distance dans la base de données MySQL * * Module RF 433MHz :* rx_pin --> broche 3 * * TrafficLight (3 LED) :* RedLED --> broche 5 * OrangeLED --> broche 6 * GreenLED --> broche 7 * * DS3231 (Real-Time-Clock) :* SCL --> SCL (broche 3 sur Arduino Yun) * SDA --> SDA (broche 2 sur Arduino Yun) * * Carte SD - Arduino Yun * Carte SD (avec fichier PHP) --> slot SD intégré* /#define RedLED 5#define OrangeLED 6#define GreenLED 7#define rx_pin 9#include  // Modules RF 433 MHz#include  // Alarmes#include  // I2C communication#include "RTClib.h" // Horloge temps réel#include  // Exécute les processus Linux sur l'AR9331// UnixTime :Temps, défini comme le nombre de secondes écoulées depuis le 1er janvier 1970long UnixTime_green_1 ; // Prochain feu vert (dans UnixTime)long UnixTime_red_1; // Prochain feu rouge (dans UnixTime)long UnixTime_green_2; // Suivant mais un feu vert (dans UnixTime)long UnixTime_red_2; // Suivant mais une lumière rouge (dans UnixTime)long s_till_orange; // Secondes jusqu'à orangeRTC_DS3231 rtc;char StringReceived[22];boolean i;int interval =5; // en secondesint distance ; // dans cmvoid setup() { rtc.begin(); //rtc.adjust(DateTime(F(__DATE__), F(__TIME__))); Serial.begin(9600); Pont.begin(); // Initialiser le pont vw_setup(2000); // Bits par seconde vw_set_rx_pin(rx_pin); vw_rx_start(); Alarm.timerRepeat(intervalle, UpdateTrafficLData); // Mettre à jour les données des feux de circulation (prochain feu vert/rouge...) Alarm.timerRepeat(1,PrintCurrentTime); // Affiche l'heure actuelle toutes les x secondes pinMode(GreenLED, OUTPUT); pinMode(OrangeLED, SORTIE); pinMode (LED rouge, SORTIE); digitalWrite (GreenLED, LOW); digitalWrite(OrangeLED, LOW); digitalWrite(RedLED, LOW); Serial.println("Configuration terminée");}boucle void() { Alarm.delay(0); // Ce délai doit être utilisé à la place du délai Arduino normal (), // pour un traitement rapide des alarmes et des minuteries. Vous pouvez passer 0 pour un délai minimal. RF_Ecouter (); }void RF_Listen (){ uint8_t buf[VW_MAX_MESSAGE_LEN]; uint8_t buflen =VW_MAX_MESSAGE_LEN; if (vw_get_message(buf, &buflen)) { int a; for (a =0; a  0) { char c =p.read(); Serial.print(c); } // Assurez-vous que le dernier bit de données est envoyé. Serial.flush();}void MySQL_UpdateDistance(){ Process p; p.begin("/mnt/sda1/MySQL_UpdateDistance.php"); p.addParameter(String(distance)); p.run(); // Lire les commentaires (pour le débogage) while (p.available()> 0) { char c =p.read(); Serial.print(c); } // Assurez-vous que le dernier bit de données est envoyé. Serial.flush();}void PrintCurrentTime() { DateTime now =rtc.now(); SetLEDsTrafficL(); Serial.print(now.hour(), DEC); Serial.print(':'); Serial.print(now.minute(), DEC); Serial.print(':'); Serial.print(now.second(), DEC); Serial.print(" "); Serial.println(now.unixtime());}void SetLEDsTrafficL () { DateTime now =rtc.now(); s_till_orange =UnixTime_red_1 - now.unixtime(); if (i ==0) { digitalWrite(GreenLED, LOW); digitalWrite(OrangeLED, LOW); digitalWrite (LED rouge, ÉLEVÉ); } if (i ==1 &&s_till_orange <=3) { digitalWrite(GreenLED, LOW); digitalWrite(OrangeLED, HAUT); digitalWrite(RedLED, LOW); } if (i ==1 &&s_till_orange> 3) { digitalWrite(GreenLED, HIGH); digitalWrite(OrangeLED, LOW); digitalWrite(RedLED, LOW); }}

MySQL_UpdateTrafficLData.phpPHP

#!/usr/bin/php-cliconnect_error) { trigger_error('La connexion à la base de données a échoué :' . $conn->connect_error, E_USER_ERROR);} $sql="UPDATE TrafficL_data SET UnixTime_green_1='$UnixTime_green_1', UnixTime_red_1='$UnixTime_red_1',UnixTime_green_2='$UnixTime_green_2', UnixTime_red_2='$UnixTime_red_2' WHERE id=1">query($conn-sql ) ===false) { trigger_error('Mauvais SQL :' . $sql . ' Erreur :' . $conn->error, E_USER_ERROR);}else{echo "Données insérées !\n";} ?>

MySQL_UpdateDistance.phpPHP

#!/usr/bin/php-cliconnect_error) { trigger_error('Echec de la connexion à la base de données :' . $conn->connect_error, E_USER_ERROR );}$sql="UPDATE TrafficL_data SET Distance='$Distance'WHERE id=1";if($conn->query($sql) ===false) { trigger_error('Wrong SQL:' . $sql . ' Erreur :' . $conn->error, E_USER_ERROR);}else{echo "Distance insérée !\n";}?>

EchoJSONPHP

MainActivity.javaJava

package com.example.xxx.xxx ;// change xxx xxximport android.support.v7.app.AppCompatActivity ;import android.os.Bundle ;import android.util.Log ;import android.widget.TextView ;import com .android.volley.RequestQueue;import com.android.volley.Response;import com.android.volley.VolleyError;import com.android.volley.toolbox.JsonArrayRequest;import com.android.volley.toolbox.Volley;import org. json.JSONArray;import org.json.JSONException;import org.json.JSONObject;//import java.text.DateFormat;import java.util.Date;import java.util.Timer;//import java.util.TimerTask; import java.util.concurrent.Executors;import java.util.concurrent.Future;import java.util.concurrent.ScheduledExecutorService;import java.util.concurrent.TimeUnit;public class MainActivity extend AppCompatActivity { // Affiche la chaîne "data " qui contient les résultats TextView ; //Le textview qui contient la vitesse recommandée TextView recSpeed; // URL de l'objet à analyser String JsonURL ="YourURLhere"; // Cette chaîne contiendra les résultats String data =""; // Définition de la file d'attente de requêtes Volley qui gère la requête d'URL simultanément RequestQueue requestQueue; //objet timer pour mettre à jour les données toutes les secondes //timer timer; //Le speedLimit (cm/s) privé final statique double maxSpeed ​​=18; //La vitesse recommandée privée double vitesse ; //nombre de fois dans la table public final static int NUMBER_OF_ENTRIES =2; // tableau avec les moments où il est vert long[] unixTimesGreen =new long[NUMBER_OF_ENTRIES]; // tableau avec les moments où il est rouge long[] unixTimesRed =new long[NUMBER_OF_ENTRIES]; //variable qui contient la distance private double distance; //variables pour répéter updateTable private final ScheduledExecutorService scheduler =Executors.newSingleThreadScheduledExecutor(); //pour tester :private Future timingTask; public void tick(long millisecondes) { timingTask =scheduler.scheduleAtFixedRate(new Runnable() { public void run() { updateTable(); } }, 0, millisecondes, TimeUnit.MILLISECONDS); } @Override protected void onCreate(Bundle protectedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); //textViews pour convertir les résultats en résultats =(TextView) findViewById(R.id.jsonData); recSpeed ​​=(TextView) findViewById(R.id.recommendedSpeed); //initialise la table updateTable(); //mettre à jour l'application toutes les 100 millisecondes (500 ); //pour travailler avec un objet timer pour mettre à jour à plusieurs reprises /** timer =new Timer("Timer"); timer.schedule(new UpdateTable(),(long)100,(long)100); */ } //pour travailler avec l'objet timer pour mettre à jour à plusieurs reprises /** la classe privée UpdateTable étend TimerTask{ public void run(){ updateTable(); } } */ private void updateTable(){ //reset String data =""; // Crée la file d'attente de requêtes Volley requestQueue =Volley.newRequestQueue(this); //pour tester /** // Convertit les résultats dans le TextView trouvé dans la mise en page principale XML avec l'id jsonData result =(TextView) findViewById(R.id.jsonData); */ // Création de la classe JsonArrayRequest appelée arrayreq, en passant les paramètres requis // JsonURL est l'URL à récupérer à partir de JsonArrayRequest arrayreq =new JsonArrayRequest(JsonURL, // Le deuxième paramètre Listener remplace la méthode onResponse() et passe //JSONArray en tant que paramètre new Response.Listener() { // Prend la réponse de la demande JSON @Override public void onResponse(JSONArray response) { try { // Récupère le premier objet JSON dans le tableau externe JSONObject TrafficLObj =response.getJSONObject( 0); // Récupère "trafficArry" à partir de l'objet JSON JSONArray trafficArry =TrafficLObj.getJSONArray("TrafficLArray"); // Itère dans le tableau JSON pour obtenir des objets et les ajouter // à la vue de liste jusqu'à ce qu'il n'y ait plus d'objets dans trafficArry for (int i =0; i  maxSpeed) speed =maxSpeed ; sinon vitesse =distance/((unixTimesGreen[interval]-time)); vitesse =vitesse*5 ; }}

AndroidManifest.xmlXML

// modifier xxx xxx         

strings.xmlXML

 NooitRood

activity_main.xmlXML

Schémas