Информационная система светофора

Код

• Код передатчика Arduino
• Приемник Arduino и MySQLdb
• MySQL_UpdateTrafficLData.php
• MySQL_UpdateDistance.php
• EchoJSON
• MainActivity.java
• AndroidManifest.xml
• strings.xml
• activity_main.xml

Код передатчика Arduino Arduino

 / * IOTOPIA - 2016-2017 - Информационная система светофора (передатчик) * от Питера Люйтена и Йоппе Смитса * * Передача расстояния до другого Arduino через модули RF 433 МГц * * Модуль RF 433 МГц:* tx_pin -> контакт 3 * * Модуль HC-SR04:* trig_pin -> pin 5 * echo_pin -> pin 6 * * / # define tx_pin 3 # define trig_pin 5 # define echo_pin 6 # include  // Библиотека для модулей RF 433 МГц #include "HCSR04.h" // Библиотека для модуля HC-SR04HCSR04 ultrasonic (trig_pin, echo_pin); int расстояние; char CharMsg [21]; void setup () {Serial.begin (9600); vw_setup (2000); // Бит в секунду vw_set_tx_pin (tx_pin);} void loop () {distance =ultrasonic.Ranging (CM); // Измерьте расстояние в см while (distance <0) {// Избегайте ложных показаний, снова измерьте расстояние distance =ultrasonic.Ranging (CM); } sprintf (CharMsg, "% d,", расстояние); vw_send ((uint8_t *) CharMsg, strlen (CharMsg)); // Отправляем расстояние vw_wait_tx (); // Ждем, пока не исчезнет все сообщение Serial.print ("Distance (cm):"); Serial.println (расстояние); задержка (250);} 

Приемник Arduino и MySQLdb Arduino

 / * IOTOPIA - 2016-2017 - Информационная система светофора (приемник + загрузка в MySQLdb) * от Pieter Luyten &Joppe Smeets * * Получение расстояния от другого Arduino через RF * Загрузка данных светофора и расстояния в базу данных MySQL * * Модуль RF 433MHz:* rx_pin -> контакт 3 * * TrafficLight (3 светодиода):* RedLED -> контакт 5 * OrangeLED -> контакт 6 * GreenLED -> контакт 7 * * DS3231 (часы реального времени) :* SCL -> SCL (вывод 3 на Arduino Yun) * SDA -> SDA (вывод 2 на Arduino Yun) * * SD-карта - Arduino Yun * SD-карта (с файлом PHP) -> встроенный слот для SD * / # определить RedLED 5 # определить OrangeLED 6 # определить GreenLED 7 # определить rx_pin 9 # включить  // модули RF 433 МГц # include  // Аварийные сигналы # include  // I2C общение # include "RTClib.h" // Часы реального времени # include  // Запуск процессов Linux на AR9331 // UnixTime:время, определяемое как количество секунд, прошедших с 1 января 1970 г. long UnixTime_green_1; // Следующий зеленый свет (в UnixTime) long UnixTime_red_1; // Следующий красный свет (в UnixTime) long UnixTime_green_2; // Дальше один зеленый свет (в UnixTime) long UnixTime_red_2; // Дальше один красный свет (в UnixTime) long s_till_orange; // Секунды до оранжевого RTC_DS3231 rtc; char StringReceived [22]; boolean i; int interval =5; // расстояние в секундах; // в cmvoid setup () {rtc.begin (); //rtc.adjust(DateTime(F(__DATE__), F (__ TIME__))); Serial.begin (9600); Bridge.begin (); // Инициализируем мост vw_setup (2000); // Бит в секунду vw_set_rx_pin (rx_pin); vw_rx_start (); Alarm.timerRepeat (интервал, UpdateTrafficLData); // Обновление данных светофора (следующий зеленый / красный свет ...) Alarm.timerRepeat (1, PrintCurrentTime); // Выводить текущее время каждые x секунд pinMode (GreenLED, OUTPUT); pinMode (OrangeLED, ВЫХОД); pinMode (RedLED, ВЫХОД); digitalWrite (GreenLED, LOW); digitalWrite (OrangeLED, LOW); digitalWrite (RedLED, LOW); Serial.println ("Настройка завершена");} void loop () {Alarm.delay (0); // Эту задержку следует использовать вместо обычной задержки Arduino (), // для своевременной обработки сигналов тревоги и таймеров. Вы можете передать 0 для минимальной задержки. RF_Listen (); } void RF_Listen () {uint8_t buf [VW_MAX_MESSAGE_LEN]; uint8_t buflen =VW_MAX_MESSAGE_LEN; если (vw_get_message (buf, &buflen)) {int a; for (a =0; a  0) {char c =p.read (); Serial.print (c); } // Убедитесь, что последний бит данных отправлен. Serial.flush ();} void MySQL_UpdateDistance () {Процесс p; p.begin ("/ mnt / sda1 / MySQL_UpdateDistance.php"); p.addParameter (String (расстояние)); p.run (); // Считываем отзыв (для отладки) while (p.available ()> 0) {char c =p.read (); Serial.print (c); } // Убедитесь, что последний бит данных отправлен. Serial.flush ();} недействительным PrintCurrentTime () {DateTime now =rtc.now (); SetLEDsTrafficL (); Serial.print (now.hour (), DEC); Серийный принт (':'); Serial.print (now.minute (), DEC); Серийный принт (':'); 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 (); если (я ==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); } если (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 ('Ошибка подключения к базе данных:'. $ conn-> connect_error, E_USER_ERROR);} $ sql ="ОБНОВЛЕНИЕ 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' $ if ) ===false) {trigger_error ('Неверный SQL:'. $ sql. 'Error:'. $ conn-> error, E_USER_ERROR);} else {echo "Данные вставлены! \ n";}?> 

MySQL_UpdateDistance.php PHP

 #! / usr / bin / php-cli  connect_error) {trigger_error (' Ошибка подключения к базе данных:'. $ conn-> connect_error, E_USER_ERROR );} $ sql ="ОБНОВИТЬ TrafficL_data SET Distance ='$ Distance'WHERE id =1"; if ($ conn-> query ($ sql) ===false) {trigger_error (' Неверный SQL:'. $ sql. 'Ошибка:'. $ Conn-> error, E_USER_ERROR);} else {echo "Расстояние вставлено! \ N";}?> 

EchoJSON PHP

MainActivity.java Java

 package com.example.xxx.xxx; // изменить 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; открытый класс MainActivity расширяет AppCompatActivity {// Будет отображать строковые данные "который содержит результаты TextView results; // Текстовое представление с рекомендованной скоростью TextView recSpeed; // URL анализируемого объекта String JsonURL ="YourURLhere"; // Эта строка будет содержать результаты String data =""; // Определение очереди запросов Volley, которая одновременно обрабатывает URL-запрос RequestQueue requestQueue; // объект таймера для обновления данных каждую секунду // Timer timer; // Ограничение скорости (см / с) private final static double maxSpeed ​​=18; // Рекомендуемая скорость private double speed; // количество раз в таблице public final static int NUMBER_OF_ENTRIES =2; // массив с временами, когда он зеленый long [] unixTimesGreen =new long [NUMBER_OF_ENTRIES]; // массив с временами, когда он красный long [] unixTimesRed =new long [NUMBER_OF_ENTRIES]; // переменная, содержащая расстояние private double distance; // переменные для повторения updateTable private final ScheduledExecutorService scheduler =Executors.newSingleThreadScheduledExecutor (); // для тестирования:private Future  TimingTask; public void tick (длинные миллисекунды) {TimingTask =scheduler.scheduleAtFixedRate (new Runnable () {public void run () {updateTable ();}}, 0, миллисекунды, TimeUnit.MILLISECONDS); } @Override protected void onCreate (Bundle savedInstanceState) {super.onCreate (savedInstanceState); setContentView (R.layout.activity_main); // textViews для преобразования результатов в результаты =(TextView) findViewById (R.id.jsonData); recSpeed ​​=(TextView) findViewById (R.id.recommendedSpeed); // инициализируем таблицу updateTable (); // обновляем приложение каждые 100 миллисекунд Tick (500); // для работы с объектом таймера многократно обновлять / ** timer =new Timer ("Timer"); timer.schedule (new UpdateTable (), (long) 100, (long) 100); * /} // для работы с объектом таймера для многократного обновления / ** частный класс UpdateTable extends TimerTask {public void run () {updateTable (); }} * / private void updateTable () {// сбросить String data =""; // Создает очередь запросов Volley requestQueue =Volley.newRequestQueue (this); // для тестирования / ** // Преобразует результаты в TextView, найденные в основном XML макета с идентификатором jsonData results =(TextView) findViewById (R.id.jsonData); * / // Создание класса JsonArrayRequest с именем arrayreq с передачей необходимых параметров // JsonURL - это URL-адрес, который нужно получить из JsonArrayRequest arrayreq =new JsonArrayRequest (JsonURL, // Второй параметр Listener переопределяет метод onResponse () и передает // JSONArray в качестве параметра new Response.Listener  () {// Принимает ответ от запроса JSON @Override public void onResponse (JSONArray response) {try {// Извлекает первый объект JSON во внешнем массиве JSONObject TrafficLObj =response.getJSONObject ( 0); // Извлекает "trafficArry" из объекта JSON JSONArray trafficArry =TrafficLObj.getJSONArray ("TrafficLArray"); // Итерирует по массиву JSON, получая объекты и добавляя их // в представление списка, пока в нем больше не останется объектов. trafficArry for (int i =0; i  maxSpeed) speed =maxSpeed; иначе скорость =расстояние / ((unixTimesGreen [интервал] -время)); скорость =скорость * 5; }} 

AndroidManifest.xml XML

   // изменить xxx xxx         

strings.xmlXML

 NooitRood

activity_main.xmlXML

Схема