Sistema de Informação de Semáforos

Código

• Código do transmissor Arduino
• Arduino Receiver &MySQLdb
• MySQL_UpdateTrafficLData.php
• MySQL_UpdateDistance.php
• EchoJSON
• MainActivity.java
• AndroidManifest.xml
• strings.xml
• activity_main.xml

Código do transmissor Arduino Arduino

 / * IOTOPIA - 2016-2017 - Traffic Light Information System (Transmitter) * por Pieter Luyten &Joppe Smeets * * Enviar distância para outro arduino via módulos RF 433MHz * * Módulo RF 433MHz:* tx_pin -> pino 3 * * Módulo HC-SR04:* trig_pin -> pino 5 * echo_pin -> pino 6 * * / # define tx_pin 3 # define trig_pin 5 # define echo_pin 6 # include  // Biblioteca para módulos RF 433 MHz #include "HCSR04.h" // Biblioteca para o módulo HC-SR04HCSR04 ultrasonic (trig_pin, echo_pin); distância interna; CharMsg char [21]; configuração void () {Serial.begin (9600); vw_setup (2000); // Bits por segundo vw_set_tx_pin (tx_pin);} void loop () {distance =ultrasonic.Ranging (CM); // Meça a distância em cm while (distance <0) {// Evite leituras falsas, meça a distância novamente distance =ultrasonic.Ranging (CM); } sprintf (CharMsg, "% d,", distância); vw_send ((uint8_t *) CharMsg, strlen (CharMsg)); // Envia a distância vw_wait_tx (); // Espere até que toda a mensagem desapareça Serial.print ("Distance (cm):"); Serial.println (distância); atraso (250);} 

Receptor Arduino e MySQLdb Arduino

 / * IOTOPIA - 2016-2017 - Traffic Light Information System (Receiver + Upload to MySQLdb) * por Pieter Luyten &Joppe Smeets * * Receba distância de outro Arduino via RF * Upload de dados de semáforo e distância para banco de dados MySQL * * Módulo RF 433 MHz:* rx_pin -> pino 3 * * TrafficLight (3 LEDs):* RedLED -> pino 5 * OrangeLED -> pino 6 * GreenLED -> pino 7 * * DS3231 (Real-Time-Clock) :* SCL -> SCL (pino 3 no Arduino Yun) * SDA -> SDA (pino 2 no Arduino Yun) * * Cartão SD - Arduino Yun * Cartão SD (com arquivo PHP) -> slot SD integrado * / # define RedLED 5 # define OrangeLED 6 # define GreenLED 7 # define rx_pin 9 # include  // Módulos RF 433 MHz # include  // Alarms # include  // I2C comunicação # include "RTClib.h" // Real Time Clock # include  // Executar processos Linux no AR9331 // UnixTime:Tempo, definido como o número de segundos decorridos desde 1º de janeiro de 1970, UnixTime_green_1; // Próxima luz verde (em UnixTime) long UnixTime_red_1; // Próxima luz vermelha (em UnixTime) long UnixTime_green_2; // Próximo, mas uma luz verde (em UnixTime) long UnixTime_red_2; // Próximo, exceto uma luz vermelha (em UnixTime) long s_till_orange; // Segundos até orangeRTC_DS3231 rtc; char StringReceived [22]; boolean i; int interval =5; // em segundosint distância; // em cmvoid setup () {rtc.begin (); //rtc.adjust(DateTime(F(__DATE__), F (__ TIME__))); Serial.begin (9600); Bridge.begin (); // Inicializar a ponte vw_setup (2000); // Bits por segundo vw_set_rx_pin (rx_pin); vw_rx_start (); Alarm.timerRepeat (intervalo, UpdateTrafficLData); // Atualizar os dados do semáforo (próximo semáforo verde / vermelho ...) Alarm.timerRepeat (1, PrintCurrentTime); // Imprime a hora atual a cada x segundos pinMode (GreenLED, OUTPUT); pinMode (OrangeLED, OUTPUT); pinMode (RedLED, OUTPUT); digitalWrite (GreenLED, LOW); digitalWrite (OrangeLED, LOW); digitalWrite (RedLED, LOW); Serial.println ("Instalação concluída");} void loop () {Alarm.delay (0); // Este atraso deve ser usado em vez do atraso normal do Arduino (), // para o processamento oportuno de alarmes e temporizadores. Você pode passar 0 para um atraso mínimo. 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; para (a =0; a  0) {char c =p.read (); Serial.print (c); } // Certifique-se de que o último bit de dados seja enviado. Serial.flush ();} void MySQL_UpdateDistance () {Processo p; p.begin ("/ mnt / sda1 / MySQL_UpdateDistance.php"); p.addParameter (String (distância)); p.run (); // Lê o feedback (para depuração) while (p.available ()> 0) {char c =p.read (); Serial.print (c); } // Certifique-se de que o último bit de dados seja enviado. 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 (RedLED, HIGH); } if (i ==1 &&s_till_orange <=3) {digitalWrite (GreenLED, LOW); digitalWrite (OrangeLED, HIGH); digitalWrite (RedLED, LOW); } if (i ==1 &&s_till_orange> 3) {digitalWrite (GreenLED, HIGH); digitalWrite (OrangeLED, LOW); digitalWrite (RedLED, LOW); }} 

MySQL_UpdateTrafficLData.php PHP

 #! / usr / bin / php-cli  connect_error) {trigger_error ('Falha na conexão do banco de dados:'. $ 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 ='$ 1 UnixTime_red_2'; ) ===false) {trigger_error ('SQL errado:'. $ sql. 'Erro:'. $ conn-> erro, E_USER_ERROR);} else {echo "Dados inseridos! \ n";}?> 

MySQL_UpdateDistance.php PHP

 #! / usr / bin / php-cli  connect_error) {trigger_error (' Falha na conexão do banco de dados:'. $ conn-> connect_error, E_USER_ERROR );} $ sql ="ATUALIZAR TrafficL_data SET Distance ='$ Distance'WHERE id =1"; if ($ conn-> query ($ sql) ===false) {trigger_error (' SQL errado:'. $ sql. 'Erro:'. $ Conn-> erro, E_USER_ERROR);} else {echo "Distância inserida! \ N";}?> 

EchoJSON PHP

MainActivity.java Java

 package com.example.xxx.xxx; // alterar 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; classe pública MainActivity estende AppCompatActivity {// Mostra os dados da string " "que contém os resultados TextView results; // O textview que mantém a velocidade recomendada TextView recSpeed; // URL do objeto a ser analisado String JsonURL ="YourURLhere"; // Esta string conterá os resultados String data =""; // Definindo a fila de solicitações do Volley que lida com a solicitação de URL simultaneamente RequestQueue requestQueue; // objeto timer para atualizar os dados a cada segundo // Timer timer; // O speedLimit (cm / s) private final static double maxSpeed ​​=18; // A velocidade recomendada private double speed; // número de vezes na tabela public final static int NUMBER_OF_ENTRIES =2; // array com os tempos em que é verde long [] unixTimesGreen =new long [NUMBER_OF_ENTRIES]; // array com os tempos em que é vermelho long [] unixTimesRed =new long [NUMBER_OF_ENTRIES]; // variável que mantém a distância private double distance; // variáveis ​​para repetir updateTable private final ScheduledExecutorService scheduler =Executors.newSingleThreadScheduledExecutor (); // para teste:private Future  timingTask; public void tick (long milissegundos) {timingTask =scheduler.scheduleAtFixedRate (new Runnable () {public void run () {updateTable ();}}, 0, milissegundos, TimeUnit.MILLISECONDS); } @Override protected void onCreate (Bundle savedInstanceState) {super.onCreate (savedInstanceState); setContentView (R.layout.activity_main); // textViews para converter resultados em resultados =(TextView) findViewById (R.id.jsonData); recSpeed ​​=(TextView) findViewById (R.id.recommendedSpeed); // inicializa a tabela updateTable (); // atualiza o aplicativo a cada 100 milissegundos tick (500); // para trabalhar com um objeto timer para atualizar repetidamente / ** timer =new Timer ("Timer"); timer.schedule (novo UpdateTable (), (longo) 100, (longo) 100); * /} // para trabalhar com o objeto timer para atualizar repetidamente / ** classe privada UpdateTable estende TimerTask {public void run () {updateTable (); }} * / private void updateTable () {// reset String data =""; // Cria a fila de solicitação do Volley requestQueue =Volley.newRequestQueue (this); // para teste / ** // Converte os resultados no TextView encontrado no XML do layout principal com id jsonData results =(TextView) findViewById (R.id.jsonData); * / // Criando a classe JsonArrayRequest chamada arrayreq, passando os parâmetros necessários // JsonURL é a URL a ser buscada em JsonArrayRequest arrayreq =new JsonArrayRequest (JsonURL, // O segundo parâmetro Listener substitui o método onResponse () e passa // JSONArray como um parâmetro new Response.Listener  () {// Obtém a resposta da solicitação JSON @Override public void onResponse (resposta JSONArray) {try {// Recupera o primeiro objeto JSON na matriz externa JSONObject TrafficLObj =response.getJSONObject ( 0); // Recupera "trafficArry" do objeto JSON JSONArray trafficArry =TrafficLObj.getJSONArray ("TrafficLArray"); // Itera por meio do array JSON obtendo objetos e adicionando-os // à visualização de lista até que não haja mais objetos em trafficArry for (int i =0; i  maxSpeed) speed =maxSpeed; senão velocidade =distância / ((unixTimesGreen [intervalo] -tempo)); velocidade =velocidade * 5; }} 

AndroidManifest.xml XML

   // alterar xxx xxx           

strings.xml XML

   NooitRood   

activity_main.xml XML

Esquemas