空間活動偵測 -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 + 乙太網路擴充板 + 自己做的電路板
連接的感測器：
  • 人體紅外線感測器
  • 門窗的磁簧開關



  1. #include <Dhcp.h>
  2. #include <Dns.h>
  3. #include <Ethernet.h>
  4. #include <EthernetClient.h>
  5. #include <EthernetServer.h>
  6. #include <EthernetUdp.h>
  7. //#include "net_function.cpp"
  8. #include "set_ID.h"
  9. #define PushingBox
  10.  
  11. unsigned char hour = 0, minute = 0;
  12. boolean push_man_check;
  13. String URL_data;
  14. #define ReedS0_pin 2
  15. #define ReedS1_pin 3
  16. #define ReedS2_pin 4
  17. #define ReedS3_pin 5
  18. #define ReedS4_pin 6
  19. #define ReedS5_pin 7
  20. #define man0_pin 8
  21. #define man1_pin 9
  22. #define man2_pin A5
  23. #define man3_pin A4
  24. #define man4_pin A3
  25. #define man5_pin A2
  26. #define ReedS_number 5  //6個(0~5)
  27. #define man_number 5    //6個(0~1)
  28.  
  29. #if defined( PushingBox )
  30. //byte mac[] = {  0x00, 0xAB, 0xBC, 0xCD, 0xDE, 0x00 };
  31. char server[] = "api.pushingbox.com";
  32. String strGet = "GET /pushingbox?devid=";
  33. String strHttp = " HTTP/1.1";
  34. String strHost = "Host: api.pushingbox.com"; //OK
  35. int serverPort = 80;
  36.  
  37. char ReedS[] = { 0, 0, 0, 0, 0, 0};//ReedS = Reed Switch 磁簧開關
  38. char oReedS[] = { 0, 0, 0, 0, 0, 0};//oReedS 過去的狀態, ReedS 現在的狀態
  39. int man[] = { 0, 0, 0, 0, 0, 0};
  40.  
  41. #endif
  42.  
  43. EthernetClient client;
  44. boolean conn; // Connected
  45. //DeviceAddress insideThermometer;
  46. unsigned long startime = 0;
  47. //------------------------------------------------------------------------------------------
  48. //串接URL
  49. void getdata(String *data, String ID, String kind) {
  50.   *data = strGet;
  51.   *data += ID;
  52.   *data += "&board=";
  53.   *data += board;
  54.  
  55.   if (kind == gettime_ID) {
  56.     *data += "&information=";
  57.     *data += "時間";
  58.  
  59.   }
  60.   if (kind == push_RS_ID || kind == push_human_ID || kind == pushnotif_ID) {
  61.     *data += "&time=";
  62.     *data += (int)hour;
  63.     *data += ':';
  64.     if(minute<=9){
  65.       *data += "0";
  66.     }
  67.     *data += (int)minute;
  68.   }
  69.  
  70.   if (kind == push_RS_ID) {
  71.     *data += "&RS0=";
  72.     *data += (int)ReedS[0];
  73.     *data += "&RS1=";
  74.     *data += (int)ReedS[1];
  75.     *data += "&RS2=";
  76.     *data += (int)ReedS[2];
  77.     *data += "&RS3=";
  78.     *data += (int)ReedS[3];
  79.     *data += "&RS4=";
  80.     *data += (int)ReedS[4];
  81.     *data += "&RS5=";
  82.     *data += (int)ReedS[5];
  83.   }
  84.   if (kind == push_human_ID) {
  85.     *data += "&man0=";
  86.     *data += man[0];
  87.     *data += "&man1=";
  88.     *data += man[1];
  89.     *data += "&man2=";
  90.     *data += man[2];
  91.     *data += "&man3=";
  92.     *data += man[3];
  93.     *data += "&man4=";
  94.     *data += man[4];
  95.     *data += "&man5=";
  96.     *data += man[5];
  97.   }
  98.   if (kind == pushnotif_ID) {
  99.     *data += "&title=";
  100.     *data += "活動情況";
  101.     *data += "&message=";
  102.     if (ReedS[0] == 1) {
  103.       *data += "門_開啟";
  104.     } 
  105.     else {
  106.       *data += "門_關閉";
  107.     }
  108.   }
  109.  
  110.   *data += strHttp;
  111.   Serial.print("URL: ");
  112.   Serial.println(*data);
  113. }
  114. //push URL data to 網路
  115. bool connect_pushdata(String *push_URL, String *host) {
  116.   Serial.println("connect server --->");
  117.   if (client.connect(server, serverPort)) {
  118.     Serial.println("Make a HTTP request ... ");
  119.     conn = true;
  120.     client.println(*push_URL);
  121.     client.println(*host);
  122.     client.println( "Connection: close" );
  123.     client.println();
  124.     return true;
  125.   }
  126.   else {
  127.     Serial.println("Can not connect server ---X---");
  128.     return false;
  129.   }
  130. }
  131.  
  132.  
  133. //網路回復
  134. void netword_request() {
  135.   int ln = 0;
  136.   int count = 0;
  137.   char date_str[40]=" ";
  138.   while (conn) {
  139.     if (client.available()) {
  140.       char c = client.read(); // Save http header to c
  141.       Serial.print(c); // Print http header to serial monitor
  142.       if (c == '\n') {
  143.         ln++;
  144.         // Serial.print("ln count: ");
  145.         // Serial.println(ln);
  146.       }
  147.       if (ln == 2) {
  148.         date_str[count++] = c;
  149.       }
  150.     }
  151.     if (!client.connected()) {
  152.       Serial.println("disconnecting...");
  153.       client.stop();
  154.       URL_data = "";
  155.       conn = false;
  156.       ln = 0;
  157.       count = 0;
  158.       Serial.print("seriver date: ");
  159.       for (char i = 1; i < 40; i++) {
  160.         Serial.print(date_str[i]);
  161.       }
  162.       Serial.print("\n");
  163.       if(((date_str[24] - '0') * 10 + (date_str[25] - '0')) >= 0 && ((date_str[24] - '0') * 10 + (date_str[25] - '0')) <= 23 &&
  164.       ((date_str[27] - '0') * 10 + (date_str[28] - '0')) >= 0 && ((date_str[27] - '0') * 10 + (date_str[28] - '0')) <= 59)
  165.       {
  166.         hour = (date_str[24] - '0') * 10 + (date_str[25] - '0') + 8;
  167.         if (hour >= 24) {
  168.           hour -= 24;
  169.         }
  170.         minute = (date_str[27] - '0') * 10 + (date_str[28] - '0');
  171.       }
  172.       Serial.print("time ");
  173.       Serial.print((int)hour);
  174.       Serial.print(":");
  175.       Serial.println((int)minute);
  176.     }
  177.   }
  178. }
  179. //網路設定
  180. void net_init() {
  181.   char in = "";
  182.   byte mac[] = {  0x00, 0xAB, 0xBC, 0xCD, 0xDE, 0x00 };
  183.   //Init Net
  184.   Serial.print("DHCP: ");
  185.   //Ethernet.begin(mac, ip, mydns);
  186.   if (Ethernet.begin(mac) == 0) {
  187.     
  188.     Serial.println("FAIL");
  189.     while (Ethernet.begin(mac) == 0){
  190.       if (Serial.available() > 0) {
  191.         in=Serial.read();
  192.         if(in == 's'){
  193.           Serial.println("skip DHCP");
  194.           break;
  195.         }
  196.       }
  197.     }
  198.     Serial.print("DHCP: ");
  199.   }
  200.   if(in != 's'){
  201.     Serial.println("OK");
  202.     Serial.print("Local IP : ");
  203.     Serial.println(Ethernet.localIP());
  204.   }
  205. }
  206. void dotime() {
  207.   //add one minute 60000=60*1000ms=1m
  208.   if ((millis() - startime) >= (60000) || (millis() - startime) < 0) {
  209.     startime = millis();
  210.     minute++;
  211.     if (minute >= 60) {
  212.       minute -= 60;
  213.       hour++;
  214.       if (hour >= 24) {
  215.         hour -= 24;
  216.       }
  217.     }
  218.   }
  219. }
  220. //需要先跑第一次的程式
  221. void first_run() {
  222.   getdata(&URL_data, gettime_ID, gettime_ID);
  223.   while(!connect_pushdata(&URL_data, &strHost));
  224.   netword_request();//網路回復
  225.   for (char i = 0; i <= ReedS_number; i++) {
  226.     ReedS[i] = digitalRead(ReedS0_pin + i);
  227.     oReedS[i] = ReedS[i];
  228.   }
  229. }
  230. //===========================================================================================
  231. void setup(void)
  232. {
  233.   // start serial port
  234.   Serial.begin(9600);
  235.   while (!Serial) {
  236.     ; // wait for serial port to connect. Needed for Leonardo only
  237.   }
  238.   Serial.println(star_information);
  239.   Serial.println("wait DHCP:FAIL input s to skip DHCP");
  240.   Serial.println("test send to input r send Reed Switch, m send human, n send notification");
  241.   pinMode(4, OUTPUT);
  242.   digitalWrite(4,HIGH);
  243.   pinMode(ReedS0_pin, INPUT);
  244.   pinMode(ReedS1_pin, INPUT);
  245.   //pinMode(ReedS2_pin, INPUT);
  246.   pinMode(ReedS3_pin, INPUT);
  247.   pinMode(ReedS4_pin, INPUT);
  248.   pinMode(ReedS5_pin, INPUT);
  249.   pinMode(man0_pin, INPUT);
  250.   pinMode(man1_pin, INPUT);
  251.  
  252.   net_init();
  253.   //delay(3000);
  254.   /* dht.begin();
  255.     Serial.println("DHTxx OK!");*/
  256.   startime = millis();
  257.   first_run();
  258. }
  259.  
  260. void loop(void)
  261. {
  262.   dotime();
  263.   
  264.   //讀ReedS
  265.   for (char i = 0; i <= ReedS_number; i++) {
  266.     ReedS[i] = digitalRead(ReedS0_pin + i);
  267.   }
  268.   //讀man
  269.   //man[0]=digitalRead(man0_pin);
  270.   if (digitalRead(man0_pin) == 1) {
  271.   man[0] += 1;
  272.   }
  273.   if (digitalRead(man1_pin) == 1) {
  274.   man[1] += 1;
  275.   }
  276.   if (digitalRead(man2_pin) == 1) {
  277.   man[2] += 1;
  278.   }
  279.   if (digitalRead(man3_pin) == 1) {
  280.   man[3] += 1;
  281.   }
  282.   if (digitalRead(man4_pin) == 1) {
  283.   man[4] += 1;
  284.   }
  285.   if (digitalRead(man5_pin) == 1) {
  286.   man[5] += 1;
  287.   }
  288.  
  289.   Serial.print("ReedS: ");
  290.   for (char i = 0; i <= ReedS_number; i++) {
  291.   Serial.print((int)ReedS[i]);
  292.     Serial.print(" ");
  293.   }
  294.   Serial.print("man: ");
  295.   for (char i = 0; i <= man_number; i++) {
  296.   Serial.print(man[i]);
  297.     Serial.print(" ");
  298.   }
  299.   Serial.println();
  300.  
  301.   //手動push
  302.   if (Serial.available() > 0) {
  303.     char in=Serial.read();
  304.     if(in=='r'){
  305.       getdata(&URL_data, push_RS_ID, push_RS_ID);
  306.       connect_pushdata(&URL_data, &strHost);
  307.       netword_request();//網路回復
  308.     }else if(in=='m'){
  309.       getdata(&URL_data, push_human_ID, push_human_ID);
  310.       connect_pushdata(&URL_data, &strHost);
  311.       netword_request();//網路回復
  312.     }else if(in=='n'){
  313.       getdata(&URL_data, pushnotif_ID, pushnotif_ID);
  314.       connect_pushdata(&URL_data, &strHost);
  315.       netword_request();//網路回復
  316.     }else{
  317.       //in=Serial.read();
  318.     }
  319.   }
  320.   //如果ReedS通知
  321.   if (ReedS[0] != oReedS[0]) {
  322.     getdata(&URL_data, pushnotif_ID, pushnotif_ID);
  323.     if(!connect_pushdata(&URL_data, &strHost)){
  324.       connect_pushdata(&URL_data, &strHost);
  325.     }
  326.     netword_request();//網路回復
  327.   }
  328.   //如果ReedS有變化 push data
  329.   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])) {
  330.     getdata(&URL_data, push_RS_ID, push_RS_ID);
  331.     connect_pushdata(&URL_data, &strHost);
  332.     netword_request();//網路回復
  333.     for (char i = 0; i <= ReedS_number; i++) {
  334.       oReedS[i] = ReedS[i];
  335.     }
  336.   }
  337.   //每15分鐘push man
  338.   if (minute == 0 || minute == 15 || minute == 30 || minute == 45) {
  339.   if (!push_man_check) {
  340.       getdata(&URL_data, push_human_ID, push_human_ID);
  341.       connect_pushdata(&URL_data, &strHost);
  342.       netword_request();//網路回復
  343.       for (char i = 0; i <= man_number; i++) {
  344.         man[i] = 0;
  345.       }
  346.       push_man_check = true;
  347.     }
  348.   }
  349.   //清除每15分鐘已通知標籤
  350.   if ((minute > 1 && minute < 14) || (minute > 16 && minute < 29) || (minute > 31 && minute < 44) || (minute > 46 && minute < 59)) {
  351.     push_man_check = false;
  352.   }
  353.  
  354.   //netword_request();//網路回復
  355.   delay(2000);
  356. }
跟pushingbox連線的ID分別有這些
  1. #define star_information "test Model"
  2. #define push_RS_ID  "vxxxxxxxxxxxxxxx"
  3. #define push_human_ID  "vyyyyyyyyyyyyyyy"
  4. #define pushnotif_ID  "vzzzzzzzzzzzzzzz"
  5. #define gettime_ID  "vaaaaaaaaaaaaaaa" //m
  6. //#define gettime_ID  "vbbbbbbbbbbbbbbb"
  7. #define board "1"






留言

張貼留言

這個網誌中的熱門文章

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...
閱讀完整內容

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) { ...
閱讀完整內容

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....
閱讀完整內容

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 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()       ...
閱讀完整內容