空間活動偵測 -1 arduino

-
我想做一個能夠及時通知家中發生異狀的系統

研究結果

用Arduino接收感測器資料，定時傳送資料人體紅外線資料，及即時傳送開關門資料，再用google apps script 做資料交換與分析，將arduino傳送過來的資料存入google試算表，由試算表做圖表繪製，再由apps script 定時推播圖表訊息，以及分析內容推播異常或警告訊息。

研究過程

一開始想用自己架設的伺服器存資料，用raspberry pi安裝apache + mysql + phpMyAdmin，但因為網路IP位置是浮動的關係，資料無法從外部傳回進伺服器，只能做本地端的資料傳輸，如果單使用arduino上傳資料到google試算表，又因為arduino uno3無網路連線加密的問題無法傳輸資料。
之後找到國外的伺服器能做資料交換，加上用google的試算表做簡單的資料庫儲存，所以最後是用arduino接收感測器資訊，傳輸到資料交換伺服器再到google，由apps script 接收資料及填入試算表，完成了資料接收的問題。



硬體：使用arduino uno3 + 乙太網路擴充板 + 自己做的電路板
連接的感測器：
  • 人體紅外線感測器
  • 門窗的磁簧開關



#include <Dhcp.h>
#include <Dns.h>
#include <Ethernet.h>
#include <EthernetClient.h>
#include <EthernetServer.h>
#include <EthernetUdp.h>
//#include "net_function.cpp"
#include "set_ID.h"
#define PushingBox

unsigned char hour = 0, minute = 0;
boolean push_man_check;
String URL_data;
#define ReedS0_pin 2
#define ReedS1_pin 3
#define ReedS2_pin 4
#define ReedS3_pin 5
#define ReedS4_pin 6
#define ReedS5_pin 7
#define man0_pin 8
#define man1_pin 9
#define man2_pin A5
#define man3_pin A4
#define man4_pin A3
#define man5_pin A2
#define ReedS_number 5  //6個(0~5)
#define man_number 5    //6個(0~1)

#if defined( PushingBox )
//byte mac[] = {  0x00, 0xAB, 0xBC, 0xCD, 0xDE, 0x00 };
char server[] = "api.pushingbox.com";
String strGet = "GET /pushingbox?devid=";
String strHttp = " HTTP/1.1";
String strHost = "Host: api.pushingbox.com"; //OK
int serverPort = 80;

char ReedS[] = { 0, 0, 0, 0, 0, 0};//ReedS = Reed Switch 磁簧開關
char oReedS[] = { 0, 0, 0, 0, 0, 0};//oReedS 過去的狀態, ReedS 現在的狀態
int man[] = { 0, 0, 0, 0, 0, 0};

#endif

EthernetClient client;
boolean conn; // Connected
//DeviceAddress insideThermometer;
unsigned long startime = 0;
//------------------------------------------------------------------------------------------
//串接URL
void getdata(String *data, String ID, String kind) {
  *data = strGet;
  *data += ID;
  *data += "&board=";
  *data += board;

  if (kind == gettime_ID) {
    *data += "&information=";
    *data += "時間";

  }
  if (kind == push_RS_ID || kind == push_human_ID || kind == pushnotif_ID) {
    *data += "&time=";
    *data += (int)hour;
    *data += ':';
    if(minute<=9){
      *data += "0";
    }
    *data += (int)minute;
  }

  if (kind == push_RS_ID) {
    *data += "&RS0=";
    *data += (int)ReedS[0];
    *data += "&RS1=";
    *data += (int)ReedS[1];
    *data += "&RS2=";
    *data += (int)ReedS[2];
    *data += "&RS3=";
    *data += (int)ReedS[3];
    *data += "&RS4=";
    *data += (int)ReedS[4];
    *data += "&RS5=";
    *data += (int)ReedS[5];
  }
  if (kind == push_human_ID) {
    *data += "&man0=";
    *data += man[0];
    *data += "&man1=";
    *data += man[1];
    *data += "&man2=";
    *data += man[2];
    *data += "&man3=";
    *data += man[3];
    *data += "&man4=";
    *data += man[4];
    *data += "&man5=";
    *data += man[5];
  }
  if (kind == pushnotif_ID) {
    *data += "&title=";
    *data += "活動情況";
    *data += "&message=";
    if (ReedS[0] == 1) {
      *data += "門_開啟";
    } 
    else {
      *data += "門_關閉";
    }
  }

  *data += strHttp;
  Serial.print("URL: ");
  Serial.println(*data);
}
//push URL data to 網路
bool connect_pushdata(String *push_URL, String *host) {
  Serial.println("connect server --->");
  if (client.connect(server, serverPort)) {
    Serial.println("Make a HTTP request ... ");
    conn = true;
    client.println(*push_URL);
    client.println(*host);
    client.println( "Connection: close" );
    client.println();
    return true;
  }
  else {
    Serial.println("Can not connect server ---X---");
    return false;
  }
}


//網路回復
void netword_request() {
  int ln = 0;
  int count = 0;
  char date_str[40]=" ";
  while (conn) {
    if (client.available()) {
      char c = client.read(); // Save http header to c
      Serial.print(c); // Print http header to serial monitor
      if (c == '\n') {
        ln++;
        // Serial.print("ln count: ");
        // Serial.println(ln);
      }
      if (ln == 2) {
        date_str[count++] = c;
      }
    }
    if (!client.connected()) {
      Serial.println("disconnecting...");
      client.stop();
      URL_data = "";
      conn = false;
      ln = 0;
      count = 0;
      Serial.print("seriver date: ");
      for (char i = 1; i < 40; i++) {
        Serial.print(date_str[i]);
      }
      Serial.print("\n");
      if(((date_str[24] - '0') * 10 + (date_str[25] - '0')) >= 0 && ((date_str[24] - '0') * 10 + (date_str[25] - '0')) <= 23 &&
      ((date_str[27] - '0') * 10 + (date_str[28] - '0')) >= 0 && ((date_str[27] - '0') * 10 + (date_str[28] - '0')) <= 59)
      {
        hour = (date_str[24] - '0') * 10 + (date_str[25] - '0') + 8;
        if (hour >= 24) {
          hour -= 24;
        }
        minute = (date_str[27] - '0') * 10 + (date_str[28] - '0');
      }
      Serial.print("time ");
      Serial.print((int)hour);
      Serial.print(":");
      Serial.println((int)minute);
    }
  }
}
//網路設定
void net_init() {
  char in = "";
  byte mac[] = {  0x00, 0xAB, 0xBC, 0xCD, 0xDE, 0x00 };
  //Init Net
  Serial.print("DHCP: ");
  //Ethernet.begin(mac, ip, mydns);
  if (Ethernet.begin(mac) == 0) {
    
    Serial.println("FAIL");
    while (Ethernet.begin(mac) == 0){
      if (Serial.available() > 0) {
        in=Serial.read();
        if(in == 's'){
          Serial.println("skip DHCP");
          break;
        }
      }
    }
    Serial.print("DHCP: ");
  }
  if(in != 's'){
    Serial.println("OK");
    Serial.print("Local IP : ");
    Serial.println(Ethernet.localIP());
  }
}
void dotime() {
  //add one minute 60000=60*1000ms=1m
  if ((millis() - startime) >= (60000) || (millis() - startime) < 0) {
    startime = millis();
    minute++;
    if (minute >= 60) {
      minute -= 60;
      hour++;
      if (hour >= 24) {
        hour -= 24;
      }
    }
  }
}
//需要先跑第一次的程式
void first_run() {
  getdata(&URL_data, gettime_ID, gettime_ID);
  while(!connect_pushdata(&URL_data, &strHost));
  netword_request();//網路回復
  for (char i = 0; i <= ReedS_number; i++) {
    ReedS[i] = digitalRead(ReedS0_pin + i);
    oReedS[i] = ReedS[i];
  }
}
//===========================================================================================
void setup(void)
{
  // start serial port
  Serial.begin(9600);
  while (!Serial) {
    ; // wait for serial port to connect. Needed for Leonardo only
  }
  Serial.println(star_information);
  Serial.println("wait DHCP:FAIL input s to skip DHCP");
  Serial.println("test send to input r send Reed Switch, m send human, n send notification");
  pinMode(4, OUTPUT);
  digitalWrite(4,HIGH);
  pinMode(ReedS0_pin, INPUT);
  pinMode(ReedS1_pin, INPUT);
  //pinMode(ReedS2_pin, INPUT);
  pinMode(ReedS3_pin, INPUT);
  pinMode(ReedS4_pin, INPUT);
  pinMode(ReedS5_pin, INPUT);
  pinMode(man0_pin, INPUT);
  pinMode(man1_pin, INPUT);

  net_init();
  //delay(3000);
  /* dht.begin();
    Serial.println("DHTxx OK!");*/
  startime = millis();
  first_run();
}

void loop(void)
{
  dotime();
  
  //讀ReedS
  for (char i = 0; i <= ReedS_number; i++) {
    ReedS[i] = digitalRead(ReedS0_pin + i);
  }
  //讀man
  //man[0]=digitalRead(man0_pin);
  if (digitalRead(man0_pin) == 1) {
  man[0] += 1;
  }
  if (digitalRead(man1_pin) == 1) {
  man[1] += 1;
  }
  if (digitalRead(man2_pin) == 1) {
  man[2] += 1;
  }
  if (digitalRead(man3_pin) == 1) {
  man[3] += 1;
  }
  if (digitalRead(man4_pin) == 1) {
  man[4] += 1;
  }
  if (digitalRead(man5_pin) == 1) {
  man[5] += 1;
  }

  Serial.print("ReedS: ");
  for (char i = 0; i <= ReedS_number; i++) {
  Serial.print((int)ReedS[i]);
    Serial.print(" ");
  }
  Serial.print("man: ");
  for (char i = 0; i <= man_number; i++) {
  Serial.print(man[i]);
    Serial.print(" ");
  }
  Serial.println();

  //手動push
  if (Serial.available() > 0) {
    char in=Serial.read();
    if(in=='r'){
      getdata(&URL_data, push_RS_ID, push_RS_ID);
      connect_pushdata(&URL_data, &strHost);
      netword_request();//網路回復
    }else if(in=='m'){
      getdata(&URL_data, push_human_ID, push_human_ID);
      connect_pushdata(&URL_data, &strHost);
      netword_request();//網路回復
    }else if(in=='n'){
      getdata(&URL_data, pushnotif_ID, pushnotif_ID);
      connect_pushdata(&URL_data, &strHost);
      netword_request();//網路回復
    }else{
      //in=Serial.read();
    }
  }
  //如果ReedS通知
  if (ReedS[0] != oReedS[0]) {
    getdata(&URL_data, pushnotif_ID, pushnotif_ID);
    if(!connect_pushdata(&URL_data, &strHost)){
      connect_pushdata(&URL_data, &strHost);
    }
    netword_request();//網路回復
  }
  //如果ReedS有變化 push data
  if ((ReedS[0] != oReedS[0]) || (ReedS[1] != oReedS[1]) || (ReedS[2] != oReedS[2]) || (ReedS[3] != oReedS[3]) || (ReedS[4] != oReedS[4]) || (ReedS[5] != oReedS[5])) {
    getdata(&URL_data, push_RS_ID, push_RS_ID);
    connect_pushdata(&URL_data, &strHost);
    netword_request();//網路回復
    for (char i = 0; i <= ReedS_number; i++) {
      oReedS[i] = ReedS[i];
    }
  }
  //每15分鐘push man
  if (minute == 0 || minute == 15 || minute == 30 || minute == 45) {
  if (!push_man_check) {
      getdata(&URL_data, push_human_ID, push_human_ID);
      connect_pushdata(&URL_data, &strHost);
      netword_request();//網路回復
      for (char i = 0; i <= man_number; i++) {
        man[i] = 0;
      }
      push_man_check = true;
    }
  }
  //清除每15分鐘已通知標籤
  if ((minute > 1 && minute < 14) || (minute > 16 && minute < 29) || (minute > 31 && minute < 44) || (minute > 46 && minute < 59)) {
    push_man_check = false;
  }

  //netword_request();//網路回復
  delay(2000);
}
跟pushingbox連線的ID分別有這些
#define star_information "test Model"
#define push_RS_ID  "vxxxxxxxxxxxxxxx"
#define push_human_ID  "vyyyyyyyyyyyyyyy"
#define pushnotif_ID  "vzzzzzzzzzzzzzzz"
#define gettime_ID  "vaaaaaaaaaaaaaaa" //m
//#define gettime_ID  "vbbbbbbbbbbbbbbb"
#define board "1"






留言

張貼留言

這個網誌中的熱門文章

C# 模擬鍵盤滑鼠控制電腦

-
滑鼠模擬 指定一個螢幕像素的座標位置 int x = 1255; int y = 161; Cursor.Position = new Point(x, y); ClassMouse.LeftClick(); //按下滑鼠左鍵 鍵盤模擬 官方文件 的範例是用小算盤程式，計算111*11= public class demo { [DllImport("USER32.DLL", CharSet = CharSet.Unicode)] public static extern IntPtr FindWindow(string lpClassName, string lpWindowName); // Activate an application window. [DllImport("USER32.DLL")] public static extern bool SetForegroundWindow(IntPtr hWnd); // Send a series of key presses to the Calculator application. public static void Calculator() { // Get a handle to the Calculator application. The window class // and window name were obtained using the Spy++ tool. IntPtr calculatorHandle = FindWindow("ApplicationFrameWindow", "小算盤"); // Verify that Calculator is a running process. if (calculatorHandle == IntPtr.Zero) { MessageBox.Show("Calculator is not running....
閱讀完整內容

python pyautogui 簡介

-
pyautogui 是 python的一個模組，他能控制鍵盤和滑鼠的操作，能利用它做自動化操作，像是用在軟體測試、重複性動作等。 pyautogui 暫停幾秒鐘 >>>pyautogui.PAUSE = 1.5 fail-safe (預設false) 當滑鼠一道螢幕左上角時，觸發 pyautogui 的failsafeexception 異常 >>>pyautogui.FAILSAFE = True 螢幕上的座標軸 (0,0) →→→→(1920,0)    ↓    ↓    ↓    ↓ (0,1080) 取得螢幕解析度 >>>import pyautogui >>>pyautogui.size() (1920, 1080) >>>width, height = pyautogui.size() 滑鼠部分 moveTo(width, height, duration) example移動到(300, 400)位置 pyautogui.moveTo(300, 400)                 #立即到 pyautogui.moveTo(300, 400, duration = 1.5) #花1.5秒移到 moeRel(width, height, duration) 移到相對座標，以當前滑鼠座標為基準點 pyautogui.moveRel(0, 100, duration=0.25) pyautogui.moveRel(-100, 0, duration=0.25) position() 獲得滑鼠當前的座標位置 >>>pyautogui.position() (300, 400) click(width, height, button) 滑鼠點擊 button = 'left', 'middle', 'right'。 pyautogui.click()       ...
閱讀完整內容

android 定時通知(永久長期的) 本篇只講AlarmManager使用

-
本篇使用AlarmManager達到準時執行某程式，跟鬧鐘的方式一樣，我之前用過IntentService、Service、Handler，都不能長期使用。 Servicer簡單缺點整理： IntentService：只要關閉activity背景保存視窗，IntentService背景所執行的程式就被強迫結束，好像可以重開(我沒試過)。 Service、Handler：雖然關閉activity會繼續執行，但他是重新在開啟一次service，這到還好，但當手機螢幕關閉處於待機狀態時，service會停止運作暫停在那邊，等你喚醒再繼續執行，所以用這個加timer做定時通知會整個亂掉，timer會停下來不數了。 AlarmManager主要架構是 跟系統註冊鬧鐘甚麼時間點 → 時間到系統會發送一個鬧鈴 → 你的activity接收那個鬧鈴後執行你的程式 當你註冊好幾個鬧鐘已經晚於現在時間，他會馬上通通都執行完 先建立接收鬧鈴的程式 在Manifest.xml 中加入接收系統鬧鈴 <application> <activity android:name=".MainActivity"> </activity> <!-- 當鬧鈴時間到達時要執行的程式 --> <receiver android:name=".AlarmReceiver"> <intent-filter> <action android:name="activity_app" /> </intent-filter> </receiver> </application> 建立一個class檔，執行接收到鬧鈴後的程式 public class AlarmReceiver extends BroadcastReceiver { @Override public void onReceive(Context context, Intent intent) { ...
閱讀完整內容

raspberrypi 開機自動執行程式 與 在terminal開啟第二個terminal執行python

-
raspberrypi 開啟另一個terminal執行程式 在terminal輸入： lxterminal -e python3 demo.py 參考自： https://www.raspberrypi.org/forums/viewtopic.php?t=65607 ------------------------------------------------------------------------------------------------------------------------------------------------------- raspberrypi 開機自動執行程式 在terminal中輸入以下指令，開啟檔案： sudo nano /etc/rc.local 以下是加入執行python程式 #!/bin/sh -e # # rc.local # # This script is executed at the end of each multiuser runlevel. # Make sure that the script will "exit 0" on success or any other # value on error. # # In order to enable or disable this script just change the execution # bits. # # By default this script does nothing. # Print the IP address _IP=$(hostname -I) || true if [ "$_IP" ]; then    printf "My IP address is %s\n" "$_IP" fi sudo python /home/pi/demo.py  <==加入在這邊 exit 0 參考自： http://dirtypig8.blogspot.tw/2016/12/python.html#!/tcmbck
閱讀完整內容

python nn 聲音辨識 -1 傅立葉轉換

-
辨識環境聲音判斷出這是甚麼聲音 主要想法是用頻域赫茲分布做判斷 首先先錄三種聲音的聲音檔，我每一種聲音重複錄製九個sample，所以有27個wav檔 讀取wav檔案，作正規劃處理，在做傅立葉轉換 一開始由於自己做的fft_domyself() function跟其他聲音處理軟體做出來的不一樣，數值非常小，之後找到有內建的spectrogram() function，使用也是數值很小，最後才想到要20log()，但由於內建的覺得不適合自由調整，所以還是修改自己的function。 import matplotlib.pyplot as plt from scipy.fftpack import fft from scipy.io import wavfile # get the api import numpy as np from scipy import signal import math import pyaudio import wave import time #buf=[] #讀入單一檔案測試 def init(): fs, data = wavfile.read('0106.wav') # load the data b=[(ele/2**16.) for ele in data] # this is 16-bit track, b is now normalized on [-1,1) c = fft(b) # calculate fourier transform (complex numbers list) d = len(c)/2 # you only need half of the fft list (real signal symmetry) plt.subplot(211) plt.plot(b,'b') plt.title('time line') plt.subplot(212) plt.plot(abs(c[:(d-1)]),'r') plt.title('fft') plt.show() return fs, b #取樣率 dat...
閱讀完整內容