信号機情報システム

コード

• Arduino送信機コード
• ArduinoレシーバーとMySQLdb
• MySQL_UpdateTrafficLData.php
• MySQL_UpdateDistance.php
• EchoJSON
• MainActivity.java
• AndroidManifest.xml
• strings.xml
• activity_main.xml

Arduino送信機コード Arduino

 / * IOTOPIA-2016-2017-Traffic Light Information System（Transmitter）* by Pieter Luyten＆Joppe Smeets * * RF433MHzモジュールを介して別のarduinoに距離を送信** RF 433MHzモジュール：* tx_pin->ピン3 * * HC-SR04モジュール：* trig_pin->ピン5 * echo_pin->ピン6 * * /＃define tx_pin 3＃define trig_pin 5＃define echo_pin 6＃include  // RF 433MHzモジュールのライブラリ#include "HCSR04.h" // HC-SR04モジュールのライブラリHCSR04超音波（trig_pin、echo_pin）; int distance; char CharMsg [21]; void setup（）{Serial.begin（9600）; vw_setup（2000）; //ビット/秒vw_set_tx_pin（tx_pin）;} void loop（）{距離=超音波.Ranging（CM）; //距離をcm単位で測定しますwhile（distance <0）{//誤った読み取りを避け、距離を再度測定しますdistance =超音波.Ranging（CM）; } sprintf（CharMsg、 "％d、"、distance）; vw_send（（uint8_t *）CharMsg、strlen（CharMsg））; //距離を送信しますvw_wait_tx（）; //メッセージ全体が消えるまで待ちますSerial.print（ "Distance（cm）："）; Serial.println（距離）; delay（250）;} 

ArduinoレシーバーとMySQLdb Arduino

 / * IOTOPIA-2016-2017-Traffic Light Information System（Receiver + Upload to MySQLdb）* by Pieter Luyten＆Joppe Smeets * * RF経由で別のarduinoからの距離を受信*トラフィックライトデータとMySQLデータベースへの距離をアップロード** RF 433MHzモジュール：* rx_pin->ピン3 * * TrafficLight（3 LED）：* RedLED->ピン5 * OrangeLED->ピン6 * GreenLED->ピン7 * * DS3231（リアルタイムクロック） ：* SCL-> SCL（Arduino Yunのピン3）* SDA-> SDA（Arduino Yunのピン2）* * SDカード-ArduinoYun * SDカード（PHPファイル付き）->統合SDスロット* /＃define RedLED 5＃define OrangeLED 6＃define GreenLED 7＃define rx_pin 9＃include  // RF 433 MHzモジュール#include  //アラーム#include  // I2C communication＃include "RTClib.h" //リアルタイムクロック#include  // AR9331 //でLinuxプロセスを実行UnixTime：1970年1月1日から経過した秒数として定義される時間UnixTime_green_1; //次の青信号（UnixTime内）long UnixTime_red_1; //次の赤信号（UnixTime内）long UnixTime_green_2; //次に、1つの緑色のライト（UnixTime内）long UnixTime_red_2; //次に、1つの赤信号（UnixTimeの場合）long s_till_orange; // orangeRTC_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（interval、UpdateTrafficLData）; //信号機のデータを更新します（次の緑/赤信号...）Alarm.timerRepeat（1、PrintCurrentTime）; //現在の時刻をx秒ごとに出力しますpinMode（GreenLED、OUTPUT）; pinMode（OrangeLED、OUTPUT）; pinMode（RedLED、OUTPUT）; digitalWrite（GreenLED、LOW）; digitalWrite（OrangeLED、LOW）; digitalWrite（RedLED、LOW）; Serial.println（ "セットアップが終了しました"）;} void loop（）{Alarm.delay（0）; //この遅延は、通常のArduino delay（）の代わりに//アラームとタイマーをタイムリーに処理するために使用する必要があります。最小の遅延のために0を渡すことができます。 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）; } //データの最後のビットが送信されていることを確認します。 Serial.flush（）;} void MySQL_UpdateDistance（）{プロセスp; p.begin（ "/ mnt / sda1 / MySQL_UpdateDistance.php"）; p.addParameter（String（distance））; p.run（）; //フィードバックを（デバッグ用に）読み取りますwhile（p.available（）> 0）{char c =p.read（）; Serial.print（c）; } //データの最後のビットが送信されていることを確認します。 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 <？php $ UnixTime_green_1 =$ argv [1]; $ UnixTime_red_1 =$ argv [2]; $ UnixTime_green_2 =$ argv [3]; $ UnixTime_red_2 =$ argv [4]; $ DBServer ='yourServerName'; $ DBUser ='yourUserName'; $ DBPass ='yourPassword'; $ DBName ='yourDBName'; $ conn =new mysqli（$ DBServer、$ DBUser、$ DBPass、$ DBName）; // connectionif（$ conn-> connect_error）{trigger_error（ 'データベース接続に失敗しました：'。$ 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"; if（$ conn-> query（$ sql ）===false）{trigger_error（ '間違ったSQL：'。$ sql。 'エラー：'。$ conn-> error、E_USER_ERROR）;} else {echo "データが挿入されました！\ n";}？> 

MySQL_UpdateDistance.php PHP

＃！/ usr / bin / php-cli <？php $ Distance =$ argv [1]; $ DBServer ='yourServerName'; $ DBUser ='yourUserName'; $ DBPass ='yourPassword'; $ DBName =' yourDBName '; $ conn =new mysqli（$ DBServer、$ DBUser、$ DBPass、$ DBName）; // connectionif（$ conn-> connect_error）{trigger_error（'データベース接続に失敗しました： '。$ 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。 'エラー：'。$ conn-> error、E_USER_ERROR）;} else {echo "Distance Inserted！\ n";}？> 

EchoJSON PHP

 <？phpdefine（ 'HOST'、 'yourServerName'）; define（ 'USER'、 'yourUserName'）; define（ 'PASS'、 'yourPassword'）; define（ 'DB'、 'yourDBName'）; $ con =mysqli_connect（HOST、USER、PASS、DB）; $ sql ="select * fromTrafficL_data"; $ res =mysqli_query（$ con、$ sql）; while（$ row =mysqli_fetch_array（$ res、MYSQLI_BOTH））{printf（ '[{"TrafficLArray"：[{"UnixTime_green_1"： "％s"、 "UnixTime_red_1"： "％s"、 "UnixTime_green_2"： "％s "、" UnixTime_red_2 "："％s "、" Distance "："％s "}]}] '、$ row [' UnixTime_green_1 ']、$ row [' UnixTime_red_1 ']、$ row [' UnixTime_green_2 ']、$ row ['UnixTime_red_2']、$ row ['Distance']）;} mysqli_close（$ con）; ？> 

MainActivity.java Java

 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; importorg。 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 extends AppCompatActivity {//文字列 "dataを表示します"結果TextViewの結果を保持します。 //推奨速度を保持するtextviewTextView recSpeed; //解析されるオブジェクトのURLString JsonURL ="YourURLhere"; //この文字列は結果を保持しますStringdata =""; // URLリクエストを同時に処理するVolleyリクエストキューを定義しますRequestQueuerequestQueue; //データを毎秒更新するタイマーオブジェクト//タイマータイマー; // speedLimit（cm / s）private final static double maxSpeed =18; //推奨速度プライベート倍速; //テーブル内の回数publicfinal static int NUMBER_OF_ENTRIES =2; //緑色の時刻の配列long [] unixTimesGreen =new long [NUMBER_OF_ENTRIES]; //赤の時間の配列long [] unixTimesRed =new long [NUMBER_OF_ENTRIES]; //距離を保持する変数privatedouble distance; // updateTableを繰り返すための変数privatefinal ScheduledExecutorService Scheduler =Executors.newSingleThreadScheduledExecutor（）; //テスト用：private Future <？> TimingTask; public void tick（longミリ秒）{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）; * /} //タイマーオブジェクトを操作して繰り返し更新する場合/ **プライベートクラスUpdateTableextends TimerTask {public void run（）{updateTable（）; }} * / private void updateTable（）{//文字列データをリセット=""; //ボレーリクエストキューを作成しますrequestQueue =Volley.newRequestQueue（this）; //テスト用/ ** //結果をメインレイアウトXML内で見つかったTextViewにキャストします。idjsonDataresults=（TextView）findViewById（R.id.jsonData）; * / // arrayreqというJsonArrayRequestクラスを作成し、必要なパラメーターを渡します// JsonURLはJsonArrayRequestからフェッチされるURLですarrayreq =new JsonArrayRequest（JsonURL、// 2番目のパラメーターListenerはメソッドonResponse（）をオーバーライドし、// JSONArrayを渡しますパラメータとしてnewResponse.Listener （）{// JSONリクエストから応答を取得します@Overridepublic void onResponse（JSONArray response）{try {//外部配列の最初のJSONオブジェクトを取得しますJSONObjectTrafficLObj =response.getJSONObject（ 0）; // JSONオブジェクトから "trafficArry"を取得しますJSONArraytrafficArry =TrafficLObj.getJSONArray（ "TrafficLArray"）; // JSON配列を反復処理して、オブジェクトを取得して追加します// trafficArryにオブジェクトがなくなるまでリストビューに移動しますfor（int i =0; i  maxSpeed）speed =maxSpeed;それ以外の場合、速度=距離/（（unixTimesGreen [間隔]-時間））;速度=速度* 5; }} 

AndroidManifest.xml XML

 <？xml version ="1.0" encoding ="utf-8"？>  //変更xxxxxx           

strings.xml XML

   NooitRood   

activity_main.xml XML

 <？xml version ="1.0" encoding ="utf-8"？>     

回路図