用安信可WiFi+藍牙模組Ai-WB2-32S-Kit實現安防檢測
以下作品由安信可社區用戶
ch999制作
前言：
筆者這次決定使用AI-WB2-32s-Kit＋雷達模塊制+藍牙信標作安防檢測，靈感來源是想著馬上畢業要外出租房，擔心陌生人進入房間。
制作這個項目，目的是實現當有人進入房間時起到提示作用。但如果僅用雷達檢查，每次自己回家都也會觸發報告，那樣就太煩了，所以決定通過藍牙信標來過濾指定目標。
01
材料
●Ai-WB2-32S-Kit
●雷達模塊（自帶uart串口，通過串口輸出數據）
●藍牙模塊
●服務器，用來做中轉發送消息
雷達部分的代碼
#include
#include
#include
#include
#include
#include "bl_sys.h"
#include
#include
#include
#include
#include "bl_uart.h"
#define TAG "uart_demo"
#define GPIO_LED_PIN 3
hosal_uart_dev_t uart_dev_log = {
.config = {
.uart_id = 0,
.tx_pin = 16, // TXD GPIO
.rx_pin = 7, // RXD GPIO
.cts_pin = 255,
.rts_pin = 255,
.baud_rate = 115200,
.data_width = HOSAL_DATA_WIDTH_8BIT,
.parity = HOSAL_NO_PARITY,
.stop_bits = HOSAL_STOP_BITS_1,
.mode = HOSAL_UART_MODE_POLL,
},
};
//UART radar
void uart_radar_data(void *param)
{
char data[64];
int ret;
while (1)
{
/* UART receive poll */
ret = hosal_uart_receive(&uart_dev_log, data, sizeof(data)-1);
if (ret > 0)
{
bl_gpio_output_set(GPIO_LED_PIN, 1);//set led
}
else{
bl_gpio_output_set(GPIO_LED_PIN, 0);//set led
}
/* sscanf 是 C 語言標準庫中的一個函數，
* 用于從字符串中按照指定的格式讀取數據，
* 并將數據存儲到指定的變量中123。
* 它的原型定義在 頭文件中
*/
//雷達串口輸出數據的格式: v=-0.6 km/h, str=208
float velocity;
int str_value;
if (2 == sscanf(data, "v=%f km/h, str=%d", &velocity, &str_value)) {
printf("Parsed: v=%.1f, str=%drn", velocity, str_value);
}
vTaskDelay(200);
}
}
void main(void)
{
/* UART InIt device */
hosal_uart_init(&uart_dev_log);
/*LED*/
bl_gpio_enable_output(GPIO_LED_PIN, 0, 0);
xTaskCreate(uart_radar_data, "radar", 1024, NULL, 15, NULL);
}
第一階段先通過這個小項目，測試了點燈和串口，以及結合外設實現安防功能。
接下來要做的：藍牙信標（該部分以完成）
開發板以主機模式掃描設備，雷達發現有人進屋且掃描到指定MAC設備，表示是自己回家，否則就是陌生人闖入。
藍牙部分代碼
在bl_interface.c庫文件里添加如下代碼實現mac比對和rssi。
//
int ble_master_get_rssi_by_mac(uint8_t *target_mac){
if(target_mac==NULL)return -127;
int ret=0;
int rssi=0;
int retry=3;
struct bt_le_scan_param scan_param;
char scan_data[250];
scan_param.type = BT_LE_SCAN_TYPE_ACTIVE;
scan_param.filter_dup = BT_LE_SCAN_FILTER_DUPLICATE;
scan_param.interval = 320;
scan_param.window = 48;
master_current_scan = 0;
memset(scan_le_addr, 0, sizeof(scan_le_addr));
memset(master_scan_tbl, 0, sizeof(master_scan_tbl));
//scan
ret = bt_le_scan_start(&scan_param, scan_device_found);
if(ret!=0){rssi=-127;}
vTaskDelay(800 / portTICK_PERIOD_MS);//持續掃描的時間
for (int i = 0; i < master_current_scan; i++) {
ble_reverse_byte(master_scan_tbl[i].mac, 6);
if(memcmp(target_mac,master_scan_tbl[i].mac, 6)==0){
sprintf(scan_data,"My BLE MAC:%02X%02X%02X%02X%02X%02X RSSI:%i name:%srn",
master_scan_tbl[i].mac[0],master_scan_tbl[i].mac[1],master_scan_tbl[i].mac[2],
master_scan_tbl[i].mac[3],master_scan_tbl[i].mac[4],master_scan_tbl[i].mac[5],
master_scan_tbl[i].rssi, master_scan_tbl[i].name);
bleuart_printf(scan_data);
rssi=master_scan_tbl[i].rssi;
break;
}
else{
//bleuart_printf("Not Found MAC Devicern");
rssi= -127;
}
}
return rssi;
}
再部署完服務器后，進行一下簡單測試。
完成雷達掃描和藍牙信標后，現在來完成信息發送功能，參照安信可社區這位大佬的做法 ：用AI-WB2消息推送到個人通知https://bbs.ai-thinker.com/forum.php?mod=viewthread&tid=45846&highlight=wb2&_dsign=04722896
可以看到手機可以正常接收消息。
接下來是開發板代碼,notify部分的代碼參考原文鏈接，記得添加必要的network庫到MAKEFILE以及修改pro_config.mk
notify.h
#ifndef __NOTIFY_H__
#define __NOTIFY_H__
#define WEB_SERVER "192.168.43.218" //這里改成你搭建的gotify服務器地址
#define WEB_PORT "8000" //默認地址是80 我改為了8000,dokcer部署時選到什么端口這里填什么端口，最好避開80，怕運營商屏蔽
#define WEB_PATH_BASE "/message"
#define QUERY_STRING "?token=AQSv2fQhrE.8_Fq" //token替換為你的通道token，token加到token=Axxxxxx后面
void notify_task(void *pvParameters);
#endif
notify.c
這里的Wi-Fi是從sdk里的Wi-Fi demo修改過來的。
#include "notify.h"
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#define BOUNDARY "---"
static char REQUEST[512];
typedef struct {
const char *title;
const char *message;
const char *priority;
} Message;
void notify_task(void *pvParameters) {
Message *params = (Message *)pvParameters; // 接收參數
//
//
//
printf("title=%s rnmessage=%srnpriority=%srn", params->title,
params->message, params->priority);
//
const struct addrinfo hints = {
.ai_family = AF_INET,
.ai_socktype = SOCK_STREAM,
};
struct addrinfo *res;
struct in_addr *addr;
int s, r;
char recv_buf[4096];
while (1) {
int err = getaddrinfo(WEB_SERVER, WEB_PORT, &hints, &res);
if (err != 0 || res == NULL) {
blog_error("DNS lookup failed err=%d res=%p", err, res);
vTaskDelay(1000 / portTICK_PERIOD_MS);
continue;
}
/* Code to print the resolved IP.
Note: inet_ntoa is non-reentrant, look at ipaddr_ntoa_r for "real" code
*/
addr = &((struct sockaddr_in *)res->ai_addr)->sin_addr;
blog_info("DNS lookup succeeded. IP=%s", inet_ntoa(*addr));
s = socket(res->ai_family, res->ai_socktype, 0);
if (s < 0) {
blog_error("... Failed to allocate socket.");
freeaddrinfo(res);
vTaskDelay(1000 / portTICK_PERIOD_MS);
continue;
}
blog_info("... allocated socket");
if (connect(s, res->ai_addr, res->ai_addrlen) != 0) {
blog_error("... socket connect failed errno=%d", errno);
close(s);
freeaddrinfo(res);
vTaskDelay(4000 / portTICK_PERIOD_MS);
continue;
}
blog_info("... connected");
freeaddrinfo(res);
// 構造請求體
char body[1024];
snprintf(body, sizeof(body),
"--%srn"
"Content-Disposition: form-data; name="title"rnrn"
"%srn"
"--%srn"
"Content-Disposition: form-data; name="message"rnrn"
"%srn"
"--%srn"
"Content-Disposition: form-data; name="priority"rnrn"
"%srn"
"--%s--rn",
BOUNDARY, params->title, BOUNDARY, params->message, BOUNDARY,
params->priority, BOUNDARY);
snprintf(REQUEST, sizeof(REQUEST),
"POST %s%s HTTP/1.0rn"
"Host: %s:%srn"
"User-Agent: aithinker wb2rn"
"Content-Type: multipart/form-data; boundary=%srn"
"Content-Length: %drn"
"rn"
"%s",
WEB_PATH_BASE, QUERY_STRING, WEB_SERVER, WEB_PORT, BOUNDARY,
strlen(body), body);
if (write(s, REQUEST, strlen(REQUEST)) < 0) {
blog_error("... socket send failed");
close(s);
vTaskDelay(4000 / portTICK_PERIOD_MS);
continue;
}
blog_info("... socket send success");
struct timeval receiving_timeout;
receiving_timeout.tv_sec = 5;
receiving_timeout.tv_usec = 0;
if (setsockopt(s, SOL_SOCKET, SO_RCVTIMEO, &receiving_timeout,
sizeof(receiving_timeout)) < 0) {
blog_error("... failed to set socket receiving timeout");
close(s);
vTaskDelay(4000 / portTICK_PERIOD_MS);
continue;
}
blog_info("... set socket receiving timeout success");
// FIXME fix putchar
extern int bl_putchar(int c);
/* Read HTTP response */
do {
bzero(recv_buf, sizeof(recv_buf));
r = read(s, recv_buf, sizeof(recv_buf) - 1);
for (int i = 0; i < r; i++) {
bl_putchar(recv_buf[i]);
}
} while (r > 0);
blog_info("... done reading from socket. Last read return=%d "
"errno=%drn",
r, errno);
close(s);
for (int countdown = 10; countdown >= 0; countdown--) {
blog_info("%d... ", countdown);
vTaskDelay(1000 / portTICK_PERIOD_MS);
}
blog_info("Starting again!");
}
}
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include "bluetooth.h"
#include "ble_interface.h"
#include
#include "notify.h"
#include
#include
#include
#include
#define ROUTER_SSID "Play4T"
#define ROUTER_PWD "qq123456"
typedef struct {
const char *title;
const char *message;
const char *priority;
} Message;
hosal_uart_dev_t ble_uart_dev = {
.config = {
.uart_id = 0,
.tx_pin = 16, // TXD GPIO
.rx_pin = 7, // RXD GPIO
.cts_pin = 255,
.rts_pin = 255,
.baud_rate = 115200,
.data_width = HOSAL_DATA_WIDTH_8BIT,
.parity = HOSAL_NO_PARITY,
.stop_bits = HOSAL_STOP_BITS_1,
.mode = HOSAL_UART_MODE_POLL,
},
};
static wifi_conf_t conf = {
.country_code = "CN",
};
//
bool is_Send=false;
uint32_t last_send_time=0;
int rssi;
// 構建消息內容結構體
static const char title[] = "tt";
static const char message[] = "12345";
static const char priority[] = "0";
static uint8_t target_mac[6] ={0xD1,0x10,0x91,0x29,0x8F,0xF5}; // 目標設備MAC地址，請改為實際MAC
static Message msg = {title, message, priority};
extern uint8_t axk_HalBleInit();
/**
* @brief wifi_sta_connect
* wifi station mode connect start
* @param ssid
* @param password
*/
static void wifi_sta_connect(char *ssid, char *password) {
wifi_interface_t wifi_interface;
wifi_interface = wifi_mgmr_sta_enable();
wifi_mgmr_sta_connect(wifi_interface, ssid, password, NULL, NULL, 0, 0);
}
// WiFi事件處理
static void event_cb_wifi_event(input_event_t *event, void *private_data) {
static char *ssid;
static char *password;
switch (event->code) {
case CODE_WIFI_ON_INIT_DONE: {
printf("[APP] [EVT] INIT DONE %lldrn", aos_now_ms());
wifi_mgmr_start_background(&conf);
} break;
case CODE_WIFI_ON_MGMR_DONE: {
printf("[APP] [EVT] MGMR DONE %lldrn", aos_now_ms());
//_connect_wifi();
wifi_sta_connect(ROUTER_SSID, ROUTER_PWD);
} break;
case CODE_WIFI_ON_SCAN_DONE: {
printf("[APP] [EVT] SCAN Done %lldrn", aos_now_ms());
// wifi_mgmr_cli_scanlist();
} break;
case CODE_WIFI_ON_DISCONNECT: {
printf("[APP] [EVT] disconnect %lldrn", aos_now_ms());
} break;
case CODE_WIFI_ON_CONNECTING: {
printf("[APP] [EVT] Connecting %lldrn", aos_now_ms());
} break;
case CODE_WIFI_CMD_RECONNECT: {
printf("[APP] [EVT] Reconnect %lldrn", aos_now_ms());
} break;
case CODE_WIFI_ON_CONNECTED: {
printf("[APP] [EVT] connected %lldrn", aos_now_ms());
} break;
case CODE_WIFI_ON_PRE_GOT_IP: {
printf("[APP] [EVT] connected %lldrn", aos_now_ms());
} break;
case CODE_WIFI_ON_GOT_IP: {
printf("[APP] [EVT] GOT IP %lldrn", aos_now_ms());
printf("[SYS] Memory left is %d Bytesrn", xPortGetFreeHeapSize());
} break;
case CODE_WIFI_ON_PROV_SSID: {
printf("[APP] [EVT] [PROV] [SSID] %lld: %srn", aos_now_ms(),
event->value ? (const char *)event->value : "UNKNOWN");
if (ssid) {
vPortFree(ssid);
ssid = NULL;
}
ssid = (char *)event->value;
} break;
case CODE_WIFI_ON_PROV_BSSID: {
printf("[APP] [EVT] [PROV] [BSSID] %lld: %srn", aos_now_ms(),
event->value ? (const char *)event->value : "UNKNOWN");
if (event->value) {
vPortFree((void *)event->value);
}
} break;
case CODE_WIFI_ON_PROV_PASSWD: {
printf("[APP] [EVT] [PROV] [PASSWD] %lld: %srn", aos_now_ms(),
event->value ? (const char *)event->value : "UNKNOWN");
if (password) {
vPortFree(password);
password = NULL;
}
password = (char *)event->value;
} break;
case CODE_WIFI_ON_PROV_CONNECT: {
printf("[APP] [EVT] [PROV] [CONNECT] %lldrn", aos_now_ms());
printf("connecting to %s:%s...rn", ssid, password);
wifi_sta_connect(ssid, password);
} break;
case CODE_WIFI_ON_PROV_DISCONNECT: {
printf("[APP] [EVT] [PROV] [DISCONNECT] %lldrn", aos_now_ms());
} break;
default: {
printf("[APP] [EVT] Unknown code %u, %lldrn", event->code, aos_now_ms());
/*nothing*/
}
}
}
//開啟藍牙掃描必須要聲明bleuart_printf這個函數，不知道為什么，這個函數在ble_interface.c中要用到
//注釋掉ble_interface.c會報錯，實再沒看懂，留著吧
void bleuart_printf(char *buf)
{
hosal_uart_send(&ble_uart_dev, buf, strlen(buf));
}
// UART InIt device
static void uart_init(void)
{
hosal_uart_init(&ble_uart_dev);
}
//UART radar
static void radar_detection(void *param)
{
char data[64];
while (1)
{
//接收到數據data
hosal_uart_receive(&ble_uart_dev, data, sizeof(data)-1);
/*data: v=-0.6 km/h, str=208
* sscanf 是 C 語言標準庫中的一個函數，
* 用于從字符串中按照指定的格式讀取數據，
* 并將數據存儲到指定的變量中123。
* 它的原型定義在 頭文件中
*/
//解析data
float velocity;
int str_value;
if (2 == sscanf(data, "v=%f km/h, str=%d", &velocity, &str_value)) {
//printf("radar data: v=%.1f, str=%drn", velocity, str_value);
}
if(str_value>1000 && rssi==-127){
xTaskCreate(?ify_task, "notify_task", 2048, &msg, 5, NULL);
printf("There are strangers entering the housern");
}
vTaskDelay(200);
}
}
//BLE
static void ble_loop_proc(void *pvParameters)
{
char data[250];
while (1)
{
rssi=ble_master_get_rssi_by_mac(target_mac); // 掃描指定MAC的藍牙設備
if(rssi>-80){
bl_gpio_output_set(3, 1);
}
else{
bl_gpio_output_set(3, 0);
}
hosal_uart_receive(&ble_uart_dev, data, sizeof(data));
vTaskDelay(100/portTICK_PERIOD_MS);
}
}
////發送消息
//static void send_message(void *param){
// while(1){
// if(is_BreakIn){
//printf("is_BreakIn");
// //uint32_t current_time=aos_now_ms();
// //if((current_time-last_send_time)>10){
// xTaskCreate(?ify_task, "notify_task", 1024, &msg, 5, NULL);
// //last_send_time=current_time;
// is_BreakIn=false;
// printf("There are strangers entering the housern");
// //}
//
// }
// }
//
//}
void main()
{
uart_init();
bl_sys_init(); // if use BLE ,must InIt
axk_HalBleInit();
//printf("BLE MASTER InItrn");
tcpip_init(NULL, NULL);
aos_register_event_filter(EV_WIFI, event_cb_wifi_event, NULL);
hal_wifi_start_firmware_task();
aos_post_event(EV_WIFI, CODE_WIFI_ON_INIT_DONE, 0);
bl_gpio_enable_output(3, 0, 0);//GPIO
xTaskCreate(ble_loop_proc, "ble master", 1024, NULL, 15, NULL);
xTaskCreate(radar_detection, "radar", 1024, NULL, 15, NULL);
// xTaskCreate(send_message, "send_message", 1024, NULL, 15, NULL);
}
雷達掃描到有人時，如果開發板同時掃描到指定MAC地址的藍牙，則表示自己回家，否則就發送消息到服務器，接下來只需要把服務器放公網上或者用內網穿透，即可實現公網通知了，當然用其他的消息通知也是一樣的，看個人喜好。
審核編輯 黃宇
-
藍牙
+關注
關注
116文章
6047瀏覽量
173378 -
檢測
+關注
關注
5文章
4618瀏覽量
92594 -
WIFI
+關注
關注
81文章
5382瀏覽量
207653
發布評論請先 登錄
BLE + Mesh ，安信可藍牙模組從可穿戴到智慧照明全覆蓋場景
安信可Ai-M62-CBS，極小尺寸的Wi-Fi/藍牙二合一模組
如何用安信可藍牙模塊遠程控制家中的設備？
用安信可Ai-WB2-01S做一個可用網頁控制的簡易燈
低價不貴！安信可WiFi+BLE模組Ai-WB2系列
用安信可AI人臉識別開發板BW21-CBV-Kit驅動墨水屏
安信可藍牙模組PB系列常見問題
安信可Ai-WB2系列的優勢是？一秒讀懂！
安信可，可安心！安信可科技亮相2024德國慕尼黑電子展會
用Ai-WB2開發板做智能家居全彩LED小夜燈
外設移植 安信可Ai-WB2+FPM383C指紋
外設移植 安信可Ai-WB2-32S開發板+TM1637 NTP時鐘
安信可Ai-WB2系列模組/開發板連接AWS亞馬遜云方法
工商網監
評論