Published October 7, 2016 © GPL3+

Vehicle Violation Detector

Automatically detects the vehicles crossing the stop line during red signal and generates penalty - cloud based on no. of records.

AdvancedShowcase (no instructions)4,491

Things used in this project

Hardware components

Arduino UNO

Software apps and online services

Microsoft Windows 10 IoT Core

Microsoft Visual Studio 2015

Story

Generally, many don’t follow the rules in a traffic light intersection and that is a major conflict of accidents. Many of us won’t stop the vehicle before the stop line during the red signal and we will stop the vehicle after the pedestrian which lies after stop line. That causes the pedestrians to cross the roads in mid of the lane and that’s a big conflict for accidents.

So I thought of establishing an invisible ultra sound screen at the stop line post. The CCTV cameras exist on every signal zones and i'm making use of it.

At the time of red signal, if any vehicle crosses the ultra sound screen, automatically the CCTV will focus the number plate of the vehicle and captures the number and processes the image via arduino and sends the number to the cloud. The cloud is like a reference index, where it searches the vehicle registrar index for the details of the vehicle owner. Once it fetches the details, it immediately add a violation record on that vehicle owner's profile and a sms will be sent to vehicle owner regarding penalty as initial enforcement.

If the same vehicle kept on violating, the number of records will be increased and the cloud will analyse these records and shows to the dashboard as priority which will be monitoring by Traffic police authorities of the city and rest enforcement they take care.

Code

#include <NewPing.h>
#define  c     3830    // 261 Hz 
#define  d     3400    // 294 Hz 
#define  e     3038    // 329 Hz 
#define  f     2864    // 349 Hz 
#define  g     2550    // 392 Hz 
#define  a     2272    // 440 Hz 
#define  b     2028    // 493 Hz 
#define  C     1912    // 523 Hz 
#define  R     0
int speakerOut = 9;
int DEBUG = 1;
#define TRIGGER_PIN 12
#define ECHO_PIN 11
#define MAX_DISTANCE 400 
int output;
NewPing sonar(TRIGGER_PIN, ECHO_PIN, MAX_DISTANCE); 
int melody[] = {  C,  b,  g,  C,  b,   e,  R,  C,  c,  g, a, C };
int beats[]  = { 16, 16, 16,  8,  8,  16, 32, 16, 16, 16, 8, 8 }; 
int MAX_COUNT = sizeof(melody) / 2; // Melody length, for looping.

// Set overall tempo
long tempo = 10000;
// Set length of pause between notes
int pause = 1000;
// Loop variable to increase Rest length
int rest_count = 100; //<-BLETCHEROUS HACK; See NOTES

// Initialize core variables
int tone_ = 0;
int beat = 0;
long duration  = 0;

////////////////////////////////////////////////////////////////////////////////////////////////////////////
class Output
{
  
  long OnTime;     // milliseconds of on-time

  unsigned long previousMillis;   // will store last time LED was updated

  public:
  Output(long on)
  {
    
  OnTime = on;
  
  previousMillis = 0;
  }

  void Update()
  {
   unsigned long currentMillis = millis();
     
    if((currentMillis - previousMillis >= OnTime))
    {
      previousMillis = currentMillis;  // Remember the time

Serial.print("Ping: ");
unsigned int uS = sonar.ping();
output = uS / US_ROUNDTRIP_CM;
Serial.print(output);
Serial.println("cm");

    }   
  }
};
////////////////////////////////////////////////////////////////////////////////////////////////////////
void playTone() {
  long elapsed_time = 0;
  if (tone_ > 0) { // if this isn't a Rest beat, while the tone has 
    //  played less long than 'duration', pulse speaker HIGH and LOW
    while (elapsed_time < duration) {

      digitalWrite(speakerOut,HIGH);
      delayMicroseconds(tone_ / 2);

      // DOWN
      digitalWrite(speakerOut, LOW);
      delayMicroseconds(tone_ / 2);

      // Keep track of how long we pulsed
      elapsed_time += (tone_);
    } 
  }
  else { // Rest beat; loop times delay
    for (int j = 0; j < rest_count; j++) { // See NOTE on rest_count
      delayMicroseconds(duration);  
    }                                
  }                                 
}
  ///////////////////////////////////////////////////////////////////////////////////////////////////////


class Buzzer
{
 
  long OnTime1;     // milliseconds of on-time

  unsigned long previousMillis1;   // will store last time LED was updated

public: 
  Buzzer(long off)
  {
    
  OnTime1 = off;
  previousMillis1 = 0;
  } 
  void Update()
  {
    unsigned long currentMillis1 = millis();
     
    if((currentMillis1 - previousMillis1 >= OnTime1))
    {
      previousMillis1 = currentMillis1;  // Remember the time

      if(output > 0)
{
  Serial.println("im done");

   for (int i=0; i<MAX_COUNT; i++) {
    tone_ = melody[i];
    beat = beats[i];

    duration = beat * tempo; // Set up timing

    playTone(); 
    // A pause between notes...
    delayMicroseconds(pause);
}
}
}
}
};

Output out(100);
Buzzer buzzer(101);

///////////////////////////////////////////////////////////////////////////////////////////////////////////
void setup() {
   pinMode(speakerOut, OUTPUT);
Serial.begin(9600); 
}
/////////////////////////////////////////////////////////////////////////////////////////////////////
void loop() {
delay(50); 
out.Update();
buzzer.Update();
}

#include <SoftwareSerial.h>
#include <stdlib.h>



// replace with your channel's thingspeak API key
String apiKey = "ZP1PZO62773HXWVU";

// connect 10 to TX of Serial USB
// connect 11 to RX of serial USB
SoftwareSerial ser(10, 11); // RX, TX

// this runs once
void setup() {
// initialize the digital pin as an output.
Serial.begin(9600);
// enable software serial
ser.begin(9600);

// reset ESP8266
ser.println("AT+RST");
connectWiFi;
}
// the loop
void loop() {

Serial.println(output);

// TCP connection
String cmd = "AT+CIPSTART=\"TCP\",\"";
cmd += "184.106.153.149"; // api.thingspeak.com
cmd += "\",80";
ser.println(cmd);

if(ser.find("Error")){
Serial.println("AT+CIPSTART error");
return;
}

// prepare GET string
String getStr = "GET /update?api_key=";
getStr += apiKey;
getStr +="&field1=";
getStr += String(output);
getStr += "\r\n\r\n";

// send data length
cmd = "AT+CIPSEND=";
cmd += String(getStr.length());
ser.println(cmd);

if(ser.find(">")){
ser.print(getStr);
}
else{
ser.println("AT+CIPCLOSE");
// alert user
Serial.println("AT+CIPCLOSE");
}

// thingspeak needs 15 sec delay between updates
delay(16000);
}
boolean connectWiFi(){
  Serial.println("AT+CWMODE=1");
  delay(2000);
  String cmd="AT+CWJAP=\"";
  cmd+=SSID;
  cmd+="\",\"";
  cmd+=PASS;
  cmd+="\"";
  Serial.println(cmd);
  delay(5000);
  if(Serial.find("OK")){
    ser.println("OK");
    return true;
  }else{
    return false;
  }
}