空間活動偵測 -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 爬蟲程式 -1

-
做一個抓取 104人力銀行 新鮮人找工作版 所有工作及公司資料的程式 首先要抓搜尋結果頁面的資訊 import requests from bs4 import BeautifulSoup as bs search_url = "https://www.104.com.tw/area/freshman/search?keyword=%E6%A9%9F%E5%99%A8%E4%BA%BA&area=6001001000,6001002000&jobcategory=2007000000&industry=&page=1&sortField=APPEAR_DATE&sortMode=DESC" head = {'User-Agent':'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/60.0.3112.90 Safari/537.36', 'Accept-Language':'zh-TW,zh;q=0.8,en-US;q=0.6,en;q=0.4'} res = requests.get(search_url, headers = head) print(res.encoding) res.encoding = 'utf8' soup = bs(res.text) Out[1]:ISO-8859-1 用request傳回網頁內容 res.encoding可得知網頁編碼方式，一開始我根據網站上寫utf-8編碼，跟python設定編碼一致，想說沒問題，之後才找到如何知道是用甚麼編碼的方法，print出來才知道被python判斷成ISO-8859-1，那就自行設定成utf-8 BeautifulSoup 是一個能解構及分析的一套很好用的工具，將res轉成文字"res.text"，丟給 BeautifulSoup 抓取一個工作資料 用select擷取出我們要的資訊在哪個區域 job_box = soup.select(...
閱讀完整內容

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

訂午餐/訂飲料/團購訂單 使用excel製作 - 4 統計項目唯一值/去除重複值 使用office365 新UNIQUE函數

-
新的 office 365 在 excel 回傳多個數值推出了一個新功能"溢出"，意思是如果公式得出多個數值，無法在一個儲存格內全部顯示，他會溢出到鄰近的空白儲存格內，但是當周遭都沒有空白儲存格時會顯示"溢出"，所以要注意溢出的地方要有空白儲存格讓他溢出。 一、公式介紹 主要是用以下兩個公式： UNIQUE (array，[by_col]，[exactly_once]) FILTER(array,include,[if_empty]) 1.UNIQUE (array，[by_col]，[exactly_once]) 描述：傳回清單或範圍中的唯一值清單。 array - 尋找唯一值的範圍 [by_col] - TRUE：欄彼此比較 FALSE：(可省略)列彼此比較 [exactly_once] - TRUE：剛好發生一次之列或欄 FALSE：(可省略)返回所有不同的列或欄 2.FILTER(array,include,[if_empty]) 描述：根據自定義的準則來篩選資料範圍。 array - 要篩選的陣列或範圍 include - 布林陣列的高度或寬度必須與該陣列相同 [if_empty] - 若所包含陣列中的全部值均為空時要傳回的值 二、取得項目的唯一值(使用office365) 使用 FILTER 函數是因為當取唯一值範圍裡有空白儲存格時，空白儲存格會被當作一個唯一值看待，但我的資料有時量多有時量少資料長度不固定，公式每次都調整資料範圍非常麻煩所以要將空白儲存格捨去。 1.有空白儲存格的情況 A12、A13為空白儲存格，取唯一值後空白儲存格會當作0。 =UNIQUE(A2:A13) 2.解決方法 不等於的寫法： <> 空白值 ""  公式一：先移除空白再取唯一值 =UNIQUE(FILTER(A2:A13, A2:A13<>"")) 黃色為公式拆解步驟結果 拆解步驟公式 ...
閱讀完整內容

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