신호등 정보 시스템

데이터베이스 업데이트에 성공했다면 'Arduino Receiver &MySQLdb'의 arduino 코드에서 다음 절차를 수정할 수 있습니다.

프로젝트를 복제하려는 경우 모든 것을 한 번에 구현하는 것은 좋지 않습니다. 먼저 각 구성 요소를 개별적으로 테스트해 보십시오. 모두 잘 작동하면 다른 구성 요소를 결합하여 시작할 수 있습니다. 댓글 섹션에서 자유롭게 도움을 요청하고 문제를 최대한 자세히 설명하세요.

코드

Arduino 송신기 코드Arduino

/* IOTOPIA - 2016-2017 - 신호등 정보 시스템(송신기) * by Pieter Luyten &Joppe Smeets * * RF 433MHz 모듈을 통해 다른 arduino까지 거리 보내기 * * RF 433MHz 모듈:* tx_pin --> 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용 라이브러리 moduleHCSR04 초음파(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() { distance =초음파.Ranging(CM); // cm 단위로 거리를 측정합니다. while(distance <0){ // 잘못된 판독을 방지하고 거리를 다시 측정합니다. distance =초음파.Ranging(CM); } sprintf(CharMsg, "%d,", 거리); vw_send((uint8_t *)CharMsg, strlen(CharMsg)); // 거리 전송 vw_wait_tx(); // 전체 메시지가 사라질 때까지 기다립니다. Serial.print("Distance (cm):"); Serial.println(거리); 지연(250);}

Arduino 수신기 및 MySQLdbArduino

/* IOTOPIA - 2016-2017 - 신호등 정보 시스템(수신기 + MySQLdb에 업로드) * 작성자 Pieter Luyten &Joppe Smeets * * RF를 통해 다른 arduino에서 거리 수신 * MySQL 데이터베이스에 신호등 데이터 및 거리 업로드 * * RF 433MHz 모듈:* rx_pin --> 핀 3 * * 신호등(LED 3개):* RedLED --> 핀 5 * OrangeLED --> 핀 6 * GreenLED --> 핀 7 * * DS3231(실시간 클록) :* SCL --> SCL(Arduino Yun의 핀 3) * SDA --> SDA(Arduino Yun의 핀 2) * * SD 카드 - Arduino Yun * SD 카드(PHP 파일 포함)--> 통합 SD 슬롯* /#define RedLED 5#define OrangeLED 6#define GreenLED 7#define rx_pin 9#include  // RF 433MHz 모듈#include  // 알람#include  // I2C communication#include "RTClib.h" // Real Time Clock#include  // Linux 프로세스를 AR9331에서 실행 // UnixTime:1970년 1월 1일 이후 경과된 시간(초)으로 정의된 시간long UnixTime_green_1; // 다음 녹색 표시등(UnixTime에서)long UnixTime_red_1; // 다음 빨간불(UnixTime에서)long UnixTime_green_2; // 다음 단 하나의 녹색 표시등(UnixTime에서)long UnixTime_red_2; // 다음 단 하나의 빨간불(UnixTime에서)long s_till_orange; // OrangeRTC_DS3231까지의 시간(초) rtc;char StringReceived[22];boolean i;int interval =5; // 초 단위 int 거리; // 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); 핀모드(주황색 LED, 출력); 핀모드(빨간색 LED, 출력); 디지털 쓰기(녹색 LED, 낮음); digitalWrite(주황색 LED, 낮음); 디지털 쓰기(빨간색 LED, 낮음); Serial.println("설정 완료");}void 루프() { Alarm.delay(0); // 이 지연은 알람과 타이머를 적시에 처리하기 위해 // 일반적인 Arduino delay() 대신 사용해야 합니다. 최소 지연을 위해 0을 전달할 수 있습니다. RF_듣기(); }무효 RF_Listen(){ uint8_t buf[VW_MAX_MESSAGE_LEN]; uint8_t 버퍼 =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();} 무효 MySQL_UpdateDistance(){ 프로세스 p; p.begin("/mnt/sda1/MySQL_UpdateDistance.php"); p.addParameter(문자열(거리)); p.run(); // 피드백 읽기(디버깅용) while (p.available()> 0) { char c =p.read(); Serial.print(c); } // 데이터의 마지막 비트가 전송되었는지 확인합니다. Serial.flush();} 무효 PrintCurrentTime() { 현재 날짜 시간 =rtc.now(); SetLEDsTrafficL(); Serial.print(now.hour(), DEC); Serial.print(':'); Serial.print(지금.분(), DEC); Serial.print(':'); Serial.print(now.second(), DEC); Serial.print(" "); Serial.println(now.unixtime());} 무효 SetLEDsTrafficL() { 현재 날짜 시간 =rtc.now(); s_till_orange =UnixTime_red_1 - now.unixtime(); if (i ==0) { digitalWrite(GreenLED, LOW); digitalWrite(주황색 LED, 낮음); 디지털 쓰기(빨간색 LED, 높음); } if (i ==1 &&s_till_orange <=3) { digitalWrite(GreenLED, LOW); 디지털 쓰기(주황색 LED, 높음); 디지털 쓰기(빨간색 LED, 낮음); } if (i ==1 &&s_till_orange> 3) { digitalWrite(GreenLED, HIGH); digitalWrite(주황색 LED, 낮음); 디지털 쓰기(빨간색 LED, 낮음); }}

MySQL_UpdateTrafficLData.phpPHP

#!/usr/bin/php-cliconnect_error) { trigger_error('데이터베이스 연결 실패:' . $conn->connect_error, E_USER_ERROR);} $sql="업데이트 트래픽L_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($con ) ===false) { trigger_error('잘못된 SQL:' . $sql . ' 오류:' . $conn->error, E_USER_ERROR);}else{echo "데이터가 삽입되었습니다!\n";} ?>

MySQL_UpdateDistance.phpPHP

#!/usr/bin/php-cliconnect_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('잘못된 SQL:' . $sql . ' 오류:' . $conn->error, E_USER_ERROR);}else{echo "거리 삽입!\n";}?>

EchoJSONPHP

MainActivity.java자바

패키지 com.example.xxx.xxx;// xxx xxximport android.support.v7.app.AppCompatActivity 가져오기 가져오기 android.os.Bundle 가져오기; android.util.Log 가져오기; android.widget.TextView 가져오기;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 extends AppCompatActivity { // 문자열 "data "는 결과 TextView 결과를 보유합니다. //권장 속도를 유지하는 텍스트 뷰 TextView recSpeed; // 파싱할 객체의 URL String JsonURL ="YourURLhere"; // 이 문자열은 결과를 보유할 것입니다. String data =""; // URL 요청을 동시에 처리하는 Volley 요청 큐 정의 RequestQueue requestQueue; //매초 데이터를 업데이트하는 타이머 객체 //타이머 타이머; //speedLimit(cm/s) private final static double maxSpeed ​​=18; //권장 속도 전용 2배속; // 테이블의 횟수 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; 공개 무효 틱(긴 밀리초) { timingTask =scheduler.scheduleAtFixedRate(new Runnable() { 공개 무효 실행() { updateTable(); } }, 0, 밀리초, TimeUnit.MILLISECONDS); } @Override protected void onCreate(Bundle storedInstanceState) { 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); */ } // 반복적으로 업데이트하기 위해 타이머 객체를 사용하기 위해 /** private class UpdateTable extends TimerTask{ public void run(){ updateTable(); } } */ private void updateTable(){ //문자열 데이터 재설정 =""; // Volley 요청 큐를 생성합니다. requestQueue =Volley.newRequestQueue(this); // 테스트용 /** // id가 jsonData인 기본 레이아웃 XML에서 찾은 TextView로 결과를 캐스트합니다. results =(TextView) findViewById(R.id.jsonData); */ // arrayreq라는 JsonArrayRequest 클래스 생성, 필수 매개변수 전달 //JsonURL은 JsonArrayRequest에서 가져올 URL입니다. arrayreq =new JsonArrayRequest(JsonURL, // 두 번째 매개변수 Listener는 onResponse() 메서드를 재정의하고 //JSONArray를 전달합니다. 매개변수로 new Response.Listener() { // JSON 요청에서 응답을 받습니다. @Override public void onResponse(JSONArray response) { try { // 외부 배열에서 첫 번째 JSON 객체를 검색합니다. JSONObject TrafficLObj =response.getJSONObject( 0); // JSON 개체에서 "trafficArry"를 검색합니다. JSONArray trafficArry =TrafficLObj.getJSONArray("TrafficLArray"); // 개체를 가져와 더 이상 개체가 없을 때까지 목록 보기에 추가하는 JSON 배열을 반복합니다. trafficArry for (int i =0; i  maxSpeed) 속도 =maxSpeed; 그렇지 않으면 속도 =거리/((unixTimesGreen[간격]-시간)); 속도 =속도*5; }}

AndroidManifest.xmlXML

// xxx xxx 변경         

strings.xmlXML

 NooitRood

activity_main.xmlXML