Ampelinformationssystem

Code

• Arduino-Sendercode
• Arduino-Empfänger und MySQLdb
• MySQL_UpdateTrafficLData.php
• MySQL_UpdateDistance.php
• EchoJSON
• MainActivity.java
• AndroidManifest.xml
• strings.xml
• activity_main.xml

Arduino-SendercodeArduino

/* IOTOPIA - 2016-2017 - Ampelinformationssystem (Sender) * von Pieter Luyten &Joppe Smeets * * Distanz zu einem anderen Arduino über RF 433 MHz-Module senden * * RF 433 MHz-Modul:* tx_pin --> Pin 3 * * HC-SR04 Modul:* trig_pin --> Pin 5 * echo_pin --> Pin 6 * */#define tx_pin 3#define trig_pin 5#define echo_pin 6#include  // Bibliothek für RF 433 MHz Module #include "HCSR04.h" // Bibliothek für HC-SR04-ModulHCSR04 Ultraschall(trig_pin,echo_pin); int distance;char CharMsg[21];void setup () { Serial.begin (9600); vw_setup(2000); // Bits pro Sekunde vw_set_tx_pin (tx_pin);}void loop () { Abstand =Ultraschall.Ranging (CM); // Messen Sie den Abstand in cm während (Abstand <0) {// Vermeiden Sie falsche Messwerte, messen Sie den Abstand erneut. Abstand =Ultraschall.Ranging (CM); } sprintf(CharMsg, "%d,", Distanz); vw_send((uint8_t *)CharMsg, strlen(CharMsg)); // Sende die Distanz vw_wait_tx(); // Warten Sie, bis die gesamte Nachricht verschwunden ist Serial.print ( "Distanz (cm):"); Serial.println (Entfernung); Verzögerung(250);}

Arduino-Empfänger &MySQLdbArduino

/* IOTOPIA - 2016-2017 - Ampelinformationssystem (Empfänger + Upload in MySQLdb) * von Pieter Luyten &Joppe Smeets * * Entfernung von einem anderen Arduino über RF empfangen * Ampeldaten und Entfernung in die MySQL-Datenbank hochladen * * RF 433MHz Modul:* rx_pin --> Pin 3 * * TrafficLight (3 LEDs):* RedLED --> Pin 5 * OrangeLED --> Pin 6 * GreenLED --> Pin 7 * * DS3231 (Real-Time-Clock) :* SCL --> SCL (Pin 3 auf Arduino Yun) * SDA --> SDA (Pin 2 auf Arduino Yun) * * SD-Karte - Arduino Yun * SD-Karte (mit PHP-Datei) --> integrierter SD-Slot* /#define RedLED 5#define OrangeLED 6#define GreenLED 7#define rx_pin 9#include  // RF 433 MHz Module#include  // Alarme#include  // I2C communication#include "RTClib.h" // Echtzeituhr#include  // Linux-Prozesse auf dem AR9331 ausführen // UnixTime:Zeit, definiert als die Anzahl der Sekunden, die seit dem 1. Januar 1970 vergangen sindlong UnixTime_green_1; // Nächstes grünes Licht (in UnixTime)long UnixTime_red_1; // Nächstes rotes Licht (in UnixTime)long UnixTime_green_2; // Übernächstes grünes Licht (in UnixTime)long UnixTime_red_2; // Übernächstes rotes Licht (in UnixTime)long s_till_orange; // Sekunden bis orangeRTC_DS3231 rtc;char StringReceived[22];boolean i;int interval =5; // im Sekundenintabstand; // im cmvoid-Setup () { rtc.begin (); //rtc.adjust(DateTime(F(__DATE__), F(__TIME__))); Serial.begin (9600); Bridge.begin(); // Brücke initialisieren vw_setup(2000); // Bits pro Sekunde vw_set_rx_pin (rx_pin); vw_rx_start(); Alarm.timerRepeat(Intervall, UpdateTrafficLData); // Ampeldaten aktualisieren (nächstes grünes/rotes Licht ... ) Alarm.timerRepeat(1,PrintCurrentTime); // Aktuelle Uhrzeit alle x Sekunden ausgeben pinMode (GreenLED, OUTPUT); pinMode (OrangeLED, AUSGANG); pinMode (Rote LED, AUSGANG); digitalWrite (Grüne LED, NIEDRIG); digitalWrite (OrangeLED, NIEDRIG); digitalWrite (Rote LED, NIEDRIG); Serial.println ("Setup abgeschlossen");}void loop () { Alarm.delay (0); // Diese Verzögerung sollte anstelle des normalen Arduino delay() verwendet werden, // für die rechtzeitige Verarbeitung von Alarmen und Timern. Sie können 0 für minimale Verzögerung übergeben. RF_Listen(); }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); } // Stellen Sie sicher, dass das letzte Datenbit gesendet wird. Serial.flush();}void MySQL_UpdateDistance(){ Process p; p.begin("/mnt/sda1/MySQL_UpdateDistance.php"); p.addParameter(String(Abstand)); p.run(); // Feedback lesen (zum Debuggen) while (p.available ()> 0) { char c =p.read (); Serial.print (c); } // Stellen Sie sicher, dass das letzte Datenbit gesendet wird. 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 - jetzt.unixtime(); if (i ==0) { DigitalWrite (GreenLED, LOW); digitalWrite (OrangeLED, NIEDRIG); digitalWrite (Rote LED, HOCH); } if (i ==1 &&s_till_orange <=3) { DigitalWrite (GreenLED, LOW); digitalWrite (OrangeLED, HOCH); digitalWrite (Rote LED, NIEDRIG); } if (i ==1 &&s_till_orange> 3) { digitalWrite (GreenLED, HIGH); digitalWrite (OrangeLED, NIEDRIG); digitalWrite (Rote LED, NIEDRIG); }}

MySQL_UpdateTrafficLData.phpPHP

#!/usr/bin/php-cliconnect_error) { trigger_error('Datenbankverbindung fehlgeschlagen:' . $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";ly($(s) ) ===false) { trigger_error('Falsche SQL:' . $sql . ' Fehler:' . $conn->error, E_USER_ERROR);}else{echo "Daten eingefügt!\n";} ?>

MySQL_UpdateDistance.phpPHP

#!/usr/bin/php-cliconnect_error) { trigger_error('Datenbankverbindung fehlgeschlagen:' . $conn->connect_error, E_USER_ERROR );}$sql="UPDATE TrafficL_data SET Distance='$Distance'WHERE id=1";if($conn->query($sql) ===false) { trigger_error('Falsche SQL:' . $sql . ' Fehler:' . $conn->error, E_USER_ERROR);}else{echo "Entfernung eingefügt!\n";}?>

EchoJSONPHP

MainActivity.javaJava

Paket 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;öffentliche Klasse MainActivity erweitert AppCompatActivity { // Zeigt die Zeichenfolge "data ." ", das die Ergebnisse enthält TextView-Ergebnisse; //Die Textansicht, die die empfohlene Geschwindigkeit enthält TextView recSpeed; // URL des zu analysierenden Objekts String JsonURL ="YourURLhere"; // Dieser String enthält die Ergebnisse String data =""; // Definieren der Volley-Anforderungswarteschlange, die gleichzeitig die URL-Anforderung verarbeitet RequestQueue requestQueue; //Timer-Objekt, um die Daten jede Sekunde zu aktualisieren //Timer-Timer; //Das speedLimit (cm/s) private final static double maxSpeed ​​=18; //Die empfohlene Geschwindigkeit private double speed; // Häufigkeit in der Tabelle public final static int NUMBER_OF_ENTRIES =2; //Array mit den Zeiten, in denen es grün ist long[] unixTimesGreen =new long[NUMBER_OF_ENTRIES]; //Array mit den Zeiten, in denen es rot ist long[] unixTimesRed =new long[NUMBER_OF_ENTRIES]; //Variable, die den Abstand hält private double distance; //Variablen zum Wiederholen von updateTable private final ScheduledExecutorService scheduler =Executors.newSingleThreadScheduledExecutor(); //zum Testen:private Future TimingTask; public void tick (lange Millisekunden) {timingTask =scheduler.scheduleAtFixedRate(new Runnable() { public void run() {updateTable();}}, 0, Millisekunden, TimeUnit.MILLISECONDS); } @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); //textViews um Ergebnisse in Ergebnisse umzuwandeln =(TextView) findViewById(R.id.jsonData); recSpeed ​​=(TextView) findViewById(R.id.recommendedSpeed); //Tabelle initialisieren updateTable(); // App alle 100 Millisekunden aktualisieren Tick (500); // zum Arbeiten mit einem Timer-Objekt zum wiederholten Aktualisieren /** Timer =new Timer("Timer"); timer.schedule(neue UpdateTable(),(long)100,(long)100); */ } // für die Arbeit mit Timer-Objekten, um wiederholt zu aktualisieren /** private Klasse UpdateTable erweitert TimerTask{ public void run(){ updateTable(); } } */ private void updateTable(){//reset String data =""; // Erstellt die Volley-Anforderungswarteschlange requestQueue =Volley.newRequestQueue(this); //zum Testen /** // Wandelt die Ergebnisse in die TextView im XML-Hauptlayout mit der ID um jsonData results =(TextView) findViewById(R.id.jsonData); */ // Erstellen der JsonArrayRequest-Klasse namens arrayreq, Übergeben der erforderlichen Parameter //JsonURL ist die URL, die von JsonArrayRequest abgerufen werden soll arrayreq =new JsonArrayRequest(JsonURL, // Der zweite Parameter Listener überschreibt die Methode onResponse() und übergibt //JSONArray als Parameter new Response.Listener() { // Nimmt die Antwort von der JSON-Anfrage @Override public void onResponse(JSONArray response) { try { // Ruft das erste JSON-Objekt im äußeren Array ab JSONObject TrafficLObj =response.getJSONObject( 0); // Ruft "trafficArry" aus dem JSON-Objekt ab JSONArray trafficArry =TrafficLObj.getJSONArray("TrafficLArray"); // Iteriert durch das JSON-Array, holt Objekte und fügt sie //zu der Listenansicht hinzu, bis keine weiteren Objekte mehr vorhanden sind trafficArry for (int i =0; i  maxSpeed) speed =maxSpeed; else Geschwindigkeit =Distanz/((unixTimesGreen[Intervall]-Zeit)); Geschwindigkeit =Geschwindigkeit*5; }}

AndroidManifest.xmlXML

// xxx xxx ändern         

strings.xmlXML

 NooitRood

activity_main.xmlXML

Schaltpläne